fix(修复出库生成任务报警): shipmentContainerHeaderId 入参去重

tongzhonghao
1 parent dac6d685
Showing 2 changed files with 4 additions and 3 deletions
src/main/java/com/huaheng/pc/shipment/shipmentContainerHeader/service/ShipmentContainerHeaderServiceImpl.java
src/main/java/com/huaheng/pc/shipment/shippingCombination/controller/ShippingCombinationController.java
@@ -633,7 +633,7 @@ public class ShipmentContainerHeaderServiceImpl extends ServiceImpl&lt;ShipmentCont
  
     /* 生成任务 */
     @Override
-    @Transactional
+    @Transactional(rollbackFor = Exception.class)
     public AjaxResult createTask(List<Integer> idList) {
         ShipmentTaskCreateModel shipmentTask = new ShipmentTaskCreateModel();
         for (Integer id : idList)   {
@@ -293,7 +293,8 @@ public class ShippingCombinationController extends BaseController {
             return AjaxResult.error("id不能为空");
         }
         List<Integer> idList = Arrays.asList(Convert.toIntArray(ids));
-        for (Integer id : idList) {
+        List<Integer> idsList = idList.stream().distinct().collect(Collectors.toList());
+        for (Integer id : idsList) {
             //获取表头
             ShipmentContainerHeader shipmentContainerHeader = shipmentContainerHeaderService.getById(id);
             if(shipmentContainerHeader == null) {
@@ -303,7 +304,7 @@ public class ShippingCombinationController extends BaseController {
                 return AjaxResult.error("出库货箱编码(" + shipmentContainerHeader.getContainerCode() + ")已经生成任务，请不要重复生成，操作中止");
             }
         }
-        ajaxResult = shipmentContainerHeaderService.createTask(idList);
+        ajaxResult = shipmentContainerHeaderService.createTask(idsList);
         return ajaxResult;
     }
 }