package cn.com.goldenwater.dcproj.service.impl;

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
import cn.com.goldenwater.dcproj.constValue.CommonLabel;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.dao.AttAdXBaseDao;
import cn.com.goldenwater.dcproj.dao.BisInspAllRlationDao;
import cn.com.goldenwater.dcproj.dao.BisInspVillgdDao;
import cn.com.goldenwater.dcproj.dto.AttCountryDto;
import cn.com.goldenwater.dcproj.dto.BisInspVillgdDto;
import cn.com.goldenwater.dcproj.dto.BisInspVillgdVillDto;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.*;
import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
import cn.com.goldenwater.dcproj.utils.Builder;
import cn.com.goldenwater.dcproj.utils.Constant;
import cn.com.goldenwater.id.util.UuidUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.apache.commons.collections.MapUtils;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletResponse;
import java.util.*;

/**
 * @author lhc
 * @date 2021-4-23
 */
@Service
@Transactional
public class BisInspVillgdServiceImpl extends AbstractCrudService<BisInspVillgd, BisInspVillgdParam> implements BisInspVillgdService, BisInspObjStrategy {

    @Autowired
    private BisInspVillgdDao bisInspVillgdDao;

    @Autowired
    private BisInspVillgdQqeService bisInspVillgdQqeService;

    @Autowired
    private AttAdXBaseDao attAdXBaseDao;

    @Autowired
    private BisInspVillgdWtspService bisInspVillgdWtspService;

    @Autowired
    private BisInspVillgdVillService bisInspVillgdVillService;
    @Autowired
    private BisInspVillgdNvillService bisInspVillgdNvillService;

    @Autowired
    private BisInspAllRlationDao bisInspAllRlationDao;

    @Autowired
    private BisInspVillgdVillUsrService bisInspVillgdVillUsrService;

    @Autowired
    private BisInspVillgdVillWtspService bisInspVillgdVillWtspService;
    @Autowired
    private BisInspPblmService bisInspPblmService;
    private Logger logger = LoggerFactory.getLogger(getClass());

    public BisInspVillgdServiceImpl(BisInspVillgdDao bisInspVillgdDao) {
        super(bisInspVillgdDao);
        this.bisInspVillgdDao = bisInspVillgdDao;
    }

    @Override
    public int insert(BisInspVillgd bisInspVillgd) {
        String uuid = UuidUtil.uuid();  // 生成uuid
        bisInspVillgd.setId(uuid);
        bisInspVillgd.setIntm(new Date());
        bisInspVillgd.setUptm(new Date());
        bisInspVillgd.setDataStat("0");
        return this.bisInspVillgdDao.insert(bisInspVillgd);
    }

    @Override
    public int update(BisInspVillgd bisInspVillgd) {
        bisInspVillgd.setUptm(new Date());
        updatePblmState(bisInspVillgd);//更新状态 同时更新问题
        return this.bisInspVillgdDao.update(bisInspVillgd);
    }
    private void updatePblmState(BisInspVillgd rgstr) {
        BisInspVillgd r = get(rgstr.getId());
        if (r == null) {
            return;
        }
        bisInspPblmService.updateStateByObjId(r.getObjId(), rgstr.getState());
    }

    @Override
    public int delete(String id) {
        return this.bisInspVillgdDao.delete(id);
    }


    @Override
    public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
        BisInspVillgd b = new BisInspVillgd();
        AttAdXBase base = attAdXBaseDao.get(bisInspAllObj.getCode());
        BeanUtils.copyProperties(base, b);

        // 统一字段 rgstrId, objId
        b.setId(UuidUtil.uuid());
        b.setObjId(bisInspAllObj.getObjId());
        // 日期
        Date d = new Date();
        b.setIntm(d);
        b.setUptm(d);
        // 数据状态 默认为 0
        // 督查状态(0:未督查;1:督查中;2:已督查)
        b.setState(CommonLabel.INIT_DATA);
        // 子表状态(0:未督查;1:督查中;2:已督查)
        b.setQqeState(CommonLabel.INIT_DATA);
        // 创建人
        b.setPersId(persId);
        /* 添加 登记表 */
        this.bisInspVillgdDao.insert(b);

        bisInspVillgdQqeService.insert(Builder.of(BisInspVillgdQqeParam::new).with(BisInspVillgdQqeParam::setRgstrId, b.getId()).build());
    }

    @Override
    public BisInspVillgd get(String key) {
        BisInspVillgd bisInspVillgd = super.get(key);
        Optional.ofNullable(bisInspVillgd).ifPresent(vill -> {
            vill.setVillCount(bisInspVillgdVillService.selectCount(Builder.of(BisInspVillgdVill::new).with(BisInspVillgdVill::setRgstrId, key).build()));
            vill.setNvillCount(bisInspVillgdNvillService.selectCount(Builder.of(BisInspVillgdNvill::new).with(BisInspVillgdNvill::setRgstrId, key).build()));
            vill.setWtspCount(bisInspVillgdWtspService.selectCount(Builder.of(BisInspVillgdWtsp::new).with(BisInspVillgdWtsp::setRgstrId, key).build()));
            vill.setVillUsrCount(bisInspVillgdVillUsrService.selectCount(Builder.of(BisInspVillgdVillUsr::new).with(BisInspVillgdVillUsr::setRgstrId, key).build()));
            vill.setVillWtspCount(bisInspVillgdVillWtspService.selectCount(Builder.of(BisInspVillgdVillWtsp::new).with(BisInspVillgdVillWtsp::setRgstrId, key).build()));
        });
        return bisInspVillgd;
    }

    @Override
    public String getType() {
        return BisInspEnum.VILLGD.getValue();
    }

    @Override
    public void cleanObjData(String objId) {
        BisInspVillgdParam rgstrParam = new BisInspVillgdParam();
        rgstrParam.setObjId(objId);
        List<BisInspVillgd> list = this.bisInspVillgdDao.findList(rgstrParam);
        if (list.size() > 0) {
            String id = list.get(0).getId();
            // 删除子表
            bisInspVillgdQqeService.deleteBy(Builder.of(BisInspVillgdQqeParam::new).with(BisInspVillgdQqeParam::setRgstrId, id).build());
            // 删除所有工程
            bisInspVillgdWtspService.deleteBy(Builder.of(BisInspVillgdWtspParam::new).with(BisInspVillgdWtspParam::setRgstrId, id).build());
            // 删除所有行政村
            bisInspVillgdVillService.deleteBy(Builder.of(BisInspVillgdVillParam::new).with(BisInspVillgdVillParam::setRgstrId, id).build());
            // 删除登记表
            this.bisInspVillgdDao.delete(id);
        }
    }

    @Override
    public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) {
        if (StringUtils.isNotBlank(typeParam.getAdCode())) {
            typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
        }
        PageHelper.startPage(typeParam);
        String[] groupIds = bisInspAllRlationDao.getIdByPersid(Builder
                .of(BisInspAllRlationParam::new)
                .with(BisInspAllRlationParam::setPersid, typeParam.getPresId())
                .with(BisInspAllRlationParam::setpType, typeParam.getpType())
                .build());
        typeParam.setGroupIds(groupIds);
        List<BisInspVillgdDto> list = (List<BisInspVillgdDto>) findObjListByType(typeParam);
        return (PageInfo<BisInspVillgdDto>) new PageInfo(list);
    }

    @Override
    public Object findObjListByType(TypeParam typeParam) {
        List<BisInspVillgdDto> list = this.bisInspVillgdDao.findPageList(typeParam);
        for (BisInspVillgdDto vill : list) {
            vill.setVillCount(bisInspVillgdVillService.selectCount(Builder.of(BisInspVillgdVill::new).with(BisInspVillgdVill::setRgstrId, vill.getId()).build()));
            vill.setNvillCount(bisInspVillgdNvillService.selectCount(Builder.of(BisInspVillgdNvill::new).with(BisInspVillgdNvill::setRgstrId, vill.getId()).build()));
            vill.setWtspCount(bisInspVillgdWtspService.selectCount(Builder.of(BisInspVillgdWtsp::new).with(BisInspVillgdWtsp::setRgstrId, vill.getId()).build()));
            vill.setVillUsrCount(bisInspVillgdVillUsrService.selectCount(Builder.of(BisInspVillgdVillUsr::new).with(BisInspVillgdVillUsr::setRgstrId, vill.getId()).build()));
            vill.setVillWtspCount(bisInspVillgdVillWtspService.selectCount(Builder.of(BisInspVillgdVillWtsp::new).with(BisInspVillgdVillWtsp::setRgstrId, vill.getId()).build()));
        }

        return list;
    }

    @Override
    public Map<String, Object> findNode(String villId, String regstrId) {
        Map<String, Object> map = new HashMap<>(2);
        villId = AdLevelUtil.getAddvcd(villId);
        // 获取工程暗访情况
        BisInspVillgdVillWtspParam wtspParam = Builder.of(BisInspVillgdVillWtspParam::new)
                .with(BisInspVillgdVillWtspParam::setRgstrId, regstrId)
                .with(BisInspVillgdVillWtspParam::setVillId, villId)
                .build();
        List<BisInspVillgdVillWtsp> wtspList = bisInspVillgdVillWtspService.findList(wtspParam);
        // 获取农牧民情况
        BisInspVillgdVillUsrParam poorParam = Builder.of(BisInspVillgdVillUsrParam::new)
                .with(BisInspVillgdVillUsrParam::setRgstrId, regstrId)
                .with(BisInspVillgdVillUsrParam::setVillId, villId)
                .build();
        List<BisInspVillgdVillUsr> usrList = bisInspVillgdVillUsrService.findList(poorParam);
        map.put("usr", usrList);
        map.put("wtsp", wtspList);

        return map;
    }

    @Override
    public List<AttCountryDto> findCheckTree(String code, String regstrId) {
        // 获取镇信息
        List<AttCountryDto> zhenDtoList = attAdXBaseDao.findXZCZhenList(code);
        // 获取村信息
        List<AttCountryDto> countryDtoList = attAdXBaseDao.findXZCCunList(code, regstrId, BisInspEnum.VILLGD.getValue());
        for (AttCountryDto attCountryDto : zhenDtoList) {
            String adCode = attCountryDto.getAdCode().replace("000", "");
            List<AttCountryDto> childList = new ArrayList<>();
            for (AttCountryDto countryDto : countryDtoList) {
                if (countryDto.getAdCode().startsWith(adCode)) {
                    childList.add(countryDto);
                }
            }

            attCountryDto.setAttCountryDtoList(childList);
        }
        return zhenDtoList;
    }

    @Override
    public void updateState(Map<String, Object> map) {
        BisInspVillgd rgstr = get(MapUtils.getString(map, "rgstrId"));
        if (!Constant.STRING_TWO.equals(rgstr.getState())) {
            rgstr.setState(Constant.STRING_ONE);
            if (StringUtils.isNotBlank(MapUtils.getString(map, "state"))) {
                switch (MapUtils.getString(map, "param")) {
                    case "qqe":
                        rgstr.setQqeState(MapUtils.getString(map, "state"));
                        break;
//                case "poor":
//                    rgstr.setPoorState(MapUtils.getString(map, "state"));
//                    break;
                    default:
                }
            }
            update(rgstr);
        }
    }

    @Override
    public List<BisInspVillgdVillDto> getVillTree(String id) {
        List<BisInspVillgdVillDto> villDtoList = new ArrayList<>();
        List<BisInspVillgdVill> villList = bisInspVillgdVillService.findList(Builder.of(BisInspVillgdVillParam::new)
                .with(BisInspVillgdVillParam::setRgstrId, id).build());
        if (villList == null || villList.size() == 0) {
            return null;
        }

        villList.forEach(vill -> {
//            vill.setNvillCount(bisInspVillgdNvillService.selectCount(Builder.of(BisInspVillgdNvill::new).with(BisInspVillgdNvill::setRgstrId, key).build()));
            vill.setVillUsrCount(bisInspVillgdVillUsrService.selectCount(Builder.of(BisInspVillgdVillUsr::new).with(BisInspVillgdVillUsr::setVillId, vill.getId()).build()));
            vill.setVillWtspCount(bisInspVillgdVillWtspService.selectCount(Builder.of(BisInspVillgdVillWtsp::new).with(BisInspVillgdVillWtsp::setVillId, vill.getId()).build()));
            BisInspVillgdVillDto villDto = new BisInspVillgdVillDto();
            BeanUtils.copyProperties(vill, villDto);
            villDto.setLevel("1");
            villDtoList.add(villDto);
        });

        for (BisInspVillgdVillDto villDto : villDtoList) {
            List<BisInspVillgdNvill> nvillList = bisInspVillgdNvillService.findList(Builder.of(BisInspVillgdNvillParam::new)
                    .with(BisInspVillgdNvillParam::setVillId, villDto.getId()).build());
            if (nvillList != null && nvillList.size() > 0) {
                nvillList.forEach(vill -> {
                    vill.setVillUsrCount(bisInspVillgdVillUsrService.selectCount(Builder.of(BisInspVillgdVillUsr::new).with(BisInspVillgdVillUsr::setVillId, vill.getId()).build()));
                    vill.setVillWtspCount(bisInspVillgdVillWtspService.selectCount(Builder.of(BisInspVillgdVillWtsp::new).with(BisInspVillgdVillWtsp::setVillId, vill.getId()).build()));
                });
                villDto.getChildren().addAll(nvillList);
            }
        }

        return villDtoList;
    }
}