api/src/test/java/com/xjrsoft/module/liteflow/node/WfSubscriptionNodeTest.java

package com.xjrsoft.module.liteflow.node;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.xjrsoft.XjrSoftApplication;
import com.xjrsoft.module.workflow.entity.WorkflowFormRelation;
import com.xjrsoft.module.workflow.service.IWorkflowExecuteService;
import com.xjrsoft.module.workflow.service.IWorkflowFormRelationService;
import org.camunda.bpm.engine.history.HistoricProcessInstance;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;
import java.util.Optional;

import static org.junit.jupiter.api.Assertions.*;

/**
 * @author dzx
 * @date 2024/9/24
 */
@RunWith(SpringRunner.class)
@SpringBootTest(classes = XjrSoftApplication.class)
class WfSubscriptionNodeTest {

    @Autowired
    private IWorkflowExecuteService workflowExecuteService;

    @Autowired
    private IWorkflowFormRelationService relationService;


    @Test
    void test(){
        List<WorkflowFormRelation> list = relationService.list(
                new QueryWrapper<WorkflowFormRelation>().lambda()
                        .isNull(WorkflowFormRelation::getCurrentState)
        );

        for (WorkflowFormRelation workflowFormRelation : list) {
            Optional<HistoricProcessInstance> historicProcessInstanceOptional = workflowExecuteService.getHistoricProcessInstance(workflowFormRelation.getProcessId());
            if (historicProcessInstanceOptional.isEmpty()) {
                continue;
            }
            HistoricProcessInstance historicProcessInstance = historicProcessInstanceOptional.get();

            workflowFormRelation.setStartTime(historicProcessInstance.getStartTime());
            workflowFormRelation.setEndTime(historicProcessInstance.getEndTime());
            workflowFormRelation.setCurrentState(historicProcessInstance.getState());
            relationService.updateCurrentState(workflowFormRelation);
        }
    }

}