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

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

Browse Source
webservice
calyrex 5 months ago
parent 87765edf4f 9406ca688c
commit c23e24d46f
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 poolname = CONN_TYPE.ebuilder.getType();
// 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()) {
currencyCode = rs.getString("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();
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();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_c1);
boolean b1 = rs.executeSql(sql, poolname_c1);
logger_336cd654.info("sql flag == "+b1);
} catch (Exception e) {
request.getRequestManager().setMessageid("error");
request.getRequestManager().setMessagecontent("SRM接口返回错误信息：" + e.toString());
logger_336cd654.info(String.valueOf(requestId + "AddVenMatExtsToSrmAction-Request出错: " + e.toString()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
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();
// 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.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) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
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();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
boolean b1 = rs.executeSql(sql, poolname);
logger_454fb322.info("getApplyCom sql flag== " + b1);
String lrhmddw = "";
if (rs.next()) {
lrhmddw = Util.null2String(rs.getString("lrhmddw"));
}
logger_454fb322.info("getApplyCom lrhmddw= " + 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();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(createsqlString, poolname);
boolean b11 = rs.executeSql(createsqlString, poolname);
logger_f1f35583.info(String.valueOf("createsqlString flag === " + b11));
rs.next();
String createrId = rs.getString("id");
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.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_ChangeOrgRoleAction")
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);
try {
String requestid = request.getRequestid();
try {
logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限"));
Property[] properties = request.getMainTableInfo().getProperty();
Map<String, String> map = new HashMap<String, String>();
for (int i = 0; i < properties.length; i++) {
String name = properties[i].getName().toUpperCase();
String value = Util.null2String(properties[i].getValue());
map.put(name, value);
}
String org = "";
String role = "";
String sql = "";
String resorceid = map.get("XJSYY");
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
if ("0".equals(map.get("ZZJGGG"))) {
org = map.get("XTZGS");
role = map.get("XTZFBJS");
role = role.substring(role.indexOf("_") + 1);
sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org;
String poolname_i8 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_i8);
SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class);
subCompanyComInfo.removeCompanyCache();
String poolname_v1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1);
//TODO config
// MatrixUtil.updateSubcompayData(org);
} else if ("1".equals(map.get("ZZJGGG"))) {
org = map.get("XTZBM");
role = map.get("XTZBMJS");
role = role.substring(role.indexOf("_") + 1);
sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class);
departmentComInfo.removeCompanyCache();
ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class);
ResourceComInfo.removeResourceCache();
String poolname_ou = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou);
//TODO config
// MatrixUtil.updateDepartmentData(org);
}
logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束"));
} catch (Exception e) {
logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString()));
}
//TODO custom 不启用
// try {
// logger_c08ea2e1.info(String.valueOf(requestid + "开始修改组织架构权限"));
// Property[] properties = request.getMainTableInfo().getProperty();
// Map<String, String> map = new HashMap<String, String>();
// for (int i = 0; i < properties.length; i++) {
// String name = properties[i].getName().toUpperCase();
// String value = Util.null2String(properties[i].getValue());
// map.put(name, value);
// }
// String org = "";
// String role = "";
// String sql = "";
// String resorceid = map.get("XJSYY");
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// if ("0".equals(map.get("ZZJGGG"))) {
// org = map.get("XTZGS");
// role = map.get("XTZFBJS");
// role = role.substring(role.indexOf("_") + 1);
// sql = "update formdata_detail as HrmSubcompanyDefined set " + role + "='" + resorceid + "' where subcomid=" + org;
// String poolname_i8 = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_i8);
// SubCompanyComInfo subCompanyComInfo = I18nContextUtil.getBean(SubCompanyComInfo.class);
// subCompanyComInfo.removeCompanyCache();
// String poolname_v1 = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_v1);
// //TODO config
//// MatrixUtil.updateSubcompayData(org);
// } else if ("1".equals(map.get("ZZJGGG"))) {
// org = map.get("XTZBM");
// role = map.get("XTZBMJS");
// role = role.substring(role.indexOf("_") + 1);
// sql = "update HrmDepartmentDefined set " + role + "='" + resorceid + "' where deptid=" + org;
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname);
// DepartmentComInfo departmentComInfo = I18nContextUtil.getBean(DepartmentComInfo.class);
// departmentComInfo.removeCompanyCache();
// ResourceComInfo ResourceComInfo = I18nContextUtil.getBean(ResourceComInfo.class);
// ResourceComInfo.removeResourceCache();
// String poolname_ou = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql("UPDATE orgchartstate SET orgchartstate.needupdate = 1 WHERE orgchartstate.delete_type = 0 AND orgchartstate.tenant_key = 't6kj9c07jr'", poolname_ou);
// //TODO config
//// MatrixUtil.updateDepartmentData(org);
// }
// logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限结束"));
// } catch (Exception e) {
// logger_c08ea2e1.info(String.valueOf(requestid + "修改组织架构权限出错：" + e.toString()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) {
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.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_CloseAccountAction")
public class CloseAccountAction extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -59,91 +62,92 @@ public class CloseAccountAction extends BaseBean implements Action, EsbServerles
String status = "";
String message = "";
String sql_error = "";
try {
// 用户工号
String yhgh = "";
Property[] properties = request.getMainTableInfo().getProperty();
for (int i = 0; i < properties.length; i++) {
String name = properties[i].getName().toUpperCase();
String value = Util.null2String(properties[i].getValue());
if (name.equals("YHGH")) {
yhgh = value;
}
}
DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable();
DetailTable dtq = detailtable[0];
Row[] sq = dtq.getRow();
SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length];
SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo();
logger_ac56032a.info("sq -- "+ sq);
for (int j = 0; j < sq.length; j++) {
Row rq = sq[j];
Cell[] cq = rq.getCell();
paramInfo.setMail("");
paramInfo.setOperation("disable");
paramInfo.setUserid(yhgh);
for (int k = 0; k < cq.length; k++) {
Cell cq1 = cq[k];
String nameq = cq1.getName().toUpperCase();
String valueq = Util.null2String(cq1.getValue());
if (nameq.equals("XTBH")) {
paramInfo.setSystemid(valueq);
}
}
param[j] = paramInfo;
}
// AccountService service = new AccountService();
logger_ac56032a.info("param--"+ param);
StringBuilder sb = new StringBuilder();
String[] array = service.account("HT01EIP006", param);
logger_ac56032a.info("array--"+ array);
if ("E".equals(array[0])) {
status = array[0];
message = array[1];
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1]));
} else {
JSONObject jsonObject = JSONObject.parseObject(array[1]);
JSONArray jsonArray = jsonObject.getJSONArray("returnMsg");
for (int i = 0; i < jsonArray.size(); i++) {
JSONObject jsonObjectone = jsonArray.getJSONObject(i);
String result = jsonObjectone.getString("result");
String systemid = jsonObjectone.getString("systemid");
String stat = jsonObjectone.getString("stat");
if ("0".equals(stat)) {
sb.append(systemid + ":" + result + ";");
}
}
if (sb.length() > 0) {
status = "E";
message = sb.toString();
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message));
} else {
status = "S";
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);
String poolname_1n = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql_error, poolname_1n);
if ("E".equals(status)) {
logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + 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;
logger_ac56032a.info("sql_error -- " + sql_error);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql_error, poolname);
logger_ac56032a.info(String.valueOf(requestId + "批量销户失败：" + e.toString()));
request.getRequestManager().setMessageid("ERROR");
request.getRequestManager().setMessagecontent("门户返回错误信息：" + e.toString());
return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager()));
}
//TODO custom 不启用
// try {
// // 用户工号
// String yhgh = "";
// Property[] properties = request.getMainTableInfo().getProperty();
// for (int i = 0; i < properties.length; i++) {
// String name = properties[i].getName().toUpperCase();
// String value = Util.null2String(properties[i].getValue());
// if (name.equals("YHGH")) {
// yhgh = value;
// }
// }
// DetailTable[] detailtable = request.getDetailTableInfo().getDetailTable();
// DetailTable dtq = detailtable[0];
// Row[] sq = dtq.getRow();
// SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[] param = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo[sq.length];
// SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo paramInfo = new SI_HTPortalUAMGMT2_OUTServiceStub.UserSyncInfo();
// logger_ac56032a.info("sq -- "+ sq);
// for (int j = 0; j < sq.length; j++) {
// Row rq = sq[j];
// Cell[] cq = rq.getCell();
// paramInfo.setMail("");
// paramInfo.setOperation("disable");
// paramInfo.setUserid(yhgh);
// for (int k = 0; k < cq.length; k++) {
// Cell cq1 = cq[k];
// String nameq = cq1.getName().toUpperCase();
// String valueq = Util.null2String(cq1.getValue());
// if (nameq.equals("XTBH")) {
// paramInfo.setSystemid(valueq);
// }
// }
// param[j] = paramInfo;
// }
//// AccountService service = new AccountService();
// logger_ac56032a.info("param--"+ param);
// StringBuilder sb = new StringBuilder();
// String[] array = service.account("HT01EIP006", param);
// logger_ac56032a.info("array--"+ array);
// if ("E".equals(array[0])) {
// status = array[0];
// message = array[1];
// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "调用批量销户接口出错：" + array[1]));
// } else {
// JSONObject jsonObject = JSONObject.parseObject(array[1]);
// JSONArray jsonArray = jsonObject.getJSONArray("returnMsg");
// for (int i = 0; i < jsonArray.size(); i++) {
// JSONObject jsonObjectone = jsonArray.getJSONObject(i);
// String result = jsonObjectone.getString("result");
// String systemid = jsonObjectone.getString("systemid");
// String stat = jsonObjectone.getString("stat");
// if ("0".equals(stat)) {
// sb.append(systemid + ":" + result + ";");
// }
// }
// if (sb.length() > 0) {
// status = "E";
// message = sb.toString();
// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户失败" + message));
// } else {
// status = "S";
// 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);
// String poolname_1n = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql_error, poolname_1n);
// if ("E".equals(status)) {
// logger_ac56032a.info(String.valueOf(requestId + "---" + yhgh + "批量销户[" + 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;
// logger_ac56032a.info("sql_error -- " + sql_error);
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql_error, poolname);
// logger_ac56032a.info(String.valueOf(requestId + "批量销户失败：" + e.toString()));
// request.getRequestManager().setMessageid("ERROR");
// request.getRequestManager().setMessagecontent("门户返回错误信息：" + e.toString());
// return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, request.getRequestManager()));
} catch (Exception e) {
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.interfaces.workflow.action.Action;
//不启用
/**
* EAS007电子档案凭证号修改流程
* 接口账号密码 测试环境-都为空 正式环境：eas/qwerfdsa
@ -65,94 +67,95 @@ public class EAS_VoucherModifyAction extends BaseBean implements Action, EsbServ
String USERNAME = "eas";
// 接口密码
String PASSWORD = "qwerfdsa";
try {
ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class);
BillFieldUtil unit = new BillFieldUtil();
Property[] properties = requestInfo.getMainTableInfo().getProperty();
requestID = requestInfo.getRequestid();
logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID));
String lastopertorid = requestInfo.getLastoperator();
Map<String, String> mMap = new HashMap<String, String>();
for (int i = 0; i < properties.length; i++) {
String name = properties[i].getName().toUpperCase();
String value = Util.null2String(properties[i].getValue());
mMap.put(name, value);
}
String boeNum = mMap.get("DJH");
logger_57237c37.info(String.valueOf("报账单号：" + boeNum));
String kjqj = mMap.get("BGPZKJQJ");
if (kjqj != null && !kjqj.equals("")) {
kjqj = kjqj.replaceAll("-", "");
}
logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj));
String sqrq = mMap.get("SQRQ");
if (sqrq != null && !sqrq.equals("")) {
sqrq = sqrq.replaceAll("-", "");
}
logger_57237c37.info(String.valueOf("申请日期：" + sqrq));
String sqr = mMap.get("SQR");
String sqrcode = "";
if (!sqr.equals("")) {
// 申请人工号
sqrcode = unit.getWorkcode(sqr);
}
logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode));
String hsdwbm = mMap.get("HSDWDM");
logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm));
String lcbh = mMap.get("LCBH");
logger_57237c37.info(String.valueOf("OA流程号：" + lcbh));
String zt = mMap.get("ZT");
logger_57237c37.info(String.valueOf("主题：" + zt));
String bgqpzh = mMap.get("BGQPZH");
logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh));
String bghpzh = mMap.get("BGHPZH");
logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh));
SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO();
param.setITFID(ITFID);
param.setSYSID(SYSID);
param.setUSERNAME(USERNAME);
param.setPASSWORD(PASSWORD);
// 保障单号
param.setBoeNum(boeNum);
// 会计期间
param.setAccPeriod(kjqj);
// 申请日期
param.setApplyDate(sqrq);
// 申请人工号
param.setApplyEmployeeNo(sqrcode);
// 核算单位编码
param.setCompanyCode(hsdwbm);
// oa流程号
param.setFlowNoOA(lcbh);
param.setRequestId(requestID);
// 主题
param.setSubject(zt);
// 新凭证号
param.setVoucherNoNew(bghpzh);
// 原凭证号
param.setVoucherNoOld(bgqpzh);
// 调用接口
// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim();
String url = configProp.getUpdatevoucherurl();
logger_57237c37.info("url == " + url);
CallSieOAVoucherService service = new CallSieOAVoucherService(url);
String[] result = service.syncVoucherInfo(param);
logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result));
if (!"S".equals(result[0])) {
// 失败
logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1]));
requestInfo.getRequestManager().setMessageid("ERROR");
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("提交失败！"));
logger_57237c37.info(String.valueOf("Error======" + e.getMessage()));
requestInfo.getRequestManager().setMessageid("ERROR");
requestInfo.getRequestManager().setMessagecontent("提交失败！");
// return FAILURE_AND_CONTINUE;
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, requestInfo.getRequestManager()));
}
//TODO custom 不启用
// try {
// ResourceComInfo hr = I18nContextUtil.getBean(ResourceComInfo.class);
// BillFieldUtil unit = new BillFieldUtil();
// Property[] properties = requestInfo.getMainTableInfo().getProperty();
// requestID = requestInfo.getRequestid();
// logger_57237c37.info(String.valueOf("EAS_VoucherModifyAction--start--" + requestID));
// String lastopertorid = requestInfo.getLastoperator();
// Map<String, String> mMap = new HashMap<String, String>();
// for (int i = 0; i < properties.length; i++) {
// String name = properties[i].getName().toUpperCase();
// String value = Util.null2String(properties[i].getValue());
// mMap.put(name, value);
// }
// String boeNum = mMap.get("DJH");
// logger_57237c37.info(String.valueOf("报账单号：" + boeNum));
// String kjqj = mMap.get("BGPZKJQJ");
// if (kjqj != null && !kjqj.equals("")) {
// kjqj = kjqj.replaceAll("-", "");
// }
// logger_57237c37.info(String.valueOf("凭证变更会计期间：" + kjqj));
// String sqrq = mMap.get("SQRQ");
// if (sqrq != null && !sqrq.equals("")) {
// sqrq = sqrq.replaceAll("-", "");
// }
// logger_57237c37.info(String.valueOf("申请日期：" + sqrq));
// String sqr = mMap.get("SQR");
// String sqrcode = "";
// if (!sqr.equals("")) {
// // 申请人工号
// sqrcode = unit.getWorkcode(sqr);
// }
// logger_57237c37.info(String.valueOf("申请人工号：" + sqrcode));
// String hsdwbm = mMap.get("HSDWDM");
// logger_57237c37.info(String.valueOf("核算单位编码：" + hsdwbm));
// String lcbh = mMap.get("LCBH");
// logger_57237c37.info(String.valueOf("OA流程号：" + lcbh));
// String zt = mMap.get("ZT");
// logger_57237c37.info(String.valueOf("主题：" + zt));
// String bgqpzh = mMap.get("BGQPZH");
// logger_57237c37.info(String.valueOf("变更前凭证号：" + bgqpzh));
// String bghpzh = mMap.get("BGHPZH");
// logger_57237c37.info(String.valueOf("变更后凭证号：" + bghpzh));
// SieOaVoucherServiceStub.SieOaVoucherDO param = new SieOaVoucherServiceStub.SieOaVoucherDO();
// param.setITFID(ITFID);
// param.setSYSID(SYSID);
// param.setUSERNAME(USERNAME);
// param.setPASSWORD(PASSWORD);
// // 保障单号
// param.setBoeNum(boeNum);
// // 会计期间
// param.setAccPeriod(kjqj);
// // 申请日期
// param.setApplyDate(sqrq);
// // 申请人工号
// param.setApplyEmployeeNo(sqrcode);
// // 核算单位编码
// param.setCompanyCode(hsdwbm);
// // oa流程号
// param.setFlowNoOA(lcbh);
// param.setRequestId(requestID);
// // 主题
// param.setSubject(zt);
// // 新凭证号
// param.setVoucherNoNew(bghpzh);
// // 原凭证号
// param.setVoucherNoOld(bgqpzh);
// // 调用接口
//// String url = Util.null2String(I18nContextUtilcus.getBean(Environment.class).getProperty("hteasoasync.updatevoucherurl")).trim();
// String url = configProp.getUpdatevoucherurl();
// logger_57237c37.info("url == " + url);
// CallSieOAVoucherService service = new CallSieOAVoucherService(url);
// String[] result = service.syncVoucherInfo(param);
// logger_57237c37.info(String.valueOf("调用借阅审批回调接口返回值：" + result));
// if (!"S".equals(result[0])) {
// // 失败
// logger_57237c37.info(String.valueOf("报账系统返回错误信息：" + result[1]));
// requestInfo.getRequestManager().setMessageid("ERROR");
// 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("提交失败！"));
// logger_57237c37.info(String.valueOf("Error======" + e.getMessage()));
// requestInfo.getRequestManager().setMessageid("ERROR");
// requestInfo.getRequestManager().setMessagecontent("提交失败！");
// // 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()));
} catch (Exception e) {
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.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_UpdateSeclevelAndpasswordlock")
public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, EsbServerlessRpcRemoteInterface {
@ -43,53 +46,54 @@ public class UpdateSeclevelAndpasswordlock extends BaseBean implements Action, E
DetailTable dtq = detailtable[0];
Row[] sq = dtq.getRow();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
try {
for (int j = 0; j < sq.length; j++) {
// 指定行
Row rq = sq[j];
// 每行数据再按列存储
Cell[] cq = rq.getCell();
Map<String, String> map = new HashMap<String, String>();
for (int k = 0; k < cq.length; k++) {
// 指定列
Cell cq1 = cq[k];
// 明细字段名称
String nameq = cq1.getName().toLowerCase();
String valueq = Util.null2String(cq1.getValue());
map.put(nameq, valueq);
}
if (map.get("xglx").equals("0")) {
String userid = map.get("xgyhxm");
String seclevel = map.get("xaqjb");
String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid;
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
}
if (map.get("xglx").equals("1")) {
String userid = map.get("xgyhxm");
String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid;
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
String poolname_ow = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_ow);
}
if (map.get("xglx").equals("2")) {
String userid = map.get("xgyhxm");
String seclevel = map.get("xaqjb");
String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid;
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
String poolname_fw = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_fw);
}
}
logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束"));
} catch (Exception e) {
logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁出错：" + e.toString()));
return WeaResult.fail(500, "出错啦", getResultMapForAction(weaverResultMap, "result", "", request.getRequestManager()));
}
//TODO custom 不启用
// try {
// for (int j = 0; j < sq.length; j++) {
// // 指定行
// Row rq = sq[j];
// // 每行数据再按列存储
// Cell[] cq = rq.getCell();
// Map<String, String> map = new HashMap<String, String>();
// for (int k = 0; k < cq.length; k++) {
// // 指定列
// Cell cq1 = cq[k];
// // 明细字段名称
// String nameq = cq1.getName().toLowerCase();
// String valueq = Util.null2String(cq1.getValue());
// map.put(nameq, valueq);
// }
// if (map.get("xglx").equals("0")) {
// String userid = map.get("xgyhxm");
// String seclevel = map.get("xaqjb");
// String sql = "update eteams.dbo.employee as hrmresource set seclevel=" + seclevel + " where id=" + userid;
// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname);
// }
// if (map.get("xglx").equals("1")) {
// String userid = map.get("xgyhxm");
// String sql = "update employee as hrmresource set passwordlock=0 where id=" + userid;
// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// String poolname_ow = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_ow);
// }
// if (map.get("xglx").equals("2")) {
// String userid = map.get("xgyhxm");
// String seclevel = map.get("xaqjb");
// String sql = "update eteams.dbo.employee as hrmresource set passwordlock=0,seclevel=" + seclevel + " where id=" + userid;
// logger_54eacf62.info(String.valueOf("修改安全级别和密码解锁sql:" + sql));
// String poolname_fw = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_fw);
// }
// }
// logger_54eacf62.info(String.valueOf(requestid + "修改安全级别和密码解锁结束"));
// } catch (Exception e) {
// 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()));
} catch (Exception e) {
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.interfaces.workflow.action.Action;
// 不启用
@org.springframework.stereotype.Service("workflow_action_ZOA_PRICE_RFCAction")
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 requestId = requestinfo.getRequestid();
retstr = new String[2];
try {
String sapId = "";
Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
for (int i = 0; i < aproperty.length; i++) {
String name = aproperty[i].getName().toUpperCase();
String value = Util.null2String(aproperty[i].getValue());
if (name.equals("BH")) {
sapId = value;
}
}
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
recordsettrans.setAutoCommit(false);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC");
if (jcofunction == null) {
logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP."));
retstr[0] = "E";
retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数";
} else {
jcofunction.getImportParameterList().setValue("ID", sapId);
logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数"));
jcofunction.execute(destination);
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
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();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_sg);
if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessageid("ERROR");
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()));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage());
String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
return WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestinfo.getRequestManager()));
}
//TODO custom 不启用
// try {
// String sapId = "";
// Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
// for (int i = 0; i < aproperty.length; i++) {
// String name = aproperty[i].getName().toUpperCase();
// String value = Util.null2String(aproperty[i].getValue());
// if (name.equals("BH")) {
// sapId = value;
// }
// }
// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
// recordsettrans.setAutoCommit(false);
// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_PRICE_RFC");
// if (jcofunction == null) {
// logger_489475fd.info(String.valueOf("ZOA_PRICE_RFC not found in SAP."));
// retstr[0] = "E";
// retstr[1] = "没找到SAP的ZOA_PRICE_RFC函数";
// } else {
// jcofunction.getImportParameterList().setValue("ID", sapId);
// logger_489475fd.info(String.valueOf("开始调用ZOA_PRICE_RFC函数"));
// jcofunction.execute(destination);
// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
// 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();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_sg);
// if (!"S".equals(retstr[0])) {
// requestinfo.getRequestManager().setMessageid("ERROR");
// 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()));
// requestinfo.getRequestManager().setMessageid("ERROR");
// requestinfo.getRequestManager().setMessagecontent("调用SAP函数出错：：" + e.getMessage());
// String sql = "update e10_core_business.dbo." + tablename + " set jgfb= '" + retstr[0] + "',message='" + retstr[1] + "' where id =" + requestId;
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// 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()));
} catch (Exception e) {
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.interfaces.workflow.action.Action;
//不启用
@org.springframework.stereotype.Service("workflow_action_ZOA_SIGN_RFCAction")
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();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
retstr = new String[2];
try {
String sapId = "";
Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
for (int i = 0; i < aproperty.length; i++) {
String name = aproperty[i].getName().toUpperCase();
String value = Util.null2String(aproperty[i].getValue());
if (name.equals("BH")) {
sapId = value;
}
}
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
recordsettrans.setAutoCommit(false);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC");
if (jcofunction == null) {
logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP."));
retstr[0] = "E";
retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数";
} else {
jcofunction.getImportParameterList().setValue("ID", sapId);
logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数"));
jcofunction.execute(destination);
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
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();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_pq);
if (!"S".equals(retstr[0])) {
requestinfo.getRequestManager().setMessageid("ERROR");
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()));
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;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
}
//TODO custom 不启用
// try {
// String sapId = "";
// Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
// for (int i = 0; i < aproperty.length; i++) {
// String name = aproperty[i].getName().toUpperCase();
// String value = Util.null2String(aproperty[i].getValue());
// if (name.equals("BH")) {
// sapId = value;
// }
// }
// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
// recordsettrans.setAutoCommit(false);
// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_SIGN_RFC");
// if (jcofunction == null) {
// logger_43f5aff5.info(String.valueOf("ZOA_SIGN_RFC not found in SAP."));
// retstr[0] = "E";
// retstr[1] = "没找到SAP的ZOA_SIGN_RFC函数";
// } else {
// jcofunction.getImportParameterList().setValue("ID", sapId);
// logger_43f5aff5.info(String.valueOf("开始调用ZOA_SIGN_RFC函数"));
// jcofunction.execute(destination);
// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
// 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();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_pq);
// if (!"S".equals(retstr[0])) {
// requestinfo.getRequestManager().setMessageid("ERROR");
// 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()));
// 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;
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname);
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
// }
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
} catch (Exception e) {
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);
logger_f5224b91.info("sql3 = " + sql3);
logger_f5224b91.info("添加 = " + b1);
logger_f5224b91.info("b -----"+ b1);
if (applyEmpNum.length() < 10) {
// 经办人工号
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.interfaces.workflow.action.Action;
@org.springframework.stereotype.Service("workflow_action_ZOA_STATUS_RFCAction")
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();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
retstr = new String[2];
try {
String sapId = "";
Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
for (int i = 0; i < aproperty.length; i++) {
String name = aproperty[i].getName().toUpperCase();
String value = Util.null2String(aproperty[i].getValue());
if (name.equals("BH")) {
sapId = value;
}
}
RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
recordsettrans.setAutoCommit(false);
JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC");
if (jcofunction == null) {
logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP."));
retstr[0] = "E";
retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数";
} else {
jcofunction.getImportParameterList().setValue("ID", sapId);
logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数"));
jcofunction.execute(destination);
retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
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 poolname_vx = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
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]);
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
}
} catch (Exception e) {
logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString()));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage());
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("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname);
logger_2bfe536a.info("b2 -----"+ b);
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
}
//TODO custom 不启用
// try {
// String sapId = "";
// Property[] aproperty = requestinfo.getMainTableInfo().getProperty();
// for (int i = 0; i < aproperty.length; i++) {
// String name = aproperty[i].getName().toUpperCase();
// String value = Util.null2String(aproperty[i].getValue());
// if (name.equals("BH")) {
// sapId = value;
// }
// }
// RecordSetTrans recordsettrans = I18nContextUtil.getBean(RecordSetTrans.class);
// recordsettrans.setAutoCommit(false);
// JCoFunction jcofunction = destination.getRepository().getFunction("ZOA_STATUS_RFC");
// if (jcofunction == null) {
// logger_2bfe536a.info(String.valueOf("ZOA_STATUS_RFC not found in SAP."));
// retstr[0] = "E";
// retstr[1] = "没找到SAP的ZOA_STATUS_RFC函数";
// } else {
// jcofunction.getImportParameterList().setValue("ID", sapId);
// logger_2bfe536a.info(String.valueOf("开始调用ZOA_STATUS_RFC函数"));
// jcofunction.execute(destination);
// retstr[0] = jcofunction.getExportParameterList().getValue("E_STATUS").toString();
// 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 poolname_vx = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// 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]);
// return WeaResult.success(getResultMapForAction(weaverResultMap, "result", Action.SUCCESS, requestinfo.getRequestManager()));
// }
// } catch (Exception e) {
// logger_2bfe536a.info(String.valueOf("调用ZOA_STATUS_RFC更新审批不通过状态出错：" + e.toString()));
// requestinfo.getRequestManager().setMessageid("ERROR");
// requestinfo.getRequestManager().setMessagecontent("调用SAP接口出错：" + e.getMessage());
// 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("sql2 -----"+ sql);
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// 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()));
} catch (Exception e) {
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);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
boolean b1 = rs.executeSql(sql, poolname);
logger_adc1e038.info("sql flag1-----"+ b1);
if (rs.next()) {
mxcount = rs.getInt("mxcount");
logger_adc1e038.info("mxcount -----"+ mxcount);

Write Preview
Loading…
Cancel
Save