rj
/
ht
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

formdataid

Browse Source
ht
qijirenjian 3 months ago
parent 30ebd9b728
commit f05da8881d
9 changed files with 57 additions and 32 deletions
Show Stats Download Patch File Download Diff File

3
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ChangeInformationExpertsAction.java
Unescape Escape View File

@ -53,13 +53,14 @@ public class ChangeInformationExpertsAction extends BaseBean implements Action,
// String workflowid = request.getWorkflowid(); // String workflowid = request.getWorkflowid();
String tablename = request.getRequestManager().getBillTableName(); String tablename = request.getRequestManager().getBillTableName();
logger_750b7a22.error(String.valueOf("ChangeInformationExpertsAction--start--" + requestid)); logger_750b7a22.error(String.valueOf("ChangeInformationExpertsAction--start--" + requestid));
String dataid = commonDevUtil.getidByrequestid(requestid);
TransUtil tu = new TransUtil(); TransUtil tu = new TransUtil();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String tablename = tu.getTableName(workflowid); // String tablename = tu.getTableName(workflowid);
String roleid = "100502830000001498"; String roleid = "100502830000001498";
String zjlx1 = ""; String zjlx1 = "";
String sqdw = ""; String sqdw = "";
String sql = "select * from e10_core_business.dbo." + tablename + " where id=" + requestid; String sql = "select * from e10_core_business.dbo." + tablename + " where FORM_DATA_ID = " + dataid;
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b2 = rs.executeSql(sql, poolname); boolean b2 = rs.executeSql(sql, poolname);

3
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/EasQuerySourceBoeNumAction.java
Unescape Escape View File

@ -109,7 +109,6 @@ public class EasQuerySourceBoeNumAction extends BaseBean implements Action, EsbS
lxArray[j] = lx; lxArray[j] = lx;
logger_3c7e784f.error(String.valueOf("类型：" + lx)); logger_3c7e784f.error(String.valueOf("类型：" + lx));
} }
djjeArray[j] = "";
if (nameq.equals("DJJE")) { if (nameq.equals("DJJE")) {
// 冻结金额 // 冻结金额
String djje = valueq.trim(); String djje = valueq.trim();
@ -163,6 +162,8 @@ public class EasQuerySourceBoeNumAction extends BaseBean implements Action, EsbS
String[] result = null; String[] result = null;
logger_3c7e784f.error(String.valueOf("type1：" + type1)); logger_3c7e784f.error(String.valueOf("type1：" + type1));
logger_3c7e784f.error(String.valueOf("type2：" + type2)); logger_3c7e784f.error(String.valueOf("type2：" + type2));
logger_3c7e784f.error(String.valueOf("lxArrays：" + Arrays.toString(lxArray)));
logger_3c7e784f.error(String.valueOf("djjeArrays：" + Arrays.toString(djjeArray)));
if ("2".equals(type1) && "Y".equals(type2)) { if ("2".equals(type1) && "Y".equals(type2)) {
// 报账单 冻结 // 报账单 冻结
for (int i = 0; i < bzdhArray.length; i++) { for (int i = 0; i < bzdhArray.length; i++) {

8
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/K3PORequestAction.java
Unescape Escape View File

@ -6,6 +6,7 @@ import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -35,7 +36,8 @@ public class K3PORequestAction extends BaseBean implements Action, EsbServerless
// 对应E9的请求信息对象 // 对应E9的请求信息对象
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
@Autowired @Autowired
private CallPORequestService service ; private CallPORequestService service ;
private static final Logger logger_7396c45f = LoggerFactory.getLogger(K3PORequestAction.class); private static final Logger logger_7396c45f = LoggerFactory.getLogger(K3PORequestAction.class);
@ -72,6 +74,8 @@ public class K3PORequestAction extends BaseBean implements Action, EsbServerless
// String tableName = tu.getTableName(workflowID); // String tableName = tu.getTableName(workflowID);
String tableName = requestInfo.getRequestManager().getBillTableName(); String tableName = requestInfo.getRequestManager().getBillTableName();
logger_7396c45f.error(String.valueOf("K3PORequestAction--start--" + requestID)); logger_7396c45f.error(String.valueOf("K3PORequestAction--start--" + requestID));
String dataid = commonDevUtil.getidByrequestid(requestID);
Map<String, String> mMap = new HashMap<String, String>(); Map<String, String> mMap = new HashMap<String, String>();
for (int i = 0; i < properties.length; i++) { for (int i = 0; i < properties.length; i++) {
String name = properties[i].getName().toUpperCase(); String name = properties[i].getName().toUpperCase();
@ -168,7 +172,7 @@ public class K3PORequestAction extends BaseBean implements Action, EsbServerless
String message = response.getMessage(); String message = response.getMessage();
String cgdddjbh = Util.null2String(response.getFBillNO()); String cgdddjbh = Util.null2String(response.getFBillNO());
logger_7396c45f.error(String.valueOf(requestID + "result:code:" + code + " result:" + result + " message:" + message + " cgdddjbh:" + cgdddjbh)); logger_7396c45f.error(String.valueOf(requestID + "result:code:" + code + " result:" + result + " message:" + message + " cgdddjbh:" + cgdddjbh));
String sql = "update e10_core_business.dbo." + tableName + " set cgdddjbh='" + cgdddjbh + "' where id=" + requestID; String sql = "update e10_core_business.dbo." + tableName + " set cgdddjbh='" + cgdddjbh + "' where FORM_DATA_ID = " + dataid;
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname); boolean b = rs.executeSql(sql, poolname);

13
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/OaWmsReturnAction.java
Unescape Escape View File

@ -5,6 +5,7 @@ import com.weaver.seconddev.interfaces.gdwmsoa.ZMES_OA_SUBMIT_SERVICE;
import com.weaver.seconddev.interfaces.gdwmsoa.ZMES_OA_SUBMIT_SERVICEStub; import com.weaver.seconddev.interfaces.gdwmsoa.ZMES_OA_SUBMIT_SERVICEStub;
import com.weaver.seconddev.interfaces.swfa.BillFieldUtil; import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -29,7 +30,8 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
// 对应E9的请求信息对象 // 对应E9的请求信息对象
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
@Autowired @Autowired
private ZMES_OA_SUBMIT_SERVICE service; private ZMES_OA_SUBMIT_SERVICE service;
@ -45,6 +47,9 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
try { try {
String requestid = requestinfo.getRequestid(); String requestid = requestinfo.getRequestid();
logger_824c0f2.error(String.valueOf(requestid + "--OaWmsReturnAction--start")); logger_824c0f2.error(String.valueOf(requestid + "--OaWmsReturnAction--start"));
String dataid = commonDevUtil.getidByrequestid(requestid);
String createrid = requestinfo.getCreatorid(); String createrid = requestinfo.getCreatorid();
String workflowid = requestinfo.getWorkflowid(); String workflowid = requestinfo.getWorkflowid();
TransUtil tu = new TransUtil(); TransUtil tu = new TransUtil();
@ -70,7 +75,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
} }
// 获取申请人直接上级 // 获取申请人直接上级
String zjsj = ""; String zjsj = "";
sql = "select (select lastname from eteams.dbo.employee as hrmresource where id=b.superior) as zjsj from e10_core_business.dbo." + tableName + " a,employee b where a.sqr=b.id and a.id =" + requestid; sql = "select (select lastname from eteams.dbo.employee as hrmresource where id=b.superior) as zjsj from e10_core_business.dbo." + tableName + " a,employee b where a.sqr=b.id and a.FORM_DATA_ID = " + dataid;
logger_824c0f2.error("sql--" + sql); logger_824c0f2.error("sql--" + sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -95,7 +100,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
// ZMES_OA_SUBMIT_SERVICE service = new ZMES_OA_SUBMIT_SERVICE(); // ZMES_OA_SUBMIT_SERVICE service = new ZMES_OA_SUBMIT_SERVICE();
str = service.call(param, requestid, cfxt); str = service.call(param, requestid, cfxt);
logger_824c0f2.error(String.valueOf(requestid + "--OaWmsReturnAction--result:" + str[0] + "-" + str[1])); logger_824c0f2.error(String.valueOf(requestid + "--OaWmsReturnAction--result:" + str[0] + "-" + str[1]));
sql = "update e10_core_business.dbo." + tableName + " set state='" + str[0] + "',message='" + str[1] + "' where id=" + requestid; sql = "update e10_core_business.dbo." + tableName + " set state='" + str[0] + "',message='" + str[1] + "' where FORM_DATA_ID = " + dataid;
logger_824c0f2.error("sql--" + sql); logger_824c0f2.error("sql--" + sql);
String poolname_et = CONN_TYPE.workflow.getType(); String poolname_et = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -106,7 +111,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
return WeaResult.fail(500, "光导WMS系统返回信息：" + str[1], getResultMapForAction(weaverResultMap, "result","光导WMS系统返回信息：" + str[1], requestinfo.getRequestManager())); return WeaResult.fail(500, "光导WMS系统返回信息：" + str[1], getResultMapForAction(weaverResultMap, "result","光导WMS系统返回信息：" + str[1], requestinfo.getRequestManager()));
} }
} catch (Exception e) { } catch (Exception e) {
sql = "update e10_core_business.dbo." + tableName + " set state='E',message='" + e.toString() + "' where id=" + requestid; sql = "update e10_core_business.dbo." + tableName + " set state='E',message='" + e.toString() + "' where FORM_DATA_ID = " + dataid;
logger_824c0f2.error("sql--"+sql); logger_824c0f2.error("sql--"+sql);
String poolname_bm = CONN_TYPE.workflow.getType(); String poolname_bm = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

10
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/XNY_YCLTC_ReturnAction.java
Unescape Escape View File

@ -7,6 +7,7 @@ import java.util.HashMap;
import java.util.Map; import java.util.Map;
import java.util.UUID; import java.util.UUID;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -33,7 +34,8 @@ public class XNY_YCLTC_ReturnAction extends BaseBean implements Action, EsbServe
// 对应E9的请求信息对象 // 对应E9的请求信息对象
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
@Autowired @Autowired
private ReturnMesWLPS_SYService service; private ReturnMesWLPS_SYService service;
private static final Logger logger_555b962f = LoggerFactory.getLogger(XNY_YCLTC_ReturnAction.class); private static final Logger logger_555b962f = LoggerFactory.getLogger(XNY_YCLTC_ReturnAction.class);
@ -50,6 +52,8 @@ public class XNY_YCLTC_ReturnAction extends BaseBean implements Action, EsbServe
try { try {
String requestId = requestinfo.getRequestid(); String requestId = requestinfo.getRequestid();
logger_555b962f.error(String.valueOf("XNY_YCLTC_ReturnAction--" + requestId + "开始执行")); logger_555b962f.error(String.valueOf("XNY_YCLTC_ReturnAction--" + requestId + "开始执行"));
String dataid = commonDevUtil.getidByrequestid(requestId);
// 工作流ID // 工作流ID
String workFlowId = requestinfo.getWorkflowid(); String workFlowId = requestinfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil(); BillFieldUtil util = new BillFieldUtil();
@ -89,7 +93,7 @@ public class XNY_YCLTC_ReturnAction extends BaseBean implements Action, EsbServe
String[] ret = service.returnRes(req); String[] ret = service.returnRes(req);
if ("E".equals(ret[0])) { if ("E".equals(ret[0])) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestId; String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where FORM_DATA_ID = " + dataid;
logger_555b962f.error("sql--" + sql); logger_555b962f.error("sql--" + sql);
String poolname_ah = CONN_TYPE.workflow.getType(); String poolname_ah = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -101,7 +105,7 @@ public class XNY_YCLTC_ReturnAction extends BaseBean implements Action, EsbServe
} catch (Exception exception) { } catch (Exception exception) {
logger_555b962f.error(String.valueOf("XNY_YCLTC_ReturnAction--" + requestId + "执行出错：" + exception.getMessage())); logger_555b962f.error(String.valueOf("XNY_YCLTC_ReturnAction--" + requestId + "执行出错：" + exception.getMessage()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where id=" + requestId; String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where FORM_DATA_ID = " + dataid;
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname); boolean b = rs.executeSql(sql, poolname);

7
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_MATRIAL_PRICE_Action.java
Unescape Escape View File

@ -4,6 +4,7 @@ import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -31,7 +32,8 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
// 对应E9的请求信息对象 // 对应E9的请求信息对象
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
private static final Logger logger_8aa7358c = LoggerFactory.getLogger(ZOEM_MATRIAL_PRICE_Action.class); private static final Logger logger_8aa7358c = LoggerFactory.getLogger(ZOEM_MATRIAL_PRICE_Action.class);
@Override @Override
@ -49,6 +51,7 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
String wfid = requestinfo.getWorkflowid(); String wfid = requestinfo.getWorkflowid();
try { try {
logger_8aa7358c.error(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-start-" + requestid)); logger_8aa7358c.error(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-start-" + requestid));
String dataid = commonDevUtil.getidByrequestid(requestid);
// Property aproperty[] = requestinfo.getMainTableInfo().getProperty(); // Property aproperty[] = requestinfo.getMainTableInfo().getProperty();
// for(int j = 0; j < aproperty.length; j++){ // for(int j = 0; j < aproperty.length; j++){
// String name = aproperty[j].getName().toUpperCase(); // String name = aproperty[j].getName().toUpperCase();
@ -101,7 +104,7 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
BillFieldUtil util = new BillFieldUtil(); BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid); // String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName(); String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid; String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where FORM_DATA_ID = " + dataid;
logger_8aa7358c.error("sql -----"+ sql); logger_8aa7358c.error("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();

7
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZOEM_PROCESSING_CHARGE_Action.java
Unescape Escape View File

@ -4,6 +4,7 @@ import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -31,7 +32,8 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
// 对应E9的请求信息对象 // 对应E9的请求信息对象
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
private static final Logger logger_9b3f3cb8 = LoggerFactory.getLogger(ZOEM_PROCESSING_CHARGE_Action.class); private static final Logger logger_9b3f3cb8 = LoggerFactory.getLogger(ZOEM_PROCESSING_CHARGE_Action.class);
@Override @Override
@ -50,6 +52,7 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
String wfid = requestinfo.getWorkflowid(); String wfid = requestinfo.getWorkflowid();
try { try {
logger_9b3f3cb8.error(String.valueOf("ZOEM_PROCESSING_CHARGE_Action-start-" + requestid)); logger_9b3f3cb8.error(String.valueOf("ZOEM_PROCESSING_CHARGE_Action-start-" + requestid));
String dataid = commonDevUtil.getidByrequestid(requestid);
// Property aproperty[] = requestinfo.getMainTableInfo().getProperty(); // Property aproperty[] = requestinfo.getMainTableInfo().getProperty();
// for(int j = 0; j < aproperty.length; j++){ // for(int j = 0; j < aproperty.length; j++){
// String name = aproperty[j].getName().toUpperCase(); // String name = aproperty[j].getName().toUpperCase();
@ -100,7 +103,7 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
BillFieldUtil util = new BillFieldUtil(); BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid); // String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName(); String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid; String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where FORM_DATA_ID = " + dataid;
logger_9b3f3cb8.error("sql -----"+ sql); logger_9b3f3cb8.error("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();

8
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/action/ZSRM_PUR_INFO_GY107_Action.java
Unescape Escape View File

@ -4,6 +4,7 @@ import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
import com.weaver.common.i18n.tool.util.I18nContextUtil; import com.weaver.common.i18n.tool.util.I18nContextUtil;
import com.weaver.seconddev.interfaces.workflow.util.CommonDevUtil;
import com.weaver.verupgrade.conn.CONN_TYPE; import com.weaver.verupgrade.conn.CONN_TYPE;
import java.lang.*; import java.lang.*;
import java.util.*; import java.util.*;
@ -31,6 +32,8 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
@Autowired @Autowired
private RequestInfo requestInfoTemp; private RequestInfo requestInfoTemp;
@Autowired
private CommonDevUtil commonDevUtil;
private static final Logger logger_da6b5da2 = LoggerFactory.getLogger(ZSRM_PUR_INFO_GY107_Action.class); private static final Logger logger_da6b5da2 = LoggerFactory.getLogger(ZSRM_PUR_INFO_GY107_Action.class);
public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) { public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
@ -44,6 +47,7 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
logger_da6b5da2.error("userIdTemp -----"+ userIdTemp); logger_da6b5da2.error("userIdTemp -----"+ userIdTemp);
try { try {
String requestid = requestinfo.getRequestid(); String requestid = requestinfo.getRequestid();
String dataid = commonDevUtil.getidByrequestid(requestid);
String wfid = requestinfo.getWorkflowid(); String wfid = requestinfo.getWorkflowid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil(); BillFieldUtil util = new BillFieldUtil();
@ -101,7 +105,7 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
ZSRM_PUR_INFO info = new ZSRM_PUR_INFO(); ZSRM_PUR_INFO info = new ZSRM_PUR_INFO();
String[] ret = info.Getexecute(str); String[] ret = info.Getexecute(str);
logger_da6b5da2.error(String.valueOf("ZSRM_PUR_INFO_GY107_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]")); logger_da6b5da2.error(String.valueOf("ZSRM_PUR_INFO_GY107_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]"));
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestid; String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where FORM_DATA_ID = " + dataid;
logger_da6b5da2.error("sql -----"+ sql); logger_da6b5da2.error("sql -----"+ sql);
String poolname_mm = CONN_TYPE.workflow.getType(); String poolname_mm = CONN_TYPE.workflow.getType();
@ -117,7 +121,7 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
logger_da6b5da2.error(String.valueOf("ZSRM_PUR_INFO_GY107_Action-error-" + requestid + "-[" + e.toString() + "]")); logger_da6b5da2.error(String.valueOf("ZSRM_PUR_INFO_GY107_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessageid("ERROR"); requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString()); requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString());
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where id=" + requestid; String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where FORM_DATA_ID = " + dataid;
logger_da6b5da2.error("sql2 -----"+ sql); logger_da6b5da2.error("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

30
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/workflow/controller/MessageSubscriptionController.java
Unescape Escape View File

@ -83,7 +83,7 @@ public class MessageSubscriptionController {
} }
private void sendMsg(Map<String,Object> params) throws RemoteException, ServiceException { private void sendMsg(Map<String,Object> params) throws RemoteException, ServiceException {
logger.error("sendMsg params " + params); // logger.error("sendMsg params " + params);
String systemId = "SYS006"; String systemId = "SYS006";
String password = "123456"; String password = "123456";
String moudule = "流程待办"; String moudule = "流程待办";
@ -101,13 +101,13 @@ public class MessageSubscriptionController {
String receivers = String.valueOf(params.get("receivers")) ; String receivers = String.valueOf(params.get("receivers")) ;
logger.error(" receivers: " + receivers); // logger.error(" receivers: " + receivers);
logger.error(" moudule: " + moudule); // logger.error(" moudule: " + moudule);
logger.error(" pcurl: " + pcurl); // logger.error(" pcurl: " + pcurl);
logger.error(" msgurl: " + msgurl); // logger.error(" msgurl: " + msgurl);
logger.error(" m_msgtitle: " + m_msgtitle); // logger.error(" m_msgtitle: " + m_msgtitle);
logger.error(" moudule: " + moudule); // logger.error(" moudule: " + moudule);
logger.error(" sendid: " + sendid); // logger.error(" sendid: " + sendid);
String sendname = "系统管理员"; String sendname = "系统管理员";
@ -138,8 +138,8 @@ public class MessageSubscriptionController {
msgtt = refurl + "：" + msgtt; msgtt = refurl + "：" + msgtt;
} }
} }
logger.error(" content: " + content); // logger.error(" content: " + content);
logger.error(" msgtt: " + msgtt); // logger.error(" msgtt: " + msgtt);
refurl = msgurl; refurl = msgurl;
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -175,7 +175,7 @@ public class MessageSubscriptionController {
} }
String user = sb.toString().substring(0, sb.length() - 1); String user = sb.toString().substring(0, sb.length() - 1);
logger.error(" user: " + user); // logger.error(" user: " + user);
String msgid = "MsgSYS006" + userid + (new Date()).getTime(); String msgid = "MsgSYS006" + userid + (new Date()).getTime();
messages = messages + "<message>"; messages = messages + "<message>";
messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + refurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + target + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>"; messages = messages + "<MSG_ID>" + msgid + "</MSG_ID><PRE_MSG_ID>" + pre + "</PRE_MSG_ID><USER_ID>" + user + "</USER_ID><MSG_TITLE>" + msgtt + "</MSG_TITLE><MSG_CONTENT>" + msgtt + "</MSG_CONTENT><SENDER_NAME>" + sendname + "</SENDER_NAME><REF_URL>" + refurl + "</REF_URL><MSG_TIME>" + msgtime + "</MSG_TIME><TARGET>" + target + "</TARGET><EXT_DATA>" + extdata + "</EXT_DATA>";
@ -215,10 +215,10 @@ public class MessageSubscriptionController {
} }
headers.put("Authorization", configProp.getUrl_password()); headers.put("Authorization", configProp.getUrl_password());
logger.error(" Url_password(): " + configProp.getUrl_password()); // logger.error(" Url_password(): " + configProp.getUrl_password());
logger.error(" systemId: " + systemId); // logger.error(" systemId: " + systemId);
logger.error(" password: " + password); // logger.error(" password: " + password);
logger.error(" moudule: " + moudule); // logger.error(" moudule: " + moudule);
logger.error(" messages: " + messages); logger.error(" messages: " + messages);
Object[] val = new Object[] { systemId, password, moudule, messages }; Object[] val = new Object[] { systemId, password, moudule, messages };

Write Preview
Loading…
Cancel
Save