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

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.dao.AttCwsBaseDao;
import cn.com.goldenwater.dcproj.dao.BisInspVill2021CwsDao;
import cn.com.goldenwater.dcproj.model.AttCwsBase;
import cn.com.goldenwater.dcproj.model.BisInspVill2021Cws;
import cn.com.goldenwater.dcproj.param.BisInspVill2021CwsParam;
import cn.com.goldenwater.dcproj.param.CwsParam;
import cn.com.goldenwater.dcproj.service.BisInspVill2021CwsService;
import cn.com.goldenwater.dcproj.service.BisInspVill2021RgstrService;
import cn.com.goldenwater.dcproj.utils.Builder;
import cn.com.goldenwater.id.util.UuidUtil;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import static cn.com.goldenwater.dcproj.util.CheckUtil.check;

/**
 * @author lhc
 * @date 2021-6-16
 */
@Service
@Transactional
public class BisInspVill2021CwsServiceImpl extends AbstractCrudService<BisInspVill2021Cws, BisInspVill2021CwsParam> implements BisInspVill2021CwsService {

    @Autowired
    private BisInspVill2021CwsDao bisInspVill2021CwsDao;

    @Autowired
    private AttCwsBaseDao attCwsBaseDao;

    @Autowired
    private BisInspVill2021RgstrService bisInspVill2021RgstrService;

    public BisInspVill2021CwsServiceImpl(BisInspVill2021CwsDao bisInspVill2021CwsDao) {
        super(bisInspVill2021CwsDao);
        this.bisInspVill2021CwsDao = bisInspVill2021CwsDao;
    }

    @Override
    public int insert(BisInspVill2021Cws bisInspVill2021Cws) {
        check(StringUtils.isNotBlank(bisInspVill2021Cws.getRgstrId()), "rgstrId.no");
        String uuid = UuidUtil.uuid();
        bisInspVill2021Cws.setId(uuid);
        bisInspVill2021Cws.setIntm(new Date());
        bisInspVill2021Cws.setUptm(new Date());
        bisInspVill2021Cws.setDataStat("0");
        return this.bisInspVill2021CwsDao.insert(bisInspVill2021Cws);
    }

    @Override
    public int update(BisInspVill2021Cws bisInspVill2021Cws) {
        bisInspVill2021Cws.setUptm(new Date());
        return this.bisInspVill2021CwsDao.update(bisInspVill2021Cws);
    }

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

    @Override
    public PageInfo<AttCwsBase> pageNotDC(CwsParam cwsParam) {
        check(StringUtils.isNotBlank(cwsParam.getRegstrId()), "regstrId.no");
        PageHelper.startPage(cwsParam.getPageNum(), cwsParam.getPageSize());
        List<AttCwsBase> bisInspBaseDtos = attCwsBaseDao.queryListByRegstrIdNotDC(cwsParam);
        return new PageInfo<>(bisInspBaseDtos);
    }

    @Override
    public void addBatch(CwsParam cwsParam) {
        check(StringUtils.isNotBlank(cwsParam.getRegstrId()), "regstrId.no");
        check(StringUtils.isNotBlank(cwsParam.getCwsIds()), "cwsIds.no");

        String[] cwsIdArray;
        if (cwsParam.getCwsIds().contains(SplitValue.FENHAO_SPLIT)) {
            cwsIdArray = cwsParam.getCwsIds().split(SplitValue.FENHAO_SPLIT);
        } else {
            cwsIdArray = cwsParam.getCwsIds().split(SplitValue.DOUHAO_SPLIT);
        }

        for (String cwsId : cwsIdArray) {
            AttCwsBase attCwsBase = attCwsBaseDao.get(cwsId);
            if (attCwsBase == null) {
                continue;
            }
            BisInspVill2021Cws fee = Builder.of(BisInspVill2021Cws::new)
                    .with(BisInspVill2021Cws::setRgstrId, cwsParam.getRegstrId())
                    .build();

//            if (StringUtils.isNotBlank(cwsParam.getAdCode())) {
//                AttAdXBase attAdXBase = attAdXBaseService.get(cwsParam.getAdCode());
//                Optional.ofNullable(attAdXBase).ifPresent(base -> {
//                    fee.setAdCode(base.getAdCode());
//                    fee.setAdFullName(base.getAdFullName());
//                    fee.setAdName(base.getAdName());
//                });
//            }

            fee.setPersId(cwsParam.getPersId());
            fee.setCwsCode(attCwsBase.getCwsCode());
            fee.setCwsNm(attCwsBase.getCwsName());
            fee.setCwsLoc(attCwsBase.getCwsLoc());
            fee.setGdX(attCwsBase.getCenterXGd());
            fee.setGdY(attCwsBase.getCenterYGd());
            fee.setCenterX(attCwsBase.getCwsLong());
            fee.setCenterY(attCwsBase.getCwsLat());
            insert(fee);
        }

        // 更新登记表状态
        Map<String, Object> map = new HashMap<>(3);
        map.put("rgstrId", cwsParam.getRegstrId());
        map.put("param", "indus");
        map.put("state", "1");
        bisInspVill2021RgstrService.updateState(map);
    }
}