package com.fzzy.async.whhpjl.impl; import com.alibaba.fastjson.JSON; import com.fzzy.api.Constant; import com.fzzy.api.entity.ApiInfoData; import com.fzzy.api.entity.ApiLog; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.ApiInfoDataRep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.whhpjl.entity.Fz40WhjlDefaultGranary; import com.fzzy.async.whhpjl.repository.Fz40ToWhjlSync1106Rep; import com.fzzy.otherview.whhpjl.WhjlConstant; import com.fzzy.otherview.whhpjl.dto.WhjlApi1107; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; /** * 廒间信息 * * @Author:YAN */ @Slf4j @Component public class Fz40ToWhjlSync1107 { @Autowired private Fz40ToWhjlSync1106Rep fz40ToWhjlSync1106Rep; @Autowired private ApiLogRep apiLogRep; @Autowired private ApiInfoDataRep apiInfoDataRep; /** * 廒间信息 * * @param kqdm * @param deptId * @param start * @param end */ public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1106接口数据开始同步------------------"); //同步数据,只记录失败的信息 ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1106); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { List list = fz40ToWhjlSync1106Rep.listApi1106(deptId.substring(0, 4)); if (null == list || list.isEmpty()) { log.info("-------------没有获取到单位信息------------------"); return; } List apiInfoDataList; WhjlApi1107 apiData; for (Fz40WhjlDefaultGranary sysData : list) { apiData = new WhjlApi1107(); apiData.setAjbh(sysData.getAjdh()); //廒间编号 apiData.setJlqybh(""); //军粮企业编号 apiData.setJlqymc(""); //军粮企业名称 apiData.setJgzdbh(""); //军供站点编号 apiData.setJlqymc(""); //军供站点名称 apiData.setSscfbh(sysData.getCfbh()); //仓房编号 apiData.setSscfmc(""); //仓房名称 apiData.setAjmc(sysData.getAjmc()); //廒间名称 apiData.setAjcd(sysData.getAjcd()); //廒间长度 apiData.setAjkd(sysData.getAjkd()); //廒间宽度 apiData.setAjgd(sysData.getAjgd()); //廒间高度 apiData.setAjsjcr(sysData.getAjsjcr()); //廒间设计仓容 apiData.setAjsjcr01(null); //廒间实际仓容 apiData.setAjlxdh(sysData.getAjlxdh()); //廒间联系电话 apiData.setAjjd(null); //廒间经度 apiData.setAjwd(null); //廒间纬度 apiData.setAjqyrq(sysData.getAjqyrq()); //廒间启用日期 apiData.setAjzt(sysData.getAjzt()); //廒间状态 apiData.setAjsyzt(""); //廒间使用状态 apiData.setSfyx(""); //是否有效 apiData.setBizId(sysData.getAjdh()); apiData.setUpdateTime(new Date()); //持久化保存,单独存入非国标接口表 ApiInfoData infoData = new ApiInfoData(); infoData.setId(sysData.getAjdh()); infoData.setKqdm(kqdm); infoData.setInteType(WhjlConstant.API_CATEGORY_11); infoData.setInteId(WhjlConstant.API_CODE_1106); infoData.setUpdateTime(new Date()); infoData.setDataId(sysData.getAjdh()); infoData.setRemarks("备注信息"); //设置操作标志 apiInfoDataList = apiInfoDataRep.getDataByDataId(infoData.getDataId()); if (null == apiInfoDataList || apiInfoDataList.isEmpty()) { apiData.setCzbz(Constant.CZBZ_I); infoData.setCzbz(Constant.CZBZ_I); } else { apiData.setCzbz(apiInfoDataList.get(0).getCzbz()); infoData.setCzbz(apiInfoDataList.get(0).getCzbz()); } infoData.setData(JSON.toJSONString(apiData)); apiInfoDataRep.save(infoData); log.info("1106---廒间-同步数据:{}", apiData.toString()); } } catch (Exception e) { log.error("---1106廒间-同步数据执行失败----{}", e.getMessage()); apiLog.setResult("1106廒间信息同步失败:" + e.getMessage()); apiLogRep.save(apiLog); } } }