njs 2 年之前
父節點
當前提交
203c07b956

+ 29 - 1
suishenbang-system/src/main/java/com/dgtly/system/service/impl/SysUserOrderAuthorServiceImpl.java

@@ -529,7 +529,15 @@ public class SysUserOrderAuthorServiceImpl implements ISysUserOrderAuthorService
                                tmsLogisticsStatus.setOrderNumber(deliver.getDocNumber());
                                tmsLogisticsStatus.setAssignTime(new Date());
                                tmsLogisticsStatus.setTransferOrder("n");
-                               tmslistNo.add(tmsLogisticsStatus);
+                                tmslistNo.add(tmsLogisticsStatus);
+                               if(tmslistNo!=null && tmslistNo.size()>10000){
+                                   sysBatchSignForMapper.saveTmsLogisticsStatus(tmslistNo);
+                                   tmslistNo.clear();
+                                   List<TmsLogisticsStatus> tmsNewLog=sysBatchSignForMapper.selectByDelivery();
+                                   if(tmsNewLog !=null && tmsNewLog.size()>0){
+                                       keytmsMap=tmsNewLog.stream().collect(Collectors.groupingBy(TmsLogisticsStatus::getDeliveryNumber));
+                                   }
+                               }
                     }
                 }
             }
@@ -582,6 +590,14 @@ public class SysUserOrderAuthorServiceImpl implements ISysUserOrderAuthorService
                                 }
                                 tmsLogisticsStatus.setArrivalGoodsTime(date);
                             tmslistYes.add(tmsLogisticsStatus);
+                            if(tmslistYes!=null && tmslistYes.size()>10000){
+                                sysBatchSignForMapper.saveTmsLogisticsStatus(tmslistYes);
+                                tmslistYes.clear();
+                                List<TmsLogisticsStatus> tmsNewLog=sysBatchSignForMapper.selectByDelivery();
+                                if(tmsNewLog !=null && tmsNewLog.size()>0){
+                                    keytmsMap=tmsNewLog.stream().collect(Collectors.groupingBy(TmsLogisticsStatus::getDeliveryNumber));
+                                }
+                            }
                } else if(keytmsMap !=null && keytmsMap.containsKey(deliver.getDeliverNumber())){
                     List<TmsLogisticsStatus> tmsStatusList= keytmsMap.get(deliver.getDeliverNumber());
                     if(tmsStatusList !=null && tmsStatusList.size()>0){
@@ -598,6 +614,10 @@ public class SysUserOrderAuthorServiceImpl implements ISysUserOrderAuthorService
                             tmsStatus.get().setArrivalGoodsTime(date);
                             tmsStatus.get().setUpdateTime(new Date());
                             tmsStatus5list.add(tmsStatus.get());
+                            if(tmsStatus5list!=null && tmsStatus5list.size()>10000){
+                                sysBatchSignForMapper.updateBatchTmsStatus(tmsStatus5list);
+                                tmsStatus5list.clear();
+                            }
                         }
                     }
                     List<String> newdeliver = deliverlist.stream().map(DeliverQuantityConfirm::getCode).collect(Collectors.toList());
@@ -627,6 +647,14 @@ public class SysUserOrderAuthorServiceImpl implements ISysUserOrderAuthorService
                             number.setDeliverWt(deliver.getDeliverWt());
                             number.setConfirmQuantity(deliver.getDeliverQty());
                             deliverlist.add(number);
+                            if(deliverlist!=null && deliverlist.size()>10000){
+                                deliverQuantityConfirmMapper.saveDeliverNumber(deliverlist);
+                                deliverlist.clear();
+                                List<DeliverQuantityConfirm> delivernewNumber=deliverQuantityConfirmMapper.selectDeliverQuantityConfirmList(numbernull);
+                                if(delivernewNumber !=null && delivernewNumber.size()>0){
+                                    deliverNumbers = delivernewNumber.stream().map(DeliverQuantityConfirm::getCode).collect(Collectors.toList());
+                                }
+                            }
                     }
                 }
                 }