tjBANK/com/engine/tjbankSocket/impl/CWGLSocketExecute.java

package com.engine.tjbankSocket.impl;

import com.cloudstore.dev.api.bean.MessageBean;
import com.cloudstore.dev.api.bean.MessageType;
import com.cloudstore.dev.api.util.Util_Message;
import com.engine.tjbankSocket.SocketExecute;
import com.engine.util.XMLUtils;
import com.icbc.api.internal.apache.http.impl.cookie.S;
import weaver.conn.RecordSet;
import weaver.conn.RecordSetTrans;
import weaver.general.BaseBean;
import weaver.general.GCONST;
import weaver.general.StringUtil;
import weaver.general.Util;
import weaver.interfaces.workflow.action.Action;
import weaver.soa.workflow.request.RequestService;

import java.io.IOException;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

public class CWGLSocketExecute extends BaseBean implements SocketExecute {
    @Override
    public String execute(String param) {
        Map<String, String> paramMap = XMLUtils.parseXMLToMap(param);
        writeLog("paramMap==="+paramMap);
        String oaTrvlBnsExpnsAcctNo =  Util.null2String(paramMap.get("oaTrvlBnsExpnsAcctNo"));
        String apprvrNo = Util.null2String(paramMap.get("apprvrNo"));
        String apprvrName = Util.null2String(paramMap.get("apprvrName"));
        String flowStatus = Util.null2String(paramMap.get("flowStatus"));
        String sgntrOpn = Util.null2String(paramMap.get("sgntrOpn"));
        sgntrOpn = apprvrName + "(" + apprvrNo + "):" + sgntrOpn;
        Map<String, String> resultMap = null;
        int userid = 0;
        try {
            resultMap = getBeanByOAnum(oaTrvlBnsExpnsAcctNo, "formtable_main_281");
        } catch (Exception e) {
            e.printStackTrace();
            return XMLUtils.CW2XML(paramMap, "1", e.getMessage());
        }
        try {
            userid = getHrmidByWorkCode(apprvrNo);
        } catch (Exception e) {
            e.printStackTrace();
        }
        String id = resultMap.get("id");
        int requestid = Util.getIntValue(resultMap.get("requestid"));
        writeLog("requestid==="+requestid);
        if (requestid == 0) {
            return XMLUtils.CW2XML(paramMap, "1", "流程未找到");
        }
        if (userid == 0) {
            return XMLUtils.CW2XML(paramMap, "1", "人员未找到");
        }
        RequestService requestService = new RequestService();
        boolean istrue = false;
        if ("0".equals(flowStatus)) {
            sgntrOpn = sgntrOpn + "(驳回)";
            istrue = requestService.nextNodeByReject(requestid, 1, sgntrOpn);
        } else if ("1".equals(flowStatus)) {
            sgntrOpn = sgntrOpn + "(记账前退单)";
            istrue = requestService.nextNodeByReject(requestid, 1, sgntrOpn);
        } else if ("2".equals(flowStatus)) {
            sgntrOpn = sgntrOpn + "(记账后退单)";
            istrue = requestService.nextNodeByReject(requestid, 1, sgntrOpn);
        } else {
            istrue = requestService.nextNodeBySubmit(null, requestid, 1, sgntrOpn);
        }
        writeLog("istrue==="+istrue);
        if (istrue) {
            try {
                updateStatus(requestid, flowStatus);
                String sqr = getsqrbyBH(oaTrvlBnsExpnsAcctNo, "formtable_main_281");
                sendMsgForSuccess(sqr);
            } catch (Exception e) {
                e.printStackTrace();
                return XMLUtils.CW2XML(paramMap, "1", e.getMessage());
            }
            return XMLUtils.CW2XML(paramMap, "0", "");
        } else {
            return XMLUtils.CW2XML(paramMap, "1", "流程提交失败");
        }
    }

    private void sendMsgForSuccess(String userid) {
        MessageType messageType = MessageType.newInstance(1674); // 消息来源（见文档第四点补充 必填）
        Set<String> userIdList = new HashSet<>(); // 接收人id 必填
        String[] useridArr =  userid.split(",");
        for (String s : useridArr) {
            userIdList.add(s);
        }
        String title = "补助提醒"; // 标题
        String context = "您有新的差旅补助到账，请您查收";
        String linkUrl = ""; // PC端链接
        String linkMobileUrl = ""; // 移动端链接
        try {
            MessageBean messageBean = Util_Message.createMessage(messageType, userIdList, title, context, linkUrl, linkMobileUrl);
            messageBean.setCreater(1);// 创建人id
            //message.setBizState("0");// 需要修改消息为已处理等状态时传入,表示消息最初状态为待处理
            //messageBean.setTargetId("121|22"); //消息来源code +“|”+业务id需要修改消息为已处理等状态时传入
            Util_Message.store(messageBean);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private void updateStatus(int requestid, String flowStatus) throws Exception {
        try {
            RecordSet recordSet = new RecordSet();
            recordSet.executeUpdate("update formtable_main_281 set cwxtzt = ? where requestId = ?", flowStatus, requestid);
        } catch (Exception e) {
            throw new Exception("更新状态失败");
        }
    }


    public Map<String, String> getBeanByOAnum(String oaTrvlBnsExpnsAcctNo, String tableName) throws Exception {
        RecordSet recordSet = new RecordSet();
        HashMap<String, String> resultMap = new HashMap<>();
        String sql = "select * from " + tableName + " where djbh = ?";
        recordSet.executeQuery(sql, oaTrvlBnsExpnsAcctNo);
        if (recordSet.next()) {
            resultMap.put("id", Util.null2String(recordSet.getString("id")));
            resultMap.put("requestid", Util.null2String(recordSet.getString("requestid")));
            return resultMap;
        } else {
            throw new Exception("编号对应单据不存在");
        }
    }

    /**
     * 获取单据的
     * @param oaTrvlBnsExpnsAcctNo
     * @param tableName
     * @return
     * @throws Exception
     */
    public String getsqrbyBH(String oaTrvlBnsExpnsAcctNo, String tableName) throws Exception {
        RecordSet recordSet = new RecordSet();
        HashMap<String, String> resultMap = new HashMap<>();
        String sql = "select jbrxm from " + tableName + " where djbh = ?";
        recordSet.executeQuery(sql, oaTrvlBnsExpnsAcctNo);
        if (recordSet.next()) {

            return Util.null2String(recordSet.getString("jbrxm"));
        } else {
            throw new Exception("编号对应单据不存在");
        }
    }

    public int getHrmidByWorkCode(String workcode) throws Exception {
        RecordSet recordSet = new RecordSet();
        String sql = "select id from HRMRESOURCE where workcode = ?";
        recordSet.executeQuery(sql, workcode);
        if (recordSet.next()) {
            return Util.getIntValue(recordSet.getString("id"));
        } else {
            throw new Exception("审批人不存在");
        }
    }

    public static void main(String[] args) {
        HashMap<String, String> paramMap = new HashMap<>();
        String sgntrOpn = paramMap.get("sgntrOpn");
        sgntrOpn =  "(" + 1111 + "):" + sgntrOpn;
        System.out.println(sgntrOpn);
    }
}