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

未启用排除

Browse Source
webservice
qijirenjian 5 months ago
parent 1080292c35
commit 9406ca688c
13 changed files with 454 additions and 414 deletions
Show Stats Download Patch File Download Diff File

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

@ -92,7 +92,10 @@ public class ARSPaymentRecepitAction extends BaseBean implements Action, EsbServ
String currencyCode = ""; String currencyCode = "";
String poolname = CONN_TYPE.ebuilder.getType(); String poolname = CONN_TYPE.ebuilder.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select currencyCode from e10_common.dbo.uf_eas_currency where id=" + map.get("BZ"), poolname); String sql = "select currencyCode from e10_common.dbo.uf_eas_currency where id=" + map.get("BZ");
logger_c29b3679.info( "sql--" + sql) ;
boolean b1 = rs.executeSql(sql, poolname);
logger_c29b3679.info( "sql flag = " + b1) ;
while (rs.next()) { while (rs.next()) {
currencyCode = rs.getString("currencyCode"); currencyCode = rs.getString("currencyCode");
logger_c29b3679.info( "currencyCode--" + currencyCode) ; logger_c29b3679.info( "currencyCode--" + currencyCode) ;

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

@ -230,18 +230,22 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer
} }
// RecordSet rs = new RecordSet(); // RecordSet rs = new RecordSet();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + isTat + "',message='" + msg + "' where requestId=" + requestId; String sql = "update e10_core_business.dbo." + tablename + " set state='" + isTat + "',message='" + msg + "' where requestId=" + requestId;
logger_336cd654.info("sql == "+sql);
String poolname_c1 = CONN_TYPE.workflow.getType(); String poolname_c1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_c1); boolean b1 = rs.executeSql(sql, poolname_c1);
logger_336cd654.info("sql flag == "+b1);
} catch (Exception e) { } catch (Exception e) {
request.getRequestManager().setMessageid("error"); request.getRequestManager().setMessageid("error");
request.getRequestManager().setMessagecontent("SRM接口返回错误信息：" + e.toString()); request.getRequestManager().setMessagecontent("SRM接口返回错误信息：" + e.toString());
logger_336cd654.info(String.valueOf(requestId + "AddVenMatExtsToSrmAction-Request出错: " + e.toString())); logger_336cd654.info(String.valueOf(requestId + "AddVenMatExtsToSrmAction-Request出错: " + e.toString()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.getMessage() + "' where requestId=" + requestId; String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.getMessage() + "' where requestId=" + requestId;
logger_336cd654.info("sql == "+sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname); boolean b1 = rs.executeSql(sql, poolname);
logger_336cd654.info("sql err flag == "+b1);
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager())); return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager()));
} }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));

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

@ -159,13 +159,17 @@ public class BlackListTempThawCheckAction extends BaseBean implements Action, Es
public String getApplyCom(String id, String table) { public String getApplyCom(String id, String table) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "select lrhmddw from e10_core_business.dbo." + table + " where requestId=" + id; String sql = "select lrhmddw from e10_core_business.dbo." + table + " where requestId=" + id;
logger_454fb322.info("getApplyCom sql == " + sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname); boolean b1 = rs.executeSql(sql, poolname);
logger_454fb322.info("getApplyCom sql flag== " + b1);
String lrhmddw = ""; String lrhmddw = "";
if (rs.next()) { if (rs.next()) {
lrhmddw = Util.null2String(rs.getString("lrhmddw")); lrhmddw = Util.null2String(rs.getString("lrhmddw"));
} }
logger_454fb322.info("getApplyCom lrhmddw= " + lrhmddw);
return lrhmddw; return lrhmddw;
} }

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

@ -57,7 +57,10 @@ public class BuQianKaAction extends BaseBean implements Action, EsbServerlessRpc
String poolname = CONN_TYPE.hrm.getType(); String poolname = CONN_TYPE.hrm.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(createsqlString, poolname); boolean b11 = rs.executeSql(createsqlString, poolname);
logger_f1f35583.info(String.valueOf("createsqlString flag === " + b11));
rs.next(); rs.next();
String createrId = rs.getString("id"); String createrId = rs.getString("id");
Map<String, String> mainTableDataMap = new HashMap<String, String>(); Map<String, String> mainTableDataMap = new HashMap<String, String>();

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

@ -22,6 +22,9 @@ import com.weaver.verupgrade.hrm.resource.ResourceComInfo;
import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_ChangeOrgRoleAction") @org.springframework.stereotype.Service("workflow_action_ChangeOrgRoleAction")
public class ChangeOrgRoleAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class ChangeOrgRoleAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -38,57 +41,58 @@ public class ChangeOrgRoleAction extends BaseBean implements Action, EsbServerle
RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp); RequestInfo request = requestInfoTemp.getRequestInfo(requestIdTemp, userIdTemp);
try { try {
String requestid = request.getRequestid(); String requestid = request.getRequestid();
try { //TODO custom 不启用
logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限")); // try {
Property[] properties = request.getMainTableInfo().getProperty(); // logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限"));
Map<String, String> map = new HashMap<String, String>(); // Property[] properties = request.getMainTableInfo().getProperty();
for (int i = 0; i < properties.length; i++) { // Map<String, String> map = new HashMap<String, String>();
String name = properties[i].getName().toUpperCase(); // for (int i = 0; i < properties.length; i++) {
String value = Util.null2String(properties[i].getValue()); // String name = properties[i].getName().toUpperCase();
map.put(name, value); // String value = Util.null2String(properties[i].getValue());
} // map.put(name, value);
String org = ""; // }
String role = ""; // String org = "";
String sql = ""; // String role = "";
String resorceid = map.get("XJSYY"); // String sql = "";
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); // String resorceid = map.get("XJSYY");
if ("0".equals(map.get("ZZJGGG"))) { // RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
org = map.get("XTZGS"); // if ("0".equals(map.get("ZZJGGG"))) {
role = map.get("XTZFBJS"); // org = map.get("XTZGS");
role = role.substring(role.indexOf("_") + 1); // role = map.get("XTZFBJS");
sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org; // role = role.substring(role.indexOf("_") + 1);
String poolname_i8 = CONN_TYPE.workflow.getType(); // sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_i8 = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname_i8); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class); // rs.executeSql(sql, poolname_i8);
subCompanyComInfo.removeCompanyCache(); // SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class);
String poolname_v1 = CONN_TYPE.workflow.getType(); // subCompanyComInfo.removeCompanyCache();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_v1 = CONN_TYPE.workflow.getType();
rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
//TODO config // rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1);
// MatrixUtil.updateSubcompayData(org); // //TODO config
} else if ("1".equals(map.get("ZZJGGG"))) { //// MatrixUtil.updateSubcompayData(org);
org = map.get("XTZBM"); // } else if ("1".equals(map.get("ZZJGGG"))) {
role = map.get("XTZBMJS"); // org = map.get("XTZBM");
role = role.substring(role.indexOf("_") + 1); // role = map.get("XTZBMJS");
sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org; // role = role.substring(role.indexOf("_") + 1);
String poolname = CONN_TYPE.workflow.getType(); // sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class); // rs.executeSql(sql, poolname);
departmentComInfo.removeCompanyCache(); // DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class);
ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class); // departmentComInfo.removeCompanyCache();
ResourceComInfo.removeResourceCache(); // ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class);
String poolname_ou = CONN_TYPE.workflow.getType(); // ResourceComInfo.removeResourceCache();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_ou = CONN_TYPE.workflow.getType();
rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
//TODO config // rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou);
// MatrixUtil.updateDepartmentData(org); // //TODO config
} //// MatrixUtil.updateDepartmentData(org);
logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束")); // }
} catch (Exception e) { // logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束"));
logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString())); // } catch (Exception e) {
} // logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -27,6 +27,9 @@ import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.soa.workflow.request.Row; import com.weaver.verupgrade.soa.workflow.request.Row;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_CloseAccountAction") @org.springframework.stereotype.Service("workflow_action_CloseAccountAction")
public class CloseAccountAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class CloseAccountAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -59,91 +62,92 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles
String status = ""; String status = "";
String message = ""; String message = "";
String sql_error = ""; String sql_error = "";
try { //TODO custom 不启用
// 用户工号 // try {
String yhgh = ""; // // 用户工号
Property[] properties = request.getMainTableInfo().getProperty(); // String yhgh = "";
for (int i = 0; i < properties.length; i++) { // Property[] properties = request.getMainTableInfo().getProperty();
String name = properties[i].getName().toUpperCase(); // for (int i = 0; i < properties.length; i++) {
String value = Util.null2String(properties[i].getValue()); // String name = properties[i].getName().toUpperCase();
if (name.equals("YHGH")) { // String value = Util.null2String(properties[i].getValue());
yhgh = value; // if (name.equals("YHGH")) {
} // yhgh = value;
} // }
DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable(); // }
DetailTable dtq = detailtable[0]; // DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable();
Row[] sq = dtq.getRow(); // DetailTable dtq = detailtable[0];
SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length]; // Row[] sq = dtq.getRow();
SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo(); // SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length];
logger_ac56032a.info("sq -- "+ sq); // SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo();
for (int j = 0; j < sq.length; j++) { // logger_ac56032a.info("sq -- "+ sq);
Row rq = sq[j]; // for (int j = 0; j < sq.length; j++) {
Cell[] cq = rq.getCell(); // Row rq = sq[j];
paramInfo.setMail(""); // Cell[] cq = rq.getCell();
paramInfo.setOperation("disable"); // paramInfo.setMail("");
paramInfo.setUserid(yhgh); // paramInfo.setOperation("disable");
for (int k = 0; k < cq.length; k++) { // paramInfo.setUserid(yhgh);
Cell cq1 = cq[k]; // for (int k = 0; k < cq.length; k++) {
String nameq = cq1.getName().toUpperCase(); // Cell cq1 = cq[k];
String valueq = Util.null2String(cq1.getValue()); // String nameq = cq1.getName().toUpperCase();
if (nameq.equals("XTBH")) { // String valueq = Util.null2String(cq1.getValue());
paramInfo.setSystemid(valueq); // if (nameq.equals("XTBH")) {
} // paramInfo.setSystemid(valueq);
} // }
param[j] = paramInfo; // }
} // param[j] = paramInfo;
// AccountService service = new AccountService(); // }
logger_ac56032a.info("param--"+ param); //// AccountService service = new AccountService();
StringBuilder sb = new StringBuilder(); // logger_ac56032a.info("param--"+ param);
String[] array = service.account("HT01EIP006", param); // StringBuilder sb = new StringBuilder();
logger_ac56032a.info("array--"+ array); // String[] array = service.account("HT01EIP006", param);
if ("E".equals(array[0])) { // logger_ac56032a.info("array--"+ array);
status = array[0]; // if ("E".equals(array[0])) {
message = array[1]; // status = array[0];
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1])); // message = array[1];
} else { // logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1]));
JSONObject jsonObject = JSONObject.parseObject(array[1]); // } else {
JSONArray jsonArray = jsonObject.getJSONArray("returnMsg"); // JSONObject jsonObject = JSONObject.parseObject(array[1]);
for (int i = 0; i < jsonArray.size(); i++) { // JSONArray jsonArray = jsonObject.getJSONArray("returnMsg");
JSONObject jsonObjectone = jsonArray.getJSONObject(i); // for (int i = 0; i < jsonArray.size(); i++) {
String result = jsonObjectone.getString("result"); // JSONObject jsonObjectone = jsonArray.getJSONObject(i);
String systemid = jsonObjectone.getString("systemid"); // String result = jsonObjectone.getString("result");
String stat = jsonObjectone.getString("stat"); // String systemid = jsonObjectone.getString("systemid");
if ("0".equals(stat)) { // String stat = jsonObjectone.getString("stat");
sb.append(systemid + ":" + result + ";"); // if ("0".equals(stat)) {
} // sb.append(systemid + ":" + result + ";");
} // }
if (sb.length() > 0) { // }
status = "E"; // if (sb.length() > 0) {
message = sb.toString(); // status = "E";
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message)); // message = sb.toString();
} else { // logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message));
status = "S"; // } else {
message = "销户成功"; // status = "S";
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户成功")); // message = "销户成功";
} // logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户成功"));
} // }
sql_error = "update e10_core_business.dbo." + tablename + " set status='" + status + "',message='" + message + "' where requestId=" + requestId; // }
logger_ac56032a.info("sql_error -- " + sql_error); // sql_error = "update e10_core_business.dbo." + tablename + " set status='" + status + "',message='" + message + "' where requestId=" + requestId;
String poolname_1n = CONN_TYPE.workflow.getType(); // logger_ac56032a.info("sql_error -- " + sql_error);
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_1n = CONN_TYPE.workflow.getType();
rs.executeSql(sql_error, poolname_1n); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
if ("E".equals(status)) { // rs.executeSql(sql_error, poolname_1n);
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + message + "]")); // if ("E".equals(status)) {
request.getRequestManager().setMessageid("ERROR"); // logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + message + "]"));
request.getRequestManager().setMessagecontent("门户返回错误信息：" + message); // request.getRequestManager().setMessageid("ERROR");
} // request.getRequestManager().setMessagecontent("门户返回错误信息：" + message);
} catch (Exception e) { // }
sql_error = "update e10_core_business.dbo." + tablename + " set status='E',message='" + e.toString() + "' where requestId=" + requestId; // } catch (Exception e) {
logger_ac56032a.info("sql_error -- " + sql_error); // sql_error = "update e10_core_business.dbo." + tablename + " set status='E',message='" + e.toString() + "' where requestId=" + requestId;
String poolname = CONN_TYPE.workflow.getType(); // logger_ac56032a.info("sql_error -- " + sql_error);
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
rs.executeSql(sql_error, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
logger_ac56032a.info(String.valueOf(requestId + "批量销户失败：" + e.toString())); // rs.executeSql(sql_error, poolname);
request.getRequestManager().setMessageid("ERROR"); // logger_ac56032a.info(String.valueOf(requestId + "批量销户失败：" + e.toString()));
request.getRequestManager().setMessagecontent("门户返回错误信息：" + e.toString()); // request.getRequestManager().setMessageid("ERROR");
return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); // request.getRequestManager().setMessagecontent("门户返回错误信息：" + e.toString());
} // return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -28,6 +28,8 @@ import com.weaver.verupgrade.soa.workflow.request.*;
import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
//不启用
/** /**
* EAS007电子档案凭证号修改流程 * EAS007电子档案凭证号修改流程
* 接口账号密码 测试环境-都为空 正式环境：eas/qwerfdsa * 接口账号密码 测试环境-都为空 正式环境：eas/qwerfdsa
@ -65,94 +67,95 @@ public class EAS_VoucherModifyAction extends BaseBean implements Action, EsbServ
String USERNAME = "eas"; String USERNAME = "eas";
// 接口密码 // 接口密码
String PASSWORD = "qwerfdsa"; String PASSWORD = "qwerfdsa";
try { //TODO custom 不启用
ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class); // try {
BillFieldUtil unit = new BillFieldUtil(); // ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class);
Property[] properties = requestInfo.getMainTableInfo().getProperty(); // BillFieldUtil unit = new BillFieldUtil();
requestID = requestInfo.getRequestid(); // Property[] properties = requestInfo.getMainTableInfo().getProperty();
logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID)); // requestID = requestInfo.getRequestid();
String lastopertorid = requestInfo.getLastoperator(); // logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID));
Map<String, String> mMap = new HashMap<String, String>(); // String lastopertorid = requestInfo.getLastoperator();
for (int i = 0; i < properties.length; i++) { // Map<String, String> mMap = new HashMap<String, String>();
String name = properties[i].getName().toUpperCase(); // for (int i = 0; i < properties.length; i++) {
String value = Util.null2String(properties[i].getValue()); // String name = properties[i].getName().toUpperCase();
mMap.put(name, value); // String value = Util.null2String(properties[i].getValue());
} // mMap.put(name, value);
String boeNum = mMap.get("DJH"); // }
logger_57237c37.info(String.valueOf("报账单号：" + boeNum)); // String boeNum = mMap.get("DJH");
String kjqj = mMap.get("BGPZKJQJ"); // logger_57237c37.info(String.valueOf("报账单号：" + boeNum));
if (kjqj != null && !kjqj.equals("")) { // String kjqj = mMap.get("BGPZKJQJ");
kjqj = kjqj.replaceAll("-", ""); // if (kjqj != null && !kjqj.equals("")) {
} // kjqj = kjqj.replaceAll("-", "");
logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj)); // }
String sqrq = mMap.get("SQRQ"); // logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj));
if (sqrq != null && !sqrq.equals("")) { // String sqrq = mMap.get("SQRQ");
sqrq = sqrq.replaceAll("-", ""); // if (sqrq != null && !sqrq.equals("")) {
} // sqrq = sqrq.replaceAll("-", "");
logger_57237c37.info(String.valueOf("申请日期：" + sqrq)); // }
String sqr = mMap.get("SQR"); // logger_57237c37.info(String.valueOf("申请日期：" + sqrq));
String sqrcode = ""; // String sqr = mMap.get("SQR");
if (!sqr.equals("")) { // String sqrcode = "";
// 申请人工号 // if (!sqr.equals("")) {
sqrcode = unit.getWorkcode(sqr); // // 申请人工号
} // sqrcode = unit.getWorkcode(sqr);
logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode)); // }
String hsdwbm = mMap.get("HSDWDM"); // logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode));
logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm)); // String hsdwbm = mMap.get("HSDWDM");
String lcbh = mMap.get("LCBH"); // logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm));
logger_57237c37.info(String.valueOf("OA流程号：" + lcbh)); // String lcbh = mMap.get("LCBH");
String zt = mMap.get("ZT"); // logger_57237c37.info(String.valueOf("OA流程号：" + lcbh));
logger_57237c37.info(String.valueOf("主题：" + zt)); // String zt = mMap.get("ZT");
String bgqpzh = mMap.get("BGQPZH"); // logger_57237c37.info(String.valueOf("主题：" + zt));
logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh)); // String bgqpzh = mMap.get("BGQPZH");
String bghpzh = mMap.get("BGHPZH"); // logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh));
logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh)); // String bghpzh = mMap.get("BGHPZH");
SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO(); // logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh));
param.setITFID(ITFID); // SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO();
param.setSYSID(SYSID); // param.setITFID(ITFID);
param.setUSERNAME(USERNAME); // param.setSYSID(SYSID);
param.setPASSWORD(PASSWORD); // param.setUSERNAME(USERNAME);
// 保障单号 // param.setPASSWORD(PASSWORD);
param.setBoeNum(boeNum); // // 保障单号
// 会计期间 // param.setBoeNum(boeNum);
param.setAccPeriod(kjqj); // // 会计期间
// 申请日期 // param.setAccPeriod(kjqj);
param.setApplyDate(sqrq); // // 申请日期
// 申请人工号 // param.setApplyDate(sqrq);
param.setApplyEmployeeNo(sqrcode); // // 申请人工号
// 核算单位编码 // param.setApplyEmployeeNo(sqrcode);
param.setCompanyCode(hsdwbm); // // 核算单位编码
// oa流程号 // param.setCompanyCode(hsdwbm);
param.setFlowNoOA(lcbh); // // oa流程号
param.setRequestId(requestID); // param.setFlowNoOA(lcbh);
// 主题 // param.setRequestId(requestID);
param.setSubject(zt); // // 主题
// 新凭证号 // param.setSubject(zt);
param.setVoucherNoNew(bghpzh); // // 新凭证号
// 原凭证号 // param.setVoucherNoNew(bghpzh);
param.setVoucherNoOld(bgqpzh); // // 原凭证号
// 调用接口 // param.setVoucherNoOld(bgqpzh);
// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim(); // // 调用接口
String url = configProp.getUpdatevoucherurl(); //// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim();
logger_57237c37.info("url == " + url); // String url = configProp.getUpdatevoucherurl();
CallSieOAVoucherService service = new CallSieOAVoucherService(url); // logger_57237c37.info("url == " + url);
String[] result = service.syncVoucherInfo(param); // CallSieOAVoucherService service = new CallSieOAVoucherService(url);
logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result)); // String[] result = service.syncVoucherInfo(param);
if (!"S".equals(result[0])) { // logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result));
// 失败 // if (!"S".equals(result[0])) {
logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1])); // // 失败
requestInfo.getRequestManager().setMessageid("ERROR"); // logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1]));
requestInfo.getRequestManager().setMessagecontent("报账系统返回错误信息：" + result[1]); // requestInfo.getRequestManager().setMessageid("ERROR");
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); // requestInfo.getRequestManager().setMessagecontent("报账系统返回错误信息：" + result[1]);
} // return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
} catch (Exception e) { // }
logger_57237c37.info(String.valueOf("提交失败！")); // } catch (Exception e) {
logger_57237c37.info(String.valueOf("Error======" + e.getMessage())); // logger_57237c37.info(String.valueOf("提交失败！"));
requestInfo.getRequestManager().setMessageid("ERROR"); // logger_57237c37.info(String.valueOf("Error======" + e.getMessage()));
requestInfo.getRequestManager().setMessagecontent("提交失败！"); // requestInfo.getRequestManager().setMessageid("ERROR");
// return FAILURE_AND_CONTINUE; // requestInfo.getRequestManager().setMessagecontent("提交失败！");
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager())); // // return FAILURE_AND_CONTINUE;
} // return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestInfo.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestInfo.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -21,6 +21,9 @@ import com.weaver.verupgrade.soa.workflow.request.DetailTable;
import com.weaver.verupgrade.soa.workflow.request.Row; import com.weaver.verupgrade.soa.workflow.request.Row;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_UpdateSeclevelAndpasswordlock") @org.springframework.stereotype.Service("workflow_action_UpdateSeclevelAndpasswordlock")
public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -43,53 +46,54 @@ public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, E
DetailTable dtq = detailtable[0]; DetailTable dtq = detailtable[0];
Row[] sq = dtq.getRow(); Row[] sq = dtq.getRow();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
try { //TODO custom 不启用
for (int j = 0; j < sq.length; j++) { // try {
// 指定行 // for (int j = 0; j < sq.length; j++) {
Row rq = sq[j]; // // 指定行
// 每行数据再按列存储 // Row rq = sq[j];
Cell[] cq = rq.getCell(); // // 每行数据再按列存储
Map<String, String> map = new HashMap<String, String>(); // Cell[] cq = rq.getCell();
for (int k = 0; k < cq.length; k++) { // Map<String, String> map = new HashMap<String, String>();
// 指定列 // for (int k = 0; k < cq.length; k++) {
Cell cq1 = cq[k]; // // 指定列
// 明细字段名称 // Cell cq1 = cq[k];
String nameq = cq1.getName().toLowerCase(); // // 明细字段名称
String valueq = Util.null2String(cq1.getValue()); // String nameq = cq1.getName().toLowerCase();
map.put(nameq, valueq); // String valueq = Util.null2String(cq1.getValue());
} // map.put(nameq, valueq);
if (map.get("xglx").equals("0")) { // }
String userid = map.get("xgyhxm"); // if (map.get("xglx").equals("0")) {
String seclevel = map.get("xaqjb"); // String userid = map.get("xgyhxm");
String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid; // String seclevel = map.get("xaqjb");
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); // String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid;
String poolname = CONN_TYPE.workflow.getType(); // logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
} // rs.executeSql(sql, poolname);
if (map.get("xglx").equals("1")) { // }
String userid = map.get("xgyhxm"); // if (map.get("xglx").equals("1")) {
String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid; // String userid = map.get("xgyhxm");
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); // String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid;
String poolname_ow = CONN_TYPE.workflow.getType(); // logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_ow = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname_ow); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
} // rs.executeSql(sql, poolname_ow);
if (map.get("xglx").equals("2")) { // }
String userid = map.get("xgyhxm"); // if (map.get("xglx").equals("2")) {
String seclevel = map.get("xaqjb"); // String userid = map.get("xgyhxm");
String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid; // String seclevel = map.get("xaqjb");
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql)); // String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid;
String poolname_fw = CONN_TYPE.workflow.getType(); // logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_fw = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname_fw); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
} // rs.executeSql(sql, poolname_fw);
} // }
logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束")); // }
} catch (Exception e) { // logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束"));
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁出错：" + e.toString())); // } catch (Exception e) {
return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager())); // logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁出错：" + e.toString()));
} // return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -24,6 +24,8 @@ import com.weaver.verupgrade.general.Util;
import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
// 不启用
@org.springframework.stereotype.Service("workflow_action_ZOA_PRICE_RFCAction") @org.springframework.stereotype.Service("workflow_action_ZOA_PRICE_RFCAction")
public class ZOA_PRICE_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class ZOA_PRICE_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -57,50 +59,51 @@ public class ZOA_PRICE_RFCAction extends BaseBean implements Action, EsbServerle
String tablename = requestinfo.getRequestManager().getBillTableName(); String tablename = requestinfo.getRequestManager().getBillTableName();
String requestId = requestinfo.getRequestid(); String requestId = requestinfo.getRequestid();
retstr = new String[2]; retstr = new String[2];
try { //TODO custom 不启用
String sapId = ""; // try {
Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); // String sapId = "";
for (int i = 0; i < aproperty.length; i++) { // Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
String name = aproperty[i].getName().toUpperCase(); // for (int i = 0; i < aproperty.length; i++) {
String value = Util.null2String(aproperty[i].getValue()); // String name = aproperty[i].getName().toUpperCase();
if (name.equals("BH")) { // String value = Util.null2String(aproperty[i].getValue());
sapId = value; // if (name.equals("BH")) {
} // sapId = value;
} // }
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); // }
recordsettrans.setAutoCommit(false); // RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC"); // recordsettrans.setAutoCommit(false);
if (jcofunction == null) { // JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC");
logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP.")); // if (jcofunction == null) {
retstr[0] = "E"; // logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP."));
retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数"; // retstr[0] = "E";
} else { // retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数";
jcofunction.getImportParameterList().setValue("ID", sapId); // } else {
logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数")); // jcofunction.getImportParameterList().setValue("ID", sapId);
jcofunction.execute(destination); // logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数"));
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); // jcofunction.execute(destination);
retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); // retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC函数成功：" + retstr[0] + "," + retstr[1])); // retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString();
} // logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC函数成功：" + retstr[0] + "," + retstr[1]));
String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; // }
String poolname_sg = CONN_TYPE.workflow.getType(); // String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_sg = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname_sg); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
if (!"S".equals(retstr[0])) { // rs.executeSql(sql, poolname_sg);
requestinfo.getRequestManager().setMessageid("ERROR"); // if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessagecontent("SAP返回的错误信息：" + retstr[1]); // requestinfo.getRequestManager().setMessageid("ERROR");
return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", retstr[1], requestinfo.getRequestManager())); // requestinfo.getRequestManager().setMessagecontent("SAP返回的错误信息：" + retstr[1]);
} // return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", retstr[1], requestinfo.getRequestManager()));
} catch (Exception e) { // }
logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC查询价格是否发布出错：" + e.toString())); // } catch (Exception e) {
requestinfo.getRequestManager().setMessageid("ERROR"); // logger_489475fd.info(String.valueOf("调用ZOA_PRICE_RFC查询价格是否发布出错：" + e.toString()));
requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage()); // requestinfo.getRequestManager().setMessageid("ERROR");
String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId; // requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage());
String poolname = CONN_TYPE.workflow.getType(); // String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager())); // rs.executeSql(sql, poolname);
} // return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -23,6 +23,9 @@ import com.weaver.verupgrade.general.Util;
import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_ZOA_SIGN_RFCAction") @org.springframework.stereotype.Service("workflow_action_ZOA_SIGN_RFCAction")
public class ZOA_SIGN_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class ZOA_SIGN_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -55,50 +58,51 @@ public class ZOA_SIGN_RFCAction extends BaseBean implements Action, EsbServerles
String requestid = requestinfo.getRequestid(); String requestid = requestinfo.getRequestid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
retstr = new String[2]; retstr = new String[2];
try { //TODO custom 不启用
String sapId = ""; // try {
Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); // String sapId = "";
for (int i = 0; i < aproperty.length; i++) { // Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
String name = aproperty[i].getName().toUpperCase(); // for (int i = 0; i < aproperty.length; i++) {
String value = Util.null2String(aproperty[i].getValue()); // String name = aproperty[i].getName().toUpperCase();
if (name.equals("BH")) { // String value = Util.null2String(aproperty[i].getValue());
sapId = value; // if (name.equals("BH")) {
} // sapId = value;
} // }
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); // }
recordsettrans.setAutoCommit(false); // RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC"); // recordsettrans.setAutoCommit(false);
if (jcofunction == null) { // JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC");
logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP.")); // if (jcofunction == null) {
retstr[0] = "E"; // logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP."));
retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数"; // retstr[0] = "E";
} else { // retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数";
jcofunction.getImportParameterList().setValue("ID", sapId); // } else {
logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数")); // jcofunction.getImportParameterList().setValue("ID", sapId);
jcofunction.execute(destination); // logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数"));
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); // jcofunction.execute(destination);
retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); // retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC函数成功：" + retstr[0] + "," + retstr[1])); // retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString();
} // logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC函数成功：" + retstr[0] + "," + retstr[1]));
String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; // }
String poolname_pq = CONN_TYPE.workflow.getType(); // String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_pq = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname_pq); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
if (!"S".equals(retstr[0])) { // rs.executeSql(sql, poolname_pq);
requestinfo.getRequestManager().setMessageid("ERROR"); // if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]); // requestinfo.getRequestManager().setMessageid("ERROR");
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); // requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]);
} // return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) { // }
logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC解冻出错：" + e.toString())); // } catch (Exception e) {
requestinfo.getRequestManager().setMessageid("ERROR"); // logger_43f5aff5.info(String.valueOf("调用ZOA_SIGN_RFC解冻出错：" + e.toString()));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage()); // requestinfo.getRequestManager().setMessageid("ERROR");
String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid; // requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage());
String poolname = CONN_TYPE.workflow.getType(); // String sql = "update " + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where requestId =" + requestid;
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
rs.executeSql(sql, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); // rs.executeSql(sql, poolname);
} // return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -542,7 +542,6 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
boolean b1 = rs.executeSql(sql3, poolname_ym); boolean b1 = rs.executeSql(sql3, poolname_ym);
logger_f5224b91.info("sql3 = " + sql3); logger_f5224b91.info("sql3 = " + sql3);
logger_f5224b91.info("添加 = " + b1); logger_f5224b91.info("添加 = " + b1);
logger_f5224b91.info("b -----"+ b1);
if (applyEmpNum.length() < 10) { if (applyEmpNum.length() < 10) {
// 经办人工号 // 经办人工号
applyEmpNum = errandEmpNum; applyEmpNum = errandEmpNum;

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

@ -23,6 +23,9 @@ import com.weaver.verupgrade.general.Util;
import com.weaver.verupgrade.soa.workflow.request.Property; import com.weaver.verupgrade.soa.workflow.request.Property;
import com.weaver.verupgrade.interfaces.workflow.action.Action; import com.weaver.verupgrade.interfaces.workflow.action.Action;
@org.springframework.stereotype.Service("workflow_action_ZOA_STATUS_RFCAction") @org.springframework.stereotype.Service("workflow_action_ZOA_STATUS_RFCAction")
public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface { public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -60,54 +63,55 @@ public class ZOA_STATUS_RFCAction extends BaseBean implements Action, EsbServerl
String requestid = requestinfo.getRequestid(); String requestid = requestinfo.getRequestid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class); RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
retstr = new String[2]; retstr = new String[2];
try { //TODO custom 不启用
String sapId = ""; // try {
Property[] aproperty = requestinfo.getMainTableInfo().getProperty(); // String sapId = "";
for (int i = 0; i < aproperty.length; i++) { // Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
String name = aproperty[i].getName().toUpperCase(); // for (int i = 0; i < aproperty.length; i++) {
String value = Util.null2String(aproperty[i].getValue()); // String name = aproperty[i].getName().toUpperCase();
if (name.equals("BH")) { // String value = Util.null2String(aproperty[i].getValue());
sapId = value; // if (name.equals("BH")) {
} // sapId = value;
} // }
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class); // }
recordsettrans.setAutoCommit(false); // RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC"); // recordsettrans.setAutoCommit(false);
if (jcofunction == null) { // JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC");
logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP.")); // if (jcofunction == null) {
retstr[0] = "E"; // logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP."));
retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数"; // retstr[0] = "E";
} else { // retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数";
jcofunction.getImportParameterList().setValue("ID", sapId); // } else {
logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数")); // jcofunction.getImportParameterList().setValue("ID", sapId);
jcofunction.execute(destination); // logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数"));
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString(); // jcofunction.execute(destination);
retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString(); // retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功：" + retstr[0] + "," + retstr[1])); // retstr[1] = jcofunction.getExportParameterList().getValue("E_MESSAGE").toString();
} // logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC函数成功：" + retstr[0] + "," + retstr[1]));
String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; // }
logger_2bfe536a.info("sql -----"+ sql); // String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid;
String poolname_vx = CONN_TYPE.workflow.getType(); // logger_2bfe536a.info("sql -----"+ sql);
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname_vx = CONN_TYPE.workflow.getType();
boolean b = rs.executeSql(sql, poolname_vx); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
logger_2bfe536a.info("b -----"+ b); // boolean b = rs.executeSql(sql, poolname_vx);
if (!"S".equals(retstr[0])) { // logger_2bfe536a.info("b -----"+ b);
requestinfo.getRequestManager().setMessageid("ERROR"); // if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]); // requestinfo.getRequestManager().setMessageid("ERROR");
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); // requestinfo.getRequestManager().setMessagecontent("SAP返回错误信息：" + retstr[1]);
} // return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) { // }
logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString())); // } catch (Exception e) {
requestinfo.getRequestManager().setMessageid("ERROR"); // logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString()));
requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage()); // requestinfo.getRequestManager().setMessageid("ERROR");
String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid; // requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage());
logger_2bfe536a.info("sql2 -----"+ sql); // String sql = "update e10_core_business.dbo." + tablename + " set status= '" + retstr[0] + "',message= cast(message as varchar(8000)) +'," + retstr[1] + "' where id =" + requestid;
String poolname = CONN_TYPE.workflow.getType(); // logger_2bfe536a.info("sql2 -----"+ sql);
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // String poolname = CONN_TYPE.workflow.getType();
boolean b = rs.executeSql(sql, poolname); // // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
logger_2bfe536a.info("b2 -----"+ b); // boolean b = rs.executeSql(sql, poolname);
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager())); // 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())); return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

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

@ -71,7 +71,8 @@ public class ZSR_PUR_INFO_OEM_Action extends BaseBean implements Action, EsbServ
logger_adc1e038.info("sql -----"+ sql); logger_adc1e038.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType(); String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源 // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname); boolean b1 = rs.executeSql(sql, poolname);
logger_adc1e038.info("sql flag1-----"+ b1);
if (rs.next()) { if (rs.next()) {
mxcount = rs.getInt("mxcount"); mxcount = rs.getInt("mxcount");
logger_adc1e038.info("mxcount -----"+ mxcount); logger_adc1e038.info("mxcount -----"+ mxcount);

Write Preview
Loading…
Cancel
Save