nocommit

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

@@ -14,14 +14,17 @@ import pps.core.common.cache.ThirdPartyConfigCache;
 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.QueryWellheadDailyProductionSituationInput;
 import pps.core.prediction.service.data.wellhead_daily_production_situation.QueryWellheadDailyProductionSituationOutput;
+import pps.core.prediction.utils.ServiceUtil;
 import xstartup.annotation.XService;
 import xstartup.annotation.XText;
 import xstartup.base.XContext;
 import xstartup.base.XStartup;
 import xstartup.base.util.XCopyUtils;
 import xstartup.base.util.XHttpUtils;
+import xstartup.data.XListResult;
 import xstartup.data.XPageResult;
 import xstartup.data.XServiceResult;
 import xstartup.feature.api.annotation.XApiAnonymous;
@@ -33,8 +36,7 @@ import java.util.List;
 import java.util.Map;
 
 /**
- * 井口生产情况模块(测试用)
- * todo: 模拟测试用,后续替换
+ * 井口生产情况模块
  *
  * @author ZWT
  * @date 2023/09/27
@@ -43,7 +45,6 @@ import java.util.Map;
 @XService
 public class WellheadDailyProductionSituationService {
 
-
     /**
      * 井口生产情况--分页列表
      *
@@ -73,6 +74,31 @@ public class WellheadDailyProductionSituationService {
         return XPageResult.success(outputs, input, pageInfo.getTotal());
     }
 
+    /**
+     * 井口生产情况-甘特图
+     *
+     * @param context 上下文
+     * @param input   输入
+     * @return {@link XListResult}<{@link QueryWellheadDailyProductionSituationOutput}>
+     */
+    @XText("井口生产情况--甘特图")
+    @XApiAnonymous
+    @XApiPost
+    public XListResult<QueryWellheadDailyProductionSituationOutput> queryRptSystemStartStop(XContext context, GetWellheadDailyProductionSituationInput input) {
+        String token = ServiceUtil.getToken(context);
+        HttpRequestClient client = new HttpRequestClient(token);
+        Map<String, Object> param = new HashMap<>(4);
+        param.put("Org_Name", input.getStationName());
+        param.put("WELL_NAME", input.getWellNumber());
+        String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
+        url += ThirdPartyApiConstant.CQ_RPT_SYSTEM_START_STOP;
+        String resultStr = client.doPostForm(url, param);
+
+
+        return XListResult.success();
+    }
+
+
     @XApiAnonymous
     @XText("井口生产情况--test")
     @XApiGet

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/data/wellhead_daily_production_situation/GetWellheadDailyProductionSituationInput.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 2023/09/27
+ */
+@Data
+public class GetWellheadDailyProductionSituationInput {
+
+    @XText("电站名称")
+    @NotBlank(message = "缺少电站名称")
+    private String stationName;
+
+    @XText("井号")
+    @NotBlank(message = "缺少井号")
+    private String wellNumber;
+}
\ No newline at end of file