package com.fzzy.async.fzzy30.impl; import com.fzzy.api.Constant; import com.fzzy.api.entity.*; import com.fzzy.api.service.ApiCommonService; import com.fzzy.api.utils.ContextUtil; import com.fzzy.api.view.repository.Api1209Rep; import com.fzzy.api.view.repository.ApiLogRep; import com.fzzy.async.fzzy30.entity.MLossOver; import com.fzzy.async.fzzy30.repository.FzzySync1209Rep; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.time.DateFormatUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; /** * 粮食损溢 */ @Slf4j @Component public class Fzzy30Sync1209 { /** * 损溢类型-损耗 */ public static final String LOSS_OVER_LOSS = "LOSS"; /** * 损溢类型-溢出 */ public static final String LOSS_OVER_OVER = "OVER"; @Autowired private FzzySync1209Rep fzzySync1209Rep; @Autowired private Api1209Rep api1209Rep; @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("-------------1209接口数据开始同步------------------"); //同步数据,只记录失败的信息 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 = fzzySync1209Rep.listMLossOver(deptId, start, end); if (null == list || list.isEmpty()) { log.info("-------------没有获取到粮食损溢信息------------------"); return; } Api1209 apiData; Api1105 api1105; for (MLossOver sysData : list) { //获取货位信息 api1105 = commonService.getApi1105Cache(sysData.getDepotId()); if (null == api1105) { continue; } apiData = new Api1209(); apiData.setSydh(api1105.getHwdm() + DateFormatUtils.format(sysData.getSubmitTime(), "yyyyMMdd") + sysData.getId().substring(11)); apiData.setHwdm(api1105.getHwdm()); apiData.setYwrq(sysData.getSubmitTime()); //净重损溢数量,损耗为正,溢出为负 if (LOSS_OVER_LOSS.equals(sysData.getType())) { apiData.setJzsysl(sysData.getAmount()); apiData.setCkjz(sysData.getAmount()); apiData.setRkjz(0); } else { apiData.setJzsysl(0 - sysData.getAmount()); apiData.setRkjz(sysData.getAmount()); apiData.setCkjz(0); } apiData.setRksj(sysData.getSubmitTime()); apiData.setCksj(sysData.getSubmitTime()); //损溢是否正常,默认0-正常 apiData.setSysfzc("0"); //操作标志及最后更新时间 apiData.setCzbz(Constant.CZBZ_I); apiData.setZhgxsj(new Date()); //业务id、库区编码、同步时间 apiData.setBizId(sysData.getId()); apiData.setKqdm(kqdm); apiData.setSyncTime(new Date()); //保存数据 api1209Rep.save(apiData); } } catch (Exception e) { log.error("---同步失败----{}", e); apiLog.setResult("同步失败:" + e.getMessage()); apiLogRep.save(apiLog); } } }