| | |
|---|
| | | import org.apache.commons.lang.time.DateFormatUtils; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import java.util.Calendar; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | |
|---|
| | | import java.util.*; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 粮食出库信息 |
|---|
| | |
|---|
| | | Api1205 apiData; |
|---|
| | | Api1105 api1105; |
|---|
| | | List<Fz35InoutNoticeOut> listInoutNotice; |
|---|
| | | // List<GbArea> gbAreaList; |
|---|
| | | List<Api1205> api1205List; |
|---|
| | | Calendar c = Calendar.getInstance(); |
|---|
| | | String ywsj = ""; |
|---|
| | | String num = ""; |
|---|
| | | Map<String, Integer> map = new HashMap<>(); |
|---|
| | | for (Fz35InoutRecord 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.setId(sysData.getId()); |
|---|
| | | apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4)); |
|---|
| | | |
|---|
| | | //判断业务时间与单据号是否匹配 |
|---|
| | | ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd"); |
|---|
| | | if(!ywsj.equals(sysData.getId().substring(4, 10))){ |
|---|
| | | if(null == map.get(ywsj)){ |
|---|
| | | map.put(ywsj, 10201); |
|---|
| | | } |
|---|
| | | num = String.valueOf(map.get(ywsj)).substring(1); |
|---|
| | | apiData.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num); |
|---|
| | | map.put(ywsj, map.get(ywsj) + 1); |
|---|
| | | } |
|---|
| | | |
|---|
| | | //货位代码 |
|---|
| | | apiData.setHwdm(api1105.getHwdm()); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | //运输工具，默认汽车 |
|---|
| | | apiData.setYsgj("1"); |
|---|
| | | //运输工具，若为空，则默认给1-汽车 |
|---|
| | | apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1":sysData.getTransType()); |
|---|
| | | |
|---|
| | | //车船号 |
|---|
| | | apiData.setCch(sysData.getPlateNum()); |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
