From 029de836702607a95ccb0a69a74efcea52ddc451 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期四, 25 九月 2025 19:35:38 +0800
Subject: [PATCH] 上海对农数据接口调整2

---
 src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService13.java |   93 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 93 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService13.java b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService13.java
new file mode 100644
index 0000000..4cb8da4
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService13.java
@@ -0,0 +1,93 @@
+package com.fzzy.async.fzzy61;
+
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.data.SyncProtocol;
+import com.fzzy.api.service.SyncService13;
+import com.fzzy.async.fzzy61.impl.*;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Desc: 绮绠＄悊淇℃伅鍚屾
+ * @author: czt
+ * @update-time: 2023/08/14
+ */
+@Component
+public class Fzzy61SyncService13 implements SyncService13 {
+
+    @Autowired
+    private Fzzy61Sync1302 fzzySync1302;
+    @Autowired
+    private Fzzy61Sync1303 fzzySync1303;
+    @Autowired
+    private Fzzy61Sync1304 fzzySync1304;
+    @Autowired
+    private Fzzy61Sync1305 fzzySync1305;
+    @Autowired
+    private Fzzy61Sync1306 fzzySync1306;
+    @Autowired
+    private Fzzy61Sync1307 fzzySync1307;
+    @Autowired
+    private Fzzy61Sync1310 fzzySync1310;
+    @Autowired
+    private Fzzy61Sync1023 fzzySync1023;
+    @Autowired
+    private Fzzy61Sync1311 fzzySync1311;
+    @Autowired
+    private Fzzy61Sync9201 fzzySync9201;
+    @Autowired
+    private Fzzy61Sync2103 fzzy61Sync2103;
+
+    @Override
+    public String getProtocol() {
+        return SyncProtocol.FZZY_V61_GB.getCode();
+    }
+
+    @Override
+    public void syncData(ApiParam param) {
+
+
+        /*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/
+        if (StringUtils.isNotEmpty(param.getPushProtocol()) && (PushProtocol.SB_GD_2022.getCode().equals(param.getPushProtocol())||PushProtocol.SB_GD_2023.getCode().equals(param.getPushProtocol()))) {
+            //骞夸笢鐪佸钩鍙�2022鐗堬紝闇�瑕佸悓姝ョ啅钂稿妗堜俊鎭�
+            //鐔忚捀澶囨鏁版嵁鍚屾
+            fzzySync1023.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+            fzzySync9201.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+        }
+        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
+            //涓婃捣甯傚钩鍙�2023鐗堬紝闇�瑕佸悓姝ョ伯鎯呰澶囬厤缃俊鎭�
+
+            //鍚屾绮儏璁惧閰嶇疆淇℃伅
+            fzzy61Sync2103.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+            //瑙嗛鐩戞帶淇℃伅鍚屾
+            fzzySync1311.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+        }
+
+        /*-----鍏叡鎺ュ彛-----*/
+
+        //娓╂箍搴︽娴嬫暟鎹悓姝�
+        fzzySync1302.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //铏妫�娴嬪悓姝�
+        fzzySync1303.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //姘斾綋妫�娴嬪悓姝�
+        fzzySync1304.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //璐ㄦ鍚屾
+        fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //閫氶浣滀笟淇℃伅鍚屾
+        fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //鐔忚捀浣滀笟淇℃伅鍚屾
+        fzzySync1306.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+        //浠撳唴瑙嗛鍥惧儚鎶撴媿鍚屾
+        fzzySync1307.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+
+    }
+
+}

--
Gitblit v1.9.3