qa-prevention-gwj/src/main/java/com/zcloud/flow/xgf/JiTuan/JiTuanWeiTuoSupervise.java

package com.zcloud.flow.xgf.JiTuan;

import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
import com.zcloud.entity.PageData;
import com.zcloud.flow.xgf.util.XgfFlowDto;
import com.zcloud.mapper.datasource.bus.CorpInfoMapper;
import com.zcloud.mapper.datasource.xgf.XgfFlowsMapper;
import com.zcloud.mapper.datasource.xgf.XgfUserMapper;
import com.zcloud.service.xgf.XgfUserService;
import com.zcloud.util.DateUtil;
import com.zcloud.util.Jurisdiction;
import org.apache.commons.lang3.StringUtils;

import javax.annotation.Resource;

@LiteflowComponent("JiTuanWeiTuoSupervise")
public class JiTuanWeiTuoSupervise extends NodeComponent {

    @Resource
    private XgfFlowsMapper xgfFlowsMapper;

    @Resource
    private XgfUserService xgfUserService;

    @Resource
    private XgfUserMapper xgfUserMapper;

    @Resource
    private CorpInfoMapper corpInfoMapper;

    @Override
    public boolean isAccess() {
        XgfFlowDto info = this.getRequestData();
        // 如果指针没有数据，赋值后自动结束
        if (StringUtils.isBlank(info.getIterator())) {
            PageData condition = new PageData();
            condition.put("FLOWS_ID", info.getFLOWS_ID());
            PageData flows = xgfFlowsMapper.findById(condition);
            info.setIterator("3");
            flows.put("APPOINT_THREE_CORP_TYPE", "0");
            flows.put("APPOINT_THREE_DEPARTMENT_ID", info.getAPPOINT_DEPARTMENT_ID());
            flows.put("APPOINT_THREE_DEPARTMENT_NAME", info.getAPPOINT_DEPARTMENT_NAME());
            flows.put("APPOINT_THREE_USER_ID", info.getAPPOINT_USER_ID());
            flows.put("APPOINT_THREE_USER_NAME", info.getAPPOINT_USER_NAME());
            flows.put("FLOWS_STEP", 3);
            xgfFlowsMapper.edit(flows);
            return false;
        }
        return "3".equals(info.getIterator());
    }

    @Override
    public void process() throws Exception {
        System.out.println(getName() + "节点");

        XgfFlowDto info = this.getRequestData();
        PageData condition = new PageData();

        condition.put("FLOWS_ID", info.getFLOWS_ID());
        PageData flows = xgfFlowsMapper.findById(condition);

        condition.clear();
        condition.put("CORPINFO_ID", Jurisdiction.getCORPINFO_ID());
        PageData corpEntity = corpInfoMapper.findById(condition);

        flows.put("APPOINT_THREE_CORP_ID", Jurisdiction.getCORPINFO_ID());
        flows.put("APPOINT_THREE_CORP_NAME", corpEntity.getString("CORP_NAME"));
        flows.put("APPOINT_THREE_TIME", DateUtil.getTime());
        flows.put("APPOINT_THREE_STATUS", info.getSTATUS());
        flows.put("APPOINT_THREE_OPINION", info.getOPINION());
        flows.put("OPINION", info.getOPINION());
        if ("0".equals(info.getSTATUS())) {
            // 打回至相关方端
            xgfUserService.repulse(flows);
            // 保存操作记录
            xgfUserService.saveLog(info, info.getSTATUS(), "0");
        } else {
            xgfFlowsMapper.edit(flows);
            condition.clear();
            condition.put("XGF_USER_ID", flows.getString("FLOWS_ID"));
            PageData entity = xgfUserMapper.findById(condition);
            entity.put("CHECK_STATUS", 2);
            entity.put("VALID_FLAG", "1");
            entity.put("STATUS", "2");
            entity.put("CHECK_STEP", Integer.parseInt(entity.get("CHECK_STEP").toString()) + 1);
            xgfUserMapper.edit(entity);

            // 保存操作记录
            xgfUserService.saveLog(info, info.getSTATUS(), "1");
        }

    }

    @Override
    public boolean isEnd() {
        XgfFlowDto info = this.getRequestData();
        if ("0".equals(info.getSTATUS()) && "3".equals(info.getIterator())) {
            return true;
        }
        return super.isEnd();
    }
}