| | |
|---|
| | | import com.fzzy.api.utils.ContextUtil; |
|---|
| | | import com.fzzy.api.view.repository.Api1205Rep; |
|---|
| | | import com.fzzy.api.view.repository.ApiLogRep; |
|---|
| | | import com.fzzy.async.fzzy35.entity.InoutNoticeOut; |
|---|
| | | import com.fzzy.async.fzzy35.entity.InoutRecord; |
|---|
| | | import com.fzzy.async.fzzy35.entity.Fz35InoutNoticeOut; |
|---|
| | | import com.fzzy.async.fzzy35.entity.Fz35InoutRecord; |
|---|
| | | import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep; |
|---|
| | | import com.fzzy.async.fzzy35.repository.Fzzy35SyncNoticeOutRep; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | |
|---|
| | | apiLog.setId(ContextUtil.getUUID()); |
|---|
| | | try { |
|---|
| | | //获取粮食出库信息，根据流程完成时间获取 |
|---|
| | | List<InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_OUT, start, end); |
|---|
| | | List<Fz35InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_OUT, start, end); |
|---|
| | | |
|---|
| | | if (null == list || list.isEmpty()) { |
|---|
| | | log.info("-------------没有获取到粮食出库信息------------------"); |
|---|
| | |
|---|
| | | |
|---|
| | | Api1205 apiData; |
|---|
| | | Api1105 api1105; |
|---|
| | | List<InoutNoticeOut> listInoutNotice; |
|---|
| | | List<Fz35InoutNoticeOut> listInoutNotice; |
|---|
| | | List<Api1205> api1205List; |
|---|
| | | // List<GbArea> gbAreaList; |
|---|
| | | Calendar c = Calendar.getInstance(); |
|---|
| | | for (InoutRecord sysData : list) { |
|---|
| | | |
|---|
| | | for (Fz35InoutRecord sysData : list) { |
|---|
| | | //判断净重是否大于0，等于0表示不合格，不进行同步上传 |
|---|
| | | if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | //获取货位信息 |
|---|
| | | api1105 = commonService.getApi1105Cache(sysData.getDepotId()); |
|---|
| | | if(null == api1105){ |
|---|
| | | continue; |
|---|
| | | } |
|---|
| | | apiData = new Api1205(); |
|---|
| | | |
|---|
| | | apiData.setId(sysData.getId()); |
|---|
| | | apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4)); |
|---|
| | | |
|---|
| | | |
|---|
| | |
|---|
| | | apiData.setMzjly(sysData.getFullWeightUser()); |
|---|
| | | |
|---|
| | | //净重 |
|---|
| | | apiData.setJz(sysData.getSettleWeight()); |
|---|
| | | apiData.setJz(sysData.getRecordWeight()); |
|---|
| | | c.setTime(sysData.getCompleteTime()); |
|---|
| | | c.add(Calendar.MINUTE,3); |
|---|
| | | apiData.setCmsj(c.getTime()); |
|---|
| | | |
|---|
| | | //操作标志及最后更新时间 |
|---|
| | | apiData.setCzbz(Constant.CZBZ_I); |
|---|
| | | apiData.setZhgxsj(c.getTime()); |
|---|
| | | |
|---|
| | | //业务id、库区编码、同步时间 |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
