package com.fzzy.async.fzzy40.impl; import com.fzzy.api.Constant; import com.fzzy.api.entity.Api1105; import com.fzzy.api.entity.Api1209; import com.fzzy.api.entity.Api1210; 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.view.repository.Api1209Rep; import com.fzzy.api.view.repository.Api1210Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.fzzy40.entity.Fz40InoutLossOver; import com.fzzy.async.fzzy40.entity.Fz40InoutVarietyChange; import com.fzzy.async.fzzy40.repository.Fzzy40Sync1209Rep; import com.fzzy.async.fzzy40.repository.Fzzy40Sync1210Rep; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; 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 Fzzy40Sync1210 { @Autowired private Fzzy40Sync1210Rep fzzySync1210Rep; @Autowired private Api1210Rep api1210Rep; @Autowired private ApiCommonService commonService; @Autowired private ApiTriggerService apiTriggerService; @Autowired private ApiLogRep apiLogRep; public void syncData(String kqdm, String deptId, Date start, Date end) { log.info("-------------1210接口数据开始同步------------------"); //同步数据,只记录失败的信息 ApiLog apiLog = new ApiLog(); apiLog.setType(ApiLog.TYPE_SYNC); apiLog.setKqdm(deptId); apiLog.setUploadTime(new Date()); apiLog.setInteId(Constant.API_CODE_1209); apiLog.setStatus(99); apiLog.setId(ContextUtil.getUUID()); try { List list = fzzySync1210Rep.listVarietyChange(deptId, start, end); if (null == list || list.isEmpty()) { log.info("-------------没有获取到性质转变信息------------------"); return; } Api1210 apiData; Api1105 api1105; List api1210List; for (Fz40InoutVarietyChange sysData : list) { //获取货位信息 api1105 = commonService.getApi1105Cache(sysData.getDepotId()); if (null == api1105) { continue; } apiData = new Api1210(); apiData.setLsxzzbdh(api1105.getHwdm() + sysData.getId()); apiData.setHwdm(api1105.getHwdm()); apiData.setLssl(sysData.getNumber()); apiData.setHzsl(sysData.getChangeNumber()); apiData.setBzwh(sysData.getApprovalId()); String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety().substring(0, 3)); apiData.setLspzdm(mappingCode); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType()); apiData.setHzqlsxzdm(mappingCode); mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getNewFoodType()); apiData.setHzhlsxzdm(mappingCode); apiData.setHzrq(sysData.getChangeTime()); apiData.setCcshr(sysData.getCcshr()); apiData.setZjshr(sysData.getZjshr()); apiData.setTjshr(sysData.getTjshr()); apiData.setKjshr(sysData.getKjshr()); apiData.setLdshr(sysData.getLdshr()); apiData.setBz(sysData.getRemark()); apiData.setZhgxsj(new Date()); //业务id、库区编码、同步时间 apiData.setBizId(sysData.getId()); apiData.setKqdm(kqdm); apiData.setSyncTime(new Date()); api1210List = api1210Rep.getDataById(apiData.getLsxzzbdh()); if(null == api1210List || api1210List.isEmpty()){ apiData.setCzbz(Constant.CZBZ_I); }else { if(StringUtils.isNotEmpty(api1210List.get(0).getJhmxdh())){ apiData.setJhmxdh(api1210List.get(0).getJhmxdh()); } apiData.setCzbz(api1210List.get(0).getCzbz()); } //保存数据 api1210Rep.save(apiData); } } catch (Exception e) { log.error("---同步失败----{}", e); apiLog.setResult("同步失败:" + e.getMessage()); apiLogRep.save(apiLog); } } }