From ebaaa34038ebda73630c9ab82465c5f76692b5c2 Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期二, 05 十二月 2023 00:01:48 +0800
Subject: [PATCH] 提交粮情协议2，完成
---
src/main/java/com/fzzy/order/OrderManager.java | 38 +++++++++++++++++++++++---------------
1 files changed, 23 insertions(+), 15 deletions(-)
diff --git a/src/main/java/com/fzzy/order/OrderManager.java b/src/main/java/com/fzzy/order/OrderManager.java
index 34bb930..1e961bd 100644
--- a/src/main/java/com/fzzy/order/OrderManager.java
+++ b/src/main/java/com/fzzy/order/OrderManager.java
@@ -5,6 +5,7 @@
import com.fzzy.api.view.pr.ApiConfsPR;
import com.fzzy.order.data.OrderData;
import com.fzzy.order.data.OrderReq;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
@@ -21,6 +22,7 @@
* @author czt
* @date 2023/8/17
*/
+@Slf4j
@Component(OrderManager.BEAN_ID)
public class OrderManager implements ApplicationContextAware {
public static final String BEAN_ID = "order.orderManager";
@@ -47,23 +49,29 @@
@Async
public void execute(OrderReq<JSONObject> req){
- //鑾峰彇閰嶇疆淇℃伅
- List<ApiConfs> apiConfList = apiConfsPR.listAll();
- if(null == apiConfList || apiConfList.isEmpty()){
- return;
- }
- OrderData data = JSONObject.parseObject(req.getData().toString(), OrderData.class);
-
- //鏍规嵁閰嶇疆淇℃伅鎵ц
- OrderApiService service;
- for (ApiConfs apiConfs : apiConfList) {
-
- service = serviceMap.get(apiConfs.getPushProtocol());
- if(null == service){
- continue;
+ try{
+ //鑾峰彇閰嶇疆淇℃伅
+ List<ApiConfs> apiConfList = apiConfsPR.listAll();
+ if(null == apiConfList || apiConfList.isEmpty()){
+ return;
}
+ OrderData data = JSONObject.parseObject(req.getData().toString(), OrderData.class);
+ data.setOrderid(req.getOrderid());
+ //鏍规嵁閰嶇疆淇℃伅鎵ц
+ OrderApiService service;
+ for (ApiConfs conf : apiConfList) {
- service.execute(data, req.getType());
+ service = serviceMap.get(conf.getPushProtocol());
+ if(null == service){
+ continue;
+ }
+
+ service.execute(data, req.getType(), conf, req.getOrderid());
+ }
+ } catch (Exception e) {
+ log.error("-----鎸囦护瑙ｆ瀽寮傚父-----鎸囦护={}", req);
+ e.printStackTrace();
}
+
}
}
\ No newline at end of file
--
Gitblit v1.9.3