|
@@ -2,38 +2,32 @@ package com.sckw.slope.detection.service.task;
|
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.sckw.core.model.constant.NumberConstant;
|
|
import com.sckw.core.model.constant.NumberConstant;
|
|
|
-import com.sckw.core.model.enums.DeviceEnum;
|
|
|
|
|
import com.sckw.core.model.enums.DictItemEnum;
|
|
import com.sckw.core.model.enums.DictItemEnum;
|
|
|
import com.sckw.core.model.enums.ReportTypeEnum;
|
|
import com.sckw.core.model.enums.ReportTypeEnum;
|
|
|
|
|
+import com.sckw.core.utils.FileUtils;
|
|
|
import com.sckw.core.utils.IdWorker;
|
|
import com.sckw.core.utils.IdWorker;
|
|
|
import com.sckw.excel.annotation.ExcelContext;
|
|
import com.sckw.excel.annotation.ExcelContext;
|
|
|
import com.sckw.excel.utils.ExcelUtil;
|
|
import com.sckw.excel.utils.ExcelUtil;
|
|
|
import com.sckw.slope.detection.dao.mysql.KwsDeviceIntegrationMapper;
|
|
import com.sckw.slope.detection.dao.mysql.KwsDeviceIntegrationMapper;
|
|
|
-import com.sckw.slope.detection.dao.mysql.KwsProjectDeviceMapper;
|
|
|
|
|
import com.sckw.slope.detection.dao.mysql.KwsReportDataMapper;
|
|
import com.sckw.slope.detection.dao.mysql.KwsReportDataMapper;
|
|
|
import com.sckw.slope.detection.dao.mysql.KwsReportTemplateMapper;
|
|
import com.sckw.slope.detection.dao.mysql.KwsReportTemplateMapper;
|
|
|
import com.sckw.slope.detection.dao.tdengine.SlopeDataMapper;
|
|
import com.sckw.slope.detection.dao.tdengine.SlopeDataMapper;
|
|
|
-import com.sckw.slope.detection.model.dos.mysql.KwsDevice;
|
|
|
|
|
import com.sckw.slope.detection.model.dos.mysql.KwsReportData;
|
|
import com.sckw.slope.detection.model.dos.mysql.KwsReportData;
|
|
|
import com.sckw.slope.detection.model.dos.mysql.KwsReportTemplate;
|
|
import com.sckw.slope.detection.model.dos.mysql.KwsReportTemplate;
|
|
|
import com.sckw.slope.detection.model.dos.tdengine.SlopeData;
|
|
import com.sckw.slope.detection.model.dos.tdengine.SlopeData;
|
|
|
-import com.sckw.slope.detection.model.vo.DeviceIntegrationVo;
|
|
|
|
|
import com.sckw.slope.detection.model.vo.DeviceVo;
|
|
import com.sckw.slope.detection.model.vo.DeviceVo;
|
|
|
import com.sckw.slope.detection.model.vo.excel.TaskReportExportVO;
|
|
import com.sckw.slope.detection.model.vo.excel.TaskReportExportVO;
|
|
|
import com.sckw.slope.detection.service.CommonService;
|
|
import com.sckw.slope.detection.service.CommonService;
|
|
|
import jakarta.annotation.Resource;
|
|
import jakarta.annotation.Resource;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
-import org.springframework.beans.BeanUtils;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
-import org.springframework.scheduling.annotation.Scheduled;
|
|
|
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
-import java.net.MalformedURLException;
|
|
|
|
|
import java.net.URL;
|
|
import java.net.URL;
|
|
|
import java.net.URLConnection;
|
|
import java.net.URLConnection;
|
|
|
import java.security.MessageDigest;
|
|
import java.security.MessageDigest;
|
|
@@ -146,7 +140,8 @@ public class ReportTemplateTaskService {
|
|
|
report.setCompanyId(kwsReportTemplate.getCompanyId());
|
|
report.setCompanyId(kwsReportTemplate.getCompanyId());
|
|
|
report.setTemplateId(kwsReportTemplate.getId());
|
|
report.setTemplateId(kwsReportTemplate.getId());
|
|
|
report.setProjectId(Long.parseLong(kwsReportTemplate.getProjectId()));
|
|
report.setProjectId(Long.parseLong(kwsReportTemplate.getProjectId()));
|
|
|
- report.setFileSize(new BigDecimal(fileSize));
|
|
|
|
|
|
|
+ BigDecimal fileSizeNumber = FileUtils.getFileSize(fileSize, "MB");
|
|
|
|
|
+ report.setFileSize(fileSizeNumber);
|
|
|
report.setFileUrl(filePath);
|
|
report.setFileUrl(filePath);
|
|
|
report.setId(id);
|
|
report.setId(id);
|
|
|
report.setCreateTime(now);
|
|
report.setCreateTime(now);
|