dxfeng
/
ecology-develop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

查询BUG修复

This commit is contained in:
dxfeng 2025-04-15 11:41:59 +08:00
parent 6fc428cbc0
commit 666be234e2
1 changed files with 22 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
src/weaver/interfaces/secret/action/MeetingConveningEndAction.java
View File

@ -1,5 +1,6 @@
package weaver.interfaces.secret.action;
import com.engine.secret.util.ConfigUtil;
import com.engine.secret.util.FlowUtil;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils;
@ -17,6 +18,7 @@ import java.util.*;
*/
public class MeetingConveningEndAction implements Action {
RecordSet rs = new RecordSet();
private static final String MAIN_FLOW_TABLE = ConfigUtil.getConfig("xqxksqlc_table");
@Override
public String execute(RequestInfo requestInfo) {
@ -67,8 +69,18 @@ public class MeetingConveningEndAction implements Action {
}
}
/**
* 提交主流程
*
* @param requestInfo
* @param detail
* @param updateDetailSql
* @param errorMsg
*/
private void dealMainFlow(RequestInfo requestInfo, Map<String, String> detail, String updateDetailSql, Set<String> errorMsg) {
String mainRequestId = detail.get("xzxksqdh");
String mainId = detail.get("xzxksqdh");
String conclusion = detail.get("spfhjl");
String detailId = detail.get("detailId");
String submitStatus = detail.get("zlctjzt");
@ -76,19 +88,22 @@ public class MeetingConveningEndAction implements Action {
// 已经提交成功的流程，不重复处理
return;
}
// 更新主流程表单的审批复核结论
String tableNameByRequestId = FlowUtil.getTableNameByRequestId(mainRequestId);
if (StringUtils.isBlank(tableNameByRequestId)) {
errorMsg.add("requestId[" + mainRequestId + "],主流程表单名称获取异常，请确认");
String mainRequestId = "";
rs.executeQuery("select requestid from " + MAIN_FLOW_TABLE + " where id = ?", mainId);
if (rs.next()) {
mainRequestId = rs.getString("requestid");
}
if (StringUtils.isBlank(mainRequestId)) {
errorMsg.add("主流程ID[" + mainId + "],主流程requestId获取异常，请确认");
rs.executeUpdate(updateDetailSql, "2", detailId);
return;
}
rs.writeLog("mainRequestId==" + mainRequestId);
rs.writeLog("conclusion==" + conclusion);
rs.writeLog("tableNameByRequestId==" + tableNameByRequestId);
rs.executeUpdate("update " + tableNameByRequestId + " set spfhjl = ? where requestid = ?", conclusion, mainRequestId);
rs.executeUpdate("update " + MAIN_FLOW_TABLE + " set spfhjl = ? where requestid = ?", conclusion, mainRequestId);
// 更新完成后，自动提交流程到下一节点
rs.writeLog("mainRequestId==" + mainRequestId);