采购内贸资信：变更评审资料

@@ -1520,6 +1520,7 @@ CREATE TABLE `procurement_domestic_customer_credit`
     `region`                       varchar(200)   NOT NULL COMMENT '区域',
     `review_valid_until`           date           NOT NULL COMMENT '评审有效期',
     `status`                       varchar(20)    DEFAULT NULL COMMENT '审核状态',
+    `change_review_status`         varchar(20) DEFAULT NULL COMMENT '变更评审资料审核状态',
     `freeze`                       bool DEFAULT false COMMENT '是否冻结',
     `create_by_id`                 varchar(32)    DEFAULT NULL COMMENT '创建人ID',
     `create_by`                    varchar(64)    DEFAULT NULL COMMENT '创建人',

@@ -232,6 +232,9 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             case "CUSTOMER_CREDIT_OUT":
                 handleResultForeignTradeCreditData(flowStatus, businessId);
                 break;
+            case "IN_CHANGE_REVIEW":
+                handleResultDomesticCustomerCreditChangeReviewData(flowStatus, businessId);
+                break;
             default:
                 break;
         }
@@ -1048,4 +1051,34 @@ public class BusinessDataHandlerServiceImpl implements BusinessDataHandlerServic
             procurementForeignTradeCreditService.updateStatus(businessId, "REFUSE");
         }
     }
+
+    //采购-内贸资信-变更评审资料
+    private void handleResultDomesticCustomerCreditChangeReviewData(String flowStatus, String businessId) {
+        Object o = redisHandler.get(businessId);
+        ProcurementDomesticCustomerCredit vo = null;
+        if (o != null) {
+            String jsonString = o.toString();
+            // 2. 反序列化为 ProcurementDomesticCustomerCredit 对象
+            vo = JsonUtil.parseObject(jsonString, ProcurementDomesticCustomerCredit.class);
+        }
+
+        if (FlowInstanceStatus.APPROVE_PASS.getCode().equals(flowStatus)
+                || FlowInstanceStatus.FINISH.getCode().equals(flowStatus)) {
+            if (vo != null) {
+                vo.setChangeReviewStatus("PASS");
+                procurementDomesticCustomerCreditService.updateNoFlowInstance(vo);
+                //清除缓存
+                redisHandler.del(businessId);
+            }
+        } else if (FlowInstanceStatus.REVOKE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.REFUSE.getCode().equals(flowStatus)
+                || FlowInstanceStatus.TERMINATION.getCode().equals(flowStatus)) {
+            if (vo != null) {
+                vo.setChangeReviewStatus("REFUSE");
+                procurementDomesticCustomerCreditService.updateNoFlowInstance(vo);
+                //清除缓存
+                redisHandler.del(businessId);
+            }
+        }
+    }
 }

@@ -90,6 +90,19 @@ public class ProcurementDomesticCustomerCreditController extends DefaultBaseCont
     }
 
     /**
+     * 变更评审资料
+     */
+    @ApiOperation("变更评审资料")
+    @HasPermission({""})
+    @PutMapping
+    public InvokeResult<Void> changeReview(@Valid @RequestBody UpdateProcurementDomesticCustomerCreditVo vo) {
+
+        procurementDomesticCustomerCreditService.changeReview(vo);
+
+        return InvokeResultBuilder.success();
+    }
+
+    /**
      * 取消
      */
     @ApiOperation("取消")

@@ -287,6 +287,11 @@ public class ProcurementDomesticCustomerCredit extends BaseEntity implements Bas
     private String status;
 
     /**
+     * 变更评审审核状态
+     */
+    private String changeReviewStatus;
+
+    /**
      * 是否冻结
      */
     private Boolean freeze;

@@ -52,6 +52,7 @@ public class ProcurementDomesticCustomerCreditServiceImpl
         extends BaseMpServiceImpl<ProcurementDomesticCustomerCreditMapper, ProcurementDomesticCustomerCredit>
         implements ProcurementDomesticCustomerCreditService {
     private static final String BPM_FLAG = "CUSTOMER_CREDIT_IN";
+    private static final String BPM_FLAG_CHANGE = "IN_CHANGE_REVIEW";
     private static final int REVIEW_REMIND_DAYS = 15;
 
     @Resource
@@ -299,6 +300,33 @@ public class ProcurementDomesticCustomerCreditServiceImpl
         OpLogUtil.setExtra(vo);
     }
 
+    @OpLog(type = OtherOpLogType.class, name = "变更评审采购内贸资信调查表，ID：{}", params = {"#vo.id"})
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public void changeReview(UpdateProcurementDomesticCustomerCreditVo vo) {
+        if (ObjectUtil.isNull(vo.getId())) {
+            throw new DefaultClientException("资信ID不能为空！");
+        }
+
+        ProcurementDomesticCustomerCredit data = this.findById(vo.getId());
+        if (ObjectUtil.isNull(data)) {
+            throw new DefaultClientException("采购内贸资信调查表不存在！");
+        }
+
+        data.setId(vo.getId());
+        data.setPurchaseDepartment(vo.getPurchaseDepartment());
+        data.setRegion(vo.getRegion());
+        data.setChangeReviewStatus("AUDIT");
+
+        String jsonString = JsonUtil.toJsonString(data);
+        //存入缓存
+        redisHandler.set(data.getId(), jsonString);
+        //开启审核
+        flowInstanceWrapperService.startInstance(BPM_FLAG_CHANGE, data.getId(), BPM_FLAG_CHANGE, data);
+
+        OpLogUtil.setExtra(vo);
+    }
+
     @Override
     public void updateStatus(String id, String status) {
         if (StringUtils.isBlank(id) || StringUtils.isBlank(status)) {

@@ -54,6 +54,13 @@ public interface ProcurementDomesticCustomerCreditService extends BaseMpService<
     void update(UpdateProcurementDomesticCustomerCreditVo vo);
 
     /**
+     * 变更评审资料
+     *
+     * @param vo
+     */
+    void changeReview(UpdateProcurementDomesticCustomerCreditVo vo);
+
+    /**
      * 更新审核状态
      */
     void updateStatus(String id, String status);

@@ -57,6 +57,7 @@
         <result column="region_name" property="regionName"/>
         <result column="review_valid_until" property="reviewValidUntil"/>
         <result column="status" property="status"/>
+        <result column="change_review_status" property="changeReviewStatus"/>
         <result column="freeze" property="freeze"/>
         <result column="create_by_id" property="createById"/>
         <result column="create_by" property="createBy"/>
@@ -121,6 +122,7 @@
             sd1.name AS region_name,
             tb.review_valid_until,
             tb.status,
+            tb.change_review_status,
             tb.freeze,
             tb.create_by_id,
             tb.create_by,
@@ -163,6 +165,9 @@
             <if test="vo.status != null and vo.status != ''">
                 AND tb.status = #{vo.status}
             </if>
+            <if test="vo.changeReviewStatus != null and vo.changeReviewStatus != ''">
+                AND tb.change_review_status = #{vo.changeReviewStatus}
+            </if>
             <if test="vo.freeze != null">
                 AND tb.freeze = #{vo.freeze}
             </if>