b2894lxlx/tms-erp-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mk调试

Browse Source
This commit is contained in:
b2894lxlx
2026-09-25 15:21:22 +08:00
parent 5f036ebe6a
commit feb0ce8ee2
2 changed files with 9 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
blade-service/blade-transport/src/main/java/org/springblade/transport/mk/MkProcessMessageService.java
+4 -7
View File
@@ -10,7 +10,6 @@ import org.springblade.core.tool.utils.StringUtil;
import org.springblade.process.feign.IBusinessProcessClient;
import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
@@ -129,14 +128,12 @@ public class MkProcessMessageService {
if (!"20".equals(firstText(info, "fdProcessStatus"))) {
return false;
}
if (hasItems(info.get("currentHandlers"))) {
Object historyHandlerInfos = asMap(info.get("fdTaskInfo")).get("historyHandlerInfos");
if (!(historyHandlerInfos instanceof List<?> historyList) || historyList.isEmpty()) {
return false;
}
return !hasItems(asMap(info.get("fdTaskInfo")).get("handlerInfos"));
}
private static boolean hasItems(Object value) {
return value instanceof Collection<?> collection && !collection.isEmpty();
Object lastHandler = historyList.get(historyList.size() - 1);
return "N6".equals(firstText(asMap(lastHandler), "nodeNumber"));
}
private void applyProcessResult(IMkProcessBizHandler handler, String bizType, String bizIdText,
blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/CustomerArchivePublicProcessService.java
+5 -7
View File
@@ -15,9 +15,9 @@ import org.springblade.process.feign.IBusinessProcessClient;
import org.springblade.transport.service.ICustomerArchiveService;
import org.springframework.stereotype.Service;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
@@ -120,14 +120,12 @@ public class CustomerArchivePublicProcessService {
if (!"20".equals(firstText(info, "fdProcessStatus"))) {
return false;
}
if (hasItems(info.get("currentHandlers"))) {
Object historyHandlerInfos = asMap(info.get("fdTaskInfo")).get("historyHandlerInfos");
if (!(historyHandlerInfos instanceof List<?> historyList) || historyList.isEmpty()) {
return false;
}
return !hasItems(asMap(info.get("fdTaskInfo")).get("handlerInfos"));
}
private static boolean hasItems(Object value) {
return value instanceof Collection<?> collection && !collection.isEmpty();
Object lastHandler = historyList.get(historyList.size() - 1);
return "N6".equals(firstText(asMap(lastHandler), "nodeNumber"));
}
private void applyProcessResult(String customerIdText, String processId, Map<String, Object> formValues,