|  |  |  | 
|---|
|  |  |  | 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; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1202 fzzySync1202; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1205 fzzySync1205; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1212 fzzySync1212; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1208 fzzySync1208; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1203 fzzySync1203; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1204 fzzySync1204; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1205 fzzySync1205; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1206 fzzySync1206; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1207 fzzySync1207; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1208 fzzySync1208; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1209 fzzySync1209; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1211 fzzySync1211; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1210 fzzySync1210; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1212 fzzySync1212; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1213 fzzySync1213; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync1109 fzzySync1109; | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private Fzzy40Sync2104 fzzySync2104; | 
|---|
|  |  |  | private Fzzy40Sync2102 fzzySync2102; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public String getProtocol() { | 
|---|
|  |  |  | 
|---|
|  |  |  | Date start = param.getStart(); | 
|---|
|  |  |  | Date end = param.getEnd(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /*-----各省独有接口信息同步-----*/ | 
|---|
|  |  |  | if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) { | 
|---|
|  |  |  | //上海市平台2023版,需要同步市储驳运单 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //同步市储驳运单 | 
|---|
|  |  |  | fzzySync2104.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), 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); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //粮食入库结算 | 
|---|
|  |  |  | fzzySync1204.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  | //粮食出库结算 | 
|---|
|  |  |  | fzzySync1206.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //粮食出库同步 | 
|---|
|  |  |  | fzzySync1205.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //粮食出库结算 | 
|---|
|  |  |  | fzzySync1206.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  | //粮食损益 | 
|---|
|  |  |  | fzzySync1209.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  | //倒仓信息同步 | 
|---|
|  |  |  | 
|---|
|  |  |  | //粮食性质转变信息同步 | 
|---|
|  |  |  | fzzySync1210.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //账面库存信息同步 | 
|---|
|  |  |  | fzzySync1211.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  | //封仓确认信息同步 | 
|---|
|  |  |  | fzzySync1213.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | //账面库存信息同步  TODO | 
|---|
|  |  |  | /*-----各省独有接口信息同步-----*/ | 
|---|
|  |  |  | //上海市平台2023版 | 
|---|
|  |  |  | if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) { | 
|---|
|  |  |  | //倒仓倒入信息同步 | 
|---|
|  |  |  | fzzySync2102.syncData(kqdm, deptId, start, end); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|