在新公司接了个配置泛微流程触发的活。因为泛微的官方文档并没有详细的操作指引，在测试环境配置之后、要触发的流程可以手工提交，但是触发一直不成功。简单记录下业务场景和其他处理信息，以供参考。
应用版本
目前使用了泛微 E8 （8.100.0531）的版本。2018年上线的老系统了。
业务场景
目前使用的泛微 OA 启用了“会议”应用。我们需要定时抓取会议状态为“退回”和“取消”的会议、并将每一条记录自动转化为一个流程发送出去。我们选取了会议应用的 Meeting 表（会议管理表详细信息），并选择 “meetingstatus” 字段作为会议状态的来源。通过文档得知：当会议状态为“退回”，字段取值 3 ；当会议状态为“取消”，字段取值 4 。
设置的自定义表单 / 流程如下图所示, 目前手工提交 / 流转均正常操作：
处理步骤
首先配置了回写部分，但是不成功。根据 2012 - 2016 年的资料，文档是这么记录的。
1:该流程自动触发时，将根据外部主表条件搜索外部主表，有多少条记录即触发多少条流程；
流程主字段的值来源于外部主表，而每条流程的各明细值将分别根据明细表条件搜索明细表
得到的结果进行赋值；主表中必须包含主键(默认为id)
2:条件以“where”开头，如：“where fieldname1=1 and fieldname2='value2'”；
回写设置以“set”开头，如：“set flag=1,isok=true”，FtriggerFlag和requestid字段
自动更新，不能在此设置；
3:流程触发时如果需要回写外部主表，需要设置是否回写、流程ID字段、标志字段、标志字段
需要回写的值(字符型)，回写数据时，默认标志字段=1：表示已触发，
流程ID字段=0：表示流程创建人对应的外部字段值为空，
流程ID字段=-1：表示外部字段保存的人员信息在oa中不存在，流程ID
4:外部明细表数据如需与主表数据关联，可将外部明细表条件设置为
“where '明细表.字段'='主表.字段'”。非常 ... 语焉不详。我怀疑当年这个屌茅甚至喝大了。:)
配置数次无果之后，泛微的工程师提醒我找下日志。根据操作日期，我分别在服务器下载了泛微应用目录下的 ecology/log/integration/integration.log 、 ecology/log/ecology 、Resin/log/stderr.log 、Resin/log/stdout.log 这几个文件。
打开 integration.log 文件。发现触发的过程报错、 提示 CREATER 在外部表不存在。
2023-08-18 00:00:14,812 INFO [Thread:AutoWorlflowThread] weaver.general.AutoWorlflowThread.saveTrigLog() - saveTrigLog 记录日志 sql : update outerdatawfdetail set requestid=-1 where mainid=11 and workflowid=466 and outermaintable = 'Meeting' and keyfieldvalue='141'
2023-08-18 00:00:14,827 INFO [Thread:AutoWorlflowThread] weaver.general.AutoWorlflowThread.doActiveOutDataWF() - 检查是否已触发 : select 1 from outerdatawfdetail where workflowid=466 and mainid=11 and keyfieldvalue='142' and outermaintable = 'Meeting' and requestid>0
2023-08-18 00:00:14,827 INFO [Thread:AutoWorlflowThread] weaver.general.AutoWorlflowThread.doActiveOutDataWF() - ===================SQL:select * from outerdatawfsetdetail where (wffieldid=-1 or wffieldid=-2) and mainid=11 order by wffieldid
2023-08-18 00:00:14,827 ERROR [Thread:AutoWorlflowThread] weaver.general.AutoWorlflowThread.doActiveOutDataWF() - THE CREATER IN THE OUTER TABLE IS NOT EXIST!
于是找到应用的源代码。
package weaver.general;
import java.io.Writer;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Iterator;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import oracle.sql.CLOB;
import weaver.conn.ConnStatement;
import weaver.conn.RecordSet;
import weaver.conn.RecordSetDataSource;
import weaver.hrm.resource.ResourceComInfo;
import weaver.integration.logging.Logger;
import weaver.integration.logging.LoggerFactory;
import weaver.system.SysCreateWF;
import weaver.system.SysUpdateWF;
import weaver.system.ThreadWork;
import weaver.workflow.automatic.automaticconnect;
import weaver.workflow.dmlaction.DBTypeUtil;
import weaver.workflow.request.RequestManager;
import weaver.workflow.workflow.WorkflowComInfo;
import weaver.workflow.workflow.WorkflowVersion;
public class AutoWorlflowThread extends BaseBean implements ThreadWork {
private Logger newlog = LoggerFactory.getLogger(AutoWorlflowThread.class);
public void doThreadWork() {
Thread.currentThread().setUncaughtExceptionHandler(new AutoWorkFlowThreadExceptionHandler());
doActiveOutDataWF();
}
public void doActiveOutDataWF() {
automaticconnect automaticconnect = new automaticconnect();
Connection connection = null;
String str = "";
try {
WorkflowComInfo workflowComInfo = new WorkflowComInfo();
ResourceComInfo resourceComInfo = new ResourceComInfo();
SysCreateWF sysCreateWF = new SysCreateWF();
RecordSet recordSet1 = new RecordSet();
RecordSet recordSet2 = new RecordSet();
ArrayList<String> arrayList1 = new ArrayList();
ArrayList<String> arrayList2 = new ArrayList();
ArrayList<String> arrayList3 = new ArrayList();
ArrayList<String> arrayList4 = new ArrayList();
ArrayList<String> arrayList5 = new ArrayList();
ArrayList<String> arrayList6 = new ArrayList();
ArrayList<String> arrayList7 = new ArrayList();
ArrayList<String> arrayList8 = new ArrayList();
ArrayList<String> arrayList9 = new ArrayList();
ArrayList<String> arrayList10 = new ArrayList();
ArrayList<String> arrayList11 = new ArrayList();
ArrayList<String> arrayList12 = new ArrayList();
ArrayList<String> arrayList13 = new ArrayList();
ArrayList<String> arrayList14 = new ArrayList();
ArrayList<String> arrayList15 = new ArrayList();
ArrayList<String> arrayList16 = new ArrayList();
ArrayList<String> arrayList17 = new ArrayList();
WorkflowVersion workflowVersion = new WorkflowVersion();
recordSet1.executeSql("select * from outerdatawfset");
while (recordSet1.next()) {
String str1 = Util.null2String(recordSet1.getString("id"));
String str2 = Util.null2String(recordSet1.getString("workflowid"));
String str3 = Util.null2String(recordSet1.getString("datasourceid"));
String str4 = Util.null2String(recordSet1.getString("outermaintable"));
String str5 = Util.null2String(recordSet1.getString("keyfield"));
String str6 = Util.null2String(recordSet1.getString("datarecordtype"));
String str7 = Util.null2String(recordSet1.getString("requestid"));
String str8 = Util.null2String(recordSet1.getString("FTriggerFlag"));
String str9 = Util.null2String(recordSet1.getString("FTriggerFlagValue"));
String str10 = Util.null2String(recordSet1.getString("outermainwhere"));
String str11 = Util.null2String(recordSet1.getString("successback"));
String str12 = Util.null2String(recordSet1.getString("failback"));
String str13 = Util.null2String(recordSet1.getString("outerdetailtables"));
String str14 = Util.null2String(recordSet1.getString("outerdetailwheres"));
String str15 = Util.null2String(recordSet1.getString("isnextnode"));
String str16 = Util.null2String(recordSet1.getString("isupdatewfdata"));
String str17 = Util.null2String(recordSet1.getString("isupdatewfdataField"));
arrayList1.add(str1);
arrayList2.add(str2);
arrayList3.add(str3);
arrayList4.add(str4);
arrayList15.add(str15);
arrayList16.add(str16);
arrayList17.add(str17);
arrayList5.add(str5);
arrayList6.add(str6);
arrayList7.add(str7);
arrayList8.add(str8);
arrayList9.add(str9);
arrayList10.add(str10);
arrayList11.add(str11);
arrayList12.add(str12);
arrayList13.add(str13);
arrayList14.add(str14);
}
RecordSet recordSet3 = new RecordSet();
for (byte b = 0; b < arrayList1.size(); b++) {
try {
String str1 = arrayList1.get(b);
recordSet3.executeSql("select mainid from outerdatawfsetdetail where mainid=" + str1);
if (!recordSet3.next()) {
this.newlog.error("+ str1 + ");
} else {
String str2 = arrayList2.get(b);
String str3 = WorkflowVersion.getActiveVersionWFID(str2);
String str4 = arrayList3.get(b);
if (!str4.equals("")) {
connection = automaticconnect.getConnection("datasource." + str4);
if (connection != null && !connection.isClosed()) {
str = automaticconnect.getDBType();
Statement statement1 = connection.createStatement();
Statement statement2 = connection.createStatement();
ResultSet resultSet = null;
String str5 = arrayList4.get(b);
String str6 = arrayList5.get(b);
String str7 = arrayList6.get(b);
String str8 = arrayList7.get(b);
String str9 = arrayList8.get(b);
String str10 = arrayList9.get(b);
String str11 = arrayList15.get(b);
String str12 = arrayList16.get(b);
String str13 = arrayList17.get(b);
if ("".equals(str10))
str10 = "1";
String str14 = arrayList10.get(b);
String str15 = arrayList11.get(b);
String str16 = arrayList12.get(b);
String str17 = arrayList13.get(b);
String str18 = arrayList14.get(b);
RecordSetDataSource recordSetDataSource = new RecordSetDataSource();
Map map = new HashMap<Object, Object>();
if (!str4.equals(""))
map = recordSetDataSource.getAllColumnWithTypes(str4, str5);
String str19 = "";
if (str.toLowerCase().indexOf("oracle") > -1) {
str19 = "select 1 from user_tables a where a.TABLE_NAME = upper('" + str5 + "') union ALL select 1 from user_views b where b.VIEW_NAME = upper('" + str5 + "')";
} else if (str.toLowerCase().indexOf("sqlserver") > -1 || str.toLowerCase().indexOf("sybase") > -1) {
str19 = "select 1 from sysobjects where name = '" + str5 + "' ";
} else if (str.toLowerCase().indexOf("informix") > -1) {
str19 = "select 1 from systables where lower(tabname) = lower('" + str5 + "') ";
} else if (str.toLowerCase().indexOf("mysql") > -1) {
str19 = "select 1 from information_schema.Tables where LOWER(Table_Name)=LOWER('" + str5 + "') ";
} else if (str.toLowerCase().indexOf("db2") > -1) {
str19 = "select 1 from SYSIBM.SYSTABLES where lower(name)= lower('" + str5 + "') ";
} else {
str19 = "select 1 from " + str5;
}
resultSet = statement1.executeQuery(str19);
if (!resultSet.next()) {
this.newlog.error("TABLE " + str5 + " IS NOT EXIST!");
} else {
ArrayList<String> arrayList = new ArrayList();
Hashtable<Object, Object> hashtable1 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable2 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable3 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable4 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable5 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable6 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable7 = new Hashtable<Object, Object>();
String str20 = "";
int i = Util.getIntValue(Util.null2String(workflowComInfo.getIsBill(str2)), -1);
String str21 = Util.null2String(workflowComInfo.getFormId(str2));
if (i == 0) {
str20 = "select workflow_formfield.fieldid as id,fieldname as name,workflow_fieldlable.fieldlable as label,workflow_formdict.fieldhtmltype as htmltype,workflow_formdict.type as type,workflow_formdict.fielddbtype from workflow_formfield,workflow_formdict,workflow_fieldlable where workflow_fieldlable.formid = workflow_formfield.formid and workflow_fieldlable.isdefault = 1 and workflow_fieldlable.fieldid =workflow_formfield.fieldid and workflow_formdict.id = workflow_formfield.fieldid and workflow_formfield.formid=" + str21;
} else if (i == 1) {
str20 = "select id as id,fieldname as name,fieldlabel as label,fieldhtmltype as htmltype,type as type,fielddbtype from workflow_billfield where viewtype=0 and billid = " + str21 + " order by dsporder ";
}
recordSet1.executeSql(str20);
while (recordSet1.next()) {
String str23 = recordSet1.getString("id");
String str24 = recordSet1.getString("name");
String str25 = recordSet1.getString("htmltype");
String str26 = recordSet1.getString("type");
String str27 = recordSet1.getString("fielddbtype");
String str28 = "";
String str29 = "";
String str30 = "";
recordSet2.executeSql("select outerfieldname,changetype,customsql from outerdatawfsetdetail where wffieldid=" + str23 + " and mainid=" + str1);
if (recordSet2.next()) {
str28 = recordSet2.getString("outerfieldname");
str29 = recordSet2.getString("changetype");
str30 = recordSet2.getString("customsql");
}
arrayList.add(str23);
hashtable1.put(str23, str24);
hashtable2.put(str23, str25);
hashtable3.put(str23, str26);
hashtable4.put(str23, str27);
hashtable5.put(str23, str28);
hashtable6.put(str23, str29);
hashtable7.put(str23, str30);
}
if (str14.equals(""))
str14 = " where 1=1 ";
if ("2".equals(str7) || "".equals(str7)) {
str14 = str14 + " and ((1=1 ";
if (str.toLowerCase().indexOf("oracle") > -1) {
if (!"".equals(str8))
str14 = str14 + " and nvl(" + str8 + ",'0')='0' ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and nvl(" + str9 + ",'0')!='" + str10 + "' ";
} else if (str.toLowerCase().indexOf("sqlserver") > -1 || str.toLowerCase().indexOf("sybase") > -1) {
if (!"".equals(str8))
str14 = str14 + " and isnull(" + str8 + ",'0')='0' ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and isnull(" + str9 + ",'0')!='" + str10 + "' ";
} else if (str.toLowerCase().indexOf("informix") > -1) {
if (!"".equals(str8))
str14 = str14 + " and " + str8 + " is null ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and " + str9 + "!='" + str10 + "' ";
} else if (str.toLowerCase().indexOf("mysql") > -1) {
if (!"".equals(str8))
str14 = str14 + " and IFNULL(" + str8 + ",'0')='0' ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and IFNULL(" + str9 + ",'0')!='" + str10 + "' ";
} else if (str.toLowerCase().indexOf("db2") > -1) {
if (!"".equals(str8))
str14 = str14 + " and coalesce(" + str8 + ",'0')='0' ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and coalesce(" + str9 + ",'0')!='" + str10 + "' ";
} else {
if (!"".equals(str8))
str14 = str14 + " and " + str8 + " is null ";
if (!"".equals(str9) && !"".equals(str10))
str14 = str14 + " and " + str9 + "!='" + str10 + "' ";
}
str14 = str14 + " ) ";
if (str12.equals("2") && !str13.equals(""))
str14 = str14 + " or " + str13 + "='1' ";
str14 = str14 + " ) ";
}
this.newlog.info("select * from " + str5 + " " + str14);
ResultSet resultSet1 = statement1.executeQuery("select * from " + str5 + " " + str14);
String str22 = "";
while (resultSet1.next()) {
try {
if ("2".equals(str7) || "".equals(str7)) {
if (str6.equals(""))
str6 = "id";
if (str9.equals(""))
str9 = "FTriggerFlag";
if (str8.equals(""))
str8 = "requestid";
}
String str23 = resultSet1.getString(str6).replace("'", "''");
boolean bool1 = false;
if (str12.equals("2") && !str13.equals("")) {
String str27 = Util.null2String(resultSet1.getString(str13));
if (str27.equals("1"))
bool1 = true;
}
if (bool1)
this.newlog.info("." + str13 + "=" + Util.null2String(resultSet1.getString(str13)));
boolean bool2 = false;
str22 = "select 1 from outerdatawfdetail where workflowid=" + str2 + " and mainid=" + str1 + " and keyfieldvalue='" + str23 + "' and outermaintable = '" + str5 + "' and requestid>0";
this.newlog.info(": " + str22);
recordSet1.executeSql(str22);
if (recordSet1.next()) {
this.newlog.info("keyid : " + str23 + " );
bool2 = true;
}
if (!bool1 && bool2)
continue;
String str24 = "";
String str25 = "";
ArrayList<Integer> arrayList18 = new ArrayList();
boolean bool3 = false;
recordSet1.executeSql("select * from outerdatawfsetdetail where (wffieldid=-1 or wffieldid=-2) and mainid=" + str1 + " order by wffieldid");
this.newlog.info("===================SQL:select * from outerdatawfsetdetail where (wffieldid=-1 or wffieldid=-2) and mainid=" + str1 + " order by wffieldid");
while (recordSet1.next()) {
String str27 = Util.null2String(recordSet1.getString("wffieldid"));
if (str27.equals("-2")) {
String str28 = Util.null2String(recordSet1.getString("outerfieldname"));
String str29 = Util.null2String(recordSet1.getString("changetype"));
String str30 = Util.null2String(recordSet1.getString("customsql"));
if (str29.equals("5")) {
str25 = Util.null2String(getCreater(str28, "5"));
if (str25.equals("")) {
this.newlog.error("THE CREATER IN THE OUTER TABLE IS NOT EXIST!");
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "-1");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "-1", str1, str23, str5);
bool3 = true;
break;
}
continue;
}
if (str29.equals("6")) {
if (str28.indexOf(".") > -1)
str28 = str28.substring(str28.indexOf(".") + 1);
String str32 = Util.null2String(resultSet1.getString(str28));
if (!"".equals(str30)) {
str30 = str30 + " and status<4 and (loginid !='' Or loginid is not null) ";
str25 = getTranSqlValue(str30, str32);
} else {
str25 = str32;
}
if (str25.equals("")) {
this.newlog.error("THE CREATER IN THE OUTER TABLE IS NOT EXIST!");
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "-1");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "-1", str1, str23, str5);
bool3 = true;
break;
}
continue;
}
if (str28.equals("")) {
this.newlog.error(");
str25 = "1";
continue;
}
str28 = str28.substring(str28.indexOf(".") + 1);
String str31 = Util.null2String(resultSet1.getString(str28));
if (str31.equals("")) {
this.newlog.error("VALUE OF THE FIELD IN THE OUTER TABLE IS NULL!");
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "0");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "0", str1, str23, str5);
bool3 = true;
break;
}
str25 = Util.null2String(getCreater(str31, str29));
if (str25.equals("")) {
this.newlog.error("THE CREATER IN THE OUTER TABLE IS NOT EXIST!");
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "-1");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "-1", str1, str23, str5);
bool3 = true;
break;
}
continue;
}
if (str27.equals("-1")) {
String str28 = Util.null2String(recordSet1.getString("outerfieldname"));
String str29 = Util.null2String(workflowComInfo.getWorkflowname(str3));
String str30 = Util.toScreen(resourceComInfo.getResourcename(str25), 7);
String str31 = "";
Calendar calendar = Calendar.getInstance();
str31 = Util.add0(calendar.get(1), 4) + "-" + Util.add0(calendar.get(2) + 1, 2) + "-" + Util.add0(calendar.get(5), 2);
DateUtil dateUtil = new DateUtil();
if (str28.equals("")) {
str24 = Util.null2String(dateUtil.getWFTitleNew("" + str3, "" + str25, "" + str30, "1"));
if (str24.equals(""))
str24 = str29 + "-" + str30 + "-" + str31;
continue;
}
str28 = str28.substring(str28.indexOf(".") + 1);
String str32 = Util.null2String(resultSet1.getString(str28));
if (!str32.equals("")) {
str24 = str32;
continue;
}
str24 = Util.null2String(dateUtil.getWFTitleNew("" + str3, "" + str25, "" + str30, "1"));
if (str24.equals(""))
str24 = str29 + "-" + str30 + "-" + str31;
}
}
if (bool3)
continue;
for (byte b1 = 0; b1 < arrayList.size(); b1++) {
String str27 = Util.null2String(arrayList.get(b1));
String str28 = Util.null2String((String)hashtable1.get(str27));
if (!str28.equals("")) {
String str29 = Util.null2String((String)hashtable2.get(str27));
String str30 = Util.null2String((String)hashtable3.get(str27));
String str31 = Util.null2String((String)hashtable4.get(str27));
String str32 = Util.null2String((String)hashtable5.get(str27));
String str33 = Util.null2String((String)hashtable6.get(str27));
String str34 = Util.null2String((String)hashtable7.get(str27));
String str35 = "";
if (!str32.equals("")) {
str32 = str32.substring(str32.indexOf(".") + 1);
String str36 = (String)map.get(str32.toLowerCase());
if (str36.contains("("))
str36 = str36.substring(0, str36.indexOf("("));
if (str36.equals("number") || str36.equals("NUMBER") || str36.equals("float") || str36.equals("Real") || str36.equals("real")) {
str35 = Util.null2String(resultSet1.getString(str32));
if (str35.startsWith("."))
str35 = "0" + str35;
if (str35.startsWith("-."))
str35 = str35.replaceFirst("-.", "-0.");
} else {
str35 = Util.null2String(resultSet1.getString(str32));
}
if (!"6".equals(str33)) {
if (str29.equals("3"))
if (str30.equals("1")) {
str35 = getCreater(str35, str33);
} else if (str30.equals("4")) {
str35 = getDept(str35, str33);
} else if (str30.equals("164")) {
str35 = getSubCom(str35, str33);
}
} else if (!"".equals(str34)) {
str35 = getTranSqlValue(str34, str35);
}
}
if (str35.equals("")) {
if (str29.equals("4")) {
arrayList18.add(Integer.valueOf(0));
} else if (!str29.equals("6") && !str29.equals("2") && (!str29.equals("1") || (!str30.equals("1") && !str30.equals("5"))) && (!str29.equals("3") || (!str30.equals("2") && !str30.equals("19") && !str30.equals("161") && !str30.equals("162")))) {
arrayList18.add(null);
} else {
arrayList18.add("");
}
} else {
if (str31.startsWith("text") || str31.startsWith("char") || str31.startsWith("varchar") || str31.indexOf(".") > -1 || str31.startsWith("clob")) {
if (str31.startsWith("char") || str31.startsWith("varchar")) {
int k = Util.getIntValue(str31.substring(str31.indexOf("(") + 1, str31.indexOf(")")), 0);
if (Util.length2(str35) > k)
do {
str35 = str35.substring(0, str35.length() - 1);
} while (Util.length2(str35) > k);
}
str35 = str35.replace("'", "''");
} else if (str31.equals("int") || str31.equals("integer")) {
str35 = Util.getIntValue(str35, 0) + "";
} else if (str31.indexOf("decimal") == 0 || str31.indexOf("number") == 0) {
str35 = str35.replace(",", "");
str35 = Util.getDoubleValue(str35, 0.0D) + "";
} else if (str31.indexOf("text") == 0) {
str35 = str35.replaceAll("'", "''");
}
arrayList18.add(str35);
}
}
}
if (bool1 && bool2) {
String str27 = "";
str22 = "select requestid from outerdatawfdetail where workflowid=" + str2 + " and mainid=" + str1 + " and keyfieldvalue='" + str23 + "' and outermaintable = '" + str5 + "' and requestid>0";
this.newlog.info(": " + str22);
RecordSet recordSet = new RecordSet();
recordSet.executeSql(str22);
if (recordSet.next())
str27 = Util.null2String(recordSet.getString("requestid"));
if (str27.equals("")) {
this.newlog.info(");
continue;
}
SysUpdateWF sysUpdateWF = new SysUpdateWF();
if (sysUpdateWF.updateWorkflowInfo(Util.getIntValue(str3, 0), str24, Util.getIntValue(str25, 1), arrayList18, Util.getIntValue(str27, 0))) {
String str28 = str15;
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str28, str6, str9, str8, str23, str10, "" + str27);
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "" + str27, str1, str23, str5);
saveRequestLog(str1, str23, str3, Util.getIntValue(str27, 0));
UpdateIntoDetailTable(statement2, str5, str, str1, str2, Util.getIntValue(str27, 0), str6, str23, str17, str18, str8, str7);
continue;
}
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "0");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveRequestLog(str1, str23, str3, Util.getIntValue(str27, 0));
continue;
}
this.newlog.info("=======+ str24);
sysCreateWF = new SysCreateWF();
RequestManager requestManager = sysCreateWF.setWorkflowInfo(Util.getIntValue(str3, 0), str24, 0, Util.getIntValue(str25, 1), arrayList18, false, str11);
int j = requestManager.getRequestid();
String str26 = str15;
if (j > 0) {
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str26, str6, str9, str8, str23, str10, "" + j);
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "" + j, str1, str23, str5);
saveRequestLog(str1, str23, str3, j);
this.newlog.info("****insertIntoDetailTable = " + str + "^^^^^^^^^^^^^:requestid = " + j);
insertIntoDetailTable(str4, statement2, str5, str, str1, str2, j, str6, str23, str17, str18, str8, str7);
this.newlog.info("+ str11 + ",workflowid=" + str2);
if (str11.equals("1"))
requestManager.flowNextNode();
continue;
}
if ("2".equals(str7) || "".equals(str7))
saveOutTrigLog(statement2, str5, str16, str6, str9, str8, str23, str10, "0");
if (str12.equals("2") && !str13.equals(""))
saveUpdateWfFlag(statement2, str5, str6, str23, str12, str13);
saveTrigLog(str3, "-2", str1, str23, str5);
saveRequestLog(str1, str23, str3, j);
} catch (Exception exception) {
this.newlog.error(", exception);
}
}
resultSet1.close();
resultSet.close();
statement1.close();
statement2.close();
automaticconnect.closeConnection(connection);
}
}
}
}
} catch (Exception exception) {
this.newlog.error(", exception);
}
}
} catch (Exception exception) {
this.newlog.error(", exception);
}
}
public String getTranSqlValue(String paramString1, String paramString2) {
paramString2 = paramString2.replace("'", "''");
paramString1 = DBTypeUtil.replaceString(paramString1, "{?currentvalue}", paramString2);
RecordSet recordSet = new RecordSet();
recordSet.executeSql(paramString1);
if (recordSet.next())
return recordSet.getString(1);
return "";
}
public void insertIntoDetailTable(String paramString1, Statement paramStatement, String paramString2, String paramString3, String paramString4, String paramString5, int paramInt, String paramString6, String paramString7, String paramString8, String paramString9, String paramString10, String paramString11) throws Exception {
ResultSet resultSet = null;
HashMap<Object, Object> hashMap = new HashMap<Object, Object>();
WorkflowComInfo workflowComInfo = new WorkflowComInfo();
String str1 = Util.null2String(workflowComInfo.getIsBill(paramString5));
String str2 = Util.null2String(workflowComInfo.getFormId(paramString5));
ArrayList<String> arrayList1 = new ArrayList();
ArrayList<String> arrayList2 = new ArrayList();
String str3 = "mainid";
String str4 = "";
ArrayList<String> arrayList3 = Util.TokenizerString(paramString8, ",");
String[] arrayOfString = paramString9.split("\\$@\\|@\\$");
ArrayList<String> arrayList4 = new ArrayList();
for (byte b1 = 0; b1 < arrayOfString.length; b1++)
arrayList4.add(arrayOfString[b1]);
RecordSet recordSet = new RecordSet();
boolean bool = recordSet.getDBType().equals("oracle");
RecordSetDataSource recordSetDataSource = new RecordSetDataSource();
boolean bool1 = false;
if (!str2.equals(""))
if (str1.equals("0")) {
recordSet.executeSql("select distinct groupId from Workflow_formfield where formid=" + str2 + " and isdetail='1' order by groupid");
while (recordSet.next()) {
arrayList1.add("workflow_formdetail");
arrayList2.add(recordSet.getString(1));
}
} else if (str1.equals("1")) {
recordSet.executeSql("select tablename from Workflow_billdetailtable where billid=" + str2 + " order by orderid");
while (recordSet.next()) {
String str = Util.null2String(recordSet.getString(1));
if (!str.equals(""))
arrayList1.add(recordSet.getString(1));
}
recordSet.executeSql("select tablename,detailtablename,detailkeyfield from workflow_bill where id=" + str2);
if (recordSet.next()) {
str3 = Util.null2String(recordSet.getString("detailkeyfield"));
if (arrayList1.size() == 0) {
String str5 = Util.null2String(recordSet.getString("detailtablename"));
if (!str5.equals(""))
arrayList1.add(str5);
}
String str = recordSet.getString("tablename");
recordSet.executeSql("select id from " + str + " where requestid=" + paramInt);
if (recordSet.next())
str4 = recordSet.getString("id");
}
}
if (arrayList1.size() != arrayList3.size()) {
writeLog(");
return;
}
for (byte b2 = 0; b2 < arrayList1.size(); b2++) {
String str5 = arrayList1.get(b2);
String str6 = arrayList3.get(b2);
String str7 = "";
if (paramString3.toLowerCase().indexOf("oracle") > -1) {
str7 = "select 1 from user_tables a where a.TABLE_NAME = upper('" + str6 + "') union ALL select 1 from user_views b where b.VIEW_NAME = upper('" + str6 + "')";
} else if (paramString3.toLowerCase().indexOf("sqlserver") > -1 || paramString3.toLowerCase().indexOf("sybase") > -1) {
str7 = "select 1 from sysobjects where name = '" + str6 + "' ";
} else if (paramString3.toLowerCase().indexOf("informix") > -1) {
str7 = "select 1 from systables where lower(tabname) = lower('" + str6 + "') ";
} else if (paramString3.toLowerCase().indexOf("mysql") > -1) {
str7 = "select 1 from information_schema.Tables where LOWER(Table_Name)=LOWER('" + str6 + "') ";
} else if (paramString3.toLowerCase().indexOf("db2") > -1) {
str7 = "select 1 from SYSIBM.SYSTABLES where lower(name)= lower('" + str6 + "') ";
} else {
str7 = "select 1 from " + str6;
}
resultSet = paramStatement.executeQuery(str7);
if (!resultSet.next()) {
this.newlog.error("TABLE " + str6 + " IS NOT EXIST!");
} else {
Map map = new HashMap<Object, Object>();
if (!paramString1.equals(""))
map = recordSetDataSource.getAllColumnWithTypes(paramString1, str6);
ArrayList<String> arrayList = new ArrayList();
Hashtable<Object, Object> hashtable1 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable2 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable3 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable4 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable5 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable6 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable7 = new Hashtable<Object, Object>();
String str = Util.null2String(arrayList4.get(b2));
if (str.equals("-"))
str = "";
recordSet.executeSql("select * from outerdatawfsetdetail where outerfieldname like '" + str6 + ".%' and mainid=" + paramString4);
while (recordSet.next()) {
String str8 = recordSet.getString("wffieldid");
String str9 = recordSet.getString("wffieldname");
String str10 = recordSet.getString("wffieldhtmltype");
String str11 = recordSet.getString("wffieldtype");
String str12 = recordSet.getString("wffielddbtype");
String str13 = recordSet.getString("outerfieldname");
String str14 = recordSet.getString("changetype");
String str15 = recordSet.getString("customsql");
arrayList.add(str8);
hashtable1.put(str8, str9);
hashtable2.put(str8, str10);
hashtable3.put(str8, str11);
hashtable4.put(str8, str12);
hashtable5.put(str8, str13);
hashtable6.put(str8, str14);
hashtable7.put(str8, str15);
}
Pattern pattern = Pattern.compile("where");
Matcher matcher = pattern.matcher(str);
str = matcher.replaceFirst(" and ");
if (!paramString11.equals("1") && !paramString10.equals("")) {
str7 = "select * from " + str6 + " ," + paramString2 + " " + " where 1=1" + " and " + paramString2 + "." + paramString10 + " = " + paramInt + str;
} else {
str7 = "select * from " + str6 + " ," + paramString2 + " " + " where 1=1" + " and " + paramString2 + "." + paramString6 + " = '" + paramString7 + "'" + str;
}
this.newlog.info("querysql:" + str7);
resultSet = paramStatement.executeQuery(str7);
while (resultSet.next()) {
String str8 = "";
String str9 = "";
if (str1.equals("0")) {
str8 = "insert into " + str5 + "(requestid,groupId";
str9 = " values(" + paramInt + "," + (String)arrayList2.get(b2);
} else if (str1.equals("1")) {
str8 = "insert into " + str5 + "(" + str3;
str9 = " values(" + str4;
}
for (byte b = 0; b < arrayList.size(); b++) {
String str10 = Util.null2String(arrayList.get(b));
String str11 = Util.null2String((String)hashtable1.get(str10));
if (!str11.equals("")) {
String str12 = Util.null2String((String)hashtable2.get(str10));
String str13 = Util.null2String((String)hashtable3.get(str10));
String str14 = Util.null2String((String)hashtable4.get(str10));
String str15 = Util.null2String((String)hashtable5.get(str10));
String str16 = Util.null2String((String)hashtable6.get(str10));
String str17 = Util.null2String((String)hashtable7.get(str10));
String str18 = "";
if (!str15.equals("")) {
str15 = str15.substring(str15.indexOf(".") + 1);
String str19 = (String)map.get(str15.toLowerCase());
if (str19.contains("("))
str19 = str19.substring(0, str19.indexOf("("));
if (str19.equals("number") || str19.equals("NUMBER") || str19.equals("float") || str19.equals("real") || str19.equals("Real")) {
str18 = Util.null2String(resultSet.getString(str15));
if (str18.startsWith("."))
str18 = "0" + str18;
if (str18.startsWith("-."))
str18 = str18.replaceFirst("-.", "-0.");
} else {
str18 = Util.null2String(resultSet.getString(str15));
}
if (!"6".equals(str16)) {
if (str12.equals("3"))
if (str13.equals("1")) {
str18 = getCreater(str18, str16);
} else if (str13.equals("4")) {
str18 = getDept(str18, str16);
} else if (str13.equals("164")) {
str18 = getSubCom(str18, str16);
}
} else if (!"".equals(str17)) {
str18 = getTranSqlValue(str17, str18);
} else {
str18 = str18;
}
}
if (str18.equals("")) {
if (!str12.equals("2") && (!str12.equals("1") || (!str13.equals("1") && !str13.equals("5"))) && (!str12.equals("3") || (!str13.equals("2") && !str13.equals("19") && !str13.equals("161") && !str13.equals("162"))))
str18 = "NULL";
if (str12.equals("5")) {
str18 = "-1";
} else if (str12.equals("4")) {
str18 = "0";
}
} else if (str14.indexOf("varchar") == 0 || str14.indexOf("char") == 0) {
int i = Util.getIntValue(str14.substring(str14.indexOf("(") + 1, str14.indexOf(")")), 0);
if (Util.length2(str18) > i)
do {
str18 = str18.substring(0, str18.length() - 1);
} while (Util.length2(str18) > i);
str18 = str18.replace("'", "''");
} else if (str14.equals("int") || str14.equals("integer")) {
str18 = Util.getIntValue(str18, -1) + "";
} else if (str14.indexOf("decimal") == 0 || str14.indexOf("number") == 0) {
str18 = str18.replace(",", "");
str18 = Util.getDoubleValue(str18, -1.0D) + "";
} else if (str12.equals("3") && str13.equals("17") && bool) {
hashMap.put(str11, str18);
str18 = " empty_clob() ";
}
str8 = str8 + "," + str11;
if (str14.startsWith("text") || str14.startsWith("char") || str14.startsWith("varchar") || str14.indexOf(".") > -1) {
str9 = str9 + ",'" + str18 + "'";
} else if (str12.equals("3") && (str13.equals("256") || str13.equals("257"))) {
str9 = str9 + ",'" + str18 + "'";
} else if (str14.startsWith("clob")) {
str9 = str9 + "," + str18;
} else {
str9 = str9 + "," + str18;
}
}
}
str8 = str8 + ") ";
str9 = str9 + ") ";
this.newlog.info("detail sql:" + str8 + str9);
recordSet.executeSql(str8 + str9);
if (bool)
try {
String str10 = "";
if (str1.equals("0")) {
str10 = "select max(id) dtid from " + str5 + " where requestid =" + paramInt + " and groupId = " + (String)arrayList2.get(b2);
} else if (str1.equals("1")) {
str10 = "select max(id) dtid from " + str5 + " where " + str3 + " =" + str4;
}
recordSet.executeSql(str10);
if (recordSet.next()) {
String str11 = Util.null2String(recordSet.getString("dtid"));
if (!"".equals(str11)) {
String str12 = "";
str12 = " select ";
byte b3 = 0;
String str13 = " ";
Iterator<Map.Entry> iterator = hashMap.entrySet().iterator();
while (iterator.hasNext()) {
b3++;
Map.Entry entry = iterator.next();
String str14 = entry.getKey().toString();
String str15 = "";
if (entry.getValue() != null)
if (String.valueOf(entry.getValue()).equals(" ")) {
str15 = "";
} else {
str15 = String.valueOf(entry.getValue());
}
if (b3 > 1) {
str12 = str12 + str13 + " , " + str14;
continue;
}
str12 = str12 + str13 + " " + str14;
}
str12 = str12 + " from " + str5;
if (str1.equals("0")) {
str12 = str12 + " where requestid = " + paramInt + " and groupId = " + (String)arrayList2.get(b2) + " and id = " + str11 + " for update";
} else if (str1.equals("1")) {
str12 = str12 + " where " + str3 + " = " + str4 + "and id = " + str11 + " for update";
}
if (b3 > 0) {
ConnStatement connStatement = null;
try {
connStatement = new ConnStatement();
connStatement.setStatementSql(str12, false);
connStatement.executeQuery();
if (connStatement.next()) {
iterator = hashMap.entrySet().iterator();
b3 = 0;
while (iterator.hasNext()) {
b3++;
Map.Entry entry = iterator.next();
String str14 = entry.getKey().toString();
String str15 = "";
if (entry.getValue() != null)
if (String.valueOf(entry.getValue()).equals(" ")) {
str15 = "";
} else {
str15 = String.valueOf(entry.getValue());
}
CLOB cLOB = connStatement.getClob(b3);
char[] arrayOfChar = str15.toCharArray();
Writer writer = cLOB.getCharacterOutputStream();
writer.write(arrayOfChar);
writer.flush();
writer.close();
}
}
} catch (Exception exception) {
this.newlog.error(", exception);
} finally {
if (connStatement != null)
connStatement.close();
}
}
}
}
hashMap.clear();
} catch (Exception exception) {
this.newlog.error(", exception);
}
}
}
}
}
public void UpdateIntoDetailTable(Statement paramStatement, String paramString1, String paramString2, String paramString3, String paramString4, int paramInt, String paramString5, String paramString6, String paramString7, String paramString8, String paramString9, String paramString10) throws Exception {
ResultSet resultSet = null;
HashMap<Object, Object> hashMap = new HashMap<Object, Object>();
WorkflowComInfo workflowComInfo = new WorkflowComInfo();
String str1 = Util.null2String(workflowComInfo.getIsBill(paramString4));
String str2 = Util.null2String(workflowComInfo.getFormId(paramString4));
ArrayList<String> arrayList1 = new ArrayList();
ArrayList<String> arrayList2 = new ArrayList();
String str3 = "mainid";
String str4 = "";
ArrayList<String> arrayList3 = Util.TokenizerString(paramString7, ",");
String[] arrayOfString = paramString8.split("\\$@\\|@\\$");
ArrayList<String> arrayList4 = new ArrayList();
for (byte b1 = 0; b1 < arrayOfString.length; b1++)
arrayList4.add(arrayOfString[b1]);
RecordSet recordSet = new RecordSet();
boolean bool = recordSet.getDBType().equals("oracle");
boolean bool1 = false;
if (!str2.equals(""))
if (str1.equals("0")) {
recordSet.executeSql("select distinct groupId from Workflow_formfield where formid=" + str2 + " and isdetail='1' order by groupid");
while (recordSet.next()) {
arrayList1.add("workflow_formdetail");
arrayList2.add(recordSet.getString(1));
}
} else if (str1.equals("1")) {
recordSet.executeSql("select tablename from Workflow_billdetailtable where billid=" + str2 + " order by orderid");
while (recordSet.next()) {
String str = Util.null2String(recordSet.getString(1));
if (!str.equals(""))
arrayList1.add(recordSet.getString(1));
}
recordSet.executeSql("select tablename,detailtablename,detailkeyfield from workflow_bill where id=" + str2);
if (recordSet.next()) {
str3 = Util.null2String(recordSet.getString("detailkeyfield"));
if (arrayList1.size() == 0) {
String str5 = Util.null2String(recordSet.getString("detailtablename"));
if (!str5.equals(""))
arrayList1.add(str5);
}
String str = recordSet.getString("tablename");
recordSet.executeSql("select id from " + str + " where requestid=" + paramInt);
if (recordSet.next())
str4 = recordSet.getString("id");
}
}
if (arrayList1.size() != arrayList3.size()) {
writeLog(");
return;
}
for (byte b2 = 0; b2 < arrayList1.size(); b2++) {
String str5 = arrayList1.get(b2);
String str6 = arrayList3.get(b2);
String str7 = "";
if (paramString2.toLowerCase().indexOf("oracle") > -1) {
str7 = "select 1 from user_tables a where a.TABLE_NAME = upper('" + str6 + "') union ALL select 1 from user_views b where b.VIEW_NAME = upper('" + str6 + "')";
} else if (paramString2.toLowerCase().indexOf("sqlserver") > -1 || paramString2.toLowerCase().indexOf("sybase") > -1) {
str7 = "select 1 from sysobjects where name = '" + str6 + "' ";
} else if (paramString2.toLowerCase().indexOf("informix") > -1) {
str7 = "select 1 from systables where lower(tabname) = lower('" + str6 + "') ";
} else if (paramString2.toLowerCase().indexOf("mysql") > -1) {
str7 = "select 1 from information_schema.Tables where LOWER(Table_Name)=LOWER('" + str6 + "') ";
} else if (paramString2.toLowerCase().indexOf("db2") > -1) {
str7 = "select 1 from SYSIBM.SYSTABLES where lower(name)= lower('" + str6 + "') ";
} else {
str7 = "select 1 from " + str6;
}
resultSet = paramStatement.executeQuery(str7);
if (!resultSet.next()) {
this.newlog.error("TABLE " + str6 + " IS NOT EXIST!");
} else {
String str8 = "";
RecordSet recordSet1 = new RecordSet();
if (str1.equals("0")) {
str8 = "delete " + str5 + " where requestid='" + paramInt + "' and groupId='" + (String)arrayList2.get(b2) + "' ";
} else if (str1.equals("1")) {
str8 = "delete " + str5 + " where " + str3 + "='" + str4 + "' ";
}
recordSet1.executeSql(str8);
ArrayList<String> arrayList = new ArrayList();
Hashtable<Object, Object> hashtable1 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable2 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable3 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable4 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable5 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable6 = new Hashtable<Object, Object>();
Hashtable<Object, Object> hashtable7 = new Hashtable<Object, Object>();
String str9 = Util.null2String(arrayList4.get(b2));
if (str9.equals("-"))
str9 = "";
recordSet.executeSql("select * from outerdatawfsetdetail where outerfieldname like '" + str6 + ".%' and mainid=" + paramString3);
while (recordSet.next()) {
String str10 = recordSet.getString("wffieldid");
String str11 = recordSet.getString("wffieldname");
String str12 = recordSet.getString("wffieldhtmltype");
String str13 = recordSet.getString("wffieldtype");
String str14 = recordSet.getString("wffielddbtype");
String str15 = recordSet.getString("outerfieldname");
String str16 = recordSet.getString("changetype");
String str17 = recordSet.getString("customsql");
arrayList.add(str10);
hashtable1.put(str10, str11);
hashtable2.put(str10, str12);
hashtable3.put(str10, str13);
hashtable4.put(str10, str14);
hashtable5.put(str10, str15);
hashtable6.put(str10, str16);
hashtable7.put(str10, str17);
}
Pattern pattern = Pattern.compile("where");
Matcher matcher = pattern.matcher(str9);
str9 = matcher.replaceFirst(" and ");
if (!paramString10.equals("1") && !paramString9.equals("")) {
str7 = "select * from " + str6 + " ," + paramString1 + " " + " where 1=1" + " and " + paramString1 + "." + paramString9 + " = " + paramInt + str9;
} else {
str7 = "select * from " + str6 + " ," + paramString1 + " " + " where 1=1" + " and " + paramString1 + "." + paramString5 + " = '" + paramString6 + "'" + str9;
}
this.newlog.info("querysql:" + str7);
resultSet = paramStatement.executeQuery(str7);
while (resultSet.next()) {
String str10 = "";
String str11 = "";
if (str1.equals("0")) {
str10 = "insert into " + str5 + "(requestid,groupId";
str11 = " values(" + paramInt + "," + (String)arrayList2.get(b2);
} else if (str1.equals("1")) {
str10 = "insert into " + str5 + "(" + str3;
str11 = " values(" + str4;
}
for (byte b = 0; b < arrayList.size(); b++) {
String str12 = Util.null2String(arrayList.get(b));
String str13 = Util.null2String((String)hashtable1.get(str12));
if (!str13.equals("")) {
String str14 = Util.null2String((String)hashtable2.get(str12));
String str15 = Util.null2String((String)hashtable3.get(str12));
String str16 = Util.null2String((String)hashtable4.get(str12));
String str17 = Util.null2String((String)hashtable5.get(str12));
String str18 = Util.null2String((String)hashtable6.get(str12));
String str19 = Util.null2String((String)hashtable7.get(str12));
String str20 = "";
if (!str17.equals("")) {
str17 = str17.substring(str17.indexOf(".") + 1);
str20 = Util.null2String(resultSet.getString(str17));
if (!"6".equals(str18)) {
if (str14.equals("3"))
if (str15.equals("1")) {
str20 = getCreater(str20, str18);
} else if (str15.equals("4")) {
str20 = getDept(str20, str18);
} else if (str15.equals("164")) {
str20 = getSubCom(str20, str18);
}
} else if (!"".equals(str19)) {
str20 = getTranSqlValue(str19, str20);
} else {
str20 = str20;
}
}
if (str20.equals("")) {
if (!str14.equals("2") && (!str14.equals("1") || (!str15.equals("1") && !str15.equals("5"))) && (!str14.equals("3") || (!str15.equals("2") && !str15.equals("19") && !str15.equals("161") && !str15.equals("162"))))
str20 = "NULL";
if (str14.equals("5")) {
str20 = "-1";
} else if (str14.equals("4")) {
str20 = "0";
}
} else if (str16.indexOf("varchar") == 0 || str16.indexOf("char") == 0) {
int i = Util.getIntValue(str16.substring(str16.indexOf("(") + 1, str16.indexOf(")")), 0);
if (Util.length2(str20) > i)
do {
str20 = str20.substring(0, str20.length() - 1);
} while (Util.length2(str20) > i);
str20 = str20.replace("'", "''");
} else if (str16.equals("int") || str16.equals("integer")) {
str20 = Util.getIntValue(str20, -1) + "";
} else if (str16.indexOf("decimal") == 0 || str16.indexOf("number") == 0) {
str20 = str20.replace(",", "");
str20 = Util.getDoubleValue(str20, -1.0D) + "";
} else if (str14.equals("3") && str15.equals("17") && bool) {
hashMap.put(str13, str20);
str20 = " empty_clob() ";
}
str10 = str10 + "," + str13;
if (str16.startsWith("text") || str16.startsWith("char") || str16.startsWith("varchar") || str16.indexOf(".") > -1 || str16.startsWith("clob")) {
str11 = str11 + ",'" + str20 + "'";
} else if (str14.equals("3") && (str15.equals("256") || str15.equals("257"))) {
str11 = str11 + ",'" + str20 + "'";
} else {
str11 = str11 + "," + str20;
}
}
}
str10 = str10 + ") ";
str11 = str11 + ") ";
this.newlog.info("detail sql:" + str10 + str11);
recordSet.executeSql(str10 + str11);
if (bool)
try {
String str = "";
if (str1.equals("0")) {
str = "select max(id) dtid from " + str5 + " where requestid =" + paramInt + " and groupId = " + (String)arrayList2.get(b2);
} else if (str1.equals("1")) {
str = "select max(id) dtid from " + str5 + " where " + str3 + " =" + str4;
}
recordSet.executeSql(str);
if (recordSet.next()) {
String str12 = Util.null2String(recordSet.getString("dtid"));
if (!"".equals(str12)) {
String str13 = "";
str13 = " select ";
byte b3 = 0;
String str14 = " ";
Iterator<Map.Entry> iterator = hashMap.entrySet().iterator();
while (iterator.hasNext()) {
b3++;
Map.Entry entry = iterator.next();
String str15 = entry.getKey().toString();
String str16 = "";
if (entry.getValue() != null)
if (String.valueOf(entry.getValue()).equals(" ")) {
str16 = "";
} else {
str16 = String.valueOf(entry.getValue());
}
if (b3 > 1) {
str13 = str13 + str14 + " , " + str15;
continue;
}
str13 = str13 + str14 + " " + str15;
}
str13 = str13 + " from " + str5;
if (str1.equals("0")) {
str13 = str13 + " where requestid = " + paramInt + " and groupId = " + (String)arrayList2.get(b2) + " and id = " + str12 + " for update";
} else if (str1.equals("1")) {
str13 = str13 + " where " + str3 + " = " + str4 + "and id = " + str12 + " for update";
}
if (b3 > 0) {
ConnStatement connStatement = null;
try {
connStatement = new ConnStatement();
connStatement.setStatementSql(str13, false);
connStatement.executeQuery();
if (connStatement.next()) {
iterator = hashMap.entrySet().iterator();
b3 = 0;
while (iterator.hasNext()) {
b3++;
Map.Entry entry = iterator.next();
String str15 = entry.getKey().toString();
String str16 = "";
if (entry.getValue() != null)
if (String.valueOf(entry.getValue()).equals(" ")) {
str16 = "";
} else {
str16 = String.valueOf(entry.getValue());
}
CLOB cLOB = connStatement.getClob(b3);
char[] arrayOfChar = str16.toCharArray();
Writer writer = cLOB.getCharacterOutputStream();
writer.write(arrayOfChar);
writer.flush();
writer.close();
}
}
} catch (Exception exception) {
this.newlog.error(", exception);
} finally {
if (connStatement != null)
connStatement.close();
}
}
}
}
hashMap.clear();
} catch (Exception exception) {
this.newlog.error(", exception);
}
}
}
}
}
public String getCreater(String paramString1, String paramString2) {
paramString1 = paramString1.replace("'", "''");
RecordSet recordSet = new RecordSet();
String str = "";
if (paramString2.equals("0")) {
recordSet.executeSql("select id from HrmResource where id='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("1")) {
recordSet.executeSql("select id from HrmResource where workcode='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("2")) {
recordSet.executeSql("select id from HrmResource where loginid='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("3")) {
recordSet.executeSql("select id from HrmResource where mobile='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("4")) {
recordSet.executeSql("select id from HrmResource where email='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("5")) {
recordSet.executeSql("select id from HrmResource where id='" + paramString1 + "' and status<4 and (loginid !='' Or loginid is not null) ");
if (recordSet.next())
str = recordSet.getString("id");
}
return str;
}
public String getDept(String paramString1, String paramString2) {
paramString1 = paramString1.replace("'", "''");
RecordSet recordSet = new RecordSet();
String str = "";
if (paramString2.equals("0")) {
recordSet.executeSql("select id from HrmDepartment where id='" + paramString1 + "'");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("1")) {
recordSet.executeSql("select id from HrmDepartment where departmentcode='" + paramString1 + "'");
if (recordSet.next())
str = recordSet.getString("id");
}
return str;
}
public String getSubCom(String paramString1, String paramString2) {
paramString1 = paramString1.replace("'", "''");
RecordSet recordSet = new RecordSet();
String str = "";
if (paramString2.equals("0")) {
recordSet.executeSql("select id from HrmSubCompany where id='" + paramString1 + "'");
if (recordSet.next())
str = recordSet.getString("id");
} else if (paramString2.equals("1")) {
recordSet.executeSql("select id from HrmSubCompany where subcompanycode='" + paramString1 + "'");
if (recordSet.next())
str = recordSet.getString("id");
}
return str;
}
private boolean saveOutTrigLog(Statement paramStatement, String paramString1, String paramString2, String paramString3, String paramString4, String paramString5, String paramString6, String paramString7, String paramString8) {
try {
String str = "";
if (!"".equals(paramString4))
str = str + paramString4 + "='" + paramString7 + "'";
if (!"".equals(paramString4))
str = str + ("".equals(str) ? (paramString5 + "='" + paramString8 + "'") : ("," + paramString5 + "='" + paramString8 + "'"));
if (!"".equals(paramString2)) {
paramString2 = paramString2.trim();
if (paramString2.indexOf("set") == 0)
paramString2 = paramString2.substring(4);
str = str + ("".equals(str) ? paramString2 : ("," + paramString2));
}
if (!"".equals(str)) {
String str1 = "update " + paramString1 + " set " + str + " where " + paramString3 + "='" + paramString6 + "'";
this.newlog.info("saveOutTrigLog sql : " + str1);
paramStatement.executeUpdate(str1);
}
} catch (Exception exception) {
this.newlog.error(", exception);
return false;
}
return true;
}
private boolean saveUpdateWfFlag(Statement paramStatement, String paramString1, String paramString2, String paramString3, String paramString4, String paramString5) {
try {
String str1 = "";
String str2 = "";
if (paramString4.equals("2") && !"".equals(paramString5))
str2 = str2 + ("".equals(str2) ? (paramString5 + "='0'") : ("," + paramString5 + "='0'"));
if (!"".equals(str1)) {
str1 = str1.trim();
if (str1.indexOf("set") == 0)
str1 = str1.substring(4);
str2 = str2 + ("".equals(str2) ? str1 : ("," + str1));
}
if (!"".equals(str2)) {
String str = "update " + paramString1 + " set " + str2 + " where " + paramString2 + "='" + paramString3 + "'";
paramStatement.executeUpdate(str);
this.newlog.info("saveUpdateWfFlag sql : " + str);
}
} catch (Exception exception) {
this.newlog.error(", exception);
return false;
}
return true;
}
private boolean saveTrigLog(String paramString1, String paramString2, String paramString3, String paramString4, String paramString5) {
try {
boolean bool = false;
RecordSet recordSet = new RecordSet();
String str = "select requestid from outerdatawfdetail where keyfieldvalue='" + paramString4 + "' and outermaintable = '" + paramString5 + "' and workflowid=" + paramString1 + " and mainid=" + paramString3;
recordSet.executeSql(str);
if (recordSet.next())
bool = true;
if (bool) {
str = "update outerdatawfdetail set requestid=" + paramString2 + " where mainid=" + paramString3 + " and workflowid=" + paramString1 + " and outermaintable = '" + paramString5 + "' and keyfieldvalue='" + paramString4 + "'";
} else {
str = "insert into outerdatawfdetail(mainid,workflowid,requestid,keyfieldvalue,outermaintable) values(" + paramString3 + "," + paramString1 + "," + paramString2 + ",'" + paramString4 + "','" + paramString5 + "')";
}
this.newlog.info("saveTrigLog sql : " + str);
recordSet.executeSql(str);
} catch (Exception exception) {
this.newlog.error(", exception);
return false;
}
return true;
}
private void saveRequestLog(String paramString1, String paramString2, String paramString3, int paramInt) {
SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat("yyyy-MM-dd");
SimpleDateFormat simpleDateFormat2 = new SimpleDateFormat("HH:mm:ss");
Date date = new Date();
String str1 = simpleDateFormat1.format(date);
String str2 = simpleDateFormat2.format(date);
String str3 = "";
if (paramInt > -1) {
str3 = "1";
} else {
str3 = "0";
}
RecordSet recordSet = new RecordSet();
String str4 = "insert into outerdatawflog(Outerdatawfid,Outkey,Workflowid,RequestId,Triggerflag,CreateDate,CreateTime) values('" + paramString1 + "','" + paramString2 + "','" + paramString3 + "','" + paramInt + "','" + str3 + "','" + str1 + "','" + str2 + "')";
recordSet.executeSql(str4);
this.newlog.info("saveRequestLog sql : " + str4);
}
}
很长一段，核心检查逻辑在 public void doActiveOutDataWF() 这里。
| 参数名 | 含义 | 用途 |
id | 外部表的主键项，可以是任何名字 | |
workflowid | 需要被触发创建的流程id | |
datasourceid | 数据源id、即使是泛微自己的表作为外部表、也需要创建数据源 | |
outermaintable | 外部表（主表）的名字 | |
keyfield | ||
datarecordtype | ||
requestid | 外部表触发成功后、回写产生的流程请求id的列的名字 | |
FTriggerFlag | 默认不可更名：触发成功的回写列，不能在其他条件中进行数据修改。 | |
FTriggerFlagValue | ||
outermainwhere | 外部表的数据筛选条件，必须以 where 开头。 | |
successback | ||
failback | ||
outerdetailtables | 外部表的明细表（可选） | |
outerdetailwheres | 外部表的明细表筛选条件、用作判断和主表关联（可选） | |
isnextnode | ||
isupdatewfdata | ||
isupdatewfdataField |
目前看来、在最简单的配置方法下：CREATER 和流程标题是必须提供外部表字段的。其他等泛微工程师进行解答。
总结
未完待续。。
