Process115.java 2.4 KB
Newer Older
苗卫卫 committed
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
package com.boco.nbd.wios.flow.process;

import com.boco.nbd.framework.workflow.entity.SubmitFlowRequest;
import com.boco.nbd.framework.workflow.entity.SubmitTypeEnum;
import com.boco.nbd.framework.workflow.entity.exception.FlowException;
import com.boco.nbd.framework.workflow.flow.AbstractFlow;
import com.boco.nbd.wios.flow.entity.bo.LocalSubmitFlowBO;
import com.boco.nbd.wios.flow.enums.FlowNodeEnum;
import com.boco.nbd.wios.flow.util.ProcessUtil;
import org.springframework.stereotype.Service;

import java.util.Date;

/**
 * @author:cao hai
 * @date:2022/6/30 17:06
 * @version:V1.0
 * @description:Process115
 * @modify:
 */
@Service("Process115")
public class Process115 extends AbstractFlow {


    /**
     * 预处理(业务数据调整)
     *
     * @param request
     */
    @Override
    protected void preProcess(SubmitFlowRequest request) {
        LocalSubmitFlowBO bo = (LocalSubmitFlowBO) request;
        if (SubmitTypeEnum.Transfer.equals(bo.getSubmitType())) {
            bo.userNamesHandler();
            bo.setCommentMsg(bo.getCurrentNodeEnum().getValue() + "工单转派" + bo.getBusiness().getSurveyStaffName());
        } else if (SubmitTypeEnum.TaskFlow.equals(request.getSubmitType())) {
            //报装状态 1:通过 2:不通过
            boolean expandStatus = ProcessUtil.compare(bo.getBusiness().getExpandStatus(), 1);
            StringBuffer builder = new StringBuffer();
            builder.append(FlowNodeEnum.NODE_115.getValue() + ":");
            builder.append(expandStatus ? "通过" : "未通过;");
            if (expandStatus) {
                bo.getBusiness().setElectricExpandTime(new Date());
            } else {
                builder.append(bo.getBusiness().getExpandFailReason());
            }
            bo.setNextNodeEnum(FlowNodeEnum.NODE_104);
            bo.setCommentMsg(builder.toString());
            //下一节点流转至当前勘测电工
            if (bo.getOldBusiness().getSurveyStaffId() == null) {
                throw new FlowException(bo.getWorkId() + "下一节点操作用户缺失!");
            }
            bo.getUserNames().add(bo.getOldBusiness().getSurveyStaffId() + "");
        }
    }

    /**
     * 验证参数
     *
     * @param request
     */
    @Override
    protected void verifyParam(SubmitFlowRequest request) {

    }

    /**
     * 后续处理
     *
     * @param request
     */
    @Override
    protected void postProcess(SubmitFlowRequest request) {

    }
}