Merge remote-tracking branch 'origin/ht' into ht

webservice
calyrex 6 months ago
commit f7f9f662cb

@ -36,11 +36,12 @@ public class HrUtil {
String guid = "";
if (!"".equals(qjlb)) {
// TODO 有参构造 :new RecordSetDataSource("hr") 实例化方式改变,请检查是否有对应有参实现
RecordSetDataSource rsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
// RecordSetDataSource rsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
RecordSet rsd = I18nContextUtil.getBean(RecordSet.class);
String sql = "select classGUID from ht_ATDATTENDANCECLASS where id=" + qjlb;
String poolname = "";
// TODO E10必须指定poolname数据源
rsd.executeSql(sql, poolname);
rsd.executeSql(sql, "hr");
if (rsd.next()) {
guid = Util.null2String(rsd.getString("classGUID"));
}

@ -46,7 +46,8 @@ public class BlackListTempThawCheckAction extends BaseBean implements Action, Es
logger_454fb322.info(String.valueOf("BlackListTempThawCheckAction--start--" + requestid));
String wfid = request.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String table = util.getTablename(wfid);
// String table = util.getTablename(wfid);
String table = request.getRequestManager().getBillTableName();
Property[] properties = request.getMainTableInfo().getProperty();
Map<String, String> map = new HashMap<String, String>();
for (int i = 0; i < properties.length; i++) {

@ -60,7 +60,7 @@ public class ChuChaiShenQingNewAction extends BaseBean implements Action, EsbSer
String requestid = request.getRequestid();
String lastoperator = request.getLastoperator();
// TODO 有参构造 :new RecordSetDataSource("hr") 实例化方式改变,请检查是否有对应有参实现
RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
RecordSet rdsd = I18nContextUtil.getBean(RecordSet.class);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String workflowid = request.getWorkflowid();
String requestname = request.getRequestManager().getRequestname();
@ -100,7 +100,7 @@ public class ChuChaiShenQingNewAction extends BaseBean implements Action, EsbSer
String sql = "select classcode from e10_common.dbo.ht_ATDATTENDANCECLASS where ID='" + value + "'";
logger_fee0cda9.info("sql == " + sql );
rdsd.executeSql(sql, poolname);
rdsd.executeSql(sql, "hr");
rdsd.next();
QJLB = Util.null2String(rdsd.getString("classcode"));
logger_fee0cda9.info("QJLB == " + QJLB );

@ -94,10 +94,10 @@ public class DidiYongCheAction extends BaseBean implements Action, EsbServerless
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("滴滴返回错误信息:" + message);
} else {
String content = getPropValue("htportaloaUrl", "didiremindtext");
// String content = getPropValue("htportaloaUrl", "didiremindtext");
// Map<String,Object> urlmap = new HashMap<String,Object>();
// urlmap.put("msgurl", getPropValue("htportaloaUrl","didiremindurl"));
String dataid = getPropValue("htportaloaUrl", "didireminddataid");
// String dataid = getPropValue("htportaloaUrl", "didireminddataid");
// InterfaceUtil.sendMsg(sendlist,","+dataid+",", "", content,16,urlmap);

@ -52,7 +52,8 @@ public class HTGD_MES_NonStandardAction extends BaseBean implements Action, EsbS
// 工作流ID
String workFlowId = requestInfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestInfo.getRequestManager().getBillTableName();
try {
String requestName = requestInfo.getRequestManager().getRequestname();
String creatorId = requestInfo.getCreatorid();

@ -159,7 +159,8 @@ public class HTGD_MES_SC03Action extends BaseBean implements Action, EsbServerle
logger_1ea91e04.info(String.valueOf(requestId + "-HTGD_MES_SC03Action info:" + ret[0] + "-" + ret[1]));
if (!"S".equals(ret[0])) {
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_ig = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源

@ -115,7 +115,8 @@ public class HTGD_MES_SpeedFixAction extends BaseBean implements Action, EsbServ
logger_d0d39a5f.info(String.valueOf(requestId + "-HTGD_MES_SpeedFixAction info:" + ret[0] + "-" + ret[1]));
if (!"S".equals(ret[0])) {
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源

@ -85,7 +85,8 @@ public class HTGD_MES_TDLApproveActivon extends BaseBean implements Action, EsbS
String[] ret = service.returnRes(req);
logger_674a8052.info(String.valueOf(requestId + "-HTGD_MES_TDLApproveActivon info:" + ret[0] + "-" + ret[1]));
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源

@ -42,7 +42,8 @@ public class HTWLJiaBanAction extends BaseBean implements Action, EsbServerlessR
logger_983b20e3.info(String.valueOf("HTWLJiaBanAction--start--" + requestid));
String wfid = request.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = request.getRequestManager().getBillTableName();
Property[] aproperty = request.getMainTableInfo().getProperty();
String jbrq = "";
String jbrqx = "";
@ -90,28 +91,29 @@ public class HTWLJiaBanAction extends BaseBean implements Action, EsbServerlessR
// 下午打卡记录
String xwdkjl = "";
// TODO 有参构造 :new RecordSetDataSource("onecard") 实例化方式改变,请检查是否有对应有参实现
RecordSetDataSource rsds = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("onecard");
// RecordSetDataSource rsds = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("onecard");
RecordSet rsds = I18nContextUtil.getBean(RecordSet.class);
if ("0".equals(mGZSD)) {
// 白班,根据实际加班开始日期 获取当天最早打卡和最晚打卡
String sql = "SELECt (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time1, " + " (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time2";
logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql));
String poolname_y6 = "";
// TODO E10必须指定poolname数据源
rsds.executeSql(sql, poolname_y6);
rsds.executeSql(sql, "onecard");
} else if ("1".equals(mGZSD)) {
// 晚班,根据实际开始日期的最晚打卡时间,根据实际结束日期的最早打卡时间
String sql = "SELECt (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_ksrq_X + "' and UserNo='" + gh + "') as time1, " + " (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + mSJJB_jsrq_x + "' and UserNo='" + gh + "') as time2";
logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql));
String poolname_g7 = "";
// TODO E10必须指定poolname数据源
rsds.executeSql(sql, poolname_g7);
rsds.executeSql(sql, "onecard");
} else {
// RecordSetDataSource rsds = new RecordSetDataSource("onecard");
String sql = "SELECt (SELECT min(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + jbrqx + "' and UserNo='" + gh + "' and AttendanceDateTime<'" + jbrq + " 12:00:00" + "') as time1, " + " (SELECT max(AttendanceDateTime) FROM `view_attendance` where AttendanceDate='" + jbrqx + "' and UserNo='" + gh + "' and AttendanceDateTime>'" + jbrq + " 12:00:00" + "') as time2";
logger_983b20e3.info(String.valueOf("查询打卡记录sql:" + sql));
String poolname = "";
// TODO E10必须指定poolname数据源
rsds.executeSql(sql, poolname);
rsds.executeSql(sql, "onecard");
// String swdkjl = "";//上午打卡记录
// String xwdkjl = "";//下午打卡记录
// while (rsds.next()) {

@ -43,7 +43,8 @@ public class Iur_syncProject extends BaseBean implements Action, EsbServerlessRp
String workflowid = requestinfo.getWorkflowid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workflowid);
// String tablename = util.getTablename(workflowid);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
logger_72949ae6.info(String.valueOf("Iur_syncProject--start:" + requestid));
JSONObject map = new JSONObject();

@ -56,7 +56,8 @@ public class OaCrmZDYWFPAction extends BaseBean implements Action, EsbServerless
requestID = requestInfo.getRequestid();
workflowID = requestInfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
tablename = util.getTablename(workflowID);
// tablename = util.getTablename(workflowID);
tablename = requestInfo.getRequestManager().getBillTableName();
Map<String, String> mMap = new HashMap<String, String>();
for (int i = 0; i < properties.length; i++) {
String name = properties[i].getName().toUpperCase();

@ -45,7 +45,8 @@ public class OperateAccountAction extends BaseBean implements Action, EsbServerl
String requestId = request.getRequestid();
String wfid = request.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = request.getRequestManager().getBillTableName();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String stat = "";
String message = "";

@ -49,7 +49,8 @@ public class OperateMesAccountAction extends BaseBean implements Action, EsbServ
String requestId = request.getRequestid();
String wfid = request.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = request.getRequestManager().getBillTableName();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String stat = "";
String message = "";

@ -13,12 +13,11 @@ import java.util.concurrent.Executors;
import org.apache.commons.lang.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.weaver.seconddev.interfaces.eipoa.PortalPlanService;
import com.weaver.seconddev.interfaces.eipoa.SI_HTPortalPlan_OUTServiceStub.InsertPlan;
import com.weaver.seconddev.interfaces.swfa.BillFieldUtil;
//TODO config
//import com.weaver.seconddev.interfaces.workflow.entity.Meeting;
//import weaver.wxinterface.InterfaceUtil;
//import weaver.interfaces.eipoa.PortalPlanService;
//import weaver.interfaces.eipoa.SI_HTPortalPlan_OUTServiceStub.InsertPlan;
//import weaver.interfaces.swfa.BillFieldUtil;
//import weaver.interfaces.workflow.entity.Meeting;
//import weaver.meeting.Maint.MeetingRoomComInfo;
import java.lang.*;
import java.util.*;
import com.weaver.verupgrade.workflow.request.RequestManager;
@ -33,6 +32,7 @@ import com.weaver.verupgrade.general.BaseBean;
import com.weaver.verupgrade.general.Util;
import com.weaver.verupgrade.interfaces.workflow.action.Action;
// import weaver.wxinterface.InterfaceUtil;
@org.springframework.stereotype.Service("workflow_action_PushMeetingAction")
public class PushMeetingAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -44,15 +44,15 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless
String[] arr = ids.split(",");
Set<String> list = new HashSet<String>();
for(int i=0;i<arr.length;i++){
if(!"".equals(arr[i])){
if(!"".equals(arr[i])){
list.add(util.getWorkcode(arr[i]));
}
}
return StringUtils.join(list.toArray(),";");
}*/
private static final Logger logger_88956bf8 = LoggerFactory.getLogger(PushMeetingAction.class);
public static final org.slf4j.Logger logger_88956bf8 = LoggerFactory.getLogger(PushMeetingAction.class);
private static ExecutorService pool = Executors.newFixedThreadPool(3);
// private static ExecutorService pool = Executors.newFixedThreadPool(3);
public PushMeetingAction() {
logger_88956bf8.info(String.valueOf("PushMeetingAction---"));
@ -68,7 +68,8 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless
Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
try {
// TODO config
//TODO config
// Meeting m = new Meeting(request.getRequestid());
// pool.execute(m);
/*String requestid = request.getRequestid();
@ -85,8 +86,8 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless
"ON m.meetingtype = t.id inner join MeetingLog L on m.ApproveID = L.relatedid " +
"where m.requestid="+requestid;
rs.execute(sql);
Map<String,String> map = new HashMap<String,String>();
if(rs.next()){
Map<String,String> map = new HashMap<String,String>();
if(rs.next()){
String id = Util.null2String(rs.getString("ApproveID"));
String meetingtype = Util.null2String(rs.getString("meetingtype"));
String name = Util.null2String(rs.getString("MeetingName"));
@ -133,7 +134,7 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless
map.put("source","1");
map.put("content","会议地点:"+location+"\r\n会议内容"+description);
}
if(!"".equals(address)){
String[] str = address.split(",");
for(int a=0;a<str.length;a++){
@ -148,7 +149,7 @@ public class PushMeetingAction extends BaseBean implements Action, EsbServerless
PortalPlanService service = new PortalPlanService();
InsertPlan insertData= JSONObject.parseObject(JSON.toJSONString(map),InsertPlan.class);
String[] str = service.insertPlan(insertData);
writeLog("推送会议到门户结束--"+map.get("id")+"--"+str[1]);
writeLog("推送会议到门户结束--"+map.get("id")+"--"+str[1]);
}catch(Exception e){
writeLog("推送会议到门户失败--"+requestid+"--"+e.toString());
}*/

@ -76,7 +76,8 @@ public class QingJiaShenQingAction extends BaseBean implements Action, EsbServer
String requestid = request.getRequestid();
/*String lastoperator = request.getLastoperator();
TODO :new RecordSetDataSource("hr") , */
RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
// RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
RecordSet rdsd = I18nContextUtil.getBean(RecordSet.class);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String state = "E";
String str = "failed";
@ -126,7 +127,7 @@ public class QingJiaShenQingAction extends BaseBean implements Action, EsbServer
} else if (name.equals("QJLB2")) {
String poolname = "";
// TODO E10必须指定poolname数据源
rdsd.executeSql("select classcode from ht_ATDATTENDANCECLASS where ID='" + value + "'", poolname);
rdsd.executeSql("select classcode from ht_ATDATTENDANCECLASS where ID='" + value + "'", "hr");
rdsd.next();
QJLB = Util.null2String(rdsd.getString("classcode"));
} else if (name.equals("SQRQ")) {

@ -73,7 +73,8 @@ public class QingJiaShenQingCheckAction extends BaseBean implements Action, EsbS
String requestid = request.getRequestid();
/*String lastoperator = request.getLastoperator();
TODO :new RecordSetDataSource("hr") , */
RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
// RecordSetDataSource rdsd = I18nContextUtil.getBean(RecordSetDataSource.class).setPoolname("hr");
RecordSet rdsd = I18nContextUtil.getBean(RecordSet.class);
// RecordSet rs = new RecordSet();
// RecordSet rs2 = new RecordSet();
// String workflowid = request.getWorkflowid();
@ -120,7 +121,7 @@ public class QingJiaShenQingCheckAction extends BaseBean implements Action, EsbS
} else if (name.equals("QJLB2")) {
String poolname = "";
// TODO E10必须指定poolname数据源
rdsd.executeSql("select classcode from ht_ATDATTENDANCECLASS where ID='" + value + "'", poolname);
rdsd.executeSql("select classcode from ht_ATDATTENDANCECLASS where ID='" + value + "'", "hr");
rdsd.next();
QJLB = Util.null2String(rdsd.getString("classcode"));
} else if (name.equals("SQRQ")) {

@ -49,7 +49,8 @@ public class SY_WLPS_NEW_RETURNAction extends BaseBean implements Action, EsbSer
// 工作流ID
String workFlowId = requestinfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
String requestName = requestinfo.getRequestManager().getRequestname();
String creatorId = requestinfo.getCreatorid();

@ -56,7 +56,8 @@ public class SY_WLPS_RETURNAction extends BaseBean implements Action, EsbServerl
// 工作流ID
String workFlowId = requestinfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
String requestName = requestinfo.getRequestManager().getRequestname();
String creatorId = requestinfo.getCreatorid();

@ -57,7 +57,8 @@ public class SY_WLPS_RETURNNewAction extends BaseBean implements Action, EsbServ
// 工作流ID
String workFlowId = requestinfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
String requestName = requestinfo.getRequestManager().getRequestname();
String creatorId = requestinfo.getCreatorid();

@ -56,7 +56,8 @@ public class TransferBillToK3Action extends BaseBean implements Action, EsbServe
String message = "";
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workflowid);
// String tablename = util.getTablename(workflowid);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
logger_1a36f94a.info(String.valueOf("TransferBillToK3Action--start-" + requestid));
Property[] aproperty = requestinfo.getMainTableInfo().getProperty();

@ -52,7 +52,8 @@ public class XNY_YCLTC_ReturnAction extends BaseBean implements Action, EsbServe
// 工作流ID
String workFlowId = requestinfo.getWorkflowid();
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workFlowId);
// String tablename = util.getTablename(workFlowId);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
String requestName = requestinfo.getRequestManager().getRequestname();
String creatorId = requestinfo.getCreatorid();

@ -50,7 +50,8 @@ public class ZOA_FI_IORD_RFC_Action extends BaseBean implements Action, EsbServe
}
if ("0".equals(map.get("YWLX")) || "1".equals(map.get("YWLX"))) {
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workflowid);
// String tablename = util.getTablename(workflowid);
String tablename = requestinfo.getRequestManager().getBillTableName();
param[0][0] = "HT01";
param[0][1] = (util.getselectNameByCol("DDLX", workflowid, map.get("DDLX"))).substring(0, 4);
param[0][2] = map.get("GSDM");

@ -47,7 +47,8 @@ public class ZOA_FI_IORD_RFC_CheckAction extends BaseBean implements Action, Esb
}
if ("0".equals(map.get("YWLX")) || "1".equals(map.get("YWLX"))) {
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(workflowid);
// String tablename = util.getTablename(workflowid);
String tablename = requestinfo.getRequestManager().getBillTableName();
param[0][0] = "HT01";
param[0][1] = (util.getselectNameByCol("DDLX", workflowid, map.get("DDLX"))).substring(0, 4);
param[0][2] = map.get("GSDM");

@ -47,7 +47,8 @@ public class ZOA_MM_ZMMT002_FASTCONFIG_Action extends BaseBean implements Action
String wfid = requestinfo.getWorkflowid();
logger_e6726d63.info(String.valueOf("ZOA_MM_ZMMT002_FASTCONFIG_Action-start:" + requestid));
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
DetailTable[] detailtable = requestinfo.getDetailTableInfo().getDetailTable();
DetailTable dtq = detailtable[0];
Row[] sq = dtq.getRow();

@ -76,6 +76,11 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
Long requestIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("requestid", -1)));
Long userIdTemp = Long.parseLong(String.valueOf(requestInfoMap.getOrDefault("userid", -1)));
RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
logger_f5224b91.info("----- workflow_action_ZOA_SL_GWCC_Action new -----");
logger_f5224b91.info("requestIdTemp -----"+ requestIdTemp);
logger_f5224b91.info("userIdTemp -----"+ userIdTemp);
try {
// 流程请求ID
String reid = request.getRequestid();
@ -490,10 +495,12 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
logUtil.insertLog();
str = Message;
String sql1 = "update " + tablename + " set message = isnull(cast(message as varchar(8000)),'') + '" + Message + "' where requestId = " + reid;
logger_f5224b91.info(String.valueOf("sql1:" + sql1));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs1.executeSql(sql1, poolname);
boolean b = rs1.executeSql(sql1, poolname);
logger_f5224b91.info("b -----"+ b);
} else {
str = "SUCCESS";
hrstate = "S";
@ -510,11 +517,13 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
str = str.substring(0, 150);
}
String sql = "insert into chuchai_qingjia_log(requestId,gh,lbbh,kssj,jssj,message,state,qjss) values('" + reid + "','','A11','" + beginDateTime + "','" + endDateTime + "','" + str + "','" + hrstate + "','" + qjss + "')";
logger_f5224b91.info("sql -----"+ sql);
String poolname_ym = CONN_TYPE.workflow.getType();
/* *TODO insert -> E9sqlE10 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10sql使/使*/
long generate = IdGenerator.generate();
rs.executeSql(sql, poolname_ym,generate);
boolean b = rs.executeSql(sql, poolname_ym, generate);
logger_f5224b91.info("b -----"+ b);
if (applyEmpNum.length() < 10) {
// 经办人工号
applyEmpNum = errandEmpNum;
@ -607,7 +616,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
logger_f5224b91.info(String.valueOf("logsql:" + logsql));
String poolname_6c = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs1.executeSql(logsql, poolname_6c);
boolean b1 = rs1.executeSql(logsql, poolname_6c);
logger_f5224b91.info(String.valueOf("b1:" + b1));
}
} catch (Exception e) {
logger_f5224b91.info(String.valueOf(reid + "商旅接口Exception:" + e.getMessage()));
@ -631,7 +641,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
logger_f5224b91.info(String.valueOf("logsql2:" + logsql2));
String poolname_t9 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs1.executeSql(logsql2, poolname_t9);
boolean b1 = rs1.executeSql(logsql2, poolname_t9);
logger_f5224b91.info(String.valueOf("b1:" + b1));
}
} catch (Exception e) {
logger_f5224b91.info(String.valueOf(reid + "携程接口Exception:" + e.getMessage()));
@ -707,7 +718,8 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
logger_f5224b91.info(String.valueOf("logsql4:" + logsql4));
String poolname_ot = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs1.executeSql(logsql4, poolname_ot);
boolean b1= rs1.executeSql(logsql4, poolname_ot);
logger_f5224b91.info(String.valueOf("b4:" + b1));
} catch (Exception e) {
e.printStackTrace();
logger_f5224b91.info(String.valueOf(reid + "同程商旅接口Exception:" + e.getMessage()));
@ -759,20 +771,24 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
sta = result[0];
message = result[1];
String sql_log = "insert into sync_eas_log(requestId,lcbh,kssj,jssj,sqrq,ccmdd,gh,name,sxrgh,sxrxm,reason,title,sqbm,sqdw,status,message) " + "values('" + reid + "','" + sourceKey + "','" + kssj + "','" + jssj + "','" + sqrq + "','" + attribute8 + "','" + applyEmpNum + "','" + applyerName + "','" + synergeticNumbers + "'" + ",'" + synergeticNames + "','" + reason + "','" + title + "','" + attribute4 + "','" + attribute5 + "','" + sta + "','" + message + "')";
logger_f5224b91.info(String.valueOf( "sql_log===" + sql_log));
String poolname_05 = CONN_TYPE.workflow.getType();
/* *TODO insert -> E9sqlE10 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10sql使/使*/
generate = IdGenerator.generate();
rs1.executeSql(sql_log, poolname_05,generate);
boolean b1 = rs1.executeSql(sql_log, poolname_05, generate);
logger_f5224b91.info(String.valueOf( "b1===" + b1));
logger_f5224b91.info(String.valueOf(reid + "同步数据到EAS完成"));
} catch (Exception e) {
message = e.getMessage();
String sql_log = "insert into sync_eas_log(requestId,lcbh,kssj,jssj,sqrq,ccmdd,gh,name,sxrgh,sxrxm,reason,title,sqbm,sqdw,status,message) " + "values('" + reid + "','" + sourceKey + "','" + kssj + "','" + jssj + "','" + sqrq + "','" + attribute8 + "','" + applyEmpNum + "','" + applyerName + "','" + synergeticNumbers + "'" + ",'" + synergeticNames + "','" + reason + "','" + title + "','" + attribute4 + "','" + attribute5 + "','" + sta + "','" + message + "')";
logger_f5224b91.info(String.valueOf( "sql_log===" + sql_log));
String poolname_ni = CONN_TYPE.workflow.getType();
/* *TODO insert -> E9sqlE10 https://www.e-cology.com.cn/sp/doc/docShare/1027709301045985331?tenantKey=t7akvdnf84
TODO E10sql使/使*/
generate = IdGenerator.generate();
rs1.executeSql(sql_log, poolname_ni,generate);
boolean b1 = rs1.executeSql(sql_log, poolname_ni, generate);
logger_f5224b91.info(String.valueOf( "b1===" + b1));
logger_f5224b91.info(String.valueOf(reid + "同步数据到EAS异常:" + e.toString()));
}
} catch (Exception e) {

@ -47,6 +47,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl
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);
logger_2bfe536a.info("----- workflow_action_ZOA_STATUS_RFCAction new -----");
logger_2bfe536a.info("requestIdTemp -----"+ requestIdTemp);
logger_2bfe536a.info("userIdTemp -----"+ userIdTemp);
try {
BillFieldUtil unit = new BillFieldUtil();
String wfid = requestinfo.getWorkflowid();
@ -81,9 +86,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl
logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功" + retstr[0] + "," + retstr[1]));
}
String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid;
logger_2bfe536a.info("sql -----"+ sql);
String poolname_vx = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname_vx);
boolean b = rs.executeSql(sql, poolname_vx);
logger_2bfe536a.info("b -----"+ b);
if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息" + retstr[1]);
@ -94,9 +101,11 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错" + e.getMessage());
String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid;
logger_2bfe536a.info("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_2bfe536a.info("b2 -----"+ b);
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
}
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));

@ -25,6 +25,8 @@ public class ZOEM_MATRIAL_PRICE {
}
public String[] Getexecute(String[][] as) {
logger_8118cdc9.info("ZOEM_MATRIAL_PRICE - Getexecute as = " + as.toString());
retstr = new String[2];
try {
JCoFunction jcofunction = destination.getRepository().getFunction("ZOEM_MATRIAL_PRICE");

@ -40,6 +40,10 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
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);
logger_8aa7358c.info("----- workflow_action_ZOEM_MATRIAL_PRICE_Action new -----");
logger_8aa7358c.info("requestIdTemp -----"+ requestIdTemp);
logger_8aa7358c.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
@ -95,11 +99,15 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
}
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
logger_8aa7358c.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_8aa7358c.info("b -----"+ b);
} catch (Exception e) {
logger_8aa7358c.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错" + e.toString());

@ -29,6 +29,8 @@ public class ZOEM_PRICE_DIFFERENCE_RATE {
}
public String[] Getexecute(String[][] as, String[][] as2) {
logger_8a2de3c9.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE- Getexecute --" + as.toString()));
retstr = new String[2];
try {
JCoFunction jcofunction = destination.getRepository().getFunction("ZOEM_PRICE_DIFFERENCE_RATE");

@ -41,6 +41,10 @@ public class ZOEM_PRICE_DIFFERENCE_RATE_Action extends BaseBean implements Actio
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);
logger_69cd5f8c.info("----- workflow_action_ZOEM_PRICE_DIFFERENCE_RATE_Action new -----");
logger_69cd5f8c.info("requestIdTemp -----"+ requestIdTemp);
logger_69cd5f8c.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
@ -150,11 +154,15 @@ public class ZOEM_PRICE_DIFFERENCE_RATE_Action extends BaseBean implements Actio
sb.append("OEM成品差价率返回结果" + ret[1]);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
logger_69cd5f8c.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_69cd5f8c.info("b -----"+ b);
} catch (Exception e) {
logger_69cd5f8c.info(String.valueOf("ZOEM_PRICE_DIFFERENCE_RATE_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessagecontent("OEM成品差价率返回结果" + e.toString());

@ -40,6 +40,11 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
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);
logger_9b3f3cb8.info("----- workflow_action_ZOEM_PROCESSING_CHARGE_Action new -----");
logger_9b3f3cb8.info("requestIdTemp -----"+ requestIdTemp);
logger_9b3f3cb8.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
@ -93,11 +98,15 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
}
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
logger_9b3f3cb8.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_9b3f3cb8.info("b -----"+ b);
} catch (Exception e) {
logger_9b3f3cb8.info(String.valueOf("ZOEM_PROCESSING_CHARGE_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错" + e.toString());

@ -25,6 +25,8 @@ public class ZSRM_PUR_INFO {
}
public String[] Getexecute(String[][] as) {
logger_741408ac.info("ZSRM_PUR_INFO Getexecute as = " + as);
retstr = new String[2];
try {
JCoFunction jcofunction = destination.getRepository().getFunction("ZSRM_PUR_INFO");

@ -38,6 +38,12 @@ public class ZSRM_PUR_INFO_Action extends BaseBean implements Action, EsbServerl
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);
logger_78218549.info("----- workflow_action_ZSRM_PUR_INFO_Action new -----");
logger_78218549.info("requestIdTemp -----"+ requestIdTemp);
logger_78218549.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
@ -134,11 +140,14 @@ public class ZSRM_PUR_INFO_Action extends BaseBean implements Action, EsbServerl
}
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
logger_78218549.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_78218549.info("b -----"+ b);
} catch (Exception e) {
logger_78218549.info(String.valueOf("ZSRM_PUR_INFO_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错" + e.toString());

@ -37,6 +37,10 @@ public class ZSRM_PUR_INFO_CheckAction extends BaseBean implements Action, EsbSe
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);
logger_9ad0d62b.info("----- workflow_action_ZSRM_PUR_INFO_CheckAction new -----");
logger_9ad0d62b.info("requestIdTemp -----"+ requestIdTemp);
logger_9ad0d62b.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
try {

@ -38,12 +38,17 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
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);
logger_da6b5da2.info("----- workflow_action_ZSRM_PUR_INFO_GY107_Action new -----");
logger_da6b5da2.info("requestIdTemp -----"+ requestIdTemp);
logger_da6b5da2.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-start-" + requestid));
String sync = "";
@ -96,20 +101,25 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
ZSRM_PUR_INFO info = new ZSRM_PUR_INFO();
String[] ret = info.Getexecute(str);
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]"));
String sql = "update " + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
String sql = "update e10_core_business." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
logger_da6b5da2.info("sql -----"+ sql);
String poolname_mm = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname_mm);
boolean b = rs.executeSql(sql, poolname_mm);
logger_da6b5da2.info("b -----"+ b);
}
}
} catch (Exception e) {
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错" + e.toString());
String sql = "update " + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
logger_da6b5da2.info("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_da6b5da2.info("b2 -----"+ b);
}
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-end-" + requestid));
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));

@ -34,6 +34,11 @@ public class ZSRM_PUR_INFO_GY107_CheckAction extends BaseBean implements Action,
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);
logger_6ccd4d72.info("----- workflow_action_ZSRM_PUR_INFO_GY107_CheckAction new -----");
logger_6ccd4d72.info("requestIdTemp -----"+ requestIdTemp);
logger_6ccd4d72.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
try {

@ -38,12 +38,18 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS
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);
logger_8fd2ca4a.info("----- workflow_action_ZSRM_PUR_INFO_GY132_Action new -----");
logger_8fd2ca4a.info("requestIdTemp -----"+ requestIdTemp);
logger_8fd2ca4a.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
BillFieldUtil util = new BillFieldUtil();
String tablename = util.getTablename(wfid);
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
try {
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-start-" + requestid));
String sync = "";
@ -96,20 +102,24 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS
ZSRM_PUR_INFO info = new ZSRM_PUR_INFO();
String[] ret = info.Getexecute(str);
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]"));
String sql = "update " + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
String sql = "update e10_core_business." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
logger_8fd2ca4a.info("sql -----"+ sql);
String poolname_r3 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname_r3);
boolean b = rs.executeSql(sql, poolname_r3);
logger_8fd2ca4a.info("b -----"+ b);
}
}
} catch (Exception e) {
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错" + e.toString());
String sql = "update " + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
logger_8fd2ca4a.info("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
boolean b = rs.executeSql(sql, poolname);
logger_8fd2ca4a.info("b2 -----"+ b);
}
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-end-" + requestid));
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));

@ -34,6 +34,11 @@ public class ZSRM_PUR_INFO_GY132_CheckAction extends BaseBean implements Action,
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);
logger_69d789ca.info("----- workflow_action_ZSRM_PUR_INFO_GY132_CheckAction new -----");
logger_69d789ca.info("requestIdTemp -----"+ requestIdTemp);
logger_69d789ca.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
try {
@ -47,6 +52,7 @@ public class ZSRM_PUR_INFO_GY132_CheckAction extends BaseBean implements Action,
sync = value;
}
}
logger_69d789ca.info("sync -----"+ sync);
if ("0".equals(sync)) {
DetailTable[] detailtable = requestinfo.getDetailTableInfo().getDetailTable();
DetailTable dtq = detailtable[1];

@ -43,6 +43,10 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ
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);
logger_adc1e038.info("----- workflow_action_ZSR_PUR_INFO_OEM_Action new -----");
logger_adc1e038.info("requestIdTemp -----"+ requestIdTemp);
logger_adc1e038.info("userIdTemp -----"+ userIdTemp);
try {
String requestid = requestinfo.getRequestid();
String wfid = requestinfo.getWorkflowid();
@ -63,11 +67,13 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ
String state = "";
int mxcount = 0;
String sql = "select count(b.id) as mxcount from " + tablename + " a," + tablename + "_dt1 b where a.id = b.mainid and a.requestId =" + requestid + " and isnull(sfbjsc,1)<>0";
logger_adc1e038.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
if (rs.next()) {
mxcount = rs.getInt("mxcount");
logger_adc1e038.info("mxcount -----"+ mxcount);
}
if (mxcount > 0) {
int j = 0;
@ -138,9 +144,11 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ
}
BillFieldUtil util = new BillFieldUtil();
sql = "update " + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
logger_adc1e038.info("update sql -----"+ sql);
String poolname_d9 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname_d9);
boolean b = rs.executeSql(sql, poolname_d9);
logger_adc1e038.info("b -----"+ b);
} catch (Exception e) {
logger_adc1e038.info(String.valueOf("ZSR_PUR_INFO_OEM_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口同步数据出错" + e.toString());

@ -52,6 +52,10 @@ public class ZWZX_CG_FileUploadAction extends BaseBean implements Action, EsbSer
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);
logger_323752e9.info("----- workflow_action_ZWZX_CG_FileUploadAction new -----");
logger_323752e9.info("requestIdTemp -----"+ requestIdTemp);
logger_323752e9.info("userIdTemp -----"+ userIdTemp);
try {
/**
* ID*
@ -143,7 +147,7 @@ public class ZWZX_CG_FileUploadAction extends BaseBean implements Action, EsbSer
String[] docs = fileIds.split(",");
for (int i = 0; i < docs.length; i++) {
String docid = docs[i];
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_common.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from e10_core_business.dbo.document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
@ -167,6 +171,8 @@ public class ZWZX_CG_FileUploadAction extends BaseBean implements Action, EsbSer
fileItem.put("fileName", imagefilename);
fileItem.put("fileContent", uploadBuffer);
fileItem.put("invoiceNo", "");
logger_323752e9.info(String.valueOf("fileItem =" + fileItem));
fileVOListArr.add(fileItem);
baos.close();
fi.close();

@ -46,6 +46,10 @@ public class ZZ_DZDAFDApproveAction extends BaseBean implements Action, EsbServe
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);
logger_ccc3e432.info("----- workflow_action_ZZ_DZDAFDApproveAction new -----");
logger_ccc3e432.info("requestIdTemp -----"+ requestIdTemp);
logger_ccc3e432.info("userIdTemp -----"+ userIdTemp);
try {
/**
* ID*
@ -89,6 +93,7 @@ public class ZZ_DZDAFDApproveAction extends BaseBean implements Action, EsbServe
// 调用接口
// url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.dzdafd_zz_url")).trim();
url = configProp.getDzdafd_zz_url();
logger_ccc3e432.info("url" + url);
String yoaywbh = mMap.get("YOAYWBH");
mJson.put("receiptNO", yoaywbh);
mJson.put("voucherSysFrom", "OA");

@ -59,6 +59,10 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
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);
logger_b14cb5d0.info("----- workflow_action_ZZ_GDFileUploadAction new -----");
logger_b14cb5d0.info("requestIdTemp -----"+ requestIdTemp);
logger_b14cb5d0.info("userIdTemp -----"+ userIdTemp);
try {
/**
* ID*
@ -143,7 +147,8 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
String[] docs = fileIds.split(",");
for (int i = 0; i < docs.length; i++) {
String docid = docs[i];
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_core_business.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from e10_core_business.dbo.document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
logger_b14cb5d0.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
@ -167,6 +172,8 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
fileItem.put("fileName", imagefilename);
fileItem.put("fileContent", uploadBuffer);
fileItem.put("invoiceNo", "");
logger_b14cb5d0.info("fileItem -----"+ fileItem);
fileVOListArr.add(fileItem);
baos.close();
fi.close();
@ -289,9 +296,12 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_48 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
recordSet.executeSql("select c.name from wfp_base a " + "INNER JOIN form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_48);
String sql = "select c.name from e10_common.dbo.wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue;
logger_b14cb5d0.info("getselectNameByCol sql = " + sql );
recordSet.executeSql(sql, poolname_48);
if (recordSet.next()) {
name = recordSet.getString("selectname");
logger_b14cb5d0.info("getselectNameByCol name = " + name );
}
return name;
}

@ -55,6 +55,9 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
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);
logger_8ab26152.info("----- workflow_action_ZZ_Ten_GDFileUploadAction new -----");
logger_8ab26152.info("requestIdTemp -----"+ requestIdTemp);
logger_8ab26152.info("userIdTemp -----"+ userIdTemp);
try {
/**
* ID*
@ -154,11 +157,13 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
String[] docs = fileIds.split(",");
for (int i = 0; i < docs.length; i++) {
String docid = docs[i];
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
String sql = " select b.filerealpath,b.iszip,b.name,b.imagefileid from " + " e10_core_business.dbo.fileobj b where b.imagefileid in(select max(imagefileid) " + "from document_main_access as docimagefile where docid in(" + docid + ") group by docid)";
logger_8ab26152.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
rs.executeSql(sql, poolname);
if (rs.next()) {
JSONObject fileItem = new JSONObject();
String imagefileid = Util.null2String(rs.getString("imagefileid"));
String filerealpath = Util.null2String(rs.getString("filerealpath"));
@ -178,6 +183,8 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
fileItem.put("fileName", imagefilename);
fileItem.put("fileContent", uploadBuffer);
fileItem.put("invoiceNo", "");
logger_8ab26152.info("fileItem == "+fileItem);
fileVOListArr.add(fileItem);
baos.close();
fi.close();
@ -293,10 +300,13 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_w2 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源默认使用流程源单体客户无需修改微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
recordSet.executeSql("select c.name from wfp_base a " + "INNER JOIN form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_w2);
String sql = "select c.name from wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue;
logger_8ab26152.info("getselectNameByCol sql = " + sql);
recordSet.executeSql(sql, poolname_w2);
if (recordSet.next()) {
name = recordSet.getString("selectname");
}
logger_8ab26152.info("getselectNameByCol name = " + name);
return name;
}

Loading…
Cancel
Save