From 5408346178dd12b7ab78fb51c76f59c300a7e153 Mon Sep 17 00:00:00 2001
From: ws <ws@123.com>
Date: 星期四, 31 十月 2024 23:37:31 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/com/fzzy/push/sx2024/SX2024OrderServiceImpl.java | 207 +++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 207 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/push/sx2024/SX2024OrderServiceImpl.java b/src/main/java/com/fzzy/push/sx2024/SX2024OrderServiceImpl.java
new file mode 100644
index 0000000..a2ad449
--- /dev/null
+++ b/src/main/java/com/fzzy/push/sx2024/SX2024OrderServiceImpl.java
@@ -0,0 +1,207 @@
+package com.fzzy.push.sx2024;
+
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.entity.ApiConfs;
+import com.fzzy.api.utils.RedisConst;
+import com.fzzy.api.utils.RedisUtil;
+import com.fzzy.order.ordersx2023.OrderSxService;
+import com.fzzy.order.ordersx2023.data.OrderSxConstant;
+import com.fzzy.order.ordersx2023.data.OrderSxReq;
+import com.fzzy.push.impl.ComPushService11;
+import com.fzzy.push.impl.ComPushService12;
+import com.fzzy.push.impl.ComPushService13;
+import com.fzzy.push.impl.ComPushService14;
+import com.fzzy.push.sx2023.SX2023ApiRemoteService;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.time.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.text.ParseException;
+
+/**
+ * @Description 闄曡タ鐪佸钩鍙�2023鐗�-鎸囦护瑙ｆ瀽
+ * @Author CZT
+ * @Date 2024/4/23 11:48
+ */
+@Slf4j
+@Service
+public class SX2024OrderServiceImpl implements OrderSxService {
+
+ @Autowired
+ private RedisUtil redisUtil;
+ @Autowired
+ private SX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private ComPushService11 pushService11;
+ @Autowired
+ private ComPushService12 pushService12;
+ @Autowired
+ private ComPushService13 pushService13;
+ @Autowired
+ private ComPushService14 pushService14;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_SX_2024.getCode();
+ }
+
+ @Override
+ public void execute(OrderSxReq req, ApiConfs apiConfs) throws ParseException {
+ // 鑻ユ寚浠ょ被鍨嬩笉涓�1锛屽垯杩斿洖
+ if (!OrderSxConstant.ORDER_SX_TYPE_1.equals(req.getType())) {
+ log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾寚浠ょ被鍨嬩笉涓�1锛屼笉鎵ц鏁版嵁涓婃姤锛侊紝鎸囦护绫诲瀷={}", req.getType());
+ return;
+ }
+ String datas = req.getData();
+ if (StringUtils.isEmpty(datas)) {
+ log.error("闄曡タ鐪佸钩鍙帮細鏀跺埌鎸囦护锛屾寚浠ゅ唴瀹逛负绌猴紝涓嶆墽琛屾暟鎹笂鎶ワ紒");
+ return;
+ }
+
+ //鎸囦护瀛樺叆缂撳瓨锛屾椂鏁�24灏忔椂
+ String key = RedisConst.buildKey(RedisConst.KYE_ORDER, apiConfs.getKqdm());
+ redisUtil.set(key, req.getOrderid(), 59 * 60 * 24);
+
+ ApiParam param = new ApiParam();
+ param.setPushProtocol(apiConfs.getPushProtocol());
+ param.setKqdm(apiConfs.getKqdm());
+ param.setStart(DateUtils.parseDate(req.getStartTime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
+ param.setEnd(DateUtils.parseDate(req.getEndTime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
+ param.setDeptId(apiConfs.getDeptId());
+
+ log.info("鎺ユ敹鐨勬寚浠や腑鎺ュ彛鍐呭涓�={}", datas);
+ String[] interfaces = datas.split(",");
+ for (String inteId : interfaces) {
+ log.info("鎵ц鎺ュ彛={}鐨勬暟鎹笂鎶�", inteId);
+ getDataToPush(param, inteId);
+ }
+ }
+
+
+ private void getDataToPush(ApiParam param, String inteId) {
+
+ switch (inteId) {
+ case "ODS_UP_DWXXJK":
+ pushService11.pushData1101(apiRemoteService, param);
+ break;
+ case "ODS_UP_KQXXJK":
+ pushService11.pushData1102(apiRemoteService, param);
+ break;
+ case "ODS_UP_CFXXJK":
+ pushService11.pushData1103(apiRemoteService, param);
+ break;
+ case "ODS_UP_AJXXJK":
+ pushService11.pushData1104(apiRemoteService, param);
+ break;
+ case "ODS_UP_HWXXJK":
+ pushService11.pushData1105(apiRemoteService, param);
+ break;
+ case "ODS_UP_YGXXJK":
+ pushService11.pushData1106(apiRemoteService, param);
+ break;
+ case "ODS_UP_SBXXJK":
+ pushService11.pushData1107(apiRemoteService, param);
+ break;
+ case "ODS_UP_YJXXJK":
+ pushService11.pushData1108(apiRemoteService, param);
+ break;
+ case "ODS_UP_WJXXJK":
+ pushService12.pushData1109(apiRemoteService, param);
+ break;
+ case "ODS_UP_KQTCFDWBZSJXXJK":
+ pushService11.pushData1110(apiRemoteService, param);
+ break;
+ case "ODS_UP_KQTSPJKSBDWBZSJXXJK":
+ pushService11.pushData1111(apiRemoteService, param);
+ break;
+ case "ODS_UP_RYXXJK":
+ pushService11.pushData1112(apiRemoteService, param);
+ break;
+ case "ODS_UP_CWBBXXJK":
+ pushService11.pushData1114(apiRemoteService, param);
+ break;
+ case "ODS_UP_HTXXJK":
+ pushService12.pushData1201(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSRKXXJK":
+ pushService12.pushData1202(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSRKJYXXJK":
+ pushService12.pushData1203(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSRKJSXXJK":
+ pushService12.pushData1204(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSCKXXJK":
+ pushService12.pushData1205(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSCKJSXXJK":
+ pushService12.pushData1206(apiRemoteService, param);
+ break;
+ case "ODS_UP_DCXXJK":
+ pushService12.pushData1207(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSKCXXJK":
+ pushService12.pushData1208(apiRemoteService, param);
+ break;
+ case "ODS_UP_SYDXXJK":
+ pushService12.pushData1209(apiRemoteService, param);
+ break;
+ case "ODS_UP_LSXZZBDXXJK":
+ pushService12.pushData1210(apiRemoteService, param);
+ break;
+ case "ODS_UP_ZMKCXXJK":
+ pushService12.pushData1211(apiRemoteService, param);
+ break;
+ case "ODS_UP_KHXXJK":
+ pushService12.pushData1212(apiRemoteService, param);
+ break;
+ case "ODS_UP_AQGLXXJK":
+ pushService13.pushData1301(apiRemoteService, param);
+ break;
+ case "ODS_UP_WSDJCXXJK":
+ pushService13.pushData1302(apiRemoteService, param);
+ break;
+ case "ODS_UP_CHJCXXJK":
+ pushService13.pushData1303(apiRemoteService, param);
+ break;
+ case "ODS_UP_QTJCXXJK":
+ pushService13.pushData1304(apiRemoteService, param);
+ break;
+ case "ODS_UP_TFZYXXJK":
+ pushService13.pushData1305(apiRemoteService, param);
+ break;
+ case "ODS_UP_XZZYXXJK":
+ pushService13.pushData1306(apiRemoteService, param);
+ break;
+ case "ODS_UP_CNSPTXXXJK":
+ pushService13.pushData1307(apiRemoteService, param);
+ break;
+ case "ODS_UP_SPJKYCSJGJJBXXJK":
+ pushService13.pushData1308(apiRemoteService, param);
+ break;
+ case "ODS_UP_WGYJXXJK":
+ pushService13.pushData1309(apiRemoteService, param);
+ break;
+ case "ODS_UP_ZJXXJK":
+ pushService13.pushData1310(apiRemoteService, param);
+ break;
+ case "ODS_UP_CBGMXXJK":
+ pushService14.pushData1401(apiRemoteService, param);
+ break;
+ case "ODS_UP_LHJHXXJK":
+ pushService14.pushData1403(apiRemoteService, param);
+ break;
+ case "ODS_UP_LHJHMXXXJK":
+ pushService14.pushData1404(apiRemoteService, param);
+ break;
+ default:
+ log.error("-----闄曡タ鐪佸钩鍙帮細鏈尮閰嶅埌鎺ュ彛缂栫爜锛屼笉鎺ㄩ��-----");
+ break;
+ }
+
+ }
+}
--
Gitblit v1.9.3