高代码开发：全异步服务A中业务逻辑调用其他全异步服务B（稳态），服务A回调没有执行

华为云测试区
租户：icd
问题描述：
全异步服务A中业务逻辑调用其他全异步服务B（稳态）。
1.稳态全异步服务B能正常回调返回数据
2.服务A请求回复正常，但是回调服务没有执行。
请协助排查，谢谢。

服务接口定义：

1.     /**
   
2.      *  稳态API异步请求
   
3.      *
   
4.      * @param headers 请求头信息
   
5.      * @param messageBody 业务信息
   
6.      * @return java.util.Map<java.lang.String, java.lang.Object>
   
7.      * @author liwei1
   
8.      * @date 2024/11/15 17:33
   
9.      */
   
10.     @EAIService(id="spa.icd.async.stable.api.process")
    
11. //    @Api(name = {"icd.erp.out.wo.release"})
    
12.     public DWEAIResult processAsyncStableApi(Map<String, Object> headers, Map<String, Object> messageBody) throws Exception;
    
13. 
    
14. 
    
15.     /**
    
16.      * 稳态API异步请求，稳态API请求的callback
    
17.      *
    
18.      * @param headers
    
19.      * @param messageBody
    
20.      * @Author: xieJinLong
    
21.      * @DateTime: 2021-9-26 16:29
    
22.      * @Return com.digiwin.app.service.DWEAIResult
    
23.      */
    
24.     @EAICallback(id = "spa.icd.async.stable.api.process.callBack")
    
25.     DWEAIResult processAsyncStableApieCallBack(Map<String, Object> headers, String messageBody) throws Exception;

复制代码

服务实现：

1.     /**
   
2.      * 稳态API请求
   
3.      * spa.icd.async.stable.api.process
   
4.      *
   
5.      * @param headers     请求头信息
   
6.      * @param messageBody 业务信息
   
7.      * @return java.util.Map<java.lang.String, java.lang.Object>
   
8.      * @author liwei1
   
9.      * @date 2024/11/15 17:33
   
10.      */
    
11.     @Override
    
12.     public DWEAIResult processAsyncStableApi(Map<String, Object> headers, Map<String, Object> messageBody) throws Exception {
    
13.         Map bodyParameter = AppCommonUtils.getBodyParameter(messageBody);
    
14.         //接口名称
    
15.         String serviceName = bodyParameter.containsKey("service_name") ? bodyParameter.get("service_name").toString() : Strings.EMPTY;
    
16.         //业务信息
    
17.         Map<String, Object> requestInfo = (Map<String, Object>) bodyParameter.get("business_info");
    
18. 
    
19. 
    
20.         //调用异步稳态api
    
21.         DWEAIFasyncChainResult dweaiFasyncChainResult = new DWEAIFasyncChainResult("0", "", "", new HashMap<>(),
    
22.                 () -> {
    
23.                     try {
    
24.                         //调用稳态接口
    
25.                         AppCommonUtils.invokeFasyncStableApi(headers, serviceName, requestInfo, "spa.icd.async.stable.api.process.callBack", true);
    
26.                     } catch (Exception e) {
    
27.                         throw new RuntimeException(e);
    
28.                     }
    
29.                 },
    
30.                 (callbackHeaders, callbackMessageBody) -> {
    
31.                 });
    
32.         dweaiFasyncChainResult.setChainParameter("is_exception", true);
    
33.         return dweaiFasyncChainResult;
    
34.     }
    
35. 
    
36.     /**
    
37.      * 异步请求稳态API回调处理
    
38.      * spa.icd.async.stable.api.process.callBack
    
39.      *
    
40.      * @param headers     响应头信息
    
41.      * @param messageBody 业务信息
    
42.      * @return java.util.Map<java.lang.String, java.lang.Object>
    
43.      * @author liwei1
    
44.      * @date 2024/11/15 17:33
    
45.      */
    
46.     @Override
    
47.     public DWEAIResult processAsyncStableApieCallBack(Map<String, Object> headers, String messageBody) throws Exception {
    
48.         StdData stdData = AppCommonUtils.toStdData(messageBody);
    
49.         DigiSrvcode digiSrvcode = "0".equals(stdData.getCode()) ? DigiSrvcode.success : DigiSrvcode.failure;
    
50.         //region
    
51.         Map<String, Object> response = stdData.getParameter();
    
52. 
    
53.         //是否存在稳态请求异常
    
54.         Boolean isException = false;
    
55.         //异常处理信息
    
56.         String description = Strings.EMPTY;
    
57.         if ("0".equals(stdData.getCode())) {
    
58.             response = stdData.getParameter();
    
59.         } else {
    
60.             isException = true;
    
61.             description = stdData.getDescription();
    
62.         }
    
63.         Map<String, Object> parameter = new HashMap<>();
    
64.         parameter.put("is_exception", isException);
    
65.         //异常信息
    
66.         parameter.put("description", description);
    
67.         //业务信息
    
68.         parameter.put("business_info", response);
    
69. 
    
70.         //endregion
    
71. 
    
72.         // DWEAIChainTotalResult为服务给去中心化 ESP的回应
    
73.         DWEAIChainTotalResult chainTotalResult = new DWEAIChainTotalResult(stdData.getCode(), "111", "callback chainTotalResult", parameter);
    
74. 
    
75.         chainTotalResult.setDigiSrvcode(digiSrvcode);
    
76.         // 返回DWEAIFasyncChainEndResult结束调用链并继续调用链并返回给全异步服务spa.icd.async.stable.api.process「接收回应」
    
77.         DWEAIFasyncChainEndResult dweaiFasyncChainEndResult = new DWEAIFasyncChainEndResult("0", "", "callback", new HashMap<>(), (callbackHeaders, callbackMessageBody) -> {
    
78.             // 处理中心化 / EAI / ESP返回的「接收回应」信息
    
79.             System.out.println(callbackMessageBody.toString());
    
80.         }, chainTotalResult);
    
81.         dweaiFasyncChainEndResult.setDigiSrvcode(DigiSrvcode.success);
    
82.         return dweaiFasyncChainEndResult;
    
83.     }

复制代码

收到问题，内部确认中

1. 确认平台云呼叫地端异步服务是支持的
2. 现况没callback问题，需要确认地端服务是否有正常返回。 （需要加log确认下），
等待確認後往下排查。

問題定位在地中台沒正常返回給云中台，需請地中台人員確認
單子轉禪道單168002追踨