package cn.com.goldenwater.dcproj.controller.pblm;

import cn.com.goldenwater.core.web.BaseController;
import cn.com.goldenwater.dcproj.dao.*;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.BisInspAllObjParam;
import cn.com.goldenwater.dcproj.param.BisInspPblmParam;
import cn.com.goldenwater.dcproj.param.BisInspRsvrRgstrParam;
import cn.com.goldenwater.dcproj.service.BisInspRsvrRgstrService;
import cn.com.goldenwater.id.util.UuidUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@Api(value = "APP 数据清洗", tags = "APP 数据清洗")
@RestController
@RequestMapping("/dc/wash")
public class WashPblmDataController extends BaseController {
    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private ObjInspPblmsRsvrDao objInspPblmsRsvrDao;
    @Autowired
    private ObjInspPblmsDao objInspPblmsDao;
    @Autowired
    private BisInspPblmDao inspPblmDao;

    @Autowired
    private BisInspAllObjDao inspAllObjDao;

    @Autowired
    private BisInspRsvrRgstrService inspRsvrRgstrService;

    @Autowired
    private AttRsBaseDao attRsBaseDao;

    @ApiOperation(value = "清洗历史标准")
    @RequestMapping(value = "/wash/{objType}",method = RequestMethod.GET)
    public Object wash(@PathVariable(required = true) String objType){
        BisInspPblmParam inspPblmParam=new BisInspPblmParam();
        inspPblmParam.setObjType(objType);
        List<BisInspPblm> bisInspPblmList=inspPblmDao.findList(inspPblmParam);
        if(bisInspPblmList==null){
            return buildFailResponse();
        }
        logger.info("总数：--》"+bisInspPblmList.size());
        for(int i=0;i<bisInspPblmList.size();i++){
            BisInspPblm bisInspPblm=bisInspPblmList.get(i);
            if(StringUtils.isNotBlank(bisInspPblm.getPblmsTypeId())) {
                ObjInspPblmsRsvr inspPblmsRsvr = objInspPblmsRsvrDao.get(bisInspPblm.getPblmsTypeId());
                if(inspPblmsRsvr!=null){
                    setPblms(bisInspPblm,inspPblmsRsvr);
                    logger.info("inspPblmsRsvr总数：--》"+inspPblmsRsvr.getInspPblmsName());
                }else {
                    ObjInspPblms objInspPblms = objInspPblmsDao.get(bisInspPblm.getPblmsTypeId());
                    if (objInspPblms != null) {
                        bisInspPblm.setPblmDescBz(objInspPblms.getPblmDesc());
                        bisInspPblm.setPblmNameBz(objInspPblms.getInspPblmsName());
                        bisInspPblm.setSnNumBz(objInspPblms.getSnNum());
                        bisInspPblm.setCheckPointBz(objInspPblms.getCheckPoint());
                        bisInspPblm.setFileNo(objInspPblms.getAttach());
                        bisInspPblm.setFileNoNumber(objInspPblms.getSnNum());
                        logger.info("objInspPblms总数：--》" + objInspPblms.getInspPblmsName());
                    }else {
                         inspPblmsRsvr = objInspPblmsRsvrDao.getOldBz(bisInspPblm.getPblmsTypeId());
                        if(inspPblmsRsvr!=null) {
                            setPblms(bisInspPblm, inspPblmsRsvr);
                        }
                    }
                }
                inspPblmDao.update(bisInspPblm);
            }

        }

        return buildSuccessResponse();
    }

    private BisInspPblm setPblms(BisInspPblm bisInspPblm,ObjInspPblmsRsvr inspPblmsRsvr){
        bisInspPblm.setPblmDescBz(inspPblmsRsvr.getPblmDesc());
        bisInspPblm.setPblmNameBz(inspPblmsRsvr.getInspPblmsName());
        bisInspPblm.setSnNumBz(inspPblmsRsvr.getSnNum());
        bisInspPblm.setCheckPointBz(inspPblmsRsvr.getCheckPoint());
        bisInspPblm.setFileNo(inspPblmsRsvr.getAttach());
        bisInspPblm.setFileNoNumber(inspPblmsRsvr.getSnNum());
        return bisInspPblm;
    }

    @ApiOperation(value = "批量添加督查对象")
    @RequestMapping(value = "/add/rsvr",method = RequestMethod.GET)
    public Object rsvr(){
        List<RsvrDto> rsvrDtoList=objInspPblmsRsvrDao.findRsvrDto();
        for(RsvrDto dto:rsvrDtoList) {
           List<AttRsBase> attRsBaseList=new ArrayList<>();
            AttRsBase attRsBaseSearch = attRsBaseDao.get(dto.getAdCode());
            logger.info(dto.getId()+":"+dto.getAdCode()+":adCode="+attRsBaseSearch.getRsCode());
            if(attRsBaseSearch==null){
                continue;
            }
            attRsBaseList.add(attRsBaseSearch);
            for(AttRsBase attRsBase:attRsBaseList){
                logger.info(dto.getId()+":"+dto.getAdCode()+":rscode="+attRsBase.getRsCode());
                String objId=UuidUtil.uuid();
                BisInspAllObj bisInspAllObj=new BisInspAllObj();
                bisInspAllObj.setId(dto.getId());
                bisInspAllObj.setProvince("350000000000");
                bisInspAllObj.setCode(attRsBase.getRsCode());
                bisInspAllObj.setObjId(objId);
                bisInspAllObj.setOrgId("034");
                bisInspAllObj.setNm(attRsBase.getRsName());
                bisInspAllObj.setAdCode("350000000000");
                bisInspAllObj.setPtype("1");
                if(StringUtils.isNotBlank(attRsBase.getCenterYGd())) {
                    bisInspAllObj.setLttd(Double.valueOf(attRsBase.getCenterYGd()));
                }
                if(StringUtils.isNotBlank(attRsBase.getCenterXGd())) {
                    bisInspAllObj.setLgtd(Double.valueOf(attRsBase.getCenterXGd()));
                }
                bisInspAllObj.setLgtdpc(attRsBase.getLongitude());
                bisInspAllObj.setLttdpc(attRsBase.getLatitude());

                BisInspAllObjParam allObjParam=new BisInspAllObjParam();
                allObjParam.setId(dto.getId());
                allObjParam.setCode(attRsBase.getRsCode());
                BisInspAllObj inspAllObj=inspAllObjDao.getBy(allObjParam);
                if(inspAllObj==null) {
                    logger.info("objname--->"+bisInspAllObj.getNm());

                    inspAllObjDao.insert(bisInspAllObj);
                    BisInspRsvrRgstr bisInspRsvrRgstr = new BisInspRsvrRgstr();
                    bisInspRsvrRgstr.setRgstrId(UuidUtil.uuid());
                    bisInspRsvrRgstr.setObjId(objId);
                    bisInspRsvrRgstr.setState("0");
                    bisInspRsvrRgstr.setReverStat("0");
                    bisInspRsvrRgstr.setBenefitStat("0");
                    bisInspRsvrRgstr.setViewStat("0");
                    bisInspRsvrRgstr.setPresStat("0");
                    bisInspRsvrRgstr.setRsvrNm(attRsBase.getRsName());
                    bisInspRsvrRgstr.setBaseStat("0");
                    bisInspRsvrRgstr.setResRunStat("0");
                    bisInspRsvrRgstr.setProvince("3500000000000");
                    bisInspRsvrRgstr=setRsvr(bisInspRsvrRgstr,objId,attRsBase);
                    logger.info(bisInspRsvrRgstr.getRsvrNm() + "---->");
                    inspRsvrRgstrService.insert(bisInspRsvrRgstr);
                }
            }
        }

        return buildFailResponse();
    }

    public BisInspRsvrRgstr setRsvr(BisInspRsvrRgstr bisInspRsvrRgstr,String objId,AttRsBase attRsBase){
        if(StringUtils.isNotBlank(attRsBase.getCenterXGd())){
            bisInspRsvrRgstr.setRsvrLong(Double.valueOf(attRsBase.getCenterXGd()));
        }
        if(StringUtils.isNotBlank(attRsBase.getCenterYGd())) {
            bisInspRsvrRgstr.setRsvrLat(Double.valueOf(attRsBase.getCenterYGd()));
        }
        bisInspRsvrRgstr.setOrgId("034");
        bisInspRsvrRgstr.setDamType(attRsBase.getDamType());
        bisInspRsvrRgstr.setHystSite(attRsBase.getLocation());
        bisInspRsvrRgstr.setResCreateTime(attRsBase.getCompDate());
        bisInspRsvrRgstr.setRsvrAdmName(attRsBase.getRsAdmName());
        bisInspRsvrRgstr.setEngScal(attRsBase.getEngScal());
        bisInspRsvrRgstr.setRsCode(attRsBase.getRsCode());
        bisInspRsvrRgstr.setAdCode(attRsBase.getAdmDiv());
        bisInspRsvrRgstr.setTotCap(attRsBase.getTotCap());
        bisInspRsvrRgstr.setDamRegCode(attRsBase.getRsAdmCode());
        bisInspRsvrRgstr.setDamMaxHigh(attRsBase.getDamSizeHig() + "");
        bisInspRsvrRgstr.setCompDateStr(attRsBase.getCompDateStr());
        bisInspRsvrRgstr.setDesFlStag(attRsBase.getDesFlStag());
        bisInspRsvrRgstr.setReverStat("0");
        bisInspRsvrRgstr.setBenefitStat("1");
        bisInspRsvrRgstr.setLocation(attRsBase.getLocation());
        bisInspRsvrRgstr.setUptm(new Date());
        bisInspRsvrRgstr.setIntm(new Date());
        bisInspRsvrRgstr.setImpdDt(attRsBase.getImpdDt());
        bisInspRsvrRgstr.setRnfcImpdDt(attRsBase.getRnfcImpdDt());
        bisInspRsvrRgstr.setRsClass(attRsBase.getRsClass());
        bisInspRsvrRgstr.setFlConTopStag(attRsBase.getFlConTopStag());
        return bisInspRsvrRgstr;
    }

    @ApiOperation(value = "批量更新督查对象")
    @RequestMapping(value = "/update/rsvr",method = RequestMethod.GET)
    public Object updateRsvr() {
        List<RsvrDto> rsvrDtoList = objInspPblmsRsvrDao.findRsvrDto();
        for (RsvrDto dto : rsvrDtoList) {
            String adCode = dto.getAdCode();
            List<AttRsBase> attRsBaseList = attRsBaseDao.getObjListNotInspGroupId(dto.getId(), "1", "", "", "", adCode, "35");
            logger.info(dto.getId() + ":" + dto.getAdCode() + ":size=" + attRsBaseList.size());
            if (attRsBaseList == null) {
                continue;
            }
            for (AttRsBase attRsBase : attRsBaseList) {
                BisInspAllObjParam allObjParam = new BisInspAllObjParam();
                allObjParam.setId(dto.getId());
                allObjParam.setCode(attRsBase.getRsCode());
                BisInspAllObj inspAllObj = inspAllObjDao.getBy(allObjParam);
                if (inspAllObj != null) {
                    BisInspRsvrRgstrParam rsvrRgstrParam=new BisInspRsvrRgstrParam();
                    rsvrRgstrParam.setObjId(inspAllObj.getObjId());
                    rsvrRgstrParam.setRsCode(inspAllObj.getCode());
                    BisInspRsvrRgstr bisInspRsvrRgstr=inspRsvrRgstrService.getBy(rsvrRgstrParam);
                    if(bisInspRsvrRgstr!=null){
                        bisInspRsvrRgstr=setRsvr(bisInspRsvrRgstr,inspAllObj.getObjId(),attRsBase);
                        inspRsvrRgstrService.update(bisInspRsvrRgstr);
                    }
                }
            }
        }
        return buildSuccessResponse();
    }
}