|
|
|
@ -46,6 +46,7 @@ public class OaSrmVendorSyncAction extends BaseBean implements Action, EsbServer
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public WeaResult<Map<String, Object>> execute(Map<String, Object> requestInfoMap) {
|
|
|
|
|
logger_41a64316.info("OaSrmVendorSyncAction start");
|
|
|
|
|
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)));
|
|
|
|
@ -139,6 +140,7 @@ public class OaSrmVendorSyncAction extends BaseBean implements Action, EsbServer
|
|
|
|
|
}
|
|
|
|
|
int dtcount = 0;
|
|
|
|
|
String sql = "select b.* from " + tablename + " a," + tablename + "_dt3 b where a.id=b.mainid and a.requestid=" + requestid;
|
|
|
|
|
logger_41a64316.info(String.valueOf("sql-->" + sql));
|
|
|
|
|
String poolname = CONN_TYPE.workflow.getType();
|
|
|
|
|
// TODO E10执行sql方法第二参数必须指定源,默认使用流程源,单体客户无需修改,微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
|
|
|
|
|
rs.executeSql(sql, poolname);
|
|
|
|
@ -214,6 +216,7 @@ public class OaSrmVendorSyncAction extends BaseBean implements Action, EsbServer
|
|
|
|
|
Row[] sq = dtq.getRow();
|
|
|
|
|
int dtcount = 0;
|
|
|
|
|
String sql = "select distinct wlh from " + tablename + " a," + tablename + "_dt2 b where a.id=b.mainid and a.requestid=" + requestid;
|
|
|
|
|
logger_41a64316.info("sql-->" + sql);
|
|
|
|
|
String poolname_wk = CONN_TYPE.workflow.getType();
|
|
|
|
|
// TODO E10执行sql方法第二参数必须指定源,默认使用流程源,单体客户无需修改,微服务/组合客户需根据查询表所属服务切换源,或使用外部数据源
|
|
|
|
|
rs.executeSql(sql, poolname_wk);
|
|
|
|
@ -330,7 +333,7 @@ public class OaSrmVendorSyncAction extends BaseBean implements Action, EsbServer
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
logger_41a64316.error("OaSrmVendorSyncAction e: {}", e.getMessage());
|
|
|
|
|
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager())), requestinfo.getRequestManager()));
|
|
|
|
|
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestinfo.getRequestManager()));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|