合同：合同变更单

@@ -1465,3 +1465,29 @@ ALTER TABLE tbl_purchase_order_line ADD COLUMN production_process text COMMENT '
 
 
 ALTER TABLE tbl_contract_distributor_standard
 ALTER TABLE tbl_contract_distributor_standard
     ADD COLUMN change_reason varchar(50) DEFAULT NULL COMMENT '变更原因';
     ADD COLUMN change_reason varchar(50) DEFAULT NULL COMMENT '变更原因';
+
+CREATE TABLE IF NOT EXISTS `tbl_contract_change_application`
+(
+    `id`               varchar(32)  NOT NULL COMMENT 'ID',
+    `contract_id`      varchar(32)  NOT NULL COMMENT '合同ID',
+    `root_contract_id` varchar(32)  NOT NULL COMMENT '根合同ID',
+    `contract_code`    varchar(50)  NOT NULL COMMENT '合同编号',
+    `contract_type`    varchar(50)  NOT NULL COMMENT '合同类型',
+    `contract_stage`   varchar(20)  NOT NULL COMMENT '合同阶段(FORMAL:正式合同,STANDARD:标准合同)',
+    `change_reason`    varchar(200)          DEFAULT NULL COMMENT '变更原因',
+    `before_data_json` longtext              DEFAULT NULL COMMENT '变更前数据JSON',
+    `after_data_json`  longtext              DEFAULT NULL COMMENT '变更后数据JSON',
+    `approval_status`  varchar(20)  NOT NULL COMMENT '审核状态',
+    `approver_id`      varchar(32)           DEFAULT NULL COMMENT '审核人ID',
+    `approved_at`      datetime              DEFAULT NULL COMMENT '审核时间',
+    `create_by_id`     varchar(32)           DEFAULT NULL COMMENT '创建人ID',
+    `create_by`        varchar(50)           DEFAULT NULL COMMENT '创建人',
+    `update_by_id`     varchar(32)           DEFAULT NULL COMMENT '更新人ID',
+    `update_by`        varchar(50)           DEFAULT NULL COMMENT '更新人',
+    `create_time`      datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+    `update_time`      datetime     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
+    PRIMARY KEY (`id`),
+    KEY `idx_contract_change_application_contract_id` (`contract_id`),
+    KEY `idx_contract_change_application_root_contract_id` (`root_contract_id`),
+    KEY `idx_contract_change_application_approval_status` (`approval_status`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='合同变更申请单';

+package com.lframework.xingyun.sc.bo.contract;
+
+import com.lframework.starter.web.core.bo.BaseBo;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorStandardVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 合同变更申请单 GetBo
+ * </p>
+ */
+@Data
+public class GetContractChangeApplicationBo extends BaseBo<ContractChangeApplication> {
+
+    /**
+     * ID
+     */
+    @ApiModelProperty("ID")
+    private String id;
+
+    /**
+     * 合同ID
+     */
+    @ApiModelProperty("合同ID")
+    private String contractId;
+
+    /**
+     * 根合同ID
+     */
+    @ApiModelProperty("根合同ID")
+    private String rootContractId;
+
+    /**
+     * 合同编号
+     */
+    @ApiModelProperty("合同编号")
+    private String contractCode;
+
+    /**
+     * 合同类型
+     */
+    @ApiModelProperty("合同类型")
+    private String contractType;
+
+    /**
+     * 合同阶段
+     */
+    @ApiModelProperty("合同阶段")
+    private String contractStage;
+
+    /**
+     * 变更原因
+     */
+    @ApiModelProperty("变更原因")
+    private String changeReason;
+
+    /**
+     * 审核状态
+     */
+    @ApiModelProperty("审核状态")
+    private String approvalStatus;
+
+    /**
+     * 审核人ID
+     */
+    @ApiModelProperty("审核人ID")
+    private String approverId;
+
+    /**
+     * 审核时间
+     */
+    @ApiModelProperty("审核时间")
+    private LocalDateTime approvedAt;
+
+    /**
+     * 是否展示审核按钮
+     */
+    @ApiModelProperty("是否展示审核按钮")
+    private Boolean showExamine;
+
+    /**
+     * 变更后的合同数据
+     */
+    @ApiModelProperty("变更后的合同数据")
+    private UpdateContractDistributorStandardVo contractData;
+
+    public GetContractChangeApplicationBo() {
+    }
+
+    public GetContractChangeApplicationBo(ContractChangeApplication dto) {
+        super(dto);
+    }
+}

@@ -480,6 +480,30 @@ public class GetContractDistributorStandardBo extends BaseBo<ContractDistributor
     private Boolean canSplit;
     private Boolean canSplit;
 
 
     /**
     /**
+     * 是否可发起合同变更
+     */
+    @ApiModelProperty(value = "是否可发起合同变更")
+    private Boolean canCreateChange;
+
+    /**
+     * 是否可锁价
+     */
+    @ApiModelProperty(value = "是否可锁价")
+    private Boolean canPriceLock;
+
+    /**
+     * 是否可锁规
+     */
+    @ApiModelProperty(value = "是否可锁规")
+    private Boolean canSpecLock;
+
+    /**
+     * 是否可发起锁规延期申请
+     */
+    @ApiModelProperty(value = "是否可发起锁规延期申请")
+    private Boolean canCreateSpecLockDelay;
+
+    /**
      * 创建人
      * 创建人
      */
      */
     @ApiModelProperty(value = "创建人")
     @ApiModelProperty(value = "创建人")

+package com.lframework.xingyun.sc.bo.contract;
+
+import com.lframework.starter.web.core.bo.BaseBo;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 合同变更申请单 QueryBo
+ * </p>
+ */
+@Data
+public class QueryContractChangeApplicationBo extends BaseBo<ContractChangeApplication> {
+
+    /**
+     * ID
+     */
+    @ApiModelProperty("ID")
+    private String id;
+
+    /**
+     * 合同ID
+     */
+    @ApiModelProperty("合同ID")
+    private String contractId;
+
+    /**
+     * 根合同ID
+     */
+    @ApiModelProperty("根合同ID")
+    private String rootContractId;
+
+    /**
+     * 合同编号
+     */
+    @ApiModelProperty("合同编号")
+    private String contractCode;
+
+    /**
+     * 合同类型
+     */
+    @ApiModelProperty("合同类型")
+    private String contractType;
+
+    /**
+     * 合同阶段
+     */
+    @ApiModelProperty("合同阶段")
+    private String contractStage;
+
+    /**
+     * 变更原因
+     */
+    @ApiModelProperty("变更原因")
+    private String changeReason;
+
+    /**
+     * 审核状态
+     */
+    @ApiModelProperty("审核状态")
+    private String approvalStatus;
+
+    /**
+     * 是否展示审核按钮
+     */
+    @ApiModelProperty("是否展示审核按钮")
+    private Boolean showExamine;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty("创建时间")
+    private LocalDateTime createTime;
+
+    public QueryContractChangeApplicationBo() {
+    }
+
+    public QueryContractChangeApplicationBo(ContractChangeApplication dto) {
+        super(dto);
+    }
+}

@@ -153,6 +153,18 @@ public class QueryContractDistributorStandardBo extends BaseBo<ContractDistribut
     private BigDecimal totalAmountIncludingTax;
     private BigDecimal totalAmountIncludingTax;
 
 
     /**
     /**
+     * 生产厂ID
+     */
+    @ApiModelProperty("生产厂ID")
+    private String workshopId;
+
+    /**
+     * 生产厂名称
+     */
+    @ApiModelProperty("生产厂名称")
+    private String workshopName;
+
+    /**
      * 合计数量
      * 合计数量
      */
      */
     @ApiModelProperty("合计数量")
     @ApiModelProperty("合计数量")
@@ -240,6 +252,30 @@ public class QueryContractDistributorStandardBo extends BaseBo<ContractDistribut
     @ApiModelProperty(value = "是否可拆分")
     @ApiModelProperty(value = "是否可拆分")
     private Boolean canSplit;
     private Boolean canSplit;
 
 
+    /**
+     * 是否可发起合同变更
+     */
+    @ApiModelProperty(value = "是否可发起合同变更")
+    private Boolean canCreateChange;
+
+    /**
+     * 是否可锁价
+     */
+    @ApiModelProperty(value = "是否可锁价")
+    private Boolean canPriceLock;
+
+    /**
+     * 是否可锁规
+     */
+    @ApiModelProperty(value = "是否可锁规")
+    private Boolean canSpecLock;
+
+    /**
+     * 是否可发起锁规延期申请
+     */
+    @ApiModelProperty(value = "是否可发起锁规延期申请")
+    private Boolean canCreateSpecLockDelay;
+
 
 
     public QueryContractDistributorStandardBo() {
     public QueryContractDistributorStandardBo() {
 
 

+package com.lframework.xingyun.sc.controller.contract;
+
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.web.core.components.resp.InvokeResult;
+import com.lframework.starter.web.core.components.resp.InvokeResultBuilder;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.controller.DefaultBaseController;
+import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.starter.web.inner.entity.SysDept;
+import com.lframework.starter.web.inner.service.system.SysDeptService;
+import com.lframework.xingyun.basedata.entity.Customer;
+import com.lframework.xingyun.basedata.entity.Workshop;
+import com.lframework.xingyun.basedata.service.customer.CustomerService;
+import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
+import com.lframework.xingyun.sc.bo.contract.GetContractChangeApplicationBo;
+import com.lframework.xingyun.sc.bo.contract.QueryContractChangeApplicationBo;
+import com.lframework.xingyun.sc.bo.contract.QueryContractDistributorStandardBo;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
+import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeSelectableContractVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorStandardVo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotBlank;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * 合同变更申请单 Controller
+ */
+@Api(tags = "合同变更申请单")
+@Validated
+@RestController
+@RequestMapping("/contract/contractChangeApplication")
+public class ContractChangeApplicationController extends DefaultBaseController {
+
+    @Autowired
+    private ContractChangeApplicationService contractChangeApplicationService;
+    @Autowired
+    private CustomerService customerService;
+    @Autowired
+    private SysDeptService sysDeptService;
+    @Autowired
+    private WorkshopService workshopService;
+
+    /**
+     * 查询列表
+     */
+    @ApiOperation("查询列表")
+    @GetMapping("/query")
+    public InvokeResult<PageResult<QueryContractChangeApplicationBo>> query(QueryContractChangeApplicationVo vo) {
+        PageResult<ContractChangeApplication> pageResult = contractChangeApplicationService.query(getPageIndex(vo), getPageSize(vo), vo);
+        List<QueryContractChangeApplicationBo> results = null;
+        if (CollectionUtils.isNotEmpty(pageResult.getDatas())) {
+            results = pageResult.getDatas().stream().map(QueryContractChangeApplicationBo::new).collect(Collectors.toList());
+        }
+        return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
+    }
+
+    /**
+     * 根据ID查询
+     */
+    @ApiOperation("根据ID查询")
+    @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
+    @GetMapping
+    public InvokeResult<GetContractChangeApplicationBo> get(@NotBlank(message = "id不能为空！") String id) {
+        ContractChangeApplication data = contractChangeApplicationService.findById(id);
+        if (data == null) {
+            throw new DefaultClientException("合同变更申请单不存在！");
+        }
+
+        GetContractChangeApplicationBo result = new GetContractChangeApplicationBo(data);
+        if (org.apache.commons.lang3.StringUtils.isNotBlank(data.getAfterDataJson())) {
+            result.setContractData(JsonUtil.parseObject(data.getAfterDataJson(), UpdateContractDistributorStandardVo.class));
+        }
+        return InvokeResultBuilder.success(result);
+    }
+
+    /**
+     * 查询可发起变更的合同
+     */
+    @ApiOperation("查询可发起变更的合同")
+    @GetMapping("/querySelectableContracts")
+    public InvokeResult<PageResult<QueryContractDistributorStandardBo>> querySelectableContracts(QueryContractChangeSelectableContractVo vo) {
+        PageResult<ContractDistributorStandard> pageResult = contractChangeApplicationService
+                .querySelectableContracts(getPageIndex(vo), getPageSize(vo), vo);
+        List<QueryContractDistributorStandardBo> results = null;
+        if (CollectionUtils.isNotEmpty(pageResult.getDatas())) {
+            results = pageResult.getDatas().stream().map(QueryContractDistributorStandardBo::new).collect(Collectors.toList());
+            Map<String, Customer> customerMap = customerService.listByIds(results.stream()
+                            .map(QueryContractDistributorStandardBo::getBuyer)
+                            .collect(Collectors.toSet()))
+                    .stream()
+                    .collect(Collectors.toMap(Customer::getId, Function.identity()));
+            Map<String, SysDept> deptMap = sysDeptService.listByIds(results.stream()
+                            .map(QueryContractDistributorStandardBo::getDeptId)
+                            .collect(Collectors.toSet()))
+                    .stream()
+                    .collect(Collectors.toMap(SysDept::getId, Function.identity()));
+            Map<String, Workshop> workshopMap = workshopService.listByIds(results.stream()
+                            .map(QueryContractDistributorStandardBo::getWorkshopId)
+                            .collect(Collectors.toSet()))
+                    .stream()
+                    .collect(Collectors.toMap(Workshop::getId, Function.identity()));
+            results.forEach(item -> {
+                Customer customer = customerMap.get(item.getBuyer());
+                if (customer != null) {
+                    item.setBuyerName(customer.getName());
+                }
+                SysDept dept = deptMap.get(item.getDeptId());
+                if (dept != null) {
+                    item.setDeptName(dept.getName());
+                }
+                Workshop workshop = workshopMap.get(item.getWorkshopId());
+                if (workshop != null) {
+                    item.setWorkshopName(workshop.getName());
+                }
+            });
+        }
+        return InvokeResultBuilder.success(PageResultUtil.rebuild(pageResult, results));
+    }
+
+    /**
+     * 新增
+     */
+    @ApiOperation("新增")
+    @PostMapping
+    public InvokeResult<Void> create(@Valid @RequestBody CreateContractChangeApplicationVo vo) throws Exception {
+        contractChangeApplicationService.create(vo);
+        return InvokeResultBuilder.success();
+    }
+
+    /**
+     * 修改
+     */
+    @ApiOperation("修改")
+    @PutMapping
+    public InvokeResult<Void> update(@Valid @RequestBody UpdateContractChangeApplicationVo vo) throws Exception {
+        contractChangeApplicationService.update(vo);
+        return InvokeResultBuilder.success();
+    }
+
+    /**
+     * 取消
+     */
+    @ApiOperation("取消")
+    @ApiImplicitParam(value = "id", name = "id", paramType = "query", required = true)
+    @DeleteMapping
+    public InvokeResult<Void> cancel(@NotBlank(message = "id不能为空！") String id) {
+        contractChangeApplicationService.cancelApplication(id);
+        return InvokeResultBuilder.success();
+    }
+}

@@ -24,6 +24,7 @@ import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
 import com.lframework.xingyun.sc.entity.SpecLockDelayApplication;
 import com.lframework.xingyun.sc.entity.SpecLockDelayApplication;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
 import com.lframework.xingyun.sc.vo.contract.createVo.CreateSpecLockDelayApplicationVo;
 import com.lframework.xingyun.sc.vo.contract.createVo.CreateSpecLockDelayApplicationVo;
 import com.lframework.xingyun.sc.vo.contract.queryVo.QuerySpecLockDelayApplicationVo;
 import com.lframework.xingyun.sc.vo.contract.queryVo.QuerySpecLockDelayApplicationVo;
@@ -65,6 +66,8 @@ public class SpecLockDelayApplicationController extends DefaultBaseController {
     private CustomerService customerService;
     private CustomerService customerService;
     @Autowired
     @Autowired
     private WorkshopService workshopService;
     private WorkshopService workshopService;
+    @Autowired
+    private ContractChangeApplicationService contractChangeApplicationService;
 
 
     public static final String AUDIT_STATUS_DIC_CODE = "AUDIT_STATUS"; // 审核状态
     public static final String AUDIT_STATUS_DIC_CODE = "AUDIT_STATUS"; // 审核状态
 
 
@@ -225,6 +228,11 @@ public class SpecLockDelayApplicationController extends DefaultBaseController {
         if (contractDistributorStandard == null) {
         if (contractDistributorStandard == null) {
             throw new DefaultClientException("对应锁价无规格合同不存在！");
             throw new DefaultClientException("对应锁价无规格合同不存在！");
         }
         }
+        String rootContractId = StringUtils.isBlank(contractDistributorStandard.getParentId())
+                ? contractDistributorStandard.getId() : contractDistributorStandard.getParentId();
+        if (contractChangeApplicationService.hasUnfinishedApplication(rootContractId)) {
+            throw new DefaultClientException("该合同存在未结束的合同变更流程，不允许发起锁规延期申请！");
+        }
 
 
         QuerySpecLockDelayApplicationVo vo = new QuerySpecLockDelayApplicationVo();
         QuerySpecLockDelayApplicationVo vo = new QuerySpecLockDelayApplicationVo();
         vo.setContractId(id);
         vo.setContractId(id);

+package com.lframework.xingyun.sc.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.lframework.starter.web.core.dto.BaseDto;
+import com.lframework.starter.web.core.entity.BaseEntity;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+/**
+ * <p>
+ * 合同变更申请单
+ * </p>
+ */
+@Data
+@TableName("tbl_contract_change_application")
+public class ContractChangeApplication extends BaseEntity implements BaseDto {
+
+    private static final long serialVersionUID = 1L;
+
+    public static final String CACHE_NAME = "ContractChangeApplication";
+
+    /**
+     * ID
+     */
+    private String id;
+
+    /**
+     * 合同ID
+     */
+    private String contractId;
+
+    /**
+     * 根合同ID
+     */
+    private String rootContractId;
+
+    /**
+     * 合同编号
+     */
+    private String contractCode;
+
+    /**
+     * 合同类型
+     */
+    private String contractType;
+
+    /**
+     * 合同阶段(FORMAL:正式合同,STANDARD:标准合同)
+     */
+    private String contractStage;
+
+    /**
+     * 变更原因
+     */
+    private String changeReason;
+
+    /**
+     * 变更前数据JSON
+     */
+    private String beforeDataJson;
+
+    /**
+     * 变更后数据JSON
+     */
+    private String afterDataJson;
+
+    /**
+     * 审核状态
+     */
+    private String approvalStatus;
+
+    /**
+     * 审核人ID
+     */
+    private String approverId;
+
+    /**
+     * 审核时间
+     */
+    private LocalDateTime approvedAt;
+
+    /**
+     * 办事处编码(非持久化字段)
+     */
+    @TableField(exist = false)
+    private String deptCode;
+
+    /**
+     * 生产厂编码(非持久化字段)
+     */
+    @TableField(exist = false)
+    private String workshopCode;
+
+    /**
+     * 是否展示审核按钮(非持久化字段)
+     */
+    @TableField(exist = false)
+    private Boolean showExamine;
+
+    /**
+     * 创建人ID
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createById;
+
+    /**
+     * 创建人
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private String createBy;
+
+    /**
+     * 更新人ID
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateById;
+
+    /**
+     * 更新人
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private String updateBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(fill = FieldFill.INSERT)
+    private LocalDateTime createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(fill = FieldFill.INSERT_UPDATE)
+    private LocalDateTime updateTime;
+}

@@ -369,6 +369,30 @@ public class ContractDistributorStandard extends BaseEntity implements BaseDto {
     private Boolean canSplit;
     private Boolean canSplit;
 
 
     /**
     /**
+     * 是否可发起合同变更
+     */
+    @TableField(exist = false)
+    private Boolean canCreateChange;
+
+    /**
+     * 是否可锁价
+     */
+    @TableField(exist = false)
+    private Boolean canPriceLock;
+
+    /**
+     * 是否可锁规
+     */
+    @TableField(exist = false)
+    private Boolean canSpecLock;
+
+    /**
+     * 是否可发起锁规延期申请
+     */
+    @TableField(exist = false)
+    private Boolean canCreateSpecLockDelay;
+
+    /**
      * 剩余锁规数量
      * 剩余锁规数量
      */
      */
     @TableField(exist = false)
     @TableField(exist = false)

@@ -19,6 +19,7 @@ import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractStdProcessingLineService;
 import com.lframework.xingyun.sc.service.contract.ContractStdProcessingLineService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
@@ -106,6 +107,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     @Resource
     @Resource
     private SpecLockDelayApplicationService specLockDelayApplicationService;
     private SpecLockDelayApplicationService specLockDelayApplicationService;
     @Resource
     @Resource
+    private ContractChangeApplicationService contractChangeApplicationService;
+    @Resource
     private DraftRequestCarTicketService draftRequestCarTicketService;
     private DraftRequestCarTicketService draftRequestCarTicketService;
     @Resource
     @Resource
     private RequestCarTicketService requestCarTicketService;
     private RequestCarTicketService requestCarTicketService;
@@ -200,6 +203,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "SPEC_LOCK_DELAY":
             case "SPEC_LOCK_DELAY":
                 handleSpecLockDelayAuditData(flowStatus, businessId);
                 handleSpecLockDelayAuditData(flowStatus, businessId);
                 break;
                 break;
+            case "CONTRACT_CHANGE":
+                handleContractChangeAuditData(flowStatus, businessId);
+                break;
             case "DRAFT_REQUEST_CAR":
             case "DRAFT_REQUEST_CAR":
                 handleDraftRequestCarTicketData(flowStatus, businessId, variable);
                 handleDraftRequestCarTicketData(flowStatus, businessId, variable);
                 break;
                 break;
@@ -276,6 +282,19 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
         }
         }
     }
     }
 
 
+    private void handleContractChangeAuditData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            contractChangeApplicationService.updateAuditStatus(businessId, "PASS");
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            contractChangeApplicationService.updateAuditStatus(businessId, "REFUSE");
+        } else if (FlowInstanceStatus.UNDO.getCode().equals(flowStatus)) {
+            contractChangeApplicationService.updateAuditStatus(businessId, "CANCEL");
+        }
+    }
+
     /**
     /**
      * 客户开发业务数据处理
      * 客户开发业务数据处理
      *
      *

+package com.lframework.xingyun.sc.impl.contract;
+
+import cn.hutool.core.bean.BeanUtil;
+import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.dto.FlowTaskDto;
+import com.lframework.starter.bpm.mappers.FlowTaskWrapperMapper;
+import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
+import com.lframework.starter.bpm.vo.flow.task.QueryTodoTaskListVo;
+import com.lframework.starter.common.exceptions.impl.DefaultClientException;
+import com.lframework.starter.common.utils.Assert;
+import com.lframework.starter.common.utils.ObjectUtil;
+import com.lframework.starter.web.core.annotations.oplog.OpLog;
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.components.security.SecurityUtil;
+import com.lframework.starter.web.core.impl.BaseMpServiceImpl;
+import com.lframework.starter.web.core.utils.IdUtil;
+import com.lframework.starter.web.core.utils.JsonUtil;
+import com.lframework.starter.web.core.utils.OpLogUtil;
+import com.lframework.starter.web.core.utils.PageHelperUtil;
+import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
+import com.lframework.starter.web.inner.entity.SysDept;
+import com.lframework.starter.web.inner.service.system.SysDeptService;
+import com.lframework.xingyun.basedata.entity.Workshop;
+import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import com.lframework.xingyun.sc.entity.ContractDistributorLine;
+import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
+import com.lframework.xingyun.sc.entity.ContractStdProcessingLine;
+import com.lframework.xingyun.sc.entity.SpecLockDelayApplication;
+import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
+import com.lframework.xingyun.sc.mappers.ContractChangeApplicationMapper;
+import com.lframework.xingyun.sc.mappers.ContractDistributorStandardMapper;
+import com.lframework.xingyun.sc.mappers.SpecLockDelayApplicationMapper;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
+import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
+import com.lframework.xingyun.sc.service.contract.ContractStdProcessingLineService;
+import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractDistributorLineVo;
+import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractStdProcessingLineVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeSelectableContractVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorLineVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorStandardVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractStdProcessingLineVo;
+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.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * 合同变更申请单 Service 实现
+ */
+@Service
+@Slf4j
+public class ContractChangeApplicationServiceImpl extends BaseMpServiceImpl<ContractChangeApplicationMapper, ContractChangeApplication>
+        implements ContractChangeApplicationService {
+
+    private static final String BPM_FLAG = "CONTRACT_CHANGE";
+
+    @Autowired
+    private FlowInstanceWrapperService flowInstanceWrapperService;
+    @Resource
+    private FlowTaskWrapperMapper flowTaskWrapperMapper;
+    @Resource
+    private ContractDistributorStandardMapper contractDistributorStandardMapper;
+    @Resource
+    private ContractDistributorLineService contractDistributorLineService;
+    @Resource
+    private ContractStdProcessingLineService contractStdProcessingLineService;
+    @Resource
+    private SpecLockDelayApplicationMapper specLockDelayApplicationMapper;
+    @Resource
+    private WorkshopService workshopService;
+    @Resource
+    private SysDeptService sysDeptService;
+
+    @Override
+    public PageResult<ContractChangeApplication> query(Integer pageIndex, Integer pageSize, QueryContractChangeApplicationVo vo) {
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+
+        PageHelperUtil.startPage(pageIndex, pageSize);
+        Wrapper<ContractChangeApplication> wrapper = Wrappers.lambdaQuery(ContractChangeApplication.class)
+                .like(StringUtils.isNotBlank(vo.getContractCode()), ContractChangeApplication::getContractCode, vo.getContractCode())
+                .eq(StringUtils.isNotBlank(vo.getContractType()), ContractChangeApplication::getContractType, vo.getContractType())
+                .eq(StringUtils.isNotBlank(vo.getContractStage()), ContractChangeApplication::getContractStage, vo.getContractStage())
+                .eq(StringUtils.isNotBlank(vo.getApprovalStatus()), ContractChangeApplication::getApprovalStatus, vo.getApprovalStatus())
+                .orderByDesc(ContractChangeApplication::getCreateTime);
+        List<ContractChangeApplication> datas = list(wrapper);
+        fillShowExamine(datas);
+        return PageResultUtil.convert(new PageInfo<>(datas));
+    }
+
+    @Override
+    public ContractChangeApplication findById(String id) {
+        ContractChangeApplication data = getBaseMapper().selectById(id);
+        if (data == null) {
+            return null;
+        }
+        fillShowExamine(Arrays.asList(data));
+        return data;
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    @OpLog(type = OtherOpLogType.class, name = "新增合同变更申请单，ID：{}", params = {"#id"})
+    public String create(CreateContractChangeApplicationVo vo) throws Exception {
+        ContractDistributorStandard contract = getContractOrThrow(vo.getContractId());
+        validateContractCanChange(contract);
+
+        UpdateContractDistributorStandardVo beforeData = buildContractData(contract);
+        UpdateContractDistributorStandardVo afterData = normalizeContractData(contract, vo.getContractData(), vo.getChangeReason());
+
+        ContractChangeApplication data = new ContractChangeApplication();
+        data.setId(IdUtil.getUUID());
+        data.setContractId(contract.getId());
+        data.setRootContractId(getRootContractId(contract));
+        data.setContractCode(contract.getCode());
+        data.setContractType(contract.getType());
+        data.setContractStage(contract.getStatus());
+        data.setChangeReason(StringUtils.defaultIfBlank(vo.getChangeReason(), afterData.getChangeReason()));
+        data.setBeforeDataJson(JsonUtil.toJsonString(beforeData));
+        data.setAfterDataJson(JsonUtil.toJsonString(afterData));
+        data.setApprovalStatus(CustomerDevelopStatus.AUDIT.name());
+
+        fillFlowVariables(data, contract);
+        getBaseMapper().insert(data);
+
+        OpLogUtil.setVariable("id", data.getId());
+        OpLogUtil.setExtra(vo);
+
+        data.setCreateById(SecurityUtil.getCurrentUser().getId());
+        flowInstanceWrapperService.startInstance(BPM_FLAG, data.getId(), BPM_FLAG, data);
+        return data.getId();
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    @OpLog(type = OtherOpLogType.class, name = "修改合同变更申请单，ID：{}", params = {"#vo.id"})
+    public void update(UpdateContractChangeApplicationVo vo) throws Exception {
+        ContractChangeApplication data = getBaseMapper().selectById(vo.getId());
+        if (data == null) {
+            throw new DefaultClientException("合同变更申请单不存在！");
+        }
+        if (!CustomerDevelopStatus.REFUSE.name().equals(data.getApprovalStatus())) {
+            throw new DefaultClientException(CustomerDevelopStatus.getDescByNameSafe(data.getApprovalStatus()) + "的合同变更申请单不允许修改！");
+        }
+
+        ContractDistributorStandard contract = getContractOrThrow(data.getContractId());
+        UpdateContractDistributorStandardVo beforeData = buildContractData(contract);
+        UpdateContractDistributorStandardVo afterData = normalizeContractData(contract, vo.getContractData(), vo.getChangeReason());
+
+        Wrapper<ContractChangeApplication> wrapper = Wrappers.lambdaUpdate(ContractChangeApplication.class)
+                .set(ContractChangeApplication::getChangeReason, StringUtils.defaultIfBlank(vo.getChangeReason(), afterData.getChangeReason()))
+                .set(ContractChangeApplication::getBeforeDataJson, JsonUtil.toJsonString(beforeData))
+                .set(ContractChangeApplication::getAfterDataJson, JsonUtil.toJsonString(afterData))
+                .set(ContractChangeApplication::getApprovalStatus, CustomerDevelopStatus.AUDIT.name())
+                .eq(ContractChangeApplication::getId, vo.getId());
+        update(wrapper);
+
+        fillFlowVariables(data, contract);
+        data.setAfterDataJson(JsonUtil.toJsonString(afterData));
+        data.setChangeReason(StringUtils.defaultIfBlank(vo.getChangeReason(), afterData.getChangeReason()));
+        flowInstanceWrapperService.startInstance(BPM_FLAG, data.getId(), BPM_FLAG, data);
+
+        OpLogUtil.setVariable("id", data.getId());
+        OpLogUtil.setExtra(vo);
+        cleanCacheByKey(data.getId());
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    @OpLog(type = OtherOpLogType.class, name = "取消合同变更申请单，ID：{}", params = {"#id"})
+    public void cancelApplication(String id) {
+        ContractChangeApplication data = getBaseMapper().selectById(id);
+        if (data == null) {
+            throw new DefaultClientException("合同变更申请单不存在！");
+        }
+        if (CustomerDevelopStatus.CANCEL.name().equals(data.getApprovalStatus())) {
+            throw new DefaultClientException("合同变更申请单已取消！");
+        }
+        if (!CustomerDevelopStatus.REFUSE.name().equals(data.getApprovalStatus())) {
+            throw new DefaultClientException(CustomerDevelopStatus.getDescByNameSafe(data.getApprovalStatus()) + "的合同变更申请单不允许取消！");
+        }
+
+        Wrapper<ContractChangeApplication> wrapper = Wrappers.lambdaUpdate(ContractChangeApplication.class)
+                .set(ContractChangeApplication::getApprovalStatus, CustomerDevelopStatus.CANCEL.name())
+                .set(ContractChangeApplication::getApprovedAt, LocalDateTime.now())
+                .set(ContractChangeApplication::getApproverId, SecurityUtil.getCurrentUser().getId())
+                .eq(ContractChangeApplication::getId, id);
+        update(wrapper);
+
+        cleanCacheByKey(id);
+    }
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    @OpLog(type = OtherOpLogType.class, name = "合同变更申请单审批完成，ID：{}，审批状态：{}", params = {"#id", "#approvalStatus"})
+    public void updateAuditStatus(String id, String approvalStatus) {
+        if (StringUtils.isBlank(id) || StringUtils.isBlank(approvalStatus)) {
+            return;
+        }
+
+        ContractChangeApplication data = getBaseMapper().selectById(id);
+        if (data == null) {
+            return;
+        }
+
+        Wrapper<ContractChangeApplication> wrapper = Wrappers.lambdaUpdate(ContractChangeApplication.class)
+                .set(ContractChangeApplication::getApprovalStatus, approvalStatus)
+                .set(ContractChangeApplication::getApprovedAt, LocalDateTime.now())
+                .set(ContractChangeApplication::getApproverId, SecurityUtil.getCurrentUser().getId())
+                .eq(ContractChangeApplication::getId, id);
+        update(wrapper);
+
+        if (CustomerDevelopStatus.PASS.name().equals(approvalStatus)) {
+            applyContractChange(data);
+        }
+
+        cleanCacheByKey(id);
+    }
+
+    @Override
+    public PageResult<ContractDistributorStandard> querySelectableContracts(Integer pageIndex, Integer pageSize,
+                                                                            QueryContractChangeSelectableContractVo vo) {
+        Assert.greaterThanZero(pageIndex);
+        Assert.greaterThanZero(pageSize);
+
+        PageHelperUtil.startPage(pageIndex, pageSize);
+        List<ContractDistributorStandard> datas = getBaseMapper().querySelectableContracts(vo);
+        return PageResultUtil.convert(new PageInfo<>(datas));
+    }
+
+    @Override
+    public boolean hasUnfinishedApplication(String rootContractId) {
+        if (StringUtils.isBlank(rootContractId)) {
+            return false;
+        }
+        Wrapper<ContractChangeApplication> wrapper = Wrappers.lambdaQuery(ContractChangeApplication.class)
+                .eq(ContractChangeApplication::getRootContractId, rootContractId)
+                .notIn(ContractChangeApplication::getApprovalStatus,
+                        Arrays.asList(CustomerDevelopStatus.PASS.name(), CustomerDevelopStatus.CANCEL.name()));
+        return count(wrapper) > 0;
+    }
+
+    @CacheEvict(value = ContractChangeApplication.CACHE_NAME, key = "@cacheVariables.tenantId() + #key")
+    @Override
+    public void cleanCacheByKey(Serializable key) {
+    }
+
+    /**
+     * 填充审核待办标识
+     *
+     * @param datas 数据列表
+     */
+    private void fillShowExamine(List<ContractChangeApplication> datas) {
+        if (CollectionUtils.isEmpty(datas)) {
+            return;
+        }
+
+        List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(),
+                SecurityUtil.getCurrentUser().getId());
+        if (CollectionUtils.isEmpty(flowTaskList)) {
+            datas.forEach(item -> item.setShowExamine(false));
+            return;
+        }
+
+        Set<String> ids = flowTaskList.stream()
+                .filter(task -> BPM_FLAG.equals(task.getMode()))
+                .map(FlowTaskDto::getBusinessId)
+                .collect(Collectors.toSet());
+        datas.forEach(item -> item.setShowExamine(ids.contains(item.getId())));
+    }
+
+    /**
+     * 获取合同，不存在则抛异常
+     *
+     * @param contractId 合同ID
+     * @return 合同
+     */
+    private ContractDistributorStandard getContractOrThrow(String contractId) {
+        ContractDistributorStandard contract = contractDistributorStandardMapper.selectById(contractId);
+        if (contract == null) {
+            throw new DefaultClientException("合同不存在！");
+        }
+        return contract;
+    }
+
+    /**
+     * 校验合同是否允许发起变更
+     *
+     * @param contract 合同
+     */
+    private void validateContractCanChange(ContractDistributorStandard contract) {
+        if (contract == null) {
+            throw new DefaultClientException("合同不存在！");
+        }
+        if (!isSupportedChangeContract(contract)) {
+            throw new DefaultClientException("该合同当前不允许发起变更！");
+        }
+
+        String rootContractId = getRootContractId(contract);
+        if (hasUnfinishedApplication(rootContractId)) {
+            throw new DefaultClientException("该合同存在未结束的合同变更流程，不允许重复发起变更！");
+        }
+        if (hasUnfinishedSpecLockDelay(rootContractId)) {
+            throw new DefaultClientException("该合同存在未结束的锁规延期申请，不允许发起合同变更！");
+        }
+    }
+
+    /**
+     * 判断是否为支持发起变更的合同
+     *
+     * @param contract 合同
+     * @return 是否支持
+     */
+    private boolean isSupportedChangeContract(ContractDistributorStandard contract) {
+        if (contract == null || StringUtils.isBlank(contract.getType()) || StringUtils.isBlank(contract.getStatus())) {
+            return false;
+        }
+
+        if ("DISTRIB_STD".equals(contract.getType())
+                || "DRAFT_DIST_AGMT".equals(contract.getType())
+                || "INTL_STD_CONTRACT".equals(contract.getType())
+                || "INTL_OPEN_SPEC_AGMT".equals(contract.getType())
+                || "PROCESS_STD_AGMT".equals(contract.getType())) {
+            return "STANDARD".equals(contract.getStatus()) && CustomerDevelopStatus.PASS.name().equals(contract.getStandardApproved());
+        }
+
+        if ("DIST_STOCK_CONTRACT".equals(contract.getType()) || "INTL_INVENTORY_AGMT".equals(contract.getType())) {
+            if ("FORMAL".equals(contract.getStatus())) {
+                return CustomerDevelopStatus.PASS.name().equals(contract.getFormalApproved());
+            }
+            if ("STANDARD".equals(contract.getStatus())) {
+                return CustomerDevelopStatus.PASS.name().equals(contract.getStandardApproved());
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 构建合同变更数据快照
+     *
+     * @param contract 合同
+     * @return 合同变更数据
+     */
+    private UpdateContractDistributorStandardVo buildContractData(ContractDistributorStandard contract) {
+        UpdateContractDistributorStandardVo result = JsonUtil.parseObject(JsonUtil.toJsonString(contract),
+                UpdateContractDistributorStandardVo.class);
+
+        Wrapper<ContractDistributorLine> distributorLineWrapper = Wrappers.lambdaQuery(ContractDistributorLine.class)
+                .eq(ContractDistributorLine::getContractId, contract.getId())
+                .orderByAsc(ContractDistributorLine::getShowOrder);
+        List<ContractDistributorLine> distributorLineList = contractDistributorLineService.list(distributorLineWrapper);
+        if (CollectionUtils.isNotEmpty(distributorLineList)) {
+            result.setContractDistributorLineList(JsonUtil.parseList(JsonUtil.toJsonString(distributorLineList),
+                    UpdateContractDistributorLineVo.class));
+        } else {
+            result.setContractDistributorLineList(new ArrayList<>());
+        }
+
+        Wrapper<ContractStdProcessingLine> processingLineWrapper = Wrappers.lambdaQuery(ContractStdProcessingLine.class)
+                .eq(ContractStdProcessingLine::getContractId, contract.getId())
+                .orderByAsc(ContractStdProcessingLine::getShowOrder);
+        List<ContractStdProcessingLine> processingLineList = contractStdProcessingLineService.list(processingLineWrapper);
+        if (CollectionUtils.isNotEmpty(processingLineList)) {
+            result.setContractStdProcessingLineList(JsonUtil.parseList(JsonUtil.toJsonString(processingLineList),
+                    UpdateContractStdProcessingLineVo.class));
+        } else {
+            result.setContractStdProcessingLineList(new ArrayList<>());
+        }
+        return result;
+    }
+
+    /**
+     * 规范化变更后的合同数据
+     *
+     * @param contract 原合同
+     * @param contractData 变更后的合同数据
+     * @param changeReason 变更原因
+     * @return 规范化后的合同数据
+     */
+    private UpdateContractDistributorStandardVo normalizeContractData(ContractDistributorStandard contract,
+                                                                      UpdateContractDistributorStandardVo contractData,
+                                                                      String changeReason) {
+        if (contractData == null) {
+            throw new DefaultClientException("变更后的合同数据不能为空！");
+        }
+
+        UpdateContractDistributorStandardVo result = JsonUtil.parseObject(JsonUtil.toJsonString(contractData),
+                UpdateContractDistributorStandardVo.class);
+        result.setId(contract.getId());
+        result.setType(contract.getType());
+        result.setStatus(contract.getStatus());
+        result.setParentId(contract.getParentId());
+        result.setChangeReason(StringUtils.defaultIfBlank(changeReason, result.getChangeReason()));
+        if (result.getContractDistributorLineList() == null) {
+            result.setContractDistributorLineList(new ArrayList<>());
+        }
+        if (result.getContractStdProcessingLineList() == null) {
+            result.setContractStdProcessingLineList(new ArrayList<>());
+        }
+        return result;
+    }
+
+    /**
+     * 填充流程变量
+     *
+     * @param data 申请单
+     * @param contract 合同
+     */
+    private void fillFlowVariables(ContractChangeApplication data, ContractDistributorStandard contract) {
+        if (data == null || contract == null) {
+            return;
+        }
+
+        Workshop workshop = workshopService.findById(contract.getWorkshopId());
+        data.setWorkshopCode(workshop == null ? "" : workshop.getCode());
+        SysDept sysDept = sysDeptService.findById(contract.getDeptId());
+        data.setDeptCode(sysDept == null ? "" : sysDept.getCode());
+    }
+
+    /**
+     * 获取根合同ID
+     *
+     * @param contract 合同
+     * @return 根合同ID
+     */
+    private String getRootContractId(ContractDistributorStandard contract) {
+        if (contract == null) {
+            return null;
+        }
+        return StringUtils.isBlank(contract.getParentId()) ? contract.getId() : contract.getParentId();
+    }
+
+    /**
+     * 是否存在未结束的锁规延期申请
+     *
+     * @param rootContractId 根合同ID
+     * @return 是否存在未结束的锁规延期申请
+     */
+    private boolean hasUnfinishedSpecLockDelay(String rootContractId) {
+        if (StringUtils.isBlank(rootContractId)) {
+            return false;
+        }
+
+        Wrapper<ContractDistributorStandard> contractWrapper = Wrappers.lambdaQuery(ContractDistributorStandard.class)
+                .select(ContractDistributorStandard::getId)
+                .eq(ContractDistributorStandard::getId, rootContractId)
+                .or()
+                .eq(ContractDistributorStandard::getParentId, rootContractId);
+        List<ContractDistributorStandard> contractList = contractDistributorStandardMapper.selectList(contractWrapper);
+        List<String> contractIds = contractList.stream().map(ContractDistributorStandard::getId).collect(Collectors.toList());
+        if (!contractIds.contains(rootContractId)) {
+            contractIds.add(rootContractId);
+        }
+
+        Wrapper<SpecLockDelayApplication> wrapper = Wrappers.lambdaQuery(SpecLockDelayApplication.class)
+                .in(SpecLockDelayApplication::getContractId, contractIds)
+                .notIn(SpecLockDelayApplication::getApprovalStatus,
+                        Arrays.asList(CustomerDevelopStatus.PASS.name(), CustomerDevelopStatus.CANCEL.name()));
+        return specLockDelayApplicationMapper.selectCount(wrapper) > 0;
+    }
+
+    /**
+     * 应用合同变更
+     *
+     * @param application 变更申请单
+     */
+    private void applyContractChange(ContractChangeApplication application) {
+        if (application == null || StringUtils.isBlank(application.getAfterDataJson())) {
+            return;
+        }
+
+        UpdateContractDistributorStandardVo vo = JsonUtil.parseObject(application.getAfterDataJson(),
+                UpdateContractDistributorStandardVo.class);
+        ContractDistributorStandard data = contractDistributorStandardMapper.selectById(application.getContractId());
+        if (data == null) {
+            throw new DefaultClientException("对应合同不存在！");
+        }
+
+        Wrapper<ContractDistributorStandard> wrapper = Wrappers.lambdaUpdate(ContractDistributorStandard.class)
+                .set(ContractDistributorStandard::getCode, vo.getCode())
+                .set(ContractDistributorStandard::getSupplier, vo.getSupplier())
+                .set(ContractDistributorStandard::getBuyer, vo.getBuyer())
+                .set(ContractDistributorStandard::getDeptId, vo.getDeptId())
+                .set(ContractDistributorStandard::getRegion, vo.getRegion())
+                .set(ContractDistributorStandard::getStockUpCompanyId, vo.getStockUpCompanyId())
+                .set(ContractDistributorStandard::getOrderDate, vo.getOrderDate())
+                .set(ContractDistributorStandard::getUnit, vo.getUnit())
+                .set(ContractDistributorStandard::getWorkshopId, vo.getWorkshopId())
+                .set(ContractDistributorStandard::getTotalAmountCapital, vo.getTotalAmountCapital())
+                .set(ContractDistributorStandard::getDepositInfo, vo.getDepositInfo())
+                .set(ContractDistributorStandard::getPackagingRequirements, vo.getPackagingRequirements())
+                .set(ContractDistributorStandard::getPaymentTerms, vo.getPaymentTerms())
+                .set(ContractDistributorStandard::getExecutionStandard, vo.getExecutionStandard())
+                .set(ContractDistributorStandard::getExecutionStandardRemarks, vo.getExecutionStandardRemarks())
+                .set(ContractDistributorStandard::getTransportMode, vo.getTransportMode())
+                .set(ContractDistributorStandard::getDestination, vo.getDestination())
+                .set(ContractDistributorStandard::getForeignDestination, vo.getForeignDestination())
+                .set(ContractDistributorStandard::getIncludesPackagingFee, vo.getIncludesPackagingFee())
+                .set(ContractDistributorStandard::getIncludesTransportFee, vo.getIncludesTransportFee())
+                .set(ContractDistributorStandard::getPieceWeightHead, vo.getPieceWeightHead())
+                .set(ContractDistributorStandard::getSurface, vo.getSurface())
+                .set(ContractDistributorStandard::getTolerance, vo.getTolerance())
+                .set(ContractDistributorStandard::getPerformance, vo.getPerformance())
+                .set(ContractDistributorStandard::getComponent, vo.getComponent())
+                .set(ContractDistributorStandard::getPackaging, vo.getPackaging())
+                .set(ContractDistributorStandard::getSpecialTerms, vo.getSpecialTerms())
+                .set(ContractDistributorStandard::getDesignatedConsignee, vo.getDesignatedConsignee())
+                .set(ContractDistributorStandard::getSpecialInstructions, vo.getSpecialInstructions())
+                .set(ContractDistributorStandard::getRemarks, vo.getRemarks())
+                .set(ContractDistributorStandard::getTotalQuantity, vo.getTotalQuantity())
+                .set(ContractDistributorStandard::getTotalAmountExcludingTax, vo.getTotalAmountExcludingTax())
+                .set(ContractDistributorStandard::getTotalAmountIncludingTax, vo.getTotalAmountIncludingTax())
+                .set(ContractDistributorStandard::getChangeReason, vo.getChangeReason())
+                .eq(ContractDistributorStandard::getId, application.getContractId());
+        contractDistributorStandardMapper.update(wrapper);
+
+        overwriteDistributorLines(application.getContractId(), vo);
+        overwriteProcessingLines(application.getContractId(), vo);
+    }
+
+    /**
+     * 覆盖普通合同行
+     *
+     * @param contractId 合同ID
+     * @param vo 合同数据
+     */
+    private void overwriteDistributorLines(String contractId, UpdateContractDistributorStandardVo vo) {
+        Wrapper<ContractDistributorLine> removeWrapper = Wrappers.lambdaQuery(ContractDistributorLine.class)
+                .eq(ContractDistributorLine::getContractId, contractId);
+        contractDistributorLineService.remove(removeWrapper);
+
+        if (CollectionUtils.isEmpty(vo.getContractDistributorLineList())) {
+            return;
+        }
+
+        for (int i = 0; i < vo.getContractDistributorLineList().size(); i++) {
+            UpdateContractDistributorLineVo lineVo = vo.getContractDistributorLineList().get(i);
+            CreateContractDistributorLineVo createVo = new CreateContractDistributorLineVo();
+            BeanUtil.copyProperties(lineVo, createVo);
+            createVo.setContractId(contractId);
+            createVo.setShowOrder(i);
+            contractDistributorLineService.create(createVo);
+        }
+    }
+
+    /**
+     * 覆盖加工合同行
+     *
+     * @param contractId 合同ID
+     * @param vo 合同数据
+     */
+    private void overwriteProcessingLines(String contractId, UpdateContractDistributorStandardVo vo) {
+        Wrapper<ContractStdProcessingLine> removeWrapper = Wrappers.lambdaQuery(ContractStdProcessingLine.class)
+                .eq(ContractStdProcessingLine::getContractId, contractId);
+        contractStdProcessingLineService.remove(removeWrapper);
+
+        if (CollectionUtils.isEmpty(vo.getContractStdProcessingLineList())) {
+            return;
+        }
+
+        for (int i = 0; i < vo.getContractStdProcessingLineList().size(); i++) {
+            UpdateContractStdProcessingLineVo lineVo = vo.getContractStdProcessingLineList().get(i);
+            CreateContractStdProcessingLineVo createVo = new CreateContractStdProcessingLineVo();
+            BeanUtil.copyProperties(lineVo, createVo);
+            createVo.setContractId(contractId);
+            createVo.setShowOrder(i);
+            contractStdProcessingLineService.create(createVo);
+        }
+    }
+}

@@ -35,7 +35,9 @@ import com.lframework.starter.common.utils.ObjectUtil;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
+import com.lframework.xingyun.sc.mappers.SpecLockDelayApplicationMapper;
 import com.lframework.xingyun.sc.mappers.ContractDistributorStandardMapper;
 import com.lframework.xingyun.sc.mappers.ContractDistributorStandardMapper;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorLineService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractFrameworkService;
 import com.lframework.xingyun.sc.service.contract.ContractFrameworkService;
@@ -110,6 +112,10 @@ public class ContractDistributorStandardServiceImpl extends
     private PurchaseOrderLineService purchaseOrderLineService;
     private PurchaseOrderLineService purchaseOrderLineService;
     @Resource
     @Resource
     private TransactorHandler transactorHandler;
     private TransactorHandler transactorHandler;
+    @Resource
+    private ContractChangeApplicationService contractChangeApplicationService;
+    @Resource
+    private SpecLockDelayApplicationMapper specLockDelayApplicationMapper;
 
 
     @Override
     @Override
     public PageResult<ContractDistributorStandard> query(Integer pageIndex, Integer pageSize, QueryContractDistributorStandardVo vo) {
     public PageResult<ContractDistributorStandard> query(Integer pageIndex, Integer pageSize, QueryContractDistributorStandardVo vo) {
@@ -218,7 +224,7 @@ public class ContractDistributorStandardServiceImpl extends
     public List<ContractDistributorStandard> query(QueryContractDistributorStandardVo vo) {
     public List<ContractDistributorStandard> query(QueryContractDistributorStandardVo vo) {
 
 
         List<ContractDistributorStandard> datas = getBaseMapper().query(vo);
         List<ContractDistributorStandard> datas = getBaseMapper().query(vo);
-        CollectionUtils.emptyIfNull(datas).forEach(data -> data.setCanSplit(isCanSplit(data)));
+        CollectionUtils.emptyIfNull(datas).forEach(this::fillContractOperationPermissions);
         return datas;
         return datas;
     }
     }
 
 
@@ -239,6 +245,7 @@ public class ContractDistributorStandardServiceImpl extends
         }
         }
         data.setCanEdit(canEdit);
         data.setCanEdit(canEdit);
         fillRemainingQuantity(data);
         fillRemainingQuantity(data);
+        fillContractOperationPermissions(data);
 
 
         // 获取当前人员的待办任务数据
         // 获取当前人员的待办任务数据
         List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
         List<FlowTaskDto> flowTaskList = flowTaskWrapperMapper.queryTodoList(new QueryTodoTaskListVo(), SecurityUtil.getCurrentUser().getId());
@@ -308,6 +315,167 @@ public class ContractDistributorStandardServiceImpl extends
         return true;
         return true;
     }
     }
 
 
+    /**
+     * 填充合同操作权限字段
+     *
+     * @param data 合同
+     */
+    private void fillContractOperationPermissions(ContractDistributorStandard data) {
+        if (data == null) {
+            return;
+        }
+        data.setCanSplit(isCanSplit(data));
+        data.setCanCreateChange(isCanCreateChange(data));
+        data.setCanPriceLock(isCanPriceLock(data));
+        data.setCanSpecLock(isCanSpecLock(data));
+        data.setCanCreateSpecLockDelay(isCanCreateSpecLockDelay(data));
+    }
+
+    /**
+     * 判断是否可发起合同变更
+     *
+     * @param data 合同
+     * @return 是否可发起合同变更
+     */
+    private boolean isCanCreateChange(ContractDistributorStandard data) {
+        if (data == null || StringUtils.isBlank(data.getType()) || StringUtils.isBlank(data.getStatus())) {
+            return false;
+        }
+        if (hasUnfinishedContractChange(data) || hasUnfinishedSpecLockDelay(data)) {
+            return false;
+        }
+        if ("DISTRIB_STD".equals(data.getType())
+                || "DRAFT_DIST_AGMT".equals(data.getType())
+                || "INTL_STD_CONTRACT".equals(data.getType())
+                || "INTL_OPEN_SPEC_AGMT".equals(data.getType())
+                || "PROCESS_STD_AGMT".equals(data.getType())) {
+            return "STANDARD".equals(data.getStatus()) && CustomerDevelopStatus.PASS.name().equals(data.getStandardApproved());
+        }
+        if ("DIST_STOCK_CONTRACT".equals(data.getType()) || "INTL_INVENTORY_AGMT".equals(data.getType())) {
+            if ("FORMAL".equals(data.getStatus())) {
+                return CustomerDevelopStatus.PASS.name().equals(data.getFormalApproved());
+            }
+            if ("STANDARD".equals(data.getStatus())) {
+                return CustomerDevelopStatus.PASS.name().equals(data.getStandardApproved());
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 判断是否可锁价
+     *
+     * @param data 合同
+     * @return 是否可锁价
+     */
+    private boolean isCanPriceLock(ContractDistributorStandard data) {
+        if (data == null) {
+            return false;
+        }
+        if (!"DIST_STOCK_CONTRACT".equals(data.getType()) && !"INTL_INVENTORY_AGMT".equals(data.getType())) {
+            return false;
+        }
+        if (!"FORMAL".equals(data.getStatus())) {
+            return false;
+        }
+        if (!CustomerDevelopStatus.PASS.name().equals(data.getFormalApproved())) {
+            return false;
+        }
+        if (Boolean.TRUE.equals(data.getPriceSpecLocked())) {
+            return false;
+        }
+        if (hasUnfinishedContractChange(data)) {
+            return false;
+        }
+        Wrapper<PurchaseOrderInfo> orderInfoWrapper = Wrappers.lambdaQuery(PurchaseOrderInfo.class)
+                .eq(PurchaseOrderInfo::getContractId, data.getId())
+                .eq(PurchaseOrderInfo::getType, "PRODUCTION")
+                .eq(PurchaseOrderInfo::getExamineStatus, CustomerDevelopStatus.PASS.name());
+        return purchaseOrderInfoService.count(orderInfoWrapper) > 0;
+    }
+
+    /**
+     * 判断是否可锁规
+     *
+     * @param data 合同
+     * @return 是否可锁规
+     */
+    private boolean isCanSpecLock(ContractDistributorStandard data) {
+        if (data == null) {
+            return false;
+        }
+        if (!"DRAFT_DIST_AGMT".equals(data.getType()) && !"INTL_OPEN_SPEC_AGMT".equals(data.getType())) {
+            return false;
+        }
+        if (!"STANDARD".equals(data.getStatus())) {
+            return false;
+        }
+        if (!CustomerDevelopStatus.PASS.name().equals(data.getStandardApproved())) {
+            return false;
+        }
+        if (Boolean.TRUE.equals(data.getPriceSpecLocked())) {
+            return false;
+        }
+        return !hasUnfinishedContractChange(data);
+    }
+
+    /**
+     * 判断是否可发起锁规延期申请
+     *
+     * @param data 合同
+     * @return 是否可发起锁规延期申请
+     */
+    private boolean isCanCreateSpecLockDelay(ContractDistributorStandard data) {
+        if (!isCanSpecLock(data)) {
+            return false;
+        }
+        return !hasUnfinishedSpecLockDelay(data);
+    }
+
+    /**
+     * 是否存在未结束的合同变更
+     *
+     * @param data 合同
+     * @return 是否存在未结束的合同变更
+     */
+    private boolean hasUnfinishedContractChange(ContractDistributorStandard data) {
+        if (data == null) {
+            return false;
+        }
+        String rootContractId = StringUtils.isBlank(data.getParentId()) ? data.getId() : data.getParentId();
+        return contractChangeApplicationService.hasUnfinishedApplication(rootContractId);
+    }
+
+    /**
+     * 是否存在未结束的锁规延期申请
+     *
+     * @param data 合同
+     * @return 是否存在未结束的锁规延期申请
+     */
+    private boolean hasUnfinishedSpecLockDelay(ContractDistributorStandard data) {
+        if (data == null) {
+            return false;
+        }
+        String rootContractId = StringUtils.isBlank(data.getParentId()) ? data.getId() : data.getParentId();
+        Wrapper<ContractDistributorStandard> contractWrapper = Wrappers.lambdaQuery(ContractDistributorStandard.class)
+                .select(ContractDistributorStandard::getId)
+                .eq(ContractDistributorStandard::getId, rootContractId)
+                .or()
+                .eq(ContractDistributorStandard::getParentId, rootContractId);
+        List<String> contractIds = CollectionUtils.emptyIfNull(getBaseMapper().selectList(contractWrapper))
+                .stream()
+                .map(ContractDistributorStandard::getId)
+                .collect(Collectors.toList());
+        if (!contractIds.contains(rootContractId)) {
+            contractIds.add(rootContractId);
+        }
+        Wrapper<SpecLockDelayApplication> wrapper = Wrappers.lambdaQuery(SpecLockDelayApplication.class)
+                .in(SpecLockDelayApplication::getContractId, contractIds)
+                .notIn(SpecLockDelayApplication::getApprovalStatus,
+                        Arrays.asList(CustomerDevelopStatus.PASS.name(), CustomerDevelopStatus.CANCEL.name()));
+        return specLockDelayApplicationMapper.selectCount(wrapper) > 0;
+    }
+
     @OpLog(type = OtherOpLogType.class, name = "新增合同，ID：{}", params = {"#id"})
     @OpLog(type = OtherOpLogType.class, name = "新增合同，ID：{}", params = {"#id"})
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     @Override
     @Override
@@ -1291,6 +1459,9 @@ public class ContractDistributorStandardServiceImpl extends
         if (ObjectUtil.isNull(data)) {
         if (ObjectUtil.isNull(data)) {
             throw new DefaultClientException("合同不存在！");
             throw new DefaultClientException("合同不存在！");
         }
         }
+        if (!isCanPriceLock(data)) {
+            throw new DefaultClientException("当前合同存在未结束的合同变更流程，或未满足锁价条件，不允许锁价！");
+        }
 
 
         List<UpdateContractDistributorLineVo> lineVoList = vo.getContractDistributorLineList();
         List<UpdateContractDistributorLineVo> lineVoList = vo.getContractDistributorLineList();
         if (CollectionUtils.isEmpty(lineVoList)) {
         if (CollectionUtils.isEmpty(lineVoList)) {
@@ -1418,6 +1589,9 @@ public class ContractDistributorStandardServiceImpl extends
         if (ObjectUtil.isNull(data)) {
         if (ObjectUtil.isNull(data)) {
             throw new DefaultClientException("合同不存在！");
             throw new DefaultClientException("合同不存在！");
         }
         }
+        if (!isCanSpecLock(data)) {
+            throw new DefaultClientException("当前合同存在未结束的合同变更流程，或未满足锁规条件，不允许锁规！");
+        }
 
 
         List<UpdateContractDistributorLineVo> lineVoList = vo.getContractDistributorLineList();
         List<UpdateContractDistributorLineVo> lineVoList = vo.getContractDistributorLineList();
         if (CollectionUtils.isEmpty(lineVoList)) {
         if (CollectionUtils.isEmpty(lineVoList)) {

@@ -32,6 +32,7 @@ import com.lframework.xingyun.sc.entity.SpecLockDelayApplication;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
 import com.lframework.xingyun.sc.mappers.SpecLockDelayApplicationMapper;
 import com.lframework.xingyun.sc.mappers.SpecLockDelayApplicationMapper;
+import com.lframework.xingyun.sc.service.contract.ContractChangeApplicationService;
 import com.lframework.xingyun.sc.service.HolidaysService;
 import com.lframework.xingyun.sc.service.HolidaysService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
 import com.lframework.xingyun.sc.service.contract.SpecLockDelayApplicationService;
@@ -79,6 +80,8 @@ public class SpecLockDelayApplicationServiceImpl extends BaseMpServiceImpl<SpecL
     private SysDeptService sysDeptService;
     private SysDeptService sysDeptService;
     @Resource
     @Resource
     private TransactorHandler transactorHandler;
     private TransactorHandler transactorHandler;
+    @Resource
+    private ContractChangeApplicationService contractChangeApplicationService;
 
 
     @Override
     @Override
     public PageResult<SpecLockDelayApplication> query(Integer pageIndex, Integer pageSize, QuerySpecLockDelayApplicationVo vo) {
     public PageResult<SpecLockDelayApplication> query(Integer pageIndex, Integer pageSize, QuerySpecLockDelayApplicationVo vo) {
@@ -131,6 +134,7 @@ public class SpecLockDelayApplicationServiceImpl extends BaseMpServiceImpl<SpecL
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     @Override
     @Override
     public String create(CreateSpecLockDelayApplicationVo vo) throws Exception {
     public String create(CreateSpecLockDelayApplicationVo vo) throws Exception {
+        checkNoUnfinishedContractChange(vo.getContractId());
         checkSpecLockDateLimit(vo.getApplicationCount(), vo.getContractId(), vo.getSpecLockDate());
         checkSpecLockDateLimit(vo.getApplicationCount(), vo.getContractId(), vo.getSpecLockDate());
 
 
         SpecLockDelayApplication data = new SpecLockDelayApplication();
         SpecLockDelayApplication data = new SpecLockDelayApplication();
@@ -181,6 +185,7 @@ public class SpecLockDelayApplicationServiceImpl extends BaseMpServiceImpl<SpecL
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     @Override
     @Override
     public void update(UpdateSpecLockDelayApplicationVo vo) throws Exception {
     public void update(UpdateSpecLockDelayApplicationVo vo) throws Exception {
+        checkNoUnfinishedContractChange(vo.getContractId());
         checkSpecLockDateLimit(vo.getApplicationCount(), vo.getContractId(), vo.getSpecLockDate());
         checkSpecLockDateLimit(vo.getApplicationCount(), vo.getContractId(), vo.getSpecLockDate());
 
 
         SpecLockDelayApplication data = getBaseMapper().selectById(vo.getId());
         SpecLockDelayApplication data = getBaseMapper().selectById(vo.getId());
@@ -286,6 +291,25 @@ public class SpecLockDelayApplicationServiceImpl extends BaseMpServiceImpl<SpecL
 
 
     }
     }
 
 
+    /**
+     * 校验不存在未结束的合同变更
+     *
+     * @param contractId 合同ID
+     */
+    private void checkNoUnfinishedContractChange(String contractId) {
+        if (StringUtils.isBlank(contractId)) {
+            return;
+        }
+        ContractDistributorStandard contract = contractDistributorStandardService.findById(contractId);
+        if (contract == null) {
+            return;
+        }
+        String rootContractId = StringUtils.isBlank(contract.getParentId()) ? contract.getId() : contract.getParentId();
+        if (contractChangeApplicationService.hasUnfinishedApplication(rootContractId)) {
+            throw new DefaultClientException("该合同存在未结束的合同变更流程，不允许发起锁规延期申请！");
+        }
+    }
+
     public void sendDelaySpecLockMessage() {
     public void sendDelaySpecLockMessage() {
         log.info("开始执行延迟锁规消息发送任务");
         log.info("开始执行延迟锁规消息发送任务");
 
 

+package com.lframework.xingyun.sc.mappers;
+
+import com.lframework.starter.web.core.annotations.permission.DataPermission;
+import com.lframework.starter.web.core.annotations.permission.DataPermissions;
+import com.lframework.starter.web.core.mapper.BaseMapper;
+import com.lframework.starter.web.inner.components.permission.OrderDataPermissionDataPermissionType;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeSelectableContractVo;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * <p>
+ * 合同变更申请单 Mapper 接口
+ * </p>
+ */
+public interface ContractChangeApplicationMapper extends BaseMapper<ContractChangeApplication> {
+
+    /**
+     * 查询可发起变更的合同
+     *
+     * @param vo 查询参数
+     * @return 可发起变更的合同
+     */
+    @DataPermissions(type = OrderDataPermissionDataPermissionType.class, value = {
+            @DataPermission(template = "order", alias = "tb")
+    })
+    List<ContractDistributorStandard> querySelectableContracts(@Param("vo") QueryContractChangeSelectableContractVo vo);
+}

+package com.lframework.xingyun.sc.service.contract;
+
+import com.lframework.starter.web.core.components.resp.PageResult;
+import com.lframework.starter.web.core.service.BaseMpService;
+import com.lframework.xingyun.sc.entity.ContractChangeApplication;
+import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
+import com.lframework.xingyun.sc.vo.contract.createVo.CreateContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeApplicationVo;
+import com.lframework.xingyun.sc.vo.contract.queryVo.QueryContractChangeSelectableContractVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractChangeApplicationVo;
+
+/**
+ * 合同变更申请单 Service
+ */
+public interface ContractChangeApplicationService extends BaseMpService<ContractChangeApplication> {
+
+    /**
+     * 查询列表
+     *
+     * @param pageIndex 页码
+     * @param pageSize 页大小
+     * @param vo 查询参数
+     * @return 分页结果
+     */
+    PageResult<ContractChangeApplication> query(Integer pageIndex, Integer pageSize, QueryContractChangeApplicationVo vo);
+
+    /**
+     * 根据ID查询
+     *
+     * @param id ID
+     * @return 合同变更申请单
+     */
+    ContractChangeApplication findById(String id);
+
+    /**
+     * 创建
+     *
+     * @param vo 新增参数
+     * @return ID
+     * @throws Exception 异常
+     */
+    String create(CreateContractChangeApplicationVo vo) throws Exception;
+
+    /**
+     * 修改
+     *
+     * @param vo 修改参数
+     * @throws Exception 异常
+     */
+    void update(UpdateContractChangeApplicationVo vo) throws Exception;
+
+    /**
+     * 取消申请
+     *
+     * @param id ID
+     */
+    void cancelApplication(String id);
+
+    /**
+     * 更新审核状态
+     *
+     * @param id ID
+     * @param approvalStatus 审核状态
+     */
+    void updateAuditStatus(String id, String approvalStatus);
+
+    /**
+     * 查询可发起变更的合同
+     *
+     * @param pageIndex 页码
+     * @param pageSize 页大小
+     * @param vo 查询参数
+     * @return 分页结果
+     */
+    PageResult<ContractDistributorStandard> querySelectableContracts(Integer pageIndex, Integer pageSize,
+                                                                     QueryContractChangeSelectableContractVo vo);
+
+    /**
+     * 是否存在未结束的合同变更申请单
+     *
+     * @param rootContractId 根合同ID
+     * @return 是否存在未结束的合同变更申请单
+     */
+    boolean hasUnfinishedApplication(String rootContractId);
+}

+package com.lframework.xingyun.sc.vo.contract.createVo;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import com.lframework.xingyun.sc.vo.contract.updateVo.UpdateContractDistributorStandardVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * 合同变更申请单新增参数
+ */
+@Data
+public class CreateContractChangeApplicationVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 合同ID
+     */
+    @ApiModelProperty(value = "合同ID", required = true)
+    @NotBlank(message = "合同ID不能为空！")
+    private String contractId;
+
+    /**
+     * 变更原因
+     */
+    @ApiModelProperty(value = "变更原因")
+    @Length(message = "变更原因最多允许200个字符！")
+    private String changeReason;
+
+    /**
+     * 变更后的合同数据
+     */
+    @ApiModelProperty(value = "变更后的合同数据", required = true)
+    @NotNull(message = "变更后的合同数据不能为空！")
+    @Valid
+    private UpdateContractDistributorStandardVo contractData;
+}

+package com.lframework.xingyun.sc.vo.contract.queryVo;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import com.lframework.starter.web.core.vo.PageVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 合同变更申请单查询参数
+ */
+@Data
+public class QueryContractChangeApplicationVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 合同编号
+     */
+    @ApiModelProperty("合同编号")
+    private String contractCode;
+
+    /**
+     * 合同类型
+     */
+    @ApiModelProperty("合同类型")
+    private String contractType;
+
+    /**
+     * 合同阶段(FORMAL:正式合同,STANDARD:标准合同)
+     */
+    @ApiModelProperty("合同阶段(FORMAL:正式合同,STANDARD:标准合同)")
+    private String contractStage;
+
+    /**
+     * 审核状态
+     */
+    @ApiModelProperty("审核状态")
+    private String approvalStatus;
+}

+package com.lframework.xingyun.sc.vo.contract.queryVo;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import com.lframework.starter.web.core.vo.PageVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 可发起合同变更合同查询参数
+ */
+@Data
+public class QueryContractChangeSelectableContractVo extends PageVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 合同编号
+     */
+    @ApiModelProperty("合同编号")
+    private String code;
+
+    /**
+     * 合同类型
+     */
+    @ApiModelProperty("合同类型")
+    private String type;
+
+    /**
+     * 合同阶段(FORMAL:正式合同,STANDARD:标准合同)
+     */
+    @ApiModelProperty("合同阶段(FORMAL:正式合同,STANDARD:标准合同)")
+    private String contractStage;
+}

+package com.lframework.xingyun.sc.vo.contract.updateVo;
+
+import com.lframework.starter.web.core.vo.BaseVo;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import org.hibernate.validator.constraints.Length;
+
+import javax.validation.Valid;
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+
+/**
+ * 合同变更申请单修改参数
+ */
+@Data
+public class UpdateContractChangeApplicationVo implements BaseVo, Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @ApiModelProperty(value = "ID", required = true)
+    @NotBlank(message = "ID不能为空！")
+    private String id;
+
+    /**
+     * 变更原因
+     */
+    @ApiModelProperty(value = "变更原因")
+    @Length(message = "变更原因最多允许200个字符！")
+    private String changeReason;
+
+    /**
+     * 变更后的合同数据
+     */
+    @ApiModelProperty(value = "变更后的合同数据", required = true)
+    @NotNull(message = "变更后的合同数据不能为空！")
+    @Valid
+    private UpdateContractDistributorStandardVo contractData;
+}

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.lframework.xingyun.sc.mappers.ContractChangeApplicationMapper">
+
+    <select id="querySelectableContracts" resultType="com.lframework.xingyun.sc.entity.ContractDistributorStandard">
+        SELECT tb.id,
+               tb.code,
+               tb.buyer,
+               tb.dept_id,
+               tb.region,
+               tb.stock_up_company_id,
+               tb.order_date,
+               tb.unit,
+               tb.workshop_id,
+               tb.total_quantity,
+               tb.total_amount_including_tax,
+               tb.status,
+               tb.type,
+               tb.parent_id,
+               tb.formal_approved,
+               tb.standard_approved,
+               tb.price_spec_locked,
+               tb.change_reason,
+               tb.create_by,
+               tb.create_by_id,
+               tb.create_time
+        FROM tbl_contract_distributor_standard tb
+        WHERE tb.status != 'DELETED'
+          <if test="vo.code != null and vo.code != ''">
+              AND tb.code LIKE CONCAT('%', #{vo.code}, '%')
+          </if>
+          <if test="vo.type != null and vo.type != ''">
+              AND tb.type = #{vo.type}
+          </if>
+          <if test="vo.contractStage != null and vo.contractStage != ''">
+              AND tb.status = #{vo.contractStage}
+          </if>
+          AND (
+              (tb.type = 'DISTRIB_STD' AND tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              OR (tb.type = 'DIST_STOCK_CONTRACT' AND (
+                  (tb.status = 'FORMAL' AND tb.formal_approved = 'PASS')
+                  OR (tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              ))
+              OR (tb.type = 'DRAFT_DIST_AGMT' AND tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              OR (tb.type = 'INTL_STD_CONTRACT' AND tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              OR (tb.type = 'INTL_INVENTORY_AGMT' AND (
+                  (tb.status = 'FORMAL' AND tb.formal_approved = 'PASS')
+                  OR (tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              ))
+              OR (tb.type = 'INTL_OPEN_SPEC_AGMT' AND tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+              OR (tb.type = 'PROCESS_STD_AGMT' AND tb.status = 'STANDARD' AND tb.standard_approved = 'PASS')
+          )
+          AND NOT EXISTS (
+              SELECT 1
+              FROM tbl_contract_change_application cca
+              WHERE cca.root_contract_id = IFNULL(NULLIF(tb.parent_id, ''), tb.id)
+                AND cca.approval_status NOT IN ('PASS', 'CANCEL')
+          )
+          AND NOT EXISTS (
+              SELECT 1
+              FROM tbl_spec_lock_delay_application sda
+                       LEFT JOIN tbl_contract_distributor_standard rel
+                                 ON rel.id = sda.contract_id
+              WHERE sda.approval_status NOT IN ('PASS', 'CANCEL')
+                AND (
+                  sda.contract_id = IFNULL(NULLIF(tb.parent_id, ''), tb.id)
+                      OR rel.parent_id = IFNULL(NULLIF(tb.parent_id, ''), tb.id)
+                  )
+          )
+        ORDER BY tb.create_time DESC
+    </select>
+</mapper>