From 62b592d65a8c84114b2240ee7ba78c6ae2fe93e6 Mon Sep 17 00:00:00 2001 From: CZT <czt18638530771@163.com> Date: 星期二, 24 十月 2023 14:42:24 +0800 Subject: [PATCH] 武汉省平台-调整接口上报为单条集合形式上报 --- src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java | 56 ++++++++++++++++++++++++++++++++++++++++---------------- 1 files changed, 40 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java index 11947f2..8ab63e0 100644 --- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java +++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java @@ -1,11 +1,11 @@ package com.fzzy.async.fzzy40; 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.fzzy35.impl.Fzzy35Sync1203; -import com.fzzy.async.fzzy35.impl.Fzzy35Sync1208; import com.fzzy.async.fzzy40.impl.*; +import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; @@ -30,6 +30,22 @@ private Fzzy40Sync1208 fzzySync1208; @Autowired private Fzzy40Sync1203 fzzySync1203; + @Autowired + private Fzzy40Sync1204 fzzySync1204; + @Autowired + private Fzzy40Sync1206 fzzySync1206; + @Autowired + private Fzzy40Sync1207 fzzySync1207; + @Autowired + private Fzzy40Sync1209 fzzySync1209; + @Autowired + private Fzzy40Sync1210 fzzySync1210; + @Autowired + private Fzzy40Sync1109 fzzySync1109; + @Autowired + private Fzzy40Sync2101 fzzySync2101; + @Autowired + private Fzzy40Sync2104 fzzySync2104; @Override public String getProtocol() { @@ -53,30 +69,38 @@ //绮鍏ュ簱鍚屾 fzzySync1202.syncData(kqdm, deptId, start, end); - //绮鍏ュ簱璐ㄦ TODO + //绮鍏ュ簱璐ㄦ fzzySync1203.syncData(kqdm, deptId, start, end); - //绮鍏ュ簱缁撶畻 TODO - + //绮鍏ュ簱缁撶畻 + fzzySync1204.syncData(kqdm, deptId, start, end); //绮鍑哄簱鍚屾 fzzySync1205.syncData(kqdm, deptId, start, end); - //绮鍑哄簱缁撶畻 TODO + //绮鍑哄簱缁撶畻 + fzzySync1206.syncData(kqdm, deptId, start, end); + //绮鎹熺泭 + fzzySync1209.syncData(kqdm, deptId, start, end); + //鍊掍粨淇℃伅鍚屾 + fzzySync1207.syncData(kqdm, deptId, start, end); - //绮鎹熺泭 TODO + //鍑哄叆搴撴枃浠朵俊鎭悓姝� + fzzySync1109.syncData(kqdm, deptId, start, end); - //鍊掍粨淇℃伅鍚屾 TODO - - - //鍑哄叆搴撴枃浠朵俊鎭悓姝� TODO - - - //绮搴撳瓨鍚屾 TODO + //绮搴撳瓨鍚屾 fzzySync1208.syncData(kqdm, deptId, start, end); - //绮鎬ц川杞彉淇℃伅鍚屾 TODO + //绮鎬ц川杞彉淇℃伅鍚屾 + fzzySync1210.syncData(kqdm, deptId, start, end); - + /*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/ + if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) { + //涓婃捣甯傚钩鍙�2023鐗堬紝闇�瑕佸悓姝ュ競鍌ㄦ鏂ゅ崟锛屽悓姝ュ競鍌ㄩ┏杩愬崟 +// //鍚屾甯傚偍妫�鏂ゅ崟 +// fzzySync2101.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd()); +// //鍚屾甯傚偍椹宠繍鍗� +// fzzySync2104.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd()); + } //璐﹂潰搴撳瓨淇℃伅鍚屾 TODO } -- Gitblit v1.9.3