add wellsource struct

src/main/java/com/gct/tool/entity/centralbase/CbTempWellMechRuntime.java

@@ -2,11 +2,6 @@ package com.gct.tool.entity.centralbase;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
-
-import java.lang.reflect.Field;
-import java.time.LocalDateTime;
-import java.io.Serializable;
-
 import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -14,6 +9,9 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
 /**
  * <p>
  * 机采数据 runtime

src/main/java/com/gct/tool/mapper/centralbase/CbTempWellMechRuntimeMapper.java

@@ -0,0 +1,29 @@
+package com.gct.tool.mapper.centralbase;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gct.centralbase.entity.CbTempWellMechRuntime;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 机采数据 runtime Mapper 接口
+ * </p>
+ *
+ * @author wsy
+ * @since 2021-01-19
+ */
+@Mapper
+public interface CbTempWellMechRuntimeMapper extends BaseMapper<CbTempWellMechRuntime> {
+
+
+    List getErrorData(@Param("localDateTime") LocalDateTime localDateTime);
+
+    List getErrorDataInfo(@Param("prodDate") LocalDateTime prodDate);
+
+    void createTableWithCbRunTime(@Param("startDate") String startDate,@Param("endDate") String endDate);
+    void testRuntime(@Param("p1") String p1,@Param("p2") String p2);
+}

src/main/java/com/gct/tool/mapper/centralbase/CbTempWellMechRuntimeMapper.xml

@@ -0,0 +1,75 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.gct.centralbase.mapper.CbTempWellMechRuntimeMapper">
+
+    <cache flushInterval="6000000" size="5096"/>
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.gct.centralbase.entity.CbTempWellMechRuntime">
+        <result column="well_id" property="wellId" />
+        <result column="prod_date" property="prodDate" />
+        <result column="theo_discharge" property="theoDischarge" />
+        <result column="indi_diagram_interp_code" property="indiDiagramInterpCode" />
+        <result column="dynamic_liq_level" property="dynamicLiqLevel" />
+        <result column="static_liq_lev" property="staticLiqLev" />
+        <result column="static_pressure" property="staticPressure" />
+        <result column="flow_pres" property="flowPres" />
+        <result column="pump_diameter" property="pumpDiameter" />
+        <result column="pump_depth" property="pumpDepth" />
+        <result column="pump_efficiency" property="pumpEfficiency" />
+        <result column="rotate_frequency" property="rotateFrequency" />
+        <result column="stroke_length" property="strokeLength" />
+        <result column="stroke_frequency" property="strokeFrequency" />
+        <result column="susp_max_load" property="suspMaxLoad" />
+        <result column="susp_min_load" property="suspMinLoad" />
+        <result column="pump_tag_discharge" property="pumpTagDischarge" />
+        <result column="rep_pressure_gradient_flow" property="repPressureGradientFlow" />
+        <result column="pump_type" property="pumpType" />
+        <result column="electromotor_power" property="electromotorPower" />
+        <result column="elec_frequency" property="elecFrequency" />
+        <result column="diagram_interp_code_time" property="diagramInterpCodeTime" />
+        <result column="sgt" property="sgt" />
+        <result column="elec_pump_current_a" property="elecPumpCurrentA" />
+        <result column="elec_pump_current_b" property="elecPumpCurrentB" />
+        <result column="elec_pump_current_c" property="elecPumpCurrentC" />
+        <result column="dgt" property="dgt" />
+    </resultMap>
+    <select id="getErrorData" resultType="java.util.Map">
+        delete from  centralbase.cb_runtime_error where prod_date::date =#{localDateTime};
+        insert into centralbase.cb_runtime_error
+        select t3.org_name org,prod_date,sum(frequencyzero) frequencyzero , sum(frequencynull) frequencynull ,sum(frequencylit) frequencylit ,sum(frequencyok) frequencyok,
+               sum(strokezero) strokezero,sum(strokenull) strokenull,sum(strokelit) strokelit,sum(strokeok) strokeok,
+               sum(sgtnullstr) sgtnullstr,sum(sgtnull) sgtnull,sum(sgtok) sgtok from (
+        select rn.well_id,#{localDateTime}::date prod_date,
+        sum(case when rn.stroke_frequency=0 then 1 else 0 end ) frequencyzero ,
+        sum(case when rn.stroke_frequency is null  then 1 else 0 end ) frequencynull,
+        sum(case when rn.stroke_frequency >12 or rn.stroke_frequency &lt; 0 then 1 else 0 end ) frequencylit,
+        sum(case when rn.stroke_frequency &lt;12 and rn.stroke_frequency > 0 then 1 else 0 end ) frequencyok,
+        sum(case when rn.stroke_length = 0  then 1 else 0 end ) strokezero,
+        sum(case when rn.stroke_length is null then 1 else 0 end ) strokenull,
+        sum(case when rn.stroke_length >12 or rn.stroke_length &lt; 0 then 1 else 0 end ) strokelit,
+        sum(case when rn.stroke_length &lt; 12 and rn.stroke_length > 0 then 1 else 0 end ) strokeok,
+        sum(case when rn.sgt ='' then 1 else 0 end ) sgtnullstr,
+        sum(case when rn.sgt is null then 1 else 0 end ) sgtnull,
+        sum(case when rn.sgt !='' and sgt is not null  then 1 else 0 end ) sgtok
+        from centralbase.cb_temp_well_mech_runtime rn
+        where  rn.prod_date::date=#{localDateTime} group by rn.well_id
+        ) dat
+        left join centralbase.cb_cd_well_source t0 on dat.well_id=t0.well_id
+        left join centralbase.cb_pc_organization t1 on t0.org_id=t1.org_id
+        left join centralbase.cb_pc_organization t2 on t1.parent_id=t2.org_id
+        left join centralbase.cb_pc_organization t3 on t2.parent_id=t3.org_id
+        group by t3.org_name,prod_date
+    </select>
+    <select id="getErrorDataInfo" resultType="java.util.Map">
+        select * from centralbase.cb_runtime_error where prod_date::date =#{prodDate} and org_name !=''
+    </select>
+
+    <select id="createTableWithCbRunTime">
+        select centralbase.timingCrateTableRunTime(#{endDate},#{startDate});
+    </select>
+    <select id="testRuntime">
+        SELECT  count(1) FROM centralbase.cb_temp_well_mech_runtime
+        WHERE prod_date = #{p1}
+    </select>
+</mapper>