SmartDataTaskService.java 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172
  1. package com.template.services;
  2. import com.alibaba.fastjson2.JSONObject;
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.github.pagehelper.PageInfo;
  5. import com.template.model.pojo.SmartDataTask;
  6. import com.template.model.pojo.SmartDataTaskDebug;
  7. import com.template.model.pojo.SmartDataTaskLog;
  8. import com.template.model.result.PageUtils;
  9. import java.util.Map;
  10. /**
  11. * <p>
  12. * 数据源任务 服务类
  13. * </p>
  14. *
  15. * @author ceshi
  16. * @since 2023-12-05
  17. */
  18. public interface SmartDataTaskService extends IService<SmartDataTask> {
  19. Map<String, Object> insertSmartDataTask1(SmartDataTask smartDataTask);
  20. // 添加任务2-字段配置
  21. Map<String, Object> insertSmartDataTask2(JSONObject requestData);
  22. Map<String, Object> insertSmartDataTask3(SmartDataTask smartDataTask);
  23. Map<String, Object> updateSmartDataTaskById1(SmartDataTask smartDataTask);
  24. Map<String, Object> updateSmartDataTaskById2(JSONObject json);
  25. Map<String, Object> updateSmartDataTaskById3(SmartDataTask smartDataTask);
  26. PageUtils<SmartDataTask> queryPageSmartDataTasks(int currentPage, int pageCount, SmartDataTask smartDataTask);
  27. Map<String, Object> deleteSmartDataTaskById(int id, int delMethod);
  28. PageInfo<SmartDataTaskDebug> queryPageSmartDataTaskDebug(int currentPage, int pageCount, Integer eTaskId, String startTime, String endTime);
  29. SmartDataTask getSmartById(int id);
  30. Map<String, Object> createJob(SmartDataTask smartDataTask);
  31. Map<String, Object> pauseJob(SmartDataTask smartDataTask);
  32. Map<String, Object> resumeJob(SmartDataTask smartDataTask);
  33. Map<String, Object> updateJob(SmartDataTask smartDataTask);
  34. Map<String, Object> deleteJob(SmartDataTask smartDataTask);
  35. Map<String, Object> runOnceJob(SmartDataTask smartDataTask);
  36. Map<String, Object> testSql(String json);
  37. Map<String, Object> getDepart();
  38. Map<String, Object> getSyncPolicy();
  39. Map<String, Object> getExchangeType();
  40. Map<String, Object> getTables(String json);
  41. Map<String, Object> getViews(String json);
  42. Map<String, Object> deleteSmartDataTaskDebugByIds(JSONObject json);
  43. PageInfo<SmartDataTaskLog> queryPageSmartDataTaskLog(int currentPage, int pageCount, Integer eTaskId, String tkLogTaskName, Integer tkLogAutoManual,
  44. Integer tkLogDsSourceId, Integer tkLogDsDestinationId,
  45. Integer tkLogCostTime, Integer tkLogExeStatus, String startTime, String endTime);
  46. }