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

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.dao.*;
import cn.com.goldenwater.dcproj.dto.BisInspRgstrDto;
import cn.com.goldenwater.dcproj.dto.BisInspWagaSapRgstrVo;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.*;
import cn.com.goldenwater.dcproj.service.BisInspObjStrategy;
import cn.com.goldenwater.dcproj.service.BisInspWagaSapRgstrService;
import cn.com.goldenwater.dcproj.utils.*;
import cn.com.goldenwater.dcproj.utils.impexcel.ExpAndImpUtil;
import cn.com.goldenwater.id.util.UuidUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

import static cn.com.goldenwater.dcproj.utils.impexcel.field.ExcelFieldLists.bisInspRgstrArrays;

/**
 * @author lune
 * @date 2020-5-19
 */
@Service
@Transactional
public class BisInspWagaSapRgstrServiceImpl extends AbstractCrudService<BisInspWagaSapRgstr, BisInspWagaSapRgstrParam> implements BisInspWagaSapRgstrService, BisInspObjStrategy {

    @Autowired
    private BisInspWagaSapRgstrDao bisInspWagaSapRgstrDao;
    @Autowired
    private AttWagaSapBaseCrrctDao attWagaSapBaseCrrctDao;
    @Autowired
    private AttFscBaseDao attFscBaseDao;
    @Autowired
    private BisInspPblmDao bisInspPblmDao;
    @Autowired
    private BisInspAllObjDao bisInspAllObjDao;
    @Autowired
    private BisInspWagaSapRgstrDamIfDao bisInspWagaSapRgstrDamIfDao;
    @Autowired
    private BisInspWagaSapRgstrMrsCiDao bisInspWagaSapRgstrMrsCiDao;
    @Autowired
    private BisInspWagaSapRgstrPnIfDao bisInspWagaSapRgstrPnIfDao;
    @Autowired
    private BisInspWagaSapRgstrSfMngDao bisInspWagaSapRgstrSfMngDao;
    @Autowired
    private BisInspWagaSapRgstrBaseDao bisInspWagaSapRgstrBaseDao;
    @Autowired
    private AttWagaSapBaseDao attWagaSapBaseDao;
    @Value("${export.templatePath}")
    private String templatePath;
    @Autowired
    private BisInspAllRlationPersDao bisInspAllRlationPersDao;

    /**
     * 管理体系
     */
    public static String[] bisInspWagaSapRgstrMrsCiArrays =
            ("compUnit,wmbpIsC,pssIsH,pssIsC,prftaofcIsH,prftaofcInfo," +
                    "befpIsFip,pmameIsFip,ebmWmbpIsC,ebmIsIacTrotm,hasEbm").split(",");

    /**
     * 安全管理
     */
    public static String[] bisInspWagaSapRgstrSfMngArrays =
            ("dmDfiIsCba,dmDfiIsPass,dmDfiIsDa,dmDfiIsTsmm,emIsStfEpffc,emEpffcIsAfaof,emIsEpffcDrl,emIsTraconfcaes,rmIsAdtr,rmIsCcPtmbar").split(",");

    /**
     * 工程实体
     */
    public static String[] bisInspWagaSapRgstrPnIfArrays =
            ("dsKmmwIsMd,tpIsPatsme,planFlSta,eboiTbsIsCwtdr,eboiBdIsEcmplt,baLcIsIsfafatslis,baLcIsTadc,baHottoadwaeeocIsTatb," +
                    "baLsIsNsrd,baLsIsCculs,baIsTaodttbabaat,baToeIsUsiw,baAacIsCefdcd,orlpRcMsIsUmcfob,orlpRcMcrIsCadd,orlpRcSrssIsUlcfo," +
                    "orlpRcTodrIsUwsdb,orlpRcAsowIsDdw,orlpRcTwIsCbd,orlpBkIsScPsnsFpi,adfAdwIsDi,wdcdcIsNcsc,wdcdcIsUsfv,wdcdcHrIsTfm,wdcdcIsDnsu," +
                    "bpeTwpfbbfbIsAd,bpeGcDbws,dsEttrSsIsMd,orlpRcType").split(",");

    /**
     * 日常管理与维护
     */
    public static String[] bisInspWagaSapRgstrDamifArrays =
            ("isCoarScw,isHirIrs,isIafditTemtdwi,isPrdRm,isMipThopeiee,socIsDe," +
                    "socIsIc,socIsAtetsotp,sopIsDe,sopIsIc,sopIsAtetsotp,msIsFaiMsftoolp").split(",");

    /**
     * 基本情况
     */
    public static String[] bisInspWagaSapRgstrBaseArrays =
            ("sapName,sapLen,dikeGrad,planFlSta,rvLkCst,compUnit,mampu,mampuAttn,mampuAttnTel").split(",");

    public BisInspWagaSapRgstrServiceImpl(BisInspWagaSapRgstrDao bisInspWagaSapRgstrDao) {
        super(bisInspWagaSapRgstrDao);
        this.bisInspWagaSapRgstrDao = bisInspWagaSapRgstrDao;
    }

    @Override
    public int setMessage(BisInspWagaSapRgstr sapRgstr) {
        try {
            HttpClient client = new SSLClient();
            HttpPost httpPost = new HttpPost("https://interface.dike.yrihr.com.cn/inspect/project/dike/danger");
            httpPost.addHeader("Content-Type", "application/json;charset=UTF-8");
            httpPost.addHeader("Accept", "application/json");
            httpPost.addHeader("authorization", "2665141c24ec4a3733d55226e4ffe811010d136e9f1473fb4039096c4ab764c4");
            JSONObject obj = new JSONObject();
            obj.put("dangerName", sapRgstr.getSapName());
            obj.put("areaCode", sapRgstr.getAdCode());
            obj.put("managerUnitName", sapRgstr.getMampu());
            obj.put("basinManage", sapRgstr.getBasCode());
            List<BisInspAllRlationPers> pers = bisInspAllRlationPersDao.getPersByObjId(sapRgstr.getObjId(), "1");
            if (pers.size() > 0) {
                obj.put("examiner", pers.stream().map(BisInspAllRlationPers::getPersName).collect(Collectors.joining(",")));
                obj.put("examinerTel", pers.stream().map(BisInspAllRlationPers::getMobilenumb).collect(Collectors.joining(",")));
            }
            obj.put("examinerTime", new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
            JSONArray jsonArray = new JSONArray();
            jsonArray.add(obj);
            StringEntity stringEntity = new StringEntity(jsonArray.toJSONString(), "UTF-8");
            stringEntity.setContentEncoding("UTF-8");
            httpPost.setEntity(stringEntity);
            HttpResponse response = client.execute(httpPost);
            if (response != null) {
                HttpEntity resEntity = response.getEntity();
                if (resEntity != null) {
                    System.out.println(EntityUtils.toString(resEntity, "UTF8"));
                }
            }
            httpPost.clone();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
        return 0;
    }

    /**
     * 修改堤防险工险段督查信息并记录到纠错信息表
     *
     * @param bisInspWagaSapRgstr 堤防险工险段督查登记表实体类
     * @return Integer
     */
    @Transactional(rollbackFor = Exception.class)
    @Override
    public String updateSapRgstrAndInsertSapBaseCrrct(BisInspWagaSapRgstr bisInspWagaSapRgstr) {
        bisInspWagaSapRgstr.setUptm(new Date());
        int updateResult = bisInspWagaSapRgstrDao.update(bisInspWagaSapRgstr);
        if (Constant.INT_ZERO != updateResult) {
            AttWagaSapBaseCrrct attWagaSapBaseCrrct = new AttWagaSapBaseCrrct();
            BeanUtils.copyProperties(bisInspWagaSapRgstr, attWagaSapBaseCrrct);
            attWagaSapBaseCrrct.setId(UuidUtil.uuid());
            attWagaSapBaseCrrctDao.insert(attWagaSapBaseCrrct);
            return "修改成功";
        }
        return "修改失败！";
    }

    /**
     * 获取堤防险工险段督查列表
     *
     * @param typeParam 传参对象
     * @return BisInspRgstrDto
     */
    @Override
    public PageInfo<BisInspRgstrDto> getSapRgstrList(TypeParam typeParam) {
        return new PageInfo<BisInspRgstrDto>(getWagaSapRgstrInfo(typeParam, true));
    }


    @Override
    public void insertObj(BisInspAllObj bisInspAllObj, String persId) {
        AttWagaSapBase attWagaSapBase = attWagaSapBaseDao.get(bisInspAllObj.getCode());
        if (null != attWagaSapBase) {
            BisInspWagaSapRgstr wagaSapRgstr = new BisInspWagaSapRgstr();
            wagaSapRgstr.setUptm(new Date());
            wagaSapRgstr.setIntm(new Date());
            wagaSapRgstr.setBaseStat(Constant.STRING_ZERO);
            wagaSapRgstr.setMrsCiStat(Constant.STRING_ZERO);
            wagaSapRgstr.setSafeStat(Constant.STRING_ZERO);
            wagaSapRgstr.setProenStat(Constant.STRING_ZERO);
            wagaSapRgstr.setDmamStat(Constant.STRING_ZERO);
            wagaSapRgstr.setState(Constant.STRING_ZERO);
            wagaSapRgstr.setChkState(attWagaSapBase.getChkState());
            wagaSapRgstr.setAdCode(attWagaSapBase.getAdCode());
            wagaSapRgstr.setAdName(attWagaSapBase.getAdName());
            wagaSapRgstr.setCenterX(attWagaSapBase.getCenterX());
            wagaSapRgstr.setCenterY(attWagaSapBase.getCenterY());
            wagaSapRgstr.setGdX(attWagaSapBase.getGdX());
            wagaSapRgstr.setGdY(attWagaSapBase.getGdY());
            String id = UuidUtil.uuid();
            wagaSapRgstr.setId(id);
            wagaSapRgstr.setObjId(bisInspAllObj.getObjId());
            wagaSapRgstr.setGroupId(bisInspAllObj.getId());
            wagaSapRgstr.setSapName(attWagaSapBase.getSapName());
            wagaSapRgstr.setDiskName(attWagaSapBase.getDiskName());
            wagaSapRgstr.setDikeGrad(attWagaSapBase.getDikeGrad());
            wagaSapRgstr.setCompUnitAttn(attWagaSapBase.getCompUnitAttn());
            wagaSapRgstr.setCompUnitAttnTel(attWagaSapBase.getCompUnitAttnTel());
            wagaSapRgstr.setRiverBank(attWagaSapBase.getRiverBank());
            wagaSapRgstr.setGvmtFldWho(attWagaSapBase.getGvmtFldWho());
            wagaSapRgstr.setGvmtFldWhoTel(attWagaSapBase.getGvmtFldWhoTel());
            wagaSapRgstr.setMampuAttn(attWagaSapBase.getMampuAttn());
            wagaSapRgstr.setMampuAttnTel(attWagaSapBase.getMampuAttnTel());
            wagaSapRgstr.setSapLen(attWagaSapBase.getSapLen());
            wagaSapRgstr.setSapType(attWagaSapBase.getSapType());
            wagaSapRgstr.setStartLoc(attWagaSapBase.getStartLoc());
            wagaSapRgstr.setCoast(attWagaSapBase.getCoast());
            wagaSapRgstr.setLake(attWagaSapBase.getLake());
            wagaSapRgstr.setSapId(attWagaSapBase.getId());
            wagaSapRgstr.setPersId(persId);
            bisInspWagaSapRgstrDao.insert(wagaSapRgstr);

            BisInspWagaSapRgstrBaseParam bisInspWagaSapRgstrBaseParam = new BisInspWagaSapRgstrBaseParam();
            bisInspWagaSapRgstrBaseParam.setRgstrId(id);
            BisInspWagaSapRgstrBase bisInspWagaSapRgstrBase = bisInspWagaSapRgstrBaseDao.getBy(bisInspWagaSapRgstrBaseParam);
            if (bisInspWagaSapRgstrBase == null) {
                bisInspWagaSapRgstrBase = new BisInspWagaSapRgstrBase();
                bisInspWagaSapRgstrBase.setId(UuidUtil.uuid());
                bisInspWagaSapRgstrBase.setRgstrId(id);
                bisInspWagaSapRgstrBase.setSapName(attWagaSapBase.getSapName());
                bisInspWagaSapRgstrBase.setSapLen(attWagaSapBase.getSapLen());
                bisInspWagaSapRgstrBase.setDikeGrad(attWagaSapBase.getDikeGrad());
                bisInspWagaSapRgstrBase.setRiverBank(attWagaSapBase.getRiverBank());
                bisInspWagaSapRgstrBase.setLake(attWagaSapBase.getLake());
                bisInspWagaSapRgstrBase.setCoast(attWagaSapBase.getCoast());
                bisInspWagaSapRgstrBase.setMampu(attWagaSapBase.getMampu());
                bisInspWagaSapRgstrBase.setMampuAttn(attWagaSapBase.getMampuAttn());
                bisInspWagaSapRgstrBase.setMampuAttnTel(attWagaSapBase.getMampuAttnTel());
                bisInspWagaSapRgstrBase.setStatus(Constant.STRING_ZERO);
                bisInspWagaSapRgstrBase.setRecPersId(persId); //不可空
                bisInspWagaSapRgstrBaseDao.insert(bisInspWagaSapRgstrBase);
            }
        }

    }

    @Override
    public void cleanObjData(String objId) {
        BisInspWagaSapRgstrParam bisInspWagaSapRgstrParam = new BisInspWagaSapRgstrParam();
        bisInspWagaSapRgstrParam.setObjId(objId);
        String id = bisInspWagaSapRgstrDao.getWagaSapRgstrInfoByObjId(objId);
        if (StringUtils.isNotBlank(id)) {
            BisInspPblmParam bisInspPblmParam = new BisInspPblmParam();
            bisInspPblmParam.setRegid(id);
            bisInspPblmParam.setObjType(BisInspEnum.SAP.getValue());
            bisInspPblmDao.deleteBy(bisInspPblmParam);
            bisInspWagaSapRgstrDao.deleteById(id);
            bisInspWagaSapRgstrDamIfDao.deleteByRgstrId(id);
            bisInspWagaSapRgstrMrsCiDao.deleteByRgstrId(id);
            bisInspWagaSapRgstrPnIfDao.deleteByRgstrId(id);
            bisInspWagaSapRgstrSfMngDao.deleteByRgstrId(id);
            bisInspWagaSapRgstrBaseDao.deleteByRgstrId(id);
            //删除督查对象
            BisInspAllObjParam bisInspAllObjParam = new BisInspAllObjParam();
            bisInspAllObjParam.setObjId(objId);
            bisInspAllObjDao.deleteBy(bisInspAllObjParam);
        }
    }

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

    @Override
    public Object findObjListByType(TypeParam typeParam) {
        return getWagaSapRgstrInfo(typeParam, false);
    }

    private List<BisInspRgstrDto> getWagaSapRgstrInfo(TypeParam typeParam, boolean isExport) {
        if (StringUtils.isNotBlank(typeParam.getAdCode())) {
            typeParam.setAdCode(String.valueOf(AdLevelUtil.SubAd(typeParam.getAdCode()).get(SplitValue.SUBAD)));
        }
        if (isExport) {
            PageHelper.startPage(typeParam);
        }
        List<BisInspRgstrDto> bisInspRgstrList = bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(typeParam);
        if (CollectionUtils.isNotEmpty(bisInspRgstrList)) {
            bisInspRgstrList.stream().forEach(bisInspRgstrDto -> {
                if (bisInspRgstrDto.getLocation() != null && bisInspRgstrDto.getLocation().contains(SplitValue.HENG_SPLIT)) {
                    String[] split = bisInspRgstrDto.getLocation().split(SplitValue.HENG_SPLIT);
                    if (split.length == Constant.INT_THREE) {
                        bisInspRgstrDto.setProvince(split[Constant.INT_ZERO]);
                        bisInspRgstrDto.setCity(split[Constant.INT_ONE]);
                        bisInspRgstrDto.setCountry(split[Constant.INT_TWO]);
                    }
                    if (split.length == Constant.INT_TWO) {
                        bisInspRgstrDto.setProvince(split[Constant.INT_ZERO]);
                        bisInspRgstrDto.setCity(split[Constant.INT_ONE]);
                        bisInspRgstrDto.setCountry(Constant.STRING_BLANK);
                    } else {
                        bisInspRgstrDto.setProvince(bisInspRgstrDto.getLocation());
                    }
                }
            });
        }
        return bisInspRgstrList;
    }

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

    @Override
    public void downloadTemplate(HttpServletResponse response, TypeParam param) throws Exception {

        List<BisInspWagaSapRgstrVo> bisInspWagaSapRgstrVoList = new ArrayList();

        // 模板路径
        String filePath = templatePath + File.separator + "pblmDfx_tb.xls";
        // SHEET名称
        String sheetName = "堤防险工险段报表";
        // startRow
        int startRow = 2;
        if (StringUtils.isBlank(param.getPlnaId())) {
            List<Map<String, Object>> list = new ArrayList<>();
            ExpAndImpUtil.download(response, list, filePath, startRow, sheetName);
        }
        List<BisInspRgstrDto> bisInspRgstrList = bisInspWagaSapRgstrDao.getWagaSapRegstrInfo(param);
        bisInspRgstrList = InspPblmUtils.changeList(bisInspRgstrList);

        //赋值其他参数
        setWagaSapRgstrVoList(bisInspRgstrList, bisInspWagaSapRgstrVoList);
        //数据转换为Map
        List<Map<String, Object>> dataList = wagaSapRgsteListConvertMap(bisInspWagaSapRgstrVoList);

        ExpAndImpUtil.download(response, dataList, filePath, startRow, sheetName);
    }

    private void setWagaSapRgstrVoList(List<BisInspRgstrDto> wagaSapList, List<BisInspWagaSapRgstrVo> bisInspWagaSapRgstrVoList) {
        wagaSapList.forEach(sapDto -> {
            BisInspWagaSapRgstrVo bisVo = new BisInspWagaSapRgstrVo();

            //登记表
            bisVo.setBisInspRgstrDto(sapDto);
            String rgstrId = sapDto.getRgstrId();

            //日常管理与维护
            BisInspWagaSapRgstrDamIfParam damIfParam = new BisInspWagaSapRgstrDamIfParam();
            damIfParam.setRgstrId(rgstrId);
            BisInspWagaSapRgstrDamIf damIf = bisInspWagaSapRgstrDamIfDao.getBy(damIfParam);
            bisVo.setBisInspWagaSapRgstrDamIf(damIf);

            //管理体系
            BisInspWagaSapRgstrMrsCiParam mrsCiParam = new BisInspWagaSapRgstrMrsCiParam();
            mrsCiParam.setRgstrId(rgstrId);
            BisInspWagaSapRgstrMrsCi mrsCi = bisInspWagaSapRgstrMrsCiDao.getBy(mrsCiParam);
            bisVo.setBisInspWagaSapRgstrMrsCi(mrsCi);

            //工程实体
            BisInspWagaSapRgstrPnIfParam pnIfParam = new BisInspWagaSapRgstrPnIfParam();
            pnIfParam.setRgstrId(rgstrId);
            BisInspWagaSapRgstrPnIf pnIf = bisInspWagaSapRgstrPnIfDao.getBy(pnIfParam);
            bisVo.setBisInspWagaSapRgstrPnIf(pnIf);

            //安全管理
            BisInspWagaSapRgstrSfMngParam sfMngParam = new BisInspWagaSapRgstrSfMngParam();
            sfMngParam.setRgstrId(rgstrId);
            BisInspWagaSapRgstrSfMng sfMng = bisInspWagaSapRgstrSfMngDao.getBy(sfMngParam);
            bisVo.setBisInspWagaSapRgstrSfMng(sfMng);
            //基本信息
            BisInspWagaSapRgstrBase bisInspWagaSapRgstrBase = bisInspWagaSapRgstrBaseDao.getWagaSapRgstrBaseByRgstrId(rgstrId);
            bisVo.setBisInspWagaSapRgstrBase(bisInspWagaSapRgstrBase);
            bisInspWagaSapRgstrVoList.add(bisVo);
        });
    }

    private List<Map<String, Object>> wagaSapRgsteListConvertMap(List<BisInspWagaSapRgstrVo> bisInspWagaSapRgstrVoList) {
        List<Map<String, Object>> dataList = new LinkedList<>();
        bisInspWagaSapRgstrVoList.forEach(vo -> {
            Map<String, Object> map = new HashMap<>();
            //登记表
            BisInspRgstrDto bisInspRgstrDto = vo.getBisInspRgstrDto();
            ExpAndImpUtil.convertBeanToMap(bisInspRgstrDto, bisInspRgstrArrays, map, WagaSapFieldFromatExp.class);
            //日常管理与维护
            BisInspWagaSapRgstrDamIf bisInspWagaSapRgstrDamIf = vo.getBisInspWagaSapRgstrDamIf();
            ExpAndImpUtil.convertBeanToMap(bisInspWagaSapRgstrDamIf, bisInspWagaSapRgstrDamifArrays, map, WagaSapFieldFromatExp.class);
            //管理体系
            BisInspWagaSapRgstrMrsCi bisInspWagaSapRgstrMrsCi = vo.getBisInspWagaSapRgstrMrsCi();
            ExpAndImpUtil.convertBeanToMap(bisInspWagaSapRgstrMrsCi, bisInspWagaSapRgstrMrsCiArrays, map, WagaSapFieldFromatExp.class);
            //工程实体
            BisInspWagaSapRgstrPnIf bisInspWagaSapRgstrPnIf = vo.getBisInspWagaSapRgstrPnIf();
            ExpAndImpUtil.convertBeanToMap(bisInspWagaSapRgstrPnIf, bisInspWagaSapRgstrPnIfArrays, map, WagaSapFieldFromatExp.class);
            //安全管理
            BisInspWagaSapRgstrSfMng bisInspWagaSapRgstrSfMng = vo.getBisInspWagaSapRgstrSfMng();
            ExpAndImpUtil.convertBeanToMap(bisInspWagaSapRgstrSfMng, bisInspWagaSapRgstrSfMngArrays, map, WagaSapFieldFromatExp.class);
            //基本情况
            BisInspWagaSapRgstrBase bisInspWagaSapRgstrBase = vo.getBisInspWagaSapRgstrBase();
            ExpAndImpUtil.convertBeanToMap(bisInspWagaSapRgstrBase, bisInspWagaSapRgstrBaseArrays, map, WagaSapFieldFromatExp.class);
            dataList.add(map);
        });
        return dataList;
    }

    @Override
    public int insertIntoData(List<LinkedHashMap<String, Object>> showDataList, FileParam param) throws Exception {
        String persId = param.getPersId();
        for (LinkedHashMap<String, Object> map : showDataList) {
            String rgstrId;
            BisInspRgstrDto bisInspRgstrDto = (BisInspRgstrDto) ExpAndImpUtil.convertMapToBean(BisInspRgstrDto.class, map);
            if (StringUtils.isNotBlank(bisInspRgstrDto.getRgstrId())) {
                //修改登记表
                rgstrId = bisInspRgstrDto.getRgstrId();
                BisInspWagaSapRgstr bisInspWagaSapRgstr = new BisInspWagaSapRgstr();
                BeanUtils.copyProperties(bisInspRgstrDto, bisInspWagaSapRgstr);
                bisInspWagaSapRgstr.setPersId(persId);
                bisInspWagaSapRgstr.setUptm(new Date());
                bisInspWagaSapRgstr.setSapName(bisInspRgstrDto.getNm());
                bisInspWagaSapRgstr.setAdName(bisInspRgstrDto.getProvince());
                bisInspWagaSapRgstr.setId(rgstrId);
                bisInspWagaSapRgstrDao.update(bisInspWagaSapRgstr);
            } else {
                String id = UuidUtil.uuid();
                rgstrId = id;
                BisInspWagaSapRgstr bisInspWagaSapRgstr = new BisInspWagaSapRgstr();
                BeanUtils.copyProperties(bisInspRgstrDto, bisInspWagaSapRgstr);
                AttWagaSapBaseParam base = new AttWagaSapBaseParam();
                base.setSapName(bisInspRgstrDto.getNm());
                List<AttWagaSapBase> baseList = attWagaSapBaseDao.findList(base);
                if (CollectionUtils.isEmpty(baseList)) {
                    continue;
                }
                AttWagaSapBase attWagaSapBase = baseList.get(0);
                BeanUtils.copyProperties(attWagaSapBase, bisInspWagaSapRgstr);
                String ObjUuid = UuidUtil.uuid();
                BisInspAllObj bisInspAllObj = new BisInspAllObj();
                bisInspAllObj.setCode(attWagaSapBase.getId());
                bisInspAllObj.setId(param.getGroupId());
                bisInspAllObj.setNm(attWagaSapBase.getSapName());
                bisInspAllObj.setLgtd(attWagaSapBase.getGdX());
                bisInspAllObj.setLttd(attWagaSapBase.getGdY());
                bisInspAllObj.setObjId(ObjUuid);
                bisInspAllObj.setPtype("29");
                bisInspAllObjDao.insert(bisInspAllObj);
                bisInspWagaSapRgstr.setId(id);
                bisInspWagaSapRgstr.setPersId(persId);
                bisInspWagaSapRgstr.setIntm(new Date());
                bisInspWagaSapRgstr.setUptm(new Date());
                bisInspWagaSapRgstr.setSapName(bisInspRgstrDto.getNm());
                bisInspWagaSapRgstr.setAdName(bisInspRgstrDto.getProvince());
                bisInspWagaSapRgstr.setObjId(ObjUuid);
                bisInspWagaSapRgstrDao.insert(bisInspWagaSapRgstr);
            }
            if (StringUtils.isBlank(rgstrId)) {
                continue;
            }
            //日常管理与维护
            insertDamif(persId, map, rgstrId);
            //管理体系
            insertMrsCi(persId, map, rgstrId);
            //工程实体
            insertPnif(persId, map, rgstrId);
            //安全管理
            insertSfMng(persId, map, rgstrId);
            //基本情况
            insertBase(persId, map, rgstrId);
        }
        return 0;
    }

    private void insertDamif(String persId, LinkedHashMap<String, Object> map, String rgstrId) throws IllegalAccessException, InstantiationException {
        BisInspWagaSapRgstrDamIf damIf = (BisInspWagaSapRgstrDamIf) ExpAndImpUtil.convertMapToBean(BisInspWagaSapRgstrDamIf.class, map);
        BisInspWagaSapRgstrDamIfParam damIfParam = new BisInspWagaSapRgstrDamIfParam();
        damIfParam.setRgstrId(rgstrId);
        List<BisInspWagaSapRgstrDamIf> damIfDaoList = bisInspWagaSapRgstrDamIfDao.findList(damIfParam);
        if (CollectionUtils.isNotEmpty(damIfDaoList)) {
            damIf.setUptm(new Date());
            damIf.setId(damIfDaoList.get(0).getId());
            damIf.setRecPersId(persId);
            bisInspWagaSapRgstrDamIfDao.update(damIf);
        } else {
            damIf.setId(UuidUtil.uuid());
            damIf.setIntm(new Date());
            damIf.setUptm(new Date());
            damIf.setRecPersId(persId);
            bisInspWagaSapRgstrDamIfDao.insert(damIf);
        }
    }

    private void insertMrsCi(String persId, LinkedHashMap<String, Object> map, String rgstrId) throws IllegalAccessException, InstantiationException {
        BisInspWagaSapRgstrMrsCi mrsCi = (BisInspWagaSapRgstrMrsCi) ExpAndImpUtil.convertMapToBean(BisInspWagaSapRgstrMrsCi.class, map);
        BisInspWagaSapRgstrMrsCiParam mrsCiParam = new BisInspWagaSapRgstrMrsCiParam();
        mrsCiParam.setRgstrId(rgstrId);
        List<BisInspWagaSapRgstrMrsCi> mrsCiDaoList = bisInspWagaSapRgstrMrsCiDao.findList(mrsCiParam);
        if (CollectionUtils.isNotEmpty(mrsCiDaoList)) {
            mrsCi.setUptm(new Date());
            mrsCi.setRecPersId(persId);
            mrsCi.setId(mrsCiDaoList.get(0).getId());
            bisInspWagaSapRgstrMrsCiDao.update(mrsCi);
        } else {
            mrsCi.setIntm(new Date());
            mrsCi.setUptm(new Date());
            mrsCi.setId(UuidUtil.uuid());
            mrsCi.setRecPersId(persId);
            bisInspWagaSapRgstrMrsCiDao.insert(mrsCi);
        }
    }

    private void insertPnif(String persId, LinkedHashMap<String, Object> map, String rgstrId) throws IllegalAccessException, InstantiationException {
        BisInspWagaSapRgstrPnIf pnIf = (BisInspWagaSapRgstrPnIf) ExpAndImpUtil.convertMapToBean(BisInspWagaSapRgstrPnIf.class, map);
        BisInspWagaSapRgstrPnIfParam pnIfParam = new BisInspWagaSapRgstrPnIfParam();
        pnIfParam.setRgstrId(rgstrId);
        List<BisInspWagaSapRgstrPnIf> pnIfDaoList = bisInspWagaSapRgstrPnIfDao.findList(pnIfParam);
        if (CollectionUtils.isNotEmpty(pnIfDaoList)) {
            pnIf.setId(pnIfDaoList.get(0).getId());
            pnIf.setUptm(new Date());
            pnIf.setRecPersId(persId);
            bisInspWagaSapRgstrPnIfDao.update(pnIf);
        } else {
            pnIf.setId(UuidUtil.uuid());
            pnIf.setUptm(new Date());
            pnIf.setIntm(new Date());
            pnIf.setRecPersId(persId);
            bisInspWagaSapRgstrPnIfDao.insert(pnIf);
        }
    }

    private void insertSfMng(String persId, LinkedHashMap<String, Object> map, String rgstrId) throws IllegalAccessException, InstantiationException {
        BisInspWagaSapRgstrSfMng sfMng = (BisInspWagaSapRgstrSfMng) ExpAndImpUtil.convertMapToBean(BisInspWagaSapRgstrSfMng.class, map);
        BisInspWagaSapRgstrSfMngParam sfMngParam = new BisInspWagaSapRgstrSfMngParam();
        sfMngParam.setRgstrId(rgstrId);
        List<BisInspWagaSapRgstrSfMng> sfMngDaoList = bisInspWagaSapRgstrSfMngDao.findList(sfMngParam);
        if (CollectionUtils.isNotEmpty(sfMngDaoList)) {
            sfMng.setUptm(new Date());
            sfMng.setRecPersId(persId);
            sfMng.setId(sfMngDaoList.get(0).getId());
            bisInspWagaSapRgstrSfMngDao.update(sfMng);
        } else {
            sfMng.setUptm(new Date());
            sfMng.setRecPersId(persId);
            sfMng.setId(UuidUtil.uuid());
            sfMng.setIntm(new Date());
            bisInspWagaSapRgstrSfMngDao.insert(sfMng);
        }
    }

    private void insertBase(String persId, LinkedHashMap<String, Object> map, String rgstrId) throws IllegalAccessException, InstantiationException {
        BisInspWagaSapRgstrBase base = (BisInspWagaSapRgstrBase) ExpAndImpUtil.convertMapToBean(BisInspWagaSapRgstrBase.class, map);
        BisInspWagaSapRgstrBaseParam baseParam = new BisInspWagaSapRgstrBaseParam();
        baseParam.setRgstrId(rgstrId);
        List<BisInspWagaSapRgstrBase> baseList = bisInspWagaSapRgstrBaseDao.findList(baseParam);
        if (CollectionUtils.isNotEmpty(baseList)) {
            base.setUptm(new Date());
            base.setRecPersId(persId);
            base.setId(baseList.get(0).getId());
            bisInspWagaSapRgstrBaseDao.update(base);
        } else {
            base.setUptm(new Date());
            base.setRecPersId(persId);
            base.setId(UuidUtil.uuid());
            base.setIntm(new Date());
            bisInspWagaSapRgstrBaseDao.insert(base);
        }
    }


}