fj-dc/.svn/pristine/72/72087d9c5442a55c003d2f4304af16a74dbdcedc.svn-base

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

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.constValue.BisInspEnum;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.constValue.StateEnum;
import cn.com.goldenwater.dcproj.dao.AttAdXBaseDao;
import cn.com.goldenwater.dcproj.dao.BisInspAllObjDao;
import cn.com.goldenwater.dcproj.dao.BisInspMfdpRgstrDao;
import cn.com.goldenwater.dcproj.dao.BisInspPblmDao;
import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto;
import cn.com.goldenwater.dcproj.model.AttAdXBase;
import cn.com.goldenwater.dcproj.model.BisInspAllObj;
import cn.com.goldenwater.dcproj.model.BisInspMfdpRgstr;
import cn.com.goldenwater.dcproj.model.BisInspPblm;
import cn.com.goldenwater.dcproj.param.BisInspAllObjParam;
import cn.com.goldenwater.dcproj.param.BisInspMfdpRgstrParam;
import cn.com.goldenwater.dcproj.param.BisInspPblmParam;
import cn.com.goldenwater.dcproj.param.PlbmParam;
import cn.com.goldenwater.dcproj.param.TypeParam;
import cn.com.goldenwater.dcproj.service.BisInspMfdpRgstrService;
import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
import cn.com.goldenwater.dcproj.service.BisInspPblmService;
import cn.com.goldenwater.dcproj.utils.AdLevelUtil;
import cn.com.goldenwater.dcproj.utils.InspPblmUtils;
import cn.com.goldenwater.dcproj.utils.InspUtils;
import cn.com.goldenwater.id.util.UuidUtil;
import cn.com.goldenwater.target.CheckException;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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.Date;
import java.util.List;

/**
 * @author lune
 * @date 2020-4-26
 */
@Service
@Transactional
public class BisInspMfdpRgstrServiceImpl extends AbstractCrudService<BisInspMfdpRgstr, BisInspMfdpRgstrParam> implements BisInspMfdpRgstrService, BisInspObjStrategy {
    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    private BisInspMfdpRgstrDao bisInspMfdpRgstrDao;

    @Autowired
    private AttAdXBaseDao attAdXBaseDao;

    @Autowired
    private BisInspPblmDao bisInspPblmDao;

    @Autowired
    private BisInspAllObjDao bisInspAllObjDao;

    @Autowired
    private BisInspPblmService bisInspPblmService;

    public BisInspMfdpRgstrServiceImpl(BisInspMfdpRgstrDao bisInspMfdpRgstrDao) {
        super(bisInspMfdpRgstrDao);
        this.bisInspMfdpRgstrDao = bisInspMfdpRgstrDao;
    }

    @Override
    public int update(BisInspMfdpRgstr entity) {
        BisInspMfdpRgstr r = get(entity.getId());
        if (r == null) {
            throw new CheckException("未找到对应登记表！");
        }

        entity.setUptm(new Date());
        if (!"2".equals(r.getState()) && !"2".equals(entity.getState())) {
            entity.setState("1");
        }
        // 跟新登记表状态
        int rows = super.update(entity);
        // 更新问题状态
        updatePblmState(entity);
        return rows;
    }

    private void updatePblmState(BisInspMfdpRgstr rgstr) {
        BisInspMfdpRgstr r = get(rgstr.getId());
        if (r == null) {
            return;
        }
        logger.info("BisInspMfdpRgstr:" + r.toString());
        bisInspPblmService.updateStateByObjId(r.getObjId(), rgstr.getState());
    }

    @Override
    public PageInfo<BisInspRgstrDto> findMfdpPage(TypeParam param, HttpServletResponse response) {
        if (StringUtils.isNotBlank(param.getAdCode())) {
            param.setAdCode(String.valueOf(AdLevelUtil.SubAd(param.getAdCode()).get(SplitValue.SUBAD)));
        }
        if (StringUtils.isNotBlank(param.getAdCodes())) {
            param.setAdCodes(AdLevelUtil.getListAddvcd(param.getAdCodes()));
        }
        PageHelper.startPage(param);
        List<BisInspRgstrDto> list = bisInspMfdpRgstrDao.findMfdpList(param);
        list = InspPblmUtils.changeList(list);
        return new PageInfo<BisInspRgstrDto>(list);
    }

    @Override
    public PageInfo<BisInspPblm> findPblmPage(PlbmParam pblmParam) {
        PageHelper.startPage(pblmParam);
        if (StringUtils.isNotBlank(pblmParam.getInspPblmName())) {
            pblmParam.setInspPblmName(InspUtils.setOrgIds(pblmParam.getInspPblmName()));
        }
        if (StringUtils.isNotBlank(pblmParam.getCheckPoint())) {
            pblmParam.setCheckPoint(InspUtils.setOrgIds(pblmParam.getCheckPoint()));
        }
        if (StringUtils.isNotBlank(pblmParam.getInspPblmCate())) {
            pblmParam.setInspPblmCate(InspUtils.setOrgIds(pblmParam.getInspPblmCate()));
        }
        List<BisInspPblm> list = bisInspMfdpRgstrDao.findPblmList(pblmParam);
        PageInfo<BisInspPblm> pageInfo = new PageInfo(list);
        return pageInfo;
    }

    @Override
    public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
        AttAdXBase xBase = attAdXBaseDao.getByCode(bisInspAllObj.getCode());
        BisInspMfdpRgstr rgstr = new BisInspMfdpRgstr();
        rgstr.setId(UuidUtil.uuid());
        rgstr.setObjId(bisInspAllObj.getObjId());
        rgstr.setAdCode(bisInspAllObj.getCode());
        rgstr.setAdName(bisInspAllObj.getNm());
        rgstr.setPoorCountry(xBase.getIsPoveryt());
        rgstr.setSitroMsNum(new Long(0));
        rgstr.setSitroRxNum(new Long(0));
        rgstr.setSitroTownNum(new Long(0));
        rgstr.setSitroVlgNum(new Long(0));
        rgstr.setState(StateEnum.NOWASTSTATE.getKey());
        rgstr.setIntm(new Date());
        rgstr.setUptm(new Date());
        bisInspMfdpRgstrDao.insert(rgstr);
    }

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

    @Override
    public void cleanObjData(String objId) {
        BisInspMfdpRgstrParam param = new BisInspMfdpRgstrParam();
        param.setObjId(objId);
        List<BisInspMfdpRgstr> list = this.bisInspMfdpRgstrDao.findList(param);
        if (list.size() > 0) {
            String id = list.get(0).getId();
            BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
            bisInspPblmParam.setObjId(objId);
            bisInspPblmParam.setObjType(BisInspEnum.MFDP.getValue());
            this.bisInspPblmDao.deleteBy(bisInspPblmParam);//删除问题
            bisInspMfdpRgstrDao.delete(id);
            BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam();
            bisInspAllObjParam.setObjId(objId);
            this.bisInspAllObjDao.deleteBy(bisInspAllObjParam);//删除督查对象
        }

    }

    @Override
    public PageInfo findObjPageByType(TypeParam typeParam, HttpServletResponse response) {
        return findMfdpPage(typeParam, response);
    }

    @Override
    public Object findObjListByType(TypeParam typeParam) {
        if (StringUtils.isNotBlank(typeParam.getAdCode())) {
            typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
        }
        if (StringUtils.isNotBlank(typeParam.getAdCodes())) {
            typeParam.setAdCodes(AdLevelUtil.getListAddvcd(typeParam.getAdCodes()));
        }
        List<BisInspRgstrDto> list = bisInspMfdpRgstrDao.findMfdpList(typeParam);
        list = InspPblmUtils.changeList(list);
        return list;
    }
}