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/push/sh2023/SH2023PushService11.java |  146 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 144 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java b/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
index be16965..5ddcc8e 100644
--- a/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
+++ b/src/main/java/com/fzzy/push/sh2023/SH2023PushService11.java
@@ -1,12 +1,17 @@
 package com.fzzy.push.sh2023;
 
+import com.fzzy.api.Constant;
 import com.fzzy.api.data.ApiParam;
 import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.Api1101;
+import com.fzzy.api.service.ApiRemoteService;
 import com.fzzy.api.service.PushService11;
-import com.fzzy.push.impl.ComPushService11;
+import com.fzzy.api.view.repository.Api1101Rep;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
+import java.util.List;
 
 /**
  * 涓婃捣甯傚钩鍙�2023鐗�-鍩虹鏁版嵁涓婁紶
@@ -20,7 +25,9 @@
 
 
     @Autowired
-    private ComPushService11 pushService;
+    private SH2023ApiRemoteService apiRemoteService;
+    @Autowired
+    private Api1101Rep api1101Rep;
 
     @Override
     public String getProtocol() {
@@ -29,11 +36,146 @@
 
     @Override
     public void pushData(ApiParam param) {
+
         log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤寮�濮�");
 
         //鎺ㄩ�佸崟浣嶄俊鎭�
+        this.pushData1101(apiRemoteService, param);
+        //TODO 鍏朵粬鍩虹淇℃伅
 
 
         log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤缁撴潫");
     }
+
+    /**
+     * 1101 鍗曚綅淇℃伅
+     */
+    public void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {
+
+        //鑾峰彇鍗曚綅淇℃伅
+        List<Api1101> list = api1101Rep.getDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+        if (null == list || list.isEmpty()) {
+            log.error("-----涓婃捣甯傚钩鍙�2023鐗堬細鏈幏鍙栧埌鍗曚綅淇℃伅锛屼笉鎺ㄩ��-----");
+            return;
+        }
+
+        //鎺ㄩ�侊紝鏁版嵁涓洪泦鍚堝舰寮�
+        ResponseDto responseDto = apiRemoteService.pushData(param, list);
+        if (responseDto.getSuccess() == 0) {
+            //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
+            for (Api1101 data : list) {
+                if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+                    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
+
+    }
 }

--
Gitblit v1.9.3