fj-dc/.svn/pristine/28/286ea655cb938b66ac065135e11ffee3c3ed6b5e.svn-base

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

import cn.com.goldenwater.core.service.AbstractCrudService;
import cn.com.goldenwater.dcproj.constValue.CommonLabel;
import cn.com.goldenwater.dcproj.constValue.SplitValue;
import cn.com.goldenwater.dcproj.dao.*;
import cn.com.goldenwater.dcproj.model.*;
import cn.com.goldenwater.dcproj.param.BisInspRsvrPblmMendParam;
import cn.com.goldenwater.dcproj.param.GwComFileParam;
import cn.com.goldenwater.dcproj.service.AttRsBaseService;
import cn.com.goldenwater.dcproj.service.BisInspRsvrPblmMendService;
import cn.com.goldenwater.dcproj.service.GwComFileService;
import cn.com.goldenwater.dcproj.utils.*;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import net.sf.json.JsonConfig;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

/**
 * @author lune
 * @date 2020-7-7
 */
@Service
public class BisInspRsvrPblmMendServiceImpl extends AbstractCrudService<BisInspRsvrPblmMend, BisInspRsvrPblmMendParam> implements BisInspRsvrPblmMendService {

    private Logger logger = LoggerFactory.getLogger(BisInspRsvrPblmMendServiceImpl.class);
    private static String accessToken = "";
    @Value("${mwr.ducha.url}")
    private String quanguoUrl;
    @Value("${hunan.phone}")
    private String phone;
    @Value("${quanguocode}")
    private String smscode;
    @Value("${getFile.prefix}")
    public String prefix;
    @Autowired
    private OlBisInspOrgDao olBisInspOrgDao;
    @Autowired
    private BisInspRsvrPblmMendDao bisInspRsvrPblmMendDao;
    @Autowired
    private GwComFileDao gwComFileDao;
    @Autowired
    private AttAdBaseDao attAdBaseDao;
    @Value("${web.upload-path}")
    public String fileDir;

    @Autowired
    private BisInspRsvrRgstrDao bisInspRsvrRgstrDao;

    @Autowired
    private GwComFileService gwComFileService;

    public BisInspRsvrPblmMendServiceImpl(BisInspRsvrPblmMendDao bisInspRsvrPblmMendDao) {
        super(bisInspRsvrPblmMendDao);
        this.bisInspRsvrPblmMendDao = bisInspRsvrPblmMendDao;
    }


    @Override
    public PageInfo<BisInspRsvrPblmMend> findRsvrPblmPage(BisInspRsvrPblmMendParam bisInspRsvrPblmMendParam) {
        if (StringUtils.isNotBlank(bisInspRsvrPblmMendParam.getAdCode())) {
            bisInspRsvrPblmMendParam.setAdCode(AdLevelUtil.SubAd(bisInspRsvrPblmMendParam.getAdCode()).get(SplitValue.SUBAD).toString());
        }
        PageHelper.startPage(bisInspRsvrPblmMendParam);
        List<BisInspRsvrPblmMend> result = bisInspRsvrPblmMendDao.findRsvrPblmList(bisInspRsvrPblmMendParam);
        if (result.size() > 0) {
            result.forEach(mend -> {
                List<GwComFile> gwComFiles = gwComFileDao.findFileByBiz(mend.getId());
                if (gwComFiles != null && gwComFiles.size() > 0) {
                    gwComFiles = gwComFiles.stream().filter(file -> "MEND_EXTRA".equals(file.getBizType())).collect(Collectors.toList());
                }
                mend.setGwComFiles(gwComFiles);
            });
        }
        PageInfo<BisInspRsvrPblmMend> pageInfo = new PageInfo<>(result);
        return pageInfo;
    }

    /**
     * 每日凌晨一点定时导入小水库问题数据
     */
    @Override
    public void getQuanguo() {
        //登录
        BisInspAllRlationPers bisInspAllRlationPers = this.login();
        Map<String, String> params = new HashMap<>();
        if (bisInspAllRlationPers != null) {
            Map<String, String> headerMap = new HashMap<>();
            headerMap.put(CommonLabel.ACCESS_TOKEN, accessToken);
            headerMap.put(CommonLabel.PERSID, bisInspAllRlationPers.getGuid());
            List<AttAdBase> attAdBases = attAdBaseDao.getAdData("000000000000");
            Calendar calendar = Calendar.getInstance();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String entm = DateUtils.Calendar2Str(calendar, "yyyy-MM-dd HH:mm:ss");
            calendar.add(Calendar.DAY_OF_MONTH, -3);//今天的时间减三天
            String sttm = DateUtils.Calendar2Str(calendar, "yyyy-MM-dd HH:mm:ss");
            logger.info("-------------开始导入部里数据----------------");
            for (AttAdBase attAdBase : attAdBases) {
                //设置省份导入
                String adCode = attAdBase.getAdCode();
                params.put("adCode", AdLevelUtil.getAddvcd(adCode));
                /*params.put("adCode", "53");*/
                params.put("startTime", sttm);
                params.put("endTime", entm);
                List<BisInspRsvrPblmMend> bisInspRsvrPblmMends = getBisInspRects(bisInspAllRlationPers, params, headerMap);
                //获取小水库数据并插入本地库
//                insertRsvr(bisInspRsvrPblmMends, bisInspAllRlationPers, params, headerMap);
                bisInspRsvrPblmMends.stream().forEach(bisInspRsvrPblmMend -> {
                    bisInspRsvrPblmMendDao.insertRsvr(bisInspRsvrPblmMend);
                    //插入附件信息，下载附件文件
                    String fileBizId = bisInspRsvrPblmMend.getId();
                    if (downloadFile(fileBizId, headerMap)) {
                        //下载成功
                        logger.info("下载成功");
                    } else {
                        //下载失败
                        logger.info("下载失败");
                    }
                    //如果附件已经插入则放弃，如果没有则进行插入
                });
            }
            logger.info("-------------导入部里数据结束----------------");
        }
    }

    /**
     * 调用部里登录接口
     *
     * @return
     */
    public BisInspAllRlationPers login() {
        String apiUrl = quanguoUrl + "/bis/insp/loginByCode";
        Map<String, String> params = new HashMap<>();
        params.put("phone", phone);
        params.put("code", smscode);
        String content = HttpClientUtils.doHttpsPost(apiUrl, params, new HashedMap());
        JSONObject jsonObject = JSONObject.fromObject(content);
        //登录结果返回
        if (jsonObject != null && jsonObject.size() > 3) {
            //获取token
            accessToken = jsonObject.getString(CommonLabel.ACCESS_TOKEN);
            String data = jsonObject.getString("data");
            JSONObject object = JSONObject.fromObject(data);
            return (BisInspAllRlationPers) JSONObject.toBean(object, BisInspAllRlationPers.class);
        }
        return new BisInspAllRlationPers();
    }

    /**
     * 下发通知，问题反馈
     *
     * @param params
     * @param headerMap
     * @param
     */
    private void sendInform(Map<String, String> params, Map<String, String> headerMap, List<BisInspRsvrPblmMend> bisInspRsvrPblmMends) {
      /*  String rectIds = rectList.stream().map(n -> n.getId()).collect(Collectors.joining(","));
        params.clear();
        params.put("rectIds", rectIds);
        String rectpblmUrl = quanguoUrl + "/api/bis/insp/rect/findRecPblmListByRectIds";
        HttpClientUtils.doHttpsPost(rectpblmUrl, params, headerMap);
        //通知下发成功，更改获取通知状态
        String rectMsgUrl = quanguoUrl + "/api/bis/insp/rect/restRectByIds";
        HttpClientUtils.doHttpsPost(rectMsgUrl, params, headerMap);
        //问题反馈成功，信息反馈(未部署)
        String rectPortUrl = quanguoUrl + "/api/bis/insp/rect/restRectPblmByIds";
        HttpClientUtils.doHttpsPost(rectPortUrl, params, headerMap);*/
    }

    /**
     * 获取小水库数据并插入本地库
     *
     * @param bisInspAllRlationPers
     * @param params
     * @param headerMap
     */
    private void insertRsvr(List<BisInspRsvrPblmMend> bisInspRsvrPblmMends, BisInspAllRlationPers bisInspAllRlationPers, Map<String, String> params, Map<String, String> headerMap) {
  /*      List<BisInspRsvrPblmMend> list = new ArrayList<>();
        int delDataStep = 0;
        for (int i = 0; i < bisInspRsvrPblmMends.size(); i++) {
            list.add(bisInspRsvrPblmMends.get(i));
            delDataStep++;
            if (delDataStep == 50) {
                bisInspRsvrPblmMendDao.insertRsvr(list);
                list.clear();
                delDataStep = 0;
            }
            if (i == bisInspRsvrPblmMends.size() - 1) {
                bisInspRsvrPblmMendDao.insertRsvr(list);
                list.clear();
            }
        }*/
    }

    /**
     * 下载数据
     *
     * @param bisInspAllRlationPers
     * @param params
     * @param headerMap
     * @return
     */
    private List<BisInspRsvrPblmMend> getBisInspRects(BisInspAllRlationPers bisInspAllRlationPers, Map<String, String> params, Map<String, String> headerMap) {
        //OlBisInspOrg olBisInspOrg = olBisInspOrgDao.get(bisInspAllRlationPers.getOrgId());
        //获取用户相关信息
        String rectUrl = quanguoUrl + "/bis/insp/rsvr/pblm/mend/downLoadRsvrList";
        Calendar date = Calendar.getInstance();
        params.put("year", String.valueOf(date.get(Calendar.YEAR)));
        params.put("mnth", String.valueOf(date.get(Calendar.MONTH) + 1));
        //params.put("rsName", "弄贯(二)水库");
        String rectContent = "";
        try {
            rectContent = HttpClientUtils.doHttpsPost2(rectUrl, params, headerMap);
            JSONObject jsonObject = JSONObject.fromObject(rectContent);
            JSONArray jsonArray = jsonObject.getJSONArray("data");
            List<BisInspRsvrPblmMend> bisInspRsvrPblmMends;
            bisInspRsvrPblmMends = JSONArray.toList(jsonArray, new BisInspRsvrPblmMend(), new JsonConfig());
            return bisInspRsvrPblmMends;
        } catch (Exception e) {
            logger.info(rectContent);
            logger.info(e.getMessage());
            return null;
        }
    }

    /**
     * 手动导入小水库数据
     *
     * @param bisInspRsvrPblmMendParam
     */
    @Override
    public void importRsvrData(BisInspRsvrPblmMendParam bisInspRsvrPblmMendParam) {
        //调用部里登录接口
        BisInspAllRlationPers bisInspAllRlationPers = this.login();
        Map<String, String> params = new HashMap<>();
        if (bisInspAllRlationPers != null) {
            Map<String, String> headerMap = new HashMap<>();
            headerMap.put(CommonLabel.ACCESS_TOKEN, accessToken);
            headerMap.put(CommonLabel.PERSID, bisInspAllRlationPers.getGuid());
            //获取用户相关信息
            List<AttAdBase> attAdBases = attAdBaseDao.getAdData("000000000000");
            for (AttAdBase attAdBase : attAdBases) {
                String adCode = attAdBase.getAdCode();
                params.put("adCode", AdLevelUtil.getAddvcd(adCode));
                List<BisInspRsvrPblmMend> bisInspRsvrPblmMends = getBisInspRects(bisInspAllRlationPers, params, headerMap);
                //获取小水库数据并插入本地库
                /*insertRsvr(bisInspRsvrPblmMends, bisInspAllRlationPers, params, headerMap);*/
                bisInspRsvrPblmMends.stream().forEach(bisInspRsvrPblmMend -> {
                    bisInspRsvrPblmMendDao.insertRsvr(bisInspRsvrPblmMend);

                });
            }
        }
    }

    public Boolean downloadFile(String bizId, Map<String, String> headerMap) {

        String rectUrl = quanguoUrl + "/file/findFileByBiz?bizId=" + bizId;
        Map<String, String> params = new HashMap<>();
        //params.put("bizId", bizId);
        String rectContent = "";
        try {
            rectContent = HttpClientUtils.doHttpsPost(rectUrl, params, headerMap);
            JSONObject jsonObject = JSONObject.fromObject(rectContent);
            JSONArray jsonArray = jsonObject.getJSONArray("data");
            List<GwComFile> gwComFiles;
            gwComFiles = JSONArray.toList(jsonArray, new GwComFile(), new JsonConfig());
            //拼接 访问地址做下载
            for (GwComFile gwComFile : gwComFiles
            ) {
                String path = quanguoUrl + "/" + gwComFile.getFilePath();
                fileDir = fileDir.replace("upload/", "");
                String dirPath = fileDir + gwComFile.getFilePath().substring(0, gwComFile.getFilePath().lastIndexOf("/"));
                File pathFile = new File(dirPath);
                if (!pathFile.exists()) {
                    pathFile.mkdirs();
                }
                ;
                HttpsDownloadUtils.downloadFile(path, fileDir + gwComFile.getFilePath());

                //插入插入本地数据库记录
                if (null != gwComFileService.get(gwComFile.getId())) {
                    gwComFileService.update(gwComFile);
                } else {
                    gwComFileService.insert(gwComFile);
                }
            }
            return true;
        } catch (Exception ex) {
            logger.info(rectContent);
            logger.info(ex.getMessage());
            return false;
        }
    }


    @Override
    public void updRevwInfo() {
        //调用部里登录接口
        BisInspAllRlationPers bisInspAllRlationPers = this.login();
        Map<String, String> params = new HashMap<>();
        String mwrUrl = quanguoUrl + "/bis/insp/rsvr/pblm/mend/findRsvrList";
        Map<String, String> headerMap = new HashMap<>();
        headerMap.put(CommonLabel.ACCESS_TOKEN, accessToken);
        headerMap.put(CommonLabel.PERSID, bisInspAllRlationPers.getGuid());
        params.put("revwInfo", "revwInfo");
        params.put("persGuid", bisInspAllRlationPers.getGuid());
        String mwrContent = HttpClientUtils.doHttpsPost2(mwrUrl, params, headerMap);
        JSONObject jsonObject = JSONObject.fromObject(mwrContent);
        JSONArray mwrJsonArray = jsonObject.getJSONArray("data");
        List<BisInspRsvrPblmMend> bisInspRsvrPblmMends = JSONArray.toList(mwrJsonArray, new BisInspRsvrPblmMend(), new JsonConfig());
        for (BisInspRsvrPblmMend bisInspRsvrPblmMend : bisInspRsvrPblmMends) {
            bisInspRsvrPblmMendDao.updateRevwInfo(bisInspRsvrPblmMend.getId(), bisInspRsvrPblmMend.getRevwInfo());
        }
    }

    @Override
    public int update2021(BisInspRsvrPblmMend bisInspRsvrPblmMend) {
        int update = update(bisInspRsvrPblmMend);

        BisInspRsvrRgstr bisInspRsvrRgstr = new BisInspRsvrRgstr();
        String rgstrId = bisInspRsvrPblmMend.getRgstrId();
        bisInspRsvrRgstr.setRgstrId(rgstrId);

        BisInspRsvrPblmMendParam mendParam = new BisInspRsvrPblmMendParam();
        mendParam.setRsCode(bisInspRsvrPblmMend.getRsCode());
//        mendParam.setRsName(bisInspRsvrPblmMend.getRsName());
//        mendParam.setAdCode(bisInspRsvrPblmMend.getAdCode());
        List<BisInspRsvrPblmMend> mendList = findList(mendParam);
        if (mendList != null) { //统计所有问题的状态得出登记表状态
            String rectState = "2";//要求前端校验提交的数据(即当前修改的问题必须有值)
            for (BisInspRsvrPblmMend mend : mendList) {
                if (mend.getRevwState() == null || !"2".equals(mend.getRevwState())) {
                    rectState = "1";
                    break;
                }
            }
            bisInspRsvrRgstr.setRectStat(rectState);
        }

        BisInspRsvrRgstr rgstr = bisInspRsvrRgstrDao.get(rgstrId);
        if (rgstr != null) {
            if (!Constant.STRING_TWO.equals(rgstr.getState())) {
                bisInspRsvrRgstr.setState(Constant.STRING_ONE);
            }
            bisInspRsvrRgstrDao.update(bisInspRsvrRgstr);
        }
        List<GwComFile> gwComFiles = bisInspRsvrPblmMend.getGwComFiles();
        // 为 佐证材料 类的文件 不能删除，所以直接加上
        GwComFileParam param = new GwComFileParam();
        param.setBizId(bisInspRsvrPblmMend.getId());
        param.setBizType("MEND_PROV");
        List<GwComFile> prov = gwComFileService.findList(param);
        if (gwComFiles != null && gwComFiles.size() > 0) {
            if (prov != null) gwComFiles.addAll(prov);
            gwComFileService.updateBiz(gwComFiles, bisInspRsvrPblmMend.getId());
        }
        return 0;
    }

    @Autowired
    private AttRsBaseService attRsBaseService;

    @Override
    public int insert2021(BisInspRsvrPblmMend bisInspRsvrPblmMend) {
        Optional.ofNullable(bisInspRsvrPblmMend).map(BisInspRsvrPblmMend::getRsCode).ifPresent(rsCode -> {
            AttRsBase attRsBase = attRsBaseService.get(rsCode);
            Optional.ofNullable(attRsBase).ifPresent(base -> {
                bisInspRsvrPblmMend.setEngScal(base.getEngScal());
                bisInspRsvrPblmMend.setRsName(base.getRsName());
            });
        });

        int insert = insert(bisInspRsvrPblmMend);

        BisInspRsvrRgstr bisInspRsvrRgstr = new BisInspRsvrRgstr();
        String rgstrId = bisInspRsvrPblmMend.getRgstrId();
        bisInspRsvrRgstr.setRgstrId(rgstrId);

        BisInspRsvrPblmMendParam mendParam = new BisInspRsvrPblmMendParam();
//        mendParam.setRsCode(bisInspRsvrPblmMend.getRsCode());
        mendParam.setRsName(bisInspRsvrPblmMend.getRsName());
        mendParam.setAdCode(bisInspRsvrPblmMend.getAdCode());
        List<BisInspRsvrPblmMend> mendList = findList(mendParam);
        if (mendList != null) { //统计所有问题的状态得出登记表状态
            String rectState = "2";//要求前端校验提交的数据(即当前修改的问题必须有值)
            for (BisInspRsvrPblmMend mend : mendList) {
                if (mend.getRevwState() == null || !mend.getRevwState().equals("2")) {
                    rectState = "1";
                    break;
                }
            }
            bisInspRsvrRgstr.setRectStat(rectState);
        }

        BisInspRsvrRgstr rgstr = bisInspRsvrRgstrDao.get(rgstrId);
        if (rgstr != null) {
            if (!Constant.STRING_TWO.equals(rgstr.getState())) {
                bisInspRsvrRgstr.setState(Constant.STRING_ONE);
            }
            bisInspRsvrRgstrDao.update(bisInspRsvrRgstr);
        }
        List<GwComFile> gwComFiles = bisInspRsvrPblmMend.getGwComFiles();
        if (gwComFiles != null && gwComFiles.size() > 0) {
            gwComFileService.updateBiz(gwComFiles, bisInspRsvrPblmMend.getId());
        }
        return 0;
    }

    @Override
    public PageInfo<BisInspRsvrPblmMend> pagerPc(BisInspRsvrPblmMendParam bisInspRsvrPblmMendParam) {
        PageHelper.startPage(bisInspRsvrPblmMendParam);
        List<BisInspRsvrPblmMend> list = bisInspRsvrPblmMendDao.findList(bisInspRsvrPblmMendParam);
        return new PageInfo<>(list);
    }
}