调整指令解析

czt

2024-04-23 a03d12962c4439cce9193f178c02164db20f734c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package com.fzzy.api.view.pr;
 
import lombok.extern.slf4j.Slf4j;
 
import com.bstek.dorado.annotation.Expose;
import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.service.*;
import com.fzzy.api.utils.ContextUtil;
 
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
/**
 * 手动同步数据业务入口
 *
 * @author Andy
 */
@Slf4j
@Component
public class SyncServicePR {
 
    @Autowired
    private ApiCommonService apiCommonService;
    @Autowired
    private ApiSyncManager apiSyncManager;
 
 
    /**
     * syncServicePR#syncData
     * 手动调用数据同步，根据接口分类编码
     *
     * @param param
     * @return
     */
    @Expose
    public String syncData(ApiParam param) {
 
 
        ApiConfs apiConfs = apiCommonService.getConf(param.getKqdm());
 
        if (null == apiConfs) {
            return "执行失败：没有获取到当前库区的配置信息";
        }
 
        //调整开始时间和截止时间
        param.setPushProtocol(apiConfs.getPushProtocol());
        param.setSyncProtocol(apiConfs.getSyncProtocol());
        param.setDeptId(apiConfs.getDeptId());
        param.setStart(ContextUtil.getCurZero(param.getStart()));
        param.setEnd(ContextUtil.getNextZero(param.getEnd()));
 
        log.info("-----手动同步数据 -----{}", param.getInteId());
 
 
        if (Constant.API_CATEGORY_11.equals(param.getInteId())) {
            SyncService11 syncService11 = apiSyncManager.getSyncService11(param.getSyncProtocol());
            syncService11.syncData(param);
        }
 
        if (Constant.API_CATEGORY_12.equals(param.getInteId())) {
            SyncService12 syncService12 = apiSyncManager.getSyncService12(param.getSyncProtocol());
            syncService12.syncData(param);
        }
 
        if (Constant.API_CATEGORY_13.equals(param.getInteId())) {
            SyncService13 syncService13 = apiSyncManager.getSyncService13(param.getSyncProtocol());
            syncService13.syncData(param);
        }
 
        if (Constant.API_CATEGORY_14.equals(param.getInteId())) {
            SyncService14 syncService14 = apiSyncManager.getSyncService14(param.getSyncProtocol());
            syncService14.syncData(param);
        }
 
        return "同步命令发送完成，请稍等刷新数据查看";
    }
 
 
}