更新提醒-》只提醒编程员；工控网显示临时更改单号

yangys

2025-09-22 c0ccbb980be6975389f09ad13dcabd7d3156dae3

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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
package org.springblade.mdm.thirdpart.service;
 
import lombok.extern.slf4j.Slf4j;
import org.flowable.engine.RuntimeService;
import org.flowable.engine.runtime.ProcessInstance;
import org.springblade.mdm.flow.constants.FlowVariableConstant;
import org.springblade.mdm.flow.entity.TaskDispatch;
import org.springblade.mdm.flow.service.TaskDispatchService;
import org.springblade.mdm.flow.vo.TaskAssignVO;
import org.springblade.mdm.thirdpart.vo.MesTaskFinishVO;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
/**
 * 任务派工数据 处理服务
 *
 * @author yangys
 */
@Slf4j
@Service
public class MesTaskService {
    @Autowired
    private TaskDispatchService taskDispatchService;
    @Autowired
    private RuntimeService runtimeService;
    /**
     * 保存mes任务
     * @param startVO
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public TaskDispatch saveTask(TaskAssignVO startVO) {
        TaskDispatch taskDispatch = new TaskDispatch();
        BeanUtils.copyProperties(startVO, taskDispatch);
 
        boolean isDuplicate = taskDispatchService.checkIsDuplicate(startVO);
        if(isDuplicate){
            taskDispatch.setStatus(TaskDispatch.STATUS_DUP);
        }
        taskDispatch.setTenantId("000000");
        taskDispatchService.save(taskDispatch);
 
        taskDispatchService.addDrawingNos(taskDispatch.getDrawingNo());
        return taskDispatch;
    }
 
    /**
     * mes 完成推送
     * @param finishTaskVO mes完工数据
     */
    public void finishTask(MesTaskFinishVO finishTaskVO) {
        TaskDispatch taskDispatch = taskDispatchService.getByOperationId(finishTaskVO.getOperationId());
        if(taskDispatch != null && taskDispatch.getProcessInstanceId() != null){
            taskDispatch.setProcessCard(finishTaskVO.getProcessCard());
            if(finishTaskVO.getInspector() != null) {
                taskDispatch.setInspector(finishTaskVO.getInspector());
            }
            if(finishTaskVO.getOperationFeedbackTime() != null){
                taskDispatch.setOperateTime(finishTaskVO.getOperationFeedbackTime());
            }
 
            if(finishTaskVO.getAcruslEndTime() !=null ) {
                taskDispatch.setCheckTime(finishTaskVO.getAcruslEndTime());
            }
            taskDispatchService.updateById(taskDispatch);
 
            ProcessInstance inst = runtimeService.createProcessInstanceQuery()
                .processInstanceId(taskDispatch.getProcessInstanceId()).active().singleResult();
            if(inst != null){
                runtimeService.setVariable(taskDispatch.getProcessInstanceId(), FlowVariableConstant.PROCESS_CARD,finishTaskVO.getProcessCard());
            }
 
        }
    }
}