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.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 "同步命令发送完成，请稍等刷新数据查看";
|
}
|
|
|
}
|
