|
|
@@ -1,41 +1,28 @@
|
|
|
package com.sckw.slope.detection.service;
|
|
|
-import cn.hutool.core.date.DateTime;
|
|
|
-import com.alibaba.fastjson.JSON;
|
|
|
-import com.alibaba.fastjson.JSONArray;
|
|
|
-import com.alibaba.fastjson.JSONObject;
|
|
|
+
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
import com.github.pagehelper.PageHelper;
|
|
|
import com.github.pagehelper.PageInfo;
|
|
|
-import com.sckw.core.exception.BusinessException;
|
|
|
import com.sckw.core.exception.SystemException;
|
|
|
-import com.sckw.core.model.constant.Global;
|
|
|
import com.sckw.core.model.constant.NumberConstant;
|
|
|
-import com.sckw.core.model.enums.DeviceEnum;
|
|
|
-import com.sckw.core.model.enums.DictEnum;
|
|
|
import com.sckw.core.model.enums.DictItemEnum;
|
|
|
-import com.sckw.core.model.enums.MessageLogEnum;
|
|
|
import com.sckw.core.model.page.PageRes;
|
|
|
import com.sckw.core.utils.IdWorker;
|
|
|
-import com.sckw.core.utils.StringUtils;
|
|
|
import com.sckw.core.web.constant.HttpStatus;
|
|
|
import com.sckw.core.web.response.HttpResult;
|
|
|
-import com.sckw.excel.utils.DateUtil;
|
|
|
import com.sckw.slope.detection.dao.mysql.*;
|
|
|
-import com.sckw.slope.detection.dao.tdengine.InsTablesMapper;
|
|
|
import com.sckw.slope.detection.dao.tdengine.SlopeDataMapper;
|
|
|
-import com.sckw.slope.detection.model.dos.mysql.*;
|
|
|
-import com.sckw.slope.detection.model.dos.tdengine.InsTables;
|
|
|
+import com.sckw.slope.detection.model.dos.mysql.KwsDevice;
|
|
|
+import com.sckw.slope.detection.model.dos.mysql.KwsDeviceReference;
|
|
|
+import com.sckw.slope.detection.model.dos.mysql.KwsIntegration;
|
|
|
+import com.sckw.slope.detection.model.dos.mysql.KwsThreshold;
|
|
|
import com.sckw.slope.detection.model.dos.tdengine.SlopeData;
|
|
|
-import com.sckw.slope.detection.model.dto.*;
|
|
|
-import com.sckw.slope.detection.model.param.DeviceAdd;
|
|
|
-import com.sckw.slope.detection.model.param.DeviceQuery;
|
|
|
-import com.sckw.slope.detection.model.param.DeviceReferenceAdd;
|
|
|
+import com.sckw.slope.detection.model.dto.DeviceDataDTO;
|
|
|
+import com.sckw.slope.detection.model.dto.HeaderData;
|
|
|
import com.sckw.slope.detection.model.param.IntegrationQuery;
|
|
|
-import com.sckw.slope.detection.model.vo.*;
|
|
|
+import com.sckw.slope.detection.model.vo.IntegrationVo;
|
|
|
import jakarta.servlet.http.HttpServletRequest;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
-import org.apache.http.HttpResponse;
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
@@ -44,9 +31,7 @@ import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
-import java.time.LocalDateTime;
|
|
|
import java.util.*;
|
|
|
-import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* @author sky
|