合同：经销、外贸库存合同拆分

@@ -467,6 +467,12 @@ public class GetContractDistributorStandardBo extends BaseBo<ContractDistributor
     @ApiModelProperty(value = "是否可修改")
     private Boolean canEdit;
 
+    /**
+     * 是否可拆分
+     */
+    @ApiModelProperty(value = "是否可拆分")
+    private Boolean canSplit;
+
     public GetContractDistributorStandardBo() {
 
     }

 package com.lframework.xingyun.sc.bo.contract;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.fasterxml.jackson.annotation.JsonFormat;
 import com.lframework.starter.common.constants.StringPool;
 import com.lframework.starter.web.core.bo.BaseBo;
@@ -227,6 +228,12 @@ public class QueryContractDistributorStandardBo extends BaseBo<ContractDistribut
     @ApiModelProperty(value = "双方盖章合同名称")
     private String signedContractFileName;
 
+    /**
+     * 是否可拆分
+     */
+    @ApiModelProperty(value = "是否可拆分")
+    private Boolean canSplit;
+
 
     public QueryContractDistributorStandardBo() {
 

@@ -806,6 +806,21 @@ public class ContractDistributorStandardController extends DefaultBaseController
         return destinationBuilder.toString();
     }
 
+    @ApiModelProperty("拆分")
+    @HasPermission({"contract-manage:distribution-inventory-contract:split", "contract-manage:foreign-trade-inventory-contract:split"})
+    @PostMapping("/split")
+    public InvokeResult<Void> split(@RequestBody UpdateContractDistributorStandardVo vo) {
+        if (vo == null || StringUtils.isBlank(vo.getId())) {
+            throw new DefaultClientException("参数错误！");
+        }
+
+        contractDistributorStandardService.splitInventoryContract(vo);
+
+        contractDistributorStandardService.cleanCacheByKey(vo.getId());
+
+        return InvokeResultBuilder.success();
+    }
+
     /**
      * 标准合同模版打印
      */

@@ -356,4 +356,10 @@ public class ContractDistributorStandard extends BaseEntity implements BaseDto {
      */
     @TableField(exist = false)
     private Boolean canEdit;
+
+    /**
+     * 是否可拆分
+     */
+    @TableField(exist = false)
+    private Boolean canSplit;
 }

@@ -14,14 +14,12 @@ import com.lframework.starter.mq.core.service.MqProducerService;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
 import com.lframework.starter.web.inner.dto.message.SysSiteMessageDto;
 import com.lframework.starter.web.inner.entity.SysDataDicItem;
-import com.lframework.starter.web.inner.entity.SysRole;
 import com.lframework.starter.web.inner.service.system.SysDataDicItemService;
 import com.lframework.starter.web.inner.service.system.SysRoleService;
 import com.lframework.starter.web.inner.service.system.SysUserDeptService;
 import com.lframework.starter.web.inner.service.system.SysUserRoleService;
 import com.lframework.xingyun.basedata.entity.Workshop;
 import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
-import com.lframework.xingyun.basedata.vo.workshop.QueryWorkshopVo;
 import com.lframework.xingyun.sc.controller.contract.ContractDistributorStandardController;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
@@ -53,13 +51,12 @@ import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractStdProcessin
 import com.lframework.xingyun.sc.vo.order.CreatePurchaseOrderInfoVo;
 import com.lframework.xingyun.sc.vo.order.CreatePurchaseOrderLineVo;
 import com.lframework.xingyun.sc.vo.order.QueryPurchaseOrderLineVo;
+import cn.hutool.core.bean.BeanUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.cache.annotation.CacheEvict;
-import org.springframework.cache.annotation.Cacheable;
-import org.springframework.security.core.parameters.P;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -217,7 +214,9 @@ public class ContractDistributorStandardServiceImpl extends
     @Override
     public List<ContractDistributorStandard> query(QueryContractDistributorStandardVo vo) {
 
-        return getBaseMapper().query(vo);
+        List<ContractDistributorStandard> datas = getBaseMapper().query(vo);
+        CollectionUtils.emptyIfNull(datas).forEach(data -> data.setCanSplit(isCanSplitByCode(data.getCode())));
+        return datas;
     }
 
     @Override
@@ -227,6 +226,7 @@ public class ContractDistributorStandardServiceImpl extends
         if (data == null) {
             return null;
         }
+        data.setCanSplit(isCanSplitByCode(data.getCode()));
         Wrapper<PurchaseOrderInfo> orderInfoWrapper = Wrappers.lambdaQuery(PurchaseOrderInfo.class)
                 .eq(PurchaseOrderInfo::getContractId, data.getId());
         List<PurchaseOrderInfo> purchaseOrderInfoList = purchaseOrderInfoService.list(orderInfoWrapper);
@@ -259,6 +259,13 @@ public class ContractDistributorStandardServiceImpl extends
         return data;
     }
 
+    private boolean isCanSplitByCode(String code) {
+        if (StringUtils.isBlank(code)) {
+            return false;
+        }
+        return !code.matches(".*_\\d{2}$");
+    }
+
     @OpLog(type = OtherOpLogType.class, name = "新增合同，ID：{}", params = {"#id"})
     @Transactional(rollbackFor = Exception.class)
     @Override
@@ -726,6 +733,119 @@ public class ContractDistributorStandardServiceImpl extends
         }
     }
 
+    @Override
+    @OpLog(type = OtherOpLogType.class, name = "合同拆分，ID：{}", params = {"#vo.id"})
+    @Transactional(rollbackFor = Exception.class)
+    public void splitInventoryContract(UpdateContractDistributorStandardVo vo) {
+        if (vo == null || StringUtils.isBlank(vo.getId())) {
+            throw new DefaultClientException("参数错误！");
+        }
+
+        List<UpdateContractDistributorLineVo> lineVoList = vo.getContractDistributorLineList();
+        if (CollectionUtils.isEmpty(lineVoList)) {
+            return;
+        }
+
+        BigDecimal splitTotalQuantity = BigDecimal.ZERO;
+        List<UpdateContractDistributorLineVo> splitLineVoList = new ArrayList<>();
+        for (UpdateContractDistributorLineVo lineVo : lineVoList) {
+            if (lineVo == null) {
+                continue;
+            }
+            BigDecimal currentQuantity = lineVo.getCurrentQuantity();
+            if (currentQuantity != null && currentQuantity.compareTo(BigDecimal.ZERO) > 0) {
+                splitLineVoList.add(lineVo);
+                splitTotalQuantity = splitTotalQuantity.add(currentQuantity);
+            }
+        }
+        if (splitLineVoList.isEmpty() || splitTotalQuantity.compareTo(BigDecimal.ZERO) <= 0) {
+            return;
+        }
+
+        ContractDistributorStandard original = getBaseMapper().selectById(vo.getId());
+        if (ObjectUtil.isNull(original)) {
+            throw new DefaultClientException("合同不存在！");
+        }
+        if (original.getTotalQuantity() == null) {
+            throw new DefaultClientException("合同合计数量为空，无法拆分！");
+        }
+
+        BigDecimal newOriginalTotalQuantity = original.getTotalQuantity().subtract(splitTotalQuantity);
+        if (newOriginalTotalQuantity.compareTo(BigDecimal.ZERO) < 0) {
+            throw new DefaultClientException("拆分数量不能大于合同合计数量！");
+        }
+
+        String baseCode = original.getCode();
+        if (StringUtils.isBlank(baseCode)) {
+            throw new DefaultClientException("合同编号为空，无法拆分！");
+        }
+        Wrapper<ContractDistributorStandard> splitWrapper = Wrappers.lambdaQuery(ContractDistributorStandard.class)
+                .likeRight(ContractDistributorStandard::getCode, baseCode + "_");
+        long splitCount = count(splitWrapper);
+        String suffix = String.format("%02d", splitCount + 1);
+        String newCode = baseCode + "_" + suffix;
+
+        ContractDistributorStandard newContract = new ContractDistributorStandard();
+        BeanUtil.copyProperties(original, newContract);
+        newContract.setId(IdUtil.getUUID());
+        newContract.setCode(newCode);
+        newContract.setParentId(null);
+        newContract.setTotalQuantity(splitTotalQuantity);
+        newContract.setCreateTime(LocalDateTime.now());
+        newContract.setUpdateTime(LocalDateTime.now());
+        getBaseMapper().insert(newContract);
+
+        Wrapper<ContractDistributorStandard> updateOriginal = Wrappers.lambdaUpdate(ContractDistributorStandard.class)
+                .set(ContractDistributorStandard::getTotalQuantity, newOriginalTotalQuantity)
+                .eq(ContractDistributorStandard::getId, original.getId());
+        getBaseMapper().update(updateOriginal);
+
+        Wrapper<ContractDistributorLine> lineWrapper = Wrappers.lambdaQuery(ContractDistributorLine.class)
+                .eq(ContractDistributorLine::getContractId, original.getId());
+        List<ContractDistributorLine> oldLineList = contractDistributorLineService.list(lineWrapper);
+        Map<String, ContractDistributorLine> oldLineMap = CollectionUtils.emptyIfNull(oldLineList)
+                .stream()
+                .filter(Objects::nonNull)
+                .filter(l -> StringUtils.isNotBlank(l.getId()))
+                .collect(Collectors.toMap(ContractDistributorLine::getId, Function.identity(), (a, b) -> a));
+
+        for (UpdateContractDistributorLineVo splitLineVo : splitLineVoList) {
+            if (StringUtils.isBlank(splitLineVo.getId())) {
+                throw new DefaultClientException("合同行数据不存在！");
+            }
+            ContractDistributorLine oldLine = oldLineMap.get(splitLineVo.getId());
+            if (oldLine == null) {
+                throw new DefaultClientException("合同行数据不存在！");
+            }
+            if (oldLine.getQuantity() == null) {
+                throw new DefaultClientException("原产品数量为空，无法拆分！");
+            }
+            if (oldLine.getQuantity().compareTo(splitLineVo.getCurrentQuantity()) < 0) {
+                throw new DefaultClientException("拆分数量不能大于原产品数量！");
+            }
+
+            ContractDistributorLine newLine = new ContractDistributorLine();
+            BeanUtil.copyProperties(oldLine, newLine);
+            newLine.setId(IdUtil.getUUID());
+            newLine.setContractId(newContract.getId());
+            newLine.setQuantity(splitLineVo.getCurrentQuantity());
+            newLine.setCreateTime(LocalDateTime.now());
+            newLine.setUpdateTime(LocalDateTime.now());
+            contractDistributorLineService.getBaseMapper().insert(newLine);
+
+            BigDecimal remainingQuantity = oldLine.getQuantity().subtract(splitLineVo.getCurrentQuantity());
+            Wrapper<ContractDistributorLine> updateOldLineWrapper = Wrappers.lambdaUpdate(ContractDistributorLine.class)
+                    .set(ContractDistributorLine::getQuantity, remainingQuantity)
+                    .set(ContractDistributorLine::getUpdateTime, LocalDateTime.now())
+                    .eq(ContractDistributorLine::getId, oldLine.getId());
+            contractDistributorLineService.update(updateOldLineWrapper);
+            contractDistributorLineService.cleanCacheByKey(oldLine.getId());
+        }
+
+        cleanCacheByKey(original.getId());
+        cleanCacheByKey(newContract.getId());
+    }
+
     /**
      * 创建订货单
      *

@@ -6,7 +6,6 @@ import com.lframework.starter.web.core.components.resp.PageResult;
 import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractDistributorStandardVo;
 import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractDistributorStandardVo;
 import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorStandardVo;
-import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -135,4 +134,9 @@ public interface ContractDistributorStandardService extends BaseMpService<Contra
      * 创建订货单
      */
     void createPurchaseOrderInfo(ContractDistributorStandard contractDistributorStandard, String type);
+
+    /**
+     * 拆分（经销库存合同、外贸库存合同）
+     */
+    void splitInventoryContract(UpdateContractDistributorStandardVo vo);
 }

@@ -95,6 +95,11 @@ public class UpdateContractDistributorLineVo implements BaseVo, Serializable {
     @IsNumberPrecision(message = "数量最多允许4位小数！", value = 4)
     private BigDecimal quantity;
 
+    @ApiModelProperty(value = "拆分数量")
+    @TypeMismatch(message = "拆分数量格式有误！")
+    @IsNumberPrecision(message = "拆分数量最多允许4位小数！", value = 4)
+    private BigDecimal currentQuantity;
+
     /**
      * 加工费
      */