高级算法异常抛出

- 移除硬编码的文件后缀名，根据操作系统自动识别.dll或.so文件
- 修正Linux系统下的库文件命名规则，移除多余的"_dll"后缀
- 添加对文件扩展名的条件判断，在Windows下确保.dll后缀
- 添加动态库加载成功后的路径打印功能

pqs-advance/advance-boot/src/main/java/com/njcn/advance/event/service/impl/EventAdvanceServiceImpl.java

@@ -75,7 +75,7 @@ public class EventAdvanceServiceImpl implements IEventAdvanceService {
                 if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
                     throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND);
                 }
-                waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 0);
+                waveDataDTO = waveFileComponent.getComtradeNoAddPoints(cfgStream, datStream, 0);
             } catch (Exception e) {
                 try {
                     InputStream cfgStream = fileStorageUtil.getFileStream(cfgPath2);

pqs-advance/advance-boot/src/main/java/com/njcn/advance/utils/JnaCallDllOrSo.java

@@ -1,11 +1,11 @@
 package com.njcn.advance.utils;
 
-import cn.hutool.core.io.resource.ClassPathResource;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.FileUtils;
 
-import java.io.*;
-import java.net.URLDecoder;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.InputStream;
 
 /**
  * pqs
@@ -20,21 +20,20 @@ public class JnaCallDllOrSo {
 
     public JnaCallDllOrSo(String name) {
         super();
-        String suffix = ".dll";
         try {
             String os = System.getProperty("os.name");
-            // windows操作系统为1 否则为0
             int beginIndex = os != null && os.startsWith("Windows") ? 1 : 0;
             String nameDll;
             if (beginIndex == 0) {
-                //linux操作系统
-                nameDll = "lib" + name + "_dll";
-                suffix = ".so";
+                nameDll = "lib" + name + ".so";
             } else {
                 nameDll = name;
+                if (!name.endsWith(".dll")) {
+                    nameDll = name + ".dll";
+                }
             }
 
-            String tem = "/usr/local/dllFile/"+ nameDll.concat(suffix);
+            String tem = "/usr/local/dllFile/"+ nameDll;
             File dockerFile = new File(tem);
             if(!dockerFile.exists()){
                 boolean f = dockerFile.getParentFile().mkdirs();
@@ -42,7 +41,11 @@ public class JnaCallDllOrSo {
                 System.out.println("文件夹创建："+f);
                 System.out.println("文件创建："+d);
 
-                try (InputStream inputStream = getClass().getClassLoader().getResourceAsStream(nameDll.concat(suffix))) {
+                try (InputStream inputStream = getClass().getClassLoader().getResourceAsStream(nameDll)) {
+                    if (inputStream == null) {
+                        log.error("找不到资源文件: {}", nameDll);
+                        throw new FileNotFoundException("找不到资源文件: " + nameDll);
+                    }
                     try (FileOutputStream outputStream = new FileOutputStream(dockerFile)) {
                         byte[] buffer = new byte[1024];
                         int bytesRead;
@@ -53,9 +56,11 @@ public class JnaCallDllOrSo {
                 }
             }
             this.path = dockerFile.getAbsolutePath();
+            System.out.println("动态库路径: " + this.path);
         } catch (Exception e) {
             log.error("调用高级算法文件异常，异常信息如下：");
-            log.error(e.getMessage());
+            log.error(e.getMessage(), e);
+            throw new RuntimeException("加载动态库失败: " + e.getMessage(), e);
         }
 
 

pqs-common/common-event/src/main/java/com/njcn/event/file/component/WaveFileComponent.java

@@ -14,11 +14,13 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
+import java.awt.*;
 import java.io.*;
 import java.nio.file.Files;
 import java.text.DateFormat;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.List;
 
 /**
  * @author hongawen
@@ -79,6 +81,46 @@ public class WaveFileComponent {
         return waveDataDTO;
     }
 
+    public WaveDataDTO getComtradeNoAddPoints(InputStream cfgStream, InputStream datStream, int iType) {
+        WaveDataDTO waveDataDTO = new WaveDataDTO();
+        // 首先判断文件路径是否为空
+        // 读取cfg文件
+        ComtradeCfgDTO comtradeCfgDTO = getComtradeCfgNoAddPoints(cfgStream);
+        // 为空或者未找到结束符号
+        if (comtradeCfgDTO == null || !"BINARY".equalsIgnoreCase(comtradeCfgDTO.getStrBinType())) {
+            throw new BusinessException(WaveFileResponseEnum.CFG_DATA_ERROR);
+        }
+
+        /*****根据通道号计算相别**  add by yexb -----Start****
+         * 1、判断是否是3的倍数，是3的倍数则是3相
+         * 2、假如不是3的倍数 ，是1的倍数则是单相
+         ********************************************************/
+        if (comtradeCfgDTO.getNAnalogNum() % 3 == 0) {
+            comtradeCfgDTO.setNPhasic(3);
+        } else {
+            comtradeCfgDTO.setNPhasic(1);
+        }
+
+        // 给相别数量赋值
+        waveDataDTO.setIPhasic(comtradeCfgDTO.getNPhasic());
+
+        // 组装解析抬头
+        getWaveTitle(waveDataDTO, comtradeCfgDTO);
+
+        // 解析.dat文件
+        List<List<Float>> listWaveData = getComtradeDatNoAddPoints(comtradeCfgDTO, datStream, iType);
+
+        waveDataDTO.setComtradeCfgDTO(comtradeCfgDTO);
+
+        waveDataDTO.setListWaveData(listWaveData);
+
+        //add by hongawen,将暂态触发起始时间记录下来
+        waveDataDTO.setTime(DateUtil.format(comtradeCfgDTO.getTimeTrige(), DatePattern.NORM_DATETIME_MS_PATTERN));
+        /*****根据通道号计算相别**  add by yexb -----end****/
+
+        return waveDataDTO;
+    }
+
     /*********************************
      * 根据波形数据算出rms值数据
      * param waveDataDTO 瞬时波形（包含了CFG配置文件）
@@ -470,6 +512,127 @@ public class WaveFileComponent {
         return comtradeCfgDTO;
     }
 
+    private ComtradeCfgDTO getComtradeCfgNoAddPoints(InputStream cfgStream) {
+        ComtradeCfgDTO comtradeCfgDTO = new ComtradeCfgDTO();
+        try (InputStreamReader read = new InputStreamReader(cfgStream, CharsetUtil.CHARSET_GBK); BufferedReader bufferedReader = new BufferedReader(read);) {
+            // 第一行不关心仅仅是一些描述类的信息
+            String strFileLine = bufferedReader.readLine();
+
+            // 第二行需要关心第二个(模拟量的个数)和第三个参数(开关量的个数)
+            strFileLine = bufferedReader.readLine();
+            // 按“,”进行分割
+            String[] strTempArray = strFileLine.split(StrUtil.COMMA);
+            // 总个数
+            comtradeCfgDTO.setNChannelNum(Integer.parseInt(strTempArray[0]));
+            // 模拟量的个数
+            comtradeCfgDTO.setNAnalogNum(Integer.parseInt(strTempArray[1].substring(0, strTempArray[1].length() - 1)));
+            // 开关量的个数
+            comtradeCfgDTO.setNDigitalNum(Integer.parseInt(strTempArray[2].substring(0, strTempArray[2].length() - 1)));
+
+            // 从第三行开始的ComtradeCfg.nChannelNum行是模拟量通道和数字量通道
+            List<AnalogDTO> lstAnalogDTO = new ArrayList<>();
+            comtradeCfgDTO.setLstAnalogDTO(lstAnalogDTO);
+            for (int i = 0; i < comtradeCfgDTO.getNChannelNum(); i++) {
+                AnalogDTO analogDTO = new AnalogDTO();
+                lstAnalogDTO.add(analogDTO);
+                strFileLine = bufferedReader.readLine();
+                strTempArray = strFileLine.split(StrUtil.COMMA);
+                //通道序号
+                analogDTO.setNIndex(Integer.parseInt(strTempArray[0]));
+                // 通道名称
+                analogDTO.setSzChannleName(strTempArray[1]);
+                // 相位名称
+                analogDTO.setSzPhasicName(strTempArray[2]);
+                // 监视的通道名称
+                analogDTO.setSzMonitoredChannleName(strTempArray[3]);
+                // 通道的单位
+                analogDTO.setSzUnitName(strTempArray[4]);
+                // 通道的系数
+                analogDTO.setFCoefficent(Float.parseFloat(strTempArray[5]));
+                // 通道的偏移量
+                analogDTO.setFOffset(Float.parseFloat(strTempArray[6]));
+                // 起始采样时间的偏移量
+                analogDTO.setFTimeOffset(Float.parseFloat(strTempArray[7]));
+                // 采样值的最小值
+                analogDTO.setNMin(Integer.parseInt(strTempArray[8]));
+                // 采样值的最大值
+                analogDTO.setNMax(Integer.parseInt(strTempArray[9]));
+                // 一次变比
+                analogDTO.setFPrimary(Float.parseFloat(strTempArray[10]));
+                // 二次变比
+                analogDTO.setFSecondary(Float.parseFloat(strTempArray[11]));
+                // 一次值还是二次值标志
+                analogDTO.setSzValueType(strTempArray[12]);
+            }
+
+            //WW 2019-11-14 // 采样频率
+            String freqLine = bufferedReader.readLine();
+            int nFreq;
+            try {
+                // 先尝试解析为double再四舍五入为整数，以兼容"50.00"这样的格式
+                nFreq = (int) Math.round(Double.parseDouble(freqLine));
+            } catch (NumberFormatException e) {
+                // 如果失败则使用原来的整数解析方式
+                nFreq = Integer.parseInt(freqLine);
+            }
+
+            // 获取采样段数
+            strFileLine = bufferedReader.readLine();
+            int nRates = Integer.parseInt(strFileLine);
+            comtradeCfgDTO.setNRates(nRates);
+            // 获得每段的采样率 //采样率
+            List<RateDTO> lstRate = new ArrayList<>();
+            int nOffset = 0;
+            for (int i = 0; i < nRates; i++) {
+                strFileLine = bufferedReader.readLine();
+                strTempArray = strFileLine.split(StrUtil.COMMA);
+                RateDTO rateDTO = new RateDTO();
+                // 单周波采样点数 //WW 2019-11-14
+                double doubleValue = Double.parseDouble(strTempArray[0]); // 解析为 double
+                int result = (int) (doubleValue / nFreq); // 强制转换为 int
+                rateDTO.setNOneSample(result);
+                // 总点数 //这里的strTemp是一个偏移量
+                rateDTO.setNSampleNum((Integer.parseInt(strTempArray[1]) - nOffset));
+                nOffset = rateDTO.getNSampleNum();
+                lstRate.add(rateDTO);
+            }
+            comtradeCfgDTO.setLstRate(lstRate);
+            // 增加读取波形起始时间个结束时间
+            String timeFormat = "dd/MM/yyyy,HH:mm:ss.SSS";
+            // 波形起始时间
+            strFileLine = bufferedReader.readLine();
+            strFileLine = strFileLine.substring(0, strFileLine.length() - 3);
+            comtradeCfgDTO.setTimeStart(DateUtil.parse(strFileLine, timeFormat));
+
+            // 暂态触发时间
+            strFileLine = bufferedReader.readLine();
+            strFileLine = strFileLine.substring(0, strFileLine.length() - 3);
+            comtradeCfgDTO.setTimeTrige(DateUtil.parse(strFileLine, timeFormat));
+
+            // 获取触发时间的时间 + 毫秒
+            Calendar calendar = DateUtil.calendar(comtradeCfgDTO.getTimeTrige());
+            comtradeCfgDTO.setFirstMs(calendar.get(Calendar.MILLISECOND));
+            comtradeCfgDTO.setFirstTime(calendar.getTime());
+
+
+            long a = comtradeCfgDTO.getTimeStart().getTime();
+            long b = comtradeCfgDTO.getTimeTrige().getTime();
+
+            int c = (int) (b - a);
+            if (c >= 90 && c <= 110) {
+                comtradeCfgDTO.setNPush(100);
+            } else if (c >= 190 && c <= 210) {
+                comtradeCfgDTO.setNPush(200);
+            }
+            // 赋值编码格式（二进制）
+            comtradeCfgDTO.setStrBinType(bufferedReader.readLine().toUpperCase());
+        } catch (Exception e) {
+            // 解析.cfg文件出错
+            comtradeCfgDTO = null;
+        }
+        return comtradeCfgDTO;
+    }
+
     /*********************************
      * 读取dat方法
      * param strFilePath  .dat访问路径
@@ -765,46 +928,46 @@ public class WaveFileComponent {
         return listWaveData;
     }
 
-//    private List<List<Float>> getComtradeDat(ComtradeCfgDTO comtradeCfgDTO, InputStream datStream, int iType) {
-//        //返回数据，如果仅仅做展示后期考虑换String类型，降低内存开销
-//        List<List<Float>> listWaveData = new ArrayList<>();
-//        //初始化xValue的值
-//        float xValueAll = 0;
-//        //判断是否首次登陆
-//        boolean blxValue = false;
-//        byte[] datArray;
-//        try {
-//            datArray = IoUtil.readBytes(datStream);
-//            if (ArrayUtil.isEmpty(datArray)) {
-//                throw new BusinessException(WaveFileResponseEnum.DAT_DATA_ERROR);
-//            }
-//            // 计算每个单独的数据块的大小 4个字节的序号 4个字节的时间 2个字节的值
-//            // 示例中的排布是 4个字节的序号 4个字节的时间 UA(2字节) UB(2字节) UC(2字节) IA(2字节) IB(2字节) IC(2字节)
-//            int nDigSize = (comtradeCfgDTO.getNDigitalNum() % 16) > 0 ? (comtradeCfgDTO.getNDigitalNum() / 16 + 1) * 2 : comtradeCfgDTO.getNDigitalNum() / 16 * 2;
-//            int nBlockSize = 2 * Integer.SIZE / 8 + comtradeCfgDTO.getNAnalogNum() * 2 + nDigSize;
-//            // 总长度除以每个块的大小
-//            int nBlockNum = (int)Math.floor(datArray.length / nBlockSize);
-//
-//            // 获取采样率
-//            int finalSampleRate = getFinalWaveSample(comtradeCfgDTO.getLstRate(), iType);
-//            if (finalSampleRate != -1) {
-//                //设置最终采样率
-//                comtradeCfgDTO.setFinalSampleRate(finalSampleRate);
-//                // 计算转换后的采样率
-//                int nnInd = 0;
-//                // 抽点后总共多少点数据
-//                int nWaveNum;
-//                //抽点后新的的采样率
-//                List<RateDTO> newLstRate = new ArrayList<>();
-//                for (int iRate = 0; iRate < comtradeCfgDTO.getNRates(); iRate++) {
-////                    if (comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() >= 32) {
-//                    // 计算本段录波总共有多少波形
-//                    nWaveNum = comtradeCfgDTO.getLstRate().get(iRate).getNSampleNum() / comtradeCfgDTO.getLstRate().get(iRate).getNOneSample();
-//                    //设置总波形大小
-//                    comtradeCfgDTO.setNAllWaveNum(comtradeCfgDTO.getNAllWaveNum() + nWaveNum);
-//                    // 将最低采样率替换到本段录波内
-//                    RateDTO tmpRateDTO = new RateDTO();
-//                    // 有效值标志,如果是有效值，那么就需要反向补点，而不是抽点
+    private List<List<Float>> getComtradeDatNoAddPoints(ComtradeCfgDTO comtradeCfgDTO, InputStream datStream, int iType) {
+        //返回数据，如果仅仅做展示后期考虑换String类型，降低内存开销
+        List<List<Float>> listWaveData = new ArrayList<>();
+        //初始化xValue的值
+        float xValueAll = 0;
+        //判断是否首次登陆
+        boolean blxValue = false;
+        byte[] datArray;
+        try {
+            datArray = IoUtil.readBytes(datStream);
+            if (ArrayUtil.isEmpty(datArray)) {
+                throw new BusinessException(WaveFileResponseEnum.DAT_DATA_ERROR);
+            }
+            // 计算每个单独的数据块的大小 4个字节的序号 4个字节的时间 2个字节的值
+            // 示例中的排布是 4个字节的序号 4个字节的时间 UA(2字节) UB(2字节) UC(2字节) IA(2字节) IB(2字节) IC(2字节)
+            int nDigSize = (comtradeCfgDTO.getNDigitalNum() % 16) > 0 ? (comtradeCfgDTO.getNDigitalNum() / 16 + 1) * 2 : comtradeCfgDTO.getNDigitalNum() / 16 * 2;
+            int nBlockSize = 2 * Integer.SIZE / 8 + comtradeCfgDTO.getNAnalogNum() * 2 + nDigSize;
+            // 总长度除以每个块的大小
+            int nBlockNum = (int)Math.floor(datArray.length / nBlockSize);
+
+            // 获取采样率
+            int finalSampleRate = getFinalWaveSample(comtradeCfgDTO.getLstRate(), iType);
+            if (finalSampleRate != -1) {
+                //设置最终采样率
+                comtradeCfgDTO.setFinalSampleRate(finalSampleRate);
+                // 计算转换后的采样率
+                int nnInd = 0;
+                // 抽点后总共多少点数据
+                int nWaveNum;
+                //抽点后新的的采样率
+                List<RateDTO> newLstRate = new ArrayList<>();
+                for (int iRate = 0; iRate < comtradeCfgDTO.getNRates(); iRate++) {
+                    if (comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() >= 32) {
+                    // 计算本段录波总共有多少波形
+                    nWaveNum = comtradeCfgDTO.getLstRate().get(iRate).getNSampleNum() / comtradeCfgDTO.getLstRate().get(iRate).getNOneSample();
+                    //设置总波形大小
+                    comtradeCfgDTO.setNAllWaveNum(comtradeCfgDTO.getNAllWaveNum() + nWaveNum);
+                    // 将最低采样率替换到本段录波内
+                    RateDTO tmpRateDTO = new RateDTO();
+                    // 有效值标志,如果是有效值，那么就需要反向补点，而不是抽点
 //                    if (comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() >= 32) {
 //                        //YXB 2025-08-27
 //                        tmpRateDTO.bRMSFlag = false;
@@ -814,52 +977,53 @@ public class WaveFileComponent {
 //                        //YXB 2025-08-27
 //                        tmpRateDTO.bRMSFlag = true;
 //                    }
-//                    newLstRate.add(tmpRateDTO);
-//                    //iFlag =3 一定不进行抽点算法
-//                    if (iType != 3) {
-//                        //true 抽点算法（当前采样率跟统一采样率不一样则是抽点，否则是未抽点）
-//                        if (!Objects.equals(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample(), comtradeCfgDTO.getFinalSampleRate())) {
-//                            newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getFinalSampleRate());
-//                            // 计算本段录波按照最低采样点应该有多少录波
-//                            newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getFinalSampleRate() * nWaveNum);
-//                        } else {
-//                            newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
-//                            // 计算本段录波按照最低采样点应该有多少录波
-//                            newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() * nWaveNum);
-//                        }
-//                    } else {
-//                        newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
-//                        // 计算本段录波按照最低采样点应该有多少录波
-//                        newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() * nWaveNum);
-//                    }
-//
-//                    // 正常的配置中采样率
-//                   /* comtradeCfgDTO.getLstRate().get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
-//                    comtradeCfgDTO.getLstRate().get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNSampleNum());*/
-//
-//                    nnInd++;
-////                    }
-//                }
-//                // 偏移量,采样间隔
-//                long nOffSet = 0, nWaveSpan;
-//                //两个点之间的时间差
-//                float fValue, dfValue;
-//                // 计算不同块的采样率
-//                int nIndex = 0;
-//                // 将最低采样率替换到本段录波内
-//                // .CFG中采样率
-//                RateDTO tmpRateDTO;
-//                // nBlockNum 总循环次数
-//                for (int i = 0; i < nBlockNum; i++) {
-//                    tmpRateDTO = comtradeCfgDTO.getLstRate().get(nIndex);
-//                    // 判断是否进入下一段
-//                    if (i == tmpRateDTO.getNSampleNum() + nOffSet) {
-//                        nOffSet += tmpRateDTO.getNSampleNum();
-//                        nIndex++;
-//                        if (nIndex == nnInd) {
-//                            break;
-//                        }
-//                    }
+                    newLstRate.add(tmpRateDTO);
+                    //iFlag =3 一定不进行抽点算法
+                    if (iType != 3) {
+                        //true 抽点算法（当前采样率跟统一采样率不一样则是抽点，否则是未抽点）
+                        if (!Objects.equals(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample(), comtradeCfgDTO.getFinalSampleRate())) {
+                            newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getFinalSampleRate());
+                            // 计算本段录波按照最低采样点应该有多少录波
+                            newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getFinalSampleRate() * nWaveNum);
+                        } else {
+                            newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
+                            // 计算本段录波按照最低采样点应该有多少录波
+                            newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() * nWaveNum);
+                        }
+                    } else {
+                        newLstRate.get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
+                        // 计算本段录波按照最低采样点应该有多少录波
+                        newLstRate.get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample() * nWaveNum);
+                    }
+
+                    // 正常的配置中采样率
+                    comtradeCfgDTO.getLstRate().get(nnInd).setNOneSample(comtradeCfgDTO.getLstRate().get(iRate).getNOneSample());
+                    comtradeCfgDTO.getLstRate().get(nnInd).setNSampleNum(comtradeCfgDTO.getLstRate().get(iRate).getNSampleNum());
+
+                    nnInd++;
+                    }
+                }
+                // 偏移量,采样间隔
+                long nOffSet = 0, nWaveSpan;
+                //两个点之间的时间差
+                float fValue, dfValue;
+                // 计算不同块的采样率
+                int nIndex = 0;
+                // 将最低采样率替换到本段录波内
+                // .CFG中采样率
+                RateDTO tmpRateDTO;
+                // nBlockNum 总循环次数
+                for (int i = 0; i < nBlockNum; i++) {
+                    tmpRateDTO = comtradeCfgDTO.getLstRate().get(nIndex);
+                    // 判断是否进入下一段
+                    if (i == tmpRateDTO.getNSampleNum() + nOffSet) {
+                        nOffSet += tmpRateDTO.getNSampleNum();
+                        nIndex++;
+                        if (nIndex == nnInd) {
+                            break;
+                        }
+                    }
+                    nWaveSpan = tmpRateDTO.getNOneSample() / newLstRate.get(nIndex).getNOneSample();
 //                    tmpRateDTO = comtradeCfgDTO.getLstRate().get(nIndex);
 //                    //YXB 2025-08-27 如果是有效值，那么需要去补点，而不是抽点
 //                    if (newLstRate.get(nIndex).bRMSFlag == true) {
@@ -869,199 +1033,99 @@ public class WaveFileComponent {
 //                        // 计算本段抽点采样间隔
 //                        nWaveSpan = tmpRateDTO.getNOneSample() / newLstRate.get(nIndex).getNOneSample();
 //                    }
-//
-//                    dfValue = (float) 20 / tmpRateDTO.getNOneSample();
-//                    // 判断是否到了需要抽的采样点
-//                    if (i % nWaveSpan == 0) {
-//                        // 计算每个通道的值
-//                        //存储局部数据集合，包含了时间，A，B，C三相
-//                        List<Float> tmpWaveData = new ArrayList<>();
-//                        //YXB 2025-08-27 如果是有效值，那么需要去补点，而不是抽点
-//                        if (newLstRate.get(nIndex).bRMSFlag == true) {
-//                            // 计算有多少个周波
-//                            long allWaveTemp = newLstRate.get(nIndex).getNSampleNum() / newLstRate.get(nIndex).getNOneSample();
-//                            // 本段需要补多少点
-//                            long allempSample = newLstRate.get(nIndex).getNOneSample();
-//                            //int iStartWaveTemp = i ;// 开始补点的起点
-//                            for (int iWaveTemp = 0; iWaveTemp < allWaveTemp; iWaveTemp++) {
-//                                for (int mTempSample = 0; mTempSample < allempSample; mTempSample++) {
-//                                    //最多只有半波有效值，也就是每周波是1个或者2个点，然后去补最少16个点
-//                                    if (mTempSample / nWaveSpan == 1 && mTempSample % nWaveSpan == 0) {
-//                                        i++;
-//                                    }
-//                                    //存储局部数据集合，包含了时间，A，B，C三相
-//                                    tmpWaveData = new ArrayList<>();
-//                                    for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
-//                                        //数据只有电压ABC三相数据，不展示U0、I0等数据 YXB2020-10-09 去除相别为N相的数据
-//                                        if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
-//                                            break;
-//                                        }
-//                                        float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
-//
-//                                        if((i * nBlockSize + 2 * 4 + j * 2) == 2437568){
-//                                            System.out.println(55);
-//                                        }
-//                                        fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
-//                                        //WW 2019-11-14
-//                                        /*************************
-//                                         * 1、接口返回的默认是二次值
-//                                         * 2、P是一次值 S是二次值
-//                                         * 3、S(二次值）情况下：
-//                                         *     ①、单位为"V"时候则直接等于；
-//                                         *     ②、单位为"kV"时候需要乘以1000
-//                                         * 4、P(一次值）情况下：
-//                                         *     ①、单位为"V"时候则直接等于；
-//                                         *     ②、单位为"kV"时候需要乘以1000
-//                                         *************************/
-//                                        //P是一次值 S是二次值
-//                                        if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
-//                                            //判断单位是V还是kV
-//                                            if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
-//                                                fValue = fValue * 1000.0f;
-//                                            } else {
-//                                                fValue = fValue;
-//                                            }
-//                                        }
-//                                        //P是一次值 S是二次值
-//                                        else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
-//                                            //判断单位是V还是kV
-//                                            if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
-//                                                //根据cfg内的变比，将一次值转换成二次值
-//                                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                                    fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                                } else {
-//                                                    fValue = fValue;
-//                                                }
-//                                            }
-//                                            //判断单位是V还是kV
-//                                            else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
-//                                                //根据cfg内的变比，将一次值转换成二次值
-//                                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                                    fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                                } else {
-//                                                    fValue = fValue;
-//                                                }
-//                                            } else //还有可能是  电流，单位是A
-//                                            {
-//                                                //根据cfg内的变比，将一次值转换成二次值
-//                                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                                    fValue = comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                                } else {
-//                                                    fValue = fValue;
-//                                                }
-//                                            }
-//                                        }
-//
-//                                        //xValue前移量，假如是第一次时候则需要前移
-//                                        if (!blxValue && j == 0) {
-//                                            xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
-//                                            blxValue = true;
-//                                            //只增加一个xValue的值 //增加时间值
-//                                            tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
-//                                        } else if (j == 0) {
-//                                            xValueAll += (float) dfValue / nWaveSpan;
-//                                            //只增加一个xValue的值 //增加时间值
-//                                            tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
-//                                        }
-//
-//                                        //不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
-//                                        tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
-//                                    }
-//                                    //把每个单独的值赋予到整体里面去
-//                                    listWaveData.add(tmpWaveData);
-//                                }
-//                                // 把每个单独的值赋予到整体里面去
-//                                if (iWaveTemp < (allWaveTemp - 1)) {
-//                                    i++;
-//                                }
-//                            }
-//                        } else {
-//                            for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
-//                                //数据只有电压ABC三相数据，不展示U0、I0等数据 YXB2020-10-09 去除相别为N相的数据
-//                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
-//                                    break;
-//                                }
-//
-//                                float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
-//                                fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
-//
-//                                //WW 2019-11-14
-//                                /**************************
-//                                 * 1、接口返回的默认是二次值
-//                                 * 2、P是一次值 S是二次值
-//                                 * 3、S(二次值）情况下：
-//                                 *     ①、单位为"V"时候则直接等于；
-//                                 *     ②、单位为"kV"时候需要乘以1000
-//                                 * 4、P(一次值）情况下：
-//                                 *     ①、单位为"V"时候则直接等于；
-//                                 *     ②、单位为"kV"时候需要乘以1000
-//                                 **************************/
-//                                //P是一次值 S是二次值
-//                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
-//                                    //判断单位是V还是kV
-//                                    if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
-//                                        fValue = fValue * 1000.0f;
-//                                    } else {
-//                                        fValue = fValue;
-//                                    }
-//                                }
-//                                //P是一次值 S是二次值
-//                                else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
-//                                    //判断单位是V还是kV
-//                                    if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
-//                                        //根据cfg内的变比，将一次值转换成二次值
-//                                        if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                            fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                        } else {
-//                                            fValue = fValue;
-//                                        }
-//                                    }
-//                                    //判断单位是V还是kV
-//                                    else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
-//                                        //根据cfg内的变比，将一次值转换成二次值
-//                                        if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                            fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                        } else {
-//                                            fValue = fValue;
-//                                        }
-//                                    } else //还有可能是  电流，单位是A
-//                                    {
-//                                        //根据cfg内的变比，将一次值转换成二次值
-//                                        if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
-//                                            fValue = comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
-//                                        } else {
-//                                            fValue = fValue;
-//                                        }
-//                                    }
-//                                }
-//                                //xValue前移量，假如是第一次时候则需要前移
-//                                if (!blxValue && j == 0) {
-//                                    xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
-//                                    blxValue = true;
-//                                    //只增加一个xValue的值 //增加时间值
-//                                    tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
-//                                } else if (j == 0) {
-//                                    xValueAll += (float) nWaveSpan * dfValue;
-//                                    //只增加一个xValue的值 //增加时间值
-//                                    tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
-//                                }
-//
-//                                //不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
-//                                tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
-//                            }
-//                            //把每个单独的值赋予到整体里面去
-//                            listWaveData.add(tmpWaveData);
-//                        }
-//                    }
-//                }
-//            }
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//            throw new BusinessException(WaveFileResponseEnum.DAT_DATA_ERROR);
-//        }
-//
-//        return listWaveData;
-//    }
+
+                    dfValue = (float) 20 / tmpRateDTO.getNOneSample();
+                    // 判断是否到了需要抽的采样点
+                    if (i % nWaveSpan == 0) {
+                        // 计算每个通道的值
+                        //存储局部数据集合，包含了时间，A，B，C三相
+                        List<Float> tmpWaveData = new ArrayList<>();
+                        for (int j = 0; j < comtradeCfgDTO.getNAnalogNum(); j++) {
+                            //数据只有电压ABC三相数据，不展示U0、I0等数据 YXB2020-10-09 去除相别为N相的数据
+                            if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzPhasicName().equalsIgnoreCase("N")) {
+                                break;
+                            }
+
+                            float fCoef = comtradeCfgDTO.getLstAnalogDTO().get(j).getFCoefficent();
+                            fValue = BitConverter.byte2ToUnsignedShort(datArray, i * nBlockSize + 2 * 4 + j * 2) * fCoef;
+
+                            //WW 2019-11-14
+                            /**************************
+                             * 1、接口返回的默认是二次值
+                             * 2、P是一次值 S是二次值
+                             * 3、S(二次值）情况下：
+                             *     ①、单位为"V"时候则直接等于；
+                             *     ②、单位为"kV"时候需要乘以1000
+                             * 4、P(一次值）情况下：
+                             *     ①、单位为"V"时候则直接等于；
+                             *     ②、单位为"kV"时候需要乘以1000
+                             **************************/
+                            //P是一次值 S是二次值
+                            if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("S")) {
+                                //判断单位是V还是kV
+                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
+                                    fValue = fValue * 1000.0f;
+                                } else {
+                                    fValue = fValue;
+                                }
+                            }
+                            //P是一次值 S是二次值
+                            else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzValueType().equalsIgnoreCase("P")) {
+                                //判断单位是V还是kV
+                                if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("V")) {
+                                    //根据cfg内的变比，将一次值转换成二次值
+                                    if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
+                                        fValue = fValue * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
+                                    } else {
+                                        fValue = fValue;
+                                    }
+                                }
+                                //判断单位是V还是kV
+                                else if (comtradeCfgDTO.getLstAnalogDTO().get(j).getSzUnitName().equalsIgnoreCase("KV")) {
+                                    //根据cfg内的变比，将一次值转换成二次值
+                                    if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
+                                        fValue = fValue * 1000.0f * comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
+                                    } else {
+                                        fValue = fValue;
+                                    }
+                                } else //还有可能是  电流，单位是A
+                                {
+                                    //根据cfg内的变比，将一次值转换成二次值
+                                    if (comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary() != 0.0f) {
+                                        fValue = fValue *comtradeCfgDTO.getLstAnalogDTO().get(j).getFSecondary() / comtradeCfgDTO.getLstAnalogDTO().get(j).getFPrimary();
+                                    } else {
+                                        fValue = fValue;
+                                    }
+                                }
+                            }
+                            //xValue前移量，假如是第一次时候则需要前移
+                            if (!blxValue && j == 0) {
+                                xValueAll = (float) (i * 20) / tmpRateDTO.getNOneSample() - comtradeCfgDTO.getNPush();
+                                blxValue = true;
+                                //只增加一个xValue的值 //增加时间值
+                                tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
+                            } else if (j == 0) {
+                                xValueAll += (float) nWaveSpan * dfValue;
+                                //只增加一个xValue的值 //增加时间值
+                                tmpWaveData.add((float) (Math.round(xValueAll * 100)) / 100);
+                            }
+
+                            //不同通道yValue的值都需要增加，最终成ABC三相 //每个通道的值
+                            tmpWaveData.add((float) (Math.round(fValue * 100)) / 100);
+                        }
+                        //把每个单独的值赋予到整体里面去
+                        listWaveData.add(tmpWaveData);
+
+                    }
+                }
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new BusinessException(WaveFileResponseEnum.DAT_DATA_ERROR);
+        }
+
+        return listWaveData;
+    }
 
 
     /*********************************
@@ -1656,10 +1720,10 @@ public class WaveFileComponent {
         s = sdf.format(d);
         System.out.println(s);
         WaveFileComponent waveFileComponent = new WaveFileComponent();
-        InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\Administrator\\Desktop\\wave\\PQMonitor_PQM2_006970_20260320_175033_734.CFG");
-        InputStream datStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\Administrator\\Desktop\\wave\\PQMonitor_PQM2_006970_20260320_175033_734.DAT");
+        InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\无名\\Desktop\\月报\\2026\\202603\\文档\\暂态事件及波形\\新建文件夹 (3)\\Comtrade\\Comtrade\\10.95.0.201\\PQMonitor_PQM1_001183_20260320_175042_316.CFG");
+        InputStream datStream = waveFileComponent.getFileInputStreamByFilePath("C:\\Users\\无名\\Desktop\\月报\\2026\\202603\\文档\\暂态事件及波形\\新建文件夹 (3)\\Comtrade\\Comtrade\\10.95.0.201\\PQMonitor_PQM1_001183_20260320_175042_316.DAT");
         // 获取瞬时波形 //获取原始波形值
-        WaveDataDTO waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);
+        WaveDataDTO waveDataDTO = waveFileComponent.getComtradeNoAddPoints(cfgStream, datStream, 0);
         d = new Date();
         s = sdf.format(d);
         System.out.println(s);

pqs-common/common-redis/src/main/java/com/njcn/redis/utils/RedisUtil.java

@@ -2,9 +2,7 @@ package com.njcn.redis.utils;
 
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
-import org.springframework.data.redis.core.RedisCallback;
-import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.core.*;
 import org.springframework.stereotype.Component;
 
 import java.nio.charset.StandardCharsets;
@@ -325,8 +323,25 @@ public class RedisUtil {
      * @return
      */
     public List<?> getLikeListAllValues(String key) {
-        List<Object> info=new ArrayList<>();
-        for (String s : redisTemplate.keys(key + "*")) {
+        List<Object> info = new ArrayList<>();
+        // 使用 SCAN 替代 keys，解决 Tair 禁用 KEYS 命令的问题
+        Set<String> keys = redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
+            Set<String> keySet = new HashSet<>();
+            ScanOptions options = ScanOptions.scanOptions()
+                    .match(key + "*")
+                    .count(1000)
+                    .build();
+
+            try (Cursor<byte[]> cursor = connection.scan(options)) {
+                while (cursor.hasNext()) {
+                    keySet.add(new String(cursor.next()));
+                }
+            } catch (Exception e) {
+                throw new RuntimeException("Redis SCAN 模糊查询失败", e);
+            }
+            return keySet;
+        });
+        for (String s : keys) {
             info.add(redisTemplate.opsForValue().get(s));
         }
         return info;

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/DeviceProcess.java

@@ -1,6 +1,8 @@
 package com.njcn.device.pq.pojo.po;
 
+import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
 import lombok.Data;
 
 import java.io.Serializable;
@@ -17,6 +19,7 @@ import java.io.Serializable;
 public class DeviceProcess implements Serializable {
     private static final long serialVersionUID = 1L;
     //设备id
+    @TableId("Id")
     private String id;
     //设备设备所在前置机进程号
     private Integer processNo;

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/RunManageServiceImpl.java

@@ -139,7 +139,7 @@ public class RunManageServiceImpl implements RunManageService {
             List<String> devIndexes = generalDeviceDTOList.stream().flatMap(list -> list.getDeviceIndexes().stream()).collect(Collectors.toList());
             List<String> manuList = runManageParam.getManufacturer().stream().map(SimpleDTO::getId).collect(Collectors.toList());
             if (CollectionUtil.isEmpty(devIndexes)) {
-                throw new BusinessException("当前部门没有装置台账");
+                return  new Page<>(PageFactory.getPageNum(runManageParam), PageFactory.getPageSize(runManageParam));
             }
             return deviceMapper.getRunManageDevList(new Page<>(PageFactory.getPageNum(runManageParam), PageFactory.getPageSize(runManageParam)),devIndexes, runManageParam.getComFlag(), runManageParam.getRunFlag(), manuList, runManageParam.getSearchValue());
     }

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/common/service/impl/TerminalBaseServiceImpl.java

@@ -853,7 +853,8 @@ public class TerminalBaseServiceImpl extends ServiceImpl<LineMapper, Line> imple
                                 if (!Objects.equals(lineDetail.getCt1(), lineDetailRes.getCt1()) || !Objects.equals(lineDetail.getCt2(), lineDetailRes.getCt2())
                                         || !Objects.equals(lineDetail.getPt1(), lineDetailRes.getPt1()) || !Objects.equals(lineDetail.getPt2(), lineDetailRes.getPt2())
                                         || !Objects.equals(lineDetail.getDevCapacity(), lineDetailRes.getDevCapacity()) || !Objects.equals(lineDetail.getShortCapacity(), lineDetailRes.getShortCapacity())
-                                        || !Objects.equals(lineDetail.getStandardCapacity(), lineDetailRes.getStandardCapacity()) || !Objects.equals(lineDetail.getDealCapacity(), lineDetailRes.getDealCapacity())) {
+                                        || !Objects.equals(lineDetail.getStandardCapacity(), lineDetailRes.getStandardCapacity()) || !Objects.equals(lineDetail.getDealCapacity(), lineDetailRes.getDealCapacity())
+                                        || !Objects.equals(lineDetail.getPtType(), lineDetailRes.getPtType())) {
                                     //获取用户信息
                                     String index = RequestUtil.getUserIndex();
                                     queryUpdateAndInsertLog(userName, index, lineDetail, lineDetailRes);
@@ -959,6 +960,11 @@ public class TerminalBaseServiceImpl extends ServiceImpl<LineMapper, Line> imple
             sbNew.append("协议容量: ").append(newLine.getDealCapacity()).append(";");
             sbOld.append("协议容量: ").append(oldLine.getDealCapacity()).append(";");
         }
+        //接线方式
+        if (!Objects.equals(newLine.getPtType(), oldLine.getPtType())) {
+            sbNew.append("接线方式: ").append(newLine.getPtType()).append(";");
+            sbOld.append("接线方式: ").append(oldLine.getPtType()).append(";");
+        }
         sb.append(sbNew).append(sbOld);
         HttpResult<DictData> dicDataByCode = dicDataFeignClient.getDicDataByCode(DicDataEnum.LINE_PARAMETER.getCode());
         DictData data = dicDataByCode.getData();
@@ -3851,14 +3857,29 @@ public class TerminalBaseServiceImpl extends ServiceImpl<LineMapper, Line> imple
                                 }
                                 //设备删除找不到设备名称,重日志截取
                                 if (Objects.equals(temp.getOperateType(), Param.DEL)) {
-                                    String temLos = "%s名称:%s;前置信息:%s";
-                                    List<String> strings = this.parseTemplateValues(temLos, temp.getTerminalDescribe());
-                                    String devName = strings.get(1); // 设备名称
-                                    String nodeName = strings.get(2); // 进程名称
-                                    pqsTerminalPushLogDTO.setDevName(devName);
-                                    String nodeId = nodeNameMap.get(nodeName).getId();
-                                    pqsTerminalPushLogDTO.setNodeId(nodeId);
-                                    pqsTerminalPushLogDTO.setNodeName(nodeName);
+                                    //删除有2种情况，1.设备删除，2，设备状态修改；
+                                    if (lineMap.containsKey(deviceId)) {
+                                        pqsTerminalPushLogDTO.setDevName(lineMap.get(deviceId).getName());
+                                        String nodeId = deviceMap.get(deviceId).getNodeId();
+                                        pqsTerminalPushLogDTO.setNodeId(nodeId);
+                                        pqsTerminalPushLogDTO.setNodeName(nodeMap.containsKey(nodeId)?nodeMap.get(nodeId).getName():"删除前置");
+
+                                    }else {
+                                        if(temp.getTerminalDescribe().contains("前置信息")){
+                                            String temLos = "%s名称:%s;前置信息:%s";
+                                            List<String> strings = this.parseTemplateValues(temLos, temp.getTerminalDescribe());
+                                            String devName = strings.get(1); // 设备名称
+                                            String nodeName = strings.get(2); // 进程名称
+                                            pqsTerminalPushLogDTO.setDevName(devName);
+                                            String nodeId = nodeNameMap.get(nodeName).getId();
+                                            pqsTerminalPushLogDTO.setNodeId(nodeId);
+                                            pqsTerminalPushLogDTO.setNodeName(nodeName);
+                                        }else {
+                                            return;
+                                        }
+
+                                    }
+
                                 } else {
                                     //如果存在说明设备未被删除，不存在说明有一条删除日志，直接return；
                                     if (lineMap.containsKey(deviceId)) {

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/terminal/service/impl/TerminalMaintainServiceImpl.java

@@ -13,10 +13,12 @@ import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.device.common.mapper.SuperDataMapper;
 import com.njcn.device.common.service.GeneralDeviceService;
 import com.njcn.device.device.mapper.DevFuctionMapper;
+import com.njcn.device.device.service.DeviceProcessService;
 import com.njcn.device.device.service.IDevMealService;
 import com.njcn.device.device.service.IDevStrategyService;
 import com.njcn.device.device.service.IDeviceService;
 import com.njcn.device.line.service.LineService;
+import com.njcn.device.pq.constant.Param;
 import com.njcn.device.pq.enums.LineBaseEnum;
 import com.njcn.device.pq.pojo.dto.GeneralDeviceDTO;
 import com.njcn.device.pq.pojo.param.*;
@@ -84,6 +86,7 @@ public class TerminalMaintainServiceImpl implements TerminalMaintainService {
 
     private final CldStatisticsFlowMapper cldStatisticsFlowMapper;
     private final LineService lineService;
+    private final DeviceProcessService deviceProcessService;
 
     @Override
     public List<TerminalMaintainVO> getTerminalMainList(TerminalMainQueryParam terminalMainQueryParam) {
@@ -205,7 +208,19 @@ public class TerminalMaintainServiceImpl implements TerminalMaintainService {
                         terminalLogsNew.setObjIndex(device.getId());
                         terminalLogsNew.setTerminalDescribe(sb.toString());
                         terminalLogsNew.setIsPush(0);
-                        terminalLogsNew.setOperateType("update");
+                        if(device.getRunFlag() == 0&&device1.getRunFlag()!=0){
+                            terminalLogsNew.setOperateType(Param.DEL);
+
+                        }
+                        if(device1.getRunFlag() == 0&&device.getRunFlag()!=0){
+                            terminalLogsNew.setOperateType(Param.ADD);
+                            //判断device是否绑定进程号；
+                            DeviceProcess deviceProcess = new DeviceProcess();
+                            deviceProcess.setId(device1.getId());
+                            deviceProcess.setProcessNo(1);
+
+                            deviceProcessService.saveOrUpdate(deviceProcess);
+                        }
                         terminalLogsNew.setLogsType(data.getId());
                         terminalLogsNew.setTerminalType(LineBaseEnum.DEVICE_LEVEL.getCode());
                         terminalLogsNew.setState(DataStateEnum.ENABLE.getCode());

pqs-event/event-common/src/main/java/com/njcn/event/common/service/impl/EventDetailServiceImpl.java

@@ -175,37 +175,40 @@ public class EventDetailServiceImpl extends ServiceImpl<RmpEventDetailMapper, Rm
         //如果不为空，说明是二次上传波形文件了;
         String  reason,type;
         if(!StringUtils.isEmpty(rmpEventDetailPO.getWavePath())){
-            LineDetailDataVO lineDetailData = lineFeignClient.getLineDetailData(rmpEventDetailPO.getLineId()).getData();
-            String ip = lineDetailData.getIp();
-            EventAnalysisDTO eventAnalysisDTO = new EventAnalysisDTO();
-            eventAnalysisDTO.setIp(ip);
-            eventAnalysisDTO.setWaveName(rmpEventDetailPO.getWavePath());
+            try {
+                LineDetailDataVO lineDetailData = lineFeignClient.getLineDetailData(rmpEventDetailPO.getLineId()).getData();
+                String ip = lineDetailData.getIp();
+                EventAnalysisDTO eventAnalysisDTO = new EventAnalysisDTO();
+                eventAnalysisDTO.setIp(ip);
+                eventAnalysisDTO.setWaveName(rmpEventDetailPO.getWavePath());
 
-            EventAnalysisDTO result = eventCauseFeignClient.analysisCauseAndType(eventAnalysisDTO).getData();
-            if(Objects.isNull(result.getCause())){
-                reason =reasonReflection(0);
+                EventAnalysisDTO result = eventCauseFeignClient.analysisCauseAndType(eventAnalysisDTO).getData();
+                if(Objects.isNull(result.getCause())){
+                    reason =reasonReflection(0);
 
-            }else {
-                reason =reasonReflection(result.getCause());
+                }else {
+                    reason =reasonReflection(result.getCause());
 
-            }
-            if(Objects.isNull(result.getType())){
-                type =advanceTypeReflection(10);
+                }
+                if(Objects.isNull(result.getType())){
+                    type =advanceTypeReflection(10);
 
-            }else {
-                type =advanceTypeReflection(result.getType());
+                }else {
+                    type =advanceTypeReflection(result.getType());
 
-            }
-            DictData advancereason = dicDataFeignClient.getDicDataByCode(reason).getData();
-            DictData advanceType = dicDataFeignClient.getDicDataByCode(type).getData();
-            if(Objects.equals(result.getCauseFlag(),1)&&Objects.equals(result.getTypeFlag(),1)){
-                rmpEventDetailPO.setDealFlag(1);
-            }else {
+                }
+                DictData advancereason = dicDataFeignClient.getDicDataByCode(reason).getData();
+                DictData advanceType = dicDataFeignClient.getDicDataByCode(type).getData();
+                if(Objects.equals(result.getCauseFlag(),1)&&Objects.equals(result.getTypeFlag(),1)){
+                    rmpEventDetailPO.setDealFlag(1);
+                }else {
+                    rmpEventDetailPO.setDealFlag(0);
+                }
+                rmpEventDetailPO.setAdvanceReason(advancereason.getId());
+                rmpEventDetailPO.setAdvanceType(advanceType.getId());
+            }catch (Exception e){
                 rmpEventDetailPO.setDealFlag(0);
             }
-            rmpEventDetailPO.setAdvanceReason(advancereason.getId());
-            rmpEventDetailPO.setAdvanceType(advanceType.getId());
-
         }
         //默认都是其他
 //        DictData reason = dicDataFeignClient.getDicDataByCode(DicDataEnum.RESON_REST.getCode()).getData();

pqs-system/system-boot/pom.xml

@@ -80,11 +80,11 @@
             <version>${project.version}</version>
         </dependency>
 
-        <dependency>
+     <!--   <dependency>
             <groupId>com.njcn</groupId>
             <artifactId>energy-api</artifactId>
             <version>${project.version}</version>
-        </dependency>
+        </dependency>-->
 
         <dependency>
             <groupId>com.njcn</groupId>

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java

@@ -5,7 +5,6 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.njcn.algorithm.pojo.bo.BaseParam;
 import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
 import com.njcn.system.timer.TimerTaskRunner;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java

@@ -1,39 +1,39 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * 类的介绍：母线算法执行链定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/6 9:35
- */
-@Component
-@RequiredArgsConstructor
-public class GeneraTrixTaskRunner implements TimerTaskRunner {
-
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        baseParam.setRepair(false);
-        if(StrUtil.isBlank(date)){
-            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
-        }else {
-            baseParam.setDataDate(date);
-        }
-        liteFlowFeignClient.generaTrixExecutor(baseParam);
-    }
-
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 类的介绍：母线算法执行链定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/6 9:35
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class GeneraTrixTaskRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        baseParam.setRepair(false);
+//        if(StrUtil.isBlank(date)){
+//            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+//        }else {
+//            baseParam.setDataDate(date);
+//        }
+//        liteFlowFeignClient.generaTrixExecutor(baseParam);
+//    }
+//
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementHourTaskRunner.java

@@ -1,42 +1,42 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * 类的介绍：监测点算法执行链定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/6 9:35
- */
-@Component
-@RequiredArgsConstructor
-public class MeasurementHourTaskRunner implements TimerTaskRunner {
-
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        //由于是按小时跑的，前端其他算法都是按天跑的，因此修改参数
-        if(StrUtil.isBlank(date)){
-            baseParam.setRepair(false);
-            baseParam.setDataDate(DateUtil.now());
-        }else {
-            baseParam.setRepair(true);
-            baseParam.setBeginTime(date+ " 00:00:00");
-            baseParam.setEndTime(date+ " 24:00:00");
-        }
-        liteFlowFeignClient.measurementPointExecutorByHour(baseParam);
-    }
-
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 类的介绍：监测点算法执行链定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/6 9:35
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class MeasurementHourTaskRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        //由于是按小时跑的，前端其他算法都是按天跑的，因此修改参数
+//        if(StrUtil.isBlank(date)){
+//            baseParam.setRepair(false);
+//            baseParam.setDataDate(DateUtil.now());
+//        }else {
+//            baseParam.setRepair(true);
+//            baseParam.setBeginTime(date+ " 00:00:00");
+//            baseParam.setEndTime(date+ " 24:00:00");
+//        }
+//        liteFlowFeignClient.measurementPointExecutorByHour(baseParam);
+//    }
+//
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java

@@ -5,7 +5,6 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.njcn.algorithm.pojo.bo.BaseParam;
 import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
 import com.njcn.system.timer.TimerTaskRunner;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Component;
@@ -21,8 +20,6 @@ import org.springframework.stereotype.Component;
 @RequiredArgsConstructor
 public class MeasurementTaskRunner implements TimerTaskRunner {
 
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
     private final LiteFlowAlgorithmFeignClient liteFlowAlgorithmFeignClient;
 
     @Override

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgSubStationTaskRunner.java

@@ -1,39 +1,39 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * 类的介绍：监测点算法执行链定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/6 9:35
- */
-@Component
-@RequiredArgsConstructor
-public class OrgSubStationTaskRunner implements TimerTaskRunner {
-
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        baseParam.setRepair(false);
-        if(StrUtil.isBlank(date)){
-            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
-        }else {
-            baseParam.setDataDate(date);
-        }
-        liteFlowFeignClient.orgSubStationExecutor(baseParam);
-    }
-
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 类的介绍：监测点算法执行链定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/6 9:35
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class OrgSubStationTaskRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        baseParam.setRepair(false);
+//        if(StrUtil.isBlank(date)){
+//            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+//        }else {
+//            baseParam.setDataDate(date);
+//        }
+//        liteFlowFeignClient.orgSubStationExecutor(baseParam);
+//    }
+//
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java

@@ -1,38 +1,38 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.algorithm.pojo.bo.BaseParam;
-import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * 类的介绍：单位监测点算法执行链定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/6 9:35
- */
-@Component
-@RequiredArgsConstructor
-public class OrgTaskRunner implements TimerTaskRunner {
-
-    private final LiteFlowAlgorithmFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        baseParam.setRepair(false);
-        if(StrUtil.isBlank(date)){
-            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
-        }else {
-            baseParam.setDataDate(date);
-        }
-        liteFlowFeignClient.orgPointExecutor(baseParam);
-    }
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.algorithm.pojo.bo.BaseParam;
+//import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 类的介绍：单位监测点算法执行链定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/6 9:35
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class OrgTaskRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowAlgorithmFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        baseParam.setRepair(false);
+//        if(StrUtil.isBlank(date)){
+//            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+//        }else {
+//            baseParam.setDataDate(date);
+//        }
+//        liteFlowFeignClient.orgPointExecutor(baseParam);
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java

@@ -1,37 +1,37 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * 类的介绍：变电站母线算法执行链定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/6 9:35
- */
-@Component
-@RequiredArgsConstructor
-public class PmsDimTaskRunner implements TimerTaskRunner {
-
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        baseParam.setRepair(false);
-        if(StrUtil.isBlank(date)){
-            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
-        }else {
-            baseParam.setDataDate(date);
-        }
-        liteFlowFeignClient.pmsDimExecutor(baseParam);
-    }
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 类的介绍：变电站母线算法执行链定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/6 9:35
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class PmsDimTaskRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        baseParam.setRepair(false);
+//        if(StrUtil.isBlank(date)){
+//            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+//        }else {
+//            baseParam.setDataDate(date);
+//        }
+//        liteFlowFeignClient.pmsDimExecutor(baseParam);
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsRunStatisticTaskRunner.java

@@ -1,32 +1,32 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
-import com.njcn.prepare.harmonic.api.upload.DimBusGlobalFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * pqs
- *
- * @author cdf
- * @date 2024/4/17
- */
-@Component
-@RequiredArgsConstructor
-public class PmsRunStatisticTaskRunner implements TimerTaskRunner {
-
-    private final DimBusGlobalFeignClient dimBusGlobalFeignClient;
-
-    @Override
-    public void action(String date) {
-        if(StrUtil.isBlank(date)){
-            date = DateUtil.format(DateUtil.yesterday(),DatePattern.NORM_DATE_PATTERN);
-        }
-        dimBusGlobalFeignClient.runLedgerStatistic(date);
-        dimBusGlobalFeignClient.dimBusUpEveryDay(date);
-    }
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
+//import com.njcn.prepare.harmonic.api.upload.DimBusGlobalFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * pqs
+// *
+// * @author cdf
+// * @date 2024/4/17
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class PmsRunStatisticTaskRunner implements TimerTaskRunner {
+//
+//    private final DimBusGlobalFeignClient dimBusGlobalFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        if(StrUtil.isBlank(date)){
+//            date = DateUtil.format(DateUtil.yesterday(),DatePattern.NORM_DATE_PATTERN);
+//        }
+//        dimBusGlobalFeignClient.runLedgerStatistic(date);
+//        dimBusGlobalFeignClient.dimBusUpEveryDay(date);
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java

@@ -1,113 +1,113 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.common.pojo.constant.BizParamConstant;
-import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.Objects;
-
-/**
- * 类的介绍：专项分析-台账统计定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/08 11:23
- */
-@Component
-@RequiredArgsConstructor
-@Slf4j
-public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner {
-
-    private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient;
-
-    @Override
-    public void action(String date) {
-        log.info(LocalDateTime.now()+"专项分析-台账统计调度开始");
-        LineParam lineParam = new LineParam();
-        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
-        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
-        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
-        pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam);
-    }
-
-    public String prepareTimeDeal(String command) {
-        if (StrUtil.isBlank(command)) {
-            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
-            return null;
-        }
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-        Calendar calendar = Calendar.getInstance();
-        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
-            calendar.add(Calendar.DAY_OF_MONTH, -1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
-            int nowMonth = calendar.get(Calendar.MONTH);
-            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-            calendar.set(Calendar.HOUR_OF_DAY, 0);
-            calendar.set(Calendar.MINUTE, 0);
-            calendar.set(Calendar.SECOND, 0);
-            calendar.set(Calendar.MILLISECOND, 0);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
-            calendar.set(Calendar.DAY_OF_YEAR, 1);
-        }
-        log.info("job调度时间:" + sdf.format(calendar.getTime()));
-        return sdf.format(calendar.getTime());
-    }
-
-    /**
-     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
-     *
-     * @author cdf
-     * @date 2023/9/20
-     */
-    public void commDefineDate(String command, LineParam lineParam) {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        String begin;
-        String end;
-        Calendar calendar = Calendar.getInstance();
-        calendar.add(Calendar.DAY_OF_MONTH, -1);
-        Date temDate = calendar.getTime();
-        switch (command) {
-            case BizParamConstant.STAT_BIZ_DAY:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_WEEK:
-                begin = sdf.format(DateUtil.beginOfWeek(temDate));
-                end = sdf.format(DateUtil.endOfWeek(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_MONTH:
-                begin = sdf.format(DateUtil.beginOfMonth(temDate));
-                end = sdf.format(DateUtil.endOfMonth(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_QUARTER:
-                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
-                end = sdf.format(DateUtil.endOfQuarter(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_YEAR:
-                begin = sdf.format(DateUtil.beginOfYear(temDate));
-                end = sdf.format(DateUtil.endOfYear(temDate));
-                break;
-            default:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-        }
-        lineParam.setBeginTime(begin);
-        lineParam.setEndTime(end);
-        lineParam.setDataDate(begin.substring(0, 10));
-    }
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.common.pojo.constant.BizParamConstant;
+//import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient;
+//import com.njcn.prepare.harmonic.pojo.param.LineParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//import java.text.SimpleDateFormat;
+//import java.time.LocalDateTime;
+//import java.util.Calendar;
+//import java.util.Date;
+//import java.util.Objects;
+//
+///**
+// * 类的介绍：专项分析-台账统计定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/08 11:23
+// */
+//@Component
+//@RequiredArgsConstructor
+//@Slf4j
+//public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner {
+//
+//    private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        log.info(LocalDateTime.now()+"专项分析-台账统计调度开始");
+//        LineParam lineParam = new LineParam();
+//        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+//        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+//        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
+//        pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam);
+//    }
+//
+//    public String prepareTimeDeal(String command) {
+//        if (StrUtil.isBlank(command)) {
+//            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+//            return null;
+//        }
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+//        Calendar calendar = Calendar.getInstance();
+//        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+//            calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+//            int nowMonth = calendar.get(Calendar.MONTH);
+//            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//            calendar.set(Calendar.HOUR_OF_DAY, 0);
+//            calendar.set(Calendar.MINUTE, 0);
+//            calendar.set(Calendar.SECOND, 0);
+//            calendar.set(Calendar.MILLISECOND, 0);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+//            calendar.set(Calendar.DAY_OF_YEAR, 1);
+//        }
+//        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+//        return sdf.format(calendar.getTime());
+//    }
+//
+//    /**
+//     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
+//     *
+//     * @author cdf
+//     * @date 2023/9/20
+//     */
+//    public void commDefineDate(String command, LineParam lineParam) {
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+//        String begin;
+//        String end;
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        Date temDate = calendar.getTime();
+//        switch (command) {
+//            case BizParamConstant.STAT_BIZ_DAY:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_WEEK:
+//                begin = sdf.format(DateUtil.beginOfWeek(temDate));
+//                end = sdf.format(DateUtil.endOfWeek(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_MONTH:
+//                begin = sdf.format(DateUtil.beginOfMonth(temDate));
+//                end = sdf.format(DateUtil.endOfMonth(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_QUARTER:
+//                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
+//                end = sdf.format(DateUtil.endOfQuarter(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_YEAR:
+//                begin = sdf.format(DateUtil.beginOfYear(temDate));
+//                end = sdf.format(DateUtil.endOfYear(temDate));
+//                break;
+//            default:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//        }
+//        lineParam.setBeginTime(begin);
+//        lineParam.setEndTime(end);
+//        lineParam.setDataDate(begin.substring(0, 10));
+//    }
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java

@@ -1,113 +1,113 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.common.pojo.constant.BizParamConstant;
-import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.Objects;
-
-/**
- * 类的介绍：发射特性定时任务
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/20 13:55
- */
-@Component
-@RequiredArgsConstructor
-@Slf4j
-public class RMpEmissionTaskRunner implements TimerTaskRunner {
-
-    private final RMpEmissionFeignClient rMpEmissionFeignClient;
-
-    @Override
-    public void action(String date) {
-        log.info(LocalDateTime.now()+"发射特性调度开始");
-        LineParam lineParam = new LineParam();
-        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
-        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
-        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
-        rMpEmissionFeignClient.rMpEmissionMHandler(lineParam);
-    }
-
-    public String prepareTimeDeal(String command) {
-        if (StrUtil.isBlank(command)) {
-            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
-            return null;
-        }
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-        Calendar calendar = Calendar.getInstance();
-        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
-            calendar.add(Calendar.DAY_OF_MONTH, -1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
-            int nowMonth = calendar.get(Calendar.MONTH);
-            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-            calendar.set(Calendar.HOUR_OF_DAY, 0);
-            calendar.set(Calendar.MINUTE, 0);
-            calendar.set(Calendar.SECOND, 0);
-            calendar.set(Calendar.MILLISECOND, 0);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
-            calendar.set(Calendar.DAY_OF_YEAR, 1);
-        }
-        log.info("job调度时间:" + sdf.format(calendar.getTime()));
-        return sdf.format(calendar.getTime());
-    }
-
-    /**
-     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
-     *
-     * @author cdf
-     * @date 2023/9/20
-     */
-    public void commDefineDate(String command, LineParam lineParam) {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        String begin;
-        String end;
-        Calendar calendar = Calendar.getInstance();
-        calendar.add(Calendar.DAY_OF_MONTH, -1);
-        Date temDate = calendar.getTime();
-        switch (command) {
-            case BizParamConstant.STAT_BIZ_DAY:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_WEEK:
-                begin = sdf.format(DateUtil.beginOfWeek(temDate));
-                end = sdf.format(DateUtil.endOfWeek(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_MONTH:
-                begin = sdf.format(DateUtil.beginOfMonth(temDate));
-                end = sdf.format(DateUtil.endOfMonth(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_QUARTER:
-                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
-                end = sdf.format(DateUtil.endOfQuarter(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_YEAR:
-                begin = sdf.format(DateUtil.beginOfYear(temDate));
-                end = sdf.format(DateUtil.endOfYear(temDate));
-                break;
-            default:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-        }
-        lineParam.setBeginTime(begin);
-        lineParam.setEndTime(end);
-        lineParam.setDataDate(begin.substring(0, 10));
-    }
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.common.pojo.constant.BizParamConstant;
+//import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient;
+//import com.njcn.prepare.harmonic.pojo.param.LineParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//import java.text.SimpleDateFormat;
+//import java.time.LocalDateTime;
+//import java.util.Calendar;
+//import java.util.Date;
+//import java.util.Objects;
+//
+///**
+// * 类的介绍：发射特性定时任务
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/20 13:55
+// */
+//@Component
+//@RequiredArgsConstructor
+//@Slf4j
+//public class RMpEmissionTaskRunner implements TimerTaskRunner {
+//
+//    private final RMpEmissionFeignClient rMpEmissionFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        log.info(LocalDateTime.now()+"发射特性调度开始");
+//        LineParam lineParam = new LineParam();
+//        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+//        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+//        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
+//        rMpEmissionFeignClient.rMpEmissionMHandler(lineParam);
+//    }
+//
+//    public String prepareTimeDeal(String command) {
+//        if (StrUtil.isBlank(command)) {
+//            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+//            return null;
+//        }
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+//        Calendar calendar = Calendar.getInstance();
+//        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+//            calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+//            int nowMonth = calendar.get(Calendar.MONTH);
+//            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//            calendar.set(Calendar.HOUR_OF_DAY, 0);
+//            calendar.set(Calendar.MINUTE, 0);
+//            calendar.set(Calendar.SECOND, 0);
+//            calendar.set(Calendar.MILLISECOND, 0);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+//            calendar.set(Calendar.DAY_OF_YEAR, 1);
+//        }
+//        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+//        return sdf.format(calendar.getTime());
+//    }
+//
+//    /**
+//     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
+//     *
+//     * @author cdf
+//     * @date 2023/9/20
+//     */
+//    public void commDefineDate(String command, LineParam lineParam) {
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+//        String begin;
+//        String end;
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        Date temDate = calendar.getTime();
+//        switch (command) {
+//            case BizParamConstant.STAT_BIZ_DAY:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_WEEK:
+//                begin = sdf.format(DateUtil.beginOfWeek(temDate));
+//                end = sdf.format(DateUtil.endOfWeek(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_MONTH:
+//                begin = sdf.format(DateUtil.beginOfMonth(temDate));
+//                end = sdf.format(DateUtil.endOfMonth(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_QUARTER:
+//                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
+//                end = sdf.format(DateUtil.endOfQuarter(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_YEAR:
+//                begin = sdf.format(DateUtil.beginOfYear(temDate));
+//                end = sdf.format(DateUtil.endOfYear(temDate));
+//                break;
+//            default:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//        }
+//        lineParam.setBeginTime(begin);
+//        lineParam.setEndTime(end);
+//        lineParam.setDataDate(begin.substring(0, 10));
+//    }
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java

@@ -1,113 +1,113 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.common.pojo.constant.BizParamConstant;
-import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.Objects;
-
-/**
- * 类的介绍：
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/20 14:12
- */
-@Component
-@RequiredArgsConstructor
-@Slf4j
-public class RMpInfluenceTaskRunner implements TimerTaskRunner {
-
-    private final RMpInfluenceFeignClient rMpInfluenceFeignClient;
-
-    @Override
-    public void action(String date) {
-        log.info(LocalDateTime.now()+"影响特性调度开始");
-        LineParam lineParam = new LineParam();
-        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
-        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
-        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
-        rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam);
-    }
-
-    public String prepareTimeDeal(String command) {
-        if (StrUtil.isBlank(command)) {
-            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
-            return null;
-        }
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-        Calendar calendar = Calendar.getInstance();
-        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
-            calendar.add(Calendar.DAY_OF_MONTH, -1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
-            int nowMonth = calendar.get(Calendar.MONTH);
-            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-            calendar.set(Calendar.HOUR_OF_DAY, 0);
-            calendar.set(Calendar.MINUTE, 0);
-            calendar.set(Calendar.SECOND, 0);
-            calendar.set(Calendar.MILLISECOND, 0);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
-            calendar.set(Calendar.DAY_OF_YEAR, 1);
-        }
-        log.info("job调度时间:" + sdf.format(calendar.getTime()));
-        return sdf.format(calendar.getTime());
-    }
-
-    /**
-     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
-     *
-     * @author cdf
-     * @date 2023/9/20
-     */
-    public void commDefineDate(String command, LineParam lineParam) {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        String begin;
-        String end;
-        Calendar calendar = Calendar.getInstance();
-        calendar.add(Calendar.DAY_OF_MONTH, -1);
-        Date temDate = calendar.getTime();
-        switch (command) {
-            case BizParamConstant.STAT_BIZ_DAY:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_WEEK:
-                begin = sdf.format(DateUtil.beginOfWeek(temDate));
-                end = sdf.format(DateUtil.endOfWeek(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_MONTH:
-                begin = sdf.format(DateUtil.beginOfMonth(temDate));
-                end = sdf.format(DateUtil.endOfMonth(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_QUARTER:
-                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
-                end = sdf.format(DateUtil.endOfQuarter(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_YEAR:
-                begin = sdf.format(DateUtil.beginOfYear(temDate));
-                end = sdf.format(DateUtil.endOfYear(temDate));
-                break;
-            default:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-        }
-        lineParam.setBeginTime(begin);
-        lineParam.setEndTime(end);
-        lineParam.setDataDate(begin.substring(0, 10));
-    }
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.common.pojo.constant.BizParamConstant;
+//import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient;
+//import com.njcn.prepare.harmonic.pojo.param.LineParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//import java.text.SimpleDateFormat;
+//import java.time.LocalDateTime;
+//import java.util.Calendar;
+//import java.util.Date;
+//import java.util.Objects;
+//
+///**
+// * 类的介绍：
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/20 14:12
+// */
+//@Component
+//@RequiredArgsConstructor
+//@Slf4j
+//public class RMpInfluenceTaskRunner implements TimerTaskRunner {
+//
+//    private final RMpInfluenceFeignClient rMpInfluenceFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        log.info(LocalDateTime.now()+"影响特性调度开始");
+//        LineParam lineParam = new LineParam();
+//        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+//        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+//        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
+//        rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam);
+//    }
+//
+//    public String prepareTimeDeal(String command) {
+//        if (StrUtil.isBlank(command)) {
+//            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+//            return null;
+//        }
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+//        Calendar calendar = Calendar.getInstance();
+//        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+//            calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+//            int nowMonth = calendar.get(Calendar.MONTH);
+//            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//            calendar.set(Calendar.HOUR_OF_DAY, 0);
+//            calendar.set(Calendar.MINUTE, 0);
+//            calendar.set(Calendar.SECOND, 0);
+//            calendar.set(Calendar.MILLISECOND, 0);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+//            calendar.set(Calendar.DAY_OF_YEAR, 1);
+//        }
+//        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+//        return sdf.format(calendar.getTime());
+//    }
+//
+//    /**
+//     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
+//     *
+//     * @author cdf
+//     * @date 2023/9/20
+//     */
+//    public void commDefineDate(String command, LineParam lineParam) {
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+//        String begin;
+//        String end;
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        Date temDate = calendar.getTime();
+//        switch (command) {
+//            case BizParamConstant.STAT_BIZ_DAY:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_WEEK:
+//                begin = sdf.format(DateUtil.beginOfWeek(temDate));
+//                end = sdf.format(DateUtil.endOfWeek(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_MONTH:
+//                begin = sdf.format(DateUtil.beginOfMonth(temDate));
+//                end = sdf.format(DateUtil.endOfMonth(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_QUARTER:
+//                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
+//                end = sdf.format(DateUtil.endOfQuarter(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_YEAR:
+//                begin = sdf.format(DateUtil.beginOfYear(temDate));
+//                end = sdf.format(DateUtil.endOfYear(temDate));
+//                break;
+//            default:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//        }
+//        lineParam.setBeginTime(begin);
+//        lineParam.setEndTime(end);
+//        lineParam.setDataDate(begin.substring(0, 10));
+//    }
+//
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java

@@ -5,7 +5,6 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.njcn.algorithm.pojo.bo.BaseParam;
 import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
 
 import com.njcn.system.timer.TimerTaskRunner;
 import lombok.RequiredArgsConstructor;

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwOrgAllRunner.java

@@ -1,31 +1,31 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateUtil;
-import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
-import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-/**
- * pqs
- * 每日定时统计河北两级贯通接口主网数据，用于后续定时上送国网
- * @author cdf
- * @date 2024/2/22
- */
-@Component
-@RequiredArgsConstructor
-public class UploadGwOrgAllRunner implements TimerTaskRunner {
-
-    private final LiteFlowFeignClient liteFlowFeignClient;
-
-    @Override
-    public void action(String date) {
-        BaseParam baseParam = new BaseParam();
-        baseParam.setFullChain(true);
-        baseParam.setRepair(false);
-        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
-        liteFlowFeignClient.uploadOrgExecutor(baseParam);
-    }
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateUtil;
+//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+//import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * pqs
+// * 每日定时统计河北两级贯通接口主网数据，用于后续定时上送国网
+// * @author cdf
+// * @date 2024/2/22
+// */
+//@Component
+//@RequiredArgsConstructor
+//public class UploadGwOrgAllRunner implements TimerTaskRunner {
+//
+//    private final LiteFlowFeignClient liteFlowFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        BaseParam baseParam = new BaseParam();
+//        baseParam.setFullChain(true);
+//        baseParam.setRepair(false);
+//        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+//        liteFlowFeignClient.uploadOrgExecutor(baseParam);
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/energy/AirControllerRunner.java

@@ -1,19 +1,19 @@
-package com.njcn.system.timer.tasks.energy;
-
-
-import com.njcn.energy.pojo.api.EleAirStrategyFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-@Component
-@RequiredArgsConstructor
-public class AirControllerRunner implements TimerTaskRunner {
-
-    private final EleAirStrategyFeignClient eleAirStrategyFeignClient;
-
-    @Override
-    public void action(String date) {
-        eleAirStrategyFeignClient.dealAirStrategyId("close");
-    }
-}
+//package com.njcn.system.timer.tasks.energy;
+//
+//
+//import com.njcn.energy.pojo.api.EleAirStrategyFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//@RequiredArgsConstructor
+//public class AirControllerRunner implements TimerTaskRunner {
+//
+//    private final EleAirStrategyFeignClient eleAirStrategyFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        eleAirStrategyFeignClient.dealAirStrategyId("close");
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/energy/EleIntegrityRunner.java

@@ -1,18 +1,18 @@
-package com.njcn.system.timer.tasks.energy;
-
-import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-@Component
-@RequiredArgsConstructor
-public class EleIntegrityRunner implements TimerTaskRunner {
-
-    private final EnergyStatisticFeignClient energyStatisticFeignClient;
-
-    @Override
-    public void action(String date) {
-        energyStatisticFeignClient.eleIntegrityJobHandler();
-    }
-}
+//package com.njcn.system.timer.tasks.energy;
+//
+//import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//@RequiredArgsConstructor
+//public class EleIntegrityRunner implements TimerTaskRunner {
+//
+//    private final EnergyStatisticFeignClient energyStatisticFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        energyStatisticFeignClient.eleIntegrityJobHandler();
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/energy/EleOnlineRateRunner.java

@@ -1,18 +1,18 @@
-package com.njcn.system.timer.tasks.energy;
-
-import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-@Component
-@RequiredArgsConstructor
-public class EleOnlineRateRunner implements TimerTaskRunner {
-
-    private final EnergyStatisticFeignClient energyStatisticFeignClient;
-
-    @Override
-    public void action(String date) {
-        energyStatisticFeignClient.eleOnlineRateJobHandler();
-    }
-}
+//package com.njcn.system.timer.tasks.energy;
+//
+//import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//@RequiredArgsConstructor
+//public class EleOnlineRateRunner implements TimerTaskRunner {
+//
+//    private final EnergyStatisticFeignClient energyStatisticFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        energyStatisticFeignClient.eleOnlineRateJobHandler();
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/energy/EnergyStatisticRunner.java

@@ -1,21 +1,21 @@
-package com.njcn.system.timer.tasks.energy;
-
-
-import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import org.springframework.stereotype.Component;
-
-@Component
-@RequiredArgsConstructor
-public class EnergyStatisticRunner implements TimerTaskRunner {
-
-    private final EnergyStatisticFeignClient energyStatisticFeignClient;
-
-    @Override
-    public void action(String date) {
-
-        energyStatisticFeignClient.electricCalJob();
-
-    }
-}
+//package com.njcn.system.timer.tasks.energy;
+//
+//
+//import com.njcn.energy.pojo.api.EnergyStatisticFeignClient;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//@RequiredArgsConstructor
+//public class EnergyStatisticRunner implements TimerTaskRunner {
+//
+//    private final EnergyStatisticFeignClient energyStatisticFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//
+//        energyStatisticFeignClient.electricCalJob();
+//
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/report/CustomReportRunner.java

@@ -1,38 +1,38 @@
-package com.njcn.system.timer.tasks.report;
-
-import cn.hutool.core.date.DatePattern;
-import cn.hutool.core.date.DateTime;
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.harmonic.api.ReportFeignClient;
-import com.njcn.prepare.harmonic.api.line.CustomReportFeignClient;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-/**
- * 自定义报表预处理
- */
-@Component
-@RequiredArgsConstructor
-@Slf4j
-public class CustomReportRunner implements TimerTaskRunner {
-
-    private final CustomReportFeignClient customReportFeignClient;
-
-
-    @Override
-    public void action(String date) {
-        LineParam lineParam = new LineParam();
-        if(StrUtil.isNotBlank(date)){
-            lineParam.setDataDate(date);
-        }else {
-            DateTime dealDate = DateUtil.yesterday();
-            String end = DateUtil.format(dealDate, DatePattern.NORM_DATE_PATTERN);
-            lineParam.setDataDate(end);
-        }
-        customReportFeignClient.batchReport(lineParam);
-    }
-}
+//package com.njcn.system.timer.tasks.report;
+//
+//import cn.hutool.core.date.DatePattern;
+//import cn.hutool.core.date.DateTime;
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.harmonic.api.ReportFeignClient;
+//import com.njcn.prepare.harmonic.api.line.CustomReportFeignClient;
+//import com.njcn.prepare.harmonic.pojo.param.LineParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+///**
+// * 自定义报表预处理
+// */
+//@Component
+//@RequiredArgsConstructor
+//@Slf4j
+//public class CustomReportRunner implements TimerTaskRunner {
+//
+//    private final CustomReportFeignClient customReportFeignClient;
+//
+//
+//    @Override
+//    public void action(String date) {
+//        LineParam lineParam = new LineParam();
+//        if(StrUtil.isNotBlank(date)){
+//            lineParam.setDataDate(date);
+//        }else {
+//            DateTime dealDate = DateUtil.yesterday();
+//            String end = DateUtil.format(dealDate, DatePattern.NORM_DATE_PATTERN);
+//            lineParam.setDataDate(end);
+//        }
+//        customReportFeignClient.batchReport(lineParam);
+//    }
+//}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java

@@ -1,113 +1,113 @@
-package com.njcn.system.timer.tasks;
-
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.util.StrUtil;
-import com.njcn.common.pojo.constant.BizParamConstant;
-import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
-import com.njcn.system.timer.TimerTaskRunner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-import java.time.LocalDateTime;
-import java.util.Calendar;
-import java.util.Date;
-import java.util.Objects;
-
-/**
- * 类的介绍：
- *
- * @author xuyang
- * @version 1.0.0
- * @createTime 2023/12/20 14:15
- */
-@Component
-@RequiredArgsConstructor
-@Slf4j
-public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner {
-
-    private final SpecialAnalysisFeignClient specialAnalysisFeignClient;
-
-    @Override
-    public void action(String date) {
-        log.info(LocalDateTime.now()+"专项分析-指标总览开始执行");
-        LineParam lineParam = new LineParam();
-        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
-        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
-        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
-        specialAnalysisFeignClient.hanlder(lineParam);
-    }
-
-    public String prepareTimeDeal(String command) {
-        if (StrUtil.isBlank(command)) {
-            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
-            return null;
-        }
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
-        Calendar calendar = Calendar.getInstance();
-        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
-            calendar.add(Calendar.DAY_OF_MONTH, -1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
-            int nowMonth = calendar.get(Calendar.MONTH);
-            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
-            calendar.set(Calendar.DAY_OF_MONTH, 1);
-            calendar.set(Calendar.HOUR_OF_DAY, 0);
-            calendar.set(Calendar.MINUTE, 0);
-            calendar.set(Calendar.SECOND, 0);
-            calendar.set(Calendar.MILLISECOND, 0);
-        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
-            calendar.set(Calendar.DAY_OF_YEAR, 1);
-        }
-        log.info("job调度时间:" + sdf.format(calendar.getTime()));
-        return sdf.format(calendar.getTime());
-    }
-
-    /**
-     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
-     *
-     * @author cdf
-     * @date 2023/9/20
-     */
-    public void commDefineDate(String command, LineParam lineParam) {
-        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-        String begin;
-        String end;
-        Calendar calendar = Calendar.getInstance();
-        calendar.add(Calendar.DAY_OF_MONTH, -1);
-        Date temDate = calendar.getTime();
-        switch (command) {
-            case BizParamConstant.STAT_BIZ_DAY:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_WEEK:
-                begin = sdf.format(DateUtil.beginOfWeek(temDate));
-                end = sdf.format(DateUtil.endOfWeek(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_MONTH:
-                begin = sdf.format(DateUtil.beginOfMonth(temDate));
-                end = sdf.format(DateUtil.endOfMonth(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_QUARTER:
-                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
-                end = sdf.format(DateUtil.endOfQuarter(temDate));
-                break;
-            case BizParamConstant.STAT_BIZ_YEAR:
-                begin = sdf.format(DateUtil.beginOfYear(temDate));
-                end = sdf.format(DateUtil.endOfYear(temDate));
-                break;
-            default:
-                begin = sdf.format(DateUtil.beginOfDay(temDate));
-                end = sdf.format(DateUtil.endOfDay(temDate));
-                break;
-        }
-        lineParam.setBeginTime(begin);
-        lineParam.setEndTime(end);
-        lineParam.setDataDate(begin.substring(0, 10));
-    }
-
-}
+//package com.njcn.system.timer.tasks;
+//
+//import cn.hutool.core.date.DateUtil;
+//import cn.hutool.core.util.StrUtil;
+//import com.njcn.common.pojo.constant.BizParamConstant;
+//import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient;
+//import com.njcn.prepare.harmonic.pojo.param.LineParam;
+//import com.njcn.system.timer.TimerTaskRunner;
+//import lombok.RequiredArgsConstructor;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.stereotype.Component;
+//
+//import java.text.SimpleDateFormat;
+//import java.time.LocalDateTime;
+//import java.util.Calendar;
+//import java.util.Date;
+//import java.util.Objects;
+//
+///**
+// * 类的介绍：
+// *
+// * @author xuyang
+// * @version 1.0.0
+// * @createTime 2023/12/20 14:15
+// */
+//@Component
+//@RequiredArgsConstructor
+//@Slf4j
+//public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner {
+//
+//    private final SpecialAnalysisFeignClient specialAnalysisFeignClient;
+//
+//    @Override
+//    public void action(String date) {
+//        log.info(LocalDateTime.now()+"专项分析-指标总览开始执行");
+//        LineParam lineParam = new LineParam();
+//        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+//        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+//        this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
+//        specialAnalysisFeignClient.hanlder(lineParam);
+//    }
+//
+//    public String prepareTimeDeal(String command) {
+//        if (StrUtil.isBlank(command)) {
+//            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+//            return null;
+//        }
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+//        Calendar calendar = Calendar.getInstance();
+//        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+//            calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+//            int nowMonth = calendar.get(Calendar.MONTH);
+//            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+//            calendar.set(Calendar.DAY_OF_MONTH, 1);
+//            calendar.set(Calendar.HOUR_OF_DAY, 0);
+//            calendar.set(Calendar.MINUTE, 0);
+//            calendar.set(Calendar.SECOND, 0);
+//            calendar.set(Calendar.MILLISECOND, 0);
+//        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+//            calendar.set(Calendar.DAY_OF_YEAR, 1);
+//        }
+//        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+//        return sdf.format(calendar.getTime());
+//    }
+//
+//    /**
+//     * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
+//     *
+//     * @author cdf
+//     * @date 2023/9/20
+//     */
+//    public void commDefineDate(String command, LineParam lineParam) {
+//        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+//        String begin;
+//        String end;
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        Date temDate = calendar.getTime();
+//        switch (command) {
+//            case BizParamConstant.STAT_BIZ_DAY:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_WEEK:
+//                begin = sdf.format(DateUtil.beginOfWeek(temDate));
+//                end = sdf.format(DateUtil.endOfWeek(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_MONTH:
+//                begin = sdf.format(DateUtil.beginOfMonth(temDate));
+//                end = sdf.format(DateUtil.endOfMonth(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_QUARTER:
+//                begin = sdf.format(DateUtil.beginOfQuarter(temDate));
+//                end = sdf.format(DateUtil.endOfQuarter(temDate));
+//                break;
+//            case BizParamConstant.STAT_BIZ_YEAR:
+//                begin = sdf.format(DateUtil.beginOfYear(temDate));
+//                end = sdf.format(DateUtil.endOfYear(temDate));
+//                break;
+//            default:
+//                begin = sdf.format(DateUtil.beginOfDay(temDate));
+//                end = sdf.format(DateUtil.endOfDay(temDate));
+//                break;
+//        }
+//        lineParam.setBeginTime(begin);
+//        lineParam.setEndTime(end);
+//        lineParam.setDataDate(begin.substring(0, 10));
+//    }
+//
+//}