feat(crm,mes): 扩展客户字段与重构批次号生成逻辑

云

3 天以前 87733eb3623593da247c051593d64b8ff9e1d3a4

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
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.api.event.BpmProcessInstanceStatusEventListener;
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.stereotype.Component;
 
/**
 * 种子质检本线领导审批状态监听器
 *
 * <p>流程定义 key：mes_seed_quality_line_approve；businessKey 格式：{质检线}#{生产批次号}。
 * 审批通过后本线进入复检，驳回后本线重新初检。
 */
@Component
@Slf4j
public class MesQcSeedLineStatusListener extends BpmProcessInstanceStatusEventListener {
 
    private static final String BPM_PROCESS_DEFINITION_KEY = "mes_seed_quality_line_approve";
 
    @Resource
    private MesQcSeedQualityService seedQualityService;
 
    @Override
    protected String getProcessDefinitionKey() {
        return BPM_PROCESS_DEFINITION_KEY;
    }
 
    @Override
    protected void onEvent(BpmProcessInstanceStatusEvent event) {
        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("[onEvent][本线审批 businessKey({}) 格式无效，应为 质检线#批次号]", businessKey);
            return;
        }
        Integer qcLine;
        try {
            qcLine = Integer.valueOf(businessKey.substring(0, index));
        } catch (NumberFormatException ex) {
            log.warn("[onEvent][本线审批 businessKey({}) 质检线无效]", businessKey);
            return;
        }
        String batchCode = businessKey.substring(index + 1);
        boolean approved = BpmProcessInstanceStatusEnum.APPROVE.getStatus().equals(event.getStatus());
        log.info("[onEvent][本线审批完成，批次={} 质检线={} 结果={}]", batchCode, qcLine, event.getStatus());
        seedQualityService.handleLineProcessResult(event.getId(), qcLine, batchCode, approved, event.getReason());
    }
}