nocommit

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/WellheadDailyProductionSituationService.java

@@ -12,10 +12,7 @@ import pps.core.auth.HttpRequestClient;
 import pps.core.prediction.constant.ThirdPartyApiConstant;
 import pps.core.prediction.entity.WellheadDailyProductionSituationEnt;
 import pps.core.prediction.mapper.WellheadDailyProductionSituationMapper;
-import pps.core.prediction.service.data.wellhead_daily_production_situation.GetWellheadDailyProductionSituationInput;
-import pps.core.prediction.service.data.wellhead_daily_production_situation.GetWellheadDailyProductionSituationOutput;
-import pps.core.prediction.service.data.wellhead_daily_production_situation.QueryWellheadDailyProductionSituationInput;
-import pps.core.prediction.service.data.wellhead_daily_production_situation.QueryWellheadDailyProductionSituationOutput;
+import pps.core.prediction.service.data.wellhead_daily_production_situation.*;
 import pps.core.prediction.utils.ServiceUtil;
 import xstartup.annotation.XService;
 import xstartup.annotation.XText;
@@ -51,8 +48,8 @@ public class WellheadDailyProductionSituationService {
      * @param input   输入
      * @return {@link XPageResult}<{@link QueryWellheadDailyProductionSituationOutput}>
      */
-    @XText("井口生产情况--分页列表")
     @XApiAnonymous
+    @XText("井口生产情况--分页列表")
     @XApiPost
     public XPageResult<QueryWellheadDailyProductionSituationOutput> queryWellheadDailyProductionSituationView(XContext context, QueryWellheadDailyProductionSituationInput input) {
         WellheadDailyProductionSituationMapper mapper = context.getBean(WellheadDailyProductionSituationMapper.class);
@@ -74,14 +71,17 @@ public class WellheadDailyProductionSituationService {
     }
 
     /**
-     * 井口生产情况-甘特图
+     * 甘特图
+     * POST /prediction/wellhead-daily-production-situation/query-rpt-system-start-stop
+     * 接口ID：156546795
+     * 接口地址：https://app.apifox.com/project/3196988/apis/api-156546795
      *
      * @param context 上下文
      * @param input   输入
      * @return {@link XListResult}<{@link GetWellheadDailyProductionSituationOutput}>
      */
-    @XText("井口生产情况--甘特图")
     @XApiAnonymous
+    @XText("井口生产情况--甘特图")
     @XApiPost
     public XListResult<GetWellheadDailyProductionSituationOutput> queryRptSystemStartStop(XContext context, GetWellheadDailyProductionSituationInput input) {
         String token = ServiceUtil.getToken(context);
@@ -101,6 +101,24 @@ public class WellheadDailyProductionSituationService {
         return XListResult.success(outputs);
     }
 
+    @XApiAnonymous
+    @XText("井口生产情况--油井状态")
+    @XApiPost
+    public XListResult<GetWellRealPvOutput> queryWellRealPvData(XContext context, GetWellRealPvInput input) {
+        String token = ServiceUtil.getToken(context);
+        HttpRequestClient client = new HttpRequestClient(token);
+        String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
+        url += ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA;
+        String resultStr = client.doPostForm(url, new HashMap<>(0));
+        JSONObject jsonObject = JSON.parseObject(resultStr);
+        String data = jsonObject.getString("data");
+        List<GetWellRealPvOutput> outputs = JSON.parseArray(data, GetWellRealPvOutput.class);
+        if (CollUtil.isEmpty(outputs)) {
+            outputs = new ArrayList<>(0);
+        }
+        return XListResult.success(outputs);
+    }
+
 
     @XApiAnonymous
     @XText("井口生产情况--test")

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/data/wellhead_daily_production_situation/GetWellRealPvInput.java

+package pps.core.prediction.service.data.wellhead_daily_production_situation;
+
+import jakarta.validation.constraints.NotBlank;
+import lombok.Data;
+import xstartup.annotation.XText;
+
+/**
+ * 油井状态
+ *
+ * @author ZWT
+ * @date 2024/03/18 17:24
+ */
+@Data
+public class GetWellRealPvInput {
+
+    @XText("线路ID")
+    @NotBlank(message = "缺少线路ID")
+    private String lineId;
+}

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/data/wellhead_daily_production_situation/GetWellRealPvOutput.java

+package pps.core.prediction.service.data.wellhead_daily_production_situation;
+
+import jakarta.validation.constraints.NotBlank;
+import lombok.Data;
+import xstartup.annotation.XText;
+
+/**
+ * 油井状态
+ *
+ * @author ZWT
+ * @date 2024/03/18 17:24
+ */
+@Data
+public class GetWellRealPvOutput {
+
+    @XText("线路ID")
+    @NotBlank(message = "缺少线路ID")
+    private String lineId;
+}