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 7 months ago
parent 73a48259f3 222267232a
commit b17f1e2936
52 changed files with 339 additions and 864 deletions
Show Stats Download Patch File Download Diff File

19
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/htjt/util/TransUtil.java
Unescape Escape View File

@ -46,26 +46,17 @@ public class TransUtil {
if ("".equals(selectvalue)) {
return selectname;
}
String sql = "SELECT c.name AS selectname\n" +
"FROM e10_core_business.dbo.form_field a, e10_core_business.dbo.form_table b, e10_core_business.dbo.field_option c\n" +
"WHERE a.form_id = b.form_id\n" +
" AND c.field_id = a.id\n" +
" AND b.table_name = '"+tableName+"'\n" +
" AND a.data_key = '"+filedname+"'\n" +
" AND c.value_key = '"+selectvalue+"'\n" +
" AND a.delete_type = 0\n" +
" AND a.tenant_key = 't6kj9c07jr'\n" +
" AND b.delete_type = 0\n" +
" AND b.tenant_key = 't6kj9c07jr'\n" +
" AND c.delete_type = 0\n" +
" AND c.tenant_key = 't6kj9c07jr'";
String sql = " select e.table_name, e.form_id ,e.form_name ,c.title , c.data_key ,d.name ,d.value_key from e10_core_business.dbo.form_table e " +
" left join e10_core_business.dbo.form_field c on e.form_id = c.form_id " +
" left join e10_core_business.dbo.field_option d on c.id = d.field_id " +
" where e.table_name = '"+tableName+"' and c.data_key = '"+filedname+"' and value_key = '"+selectvalue+"'";
logger_24a1e280.info("TransUtil sql "+sql);
String poolname_oj = CONN_TYPE.workflow.getType();
/* writeLog("sql:"+sql);
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
rs.executeSql(sql, poolname_oj);
if (rs.next()) {
selectname = Util.null2String(rs.getString("selectname"));
selectname = Util.null2String(rs.getString("name"));
}
logger_24a1e280.info("TransUtil selectname "+selectname);
return selectname;

443
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/swfa/BillFieldUtil.java
Unescape Escape View File

@ -34,32 +34,31 @@ public class BillFieldUtil {
* @return Map
*/
// TODO custom 问题sql
public static Map getFieldId(int formid, String num) {
logger_6c507bbc.info("BillFieldUtil getFieldId start formid "+ formid);
logger_6c507bbc.info("num "+ num);
formid = Math.abs(formid);
String sql = "";
if ("0".equals(num)) {
sql = "select b.id,fieldname,detailtable from workflow_billfield b ,workflow_base a where b.billid=-" + formid + " and a.formid=b.billid and (detailtable='' or detailtable is null)";
} else {
sql = "select b.id,fieldname,detailtable from workflow_billfield b ,workflow_base a where b.billid=-" + formid + " and a.formid=b.billid and detailtable='formtable_main_" + formid + "_dt" + num + "'";
}
logger_6c507bbc.info("sql "+ sql);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname);
Map array = new HashMap();
while (rs.next()) {
logger_6c507bbc.info("fieldname "+ rs.getString("fieldname"));
array.put(Util.null2String(rs.getString("fieldname")).toLowerCase(), Util.null2String(rs.getString("id")));
}
logger_6c507bbc.info("array "+ array);
return array;
}
// public static Map getFieldId(int formid, String num) {
//
// logger_6c507bbc.info("BillFieldUtil getFieldId start formid "+ formid);
// logger_6c507bbc.info("num "+ num);
// formid = Math.abs(formid);
// String sql = "";
// if ("0".equals(num)) {
// sql = "select b.id,fieldname,detailtable from workflow_billfield b ,workflow_base a where b.billid=-" + formid + " and a.formid=b.billid and (detailtable='' or detailtable is null)";
// } else {
// sql = "select b.id,fieldname,detailtable from workflow_billfield b ,workflow_base a where b.billid=-" + formid + " and a.formid=b.billid and detailtable='formtable_main_" + formid + "_dt" + num + "'";
// }
//
// logger_6c507bbc.info("sql "+ sql);
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname);
// Map array = new HashMap();
// while (rs.next()) {
// logger_6c507bbc.info("fieldname "+ rs.getString("fieldname"));
// array.put(Util.null2String(rs.getString("fieldname")).toLowerCase(), Util.null2String(rs.getString("id")));
// }
// logger_6c507bbc.info("array "+ array);
// return array;
// }
/**
* @Title: getlabelId
@ -73,34 +72,33 @@ public class BillFieldUtil {
* @throws
*/
//TODO 问题sql
public static String getlabelId(String name, int formid, String ismain, String num) {
logger_6c507bbc.info("BillFieldUtil getlabelId start ");
logger_6c507bbc.info("name----------- " + name);
logger_6c507bbc.info("formid----------- " + formid);
logger_6c507bbc.info("ismain----------- " + ismain);
logger_6c507bbc.info("num----------- " + num);
String id = "";
String sql = "";
formid = formid * -1;
if ("0".equals(ismain)) {
sql = "select id,fieldname,detailtable from workflow_billfield where billid=-" + formid + " and (detailtable='' or detailtable is null) and lower(fieldname)='" + name + "'";
} else {
sql = "select id,fieldname,detailtable from workflow_billfield where billid=-" + formid + " and detailtable='formtable_main_" + formid + "_dt" + num + "' and lower(fieldname)='" + name + "'";
}
// System.out.println(sql);
logger_6c507bbc.info("sql----------- " + sql);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_a1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql(sql, poolname_a1);
if (rs.next()) {
id = Util.null2String(rs.getString("id"));
}
logger_6c507bbc.info("id----------- " + id);
return id;
}
// public static String getlabelId(String name, int formid, String ismain, String num) {
//
// logger_6c507bbc.info("BillFieldUtil getlabelId start ");
// logger_6c507bbc.info("name----------- " + name);
// logger_6c507bbc.info("formid----------- " + formid);
// logger_6c507bbc.info("ismain----------- " + ismain);
// logger_6c507bbc.info("num----------- " + num);
// String id = "";
// String sql = "";
// formid = formid * -1;
// if ("0".equals(ismain)) {
// sql = "select id,fieldname,detailtable from workflow_billfield where billid=-" + formid + " and (detailtable='' or detailtable is null) and lower(fieldname)='" + name + "'";
// } else {
// sql = "select id,fieldname,detailtable from workflow_billfield where billid=-" + formid + " and detailtable='formtable_main_" + formid + "_dt" + num + "' and lower(fieldname)='" + name + "'";
// }
// // System.out.println(sql);
// logger_6c507bbc.info("sql----------- " + sql);
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname_a1 = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql(sql, poolname_a1);
// if (rs.next()) {
// id = Util.null2String(rs.getString("id"));
// }
// logger_6c507bbc.info("id----------- " + id);
// return id;
// }
/**
* 选择框 显示名
@ -118,11 +116,12 @@ public class BillFieldUtil {
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_n1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select name,field_id from field_option as workflow_selectItem where field_id =" + Util.getIntValue(id, 0) + " and selectvalue = " + Util.getIntValue(val, 0);
//TODO custom 已处理 int类型转string
String sql = "select name,field_id from e10_core_business.dbo.field_option as workflow_selectItem where field_id ='"+id+"' and value_key= '" +val+"'";
logger_6c507bbc.info("sql----------- " + sql);
recordSet.executeSql(sql, poolname_n1);
if (recordSet.next()) {
name = recordSet.getString("selectname");
name = recordSet.getString("name");
}
logger_6c507bbc.info("name----------- " + name);
return name;
@ -134,7 +133,6 @@ public class BillFieldUtil {
* @return
*/
// TODO custom 问题sql
public static String getselectNameByCol(String fieldname, String workflowid, String selectvalue) {
logger_6c507bbc.info("BillFieldUtil getselectNameByCol start ");
logger_6c507bbc.info("fieldname----------- " + fieldname);
@ -145,31 +143,17 @@ public class BillFieldUtil {
String poolname_jl = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// recordSet.executeSql("select c.name from wfp_base a " + "INNER JOIN form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_jl);
String sql = "SELECT c.name AS selectname\n" +
"FROM e10_core_business.dbo.wfp_base a\n" +
"\tINNER JOIN e10_core_business.dbo.form_field b\n" +
"\tON a.formid = b.form_id\n" +
"\tAND a.delete_type = 0\n" +
"\tAND a.tenant_key = 't6kj9c07jr'\n" +
"\tAND b.delete_type = 0\n" +
"\tAND b.tenant_key = 't6kj9c07jr'\n" +
"\tAND a.delete_type = 0\n" +
"\tAND a.tenant_key = 't6kj9c07jr'\n" +
"\tAND b.delete_type = 0\n" +
"\tAND b.tenant_key = 't6kj9c07jr'\n" +
"\tINNER JOIN field_option c\n" +
"\tON b.id = c.field_id\n" +
"\tAND c.delete_type = 0\n" +
"\tAND c.tenant_key = 't6kj9c07jr'\n" +
"WHERE b.data_key = '" + fieldname + "' \n" +
"\tAND a.id = '" + workflowid + "'\n" +
"\tAND c.value_key = '"+selectvalue+"';";
String sql = " select a.id, b.relatekey ,c.title , c.data_key ,d.name ,d.value_key from e10_core_business.dbo.wfp_base a " +
" left join e10_core_business.dbo.wfp_relateform b on a.id = b.workflowid " +
" left join e10_core_business.dbo.form_field c on b.relatekey = c.form_id " +
" left join e10_core_business.dbo.field_option d on c.id = d.field_id " +
" where a.id = '"+workflowid+"' and c.data_key = '"+fieldname+"' and value_key = '"+selectvalue+"'";
logger_6c507bbc.info("sql----------- " + sql);
recordSet.executeSql(sql, poolname_jl);
if (recordSet.next()) {
name = recordSet.getString("selectname");
name = recordSet.getString("name");
}
logger_6c507bbc.info("name----------- " + name);
return name;
@ -182,23 +166,24 @@ public class BillFieldUtil {
* @param id
* @return
*/
public static String getselectOptionStr(String val, String id) {
String str = "<option value=''></option>";
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_fi = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
recordSet.executeSql("select name,field_id,value_key from field_option as workflow_selectItem where field_id = " + Util.getIntValue(id, 0) + " order by value_key", poolname_fi);
while (recordSet.next()) {
String name = Util.null2String(recordSet.getString("selectname"));
String value = Util.null2String(recordSet.getString("selectvalue"));
if (value.equals(val)) {
str += "<option value='" + value + "' selected>" + name + "</option>";
} else {
str += "<option value='" + value + "'>" + name + "</option>";
}
}
return str;
}
// public static String getselectOptionStr(String val, String id) {
// String str = "<option value=''></option>";
// RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
// String poolname_fi = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// //TODO custom 已处理 int类型转string
// recordSet.executeSql("select name,field_id,value_key from e10_core_business.dbo.field_option as workflow_selectItem where field_id = '" + id + "' order by value_key", poolname_fi);
// while (recordSet.next()) {
// String name = Util.null2String(recordSet.getString("name"));
// String value = Util.null2String(recordSet.getString("value_key"));
// if (value.equals(val)) {
// str += "<option value='" + value + "' selected>" + name + "</option>";
// } else {
// str += "<option value='" + value + "'>" + name + "</option>";
// }
// }
// return str;
// }
/**
* 判断节点是否为创建节点
@ -206,21 +191,22 @@ public class BillFieldUtil {
* @param nodeid
* @return
*/
public static boolean judgeNodeStart(String nodeid) {
boolean falg = false;
String isstart = "0";
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_y9 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select * from wfp_node as workflow_nodebase where id=" + Util.getIntValue(nodeid, 0), poolname_y9);
if (rs.next()) {
isstart = rs.getString("isstart");
}
if ("1".equals(isstart)) {
falg = true;
}
return falg;
}
// public static boolean judgeNodeStart(String nodeid) {
// boolean falg = false;
// String isstart = "0";
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname_y9 = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// //TODO custom 已处理 int类型转string
// rs.executeSql("select * from wfp_node as workflow_nodebase where id='" + nodeid+"'", poolname_y9);
// if (rs.next()) {
// isstart = rs.getString("isstart");
// }
// if ("1".equals(isstart)) {
// falg = true;
// }
// return falg;
// }
/**
* 获取节点名称
@ -228,18 +214,18 @@ public class BillFieldUtil {
* @return
*/
// TODO custom 问题sql
public String getNodename(String nodeid) {
String nodename = "";
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_v8 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select id,nodename from wfp_node as workflow_nodebase where id=" + Util.getIntValue(nodeid, 0), poolname_v8);
if (rs.next()) {
nodename = rs.getString("nodename");
}
return nodename;
}
// public String getNodename(String nodeid) {
// String nodename = "";
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname_v8 = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// //TODO custom 已处理 int类型转string
// rs.executeSql("select id,nodename from wfp_node as workflow_nodebase where id='" + nodeid +"'", poolname_v8);
// if (rs.next()) {
// nodename = rs.getString("nodename");
// }
// return nodename;
// }
/**
* 获取计量单位内码
@ -253,8 +239,11 @@ public class BillFieldUtil {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_rg = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select id,dwnm from formtable_main_286 where id=" + Util.getIntValue(unitid, 0);
rs.executeSql(sql, poolname_rg);
//TODO custom 已处理 int类型转string
String sql = "select id,dwnm from e10_common.dbo.formtable_main_286 where id='" + unitid+"'";
logger_6c507bbc.info("sql----------- " + sql);
boolean b1 = rs.executeSql(sql, poolname_rg);
logger_6c507bbc.info("b1----------- " + b1);
if (rs.next()) {
unitno = rs.getString("dwnm");
}
@ -274,10 +263,12 @@ public class BillFieldUtil {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_vp = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select job_num from employee as HrmResource where id = " + hrid;
String sql = "select job_num from eteams.dbo.employee as HrmResource where id = " + hrid;
logger_6c507bbc.info("sql----------- " + sql);
rs.executeSql(sql, poolname_vp);
if (rs.next()) {
code = Util.null2String(rs.getString("workcode"));
code = Util.null2String(rs.getString("job_num"));
}
logger_6c507bbc.info("code----------- " + code);
return code;
@ -288,8 +279,6 @@ public class BillFieldUtil {
* @param hrid
* @return
*/
// TODO custom 问题sql
public String getCredentialsNumber(String hrid) {
logger_6c507bbc.info("BillFieldUtil getCredentialsNumber start ");
logger_6c507bbc.info("hrid----------- " + hrid);
@ -297,8 +286,25 @@ public class BillFieldUtil {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_2s = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select id_no from employee as HrmResource where id = " + hrid;
rs.executeSql(sql, poolname_2s);
String sql = "SELECT HrmResource.id_no AS certificatenum " +
"FROM ( " +
" SELECT employee.*, hr_userinfo.id_no " +
" FROM eteams.dbo.employee " +
" LEFT JOIN e10_other_business.dbo.hr_userinfo " +
" ON employee.id = hr_userinfo.[user] " +
" AND employee.delete_type = 0 " +
" AND employee.tenant_key = 't6kj9c07jr' " +
" AND hr_userinfo.delete_type = 0 " +
" AND hr_userinfo.tenant_key = 't6kj9c07jr' " +
") HrmResource " +
" WHERE HrmResource.id = '" + hrid +
"' AND HrmResource.delete_type = 0 " +
" AND HrmResource.tenant_key = 't6kj9c07jr' " ;
logger_6c507bbc.info("sql----------- " + sql);
boolean b1 = rs.executeSql(sql, poolname_2s);
logger_6c507bbc.info("getCredentialsNumber flag----------- " + b1);
if (rs.next()) {
code = Util.null2String(rs.getString("certificatenum"));
}
@ -319,10 +325,12 @@ public class BillFieldUtil {
String poolname_p1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select fullname from eteams.dbo.department as HrmDepartment where id = " + dpid;
rs.executeSql(sql, poolname_p1);
logger_6c507bbc.info("sql----------- " + sql);
boolean b1 = rs.executeSql(sql, poolname_p1);
logger_6c507bbc.info("getDepartmentname----------- " + b1);
if (rs.next()) {
dpname = Util.null2String(rs.getString("departmentname"));
dpname = Util.null2String(rs.getString("fullname"));
}
logger_6c507bbc.info("dpname----------- " + dpname);
return dpname;
@ -340,9 +348,18 @@ public class BillFieldUtil {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_tg = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select name from department as HrmSubCompany where id = " + spid, poolname_tg);
String sql ="SELECT id , name " +
"FROM eteams.dbo.department HrmSubCompany " +
"WHERE id = '"+spid+"' and HrmSubCompany.virtualid = 1 " +
" AND HrmSubCompany.type = 'subcompany' " +
" AND HrmSubCompany.delete_type = 0 " +
" AND HrmSubCompany.tenant_key = 't6kj9c07jr'";
logger_6c507bbc.info("sql----------- " + sql);
boolean b1 = rs.executeSql(sql, poolname_tg);
logger_6c507bbc.info("getSubcompanyname----------- " + b1);
if (rs.next()) {
spname = Util.null2String(rs.getString("subcompanyname"));
spname = Util.null2String(rs.getString("name"));
}
logger_6c507bbc.info("spname----------- " + spname);
return spname;
@ -354,23 +371,22 @@ public class BillFieldUtil {
* @return
*/
// TODO custom 问题sql
public String getTablename(String wfid) {
logger_6c507bbc.info("BillFieldUtil getSubcompanyname start ");
logger_6c507bbc.info("wfid----------- " + wfid);
String tbname = "";
String fmid = "";
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_tw = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select formid from wfp_base as workflow_base where id = " + wfid, poolname_tw);
if (rs.next()) {
fmid = Util.null2String(rs.getString("formid"));
tbname = "formtable_main_" + fmid.replace("-", "");
}
logger_6c507bbc.info("tbname----------- " + tbname);
return tbname;
}
// public String getTablename(String wfid) {
// logger_6c507bbc.info("BillFieldUtil getSubcompanyname start ");
// logger_6c507bbc.info("wfid----------- " + wfid);
// String tbname = "";
// String fmid = "";
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname_tw = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql("select formid from wfp_base as workflow_base where id = " + wfid, poolname_tw);
// if (rs.next()) {
// fmid = Util.null2String(rs.getString("formid"));
// tbname = "formtable_main_" + fmid.replace("-", "");
// }
// logger_6c507bbc.info("tbname----------- " + tbname);
// return tbname;
// }
/**
* 把出差人员放在一起
@ -433,72 +449,72 @@ public class BillFieldUtil {
* @param map 所有人员 工号和ID的map
* @return
*/
public Map<String, String> getIdsByWorkcode(String workcode, Map<String, String> map) {
String ids = "";
Map<String, String> returnMap = new HashMap<String, String>();
if (workcode != null && !workcode.equals("")) {
// 传入的工号为空
String[] array = workcode.split(",");
for (int i = 0; i < array.length; i++) {
if (array[i] != null) {
array[i] = array[i].trim();
}
String userid = map.get(array[i]);
if (userid == null || userid.equals("")) {
returnMap.put("msg", "工号" + array[i] + "不存在...");
return returnMap;
} else {
ids += "," + userid;
}
}
if (ids != null) {
ids = ids.replaceFirst(",", "");
}
returnMap.put("msg", "ok");
returnMap.put("data", ids);
}
return returnMap;
}
// public Map<String, String> getIdsByWorkcode(String workcode, Map<String, String> map) {
// String ids = "";
// Map<String, String> returnMap = new HashMap<String, String>();
// if (workcode != null && !workcode.equals("")) {
// // 传入的工号为空
// String[] array = workcode.split(",");
// for (int i = 0; i < array.length; i++) {
// if (array[i] != null) {
// array[i] = array[i].trim();
// }
// String userid = map.get(array[i]);
// if (userid == null || userid.equals("")) {
// returnMap.put("msg", "工号" + array[i] + "不存在...");
// return returnMap;
// } else {
// ids += "," + userid;
// }
// }
// if (ids != null) {
// ids = ids.replaceFirst(",", "");
// }
// returnMap.put("msg", "ok");
// returnMap.put("data", ids);
// }
// return returnMap;
// }
/**
* 根据工号获取ID
* @param workcode
* @return
*/
public Map<String, String> getIdsByWorkcode(String workcode) {
String ids = "";
Map<String, String> returnMap = new HashMap<String, String>();
if (workcode != null && !workcode.equals("")) {
// 传入的工号为空
String[] array = workcode.split(",");
for (int i = 0; i < array.length; i++) {
if (array[i] != null) {
array[i] = array[i].trim();
}
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_xj = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
rs.executeSql("select id,job_num from employee as HrmResource where job_num = '" + array[i] + "'", poolname_xj);
// id
String userid = "";
while (rs.next()) {
userid = Util.null2String(rs.getString("id"));
}
if (userid == null || userid.equals("")) {
returnMap.put("msg", "工号" + array[i] + "不存在...");
return returnMap;
} else {
ids += "," + userid;
}
}
if (ids != null) {
ids = ids.replaceFirst(",", "");
}
returnMap.put("msg", "ok");
returnMap.put("data", ids);
}
return returnMap;
}
// public Map<String, String> getIdsByWorkcode(String workcode) {
// String ids = "";
// Map<String, String> returnMap = new HashMap<String, String>();
// if (workcode != null && !workcode.equals("")) {
// // 传入的工号为空
// String[] array = workcode.split(",");
// for (int i = 0; i < array.length; i++) {
// if (array[i] != null) {
// array[i] = array[i].trim();
// }
// RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
// String poolname_xj = CONN_TYPE.workflow.getType();
// // TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
// rs.executeSql("select id,job_num from employee as HrmResource where job_num = '" + array[i] + "'", poolname_xj);
// // id
// String userid = "";
// while (rs.next()) {
// userid = Util.null2String(rs.getString("id"));
// }
// if (userid == null || userid.equals("")) {
// returnMap.put("msg", "工号" + array[i] + "不存在...");
// return returnMap;
// } else {
// ids += "," + userid;
// }
// }
// if (ids != null) {
// ids = ids.replaceFirst(",", "");
// }
// returnMap.put("msg", "ok");
// returnMap.put("data", ids);
// }
// return returnMap;
// }
/**
* 获取姓名
@ -511,7 +527,12 @@ public class BillFieldUtil {
String poolname_s2 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
logger_6c507bbc.info("getName --" + hrid);
rs.executeSql("select username from eteams.dbo.employee as HrmResource where id = " + hrid, poolname_s2);
String sql = "select username from eteams.dbo.employee as HrmResource where id = " + hrid;
logger_6c507bbc.info("sql----------- " + sql);
boolean b1 = rs.executeSql(sql, poolname_s2);
logger_6c507bbc.info("getName ----------- " + b1);
if (rs.next()) {
code = Util.null2String(rs.getString("username"));
}

482
secondev-history-action/src/main/java/com/weaver/seconddev/interfaces/swfa/sl/FileUtil.java
Unescape Escape View File

@ -1,482 +0,0 @@
//package com.weaver.seconddev.interfaces.swfa.sl;
//
///**
// * FileUtil.java
// * @Author: Administrator
// * @CreateDate: 2013-2-27
// * @Version 1.0
// * Copyright (C) 2013
// */
//import java.io.BufferedReader;
//import java.io.File;
//import java.io.FileInputStream;
//import java.io.FileReader;
//import java.io.FilenameFilter;
//import java.io.IOException;
//import java.text.ParseException;
//import java.text.SimpleDateFormat;
//import java.util.Date;
//import java.util.regex.Matcher;
//import java.util.regex.Pattern;
////import org.apache.log4j.Logger;
//import jcifs.smb.SmbAuthException;
//import jcifs.smb.SmbFile;
//import jcifs.smb.SmbFileInputStream;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
///**
// * <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
// */
//public class FileUtil {
//
// private static final org.slf4j.Logger logger_e7cead7a = LoggerFactory.getLogger(FileUtil.class);
//
// private FileUtil() {
// }
//
// /**
// * <20><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD>
// * @param host
// * @param user
// * @param password
// * @param fname <20><><EFBFBD>·<EFBFBD><C2B7>
// * @return
// */
// public static byte[] readLocalFile(String fname) {
// try {
// // File file = new File(fname);
// // FileInputStream is = new FileInputStream(file);
// SmbFile smbFile = new SmbFile(fname);
// SmbFileInputStream is = new SmbFileInputStream(smbFile);
// byte[] buff = new byte[smbFile.getContentLength()];
// // byte[] buff = new byte[is.available()];
// is.read(buff);
// is.close();
// return buff;
// } catch (IOException e) {
// try {
// File file = new File(fname);
// FileInputStream is = new FileInputStream(file);
// byte[] buff = new byte[is.available()];
// is.read(buff);
// is.close();
// return buff;
// } catch (IOException e1) {
// return null;
// }
// } catch (Exception e) {
// return null;
// }
// }
//
// /**
// * <20><>ȡ<EFBFBD><C8A1><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD>
// * @param host
// * @param user
// * @param password
// * @param fname <20><><EFBFBD>·<EFBFBD><C2B7>
// * @return
// */
// public static byte[] readSharedFile(String host, String user, String password, String fname) {
// String temp = "";
// try {
// temp = fname;
// if (fname.startsWith("\\\\|/")) {
// temp = fname.replaceFirst("\\\\|/", "");
// }
// temp = temp.replaceAll("\\\\", "/");
// String fullpath = "smb://" + user + ":" + password + "@" + host + temp;
// SmbFile smbFile = new SmbFile(fullpath);
// SmbFileInputStream is = new SmbFileInputStream(smbFile);
// byte[] buff = new byte[smbFile.getContentLength()];
// is.read(buff);
// is.close();
// return buff;
// } catch (SmbAuthException e) {
// try {
// String localpath = "//" + host + temp;
// FileInputStream fis = new FileInputStream(new File(localpath));
// byte[] buff = new byte[fis.available()];
// fis.read(buff);
// fis.close();
// return buff;
// } catch (IOException e1) {
// return null;
// }
// } catch (IOException e) {
// return null;
// }
// }
//
// /**
// * <20>жϹ<D0B6><CFB9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC>Ƿ<EFBFBD><C7B7><EFBFBD><EFBFBD>
// * @param host
// * @param user
// * @param password
// * @param fname
// * @return
// */
// public static boolean sharedFileExists(String host, String user, String password, String fname) {
// boolean flg = false;
// String temp = "";
// try {
// temp = fname;
// if (fname.startsWith("\\\\|/")) {
// temp = fname.replaceFirst("\\\\|/", "");
// }
// temp = fname.replaceAll("\\\\", "/");
// String fullpath = "smb://" + user + ":" + password + "@" + host + temp;
// SmbFile smbFile = new SmbFile(fullpath);
// flg = smbFile.exists();
// } catch (SmbAuthException e) {
// String localpath = "//" + host + temp;
// File file = new File(localpath);
// flg = file.exists();
// } catch (IOException e) {
// }
// return flg;
// }
//
// /**
// * <20><><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD>¹<EFBFBD><C2B9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD><EFBFBD>
// * @param host
// * @param user
// * @param password
// * @param path <20><><EFBFBD>·<EFBFBD><C2B7>
// * @return
// */
// // public static Object[] listFiles(String host, String user, String password, String path) {
// // String temp = "";
// // try {
// // temp = path;
// // if (path.startsWith("\\\\|/")) {
// // temp = path.replaceFirst("\\\\|/", "");
// // }
// // temp = temp.replaceAll("\\\\", "/");
// // if (!path.endsWith("/")) {
// // temp += "/";
// // }
// // String fullpath = "smb://" + user + ":" + password + "@" + host + temp;
// // SmbFile smbFile = new SmbFile(fullpath);
// // return smbFile.listFiles();
// // } catch (SmbAuthException e) {
// // try {
// // String localpath = "//" + host + temp;
// //
// // File file = new File(localpath);
// // return file.listFiles();
// // } catch (Exception e1) {
// // e1.printStackTrace();
// // return null;
// // }
// //
// //
// // } catch (IOException e) {
// // e.printStackTrace();
// // return null;
// // }
// // }
// /**
// * <20><><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD>¹<EFBFBD><C2B9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD>飨<EFBFBD>Թ<EFBFBD><D4B9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>ʽ<EFBFBD><CABD>ȡ<EFBFBD><C8A1>
// * @param host
// * @param user
// * @param password
// * @param path <20><><EFBFBD>·<EFBFBD><C2B7>
// * @return
// */
// public static SmbFile[] listFilesAsShare(String fullpath) {
// try {
// SmbFile smbFile = new SmbFile(fullpath);
// return smbFile.listFiles();
// } catch (IOException e) {
// e.printStackTrace();
// return null;
// }
// }
//
// /**
// * <20><><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD>¹<EFBFBD><C2B9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD>飨<EFBFBD>Թ<EFBFBD><D4B9><EFBFBD><EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>ʽ<EFBFBD><CABD>ȡ<EFBFBD><C8A1>
// * @param host
// * @param user
// * @param password
// * @param path <20><><EFBFBD>·<EFBFBD><C2B7>
// * @return
// */
// public static SmbFile[] listFilesAsShare(String host, String user, String password, String path) {
// try {
// String temp = path;
// if (path.startsWith("\\\\|/")) {
// temp = path.replaceFirst("\\\\|/", "");
// }
// temp = temp.replaceAll("\\\\", "/");
// if (!path.endsWith("/")) {
// temp += "/";
// }
// String fullpath = "smb://" + user + ":" + password + "@" + host + temp;
// SmbFile smbFile = new SmbFile(fullpath);
// return smbFile.listFiles();
// } catch (IOException e) {
// e.printStackTrace();
// return null;
// }
// }
//
// /**
// * <20><><EFBFBD><EFBFBD>ָ<EFBFBD><D6B8>ʱ<EFBFBD><CAB1>֮ǰ<D6AE><C7B0><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ļ<EFBFBD>
// * @param host
// * @param user
// * @param password
// * @param path
// * @param dateFormat <20>ļ<EFBFBD><C4BC><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ڸ<EFBFBD>ʽ
// * <09>磺<EFBFBD>ļ<EFBFBD><C4BC><EFBFBD>Ϊ
// * @param time ָ<><D6B8>ʱ<EFBFBD><CAB1>
// * @return
// */
// public static String searchLatestFiles(String host, String user, String password, String path, String dateFormat, Date time) {
// String temp = "";
// final Pattern yPattern = Pattern.compile("\\d{4}");
// final Pattern ymPattern = Pattern.compile("\\d{6}");
// final Pattern ymdPattern = Pattern.compile("\\d{8}");
// final SimpleDateFormat sdf = new SimpleDateFormat(dateFormat);
// final Date initTime = time;
// temp = path;
// if (path.startsWith("\\\\|/")) {
// temp = path.replaceFirst("\\\\|/", "");
// }
// temp = temp.replaceAll("\\\\", "/");
// if (!temp.endsWith("/")) {
// temp += "/";
// }
// try {
// String localpath = "//" + host + temp;
// File file = new File(localpath);
// File[] fileYearList = file.listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = yPattern.matcher(name);
// return m.matches();
// }
// });
// if (fileYearList != null && fileYearList.length > 0) {
// for (int i = fileYearList.length - 1; i >= 0; i--) {
// File[] fileYMList = fileYearList[i].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = ymPattern.matcher(name);
// return m.matches();
// }
// });
// if (null != fileYMList && fileYMList.length > 0) {
// for (int j = fileYMList.length - 1; j >= 0; j--) {
// File[] fileYMDList = fileYMList[j].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = ymdPattern.matcher(name);
// return m.matches();
// }
// });
// if (null != fileYMDList && fileYMDList.length > 0) {
// for (int k = fileYMDList.length - 1; k >= 0; k--) {
// File[] fileList = fileYMDList[k].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// try {
// Date curTime = sdf.parse(name);
// if (curTime.compareTo(initTime) <= 0) {
// return true;
// }
// } catch (ParseException e) {
// return false;
// }
// return false;
// }
// });
// if (null != fileList && fileList.length > 0) {
// File tempFile = fileList[fileList.length - 1];
// // TODO
// int index = tempFile.getAbsolutePath().indexOf(host);
// return tempFile.getAbsolutePath().substring(index + host.length());
// }
// }
// }
// }
// }
// }
// }
// } catch (Exception e1) {
// e1.printStackTrace();
// return "";
// }
// return "";
// }
//
// /**
// * @param host
// * @param user
// * @param password
// * @param path
// * @param p
// * @return
// */
// public static String searchLatestFiles(String host, String user, String password, String path, Pattern p) {
// String temp = "";
// final Pattern yPattern = Pattern.compile("\\d{4}");
// final Pattern ymPattern = Pattern.compile("\\d{6}");
// final Pattern ymdPattern = Pattern.compile("\\d{8}");
// final Pattern fnamePattern = p;
// temp = path;
// if (path.startsWith("\\\\|/")) {
// temp = path.replaceFirst("\\\\|/", "");
// }
// temp = temp.replaceAll("\\\\", "/");
// if (!temp.endsWith("/")) {
// temp += "/";
// }
// // try {
// //
// // String fullpath = "smb://" + user + ":" + password + "@" + host + temp;
// // SmbFile smbFile = new SmbFile(fullpath);
// // SmbFile[] smbFileYearList = smbFile.listFiles(new SmbFilenameFilter() {
// // @Override
// // public boolean accept(SmbFile dir, String name) {
// // Matcher m = yPattern.matcher(name);
// // return m.matches();
// // }});
// // if (smbFileYearList != null) {
// // for (int i = smbFileYearList.length - 1; i >= 0; i--) {
// // SmbFile[] smbFileYMList = smbFileYearList[i].listFiles(new SmbFilenameFilter() {
// // @Override
// // public boolean accept(SmbFile dir, String name) {
// // Matcher m = ymPattern.matcher(name);
// // return m.matches();
// // }});
// // if (null != smbFileYMList) {
// // for (int j = smbFileYMList.length - 1; j >= 0; j--) {
// // SmbFile[] smbFileYMDList = smbFileYMList[j].listFiles(new SmbFilenameFilter() {
// // @Override
// // public boolean accept(SmbFile dir, String name) {
// // Matcher m = ymdPattern.matcher(name);
// // return m.matches();
// // }});
// // if (null != smbFileYMDList) {
// // for (int k = smbFileYMDList.length - 1; k >= 0; k--) {
// // SmbFile[] smbFileList = smbFileYMDList[k].listFiles(new SmbFilenameFilter() {
// // @Override
// // public boolean accept(SmbFile dir, String name) {
// // Matcher m = fnamePattern.matcher(name);
// // return m.matches();
// // }});
// // if (null != smbFileList && smbFileList.length > 0) {
// // SmbFile tempFile = smbFileList[smbFileList.length - 1];
// // String share = tempFile.getShare();
// // int index = tempFile.getCanonicalPath().indexOf(share);
// // return tempFile.getCanonicalPath().substring(index);
// // }
// // }
// // }
// // }
// // }
// // }
// // }
// // } catch (SmbAuthException e) {
// try {
// String localpath = "//" + host + temp;
// File file = new File(localpath);
// File[] fileYearList = file.listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = yPattern.matcher(name);
// return m.matches();
// }
// });
// if (fileYearList != null && fileYearList.length > 0) {
// for (int i = fileYearList.length - 1; i >= 0; i--) {
// File[] fileYMList = fileYearList[i].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = ymPattern.matcher(name);
// return m.matches();
// }
// });
// if (null != fileYMList && fileYMList.length > 0) {
// for (int j = fileYMList.length - 1; j >= 0; j--) {
// File[] fileYMDList = fileYMList[j].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = ymdPattern.matcher(name);
// return m.matches();
// }
// });
// if (null != fileYMDList && fileYMDList.length > 0) {
// for (int k = fileYMDList.length - 1; k >= 0; k--) {
// File[] fileList = fileYMDList[k].listFiles(new FilenameFilter() {
//
// public boolean accept(File dir, String name) {
// Matcher m = fnamePattern.matcher(name);
// return m.matches();
// }
// });
// if (null != fileList && fileList.length > 0) {
// // return fileList[fileList.length - 1];
// File tempFile = fileList[fileList.length - 1];
// // TODO
// int index = tempFile.getAbsolutePath().indexOf(host);
// return tempFile.getAbsolutePath().substring(index + host.length());
// }
// }
// }
// }
// }
// }
// }
// } catch (Exception e1) {
// e1.printStackTrace();
// return "";
// }
// // } catch (IOException e) {
// // e.printStackTrace();
// // return "";
// // }
// return "";
// }
//
// public static void main(String[] args) {
// // System.err.println(FileUtil.sharedFileExists("10.124.41.200", "Administrator", "oracle", "jsproduct"));
// }
//
// public static String ReadFile(String path) {
// String laststr = "";
// File file = new File(path);
// if (file.exists()) {
// BufferedReader reader = null;
// try {
// reader = new BufferedReader(new FileReader(file));
// String tempString = null;
// while ((tempString = reader.readLine()) != null) {
// laststr = laststr + tempString;
// }
// reader.close();
// } catch (IOException e) {
// e.printStackTrace();
// WriteLog(e.toString());
// } finally {
// if (reader != null) {
// try {
// reader.close();
// } catch (IOException e1) {
// WriteLog(e1.toString());
// }
// }
// }
// } else {
// WriteLog("ReadFile " + path + " not exists ");
// }
// return laststr;
// }
//
// private static void WriteLog(String message) {
// // log.info(message);
// System.out.println(message);
// }
//}

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

@ -159,7 +159,7 @@ public class ARSPaymentRecepitAction extends BaseBean implements Action, EsbServ
} else {
if ("2".equals(operate)) {
// 正式formtable_main_2714,测试formtable_main_2252，formtable_main_2401
boolean billingno = rs.execute("update e10_core_business.dbo.formtable_main_2401 set hkdh='" + ret.get("billingno") + "' where requestId=" + requestid);
boolean billingno = rs.execute("update e10_core_business.dbo.formtable_main_2401 set hkdh='" + ret.get("billingno") + "' where id=" + requestid);
logger_c29b3679.info("billingno　＝　" +billingno);
}
}

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

@ -229,7 +229,7 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer
return WeaResult.fail(500, "执行失败，调用接口报错", getResultMapForAction(weaverResultMap, "result", FAILURE_AND_CONTINUE, request.getRequestManager()));
}
// 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 id=" + requestId;
logger_336cd654.info("sql == "+sql);
String poolname_c1 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -240,7 +240,7 @@ public class AddVenMatExtsToSrmAction extends BaseBean implements Action, EsbSer
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;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.getMessage() + "' where id=" + requestId;
logger_336cd654.info("sql == "+sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -158,7 +158,7 @@ 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;
String sql = "select lrhmddw from e10_core_business.dbo." + table + " where id=" + id;
logger_454fb322.info("getApplyCom sql == " + sql);
String poolname = CONN_TYPE.workflow.getType();

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

@ -88,7 +88,7 @@ public class BlackListTempThawSyncAction extends BaseBean implements Action, Esb
head.setTaxno(map.get("SHXYDM"));
// 类型
logger_e39d526d.info("lx" + map.get("LX") );
head.setType(util.getselectName(map.get("LX"), "50151"));
head.setType(util.getselectName(map.get("LX"), "100003720000056151")); //50151 -> 56151
arr[0] = head;
logger_e39d526d.info("arr" + arr.toString() );
CRM_TEMPUNFREEZE_RETURN[] rets = service.call(arr);

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

@ -59,7 +59,7 @@ public class ChangeInformationExpertsAction extends BaseBean implements Action,
String roleid = "100502830000001498";
String zjlx1 = "";
String sqdw = "";
String sql = "select * from e10_core_business.dbo." + tablename + " where requestid=" + requestid;
String sql = "select * from e10_core_business.dbo." + tablename + " where id=" + requestid;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b2 = rs.executeSql(sql, poolname);

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

@ -69,7 +69,7 @@ public class ChuChaiShenQingNewAction extends BaseBean implements Action, EsbSer
try {
logger_fee0cda9.info(String.valueOf("ChuChaiShenQingNewAction request:" + request.getRequestid()));
String requestid = request.getRequestid();
String lastoperator = request.getLastoperator();
// String lastoperator = request.getLastoperator();
// TODO 有参构造 :new RecordSetDataSource("hr") 实例化方式改变,请检查是否有对应有参实现
RecordSet rdsd = I18nContextUtil.getBean(RecordSet.class);
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);

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

@ -87,7 +87,7 @@ public class DeleteSapGuidAction extends BaseBean implements Action, EsbServerle
String state = result[0];
String message = result[1];
// 把返回的值存到流程中
String sql = (new StringBuilder()).append("update e10_core_business.dbo.").append(tablename).append(" set sta ='").append(state).append("', meg = '").append(message).append("' where requestId = ").append(requestid).toString();
String sql = (new StringBuilder()).append("update e10_core_business.dbo.").append(tablename).append(" set sta ='").append(state).append("', meg = '").append(message).append("' where id = ").append(requestid).toString();
logger_5b06e417.info(String.valueOf((new StringBuilder()).append("logsql:").append(sql).toString()));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -77,7 +77,7 @@ public class EASIntermediarySyncAction extends BaseBean implements Action, EsbSe
String yxx = "";
if ("0".equals(sfba)) {
// 测试：47916，正式：44963
ywlx = BillFieldUtil.getselectName(map.get("YWLX"), "44963");
ywlx = BillFieldUtil.getselectName(map.get("YWLX"), "100003720000044963");
lxr = map.get("CWZJJGLXR");
lxfs = map.get("CWZJJGLXFS");
name = map.get("CWZJJGMC");
@ -91,7 +91,7 @@ public class EASIntermediarySyncAction extends BaseBean implements Action, EsbSe
}
} else {
// 测试：47923，正式：44993
ywlx = BillFieldUtil.getselectName(map.get("YWLXXZ"), "44993");
ywlx = BillFieldUtil.getselectName(map.get("YWLXXZ"), "100003720000044993");
lxr = map.get("LXRXZ");
lxfs = map.get("LXFSXZ");
name = map.get("CWZJJGMCXZ");

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

@ -48,17 +48,17 @@ public class EasWhiteListAction extends BaseBean implements Action, EsbServerles
BillFieldUtil unit = new BillFieldUtil();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
int id = 0;
String id = "";
try {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "select id from e10_core_business.dbo." + tablename + " where requestId='" + requestid + "'";
String sql = "select id from e10_core_business.dbo." + tablename + " where id='" + requestid + "'";
logger_b5430ca5.info("sql == "+sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname);
logger_b5430ca5.info("b == "+b);
while (rs.next()) {
id = rs.getInt("id");
id = rs.getString("id");
logger_b5430ca5.info("id == "+id);
}
} catch (Exception e) {
@ -185,7 +185,7 @@ public class EasWhiteListAction extends BaseBean implements Action, EsbServerles
result[3] = resultInfo.getSENDID();
result[4] = resultInfo.getSYSID();
RecordSet rs1 = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='" + result[0] + "',message='" + result[2] + "' where requestId='" + requestid + "'";
String sql = "update e10_core_business.dbo." + tablename + " set state='" + result[0] + "',message='" + result[2] + "' where id='" + requestid + "'";
logger_b5430ca5.info("sql = "+sql);
String poolname_x3 = CONN_TYPE.workflow.getType();

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

@ -63,7 +63,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
String wfid = requestInfo.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = requestInfo.getRequestManager().getBillTableName();
String sql = "select sfdy from e10_core_business.dbo." + tablename + " where requestId =" + requestID;
String sql = "select sfdy from e10_core_business.dbo." + tablename + " where id =" + requestID;
logger_59285be7.info("sql == " +sql);
String poolname_l4 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -76,7 +76,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
} else {
String poolname_r6 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql2 = "update e10_core_business.dbo." + tablename + " set sfdy = 0 where requestId = " + requestID;
String sql2 = "update e10_core_business.dbo." + tablename + " set sfdy = 0 where id = " + requestID;
logger_59285be7.info("sql2 == " +sql2);
boolean b = rs.executeSql(sql2, poolname_r6);
logger_59285be7.info("b == " +b);
@ -114,7 +114,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
}
logger_59285be7.info(String.valueOf(requestID + "TAXRATE:" + mDetailMap.get("TAXRATE")));
// 测试环境-63588,正式环境-68112
String selectitem = util.getselectName(mDetailMap.get("TAXRATE"), "68112");
String selectitem = util.getselectName(mDetailMap.get("TAXRATE"), "100003720000068112");
logger_59285be7.info(String.valueOf(requestID + "selectitem:" + selectitem));
String taxrate = selectitem.substring(0, selectitem.indexOf("%"));
if ("0".equals(taxrate)) {
@ -190,7 +190,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
String poolname_so = CONN_TYPE.workflow.getType();
// 失败
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql3 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where requestId = " + requestID;
String sql3 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where id = " + requestID;
logger_59285be7.info("sql3"+sql3);
boolean b = rs.executeSql(sql3, poolname_so);
logger_59285be7.info("b2"+b);
@ -202,7 +202,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
} else {
String poolname_b5 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql4 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where requestId = " + requestID;
String sql4 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where id = " + requestID;
logger_59285be7.info("sql4"+sql4);
boolean b = rs.executeSql(sql4, poolname_b5);
logger_59285be7.info("b3"+b);
@ -210,7 +210,7 @@ public class EasYszxfpApplyResultAction extends BaseBean implements Action, EsbS
} catch (Exception e) {
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql5 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where requestId = " + requestID;
String sql5 = "update e10_core_business.dbo." + tablename + " set sfdy = 1 where id = " + requestID;
logger_59285be7.info("sql5"+sql5);
boolean b = rs.executeSql(sql5, poolname);
logger_59285be7.info("b4"+b);

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

@ -97,7 +97,7 @@ public class HTGD_MES_NonStandardAction extends BaseBean implements Action, EsbS
String[] ret = service.returnRes(req);
if ("E".equals(ret[0])) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestId;
String poolname_ar = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname_ar);
@ -107,7 +107,7 @@ public class HTGD_MES_NonStandardAction extends BaseBean implements Action, EsbS
} catch (Exception exception) {
logger_c8d15d65.info(String.valueOf("HTGD_MES_NonStandardAction--" + requestId + "执行出错：" + exception.getMessage()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where id=" + requestId;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname);

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

@ -85,7 +85,7 @@ public class HTGD_MES_SC03Action extends BaseBean implements Action, EsbServerle
JSONObject mjson = new JSONObject();
RecordSet sqbmrs = I18nContextUtil.getBean(RecordSet.class);
// 获取申请部门审核记录
String sql = "select operatedatetime,operatetime,b.username from e10_core_business.dbo.wfc_requestlog a " + "INNER JOIN employee b on a.creator = b.id " + "where requestid = " + requestId + // 申请部门一级人员 测试环境-19915 正式环境-29618
String sql = "select operatedatetime,operatetime,b.username from e10_core_business.dbo.wfc_requestlog a " + "INNER JOIN employee b on a.creator = b.id " + "where id = " + requestId + // 申请部门一级人员 测试环境-19915 正式环境-29618
" and nodeid = 29618";
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -100,7 +100,7 @@ public class HTGD_MES_SC03Action extends BaseBean implements Action, EsbServerle
mjson.put("sqbmyj", sqbmyj);
}
// 获取受理部门审核记录
String sql_slbm = "select operatedatetime,operatetime,b.username from e10_core_business.dbo.wfc_requestlog a " + "INNER JOIN employee b on a.creator = b.id " + "where requestid = " + requestId + // 受理部门一级人员 测试环境-19916 正式环境-29619
String sql_slbm = "select operatedatetime,operatetime,b.username from e10_core_business.dbo.wfc_requestlog a " + "INNER JOIN employee b on a.creator = b.id " + "where id = " + requestId + // 受理部门一级人员 测试环境-19916 正式环境-29619
" and nodeid = 29619";
String poolname_dk = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -166,7 +166,7 @@ public class HTGD_MES_SC03Action extends BaseBean implements Action, EsbServerle
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_ig = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b2 = rs.executeSql("update e10_core_business.dbo" + tablename + " set state='E',message='" + ret[1] + "' where requestId=" + requestId, poolname_ig);
boolean b2 = rs.executeSql("update e10_core_business.dbo" + tablename + " set state='E',message='" + ret[1] + "' where id=" + requestId, poolname_ig);
logger_1ea91e04.info("b2 -----"+ b2);
}
} catch (Exception exception) {

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

@ -120,7 +120,7 @@ public class HTGD_MES_SpeedFixAction extends BaseBean implements Action, EsbServ
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set state='E',message='" + ret[1] + "' where requestId=" + requestId, poolname);
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set state='E',message='" + ret[1] + "' where id=" + requestId, poolname);
logger_d0d39a5f.info(String.valueOf(requestId + "-HTGD_MES_SpeedFixAction update:" + b));
}
} catch (Exception exception) {

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

@ -90,7 +90,7 @@ public class HTGD_MES_TDLApproveActivon extends BaseBean implements Action, EsbS
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestId=" + requestId, poolname);
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestId, poolname);
if (b) {
logger_674a8052.info(String.valueOf(requestId + "-HTGD_MES_TDLApproveActivon update success"));
} else {

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

@ -368,7 +368,7 @@ public class HTGD_SW_OaBackAction extends BaseBean implements Action, EsbServerl
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_e4a191d3.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -145,7 +145,7 @@ public class HTWLJiaBanAction extends BaseBean implements Action, EsbServerlessR
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname_ux = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set jbdtzzdksj='" + swdkjl + "',jbdtzwdksj='" + xwdkjl + "' where requestId=" + requestid, poolname_ux);
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set jbdtzzdksj='" + swdkjl + "',jbdtzwdksj='" + xwdkjl + "' where id=" + requestid, poolname_ux);
logger_983b20e3.info(String.valueOf("HTWLJiaBanAction update:" + b));
} else {
request.getRequestManager().setMessageid("Error");

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

@ -75,7 +75,7 @@ public class Iur_syncProject extends BaseBean implements Action, EsbServerlessRp
logger_72949ae6.info(String.valueOf(requestid + "--Iur_syncProject--info:[" + result[0] + "|" + result[1] + "]"));
String poolname_9l = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set status='" + result[0] + "',message='" + result[1] + "' where requestId=" + requestid, poolname_9l);
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set status='" + result[0] + "',message='" + result[1] + "' where id=" + requestid, poolname_9l);
if (b) {
logger_72949ae6.info(String.valueOf(requestid + "--Iur_syncProject--update success"));
} else {
@ -85,7 +85,7 @@ public class Iur_syncProject extends BaseBean implements Action, EsbServerlessRp
logger_72949ae6.info(String.valueOf("Iur_syncProject--error:" + e.toString()));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set status='E',message='" + e.toString() + "' where requestId=" + requestid, poolname);
boolean b = rs.executeSql("update e10_core_business.dbo." + tablename + " set status='E',message='" + e.toString() + "' where id=" + requestid, poolname);
if (b) {
logger_72949ae6.info(String.valueOf(requestid + "--Iur_syncProject--update success"));
} else {

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

@ -168,7 +168,7 @@ public class K3PORequestAction extends BaseBean implements Action, EsbServerless
String message = response.getMessage();
String cgdddjbh = Util.null2String(response.getFBillNO());
logger_7396c45f.info(String.valueOf(requestID + "result:code:" + code + " result:" + result + " message:" + message + " cgdddjbh:" + cgdddjbh));
String sql = "update e10_core_business.dbo." + tableName + " set cgdddjbh='" + cgdddjbh + "' where requestid=" + requestID;
String sql = "update e10_core_business.dbo." + tableName + " set cgdddjbh='" + cgdddjbh + "' where id=" + requestID;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname);

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

@ -66,7 +66,7 @@ public class LastOperateAction extends BaseBean implements Action, EsbServerless
// String tablename = wkbl.getTablename(wkfl.getFormId(workflowid));
String tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set spr = '" + spr + "' where requestId = " + reid;
String logsql = "update e10_core_business.dbo." + tablename + " set spr = '" + spr + "' where id = " + reid;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs1.executeSql(logsql, poolname);

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

@ -64,8 +64,8 @@ public class NeiBuDiaoDongAction implements Action, EsbServerlessRpcRemoteInterf
String workflowid = request.getWorkflowid();
String maintable = "";
// String DealerID = "";
String sql = "select b.tablename from wfp_base a,form b where a.formid = b.id and a.id = " + workflowid;
String poolname = CONN_TYPE.workflow.getType();
// String sql = "select b.tablename from wfp_base a,form b where a.formid = b.id and a.id = " + workflowid;
// String poolname = CONN_TYPE.workflow.getType();
// RecordSetDataSource rsds = new RecordSetDataSource("eHR_test");
// rsds.executeSql("select ???GUID AS YGID from ht_psnaccount where ??????? ="+lastoperator);
// rsds.next();
@ -77,11 +77,11 @@ public class NeiBuDiaoDongAction implements Action, EsbServerlessRpcRemoteInterf
// int departmentId = Util.getIntValue(rs2.getString("id"));
/* String creater = rs2.getString("departmentmark") + "_" + rs2.getString("lastname");
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
boolean b = rs.executeSql(sql, poolname);
logger_1103b3f3.info("b--" + b);
while (rs.next()) {
maintable = rs.getString("tablename");
}
// boolean b = rs.executeSql(sql, poolname);
// logger_1103b3f3.info("b--" + b);
// while (rs.next()) {
// maintable = rs.getString("tablename");
// }
// ?????????
String KDCRQ = "";
// ????

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

@ -120,7 +120,7 @@ public class OA_CMZ_Action extends BaseBean implements Action, EsbServerlessRpcR
BillFieldUtil unit = new BillFieldUtil();
// tablename = unit.getTablename(wfid);
tablename = requestinfo.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set status ='" + sta + "', message = '" + meg + "' where requestId = " + requestid;
String logsql = "update e10_core_business.dbo." + tablename + " set status ='" + sta + "', message = '" + meg + "' where id = " + requestid;
logger_44f7fe13.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -129,7 +129,7 @@ public class OaCrmZDYWFPAction extends BaseBean implements Action, EsbServerless
requestInfo.getRequestManager().setMessagecontent("CRM返回错误信息：" + srMessage);
} else {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set jssqdh='" + goldenNum + "' where requestId=" + requestID;
String sql = "update e10_core_business.dbo." + tablename + " set jssqdh='" + goldenNum + "' where id=" + requestID;
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname);

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

@ -523,7 +523,7 @@ public class OaMesNewMaterialCertificationAction extends BaseBean implements Act
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_7ab25493.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -405,7 +405,7 @@ public class OaMesNewMaterialProjectAction extends BaseBean implements Action, E
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_fedc85f2.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -439,7 +439,7 @@ public class OaMesNewMaterialTSBGAction extends BaseBean implements Action, EsbS
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_f52b61d7.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -299,7 +299,7 @@ public class OaMesNewMaterialTestAction extends BaseBean implements Action, EsbS
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_908d3105.info(String.valueOf("logsql:" + logsql));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String poolname = CONN_TYPE.workflow.getType();

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

@ -105,7 +105,7 @@ public class OaSrmCheckMallRefuseAction extends BaseBean implements Action, EsbS
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_6576dfe9.info(String.valueOf(requestId + " logsql:" + logsql));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -146,7 +146,7 @@ public class OaSrmCheckPriceRefuseAction extends BaseBean implements Action, Esb
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
tablename = request.getRequestManager().getBillTableName();
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where requestId = " + requestId;
String logsql = "update e10_core_business.dbo." + tablename + " set sta ='" + sta + "', meg = '" + meg + "' where id = " + requestId;
logger_80563c68.info(String.valueOf("logsql:" + logsql));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -106,7 +106,7 @@ public class OaWmsReturnAction extends BaseBean implements Action, EsbServerless
return WeaResult.fail(500, "执行失败", getResultMapForAction(weaverResultMap, "result", Action.FAILURE_AND_CONTINUE, requestinfo.getRequestManager()));
}
} catch (Exception e) {
sql = "update e10_core_business.dbo." + tableName + " set state='E',message='" + e.toString() + "' where requestId=" + requestid;
sql = "update e10_core_business.dbo." + tableName + " set state='E',message='" + e.toString() + "' where id=" + requestid;
logger_824c0f2.info("sql--"+sql);
String poolname_bm = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -121,7 +121,7 @@ public class OperateMesAccountAction extends BaseBean implements Action, EsbServ
logger_4057422d.info(String.valueOf(requestId + "----" + gh + str + "成功"));
}
}
String sql = "update e10_core_business.dbo." + tablename + " set status='" + stat + "',message='" + message + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set status='" + stat + "',message='" + message + "' where id=" + requestId;
logger_4057422d.info("sql" + sql);
String poolname_cc = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -131,7 +131,7 @@ public class OperateMesAccountAction extends BaseBean implements Action, EsbServ
} catch (Exception e) {
stat = "E";
message = e.toString();
String errorLog = "update e10_core_business.dbo." + tablename + " set status='" + stat + "',message='" + message + "' where requestId=" + requestId;
String errorLog = "update e10_core_business.dbo." + tablename + " set status='" + stat + "',message='" + message + "' where id=" + requestId;
logger_4057422d.info("errorLog" + errorLog);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -70,7 +70,7 @@ public class SY_WLPS_NEW_RETURNAction extends BaseBean implements Action, EsbSer
String ycms = map.get("YCMS");
// 缺陷分类
String qxfl = map.get("QXFL");
String qxfl_name = getselectNameByCol("qxfl", workFlowId, qxfl);
String qxfl_name = util.getselectNameByCol("qxfl", workFlowId, qxfl);
// 缺陷代码
String qxdm = map.get("QXDM");
String uuid = UUID.randomUUID().toString();
@ -98,7 +98,7 @@ public class SY_WLPS_NEW_RETURNAction extends BaseBean implements Action, EsbSer
String[] ret = service.returnRes(req);
if ("E".equals(ret[0])) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestId;
String poolname_9c = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs.executeSql(sql, poolname_9c);
@ -109,7 +109,7 @@ public class SY_WLPS_NEW_RETURNAction extends BaseBean implements Action, EsbSer
} catch (Exception exception) {
logger_882eb0b2.error(String.valueOf("SY_WLPS_NEW_RETURNAction--" + requestId + "执行出错：" + exception.getMessage()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where id=" + requestId;
logger_882eb0b2.info("sql--" + sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -125,23 +125,7 @@ public class SY_WLPS_NEW_RETURNAction extends BaseBean implements Action, EsbSer
}
}
/**
* 通过数据库字段名获取选择框 显示名
*
* @return
*/
public static String getselectNameByCol(String fieldname, String workflowid, String selectvalue) {
String name = "";
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_p2 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = recordSet.executeSql("select c.name from e10_common.dbo.wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue, poolname_p2);
logger_882eb0b2.info("b--" + b);
if (recordSet.next()) {
name = recordSet.getString("selectname");
}
return name;
}
Map<String, Object> getResultMapForAction(Map<String, Object> map, String key, Object value, RequestManager requestManager) {
if (key != null && !key.isEmpty()) {

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

@ -92,7 +92,7 @@ public class SY_WLPS_RETURNNewAction extends BaseBean implements Action, EsbServ
String[] ret = service.returnRes(req);
if ("E".equals(ret[0])) {
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestId;
logger_4dd7c639.info("sql--" + sql);
String poolname_2y = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -104,7 +104,7 @@ public class SY_WLPS_RETURNNewAction extends BaseBean implements Action, EsbServ
} catch (Exception exception) {
logger_4dd7c639.info(String.valueOf("SY_WLPS_RETURNAction--" + requestId + "执行出错：" + exception.getMessage()));
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where requestId=" + requestId;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + exception.getMessage() + "' where id=" + requestId;
logger_4dd7c639.info("sql--" + sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -64,30 +64,30 @@ public class YongGongXuQiuAction implements Action, EsbServerlessRpcRemoteInterf
try {
log.info("do action on request:" + request.getRequestid());
String requestid = request.getRequestid();
String lastoperator = request.getLastoperator();
String creater = request.getCreatorid();
// String lastoperator = request.getLastoperator();
// String creater = request.getCreatorid();
RecordSet rs = I18nContextUtil.getBean(RecordSet.class);
RecordSet rs2 = I18nContextUtil.getBean(RecordSet.class);
String workflowid = request.getWorkflowid();
String maintable = "";
String sql = "select b.tablename from e10_common.dbo.wfp_base a,e10_common.dbo.form b where a.formid = b.id and a.id = " + workflowid;
logger_42aadd27.info("getMainTableInfo sql = " + sql);
String createsqlString = "select id from eteams.dbo.employee as hrmresource where lastname ='" + creater + "'";
String poolname = CONN_TYPE.workflow.getType();
// RecordSet rs2 = I18nContextUtil.getBean(RecordSet.class);
// String workflowid = request.getWorkflowid();
// String maintable = "";
// String sql = "select b.tablename from e10_common.dbo.wfp_base a,e10_common.dbo.form b where a.formid = b.id and a.id = " + workflowid;
// logger_42aadd27.info("getMainTableInfo sql = " + sql);
// String createsqlString = "select id from eteams.dbo.employee as hrmresource where lastname ='" + creater + "'";
// String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
boolean b = rs2.executeSql(createsqlString, poolname);
logger_42aadd27.info("getMainTableInfo rs2.executeSql = " + b);
rs2.next();
String createrId = rs2.getString("id");
String poolname_hy = CONN_TYPE.workflow.getType();
// boolean b = rs2.executeSql(createsqlString, poolname);
// logger_42aadd27.info("getMainTableInfo rs2.executeSql = " + b);
// rs2.next();
// String createrId = rs2.getString("id");
// String poolname_hy = CONN_TYPE.workflow.getType();
// int departmentId = Util.getIntValue(rs2.getString("id"));
/* String creater = rs2.getString("departmentmark") + "_" + rs2.getString("lastname");
TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源*/
boolean b1 = rs.executeSql(sql, poolname_hy);
logger_42aadd27.info("getMainTableInfo rs.executeSql = " + b1);
while (rs.next()) {
maintable = rs.getString("tablename");
}
// boolean b1 = rs.executeSql(sql, poolname_hy);
// logger_42aadd27.info("getMainTableInfo rs.executeSql = " + b1);
// while (rs.next()) {
// maintable = rs.getString("tablename");
// }
// 需求部门
String XQBM = "";
// String GWXL = "";//岗位序列

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

@ -91,7 +91,7 @@ public class ZOA_CCSQ_AQJB_Action extends BaseBean implements Action, EsbServerl
sqr = "0";
}
if (!tablename.equals("")) {
logsql = "update e10_core_business.dbo." + tablename + " set aqjb = (select max(seclevel) from employee as HrmResource where id in (" + sqr + ") or id in (" + ccsxry + ") ) where requestId = " + reid;
logsql = "update e10_core_business.dbo." + tablename + " set aqjb = (select max(seclevel) from employee as HrmResource where id in (" + sqr + ") or id in (" + ccsxry + ") ) where id = " + reid;
logger_31bb84de.info(String.valueOf("logsql:" + logsql));
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -132,7 +132,9 @@ public class ZOA_MM_PR_CREATE_SCXAction extends BaseBean implements Action, EsbS
}
// 采购组
if (nameq.equals("CGZ")) {
cgz = unit.getselectName(valueq, "30110").trim();
// cgz = unit.getselectName(valueq, "30110").trim();
cgz = unit.getselectName(valueq, "100003720000030110").trim();
if (cgz.length() > 1) {
// 采购组
prdetail[j][4] = cgz.substring(0, 3);

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

@ -132,7 +132,7 @@ public class ZOA_MM_PR_CREATE_WWJGAction extends BaseBean implements Action, Esb
}
// 采购组
if (nameq.equals("CGZ")) {
cgz = unit.getselectName(valueq, "30137").trim();
cgz = unit.getselectName(valueq, "100003720000030137").trim();
if (cgz.length() > 1) {
// 采购组
prdetail[j][4] = cgz.substring(0, 3);

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

@ -126,7 +126,7 @@ public class ZOA_MM_PR_CREATE_YFAction extends BaseBean implements Action, EsbSe
}
// 采购组
if (nameq.equals("CGZ")) {
cgz = unit.getselectName(valueq, "57815").trim();
cgz = unit.getselectName(valueq, "100003720000063718").trim(); //57815 -> 63718
if (cgz.length() > 1) {
// 采购组
prdetail[j][4] = cgz.substring(0, 3);

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

@ -166,6 +166,10 @@ public class ZOA_MM_PR_CREATE_ZJGC_ZjAction extends BaseBean implements Action,
String tablename = "";
String wfid = request.getWorkflowid();
// tablename = unit.getTablename(wfid);
logger_518ea046.info(String.valueOf("prtype == " + prtype));
logger_518ea046.info(String.valueOf("prdetail == " + prdetail));
tablename = request.getRequestManager().getBillTableName();
ZOA_MM_PR_CREATE_ZJGC po = new ZOA_MM_PR_CREATE_ZJGC();
String[] fhz = po.Getexecute(prtype, prdetail);

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

@ -136,7 +136,7 @@ public class ZOA_MM_PR_RELEASEAction extends BaseBean implements Action, EsbServ
Object[] obj1 = new Object[2];
obj1[0] = e_status;
obj1[1] = e_message;
String sql = "update " + tablename + " set status = ? , message = ? where requestid = " + requestId;
String sql = "update " + tablename + " set status = ? , message = ? where id = " + requestId;
logger_41a94d2d.info(String.valueOf("ZOA_MM_PR_RELEASEAction ----- sql = " + sql));
String poolname_sb = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -504,7 +504,7 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
logUtil.setJkzt("1");
logUtil.insertLog();
str = Message;
String sql1 = "update e10_core_business.dbo." + tablename + " set message = isnull(cast(message as varchar(8000)),'') + '" + Message + "' where requestId = " + reid;
String sql1 = "update e10_core_business.dbo." + tablename + " set message = isnull(cast(message as varchar(8000)),'') + '" + Message + "' where id = " + reid;
logger_f5224b91.info(String.valueOf("sql1:" + sql1));
String poolname = CONN_TYPE.workflow.getType();
@ -655,7 +655,7 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
message = "--携程接口回写说明--ReturnStatus:" + strreturn[0] + "；ReturnERRORMessage:" + strreturn[1] + "；ReturnErrorCode:" + strreturn[2];
message = message.replace("'", "’");
if (!tablename.equals("")) {
String logsql2 = "update e10_core_business.dbo." + tablename + " set status ='" + status + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where requestId = " + reid;
String logsql2 = "update e10_core_business.dbo." + tablename + " set status ='" + status + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where id = " + reid;
logger_f5224b91.info(String.valueOf("logsql2:" + logsql2));
String poolname_t9 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -732,7 +732,7 @@ public class ZOA_SL_GWCC_Action extends BaseBean implements Action, EsbServerles
}
message = "--同程接口回写说明--ReturnStatus:" + dTtrip[0] + "；ReturnMessage:" + dTtrip[1] + "；出差单号:" + dTtrip[2];
message = message.replace("'", "’");
String logsql4 = "update e10_core_business.dbo." + tablename + " set status ='" + dTtrip[0] + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where requestId = " + reid;
String logsql4 = "update e10_core_business.dbo." + tablename + " set status ='" + dTtrip[0] + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where id = " + reid;
logger_f5224b91.info(String.valueOf("logsql4:" + logsql4));
String poolname_ot = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -585,7 +585,7 @@ public class ZOA_SL_GW_Action extends BaseBean implements Action, EsbServerlessR
String[] dTtrip = dTtripService.optForDTtrip(map);
message = "--同程接口回写说明--ReturnStatus:" + dTtrip[0] + "；ReturnMessage:" + dTtrip[1] + "；出差单号:" + dTtrip[2];
message = message.replace("'", "’");
String logsql4 = "update " + tablename + " set status ='" + dTtrip[0] + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where requestId = " + reid;
String logsql4 = "update " + tablename + " set status ='" + dTtrip[0] + "', message = isnull(cast(message as varchar(8000)),'') + '" + message + "' where id = " + reid;
logger_39ae6ef1.info(String.valueOf("logsql4:" + logsql4));
String poolname_2f = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -101,7 +101,7 @@ public class ZOEM_MATRIAL_PRICE_Action extends BaseBean implements Action, EsbSe
BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid;
logger_8aa7358c.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();

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

@ -158,7 +158,7 @@ public class ZOEM_PRICE_DIFFERENCE_RATE_Action extends BaseBean implements Actio
BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid;
log.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -100,7 +100,7 @@ public class ZOEM_PROCESSING_CHARGE_Action extends BaseBean implements Action, E
BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid;
logger_9b3f3cb8.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();

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

@ -147,7 +147,7 @@ public class ZSRM_PUR_INFO_Action extends BaseBean implements Action, EsbServerl
BillFieldUtil util = new BillFieldUtil();
// String tablename = util.getTablename(wfid);
String tablename = requestinfo.getRequestManager().getBillTableName();
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + state + "',message='" + sb.toString() + "' where id=" + requestid;
logger_78218549.info("sql -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -101,7 +101,7 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
ZSRM_PUR_INFO info = new ZSRM_PUR_INFO();
String[] ret = info.Getexecute(str);
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]"));
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestid;
logger_da6b5da2.info("sql -----"+ sql);
String poolname_mm = CONN_TYPE.workflow.getType();
@ -114,7 +114,7 @@ public class ZSRM_PUR_INFO_GY107_Action extends BaseBean implements Action, EsbS
logger_da6b5da2.info(String.valueOf("ZSRM_PUR_INFO_GY107_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString());
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where id=" + requestid;
logger_da6b5da2.info("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -102,7 +102,7 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS
ZSRM_PUR_INFO info = new ZSRM_PUR_INFO();
String[] ret = info.Getexecute(str);
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-return-" + requestid + "-[" + ret[0] + "," + ret[1] + "]"));
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='" + ret[0] + "',message='" + ret[1] + "' where id=" + requestid;
logger_8fd2ca4a.info("sql -----"+ sql);
String poolname_r3 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
@ -114,7 +114,7 @@ public class ZSRM_PUR_INFO_GY132_Action extends BaseBean implements Action, EsbS
logger_8fd2ca4a.info(String.valueOf("ZSRM_PUR_INFO_GY132_Action-error-" + requestid + "-[" + e.toString() + "]"));
requestinfo.getRequestManager().setMessageid("ERROR");
requestinfo.getRequestManager().setMessagecontent("调用SAP接口校验数据出错：" + e.toString());
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where requestid=" + requestid;
String sql = "update e10_core_business.dbo." + tablename + " set state='E',message='" + e.toString() + "' where id=" + requestid;
logger_8fd2ca4a.info("sql2 -----"+ sql);
String poolname = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源

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

@ -111,7 +111,7 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
// 核算系统
String hsxt = mMap.get("HSXT");
// getHSXTName(hsxt);
String hsxtName = getselectNameByCol("hsxt", workFlowId, hsxt);
String hsxtName = unit.getselectNameByCol("hsxt", workFlowId, hsxt);
// 申请人
String sqr = mMap.get("SQR");
String sqrcode = "";
@ -285,28 +285,6 @@ public class ZZ_GDFileUploadAction extends BaseBean implements Action, EsbServer
}
}
/**
* 通过数据库字段名获取选择框 显示名
*
* @param
* @param
* @return
*/
public static String getselectNameByCol(String fieldname, String workflowid, String selectvalue) {
String name = "";
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_48 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select c.name from e10_common.dbo.wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue;
logger_b14cb5d0.info("getselectNameByCol sql = " + sql );
boolean b1 = recordSet.executeSql(sql, poolname_48);
logger_b14cb5d0.info("getselectNameByCol flag = " + b1 );
if (recordSet.next()) {
name = recordSet.getString("selectname");
logger_b14cb5d0.info("getselectNameByCol name = " + name );
}
return name;
}
private InputStream getFile(String filerealpath, String iszip) throws Exception {
ZipInputStream zin = null;

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

@ -106,7 +106,7 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
// 核算系统
String hsxt = mMap.get("HSXT");
// getHSXTName(hsxt);
String hsxtName = getselectNameByCol("hsxt", workFlowId, hsxt);
String hsxtName = unit.getselectNameByCol("hsxt", workFlowId, hsxt);
// 申请人
String sqr = mMap.get("SQR");
String sqrcode = "";
@ -288,30 +288,7 @@ public class ZZ_Ten_GDFileUploadAction extends BaseBean implements Action, EsbSe
return WeaResult.success(getResultMapForAction(weaverResultMap, "result", WeaResult.fail(500, "执行异常", getResultMapForAction(weaverResultMap, "result", e.getMessage(), requestInfo.getRequestManager())), requestInfo.getRequestManager()));
}
}
/**
* 通过数据库字段名获取选择框 显示名
*
* @param
* @param
* @return
*/
public static String getselectNameByCol(String fieldname, String workflowid, String selectvalue) {
String name = "";
RecordSet recordSet = I18nContextUtil.getBean(RecordSet.class);
String poolname_w2 = CONN_TYPE.workflow.getType();
// TODO E10执行sql方法第二参数必须指定源，默认使用流程源，单体客户无需修改，微服务/组合客户需根据查询表所属服务切换源，或使用外部数据源
String sql = "select c.name from e10_common.dbo.wfp_base a " + "INNER JOIN e10_common.dbo.form_field b on a.formid=b.form_id " + "INNER JOIN e10_common.dbo.field_option c on b.id=c.field_id " + "where b.fieldname='" + fieldname + "' and a.id=" + workflowid + " and c.selectvalue=" + selectvalue;
logger_8ab26152.info("getselectNameByCol sql = " + sql);
boolean b1 = recordSet.executeSql(sql, poolname_w2);
logger_8ab26152.info("getselectNameByCol flag = " + b1);
if (recordSet.next()) {
name = recordSet.getString("selectname");
}
logger_8ab26152.info("getselectNameByCol name = " + name);
return name;
}
private InputStream getFile(String filerealpath, String iszip) throws Exception {
ZipInputStream zin = null;
InputStream imagefile = null;

Write Preview
Loading…
Cancel
Save