采购计划：变更正常流程审核

@@ -78,6 +78,12 @@ public class GetProcurementPlanChangeBo extends BaseBo<ProcurementPlanChange> {
   private String purchaseDepartmentName;
 
   /**
+   * 采购处编码
+   */
+  @ApiModelProperty("采购处编码")
+  private String purchaseDepartmentCode;
+
+  /**
    * 区域
    */
   @ApiModelProperty("区域")

@@ -20,6 +20,8 @@ import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.enums.CustomerDevelopStatus;
 import com.lframework.xingyun.sc.procurement.entity.ProcurementDomesticCustomerCredit;
 import com.lframework.xingyun.sc.procurement.entity.ProcurementForeignTradeCredit;
+import com.lframework.xingyun.sc.procurement.entity.ProcurementPlanChange;
+import com.lframework.xingyun.sc.procurement.service.change.ProcurementPlanChangeService;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementDomesticCustomerCreditService;
 import com.lframework.xingyun.sc.procurement.service.credit.ProcurementForeignTradeCreditService;
 import com.lframework.xingyun.sc.procurement.service.plan.ProcurementPlanService;
@@ -160,6 +162,8 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
     private SalesmanQuotationService salesmanQuotationService;
     @Resource
     private ProcurementPlanService procurementPlanService;
+    @Resource
+    private ProcurementPlanChangeService procurementPlanChangeService;
 
 
 
@@ -253,6 +257,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "PROCUREMENT_PLAN":
                 handleProcurementPlanData(flowStatus, businessId);
                 break;
+            case "PLAN_CHANGE":
+                handleProcurementPlanChangeData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -1147,4 +1154,21 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
         }
     }
 
+    /**
+     * 采购计划变更审核业务数据处理
+     *
+     * @param flowStatus 审核结果
+     * @param businessId 业务ID
+     */
+    private void handleProcurementPlanChangeData(String flowStatus, String businessId) {
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            procurementPlanChangeService.updateApprovalStatus(businessId, "PASS");
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            procurementPlanChangeService.updateApprovalStatus(businessId, "REFUSE");
+        }
+    }
+
 }

@@ -17,7 +17,10 @@ import com.lframework.xingyun.sc.entity.ContractDistributorStandard;
 import com.lframework.xingyun.sc.entity.FundCoordination;
 import com.lframework.xingyun.sc.entity.ProductSampleConfirmationSlip;
 import com.lframework.xingyun.sc.handlers.TransactorHandler;
+import com.lframework.xingyun.sc.procurement.entity.ProcurementPlanChange;
+import com.lframework.xingyun.sc.procurement.service.change.ProcurementPlanChangeService;
 import com.lframework.xingyun.sc.procurement.service.plan.ProcurementPlanService;
+import com.lframework.xingyun.sc.procurement.vo.change.UpdateProcurementPlanChangeVo;
 import com.lframework.xingyun.sc.service.contract.ContractDistributorStandardService;
 import com.lframework.xingyun.sc.service.customer.CustomerCreditService;
 import com.lframework.xingyun.sc.service.ledger.FundCoordinationService;
@@ -62,6 +65,8 @@ public class FlowTaskServiceImpl implements FlowTaskService {
     private ContractDistributorStandardService contractDistributorStandardService;
     @Resource
     private ProcurementPlanService procurementPlanService;
+    @Resource
+    private ProcurementPlanChangeService procurementPlanChangeService;
 
 
     @OpLog(type = OtherOpLogType.class, name = "修改客户资信，ID：{}", params = {"#id"})
@@ -439,6 +444,7 @@ public class FlowTaskServiceImpl implements FlowTaskService {
         sampleResultTrackingService.updateExamine(id, nodeCode, message);
     }
 
+    @Transactional(rollbackFor = Exception.class)
     @Override
     public void updateProcurementPlanMap(Map<String, Object> map) {
         //主键
@@ -448,6 +454,12 @@ public class FlowTaskServiceImpl implements FlowTaskService {
         procurementPlanService.updateExamine(id);
     }
 
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void updateProcurementPlanChangeMap(Map<String, Object> map) {
+        procurementPlanChangeService.updateNoFlowInstance(map);
+    }
+
     @Override
     public Map<String, Object> findById(String s) {
         ProductSampleConfirmationSlip slip = productSampleConfirmationSlipService.findById(s);

@@ -50,7 +50,7 @@ public class ProcurementPlanChangeController extends DefaultBaseController {
    */
   @ApiOperation("查询详情")
   @ApiImplicitParam(value = "ID", name = "id", paramType = "query", required = true)
-  @HasPermission({"plan-manage:plan-change:query"})
+  @HasPermission({"plan-manage:plan-change:query","plan-manage:schedule-plan:view"})
   @GetMapping("/findById")
   public InvokeResult<GetProcurementPlanChangeBo> findById(@NotBlank(message = "ID不能为空！") String id) {
     GetProcurementPlanChangeBo result = procurementPlanChangeService.findDetail(id);
@@ -61,7 +61,7 @@ public class ProcurementPlanChangeController extends DefaultBaseController {
    * 新增
    */
   @ApiOperation("新增采购计划变更单")
-  @HasPermission({"plan-manage:plan-change:add"})
+  @HasPermission({"plan-manage:schedule-plan:add"})
   @PostMapping("/create")
   public InvokeResult<String> create(@RequestBody @Valid CreateProcurementPlanChangeVo vo) {
     vo.validate();
@@ -73,7 +73,7 @@ public class ProcurementPlanChangeController extends DefaultBaseController {
    * 修改
    */
   @ApiOperation("修改采购计划变更单")
-  @HasPermission({"plan-manage:plan-change:supple"})
+  @HasPermission({"plan-manage:schedule-plan:modify","plan-manage:schedule-plan:approve"})
   @PostMapping("/update")
   public InvokeResult<Void> update(@RequestBody @Valid UpdateProcurementPlanChangeVo vo) {
     vo.validate();
@@ -81,4 +81,26 @@ public class ProcurementPlanChangeController extends DefaultBaseController {
     return InvokeResultBuilder.success();
   }
 
+  /**
+   * 采购计划变更单提交审核
+   */
+  @ApiOperation("采购计划变更单提交审核")
+  @HasPermission({"plan-manage:schedule-plan:initiate"})
+  @PostMapping("/submit")
+  public InvokeResult<Void> submit(@NotBlank(message = "ID不能为空！") String id) {
+    procurementPlanChangeService.submit(id);
+    return InvokeResultBuilder.success();
+  }
+
+  /**
+   * 取消采购计划变更单
+   */
+  @ApiOperation("取消采购计划变更单")
+  @HasPermission({"plan-manage:schedule-plan:cancel"})
+  @PostMapping("/cancel")
+  public InvokeResult<Void> cancel(@NotBlank(message = "ID不能为空！") String id) {
+    procurementPlanChangeService.cancel(id);
+    return InvokeResultBuilder.success();
+  }
+
 }

@@ -70,6 +70,12 @@ public class ProcurementPlanChange extends BaseEntity implements BaseDto {
   private String purchaseDepartmentName;
 
   /**
+   * 采购处编码
+   */
+  @TableField(exist = false)
+  private String purchaseDepartmentCode;
+
+  /**
    * 区域
    */
   private String region;
@@ -278,6 +284,9 @@ public class ProcurementPlanChange extends BaseEntity implements BaseDto {
    */
   private String workshopId;
 
+  @TableField(exist = false)
+  private String roleCode;
+
   /**
    * 创建人ID
    */

@@ -2,9 +2,13 @@ package com.lframework.xingyun.sc.procurement.impl.change;
 
 import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.Wrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.github.pagehelper.PageInfo;
+import com.lframework.starter.bpm.service.FlowInstanceWrapperService;
 import com.lframework.starter.common.exceptions.impl.DefaultClientException;
 import com.lframework.starter.common.exceptions.impl.InputErrorException;
 import com.lframework.starter.common.utils.Assert;
@@ -13,9 +17,7 @@ import com.lframework.starter.common.utils.StringUtil;
 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.utils.IdUtil;
-import com.lframework.starter.web.core.utils.PageHelperUtil;
-import com.lframework.starter.web.core.utils.PageResultUtil;
+import com.lframework.starter.web.core.utils.*;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.starter.web.inner.entity.SysRole;
 import com.lframework.starter.web.inner.service.system.SysRoleService;
@@ -45,6 +47,8 @@ public class ProcurementPlanChangeServiceImpl extends
         ServiceImpl<ProcurementPlanChangeMapper, ProcurementPlanChange> implements
     ProcurementPlanChangeService {
 
+  private static final String BPM_FLAG = "PLAN_CHANGE";
+
   @Resource
   private ProcurementPlanService procurementPlanService;
   @Resource
@@ -53,6 +57,8 @@ public class ProcurementPlanChangeServiceImpl extends
   private ProcurementPlanChangeLineMapper procurementPlanChangeLineMapper;
   @Resource
   private SysRoleService sysRoleService;
+  @Resource
+  private FlowInstanceWrapperService flowInstanceWrapperService;
 
 
   private static final List<String> PROCESS_STATUSES = Arrays.asList(
@@ -90,7 +96,6 @@ public class ProcurementPlanChangeServiceImpl extends
     ProcurementPlanChange planChange = new ProcurementPlanChange();
     BeanUtil.copyProperties(vo, planChange);
     planChange.setId(IdUtil.getId());
-    planChange.setProcessStatus("DRAFT");
     if (roleCodes.contains("ltcgczg") || roleCodes.contains("ztcgczg")
             || roleCodes.contains("htcgeczg") || roleCodes.contains("htcgyczg")) {
       planChange.setProcessNode("CGCZG");
@@ -140,7 +145,7 @@ public class ProcurementPlanChangeServiceImpl extends
     }
     ProcurementPlanChange planChange = new ProcurementPlanChange();
     BeanUtil.copyProperties(vo, planChange);
-    this.updateById(entity);
+    this.updateById(planChange);
     //保存或更新采购计划变更单明细
     saveOrUpdateLines(vo.getProcurementPlanId(), vo.getLines());
   }
@@ -168,7 +173,7 @@ public class ProcurementPlanChangeServiceImpl extends
       throw new InputErrorException("ID不能为空！");
     }
 
-    ProcurementPlanChange entity = this.getById(id);
+    ProcurementPlanChange entity = this.getBaseMapper().findById(id);
     if (entity == null) {
       throw new DefaultClientException("采购计划变更单不存在！");
     }
@@ -186,6 +191,188 @@ public class ProcurementPlanChangeServiceImpl extends
     return bo;
   }
 
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  @OpLog(type = OtherOpLogType.class, name = "采购计划变更单提交审核，ID：{}", params = {"#id"})
+  public void submit(String id) {
+    if (StringUtil.isBlank(id)) {
+      throw new InputErrorException("ID不能为空！");
+    }
+
+    ProcurementPlanChange entity = this.getById(id);
+    if (entity == null) {
+      throw new DefaultClientException("采购计划变更单不存在！");
+    }
+    String processNode = null;
+    String node = entity.getProcessNode();
+    if ("YWY".equals(node)) {
+      processNode = "QYJL";
+    } else if ("QYJL".equals(node)) {
+      processNode = "CGCZG";
+    } else if ("CGCZG".equals(node)) {
+      processNode = "GYGLKJHGLY";
+    }
+    LambdaUpdateWrapper<ProcurementPlanChange> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlanChange.class)
+            .set(ProcurementPlanChange::getApprovalStatus, "AUDIT")
+            .set(ProcurementPlanChange::getProcessNode, processNode)
+            .eq(ProcurementPlanChange::getId, id);
+    getBaseMapper().update(updateWrapper);
+    ProcurementPlanChange procurementPlanChange = this.getBaseMapper().findById(id);
+    List<SysRole> sysRoleList = sysRoleService.getByUserId(SecurityUtil.getCurrentUser().getId());
+    String roleCode = null;
+    if (CollectionUtil.isNotEmpty(sysRoleList)) {
+      // 1. 提取角色列表中的所有 code，转换为 Set 集合，提升后续判断效率
+      Set<String> roleCodeSet = sysRoleList.stream()
+              .map(SysRole::getCode)
+              .collect(Collectors.toSet());
+
+      // 2. 判断是否包含采购主管相关的角色
+      if (roleCodeSet.contains("htcgeczg") || roleCodeSet.contains("htcgyczg")
+              || roleCodeSet.contains("ltcgczg") || roleCodeSet.contains("ztcgczg")) {
+        roleCode = "cgczg";
+      } else if (roleCodeSet.contains("qyjl")) {
+        // 3. 如果没有，继续判断是否包含区域经理
+        roleCode = "qyjl";
+      } else if (roleCodeSet.contains("nmcgkywy")) {
+        // 4. 如果还没有，继续判断是否包含内贸采购科业务员
+        roleCode = "nmcgkywy";
+      } else {
+        throw new DefaultClientException("当前角色无法发起审核！");
+      }
+    } else {
+      throw new DefaultClientException("当前角色无法发起审核！");
+    }
+    procurementPlanChange.setRoleCode(roleCode);
+    flowInstanceWrapperService.startInstance(BPM_FLAG, entity.getId(), BPM_FLAG, procurementPlanChange);
+    OpLogUtil.setVariable("id", id);
+    OpLogUtil.setExtra(entity);
+  }
+
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  @OpLog(type = OtherOpLogType.class, name = "取消采购计划变更单，ID：{}", params = {"#id"})
+  public void cancel(String id) {
+    if (StringUtil.isBlank(id)) {
+      throw new InputErrorException("ID不能为空！");
+    }
+
+    ProcurementPlanChange entity = this.getById(id);
+    if (entity == null) {
+      throw new DefaultClientException("采购计划变更单不存在！");
+    }
+    LambdaUpdateWrapper<ProcurementPlanChange> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlanChange.class)
+            .set(ProcurementPlanChange::getApprovalStatus, "CANCEL")
+            .set(ProcurementPlanChange::getProcessNode, null)
+            .eq(ProcurementPlanChange::getId, id);
+    getBaseMapper().update(updateWrapper);
+
+    Wrapper<ProcurementPlan> parentWrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+            .set(ProcurementPlan::getChangeStatus, "CHANGED")
+            .eq(ProcurementPlan::getId, entity.getProcurementPlanId());
+    procurementPlanService.update(parentWrapper);
+
+    OpLogUtil.setVariable("id", id);
+    OpLogUtil.setExtra(entity);
+  }
+
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  @OpLog(type = OtherOpLogType.class, name = "更新采购计划变更单审核状态，ID：{}", params = {"#id"})
+  public void updateApprovalStatus(String id, String approvalStatus) {
+    if (StringUtil.isBlank(id) || StringUtil.isBlank(approvalStatus)) {
+      throw new InputErrorException("ID、审核状态不能为空！");
+    }
+
+    ProcurementPlanChange entity = this.getById(id);
+    if (entity == null) {
+      throw new DefaultClientException("采购计划变更单不存在！");
+    }
+
+    if ("PASS".equals(approvalStatus)) {
+      LambdaUpdateWrapper<ProcurementPlanChange> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlanChange.class)
+              .set(ProcurementPlanChange::getApprovalStatus, approvalStatus)
+              .set(ProcurementPlanChange::getProcessNode, null)
+              .eq(ProcurementPlanChange::getId, id);
+      getBaseMapper().update(updateWrapper);
+
+      Wrapper<ProcurementPlan> parentWrapper = Wrappers.lambdaUpdate(ProcurementPlan.class)
+              .set(ProcurementPlan::getChangeStatus, "CHANGED")
+              .eq(ProcurementPlan::getId, entity.getProcurementPlanId());
+      procurementPlanService.update(parentWrapper);
+      //todo 拆分分厂、生产买断操作申请单、生成合同,生成一份原始的计划数据（第一次变更）
+    } else if ("REFUSE".equals(approvalStatus)) {
+      List<SysRole> roles = sysRoleService.getByUserId(entity.getCreateById());
+      List<String> roleCodes = CollectionUtil.isEmpty(roles) ? new java.util.ArrayList<>()
+              : roles.stream().map(SysRole::getCode).collect(Collectors.toList());
+      String processNode = null;
+      if (roleCodes.contains("ltcgczg") || roleCodes.contains("ztcgczg")
+              || roleCodes.contains("htcgeczg") || roleCodes.contains("htcgyczg")) {
+        processNode = "CGCZG";
+      } else if (roleCodes.contains("qyjl")) {
+        processNode = "QYJL";
+      } else if (roleCodes.contains("nmcgkywy")) {
+        processNode = "YWY";
+      }
+
+      LambdaUpdateWrapper<ProcurementPlanChange> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlanChange.class)
+              .set(ProcurementPlanChange::getApprovalStatus, approvalStatus)
+              .set(ProcurementPlanChange::getProcessNode, processNode)
+              .eq(ProcurementPlanChange::getId, id);
+      getBaseMapper().update(updateWrapper);
+    }
+
+    OpLogUtil.setVariable("id", id);
+    OpLogUtil.setExtra(entity);
+  }
+
+
+  @Override
+  @Transactional(rollbackFor = Exception.class)
+  @OpLog(type = OtherOpLogType.class, name = "采购计划变更单流程数据修改，ID：{}", params = {"#id"})
+  public void updateNoFlowInstance(Map<String, Object> map) {
+    try {
+      //流程编码
+      Object n = map.get("nodeCode");
+      String nodeCode = String.valueOf(n);
+
+      //审核状态
+      Object e = map.get("examStatus");
+      String examStatus = String.valueOf(e);
+      // 创建 ObjectMapper 实例
+      ObjectMapper objectMapper = new ObjectMapper();
+      //先将 Map 序列化为 JSON 字符串，再反序列化为目标对象
+      String json = objectMapper.writeValueAsString(map);
+      UpdateProcurementPlanChangeVo vo = JsonUtil.parseObject(json, UpdateProcurementPlanChangeVo.class);
+      ProcurementPlanChange planChange = new ProcurementPlanChange();
+      BeanUtil.copyProperties(vo, planChange);
+      this.updateById(planChange);
+      //保存或更新采购计划变更单明细
+      saveOrUpdateLines(vo.getProcurementPlanId(), vo.getLines());
+      if ("PASS".equals(examStatus)) {
+        String processNode = null;
+        if ("plan_change_qyjl".equals(nodeCode)) {
+          processNode = "CGCZG";
+        } else if ("plan_change_ztcgczg".equals(nodeCode) || "plan_change_ltcgczg".equals(nodeCode)
+                || "plan_change_htcgyczg".equals(nodeCode) || "plan_change_htcgeczg".equals(nodeCode)) {
+          processNode = "GYGLKJHGLY";
+        } else if ("plan_change_gyglkjhgly".equals(nodeCode)) {
+          processNode = "GYGLKZLGLG";
+        } else if ("plan_change_gyglkzlglg".equals(nodeCode)) {
+          processNode = "GYGLKZG";
+        } else if ("plan_change_gyglkzg".equals(nodeCode)) {
+          processNode = "GYBZG";
+        } else if ("plan_change_gybzg".equals(nodeCode)) {
+          processNode = "YSFG";
+        }
+        LambdaUpdateWrapper<ProcurementPlanChange> updateWrapper = Wrappers.lambdaUpdate(ProcurementPlanChange.class)
+                .set(ProcurementPlanChange::getProcessNode, processNode)
+                .eq(ProcurementPlanChange::getId, vo.getId());
+        getBaseMapper().update(updateWrapper);
+      }
+    } catch (JsonProcessingException e) {
+      e.printStackTrace();
+    }
+  }
 
   /**
    * 保存或更新采购计划变更单明细

@@ -8,6 +8,7 @@ import com.lframework.xingyun.sc.procurement.vo.change.CreateProcurementPlanChan
 import com.lframework.xingyun.sc.procurement.vo.change.QueryProcurementPlanChangeVo;
 import com.lframework.xingyun.sc.procurement.vo.change.UpdateProcurementPlanChangeVo;
 import java.util.List;
+import java.util.Map;
 
 public interface ProcurementPlanChangeService extends IService<ProcurementPlanChange> {
 
@@ -52,4 +53,33 @@ public interface ProcurementPlanChangeService extends IService<ProcurementPlanCh
    * @return
    */
   GetProcurementPlanChangeBo findDetail(String id);
+
+  /**
+   * 提交审核
+   *
+   * @param id
+   */
+  void submit(String id);
+
+  /**
+   * 取消
+   *
+   * @param id
+   */
+  void cancel(String id);
+
+  /**
+   * 修改审核状态
+   *
+   * @param id             主键
+   * @param approvalStatus 审核状态
+   */
+  void updateApprovalStatus(String id, String approvalStatus);
+
+  /**
+   * 更新审核流程数据
+   *
+   * @param map 更新数据
+   */
+  void updateNoFlowInstance(Map<String, Object> map);
 }

@@ -279,6 +279,12 @@ public class CreateProcurementPlanChangeVo implements BaseVo, Serializable {
   private String workshopId;
 
   /**
+   * 变更类型 快速变更：FAST
+   */
+  @ApiModelProperty("变更类型")
+  private String changeType;
+
+  /**
    * 明细信息
    */
   @ApiModelProperty(value = "明细信息", required = true)

@@ -13,6 +13,7 @@
         <result column="supplier_name" property="supplierName"/>
         <result column="purchase_department" property="purchaseDepartment"/>
         <result column="purchase_department_name" property="purchaseDepartmentName"/>
+        <result column="purchase_department_code" property="purchaseDepartmentCode"/>
         <result column="region" property="region"/>
         <result column="region_name" property="regionName"/>
         <result column="date" property="date"/>
@@ -75,6 +76,7 @@
             pdc.unit_name AS supplier_name,
             ppc.purchase_department,
             sd.name AS purchase_department_name,
+            sd.code AS purchase_department_code,
             ppc.region,
             sd1.name AS region_name,
             ppc.date,