From df7d774a113fdafdf6f06b31ac8eb1f49f1d4a3b Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Tue, 16 Jan 2024 15:54:42 +0800
Subject: [PATCH] =?UTF-8?q?oralce=E5=90=8C=E6=AD=A5=E5=88=B0influxDB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../influx/service/impl/JobDetailInfluxDBServiceImpl.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/JobDetailInfluxDBServiceImpl.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/JobDetailInfluxDBServiceImpl.java
index c7ce7e1..3724c8a 100644
--- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/JobDetailInfluxDBServiceImpl.java
+++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/JobDetailInfluxDBServiceImpl.java
@@ -4,11 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.influx.bo.param.TableEnum;
 import com.njcn.influx.bo.po.JobDetailInfluxDB;
 import com.njcn.influx.mapper.JobDetailInfluxDBMapper;
 import com.njcn.influx.service.JobDetailInfluxDBService;
 import com.njcn.oracle.bo.param.JobQueryParam;
-import com.njcn.oracle.bo.param.ServiceTypeEnum;
 import com.njcn.oracle.util.LocalDateUtil;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -49,7 +49,7 @@ public class JobDetailInfluxDBServiceImpl extends MppServiceImpl<JobDetailInflux
 
         List<String> tableNames;
         if (CollectionUtils.isEmpty(jobQueryParam.getTableNames())) {
-            tableNames = ServiceTypeEnum.getExecutableTypes();
+            tableNames = TableEnum.getExecutableTypes();
         } else {
             tableNames = jobQueryParam.getTableNames();
         }
@@ -63,7 +63,7 @@ public class JobDetailInfluxDBServiceImpl extends MppServiceImpl<JobDetailInflux
                 if (jobDetails.contains(jobDetail)) {
                     return;
                 }
-                jobDetail.setTableName_CN(ServiceTypeEnum.getValueByCode(temp));
+                jobDetail.setTableName_CN(TableEnum.getValueByCode(temp));
                 jobDetail.setState(3);
                 jobDetails.add(jobDetail);
             });
@@ -72,7 +72,7 @@ public class JobDetailInfluxDBServiceImpl extends MppServiceImpl<JobDetailInflux
         List<JobDetailInfluxDB> jobDetailIPage = jobDetails.stream().filter(temp->jobQueryParam.getStates().contains(temp.getState()+"")).sorted(Comparator.comparing(JobDetailInfluxDB::getExcuteDate).reversed()).
                 skip((jobQueryParam.getCurrentPage() - 1) * jobQueryParam.getPageSize()).
                 limit(jobQueryParam.getPageSize()).collect(Collectors.toList());
-        jobDetailIPage.stream().forEach(temp -> temp.setTableName_CN(ServiceTypeEnum.getValueByCode(temp.getTableName())));
+        jobDetailIPage.stream().forEach(temp -> temp.setTableName_CN(TableEnum.getValueByCode(temp.getTableName())));
 
         page.setRecords(jobDetailIPage);
         page.setTotal(Long.parseLong(jobDetails.size() + ""));