init 2

pom.xml

@@ -67,6 +67,10 @@
             <version>2.0-SNAPSHOT</version>
         </dependency>
         <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+        <dependency>
             <groupId>com.oracle.database.jdbc</groupId>
             <artifactId>ojdbc8</artifactId>
             <version>19.3.0.0</version>

src/main/java/com/gct/tool/config/FeignConfig.java

@@ -0,0 +1,53 @@
+package com.gct.tool.config;
+
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.EnvironmentAware;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.env.Environment;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.ThreadLocalRandom;
+
+
+/**
+ * feign 调用配置，统一添加token请求头
+ * @author: NewMeanning
+ * @create: 2021-01-29 00:10
+ **/
+@Slf4j
+@Configuration
+public class FeignConfig implements RequestInterceptor, EnvironmentAware {
+
+    private static String token;
+
+    private static Environment env;
+
+    @Override
+    public void apply(RequestTemplate requestTemplate) {
+        requestTemplate.header("token",token);//请求头添加token
+    }
+
+    @Override
+    public void setEnvironment(Environment environment) {
+        //获取配置的认证中心主机地址  todo 升级为自动从Nacos中读取，目前这里读取不到
+        this.env = environment;
+        List<String> hostList = Arrays.asList(this.env.getProperty("auth.hostList").split(","));
+        //手动获取RestTemplate 实例
+        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
+        applicationContext.register(RestTemplate.class);
+        applicationContext.refresh();
+        RestTemplate restTemplate= (RestTemplate) applicationContext.getBean("restTemplate");
+        //自定义轮询方式负载
+        int index = ThreadLocalRandom.current().nextInt(hostList.size());
+        String url = "http://"+hostList.get(index)+"/token";
+        token = restTemplate.getForObject(url,String.class);
+//        log.info("token:{}",token);
+    }
+}

src/main/java/com/gct/tool/config/QuartzTaskConfig.java

@@ -0,0 +1,74 @@
+package com.gct.tool.config;
+
+import com.gct.tool.quartztask.LoadBaseDataTask;
+import com.gct.tool.quartztask.ProduceTask;
+import org.quartz.JobBuilder;
+import org.quartz.JobDetail;
+import org.quartz.Trigger;
+import org.quartz.TriggerBuilder;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import static org.quartz.CronScheduleBuilder.cronSchedule;
+
+/**
+ * class name: QuartzTaskConfig
+ *
+ * @author lloyd
+ * @version 1.0
+ * @since 2021/5/21 上午10:21
+ */
+@Configuration
+public class QuartzTaskConfig {
+
+    @Bean
+    public JobDetail jobDetail1() {
+        try {
+            return JobBuilder.newJob(LoadBaseDataTask.class)
+                    .withIdentity("LoadBaseData" ,"Group1")
+                    .storeDurably()
+                    .build();
+        } catch (Exception e) {
+            LoggerFactory.getLogger(this.getClass()).error("Create JobDetail bean failed:{},jobName->{},jobGroup->{}", e.getMessage(),"LoadBaseData","Group1");
+            throw e;
+        }
+    }
+
+    @Bean
+    public Trigger trigger1() {
+        try {
+            return TriggerBuilder.newTrigger()
+                    .forJob("LoadBaseData", "Group1")
+                    .withSchedule(cronSchedule("0/1 0 0/1 * * ?")).build();
+        } catch (Exception e) {
+            LoggerFactory.getLogger(this.getClass()).error("Create Trigger bean failed:{},jobName->{},jobGroup->{}", e.getMessage(),"LoadBaseData","Group1");
+            throw e;
+        }
+    }
+
+    @Bean
+    public JobDetail jobDetail2() {
+        try {
+            return JobBuilder.newJob(ProduceTask.class)
+                    .withIdentity("Produce" ,"Group1")
+                    .storeDurably()
+                    .build();
+        } catch (Exception e) {
+            LoggerFactory.getLogger(this.getClass()).error("Create JobDetail bean failed:{},jobName->{},jobGroup->{}", e.getMessage(),"LoadBaseData","Group1");
+            throw e;
+        }
+    }
+
+    @Bean
+    public Trigger trigger2() {
+        try {
+            return TriggerBuilder.newTrigger()
+                    .forJob("Produce", "Group1")
+                    .withSchedule(cronSchedule("0/1 0 0/1 * * ?")).build();
+        } catch (Exception e) {
+            LoggerFactory.getLogger(this.getClass()).error("Create Trigger bean failed:{},jobName->{},jobGroup->{}", e.getMessage(),"Produce","Group1");
+            throw e;
+        }
+    }
+}

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

@@ -1,20 +0,0 @@
-package com.gct.tool.mapper.centralbase;
-
-import com.baomidou.dynamic.datasource.annotation.DS;
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.gct.tool.entity.centralbase.CbCdWellSource;
-import org.apache.ibatis.annotations.Mapper;
-
-/**
- * <p>
- * 单井基础信息 Mapper 接口
- * </p>
- *
- * @author wsy
- * @since 2021-01-19
- */
-@Mapper
-@DS("centralbase")
-public interface CbCdWellSourceMapper extends BaseMapper<CbCdWellSource> {
-
-}

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

@@ -1,38 +0,0 @@
-<?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.tool.mapper.centralbase.CbCdWellSourceMapper">
-
-    <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.gct.tool.entity.centralbase.CbCdWellSource">
-        <result column="well_id" property="wellId"/>
-        <result column="well_common_name" property="wellCommonName"/>
-        <result column="well_legal_name" property="wellLegalName"/>
-        <result column="reason" property="reason"/>
-        <result column="well_purpose" property="wellPurpose"/>
-        <result column="p_start_prod_stitum" property="pStartProdStitum"/>
-        <result column="target_formation" property="targetFormation"/>
-        <result column="spud_date" property="spudDate"/>
-        <result column="org_id" property="orgId"/>
-        <result column="struct_id" property="structId"/>
-        <result column="oilfield_id" property="oilfieldId"/>
-        <result column="exp_area_id" property="expAreaId"/>
-        <result column="group_unit_id" property="groupUnitId"/>
-        <result column="station_id" property="stationId"/>
-        <result column="geo_latitude" property="geoLatitude"/>
-        <result column="geo_longitude" property="geoLongitude"/>
-        <result column="geo_offset_reference" property="geoOffsetReference"/>
-        <result column="geo_offset_east" property="geoOffsetEast"/>
-        <result column="geo_offset_north" property="geoOffsetNorth"/>
-        <result column="remarks" property="remarks"/>
-        <result column="is_deviated" property="isDeviated"/>
-        <result column="end_status" property="endStatus"/>
-        <result column="completion_name" property="completionName"/>
-        <result column="PRODUCING_AREA_name" property="producingAreaName"/>
-        <result column="top_tvd" property="topTvd"/>
-        <result column="bottom_tvd" property="bottomTvd"/>
-        <result column="completion_id" property="completionId"/>
-    </resultMap>
-</mapper>
-
-
-

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

@@ -0,0 +1,21 @@
+package com.gct.tool.mapper.centralbase;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.gct.centralbase.entity.CbPcProWellboreStatusDaily;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * <p>
+ * 采出井井筒状态日数据 Mapper 接口
+ * </p>
+ *
+ * @author wsy
+ * @since 2021-01-19
+ */
+@Mapper
+public interface CbPcProWellboreStatusDailyMapper extends BaseMapper<CbPcProWellboreStatusDaily> {
+    public CbPcProWellboreStatusDaily getWellBoreStatusDaily(@Param("wellId") String wellId,@Param("prodDate") String prodDate);
+
+    CbPcProWellboreStatusDaily getA2DataForCalProduction(@Param("wellId") String wellName,@Param("prodDate") String dateTime);
+}

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

@@ -0,0 +1,48 @@
+<?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.CbPcProWellboreStatusDailyMapper">
+
+    <cache flushInterval="6000000" size="5096"/>
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.gct.centralbase.entity.CbPcProWellboreStatusDaily">
+        <result column="well_id" property="wellId"/>
+        <result column="prod_date" property="prodDate"/>
+        <result column="oil_prod_method" property="oilProdMethod"/>
+        <result column="oil_nozzle" property="oilNozzle"/>
+        <result column="back_pres" property="backPres"/>
+        <result column="up_current" property="upCurrent"/>
+        <result column="down_current" property="downCurrent"/>
+        <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="elec_pump_voltage" property="elecPumpVoltage"/>
+        <result column="wh_temp" property="whTemp"/>
+        <result column="main_line_pres" property="mainLinePres"/>
+        <result column="avg_oil_pres" property="avgOilPres"/>
+        <result column="avg_casing_pres" property="avgCasingPres"/>
+        <result column="tubing_pres" property="tubingPres"/>
+        <result column="casing_pres" property="casingPres"/>
+        <result column="cable_setting_depth" property="cableSettingDepth"/>
+        <result column="pump_depth" property="pumpDepth"/>
+        <result column="casing_inner_diameter" property="casingInnerDiameter"/>
+        <result column="start_pump_liq_level" property="startPumpLiqLevel"/>
+        <result column="end_pump_liq_level" property="endPumpLiqLevel"/>
+        <result column="submergence_depth" property="submergenceDepth"/>
+    </resultMap>
+    <select id="getA2DataForCalProduction" resultMap="BaseResultMap">
+        select *
+        from centralbase.cb_pc_pro_wellbore_status_daily
+        where well_id = #{wellId}
+          and (prod_date::timestamp between  #{prodDate}::timestamp - INTERVAL '2 day' and #{prodDate}::timestamp)
+        order by prod_date desc limit 1
+    </select>
+    <select id="getWellBoreStatusDaily" parameterType="string"
+            resultType="com.gct.centralbase.entity.CbPcProWellboreStatusDaily">
+        select *
+        from centralbase.cb_pc_pro_wellbore_status_daily
+        where well_id = #{wellId}
+          and (prod_date::timestamp between  #{prodDate}::timestamp - INTERVAL '2 day' and #{prodDate}::timestamp)
+        order by prod_date desc limit 1
+    </select>
+</mapper>

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

@@ -0,0 +1,27 @@
+package com.gct.tool.mapper.centralbase;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.gct.centralbase.entity.CbPcProWellboreVolDaily;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Map;
+
+/**
+ * <p>
+ * 采出井井筒生产日数据 Mapper 接口
+ * </p>
+ *
+ * @author wsy
+ * @since 2021-01-19
+ */
+@Mapper
+public interface CbPcProWellboreVolDailyMapper extends BaseMapper<CbPcProWellboreVolDaily> {
+    CbPcProWellboreVolDaily getWellBoreVolDaily(String wellId,String prodDate);
+
+    CbPcProWellboreVolDaily getA2DataForCalVolDaily(@Param("wellName") String wellName, @Param("dataTime") String dataTime);
+
+    Page<Map<String,Object>> getCbPcProWellBoreVolDaily(IPage<Map<String,Object>> page, @Param("sql") String sql);
+}

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

@@ -0,0 +1,74 @@
+<?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.CbPcProWellboreVolDailyMapper">
+
+    <cache flushInterval="6000000" size="5096"/>
+
+    <!-- 通用查询映射结果 -->
+    <resultMap id="BaseResultMap" type="com.gct.centralbase.entity.CbPcProWellboreVolDaily">
+        <result column="well_id" property="wellId"/>
+        <result column="prod_date" property="prodDate"/>
+        <result column="prod_time" property="prodTime"/>
+        <result column="liq_prod_daily" property="liqProdDaily"/>
+        <result column="oil_prod_daily" property="oilProdDaily"/>
+        <result column="water_prod_daily" property="waterProdDaily"/>
+        <result column="gas_prod_daily" property="gasProdDaily"/>
+        <result column="water_cut" property="waterCut"/>
+        <result column="sand_content_ratio" property="sandContentRatio"/>
+        <result column="gas_oil_ratio" property="gasOilRatio"/>
+        <result column="gas_fluid_content" property="gasFluidContent"/>
+        <result column="gas_chloride_content" property="gasChlorideContent"/>
+        <result column="stim_key_id" property="stimKeyId"/>
+        <result column="water_gas_ratio" property="waterGasRatio"/>
+        <result column="remarks" property="remarks"/>
+        <result column="stim_content" property="stimContent"/>
+    </resultMap>
+    <resultMap id="map2" type="com.gct.centralbase.entity.CbPcProWellboreVolDaily">
+        <result column="well_id" property="wellId"/>
+        <result column="prod_date" property="prodDate"/>
+        <result column="prod_time" property="prodTime"/>
+        <result column="liq_prod_daily" property="liqProdDaily"/>
+        <result column="oil_prod_daily" property="oilProdDaily"/>
+        <result column="water_prod_daily" property="waterProdDaily"/>
+        <result column="gas_prod_daily" property="gasProdDaily"/>
+        <result column="water_cut" property="waterCut"/>
+        <result column="sand_content_ratio" property="sandContentRatio"/>
+        <result column="gas_oil_ratio" property="gasOilRatio"/>
+        <result column="gas_fluid_content" property="gasFluidContent"/>
+        <result column="gas_chloride_content" property="gasChlorideContent"/>
+        <result column="stim_key_id" property="stimKeyId"/>
+        <result column="water_gas_ratio" property="waterGasRatio"/>
+        <result column="remarks" property="remarks"/>
+        <result column="stim_content" property="stimContent"/>
+        <result column="org_id" property="orgId"/>
+    </resultMap>
+    <select id="getWellBoreVolDaily" parameterType="string"
+            resultType="com.gct.centralbase.entity.CbPcProWellboreVolDaily">
+        select *
+        from centralbase.cb_pc_pro_wellbore_vol_daily
+        where well_id = #{wellId}
+          and (prod_date::timestamp between  #{prodDate}::timestamp - INTERVAL '2 day' and #{prodDate}::timestamp)
+        order by prod_date desc limit 1
+    </select>
+    <select id="getA2DataForCalVolDaily" parameterType="string" resultMap="BaseResultMap">
+
+        select *
+        from centralbase.cb_pc_pro_wellbore_vol_daily
+        where well_id = #{wellName}
+          and (prod_date::timestamp between  #{dataTime}::timestamp - INTERVAL '2 day' and #{dataTime}::timestamp)
+        order by prod_date desc limit 1
+    </select>
+
+    <!--<select id="getCbPcProWellBoreVolDaily" resultMap="BaseResultMap">
+        select centralbase.cb_pc_pro_wellbore_vol_daily.*, centralbase.cb_cd_well_source.org_id as org_id
+        from centralbase.cb_pc_pro_wellbore_vol_daily,
+             centralbase.cb_cd_well_source
+        where prod_date::date = #{prodDate}:: timestamp :: date
+          and cb_pc_pro_wellbore_vol_daily.well_id = cb_cd_well_source.well_id
+            limit #{pageSize} offset (#{curPage}-1)*#{pageSize}
+    </select>-->
+
+    <select id="getCbPcProWellBoreVolDaily" resultType="java.util.Map">
+        ${sql}
+    </select>
+</mapper>

src/main/java/com/gct/tool/quartztask/LoadBaseDataTask.java

@@ -0,0 +1,45 @@
+package com.gct.tool.quartztask;
+
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+import org.springframework.web.client.RestTemplate;
+
+/**
+ * @author xusirui 2023/7/9
+ */
+public class LoadBaseDataTask extends QuartzJobBean {\
+
+    RestTemplate restTemplate;
+
+    public LoadBaseDataTask(){
+        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
+        applicationContext.register(RestTemplate.class);
+        applicationContext.refresh();
+        restTemplate= (RestTemplate) applicationContext.getBean("restTemplate");
+    }
+
+    public String getToken(){
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+        HttpEntity request1 = new HttpEntity<>(request, headers);
+        log.info("请求报文：{}",request);
+
+        ResponseEntity<String> jsonObjectResponseEntity = restTemplate.postForEntity(url, request1, String.class);
+        String resp = jsonObjectResponseEntity.getBody();
+        log.info("响应报文：{}",resp);
+
+    }
+
+
+    @Override
+    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
+
+
+    }
+}

src/main/java/com/gct/tool/quartztask/ProduceTask.java

@@ -0,0 +1,15 @@
+package com.gct.tool.quartztask;
+
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+
+/**
+ * @author xusirui 2023/7/9
+ */
+public class ProduceTask extends QuartzJobBean {
+    @Override
+    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
+
+    }
+}

src/main/java/com/gct/tool/service/centralbase/CbCdWellSourceServiceImpl.java

@@ -2,7 +2,6 @@ package com.gct.tool.service.centralbase;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gct.tool.entity.centralbase.CbCdWellSource;
-import com.gct.tool.mapper.centralbase.CbCdWellSourceMapper;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;

src/main/resources/application-pro.yml

@@ -55,6 +55,5 @@ swagger:
     key-name: token
   enabled: true
 
-gt-total: 24
-begin-date: 2022-11-28
-end-date: 2022-12-08
+auth:
+  hostList: 10.79.32.183:9001