|
@@ -35,63 +35,77 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
- public R dataSync(String id, String code) {
|
|
|
- AssembleApiDataStrategy assembleApiDataStrategy = null;
|
|
|
+ public R pushDataSync(String id, String code) {
|
|
|
+ ApiRequestAndProcessingStrategy apiRequestAndProcessingStrategy = null;
|
|
|
switch (code) {
|
|
|
case "KC121":
|
|
|
- assembleApiDataStrategy = new AssembleKC121ApiData();
|
|
|
- case "KC122":
|
|
|
- assembleApiDataStrategy = new AssembleKC122ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC121ApiRequestAndProcessing();
|
|
|
case "KC123":
|
|
|
- assembleApiDataStrategy = new AssembleKC123ApiData();
|
|
|
- case "KC124":
|
|
|
- assembleApiDataStrategy = new AssembleKC124ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC123ApiRequestAndProcessing();
|
|
|
case "KC125":
|
|
|
- assembleApiDataStrategy = new AssembleKC125ApiData();
|
|
|
- case "KC126":
|
|
|
- assembleApiDataStrategy = new AssembleKC126ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC125ApiRequestAndProcessing();
|
|
|
case "KC127":
|
|
|
- assembleApiDataStrategy = new AssembleKC127ApiData();
|
|
|
- case "KC128":
|
|
|
- assembleApiDataStrategy = new AssembleKC128ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC127ApiRequestAndProcessing();
|
|
|
case "KC129":
|
|
|
- assembleApiDataStrategy = new AssembleKC129ApiData();
|
|
|
- case "KC130":
|
|
|
- assembleApiDataStrategy = new AssembleKC130ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC129ApiRequestAndProcessing();
|
|
|
case "KC131":
|
|
|
- assembleApiDataStrategy = new AssembleKC131ApiData();
|
|
|
- case "KC132":
|
|
|
- assembleApiDataStrategy = new AssembleKC132ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC131ApiRequestAndProcessing();
|
|
|
case "KC133":
|
|
|
- assembleApiDataStrategy = new AssembleKC133ApiData();
|
|
|
- case "KC134":
|
|
|
- assembleApiDataStrategy = new AssembleKC134ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC133ApiRequestAndProcessing();
|
|
|
case "KC135":
|
|
|
- assembleApiDataStrategy = new AssembleKC135ApiData();
|
|
|
- case "KC136":
|
|
|
- assembleApiDataStrategy = new AssembleKC136ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC135ApiRequestAndProcessing();
|
|
|
case "KC137":
|
|
|
- assembleApiDataStrategy = new AssembleKC137ApiData();
|
|
|
- case "KC138":
|
|
|
- assembleApiDataStrategy = new AssembleKC138ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC137ApiRequestAndProcessing();
|
|
|
case "KC139":
|
|
|
- assembleApiDataStrategy = new AssembleKC139ApiData();
|
|
|
- case "KC140":
|
|
|
- assembleApiDataStrategy = new AssembleKC140ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC139ApiRequestAndProcessing();
|
|
|
case "KC141":
|
|
|
- assembleApiDataStrategy = new AssembleKC141ApiData();
|
|
|
- case "KC142":
|
|
|
- assembleApiDataStrategy = new AssembleKC142ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC141ApiRequestAndProcessing();
|
|
|
case "KC143":
|
|
|
- assembleApiDataStrategy = new AssembleKC143ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC143ApiRequestAndProcessing();
|
|
|
+ default:
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ CalculatorContext primaryContext = new CalculatorContext(apiRequestAndProcessingStrategy);
|
|
|
+ // 数据组装
|
|
|
+ Map<String, Object> apiCallData = primaryContext.executeStrategy(id,null);
|
|
|
+ // 接口请求并 处理
|
|
|
+ return primaryContext.apiCallAndDataProcessing(id, code, apiCallData);
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public R deleteDataSync(String id, String dataId, String code) {
|
|
|
+ ApiRequestAndProcessingStrategy apiRequestAndProcessingStrategy = null;
|
|
|
+ switch (code) {
|
|
|
+ case "KC122":
|
|
|
+ apiRequestAndProcessingStrategy = new KC122ApiRequestAndProcessing();
|
|
|
+ case "KC124":
|
|
|
+ apiRequestAndProcessingStrategy = new KC124ApiRequestAndProcessing();
|
|
|
+ case "KC126":
|
|
|
+ apiRequestAndProcessingStrategy = new KC126ApiRequestAndProcessing();
|
|
|
+ case "KC128":
|
|
|
+ apiRequestAndProcessingStrategy = new KC128ApiRequestAndProcessing();
|
|
|
+ case "KC130":
|
|
|
+ apiRequestAndProcessingStrategy = new KC130ApiRequestAndProcessing();
|
|
|
+ case "KC132":
|
|
|
+ apiRequestAndProcessingStrategy = new KC132ApiRequestAndProcessing();
|
|
|
+ case "KC134":
|
|
|
+ apiRequestAndProcessingStrategy = new KC134ApiRequestAndProcessing();
|
|
|
+ case "KC136":
|
|
|
+ apiRequestAndProcessingStrategy = new KC136ApiRequestAndProcessing();
|
|
|
+ case "KC138":
|
|
|
+ apiRequestAndProcessingStrategy = new KC138ApiRequestAndProcessing();
|
|
|
+ case "KC140":
|
|
|
+ apiRequestAndProcessingStrategy = new KC140ApiRequestAndProcessing();
|
|
|
+ case "KC142":
|
|
|
+ apiRequestAndProcessingStrategy = new KC142ApiRequestAndProcessing();
|
|
|
case "KC144":
|
|
|
- assembleApiDataStrategy = new AssembleKC144ApiData();
|
|
|
+ apiRequestAndProcessingStrategy = new KC144ApiRequestAndProcessing();
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
- CalculatorContext primaryContext = new CalculatorContext(assembleApiDataStrategy);
|
|
|
+ CalculatorContext primaryContext = new CalculatorContext(apiRequestAndProcessingStrategy);
|
|
|
// 数据组装
|
|
|
- Map<String, Object> apiCallData = primaryContext.executeStrategy(id);
|
|
|
+ Map<String, Object> apiCallData = primaryContext.executeStrategy(id,code);
|
|
|
// 接口请求并 处理
|
|
|
return primaryContext.apiCallAndDataProcessing(id, code, apiCallData);
|
|
|
}
|