get sgt

src/main/Test/MyTest.java

@@ -25,7 +25,7 @@ public class MyTest {
 
     @Test
     public void test() {
-        loadBaseDataService.loadCdWellSource();
+        loadBaseDataService.loadWorkDiagramData();
 //        cbPcProWellboreVolDailyMapper.selectList(new QueryWrapper<>());
     }
 

src/main/java/com/gct/tool/feign/DataBankClient.java

@@ -16,7 +16,12 @@ public interface DataBankClient {
     /*
     http://tlmdatabank.tlm.pcep.cloud/api/dde/
      */
-    @PostMapping(value = "governdataservice/struct/OP_PRO_COMPLETION_VOL_DAILY/query")
+    @PostMapping(value = "governdataservice/struct/OP_PROD_WELL_PROD_DAILY/query")
     JSONObject getVolDailyData(@RequestBody Map query, @RequestParam int page,@RequestParam int size,@RequestParam String identity);
 
+    @PostMapping(value = "subjectdataservice/X_OP_PRO_WELL_VOL_DAILY")
+    JSONObject getStatusDailyData(@RequestBody Map query, @RequestParam int page,@RequestParam int size,@RequestParam String identity);
+
+
+
 }

src/main/java/com/gct/tool/feign/WorkDiagramClient.java

@@ -0,0 +1,16 @@
+package com.gct.tool.feign;
+
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestParam;
+
+import java.util.Map;
+
+@FeignClient(url = "10.79.1.252:9101/itl_tycjpt/dataBySql", name = "work-diagram-client")
+public interface WorkDiagramClient {
+
+    @PostMapping(value = "/getDataBySqlQuery")
+    String getWorkDiagramData(@RequestParam String sqlstring);
+}

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

@@ -3,7 +3,7 @@ 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.CbCdWellSource;
+import com.gct.tool.entity.centralbase.CbCdWellSource;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -21,25 +21,5 @@ import java.util.Map;
 @Mapper
 public interface CbCdWellSourceMapper extends BaseMapper<CbCdWellSource> {
 
-    List<CbCdWellSource> selectWellSourceList(@Param("orgIds") List<String> orgIds);
-
-    List<CbCdWellSource> getjhAll();
-    List<CbCdWellSource> getjhAllByorgid(@Param("orgid") String orgid);
-    Page<Map<String,Object>> getAllWellSourceList(@Param("page") IPage<Map<String,Object>> page, @Param("sql") String sql);
-
-    /**
-     * 根据井号查询稠油井信息
-     * @param wellName
-     * @return
-     */
-    CbCdWellSource getByWellId_Heavy(@Param("wellName") String wellName);
-
-
-
-    //查询所有井用于分析误差率
-    List<CbCdWellSource> getjhAllYieldError();
-
-    List<CbCdWellSource> getjhAllConent();
-
 
 }

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

@@ -1,11 +1,9 @@
 <?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.CbCdWellSourceMapper">
-
-    <cache flushInterval="60000" size="5096"/>
+<mapper namespace="com.gct.tool.mapper.centralbase.CbCdWellSourceMapper">
 
     <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.gct.centralbase.entity.CbCdWellSource">
+    <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"/>
@@ -36,51 +34,6 @@
     </resultMap>
 
 
-    <select id="selectWellSourceList" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select "u"."well_common_name" from "centralbase"."cb_cd_well_source" "u"
-        -- LEFT JOIN sys_user_role r ON u.id = r.user_id
-        -- left join sys_user_dept d on u.id = d.user_id
-        <where>
-            <if test="orgIds != null  and orgIds != ''">
-                and "u"."org_id" in
-                <foreach collection="orgIds" item="org_id" index="index" open="(" close=")" separator=",">
-                    #{org_id}
-                </foreach>
-            </if>
-        </where>
-    </select>
-    <select id="getAllWellSourceList" resultType="java.util.Map">
-        ${sql}
-    </select>
-
-    <select id="getjhAll" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select * from centralbase.cb_cd_well_source where (station_id
-         like '%红浅%' or station_id like '%六采%' or station_id like '%五采%' or station_id like '%特采%' )
-    </select>
-
-    <select id="getjhAllByorgid" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select * from centralbase.cb_cd_well_source where org_id =#{orgid}
-    </select>
-
-    <select id="getByWellId_Heavy" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select * from centralbase.cb_cd_well_source where well_id =#{wellName} and (station_id
-         like '%红浅%' or station_id like '%六采%' or station_id like '%五采%' or station_id like '%特采%' )
-    </select>
-
-
-    <select id="getjhAllYieldError" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select * from centralbase.cb_cd_well_source where (station_id
-         like '%一采%' or station_id like '%二采%' or station_id like '%三采%')
-    </select>
-
-
-    <select id="getjhAllConent" resultType="com.gct.centralbase.entity.CbCdWellSource">
-        select * from centralbase.cb_cd_well_source
-    </select>
-
-
-
-
 
 </mapper>
 

src/main/java/com/gct/tool/service/LoadBaseDataService.java

@@ -1,22 +1,34 @@
 package com.gct.tool.service;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.gct.tool.entity.centralbase.CbCdWellSource;
+import com.gct.tool.entity.centralbase.CbPcProWellboreVolDaily;
 import com.gct.tool.entity.sql.QueryBody;
 import com.gct.tool.feign.DataBankClient;
 import com.gct.tool.feign.DataBankTokenClient;
+import com.gct.tool.feign.WorkDiagramClient;
+import com.gct.tool.mapper.centralbase.CbCdWellSourceMapper;
+import com.gct.tool.mapper.centralbase.CbPcProWellboreVolDailyMapper;
 import lombok.extern.slf4j.Slf4j;
+import org.mockito.internal.util.StringUtil;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
 
-import java.sql.SQLOutput;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Service
 @Slf4j
 public class LoadBaseDataService {
 
-    final String identity = "CDF03A45C9BF4D9B85155364FAAEE08C14D85F6D51774A59GMXF6MBQG4ZDOKZXL4YF6KZSGEZGEKZWMBQTMKZVL43WCYJVG4XWCMLDGUXT22DKO43TAZ3CMYXXEL3AMFWWWN3ROFXGEZZSONYDAMBTGEYTKLRVGEZTONZXFYXTAMBSF4YDAMQ";
+    final String governDataServiceIdentity = "CDF03A45C9BF4D9B85155364FAAEE08C14D85F6D51774A59GMXF6MBQG4ZDOKZXL4YF6KZSGEZGEKZWMBQTMKZVL43WCYJVG4XWCMLDGUXT22DKO43TAZ3CMYXXEL3AMFWWWN3ROFXGEZZSONYDAMBTGEYTKLRVGEZTONZXFYXTAMBSF4YDAMQ";
+    final String sharedDataServiceIdentity = "77ACF8C095A94D3CA3474B9561FEA62D352F67FAE44AF04CMA2TGLZPMJPTGKZUF4XTIKZSGRRDGK27MIZGAKZOF5RDGNZTGBQS4YRWF4XT2NDFGZ2DCNLIFYYXEY3XMBVG4NRSNR4DGZTEMRWTAMBTGEZC4MBQGUXTONZXFYXTAMBSF4YDAMQ";
 
     @Autowired
     BaseResourceService baseResourceService;
@@ -26,12 +38,22 @@ public class LoadBaseDataService {
     @Autowired
     DataBankTokenClient tokenClient;
 
-    private void printMap(Object o,boolean isPrintNull,Set<String>filterSet){
-        ((Map)o).forEach((k,v)->{
-            if ((isPrintNull || Objects.nonNull(v))&&(Objects.isNull(filterSet)|| filterSet.contains(k)))
-                System.out.printf("%s:%s\n",k,v);
+    @Autowired
+    WorkDiagramClient workDiagramClient;
+
+    @Autowired
+    CbCdWellSourceMapper cbCdWellSourceMapper;
+
+    @Autowired
+    CbPcProWellboreVolDailyMapper cbPcProWellboreVolDailyMapper;
+
+    private void printMap(Object o, boolean isPrintNull, Set<String> filterSet) {
+        ((Map) o).forEach((k, v) -> {
+            if ((isPrintNull || Objects.nonNull(v)) && (Objects.isNull(filterSet) || filterSet.contains(k)))
+                System.out.printf("%s:%s\n", k, v);
         });
     }
+
     /**
      * @return
      */
@@ -43,24 +65,106 @@ public class LoadBaseDataService {
         wellIds.forEach(wellId -> {
             QueryBody queryBody = new QueryBody();
             queryBody.select("TL").eq("WELL_LEGAL_NAME", wellId);
-            JSONObject object = dataBankClient.getCdWellData(queryBody.toJsonMap(), 0, 10, identity);
+            JSONObject object = dataBankClient.getCdWellData(queryBody.toJsonMap(), 0, 10, governDataServiceIdentity);
             System.out.println(object);
             JSONArray array = object.getJSONObject("resultData").getJSONArray("content");
 //            ((Map) array.get(0)).forEach((k,v)-> System.out.printf(k+","));
             System.out.println("");
             array.forEach(o -> {
-                printMap(o,false,null);
+                printMap(o, false, null);
 //                System.out.printf("%s,%s\n",((Map) o).get("WELL_LEGAL_NAME"),((Map) o).get("WELL_ID"));
             });
         });
     }
 
-    public void loadVolDailyData(){
+    public void loadVolDailyData() {
+        List<CbCdWellSource> cbCdWellSources = cbCdWellSourceMapper.selectList(new QueryWrapper<>());
+        cbCdWellSources.forEach(cbCdWellSource -> {
+            QueryBody queryBody = new QueryBody();
+            String dateStr = LocalDateTime.now().minusDays(3).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+            queryBody.select("TL").eq("WELL_ID", cbCdWellSource.getWellId()).gt("PROD_DATE", dateStr);
+            JSONObject object = dataBankClient.getVolDailyData(queryBody.toJsonMap(), 0, 5, governDataServiceIdentity);
+            JSONArray array = object.getJSONObject("resultData").getJSONArray("content");
+            for (int i = 0; i < array.size(); i++) {
+                JSONObject volDailyJson = array.getJSONObject(i);
+                CbPcProWellboreVolDaily volDaily = volDailyJson.toJavaObject(CbPcProWellboreVolDaily.class);
+                volDaily.setWaterCut(volDailyJson.getDouble("WATER_CUT_RATIO"));
+                QueryWrapper<CbPcProWellboreVolDaily> wrapper = new QueryWrapper<CbPcProWellboreVolDaily>()
+                        .eq("well_id", volDaily.getWellId())
+                        .eq("prod_date", volDaily.getProdDate());
+                if (Objects.isNull(cbPcProWellboreVolDailyMapper.selectOne(wrapper))) {
+                    cbPcProWellboreVolDailyMapper.insert(volDaily);
+                } else {
+                    cbPcProWellboreVolDailyMapper.update(volDaily, wrapper);
+                }
+            }
 
+        });
     }
 
-    public void loadStatusDailyData(){
+    public void loadStatusDailyData() {
+        List<CbCdWellSource> cbCdWellSources = cbCdWellSourceMapper.selectList(new QueryWrapper<>());
+        cbCdWellSources = cbCdWellSources.subList(0, 1);
+        cbCdWellSources.forEach(cbCdWellSource -> {
+            QueryBody queryBody = new QueryBody();
+            String dateStr = LocalDateTime.now().minusDays(365).format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+            queryBody.select("TL").eq("WELL_ID", cbCdWellSource.getWellId());
+//            queryBody.select("TL");
+            JSONObject object = dataBankClient.getStatusDailyData(queryBody.toJsonMap(), 0, 500, sharedDataServiceIdentity);
+            JSONArray array = object.getJSONObject("resultData").getJSONArray("content");
+            HashSet<String> filterSet = new HashSet<>();
+            filterSet.add("OIL_NOZZLE");
+            filterSet.add("START_PUMP_DEPTH");
+            filterSet.add("START_PUMP_LIQ_LEVEL");
+            filterSet.add("END_PUMP_DEPTH");
+            filterSet.add("END_PUMP_LIQ_LEVEL");
+            array.forEach(o -> printMap(o, true, null));
+//            for (int i = 0; i < array.size(); i++) {
+//                JSONObject volDailyJson = array.getJSONObject(i);
+//                CbPcProWellboreVolDaily volDaily = volDailyJson.toJavaObject(CbPcProWellboreVolDaily.class);
+//                volDaily.setWaterCut(volDailyJson.getDouble("WATER_CUT_RATIO"));
+//                QueryWrapper<CbPcProWellboreVolDaily> wrapper = new QueryWrapper<CbPcProWellboreVolDaily>()
+//                        .eq("well_id", volDaily.getWellId())
+//                        .eq("prod_date", volDaily.getProdDate());
+//                if (Objects.isNull( cbPcProWellboreVolDailyMapper.selectOne(wrapper))){
+//                    cbPcProWellboreVolDailyMapper.insert(volDaily);
+//                } else {
+//                    cbPcProWellboreVolDailyMapper.update(volDaily,wrapper);
+//                }
+//            }
+        });
+    }
 
+    private JSONArray executeRemoteSql(String sqlString){
+        System.out.println(sqlString);
+        String res = workDiagramClient.getWorkDiagramData(sqlString);
+        res=res.replace("\\","");
+        res=res.substring(1,res.length()-1);
+        JSONObject selectMaxTimeJson = JSONObject.parseObject(res);
+        return selectMaxTimeJson.getJSONArray("dataList");
     }
 
+    public void loadWorkDiagramData(){
+        List<CbCdWellSource> cbCdWellSources = cbCdWellSourceMapper.selectList(new QueryWrapper<>());
+        cbCdWellSources = cbCdWellSources.subList(0, 1);
+        cbCdWellSources.forEach(cbCdWellSource -> {
+            String selectNearlyWorkDiagramSqlStr = String.format(
+                            "select * from PC_FD_PUMPJACK_DYNA_DIA_T@A11gxk where DYNA_CREATE_TIME =  " +
+                            "(select max(DYNA_CREATE_TIME) from PC_FD_PUMPJACK_DYNA_DIA_T@A11gxk where WELL_COMMON_NAME = '%s')" +
+                            "and WELL_COMMON_NAME = '%s'",
+                    cbCdWellSource.getWellLegalName(),cbCdWellSource.getWellLegalName());
+            JSONObject nearlyWorkDiagram = executeRemoteSql(selectNearlyWorkDiagramSqlStr).getJSONObject(0);
+            String displacement = nearlyWorkDiagram.getString("DISPLACEMENT");
+            String load = nearlyWorkDiagram.getString("DISP_LOAD");
+            List<Double[]> sgt = new ArrayList<>();
+            List<Double> dispacementList = Arrays.stream(displacement.split(";")).map(Double::parseDouble).collect(Collectors.toList());
+            List<Double> loadList = Arrays.stream(load.split(";")).map(Double::parseDouble).collect(Collectors.toList());
+            for (int i=0;i<Math.min(dispacementList.size(),loadList.size());i++){
+                sgt.add(new Double[]{dispacementList.get(i),loadList.get(i)});
+            }
+            Double stroke = Double.parseDouble(nearlyWorkDiagram.getString("STROKE"));
+            Double frequency = Double.parseDouble(nearlyWorkDiagram.getString("FREQUENCY"));
+
+        });
+    }
 }