|
|
@@ -3,6 +3,7 @@ package com.template.controller;
|
|
|
|
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
+import com.template.annotation.DESRespondSecret;
|
|
|
import com.template.api.SmartDataTaskControllerAPI;
|
|
|
import com.template.common.utils.AesUtils;
|
|
|
import com.template.common.utils.CommonUtil;
|
|
|
@@ -30,6 +31,7 @@ import java.util.Map;
|
|
|
* @since 2023-12-05
|
|
|
*/
|
|
|
@RestController
|
|
|
+@DESRespondSecret
|
|
|
public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
|
|
|
@Autowired
|
|
|
@@ -42,6 +44,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
private SmartDataSourceLogService smartDataSourceLogService;
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult createJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -66,6 +69,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult pauseJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -90,6 +94,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult resumeJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -114,6 +119,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult updateJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -137,6 +143,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult deleteJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -161,6 +168,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult runOnceJob(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -187,6 +195,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
/**
|
|
|
* 部门
|
|
|
*/
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult getDepart() {
|
|
|
Map<String, Object> result = smartDataTaskService.getDepart();
|
|
|
if (Integer.parseInt((String) result.get("code")) == 0) {
|
|
|
@@ -200,6 +209,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* 同步策略
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult getSyncPolicy() {
|
|
|
Map<String, Object> result = smartDataTaskService.getSyncPolicy();
|
|
|
if (Integer.parseInt((String) result.get("code")) == 0) {
|
|
|
@@ -213,6 +223,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* 交换方式
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult getExchangeType() {
|
|
|
Map<String, Object> result = smartDataTaskService.getExchangeType();
|
|
|
if (Integer.parseInt((String) result.get("code")) == 0) {
|
|
|
@@ -225,6 +236,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
/**
|
|
|
* 测试sql
|
|
|
*/
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult testSql(String json) {
|
|
|
// 获取数据源id对应的数据源
|
|
|
Map<String, Object> result = smartDataTaskService.testSql(json);
|
|
|
@@ -236,6 +248,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult getTables(String json) {
|
|
|
// 获取数据源id对应的数据源
|
|
|
Map<String, Object> result = smartDataTaskService.getTables(json);
|
|
|
@@ -247,6 +260,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult getViews(String json) {
|
|
|
// 获取数据源id对应的数据源
|
|
|
Map<String, Object> result = smartDataTaskService.getViews(json);
|
|
|
@@ -265,6 +279,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult insertSmartDataTask1(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -289,6 +304,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult insertSmartDataTask2(JSONObject json, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -313,6 +329,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult insertSmartDataTask3(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -344,6 +361,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult updateSmartDataTaskById1(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -369,6 +387,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult updateSmartDataTaskById2(JSONObject json, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -393,6 +412,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult updateSmartDataTaskById3(SmartDataTask smartDataTask, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -425,6 +445,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryPageSmartDataTasks(int currentPage, int pageCount, SmartDataTask smartDataTask) {
|
|
|
PageUtils<SmartDataTask> result = smartDataTaskService.queryPageSmartDataTasks(currentPage, pageCount, smartDataTask);
|
|
|
|
|
|
@@ -439,6 +460,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult deleteSmartDataTaskById(int id, int delMethod, HttpServletRequest httpServletRequest) {
|
|
|
|
|
|
SmartDataTask smartDataTask = smartDataTaskService.getSmartById(id);
|
|
|
@@ -505,6 +527,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return 返回
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryPageSmartDataTaskDebug(int currentPage, int pageCount, Integer eTaskId, String startTime, String endTime) {
|
|
|
PageInfo<SmartDataTaskDebug> result = smartDataTaskService.queryPageSmartDataTaskDebug(currentPage, pageCount, eTaskId, startTime, endTime);
|
|
|
|
|
|
@@ -520,6 +543,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
* @return 返回
|
|
|
*/
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult delSmartDataTaskDebugByIds(JSONObject json, HttpServletRequest httpServletRequest, BindingResult bindingResult) {
|
|
|
if (bindingResult.hasErrors()) {
|
|
|
String st = paramUtils.getParamError(bindingResult);
|
|
|
@@ -544,6 +568,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryPageSmartDataTaskLog(int currentPage, int pageCount, Integer eTaskId, String tkLogTaskName, Integer tkLogAutoManual,
|
|
|
Integer tkLogDsSourceId, Integer tkLogDsDestinationId,
|
|
|
Integer tkLogCostTime, Integer tkLogExeStatus, String startTime, String endTime) {
|
|
|
@@ -554,6 +579,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryAllTask() {
|
|
|
List<SmartDataTask> result = smartDataTaskService.queryAllTask();
|
|
|
if (result.size() > 0) {
|
|
|
@@ -563,6 +589,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
}
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryTaskDebugSql() {
|
|
|
List<SmartDataTaskSetDebugSql> result = smartDataTaskService.queryTaskDebugSql();
|
|
|
if (result.size() > 0) {
|
|
|
@@ -573,6 +600,7 @@ public class SmartDataTaskController implements SmartDataTaskControllerAPI {
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @DESRespondSecret(validated = true)
|
|
|
public CommonResult queryTaskSetDebugSql(int tkId, int tkDebugSql) {
|
|
|
int count = smartDataTaskService.queryTaskSetDebugSql(tkId, tkDebugSql);
|
|
|
if (count > 0) {
|