|
|
|
@ -1,240 +0,0 @@
|
|
|
|
|
// 废弃不需要改造
|
|
|
|
|
|
|
|
|
|
//package com.weaver.seconddev.interfaces.workflow.action;
|
|
|
|
|
//
|
|
|
|
|
//import com.alibaba.fastjson.JSONArray;
|
|
|
|
|
//import com.alibaba.fastjson.JSONObject;
|
|
|
|
|
//import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
|
|
|
|
|
//import java.util.HashMap;
|
|
|
|
|
//import java.util.Map;
|
|
|
|
|
//import com.weaver.common.i18n.tool.util.I18nContextUtil;
|
|
|
|
|
//import org.springframework.core.env.Environment;
|
|
|
|
|
//import java.lang.*;
|
|
|
|
|
//import java.util.*;
|
|
|
|
|
//import com.weaver.verupgrade.workflow.request.RequestManager;
|
|
|
|
|
//import com.weaver.esb.api.rpc.EsbServerlessRpcRemoteInterface;
|
|
|
|
|
//import com.weaver.common.base.entity.result.WeaResult;
|
|
|
|
|
//import org.slf4j.Logger;
|
|
|
|
|
//import org.slf4j.LoggerFactory;
|
|
|
|
|
//import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.RequestInfo;
|
|
|
|
|
//import com.weaver.verupgrade.general.BaseBean;
|
|
|
|
|
//import com.weaver.verupgrade.general.Util;
|
|
|
|
|
//import com.weaver.verupgrade.hrm.resource.ResourceComInfo;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.*;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.Property;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.DetailTable;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.Row;
|
|
|
|
|
//import com.weaver.verupgrade.soa.workflow.request.Cell;
|
|
|
|
|
//import com.weaver.verupgrade.interfaces.workflow.action.Action;
|
|
|
|
|
//
|
|
|
|
|
///**
|
|
|
|
|
// * 访客邀约系统审批返回
|
|
|
|
|
// */
|
|
|
|
|
//@org.springframework.stereotype.Service("workflow_action_XZ_FKYYApproveAction")
|
|
|
|
|
//public class XZ_FKYYApproveAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
|
|
|
|
|
//
|
|
|
|
|
// // 对应E9的请求信息对象
|
|
|
|
|
// @Autowired
|
|
|
|
|
// private RequestInfo requestInfoTemp;
|
|
|
|
|
//
|
|
|
|
|
// private static final Logger logger_a4ff2ce0 = LoggerFactory.getLogger(XZ_FKYYApproveAction.class);
|
|
|
|
|
//
|
|
|
|
|
// @Override
|
|
|
|
|
// public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
|
|
|
|
|
// Map<String, Object> weaverResultMap = new HashMap<>();
|
|
|
|
|
// Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
|
|
|
|
|
// Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
|
|
|
|
|
// RequestInfo requestInfo = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
|
|
|
|
|
// try {
|
|
|
|
|
// /**
|
|
|
|
|
// * 请求ID*
|
|
|
|
|
// */
|
|
|
|
|
// String requestID = "";
|
|
|
|
|
// try {
|
|
|
|
|
// ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class);
|
|
|
|
|
// BillFieldUtil unit = new BillFieldUtil();
|
|
|
|
|
// // 工作流ID
|
|
|
|
|
// String workFlowId = requestInfo.getWorkflowid();
|
|
|
|
|
// Property[] properties = requestInfo.getMainTableInfo().getProperty();
|
|
|
|
|
// requestID = requestInfo.getRequestid();
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("XZ_FKYYApproveAction--start--" + requestID));
|
|
|
|
|
// Map<String, String> mMap = new HashMap<String, String>();
|
|
|
|
|
// for (int i = 0; i < properties.length; i++) {
|
|
|
|
|
// String name = properties[i].getName().toUpperCase();
|
|
|
|
|
// String value = Util.null2String(properties[i].getValue());
|
|
|
|
|
// mMap.put(name, value);
|
|
|
|
|
// }
|
|
|
|
|
// JSONObject mJson = new JSONObject();
|
|
|
|
|
// // 申请人
|
|
|
|
|
// String sqr = mMap.get("SQR");
|
|
|
|
|
// String sqrcode = "";
|
|
|
|
|
// String sqrname = "";
|
|
|
|
|
// if (!sqr.equals("")) {
|
|
|
|
|
// // 申请人工号
|
|
|
|
|
// sqrcode = unit.getWorkcode(sqr);
|
|
|
|
|
// // 申请人姓名
|
|
|
|
|
// sqrname = hr.getResourcename(sqr);
|
|
|
|
|
// }
|
|
|
|
|
// // 申请人
|
|
|
|
|
// mJson.put("applyName", sqrname);
|
|
|
|
|
// String sqdw = mMap.get("SQDW");
|
|
|
|
|
// String sqdwname = unit.getSubcompanyname(sqdw);
|
|
|
|
|
// // 申请单位
|
|
|
|
|
// mJson.put("applyCompany", sqdwname);
|
|
|
|
|
// String sqbm = mMap.get("SQBM");
|
|
|
|
|
// String sqbmname = unit.getDepartmentname(sqbm);
|
|
|
|
|
// // 申请部门
|
|
|
|
|
// mJson.put("applyDepartment", sqbmname);
|
|
|
|
|
// // 申请日期
|
|
|
|
|
// mJson.put("applyDate", mMap.get("SQRQ"));
|
|
|
|
|
// String qwyq = mMap.get("QWYQ");
|
|
|
|
|
// String qwyqName = unit.getselectNameByCol("qwyq", workFlowId, qwyq);
|
|
|
|
|
// // 前往园区
|
|
|
|
|
// mJson.put("purpose", qwyqName);
|
|
|
|
|
// // 对接人
|
|
|
|
|
// String djr = mMap.get("DJRXM");
|
|
|
|
|
// String djrcode = "";
|
|
|
|
|
// String djrname = "";
|
|
|
|
|
// if (!djr.equals("")) {
|
|
|
|
|
// // 对接人工号
|
|
|
|
|
// djrcode = unit.getWorkcode(djr);
|
|
|
|
|
// // 对接人姓名
|
|
|
|
|
// djrname = hr.getResourcename(djr);
|
|
|
|
|
// }
|
|
|
|
|
// // 对接人姓名
|
|
|
|
|
// mJson.put("receptionName", djrname);
|
|
|
|
|
// String djrdw = mMap.get("DJRDW");
|
|
|
|
|
// String djrdwname = unit.getSubcompanyname(djrdw);
|
|
|
|
|
// // 对接单位
|
|
|
|
|
// mJson.put("receptionCompany", djrdwname);
|
|
|
|
|
// // 对接人联系电话
|
|
|
|
|
// mJson.put("receptionContact", mMap.get("DJRLXDH"));
|
|
|
|
|
// String djrbm = mMap.get("DJRBM");
|
|
|
|
|
// String djrbmname = unit.getDepartmentname(djrbm);
|
|
|
|
|
// // 对接人部门
|
|
|
|
|
// mJson.put("receptionDepartment", djrbmname);
|
|
|
|
|
// String djk = mMap.get("DJK");
|
|
|
|
|
// String djkname = unit.getselectNameByCol("djk", workFlowId, djk);
|
|
|
|
|
// String name = "";
|
|
|
|
|
// String address = "";
|
|
|
|
|
// // if(djkname.contains("(")&&djkname.contains(")")){
|
|
|
|
|
// // name = djkname.substring(0,djkname.indexOf("("));
|
|
|
|
|
// // address = djkname.substring(djkname.indexOf("("),djkname.indexOf(")"));
|
|
|
|
|
// // }else{
|
|
|
|
|
// // name = djkname;
|
|
|
|
|
// // }
|
|
|
|
|
// if (djkname.contains("/")) {
|
|
|
|
|
// name = djkname.substring(0, djkname.lastIndexOf("/"));
|
|
|
|
|
// address = djkname.substring(djkname.lastIndexOf("/") + 1);
|
|
|
|
|
// } else {
|
|
|
|
|
// name = djkname;
|
|
|
|
|
// }
|
|
|
|
|
// // 登记口
|
|
|
|
|
// mJson.put("registration", name);
|
|
|
|
|
// // 登记口具体地址
|
|
|
|
|
// mJson.put("registrationAddress", address);
|
|
|
|
|
// // 备注
|
|
|
|
|
// mJson.put("remark", mMap.get("BZ"));
|
|
|
|
|
// // 标题
|
|
|
|
|
// mJson.put("title", "");
|
|
|
|
|
// // 流程编号
|
|
|
|
|
// mJson.put("visitorCode", mMap.get("LCBH"));
|
|
|
|
|
// // 访客单位全称
|
|
|
|
|
// mJson.put("visitorCompany", mMap.get("FKDWQC"));
|
|
|
|
|
// // 访客人数
|
|
|
|
|
// mJson.put("visitorNumber", mMap.get("FKRS"));
|
|
|
|
|
// // 来访事由
|
|
|
|
|
// mJson.put("visitorReason", mMap.get("LFSY"));
|
|
|
|
|
// mJson.put("requestId", requestID);
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("明细表开始取值"));
|
|
|
|
|
// DetailTable[] detailtable = requestInfo.getDetailTableInfo().getDetailTable();
|
|
|
|
|
// // ===========凭证明细==============//
|
|
|
|
|
// DetailTable dtq = detailtable[0];
|
|
|
|
|
// Row[] sq = dtq.getRow();
|
|
|
|
|
// JSONArray visitorsPeopleArr = new JSONArray();
|
|
|
|
|
// for (int j = 0; j < sq.length; j++) {
|
|
|
|
|
// // 指定行
|
|
|
|
|
// Row rq = sq[j];
|
|
|
|
|
// // 每行数据再按列存储
|
|
|
|
|
// Cell[] cq = rq.getCell();
|
|
|
|
|
// JSONObject item = new JSONObject();
|
|
|
|
|
// Map<String, String> mDetailMap = new HashMap<String, String>();
|
|
|
|
|
// for (int k = 0; k < cq.length; k++) {
|
|
|
|
|
// // 指定列
|
|
|
|
|
// Cell cq1 = cq[k];
|
|
|
|
|
// // 明细字段名称
|
|
|
|
|
// String nameq = cq1.getName().toUpperCase();
|
|
|
|
|
// String valueq = Util.null2String(cq1.getValue());
|
|
|
|
|
// mDetailMap.put(nameq, valueq);
|
|
|
|
|
// }
|
|
|
|
|
// // 姓名
|
|
|
|
|
// item.put("visitorName", mDetailMap.get("XM"));
|
|
|
|
|
// // 联系电话
|
|
|
|
|
// item.put("visitorContant", mDetailMap.get("LXDH"));
|
|
|
|
|
// // 预计入园时间
|
|
|
|
|
// item.put("estimatedInTime", mDetailMap.get("YJRYRQ") + " " + mDetailMap.get("YJRYSJ") + ":00");
|
|
|
|
|
// // 预计离开时间
|
|
|
|
|
// item.put("estimatedOutTime", mDetailMap.get("YJLKRQ") + " " + mDetailMap.get("YJLKSJ") + ":00");
|
|
|
|
|
// // 车辆
|
|
|
|
|
// item.put("licensePlateNumber", mDetailMap.get("CPH"));
|
|
|
|
|
// visitorsPeopleArr.add(item);
|
|
|
|
|
// }
|
|
|
|
|
// mJson.put("visitorsPeopleList", visitorsPeopleArr);
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("获取明细表数据结束"));
|
|
|
|
|
// writeLog("调用访客系统接口请求数据:=====" + mJson.toString());
|
|
|
|
|
// // 调用接口
|
|
|
|
|
// String url = Util.null2String(I18nContextUtil.getBean(Environment.class).getProperty("htfkxtoasync.creathtvisitorapply")).trim();
|
|
|
|
|
// ZZ_SendPostRequest mGetResult = new ZZ_SendPostRequest();
|
|
|
|
|
// String result = mGetResult.getResult(mJson, url);
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("调用访客系统接口请求数据:" + result));
|
|
|
|
|
// if (!"E".equals(result)) {
|
|
|
|
|
// JSONObject jsonObject = JSONObject.parseObject(result);
|
|
|
|
|
// // 接口处理状态 1-成功,0-失败
|
|
|
|
|
// String isTat = jsonObject.getString("code");
|
|
|
|
|
// // 处理消息
|
|
|
|
|
// String srMessage = jsonObject.getString("message");
|
|
|
|
|
// writeLog("访客系统返回数据:" + jsonObject.toString());
|
|
|
|
|
// if (!"1".equals(isTat)) {
|
|
|
|
|
// // 失败
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("访客系统返回错误信息:" + srMessage));
|
|
|
|
|
// // requestInfo.getRequestManager().setMessageid("ERROR");
|
|
|
|
|
// requestInfo.getRequestManager().setMessagecontent("访客系统返回错误信息:" + srMessage);
|
|
|
|
|
// return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
|
|
|
|
|
// }
|
|
|
|
|
// } else {
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("调用访客系统接口返回失败,请联系访客系统管理员!"));
|
|
|
|
|
// // requestInfo.getRequestManager().setMessageid("ERROR");
|
|
|
|
|
// requestInfo.getRequestManager().setMessagecontent("调用访客系统接口返回失败,请联系访客系统管理员!");
|
|
|
|
|
// return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
|
|
|
|
|
// }
|
|
|
|
|
// } catch (Exception e) {
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("提交失败!"));
|
|
|
|
|
// logger_a4ff2ce0.info(String.valueOf("Error======" + e.getMessage()));
|
|
|
|
|
// // requestInfo.getRequestManager().setMessageid("ERROR");
|
|
|
|
|
// requestInfo.getRequestManager().setMessagecontent("提交失败!");
|
|
|
|
|
// return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
|
|
|
|
|
// }
|
|
|
|
|
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestInfo.getRequestManager()));
|
|
|
|
|
// } catch (Exception e) {
|
|
|
|
|
// e.printStackTrace();
|
|
|
|
|
// logger_a4ff2ce0.error("XZ_FKYYApproveAction e: {}", e.getMessage());
|
|
|
|
|
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestInfo.getRequestManager())), requestInfo.getRequestManager()));
|
|
|
|
|
// }
|
|
|
|
|
// }
|
|
|
|
|
//
|
|
|
|
|
// Map<String, Object> getResultMapForAction(Map<String, Object> map, String key, Object value, RequestManager requestManager) {
|
|
|
|
|
// if (key != null && !key.isEmpty()) {
|
|
|
|
|
// map.put(key, value);
|
|
|
|
|
// }
|
|
|
|
|
// String msgContent = requestManager.getMessagecontent();
|
|
|
|
|
// if (msgContent != null && !msgContent.isEmpty()) {
|
|
|
|
|
// map.put("msgContent", msgContent);
|
|
|
|
|
// }
|
|
|
|
|
// String msgId = requestManager.getMessageid();
|
|
|
|
|
// if (msgId != null && !msgId.isEmpty()) {
|
|
|
|
|
// map.put("msgId", msgId);
|
|
|
|
|
// }
|
|
|
|
|
// return map;
|
|
|
|
|
// }
|
|
|
|
|
//}
|