feat(qc): 拆分部门审批流程并支持扫码自动识别

云

3 天以前 d80fa460742ddf052844746482801de355e85528

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package cn.iocoder.yudao.module.mes.service.qc.seedquality.listener;
 
import cn.iocoder.yudao.module.bpm.api.event.BpmProcessInstanceStatusEvent;
import cn.iocoder.yudao.module.bpm.enums.task.BpmProcessInstanceStatusEnum;
import cn.iocoder.yudao.module.mes.service.qc.seedquality.MesQcSeedQualityService;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
 
import java.util.Set;
 
/**
 * 种子质检部门领导审批状态监听器
 *
 * <p>加工部、销售部各使用独立流程定义；businessKey 格式：{质检线}#{生产批次号}。
 * 审批通过后本线进入公司质检待审，驳回后本线重新初检。
 */
@Component
@Slf4j
public class MesQcSeedLineStatusListener implements ApplicationListener<BpmProcessInstanceStatusEvent> {
 
    /** 加工部领导审批流程定义标识 */
    private static final String LINE_PROCESS_KEY = "mes_seed_quality_line_approve";
    /** 销售部领导审批流程定义标识 */
    private static final String SALES_LINE_PROCESS_KEY = "mes_seed_quality_sales_line_approve";
    private static final Set<String> PROCESS_KEYS = Set.of(LINE_PROCESS_KEY, SALES_LINE_PROCESS_KEY);
 
    @Resource
    private MesQcSeedQualityService seedQualityService;
 
    @Override
    public void onApplicationEvent(BpmProcessInstanceStatusEvent event) {
        if (!PROCESS_KEYS.contains(event.getProcessDefinitionKey())) {
            return;
        }
        if (!BpmProcessInstanceStatusEnum.isProcessEndStatus(event.getStatus())
                || BpmProcessInstanceStatusEnum.CANCEL.getStatus().equals(event.getStatus())) {
            return;
        }
        String businessKey = event.getBusinessKey();
        int index = businessKey == null ? -1 : businessKey.indexOf('#');
        if (index <= 0 || index == businessKey.length() - 1) {
            log.warn("[onApplicationEvent][部门审批 businessKey({}) 格式无效，应为 质检线#批次号]", businessKey);
            return;
        }
        Integer qcLine;
        try {
            qcLine = Integer.valueOf(businessKey.substring(0, index));
        } catch (NumberFormatException ex) {
            log.warn("[onApplicationEvent][部门审批 businessKey({}) 质检线无效]", businessKey);
            return;
        }
        String batchCode = businessKey.substring(index + 1);
        boolean approved = BpmProcessInstanceStatusEnum.APPROVE.getStatus().equals(event.getStatus());
        log.info("[onApplicationEvent][部门审批完成，批次={} 质检线={} 结果={}]", batchCode, qcLine, event.getStatus());
        seedQualityService.handleLineProcessResult(event.getId(), qcLine, batchCode, approved, event.getReason());
    }
}