From 11430ae628f098654579811131abc522d679e870 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期一, 22 九月 2025 17:04:42 +0800
Subject: [PATCH] 上海对农接口调整-增加自动上传
---
src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java | 115 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 115 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java
new file mode 100644
index 0000000..37885d1
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java
@@ -0,0 +1,115 @@
+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.SyncService12;
+import com.fzzy.async.fzzy61.impl.*;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+
+/**
+ * @Desc: 绮璐攢鐩稿叧鏁版嵁鍚屾
+ * @author: czt
+ * @update-time: 2023/6/29
+ */
+@Component
+public class Fzzy61SyncService12 implements SyncService12 {
+
+ @Autowired
+ private Fzzy61Sync1201 fzzySync1201;
+ @Autowired
+ private Fzzy61Sync1202 fzzySync1202;
+ @Autowired
+ private Fzzy61Sync1203 fzzySync1203;
+ @Autowired
+ private Fzzy61Sync1204 fzzySync1204;
+ @Autowired
+ private Fzzy61Sync1205 fzzySync1205;
+ @Autowired
+ private Fzzy61Sync1206 fzzySync1206;
+ @Autowired
+ private Fzzy61Sync1207 fzzySync1207;
+ @Autowired
+ private Fzzy61Sync1208 fzzySync1208;
+ @Autowired
+ private Fzzy61Sync1209 fzzySync1209;
+ @Autowired
+ private Fzzy61Sync1211 fzzySync1211;
+ @Autowired
+ private Fzzy61Sync1210 fzzySync1210;
+ @Autowired
+ private Fzzy61Sync1212 fzzySync1212;
+ @Autowired
+ private Fzzy61Sync1213 fzzySync1213;
+ @Autowired
+ private Fzzy61Sync1109 fzzySync1109;
+ @Autowired
+ private Fzzy61Sync2102 fzzySync2102;
+
+ @Override
+ public String getProtocol() {
+ return SyncProtocol.FZZY_V61_GB.getCode();
+ }
+
+ @Override
+ public void syncData(ApiParam param) {
+
+ String kqdm = param.getKqdm();
+ String deptId = param.getDeptId();
+ Date start = param.getStart();
+ Date end = param.getEnd();
+
+ //瀹㈡埛鍚屾
+ fzzySync1212.syncData(kqdm, deptId, start, end);
+
+ //鍚堝悓鍚屾
+ fzzySync1201.syncData(kqdm, deptId, start, end);
+
+ //绮鍏ュ簱缁撶畻
+ fzzySync1204.syncData(kqdm, deptId, start, end);
+
+ //绮鍏ュ簱鍚屾
+ fzzySync1202.syncData(kqdm, deptId, start, end);
+
+ //绮鍏ュ簱璐ㄦ
+ fzzySync1203.syncData(kqdm, deptId, start, end);
+
+ //绮鍑哄簱缁撶畻
+ fzzySync1206.syncData(kqdm, deptId, start, end);
+
+ //绮鍑哄簱鍚屾
+ fzzySync1205.syncData(kqdm, deptId, start, end);
+
+ //绮鎹熺泭
+ fzzySync1209.syncData(kqdm, deptId, start, end);
+ //鍊掍粨淇℃伅鍚屾
+ fzzySync1207.syncData(kqdm, deptId, start, end);
+
+ //鍑哄叆搴撴枃浠朵俊鎭悓姝�
+ fzzySync1109.syncData(kqdm, deptId, start, end);
+
+ //绮搴撳瓨鍚屾
+ fzzySync1208.syncData(kqdm, deptId, start, end);
+
+ //绮鎬ц川杞彉淇℃伅鍚屾
+ fzzySync1210.syncData(kqdm, deptId, start, end);
+
+ //璐﹂潰搴撳瓨淇℃伅鍚屾
+ fzzySync1211.syncData(kqdm, deptId, start, end);
+ //灏佷粨纭淇℃伅鍚屾
+ fzzySync1213.syncData(kqdm, deptId, start, end);
+
+ /*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/
+ //涓婃捣甯傚钩鍙�2023鐗�
+ if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
+ //鍊掍粨鍊掑叆淇℃伅鍚屾
+ fzzySync2102.syncData(kqdm, deptId, start, end);
+ }
+
+ }
+
+}
--
Gitblit v1.9.3