From e97e5cc1d6b14914ed2aa5cb281bfaeef78c7757 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期五, 18 八月 2023 11:15:45 +0800
Subject: [PATCH] 上海市接口-提交指令解析2
---
src/main/java/com/fzzy/order/OrderManager.java | 38 ++-
src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java | 113 +++++++++
src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java | 59 +++++
src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java | 123 +++++++++++
src/main/java/com/fzzy/push/sh2023/SH2023OrderApiServiceImpl.java | 177 ++++++++++++++++
src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java | 99 ++++++++
src/main/java/com/fzzy/push/whhpjl/WhjlOrderApiServiceImpl.java | 29 ++
src/main/java/com/fzzy/api/view/repository/Api1101Rep.java | 9
src/main/java/com/fzzy/order/OrderApiService.java | 5
9 files changed, 628 insertions(+), 24 deletions(-)
diff --git a/src/main/java/com/fzzy/api/view/repository/Api1101Rep.java b/src/main/java/com/fzzy/api/view/repository/Api1101Rep.java
index 7aaa4a0..0a9d967 100644
--- a/src/main/java/com/fzzy/api/view/repository/Api1101Rep.java
+++ b/src/main/java/com/fzzy/api/view/repository/Api1101Rep.java
@@ -7,6 +7,7 @@
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;
+import java.util.Date;
import java.util.List;
@@ -31,4 +32,12 @@
*/
@Query("from Api1101 where kqdm=:kqdm ")
List<Api1101> findPushData(@Param("kqdm") String kqdm);
+
+ /**
+ * 鍗曚綅淇℃伅
+ * @param kqdm
+ * @return
+ */
+ @Query("from Api1101 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Api1101> getDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);
}
diff --git a/src/main/java/com/fzzy/order/OrderApiService.java b/src/main/java/com/fzzy/order/OrderApiService.java
index 1f66d84..4d1b88b 100644
--- a/src/main/java/com/fzzy/order/OrderApiService.java
+++ b/src/main/java/com/fzzy/order/OrderApiService.java
@@ -1,6 +1,9 @@
package com.fzzy.order;
+import com.fzzy.api.entity.ApiConfs;
import com.fzzy.order.data.OrderData;
+
+import java.text.ParseException;
/**
* 鏍规嵁鍗忚瑙ｆ瀽鎸囦护
@@ -23,5 +26,5 @@
* @throws Exception
*/
- public void execute(OrderData req, String orderType);
+ public void execute(OrderData req, String orderType, ApiConfs apiConfs) throws ParseException;
}
diff --git a/src/main/java/com/fzzy/order/OrderManager.java b/src/main/java/com/fzzy/order/OrderManager.java
index 34bb930..edecb88 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);
- service.execute(data, req.getType());
+ //鏍规嵁閰嶇疆淇℃伅鎵ц
+ OrderApiService service;
+ for (ApiConfs conf : apiConfList) {
+
+ service = serviceMap.get(conf.getPushProtocol());
+ if(null == service){
+ continue;
+ }
+
+ service.execute(data, req.getType(), conf);
+ }
+ } catch (Exception e) {
+ log.error("-----鎸囦护瑙ｆ瀽寮傚父-----鎸囦护={}", req);
+ e.printStackTrace();
}
+
}
}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023OrderApiServiceImpl.java b/src/main/java/com/fzzy/push/sh2023/SH2023OrderApiServiceImpl.java
new file mode 100644
index 0000000..6aa8878
--- /dev/null
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023OrderApiServiceImpl.java
@@ -0,0 +1,177 @@
+package com.fzzy.push.sh2023;
+
+import com.alibaba.fastjson.JSON;
+import com.fzzy.api.Constant;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.entity.ApiConfs;
+import com.fzzy.order.OrderApiService;
+import com.fzzy.order.data.OrderConstant;
+import com.fzzy.order.data.OrderData;
+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 java.text.ParseException;
+
+/**
+ * 涓婃捣甯傚钩鍙�2023鐗�-鎸囦护瑙ｆ瀽
+ *
+ * @author czt
+ * @date 2023/08/17
+ */
+@Slf4j
+public class SH2023OrderApiServiceImpl implements OrderApiService {
+
+ @Autowired
+ private SH2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private SH2023PushService11 sh2023PushService11;
+ @Autowired
+ private SH2023PushService12 sh2023PushService12;
+ @Autowired
+ private SH2023PushService13 sh2023PushService13;
+ @Autowired
+ private SH2023PushService14 sh2023PushService14;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_SH_2023.getCode();
+ }
+
+
+ @Override
+ public void execute(OrderData req, String orderType, ApiConfs conf) throws ParseException {
+
+ // 鑻ユ寚浠ょ被鍨嬩笉涓�1锛屽垯杩斿洖
+ if(!OrderConstant.ORDER_TYPE_1.equals(orderType)){
+ return;
+ }
+ String ids = req.getContent();
+ if(StringUtils.isEmpty(ids)){
+ return;
+ }
+
+ ApiParam param = new ApiParam();
+ param.setPushProtocol(conf.getPushProtocol());
+ param.setKqdm(conf.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(conf.getDeptId());
+
+ String[] interfaces = ids.split(",");
+ for (String inteId : interfaces) {
+ param.setInteId(inteId);
+ getDataToPush(param, inteId);
+ }
+
+ }
+
+ private void getDataToPush(ApiParam param, String inteId) {
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(inteId);
+
+ switch (inteId) {
+ case "1101":
+ sh2023PushService11.pushData1101(apiRemoteService, param);
+ case "1102":
+ sh2023PushService11.pushData1102(apiRemoteService, param);
+ case "1103":
+ sh2023PushService11.pushData1103(apiRemoteService, param);
+ case "1104":
+ sh2023PushService11.pushData1104(apiRemoteService, param);
+ case "1105":
+ sh2023PushService11.pushData1105(apiRemoteService, param);
+ case "1106":
+ sh2023PushService11.pushData1106(apiRemoteService, param);
+ case "1107":
+ sh2023PushService11.pushData1107(apiRemoteService, param);
+ case "1108":
+ sh2023PushService11.pushData1108(apiRemoteService, param);
+ case "1109":
+ sh2023PushService11.pushData1109(apiRemoteService, param);
+ case "1110":
+ sh2023PushService11.pushData1110(apiRemoteService, param);
+ case "1111":
+ sh2023PushService11.pushData1111(apiRemoteService, param);
+ case "1112":
+ sh2023PushService11.pushData1112(apiRemoteService, param);
+ case "1113":
+ sh2023PushService11.pushData1113(apiRemoteService, param);
+ case "1114":
+ sh2023PushService11.pushData1114(apiRemoteService, param);
+ case "1201":
+ sh2023PushService12.pushData1201(apiRemoteService, param);
+ case "1202":
+ sh2023PushService12.pushData1202(apiRemoteService, param);
+ case "1203":
+ sh2023PushService12.pushData1203(apiRemoteService, param);
+ case "1204":
+ sh2023PushService12.pushData1204(apiRemoteService, param);
+ case "1205":
+ sh2023PushService12.pushData1205(apiRemoteService, param);
+ case "1206":
+ sh2023PushService12.pushData1206(apiRemoteService, param);
+ case "1207":
+ sh2023PushService12.pushData1207(apiRemoteService, param);
+ case "1208":
+ sh2023PushService12.pushData1209(apiRemoteService, param);
+ case "1209":
+ sh2023PushService12.pushData1209(apiRemoteService, param);
+ case "1210":
+ sh2023PushService12.pushData1210(apiRemoteService, param);
+ case "1211":
+ sh2023PushService12.pushData1211(apiRemoteService, param);
+ case "1212":
+ sh2023PushService12.pushData1212(apiRemoteService, param);
+ case "2101":
+ sh2023PushService12.pushData2101(apiRemoteService, param);
+ case "2102":
+ sh2023PushService12.pushData2102(apiRemoteService, param);
+ case "2104":
+ sh2023PushService12.pushData2104(apiRemoteService, param);
+ case "1301":
+ sh2023PushService13.pushData1301(apiRemoteService, param);
+ case "1302":
+ sh2023PushService13.pushData1302(apiRemoteService, param);
+ case "1303":
+ sh2023PushService13.pushData1303(apiRemoteService, param);
+ case "1304":
+ sh2023PushService13.pushData1304(apiRemoteService, param);
+ case "1305":
+ sh2023PushService13.pushData1305(apiRemoteService, param);
+ case "1306":
+ sh2023PushService13.pushData1306(apiRemoteService, param);
+ case "1307":
+ sh2023PushService13.pushData1307(apiRemoteService, param);
+ case "1308":
+ sh2023PushService13.pushData1308(apiRemoteService, param);
+ case "1309":
+ sh2023PushService13.pushData1309(apiRemoteService, param);
+ case "1310":
+ sh2023PushService13.pushData1310(apiRemoteService, param);
+ case "1311":
+ sh2023PushService13.pushData1311(apiRemoteService, param);
+ case "2103":
+ sh2023PushService13.pushData2103(apiRemoteService, param);
+ case "1401":
+ sh2023PushService14.pushData1401(apiRemoteService, param);
+ case "1402":
+ sh2023PushService14.pushData1402(apiRemoteService, param);
+ case "1403":
+ sh2023PushService14.pushData1403(apiRemoteService, param);
+ case "1404":
+ sh2023PushService14.pushData1404(apiRemoteService, param);
+ case "1405":
+ sh2023PushService14.pushData1405(apiRemoteService, param);
+ case "2203":
+ sh2023PushService14.pushData2203(apiRemoteService, param);
+ case "2204":
+ sh2023PushService14.pushData2204(apiRemoteService, param);
+ default:
+ log.error("-----涓婃捣甯傚钩鍙帮細鏈尮閰嶅埌鎺ュ彛缂栫爜锛屼笉鎺ㄩ��-----");
+ }
+
+ }
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
index 83d57da..5ddcc8e 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
@@ -36,6 +36,7 @@
@Override
public void pushData(ApiParam param) {
+
log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤寮�濮�");
//鎺ㄩ�佸崟浣嶄俊鎭�
@@ -49,12 +50,13 @@
/**
* 1101 鍗曚綅淇℃伅
*/
- private void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {
+ public void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {
- //TODO 鑾峰彇鍗曚綅淇℃伅
- List<Api1101> list = null;
+ //鑾峰彇鍗曚綅淇℃伅
+ List<Api1101> list = api1101Rep.getDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
if (null == list || list.isEmpty()) {
+ log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌鍗曚綅淇℃伅锛屼笉鎺ㄩ��-----");
return;
}
@@ -68,9 +70,112 @@
data.setCzbz(Constant.CZBZ_U);
//鏇存柊鐘舵��
api1101Rep.save(data);
-
}
}
}
}
+
+ /**
+ * 1102 搴撳尯淇℃伅
+ */
+ public void pushData1102(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1103 浠撴埧淇℃伅
+ */
+ public void pushData1103(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1104 寤掗棿淇℃伅
+ */
+ public void pushData1104(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1105 璐т綅淇℃伅
+ */
+ public void pushData1105(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1106 娌圭綈淇℃伅
+ */
+ public void pushData1106(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1107 璁惧淇℃伅
+ */
+ public void pushData1107(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1108 鑽墏淇℃伅
+ */
+ public void pushData1108(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1109 鏂囦欢淇℃伅
+ */
+ public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1110 搴撳尯鍥句粨鎴跨偣浣嶆爣娉�
+ */
+ public void pushData1110(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1111 搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉�
+ */
+ public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1112 浜哄憳淇℃伅
+ */
+ public void pushData1112(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1113 浼佷笟淇＄敤淇℃伅
+ */
+ public void pushData1113(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1114 璐㈠姟鎶ヨ〃
+ */
+ public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
}
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
index 2f2520a..af4414e 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService12.java
@@ -2,6 +2,7 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
@@ -20,7 +21,7 @@
@Autowired
- private ComPushService11 pushService;
+ private SH2023ApiRemoteService apiRemoteService;
@Override
public String getProtocol() {
@@ -36,4 +37,124 @@
log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤缁撴潫");
}
+
+ /**
+ * 1201 鍚堝悓淇℃伅
+ */
+ public void pushData1201(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1202 绮鍏ュ簱淇℃伅
+ */
+ public void pushData1202(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1203 绮鍏ュ簱妫�楠屼俊鎭�
+ */
+ public void pushData1203(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1204 绮鍏ュ簱缁撶畻淇℃伅
+ */
+ public void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1205 绮鍑哄簱淇℃伅
+ */
+ public void pushData1205(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1206 绮鍑哄簱缁撶畻淇℃伅
+ */
+ public void pushData1206(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1207 鍊掍粨鍊掑嚭
+ */
+ public void pushData1207(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1208 绮搴撳瓨
+ */
+ public void pushData1208(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1209 鎹熸孩鍗�
+ */
+ public void pushData1209(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1210 绮鎬ц川杞彉鍗�
+ */
+ public void pushData1210(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1211 璐﹂潰搴撳瓨
+ */
+ public void pushData1211(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1212 瀹㈡埛淇℃伅
+ */
+ public void pushData1212(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2101 妫�鏂ゅ崟
+ */
+ public void pushData2101(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2102 鍊掍粨鍊掑叆
+ */
+ public void pushData2102(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2104 甯傚偍椹宠繍鍗�
+ */
+ public void pushData2104(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
}
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
index f04948f..f116bb8 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService13.java
@@ -2,6 +2,7 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
@@ -20,7 +21,7 @@
@Autowired
- private ComPushService11 pushService;
+ private SH2023ApiRemoteService apiRemoteService;
@Override
public String getProtocol() {
@@ -36,4 +37,100 @@
log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤缁撴潫");
}
+
+ /**
+ * 1301 瀹夊叏绠＄悊
+ */
+ public void pushData1301(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1302 娓╂箍搴︽娴�
+ */
+ public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1303 瀹宠櫕妫�娴�
+ */
+ public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1304 姘斾綋妫�娴�
+ */
+ public void pushData1304(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1305 閫氶浣滀笟
+ */
+ public void pushData1305(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1306 鐔忚捀浣滀笟
+ */
+ public void pushData1306(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1307 浠撳唴瑙嗛鍥惧儚
+ */
+ public void pushData1307(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1308 瑙嗛鐩戞帶寮傚父浜嬩欢鍛婅
+ */
+ public void pushData1308(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1309 杩濊棰勮淇℃伅
+ */
+ public void pushData1309(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1310 璐ㄦ鏁版嵁
+ */
+ public void pushData1310(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1311 瑙嗛鐩戞帶鎺ュ彛
+ */
+ public void pushData1311(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2103 绮儏璁惧閰嶇疆
+ */
+ public void pushData2103(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
}
diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java
index 1fd1b44..b76813d 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService14.java
@@ -2,8 +2,8 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
-import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -20,7 +20,7 @@
@Autowired
- private ComPushService11 pushService;
+ private SH2023ApiRemoteService apiRemoteService;
@Override
public String getProtocol() {
@@ -36,4 +36,59 @@
log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤缁撴潫");
}
+
+ /**
+ * 1401 鍌ㄥ瑙勬ā
+ */
+ public void pushData1401(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1402 鍌ㄥ璁″垝淇℃伅
+ */
+ public void pushData1402(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1403 杞崲璁″垝淇℃伅
+ */
+ public void pushData1403(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 1404 杞崲璁″垝鏄庣粏淇℃伅
+ */
+ public void pushData1404(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+ /**
+ * 1405 椤圭洰淇℃伅
+ */
+ public void pushData1405(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2203 浜ゆ槗涓績鍚堝悓
+ */
+ public void pushData2203(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
+
+ /**
+ * 2204 瀹氬寲姘存楠�
+ */
+ public void pushData2204(ApiRemoteService apiRemoteService, ApiParam param) {
+ //TODO
+
+ }
}
diff --git a/src/main/java/com/fzzy/push/whhpjl/WhjlOrderApiServiceImpl.java b/src/main/java/com/fzzy/push/whhpjl/WhjlOrderApiServiceImpl.java
new file mode 100644
index 0000000..27afb04
--- /dev/null
+++ b/src/main/java/com/fzzy/push/whhpjl/WhjlOrderApiServiceImpl.java
@@ -0,0 +1,29 @@
+package com.fzzy.push.whhpjl;
+
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.entity.ApiConfs;
+import com.fzzy.order.OrderApiService;
+import com.fzzy.order.data.OrderData;
+
+/**
+ * 涓婃姹夊啗绮钩鍙�2023鐗�-鎸囦护瑙ｆ瀽
+ *
+ * @author czt
+ * @date 2023/08/17
+ */
+public class WhjlOrderApiServiceImpl implements OrderApiService {
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_WHJL_2023.getCode();
+ }
+
+
+ @Override
+ public void execute(OrderData req, String orderType, ApiConfs apiConfs) {
+
+ //TODO 寰呭疄鐜�
+
+ }
+
+}
\ No newline at end of file
--
Gitblit v1.9.3