量液异常信息报警

src/main/java/com/gct/aoid/feignclient/WarningClint.java

@@ -0,0 +1,13 @@
+package com.gct.aoid.feignclient;
+
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+@FeignClient(value = "warning",fallback = WarningHystrix.class)
+public interface WarningClint {
+
+    @RequestMapping(value = "/wnGkMsg/extractWorkingConditionDiagnosis/{WellID}",method = RequestMethod.GET)
+    String extractWorkingConditionDiagnosis(@PathVariable("WellID") String wellID,@PathVariable("date") String date) ;
+}

src/main/java/com/gct/aoid/feignclient/WarningHystrix.java

@@ -0,0 +1,9 @@
+package com.gct.aoid.feignclient;
+
+public class WarningHystrix implements WarningClint{
+
+    @Override
+    public String extractWorkingConditionDiagnosis(String wellID, String date) {
+        return "error";
+    }
+}

src/main/java/com/gct/aoid/job/AoidWarningJobDetail.java

@@ -0,0 +1,46 @@
+package com.gct.aoid.job;
+
+import com.gct.aoid.mapper.SumDataTaskMapper;
+import com.gct.aoid.service.AoidWarningService;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * class name: CalLiqDailyJobDetail
+ *
+ * @author lloyd
+ * @version 1.0
+ * @since 2021/5/21 上午10:24
+ */
+@Slf4j
+public class AoidWarningJobDetail extends QuartzJobBean {
+    @Autowired
+    public AoidWarningService aoidWarningService;
+
+    @Override
+    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        //sumDataTaskMapper= (SumDataTaskMapper)jobExecutionContext.getJobDetail().getJobDataMap().get("dao");
+        String jobName = jobExecutionContext.getJobDetail().getJobDataMap().getString(JobDataKey.JobName.getDec());
+        String jobGroup = jobExecutionContext.getJobDetail().getJobDataMap().getString(JobDataKey.JobGroup.getDec());
+        LocalDateTime localDateTime = LocalDateTime.now();
+        log.info("*===>AoidWarningJobDetail--JobName:{}--JobGroup:{},Time:{}", jobName, jobGroup, localDateTime.format(DateTimeFormatter.ISO_DATE_TIME));
+        //String date = DateTimeFormatter.ofPattern("yyyy-MM-dd").format(localDateTime);
+       // String dateTime = date + " 00:00:00";
+        try {
+            String isWarning = aoidWarningService.isWarning("H257", "2021-05-15");
+            System.out.println(isWarning);
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException("aoidWaring error");
+        } finally {
+            log.info("<===*AoidWarningJobDetail,Time:{}", localDateTime.format(DateTimeFormatter.ISO_DATE_TIME));
+        }
+    }
+
+}

src/main/java/com/gct/aoid/mapper/AoidDailyYieldMapper.java

@@ -17,4 +17,5 @@ public interface AoidDailyYieldMapper extends BaseMapper<AoidDailyYield> {
 
 
     List<AoidDailyYield> getAoidDailyYieldInfoByWellIdAndPorDatePeriod(@Param("wellId") String wellId,@Param("startDate") String startDate,@Param("endDate") String endDate);
+    String getAVGForA2LiqProdDaily(@Param("wellId") String wellId,@Param("date") String date);
 }

src/main/java/com/gct/aoid/mapper/AoidDailyYieldMapper.xml

@@ -54,5 +54,9 @@
         where well_id=#{wellId} and prod_date >= #{startDate}::timestamp and  #{endDate}::timestamp >= prod_date
 
     </select>
+    <select id="getAVGForA2LiqProdDaily" resultType="string">
+        select avg(liq_prod_daily) from aoid_daily_yield where well_id= #{wellId} and
+            prod_date>=#{date}::timestamp - interval '30 day';
+    </select>
 
 </mapper>

src/main/java/com/gct/aoid/service/AoidWarningService.java

@@ -0,0 +1,6 @@
+package com.gct.aoid.service;
+
+public interface AoidWarningService {
+
+    String isWarning(String wellId,String date);
+}

src/main/java/com/gct/aoid/service/impl/AoidWarningServiceImpl.java

@@ -0,0 +1,62 @@
+package com.gct.aoid.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.gct.aoid.entity.AoidDailyYield;
+import com.gct.aoid.feignclient.WarningClint;
+import com.gct.aoid.mapper.AoidDailyYieldMapper;
+import com.gct.aoid.service.AoidWarningService;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.math.BigDecimal;
+
+public class AoidWarningServiceImpl implements AoidWarningService {
+
+    @Autowired
+    AoidDailyYieldMapper aoidDailyYieldMapper;
+    @Autowired
+    WarningClint warningClint;
+    @Override
+    public String isWarning(String wellId,String date) {
+
+        //获取前一个月的平均产液量
+        String avgForA2LiqProdDaily = aoidDailyYieldMapper.getAVGForA2LiqProdDaily(wellId, date);
+        //获取当前的产液量
+        QueryWrapper<AoidDailyYield> wrapper = new QueryWrapper<>();
+        wrapper.eq("well_id",wellId).eq("prod_date",date);
+        AoidDailyYield aoidDailyYield = aoidDailyYieldMapper.selectOne(wrapper);
+        Double aDouble = Double.valueOf(avgForA2LiqProdDaily);
+        double liqProdDaily = aoidDailyYield.getLiqProdDaily();
+        double difference = aDouble-liqProdDaily;
+        String result = "";
+        int[] num = {15,10,5,1,0};
+        double[] coefficient = {0.1,0.15,0.2,0.25,0.5};
+        for (int i = 0 ;i< num.length; i++){
+            if (aDouble>=num[i]){
+                if (aDouble * (1-coefficient[i]) > liqProdDaily){
+                    result = "液量异常";
+                    break;
+                }else {
+                    result = "液量正常";
+                    break;
+                }
+            }
+        }
+        //液量异常井 提取工况诊断是否正常，不正常 进入油井工况诊断 得出结论并输出 yuancheng wn_gk_msg context
+        if (result.equals("液量异常")){
+            String extractWorkingConditionDiagnosis = warningClint.extractWorkingConditionDiagnosis(wellId,date);
+            if(extractWorkingConditionDiagnosis.equals("正常")){
+                //正常 提取该井压力库数据，判断是否在高压区 默认 低压区
+                //如处在低压区，查看 平均值与当日值的差是否大于0 ，大于0 分析为油井见效，输出结果;小于0 分析为能量不足，输出结果
+                //如在高压区，查看 平均值与当日值的差是否大于0 ,大于0 分析为油井见效,输出结果;小于0分析为地层堵塞，输出结果
+                if (difference > 0){
+                    result = "油井见效";
+                }else {
+                    result = "能量不足";
+                }
+            }else{
+                result = extractWorkingConditionDiagnosis;
+            }
+        }
+        return result;
+    }
+}

src/main/resources/application-dev.yml

@@ -83,6 +83,12 @@ spring:
         JobGroup: CAL_TASK
         DelayMilliseconds: 1000
         IsRepeatable: true
+      jt2:
+        IntervalInSeconds: 600
+        JobName: AoidWarningJobDetail
+        JobGroup: AoidWarning
+        DelayMilliseconds: 1000
+        IsRepeatable: true
 # swagger 相关配置
 swagger:
   authorization: