package com.fzzy.async.fzzy40.impl; import com.fzzy.api.Constant; import com.fzzy.api.entity.Api1105; import com.fzzy.api.entity.Api1205; import com.fzzy.api.entity.ApiLog; import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.service.ApiTriggerService; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.utils.DateUtil; import com.fzzy.api.view.repository.Api1205Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.fzzy40.entity.Fz40InoutNoticeOut; import com.fzzy.async.fzzy40.entity.Fz40InoutRecord; import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep; import com.fzzy.async.fzzy40.repository.Fzzy40SyncNoticeOutRep; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.time.DateFormatUtils; import org.apache.commons.lang.time.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.util.*; /** * 粮食出库信息 */ @Slf4j @Component public class Fzzy40Sync1205 { /** * 出库类型 */ private final static String INOUT_TYPE_OUT = "OUT"; @Autowired private Fzzy40Sync1202Rep fzzySync1202Rep; @Autowired private Fzzy40SyncNoticeOutRep fzzySyncNoticeOutRep; @Autowired private ApiTriggerService apiTriggerService; @Autowired private Api1205Rep api1205Rep; @Autowired private ApiCommonService commonService; @Autowired private ApiLogRep apiLogRep; /** * 粮食出库信息 * * @param deptId * @param start * @param end */ public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1205接口数据开始同步------------------"); //同步数据，只记录失败的信息 ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1205); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { //获取粮食出库信息，根据流程完成时间获取 List list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_OUT, start, end); if (null == list || list.isEmpty()) { log.info("-------------没有获取到粮食出库信息------------------"); return; } Api1205 apiData; Api1105 api1105; List listInoutNotice; List api1205List; for (Fz40InoutRecord sysData : list) { if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){ sysData.setRecordWeight(sysData.getSettleWeight()); } //判断净重是否大于0，等于0表示不合格，不进行同步上传 if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){ continue; } //获取货位信息 api1105 = commonService.getApi1105Cache(sysData.getDepotId()); if(null == api1105){ continue; } apiData = new Api1205(); apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4)); //判断业务时间与单据号是否匹配，若不匹配，则更改业务时间为单据号所在的时间 SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd"); Date time = dateFormat.parse(sysData.getId().substring(2, 10)); int numDay = DateUtil.difDay(DateUtil.getCurZero(sysData.getCompleteTime()), DateUtil.getCurZero(time)); if(numDay != 0){ sysData.setFullWeightTime(DateUtils.addDays(sysData.getFullWeightTime(), numDay)); sysData.setEmptyWeightTime(DateUtils.addDays(sysData.getEmptyWeightTime(), numDay)); sysData.setCompleteTime(DateUtils.addDays(sysData.getCompleteTime(), numDay)); } //货位代码 apiData.setHwdm(api1105.getHwdm()); apiData.setYwlx(Constant.INOUT_TYPE_1); //通知单号 apiData.setCktzdh(sysData.getNoticeId()); apiData.setYwrq(sysData.getRegisterTime()); //获取合同号 listInoutNotice = fzzySyncNoticeOutRep.listInoutNoticeOutById(sysData.getNoticeId()); if(null != listInoutNotice && listInoutNotice.size() >0){ apiData.setHth(api1105.getHwdm().substring(0,18) + listInoutNotice.get(0).getContractId()); }else { apiData.setHth(api1105.getHwdm().substring(0,18) + apiData.getCkywdh()); } //运输工具，若为空，则默认给1-汽车 apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1":sysData.getTransType()); //车船号 apiData.setCch(sysData.getPlateNum()); apiData.setDjsj(sysData.getRegisterTime()); //粮食品种 String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety()); apiData.setLspzdm(mappingCode); //粮食等级 mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel()); apiData.setLsdjdm(mappingCode); //粮食性质 mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType()); apiData.setLsxzdm(mappingCode); apiData.setShnd(StringUtils.isEmpty(sysData.getFoodYear())? DateFormatUtils.format(new Date(), "yyyy") :sysData.getFoodYear()); //产地代码 String cddm = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation()); apiData.setCddm(cddm); //皮重信息 apiData.setPz(sysData.getEmptyWeight()); if(sysData.getEmptyWeightTime().before(sysData.getRegisterTime())){ sysData.setEmptyWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 25)); } apiData.setPzjlsj(sysData.getEmptyWeightTime()); apiData.setPzjby(sysData.getEmptyWeightUser()); apiData.setPzjly(sysData.getEmptyWeightUser()); //毛重信息 apiData.setMz(sysData.getFullWeight()); if(sysData.getFullWeightTime().before(sysData.getEmptyWeightTime())){ sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getEmptyWeightTime(), 60)); } apiData.setMzjlsj(sysData.getFullWeightTime()); apiData.setMzjby(sysData.getFullWeightUser()); apiData.setMzjly(sysData.getFullWeightUser()); //净重 apiData.setJz(sysData.getRecordWeight()); if(sysData.getCompleteTime().before(sysData.getFullWeightTime())){ sysData.setCompleteTime(DateUtils.addMinutes(sysData.getFullWeightTime(), 10)); } apiData.setCmsj(sysData.getCompleteTime()); //操作标志及最后更新时间 apiData.setZhgxsj(sysData.getUpdateTime()); //业务id、库区编码、同步时间 apiData.setBizId(sysData.getId()); apiData.setKqdm(kqdm); apiData.setSyncTime(new Date()); log.info("1201---同步数据：{}",apiData.toString()); api1205List = api1205Rep.getDataById(apiData.getCkywdh()); if(null == api1205List || api1205List.isEmpty()){ apiData.setCzbz(Constant.CZBZ_I); }else { apiData.setCzbz(api1205List.get(0).getCzbz()); } //保存数据 api1205Rep.save(apiData); } } catch (Exception e) { log.error("---同步失败----{}", e); apiLog.setResult("同步失败：" + e.getMessage()); apiLogRep.save(apiLog); } } }