添加畸变率算法

algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/executor/MeasurementExecutor.java

@@ -2,6 +2,8 @@ package com.njcn.algorithm.executor;
 
 import com.njcn.algorithm.pojo.bo.CalculatedParam;
 import com.njcn.algorithm.service.line.*;
+import com.njcn.dataProcess.api.RmpVThdFeignClient;
+import com.njcn.dataProcess.pojo.dto.RMpVThd;
 import com.yomahub.liteflow.annotation.LiteflowComponent;
 import com.yomahub.liteflow.annotation.LiteflowMethod;
 import com.yomahub.liteflow.core.NodeComponent;
@@ -11,6 +13,7 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 
 import javax.annotation.Resource;
+import java.util.List;
 
 
 /**
@@ -39,6 +42,8 @@ public class MeasurementExecutor extends BaseExecutor {
     private IPollutionService pollutionService;
     @Resource
     private IPollutionCalc pollutionCalc;
+    @Resource
+    private RmpVThdFeignClient rmpVThdFeignClient;
     /**
      * 数据质量清洗
      */
@@ -481,6 +486,24 @@ public class MeasurementExecutor extends BaseExecutor {
         dataIntegrityService.dataIntegrity(bindCmp.getRequestData());
     }
 
+    /**
+     * 算法名: 3.4.1.6.1-----监测点谐波畸变率_日表(r_mp_v_thd)
+     *
+     * @author xuyang
+     * @date 2023年11月13日 19:34
+     */
+    @LiteflowMethod(value = LiteFlowMethodEnum.IS_ACCESS, nodeId = "rMpVThd", nodeType = NodeTypeEnum.COMMON)
+    public boolean rMpVThdAccess(NodeComponent bindCmp) {
+        return isAccess(bindCmp);
+    }
+    @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "rMpVThd", nodeType = NodeTypeEnum.COMMON)
+    public void rMpVThdProcess(NodeComponent bindCmp) {
+        List<RMpVThd> data = rmpVThdFeignClient.queryThd(bindCmp.getRequestData()).getData();
+        rmpVThdFeignClient.batchInsertionThd(data);
+
+    }
+
+
 
 
 }