增加取消组盘取消配盘功能

肖超群
1 parent e52db63a
Showing 14 changed files with 273 additions and 196 deletions
ant-design-vue-jeecg/src/views/system/receipt/ReceiptContainerHeaderList.vue
ant-design-vue-jeecg/src/views/system/shipment/ShipmentContainerHeaderList.vue
huaheng-wms-core/pom.xml
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/receipt/receiptContainerHeader/service/impl/ReceiptContainerHeaderServiceImpl.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/receipt/receiptHeader/controller/ReceiptHeaderController.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/receipt/receiptHeader/entity/ReceiptDetail.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/receipt/receiptHeader/service/IReceiptDetailService.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/receipt/receiptHeader/service/impl/ReceiptDetailServiceImpl.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/shipment/shipmentContainerHeader/controller/ShipmentContainerHeaderController.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/shipment/shipmentContainerHeader/service/IShipmentContainerHeaderService.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/shipment/shipmentContainerHeader/service/impl/ShipmentContainerHeaderServiceImpl.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/task/taskHeader/entity/TaskHeader.java
huaheng-wms-core/src/main/java/org/jeecg/modules/wms/task/taskHeader/service/impl/TaskHeaderServiceImpl.java
huaheng-wms-core/src/main/java/org/jeecg/utils/interceptor/HuahengBatisInterceptor.java
@@ -122,8 +122,8 @@
           <a v-if="record.status == 0 && record.taskType == 200" @click="selectPort(record)">生成任务</a>
           <a v-else-if="record.status == 0" @click="createTask(record)">生成任务</a>
           <a-divider type="vertical"/>
-          <a-popconfirm v-if="record.status == 0" v-has="'receiptContainerHeader:delete'" title="确定取消配盘吗?" @confirm="() => handleDelete(record.id)">
-            <a>取消配盘</a>
+          <a-popconfirm v-if="record.status == 0" v-has="'receiptContainerHeader:delete'" title="确定取消组盘吗?" @confirm="() => handleDelete(record.id)">
+            <a>取消组盘</a>
           </a-popconfirm>
           <a-divider type="vertical"/>
           <a-dropdown>
@@ -124,17 +124,17 @@
         </template>
         <span slot="action" slot-scope="text, record">
-          <a v-has="'shipmentContainerHeader:edit'" @click="handleEdit(record)">编辑</a>
-          <a-divider type="vertical"/>
           <a v-if="record.status == 0" @click="selectPort(record)">生成任务</a>
           <a-divider type="vertical"/>
+          <a-popconfirm v-if="record.status == 0" v-has="'shipmentContainerHeader:delete'" title="确定取消配盘吗?" @confirm="() => handleDelete(record.id)">
+            <a>取消配盘</a>
+          </a-popconfirm>
+          <a-divider type="vertical"/>
           <a-dropdown>
             <a class="ant-dropdown-link">更多 <a-icon type="down"/></a>
-            <a-menu slot="overlay" v-has="'shipmentContainerHeader:delete'">
+            <a-menu slot="overlay" >
               <a-menu-item>
-                <a-popconfirm title="确定删除吗?" @confirm="() => handleDelete(record.id)">
-                  <a>删除</a>
-                </a-popconfirm>
+              <a v-has="'receiptContainerHeader:edit'" @click="handleEdit(record)">编辑</a>
               </a-menu-item>
             </a-menu>
           </a-dropdown>
 <?xml version="1.0"?>
 <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
-    xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
+         xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
     <modelVersion>4.0.0</modelVersion>
     <parent>
@@ -79,6 +79,12 @@
             <artifactId>jimureport-spring-boot-starter</artifactId>
             <version>1.4.32</version>
         </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+
     </dependencies>
     <build>
@@ -338,12 +338,13 @@ public class ReceiptContainerHeaderServiceImpl extends ServiceImpl&lt;ReceiptContai
         List<ReceiptContainerDetail> receiptContainerDetailList = receiptContainerDetailService.getReceiptContainerDetailListByHeaderId(id);
         for (ReceiptContainerDetail receiptContainerDetail : receiptContainerDetailList) {
             ReceiptDetail receiptDetail = receiptDetailService.getById(receiptContainerDetail.getReceiptDetailId());
-            if (receiptDetail != null) {
-                receiptDetail.setStatus(QuantityConstant.RECEIPT_HEADER_BUILD);
-                receiptDetail.setTaskQty(receiptDetail.getTaskQty().subtract(receiptContainerDetail.getQty()));
-                if (!receiptDetailService.updateById(receiptDetail)) {
-                    throw new ServiceException("取消组盘失败, 更新入库明细失败id是" + receiptContainerDetail.getReceiptDetailId());
-                }
+            if (receiptDetail == null) {
+                throw new ServiceException("取消组盘失败, 没有找到入库组盘详情id是" + receiptContainerDetail.getReceiptDetailId());
+            }
+            receiptDetail.setStatus(QuantityConstant.RECEIPT_HEADER_BUILD);
+            receiptDetail.setTaskQty(receiptDetail.getTaskQty().subtract(receiptContainerDetail.getQty()));
+            if (!receiptDetailService.updateById(receiptDetail)) {
+                throw new ServiceException("取消组盘失败, 更新入库明细失败id是" + receiptContainerDetail.getReceiptDetailId());
             }
             if (!receiptContainerDetailService.removeById(receiptContainerDetail.getId())) {
                 throw new ServiceException("取消组盘失败， 删除入库组盘明细表失败id是" + receiptContainerDetail.getId());
@@ -42,7 +42,6 @@ import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartHttpServletRequest;
 import org.springframework.web.servlet.ModelAndView;
-import com.aliyun.oss.ServiceException;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -142,7 +141,6 @@ public class ReceiptHeaderController extends JeecgController&lt;ReceiptHeader, IRec
     @DeleteMapping(value = "/delete")
     public Result<String> delete(@RequestParam(name = "id", required = true) String id) {
         receiptHeaderService.delMain(id, QuantityConstant.WMS_DELETE_RECEIPT);
-
         return Result.OK("删除成功!");
     }
@@ -251,26 +249,7 @@ public class ReceiptHeaderController extends JeecgController&lt;ReceiptHeader, IRec
     @RequiresPermissions("receiptDetail:delete")
     @DeleteMapping(value = "/deleteReceiptDetail")
     public Result<String> deleteReceiptDetail(@RequestParam(name = "id", required = true) String id) {
-        ReceiptDetail receiptDetail = receiptDetailService.getById(id);
-        if (receiptDetail == null) {
-            return Result.error("删除失败, 没有找到入库单详情");
-        }
-        ReceiptHeader receiptHeader = receiptHeaderService.getById(receiptDetail.getReceiptId());
-        if (receiptHeader == null) {
-            return Result.error("删除失败, 没有找到入库单");
-        }
-        if (receiptHeader.getFirstStatus().intValue() != QuantityConstant.RECEIPT_HEADER_BUILD) {
-            return Result.error("删除失败, 入库单必须是新建状态才能删除详情");
-        }
-        boolean success = receiptDetailService.removeById(id);
-        if (!success) {
-            throw new ServiceException("删除详情失败");
-        }
-        success = receiptHeaderService.updateReceiptHeader(receiptDetail.getReceiptId());
-        if (!success) {
-            throw new ServiceException("更新入库单头数量失败");
-        }
-        return Result.OK("删除成功!");
+        return receiptDetailService.removeDetailById(id);
     }
     /**
@@ -283,8 +262,7 @@ public class ReceiptHeaderController extends JeecgController&lt;ReceiptHeader, IRec
     @RequiresPermissions("receiptDetail:deleteBatch")
     @DeleteMapping(value = "/deleteBatchReceiptDetail")
     public Result<String> deleteBatchReceiptDetail(@RequestParam(name = "ids", required = true) String ids) {
-        this.receiptDetailService.removeByIds(Arrays.asList(ids.split(",")));
-        return Result.OK("批量删除成功!");
+        return receiptDetailService.removeDetailListById(Arrays.asList(ids.split(",")));
     }
     /**
 package org.jeecg.modules.wms.receipt.receiptHeader.entity;
 import java.io.Serializable;
+import java.util.Date;
+
+import org.jeecg.common.aspect.annotation.Dict;
+import org.jeecgframework.poi.excel.annotation.Excel;
+
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
-import org.jeecg.common.aspect.annotation.Dict;
-import lombok.Data;
-import com.fasterxml.jackson.annotation.JsonFormat;
-import org.springframework.format.annotation.DateTimeFormat;
-import org.jeecgframework.poi.excel.annotation.Excel;
-import java.util.Date;
+
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
-import java.io.UnsupportedEncodingException;
+import lombok.Data;
 /**
  * @Description: 入库单详情
 package org.jeecg.modules.wms.receipt.receiptHeader.service;
-import com.baomidou.mybatisplus.extension.service.IService;
+import java.util.List;
+
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.modules.wms.receipt.receiptHeader.entity.ReceiptDetail;
-import org.jeecg.modules.wms.receipt.receiptHeader.entity.ReceiptHeader;
-import java.util.List;
+import com.baomidou.mybatisplus.extension.service.IService;
 /**
  * @Description: 入库单详情
@@ -18,4 +18,8 @@ public interface IReceiptDetailService extends IService&lt;ReceiptDetail&gt; {
     public List<ReceiptDetail> selectByMainId(String mainId);
     public Result saveReceiptDetail(ReceiptDetail receiptDetail);
+
+    public Result removeDetailById(String id);
+
+    public Result removeDetailListById(List<String> idList);
 }
 package org.jeecg.modules.wms.receipt.receiptHeader.service.impl;
-import com.alibaba.fastjson.JSON;
-import com.aliyun.oss.ServiceException;
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.Resource;
+
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.modules.wms.config.material.entity.Material;
 import org.jeecg.modules.wms.config.material.service.IMaterialService;
@@ -13,19 +17,17 @@ import org.jeecg.modules.wms.receipt.receiptHeader.service.IReceiptHeaderService
 import org.jeecg.utils.HuahengJwtUtil;
 import org.jeecg.utils.StringUtils;
 import org.jeecg.utils.constant.QuantityConstant;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
-import java.util.ArrayList;
-import java.util.List;
+import com.alibaba.fastjson.JSON;
+import com.aliyun.oss.ServiceException;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import cn.monitor4all.logRecord.annotation.OperationLog;
 import cn.monitor4all.logRecord.context.LogRecordContext;
-import org.springframework.beans.factory.annotation.Autowired;
-
-import javax.annotation.Resource;
-
 /**
  * @Description: 入库单详情
  * @Author:      jeecg-boot
@@ -50,6 +52,16 @@ public class ReceiptDetailServiceImpl extends ServiceImpl&lt;ReceiptDetailMapper, R
     }
     @Override
+    public boolean save(ReceiptDetail entity) {
+        BigDecimal qty = entity.getQty();
+        if (qty.compareTo(BigDecimal.ZERO) < 0) {
+            throw new ServiceException("单据数量不能小于0");
+        }
+        return super.save(entity);
+    }
+
+    @Override
+    @Transactional(rollbackFor = ServiceException.class)
     @OperationLog(bizId = "''", bizType = "'入库单追踪'", tag = "'入库详情添加'", extra = "#extraJsonString", msg = "''", operatorId = "#username", recordReturnValue = true)
     public Result saveReceiptDetail(ReceiptDetail receiptDetail) {
         ReceiptHeader receiptHeader = receiptHeaderService.getById(receiptDetail.getReceiptId());
@@ -95,4 +107,43 @@ public class ReceiptDetailServiceImpl extends ServiceImpl&lt;ReceiptDetailMapper, R
         LogRecordContext.putVariable("extraJsonString", JSON.toJSONString(receiptDetailList));
         return Result.OK("添加成功！");
     }
+
+    @Override
+    @Transactional(rollbackFor = ServiceException.class)
+    public Result removeDetailById(String id) {
+        ReceiptDetail receiptDetail = receiptDetailService.getById(id);
+        if (receiptDetail == null) {
+            return Result.error("删除失败, 没有找到入库单详情");
+        }
+        BigDecimal taskQty = receiptDetail.getTaskQty();
+        if (taskQty.compareTo(BigDecimal.ZERO) != 0) {
+            return Result.error("删除失败, 收货数量不为0");
+        }
+        ReceiptHeader receiptHeader = receiptHeaderService.getById(receiptDetail.getReceiptId());
+        if (receiptHeader == null) {
+            return Result.error("删除失败, 没有找到入库单");
+        }
+        if (receiptHeader.getFirstStatus().intValue() != QuantityConstant.RECEIPT_HEADER_BUILD) {
+            return Result.error("删除失败, 入库单必须是新建状态才能删除详情");
+        }
+        boolean success = receiptDetailService.removeById(id);
+        if (!success) {
+            throw new ServiceException("删除详情失败");
+        }
+        success = receiptHeaderService.updateReceiptHeader(receiptDetail.getReceiptId());
+        if (!success) {
+            throw new ServiceException("更新入库单头数量失败");
+        }
+        return Result.OK("删除成功!");
+    }
+
+    @Override
+    @Transactional(rollbackFor = ServiceException.class)
+    public Result removeDetailListById(List<String> idList) {
+        Result result = null;
+        for (String id : idList) {
+            result = removeDetailById(id);
+        }
+        return result;
+    }
 }
 package org.jeecg.modules.wms.shipment.shipmentContainerHeader.controller;
-import org.apache.shiro.authz.annotation.RequiresPermissions;
-import org.jeecg.common.system.query.QueryGenerator;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.common.system.base.controller.JeecgController;
-import org.jeecg.common.api.vo.Result;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
-import org.springframework.web.servlet.ModelAndView;
-import java.util.Arrays;
+
+import org.apache.shiro.SecurityUtils;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.base.controller.JeecgController;
+import org.jeecg.common.system.query.QueryGenerator;
+import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.util.oConvertUtils;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerDetail;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerHeader;
-import org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.IShipmentContainerHeaderService;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.IShipmentContainerDetailService;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.jeecg.common.aspect.annotation.AutoLog;
-import org.apache.shiro.SecurityUtils;
-import org.jeecg.common.system.vo.LoginUser;
+import org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.IShipmentContainerHeaderService;
 import org.jeecgframework.poi.excel.ExcelImportUtil;
 import org.jeecgframework.poi.excel.def.NormalExcelConstants;
 import org.jeecgframework.poi.excel.entity.ExportParams;
 import org.jeecgframework.poi.excel.entity.ImportParams;
 import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import org.springframework.web.multipart.MultipartHttpServletRequest;
-import java.io.IOException;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
+import org.springframework.web.servlet.ModelAndView;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
 /**
  * @Description: 出库组盘
@@ -114,8 +118,8 @@ public class ShipmentContainerHeaderController extends JeecgController&lt;ShipmentC
     @RequiresPermissions("shipmentContainerHeader:delete")
     @DeleteMapping(value = "/delete")
     public Result<String> delete(@RequestParam(name = "id", required = true) String id) {
-        shipmentContainerHeaderService.delMain(id);
-        return Result.OK("删除成功!");
+        Result result = shipmentContainerHeaderService.cancelCombine(Integer.parseInt(id));
+        return result;
     }
     /**
@@ -128,8 +132,10 @@ public class ShipmentContainerHeaderController extends JeecgController&lt;ShipmentC
     @RequiresPermissions("shipmentContainerHeader:deleteBatch")
     @DeleteMapping(value = "/deleteBatch")
     public Result<String> deleteBatch(@RequestParam(name = "ids", required = true) String ids) {
-        this.shipmentContainerHeaderService.delBatchMain(Arrays.asList(ids.split(",")));
-        return Result.OK("批量删除成功!");
+        List<String> idList = Arrays.asList(ids.split(","));
+        List<Integer> idInterList = idList.stream().map(Integer::parseInt).collect(Collectors.toList());
+        Result result = shipmentContainerHeaderService.cancelCombine(idInterList);
+        return result;
     }
     /**
 package org.jeecg.modules.wms.shipment.shipmentContainerHeader.service;
-import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerDetail;
-import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerHeader;
-import com.baomidou.mybatisplus.extension.service.IService;
-import org.springframework.beans.factory.annotation.Autowired;
 import java.io.Serializable;
 import java.util.Collection;
 import java.util.List;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerHeader;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+
 /**
  * @Description: 出库组盘
  * @Author:      jeecg-boot
@@ -41,4 +42,16 @@ public interface IShipmentContainerHeaderService extends IService&lt;ShipmentContai
      * @return
      */
     boolean cancelShipmentTask(Integer shipmentContainerHeaderId);
+
+    /**
+     * 取消配盘
+     * @return
+     */
+    Result cancelCombine(Integer id);
+
+    /**
+     * 取消配盘
+     * @return
+     */
+    Result cancelCombine(List<Integer> ids);
 }
 package org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.impl;
-import com.aliyun.oss.ServiceException;
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
-import org.jeecg.modules.wms.receipt.receiptContainerHeader.entity.ReceiptContainerDetail;
-import org.jeecg.modules.wms.receipt.receiptHeader.entity.ReceiptDetail;
-import org.jeecg.modules.wms.receipt.receiptHeader.entity.ReceiptHeader;
-import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerHeader;
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import javax.annotation.Resource;
+
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.wms.inventory.inventoryHeader.entity.InventoryDetail;
+import org.jeecg.modules.wms.inventory.inventoryHeader.service.IInventoryDetailService;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerDetail;
+import org.jeecg.modules.wms.shipment.shipmentContainerHeader.entity.ShipmentContainerHeader;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.mapper.ShipmentContainerDetailMapper;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.mapper.ShipmentContainerHeaderMapper;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.IShipmentContainerDetailService;
 import org.jeecg.modules.wms.shipment.shipmentContainerHeader.service.IShipmentContainerHeaderService;
 import org.jeecg.modules.wms.shipment.shipmentHeader.entity.ShipmentDetail;
-import org.jeecg.modules.wms.shipment.shipmentHeader.entity.ShipmentHeader;
 import org.jeecg.modules.wms.shipment.shipmentHeader.service.IShipmentDetailService;
 import org.jeecg.modules.wms.shipment.shipmentHeader.service.IShipmentHeaderService;
 import org.jeecg.utils.constant.QuantityConstant;
-import org.springframework.stereotype.Service;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
-import javax.annotation.Resource;
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Collection;
-import java.util.stream.Collectors;
+import com.aliyun.oss.ServiceException;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 /**
  * @Description: 出库组盘
@@ -49,6 +50,8 @@ public class ShipmentContainerHeaderServiceImpl extends ServiceImpl&lt;ShipmentCont
     private IShipmentHeaderService shipmentHeaderService;
     @Resource
     private IShipmentContainerDetailService shipmentContainerDetailService;
+    @Resource
+    private IInventoryDetailService inventoryDetailService;
     @Override
     @Transactional
@@ -164,4 +167,53 @@ public class ShipmentContainerHeaderServiceImpl extends ServiceImpl&lt;ShipmentCont
         return true;
     }
+    @Override
+    @Transactional(rollbackFor = ServiceException.class)
+    public Result cancelCombine(Integer id) {
+        ShipmentContainerHeader shipmentContainerHeader = this.getById(id);
+        if (shipmentContainerHeader == null) {
+            return Result.error("取消出库配盘失败, 没有找到出库组盘头id是" + id);
+        }
+        int status = shipmentContainerHeader.getStatus();
+        if (status >= QuantityConstant.SHIPMENT_CONTAINER_TASK) {
+            return Result.error("取消出库配盘失败，已经生成出库任务");
+        }
+        List<ShipmentContainerDetail> shipmentContainerDetailList = shipmentContainerDetailService.getShipmentContainerDetailListByHeaderId(id);
+        for (ShipmentContainerDetail shipmentContainerDetail : shipmentContainerDetailList) {
+            ShipmentDetail shipmentDetail = shipmentDetailService.getById(shipmentContainerDetail.getShipmentDetailId());
+            if (shipmentDetail == null) {
+                throw new ServiceException("取消出库配盘失败, 没有找到出库单详情id是" + shipmentContainerDetail.getShipmentDetailId());
+            }
+            shipmentDetail.setStatus(QuantityConstant.SHIPMENT_HEADER_BUILD);
+            shipmentDetail.setTaskQty(shipmentDetail.getTaskQty().subtract(shipmentContainerDetail.getQty()));
+            if (!shipmentDetailService.updateById(shipmentDetail)) {
+                throw new ServiceException("取消出库配盘失败, 更新出库明细失败id是" + shipmentContainerDetail.getShipmentDetailId());
+            }
+            if (!shipmentContainerDetailService.removeById(shipmentContainerDetail.getId())) {
+                throw new ServiceException("取消出库配盘失败， 删除出库组盘明细表失败id是" + shipmentContainerDetail.getId());
+            }
+            if (!shipmentHeaderService.updateShipmentHeaderStatus(shipmentDetail.getShipmentId())) {
+                throw new ServiceException("取消出库配盘失败, 更新出库单头失败");
+            }
+            InventoryDetail inventoryDetail = inventoryDetailService.getById(shipmentContainerDetail.getInventoryDetailId());
+            inventoryDetail.setTaskQty(inventoryDetail.getTaskQty().subtract(shipmentContainerDetail.getQty()));
+            if (!inventoryDetailService.updateById(inventoryDetail)) {
+                throw new ServiceException("取消出库配盘失败, 解锁库存详情失败");
+            }
+        }
+        if (!this.removeById(id)) {
+            throw new ServiceException("取消出库配盘失败, 删除出库组盘头表失败id是" + id);
+        }
+        return Result.ok("取消配盘成功");
+    }
+
+    @Override
+    public Result cancelCombine(List<Integer> ids) {
+        Result result = null;
+        for (Integer id : ids) {
+            result = cancelCombine(id);
+        }
+        return result;
+    }
+
 }
@@ -3,6 +3,8 @@ package org.jeecg.modules.wms.task.taskHeader.entity;
 import java.io.Serializable;
 import java.util.Date;
+import javax.validation.constraints.NotEmpty;
+
 import org.jeecg.common.aspect.annotation.Dict;
 import org.jeecgframework.poi.excel.annotation.Excel;
@@ -45,6 +47,7 @@ public class TaskHeader implements Serializable {
     /** 仓库 */
     @Excel(name = "仓库", width = 15)
     @ApiModelProperty(value = "仓库")
+    @NotEmpty(message = "仓库编码不能为空")
     private String warehouseCode;
     /** 货主 */
     @Excel(name = "货主", width = 15)
@@ -6,16 +6,13 @@ import java.util.ArrayList;
 import java.util.Collection;
 import java.util.Date;
 import java.util.List;
-import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.stream.Collectors;
 import javax.annotation.Resource;
-import org.apache.poi.hpsf.Decimal;
 import org.apache.shiro.SecurityUtils;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.system.vo.LoginUser;
-import org.jeecg.modules.system.entity.SysDepartRolePermission;
 import org.jeecg.modules.wms.api.wcs.service.LocationAllocationService;
 import org.jeecg.modules.wms.api.wcs.service.WcsService;
 import org.jeecg.modules.wms.config.container.entity.Container;
@@ -26,7 +23,6 @@ import org.jeecg.modules.wms.config.locationHigh.entity.LocationHigh;
 import org.jeecg.modules.wms.config.locationHigh.service.ILocationHighService;
 import org.jeecg.modules.wms.config.locationType.entity.LocationType;
 import org.jeecg.modules.wms.config.locationType.service.ILocationTypeService;
-import org.jeecg.modules.wms.config.material.service.IMaterialService;
 import org.jeecg.modules.wms.config.parameterConfiguration.service.IParameterConfigurationService;
 import org.jeecg.modules.wms.config.port.entity.Port;
 import org.jeecg.modules.wms.config.port.service.IPortService;
@@ -63,7 +59,6 @@ import org.jeecg.modules.wms.task.taskHeader.mapper.TaskDetailMapper;
 import org.jeecg.modules.wms.task.taskHeader.mapper.TaskHeaderMapper;
 import org.jeecg.modules.wms.task.taskHeader.service.ITaskDetailService;
 import org.jeecg.modules.wms.task.taskHeader.service.ITaskHeaderService;
-import org.jeecg.utils.HuahengJwtUtil;
 import org.jeecg.utils.StringUtils;
 import org.jeecg.utils.constant.QuantityConstant;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -1395,7 +1390,7 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
             if (!success) {
                 throw new ServiceException("完成分拣出库任务，更新目标库位失败");
             }
-            success = containerService.updateLocationCodeAndStatus(containerCode, toLocationCode, containerStatus, warehouseCode);
+            success = containerService.updateStatus(containerCode, containerStatus, warehouseCode);
             if (!success) {
                 throw new ServiceException("完成分拣出库任务，更新容器失败");
             }
@@ -1515,73 +1510,62 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
         return Result.OK("完成空托盘入库成功");
     }
-
-
-
     /**
      * 盘点完成
-     *盘点有差异完成时状态为105
-     * @param taskHeader
+     * 盘点有差异完成时状态为105
+     * @param  taskHeader
      * @return
      */
     @Transactional(rollbackFor = Exception.class)
     public Result completeCycleCountTask(TaskHeader taskHeader) {
-        /*盘点完成，传入任务主单，查出任务明细，通过任务明细查找盘点的明细单，
-        完成任务同时，修改盘点细单和主单的状态，完成后库存锁复位*/
+        /*
+         * 盘点完成，传入任务主单，查出任务明细，通过任务明细查找盘点的明细单，
+         * 完成任务同时，修改盘点细单和主单的状态，完成后库存锁复位
+         */
-        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+        LoginUser sysUser = (LoginUser)SecurityUtils.getSubject().getPrincipal();
         taskHeader.setStatus(QuantityConstant.TASK_STATUS_COMPLETED);
-        //更新用户
+        // 更新用户
         taskHeader.setUpdateBy(sysUser.getUsername());
-        //更新时间
+        // 更新时间
         taskHeader.setUpdateTime(new Date());
-
-        //1.先拿到盘点单主单据
+        // 1.先拿到盘点单主单据
         CycleCountDetail cycleCountDetail = cycleCountDetailService.getById(taskHeader.getShipmentContainerHeaderId());
-        if ((cycleCountDetail.getCountedQty().add(cycleCountDetail.getGapQty())).compareTo(BigDecimal.ZERO)==0)
-        {
-            return Result.error("盘点单据系统实盘数量跟差异数量0,不能完成 单据号" +cycleCountDetail.getCycleCountHeadCode());
+        if ((cycleCountDetail.getCountedQty().add(cycleCountDetail.getGapQty())).compareTo(BigDecimal.ZERO) == 0) {
+            return Result.error("盘点单据系统实盘数量跟差异数量0,不能完成 单据号" + cycleCountDetail.getCycleCountHeadCode());
         }
-        //2.盘点单主单据查明细单据list
+        // 2.盘点单主单据查明细单据list
         LambdaQueryWrapper<CycleCountDetailChild> childLambdaQueryWrapper = new LambdaQueryWrapper<CycleCountDetailChild>();
-        childLambdaQueryWrapper.eq(CycleCountDetailChild::getCycleCountDetailid,cycleCountDetail.getId());
+        childLambdaQueryWrapper.eq(CycleCountDetailChild::getCycleCountDetailid, cycleCountDetail.getId());
         List<CycleCountDetailChild> children = cycleCountDetailChildService.list(childLambdaQueryWrapper);
-        //3.单据list如果差异数量+生成入库单，差异数-生成出库单进行回传类型其他出库单
-
+        // 3.单据list如果差异数量+生成入库单，差异数-生成出库单进行回传类型其他出库单
         InventoryHeader inventoryHeader = inventoryHeaderService.getById(cycleCountDetail.getInventoryHeaderId());
-        int outboundOrderId=0;
-        String outboundOrderCode=null;
-        int warehousingOrderId=0;
-        String warehousingOrderCode=null;
+        int outboundOrderId = 0;
+        String outboundOrderCode = null;
+        int warehousingOrderId = 0;
+        String warehousingOrderCode = null;
-
-        for (CycleCountDetailChild child : children)
-        {
-            if (!child.getChildStatus().equals(QuantityConstant.CYCLECOUNT_STATUS_REGISTERED))
-            {
+        for (CycleCountDetailChild child : children) {
+            if (!child.getChildStatus().equals(QuantityConstant.CYCLECOUNT_STATUS_REGISTERED)) {
                 throw new ServiceException("当前任务里面还有没有进行登记的数据,不能完成任务");
             }
-
-            if (child.getInventoryDetaiId()!=null)
-            {
+            if (child.getInventoryDetaiId() != null) {
                 InventoryDetail inventoryDetail = inventoryDetailService.getById(child.getInventoryDetaiId());
-                if (inventoryDetail==null)
-                {
+                if (inventoryDetail == null) {
                     throw new ServiceException("盘点还没完成 库存明细单据就不存在了 可能出现了问题或者所容器没成功");
                 }
                 inventoryHeader.setTotalQty(inventoryHeader.getTotalQty().add(child.getGapQty()));
                 inventoryDetail.setQty(child.getCountedQty());
                 inventoryDetailService.updateById(inventoryDetail);
-            }else
-            {
-                InventoryDetail inventoryDetail=new InventoryDetail();
+            } else {
+                InventoryDetail inventoryDetail = new InventoryDetail();
                 inventoryDetail.setInventoryHeaderId(inventoryHeader.getId());
                 inventoryDetail.setWarehouseCode(inventoryHeader.getWarehouseCode());
                 inventoryDetail.setCompanyCode(inventoryHeader.getCompanyCode());
@@ -1600,30 +1584,27 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
                 child.setInventoryDetaiId(inventoryDetail.getId());
             }
-
             child.setChildStatus(QuantityConstant.CYCLECOUNT_STATUS_COMPLETED);
-            if (child.getGapQty().compareTo(BigDecimal.ZERO) == 1)
-            {
-                if (warehousingOrderId==0) {
+            if (child.getGapQty().compareTo(BigDecimal.ZERO) == 1) {
+                if (warehousingOrderId == 0) {
                     ReceiptHeader receiptHeader = new ReceiptHeader();
                     receiptHeader.setWarehouseCode(taskHeader.getWarehouseCode());
                     receiptHeader.setCompanyCode(taskHeader.getCompanyCode());
                     receiptHeader.setType(QuantityConstant.RECEIPT_BILL_TYPE_OR);
-                    receiptHeader.setRemark("盘盈 单号"+cycleCountDetail.getCycleCountHeadCode());
+                    receiptHeader.setRemark("盘盈 单号" + cycleCountDetail.getCycleCountHeadCode());
                     Result result = receiptHeaderService.saveReceiptHeader(receiptHeader);
-                    if (result.getCode() != 200)
-                    {
+                    if (result.getCode() != 200) {
                         return result;
                     }
                     receiptHeader.setFirstStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                     receiptHeader.setLastStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                     receiptHeaderService.updateById(receiptHeader);
-                    //生成入库单并且赋值给warehousingOrderId
-                    warehousingOrderId=receiptHeader.getId();
-                    warehousingOrderCode=receiptHeader.getCode();
+                    // 生成入库单并且赋值给warehousingOrderId
+                    warehousingOrderId = receiptHeader.getId();
+                    warehousingOrderCode = receiptHeader.getCode();
                 }
-                //生成明细
+                // 生成明细
                 ReceiptDetail receiptDetail = new ReceiptDetail();
                 receiptDetail.setReceiptId(warehousingOrderId);
                 receiptDetail.setReceiptCode(warehousingOrderCode);
@@ -1641,8 +1622,8 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
                 receiptDetail.setStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                 receiptDetailService.save(receiptDetail);
-                //增加库存交易记录
-                InventoryTransaction inventoryTransaction=new InventoryTransaction();
+                // 增加库存交易记录
+                InventoryTransaction inventoryTransaction = new InventoryTransaction();
                 inventoryTransaction.setWarehouseCode(taskHeader.getWarehouseCode());
                 inventoryTransaction.setCompanyCode(taskHeader.getCompanyCode());
                 inventoryTransaction.setContainerCode(child.getContainerCode());
@@ -1662,38 +1643,31 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
             }
+            if (child.getGapQty().compareTo(BigDecimal.ZERO) == -1) {
-
-            if (child.getGapQty().compareTo(BigDecimal.ZERO) == -1)
-            {
-
-                if (child.getGapQty().abs().compareTo(child.getSystemQty()) > -1)
-                {
+                if (child.getGapQty().abs().compareTo(child.getSystemQty()) > -1) {
                     inventoryDetailService.removeById(child.getInventoryDetaiId());
                 }
-
-                if (outboundOrderId==0)
-                {
+                if (outboundOrderId == 0) {
                     ShipmentHeader shipmentHeader = new ShipmentHeader();
                     shipmentHeader.setWarehouseCode(taskHeader.getWarehouseCode());
                     shipmentHeader.setCompanyCode(taskHeader.getCompanyCode());
                     shipmentHeader.setType(QuantityConstant.SHIPMENT_BILL_TYPE_OS);
-                    shipmentHeader.setRemark("盘亏 单号"+cycleCountDetail.getCycleCountHeadCode());
+                    shipmentHeader.setRemark("盘亏 单号" + cycleCountDetail.getCycleCountHeadCode());
                     Result result = shipmentHeaderService.saveShipmentHeader(shipmentHeader);
-                    if (result.getCode() != 200)
-                    {
+                    if (result.getCode() != 200) {
                         return result;
                     }
                     shipmentHeader.setFirstStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                     shipmentHeader.setLastStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                     shipmentHeaderService.updateById(shipmentHeader);
-                    //生成出库单并且赋值给outboundOrderId
-                    outboundOrderId=shipmentHeader.getId();
-                    outboundOrderCode=shipmentHeader.getCode();
+                    // 生成出库单并且赋值给outboundOrderId
+                    outboundOrderId = shipmentHeader.getId();
+                    outboundOrderCode = shipmentHeader.getCode();
                 }
-                //生成明细
+                // 生成明细
                 ShipmentDetail shipmentDetail = new ShipmentDetail();
                 shipmentDetail.setShipmentId(outboundOrderId);
                 shipmentDetail.setShipmentCode(outboundOrderCode);
@@ -1711,7 +1685,7 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
                 shipmentDetail.setStatus(QuantityConstant.RECEIPT_HEADER_COMPLETED);
                 shipmentDetailService.save(shipmentDetail);
-                InventoryTransaction inventoryTransaction=new InventoryTransaction();
+                InventoryTransaction inventoryTransaction = new InventoryTransaction();
                 inventoryTransaction.setWarehouseCode(taskHeader.getWarehouseCode());
                 inventoryTransaction.setCompanyCode(taskHeader.getCompanyCode());
                 inventoryTransaction.setContainerCode(child.getContainerCode());
@@ -1732,45 +1706,33 @@ public class TaskHeaderServiceImpl extends ServiceImpl&lt;TaskHeaderMapper, TaskHea
             cycleCountDetailChildService.updateById(child);
         }
-
-        if (inventoryHeader.getTotalQty().compareTo(BigDecimal.ZERO)<1)
-        {
+        if (inventoryHeader.getTotalQty().compareTo(BigDecimal.ZERO) < 1) {
             inventoryHeaderService.removeById(inventoryHeader);
         }
         inventoryHeaderService.updateById(inventoryHeader);
-        //4.完成当前任务
+        // 4.完成当前任务
         if (!taskHeaderService.saveOrUpdate(taskHeader)) {
             throw new ServiceException("盘点任务单据状态更新失败！");
         }
-        //盘点明细状态
+        // 盘点明细状态
         cycleCountDetail.setEnableStatus(QuantityConstant.CYCLECOUNT_STATUS_COMPLETED);
         cycleCountDetail.setCompletedBy(sysUser.getUsername());
         cycleCountDetail.setCompletedAt(new Date());
         cycleCountDetailService.updateById(cycleCountDetail);
-        //更新主单状态
+        // 更新主单状态
         cycleCountHeaderService.updataHeaderStatus(cycleCountDetail.getCycleCountHeadCode());
+        // 释放库位
+        locationService.updateStatus(cycleCountDetail.getLocationCode(), QuantityConstant.STATUS_LOCATION_EMPTY, taskHeader.getWarehouseCode());
-        //释放库位
-        locationService.updateStatus(cycleCountDetail.getLocationCode(),
-                QuantityConstant.STATUS_LOCATION_EMPTY, taskHeader.getWarehouseCode());
-
-
-        //还原容器状态
-        containerService.restoreContainer(cycleCountDetail.getContainerCode(),taskHeader.getWarehouseCode());
+        // 还原容器状态
+        containerService.restoreContainer(cycleCountDetail.getContainerCode(), taskHeader.getWarehouseCode());
         return Result.OK("完成盘点任务成功");
     }
-
-
-
-
-
-
-
     /**
      * 完成空托盘出库任务
      * @param  taskHeader 任务
@@ -12,6 +12,7 @@ import org.apache.ibatis.plugin.*;
 import org.apache.shiro.SecurityUtils;
 import org.jeecg.common.system.vo.LoginUser;
 import org.jeecg.common.util.oConvertUtils;
+import org.jeecg.utils.HuahengJwtUtil;
 import org.springframework.stereotype.Component;
 import lombok.extern.slf4j.Slf4j;
@@ -113,7 +114,7 @@ public class HuahengBatisInterceptor implements Interceptor {
                         if (sysUser != null) {
                             // 登录账号
                             field.setAccessible(true);
-                            field.set(parameter, sysUser.getRealname());
+                            field.set(parameter, HuahengJwtUtil.getCurrentOperator());
                             field.setAccessible(false);
                         }
                     }