山海数据大屏

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/datacenter/DataCenterRest.java

@@ -227,19 +227,22 @@ public class DataCenterRest {
                     list.add(nodde);
                 }
             }
-            if(list.stream().anyMatch(s->s.equals("在途"))){
-                projectDetailsVo.setCreditStage("在途");
-            }else if(list.stream().anyMatch(s->s.equals("在建"))){
-                projectDetailsVo.setCreditStage("在建");
-            }else {
-                projectDetailsVo.setCreditStage("竣工");
+            if(list.size()!=0){
+                if(list.stream().anyMatch(s->s.equals("在途"))){
+                    projectDetailsVo.setCreditStage("在途");
+                }else if(list.stream().anyMatch(s->s.equals("在建"))){
+                    projectDetailsVo.setCreditStage("在建");
+                }else if(list.stream().anyMatch(s->s.equals("竣工"))) {
+                    projectDetailsVo.setCreditStage("竣工");
+                }else if(list.stream().anyMatch(s->s.equals("结清"))){
+                    projectDetailsVo.setCreditStage("结清");
+                }
             }
         }
         return rb.success().setData(projectDetailsVos);
     }
 
 
-    //@Todo  山海光伏大屏数据接口
     @ApiOperation("获取仓库明细")
     @PostMapping("/getWarehouseAddressDetail/{shSid}")
     public ResultBean getWarehouseAddressDetail(@PathVariable("shSid") String shSid){
@@ -444,6 +447,7 @@ public class DataCenterRest {
         int dd=0;
         int zj=0;
         int jg=0;
+        int jq=0;
         for (ProjectInfo infoList : projectInfoList) {
             if(StringUtils.isNotBlank(infoList.getNodeValue())){
                 if (infoList.getNodeValue().equals("在途")){
@@ -455,6 +459,9 @@ public class DataCenterRest {
                 if (infoList.getNodeValue().equals("竣工")){
                     jg++;
                 }
+                if (infoList.getNodeValue().equals("结清")){
+                    jq++;
+                }
             }
 //            int a=crmMapper.getPhaseByProject(projectInfo.getSid(),infoList.getNodeValue());
         }
@@ -472,6 +479,9 @@ public class DataCenterRest {
                     if (shPhaseRecordVo.getNodeValue().equals("竣工")){
                         vo.setJg(vo.getDd()+1);
                     }
+                    if (shPhaseRecordVo.getNodeValue().equals("结清")){
+                        vo.setJq(vo.getDd()+1);
+                    }
                 }
             }
             if(c.size()!=0){
@@ -480,6 +490,7 @@ public class DataCenterRest {
                 warehouseInfoVoSheng1.setJg(vo.getJg());
                 warehouseInfoVoSheng1.setDd(vo.getDd());
                 warehouseInfoVoSheng1.setZj(vo.getZj());
+                warehouseInfoVoSheng1.setJq(vo.getJq());
                 warehouseInfoVoSheng1.setValue(warehouseInfoVoSheng1.getDd()+warehouseInfoVoSheng1.getJg()+warehouseInfoVoSheng1.getZj());
                 warehouseInfoVoSheng1s.add(warehouseInfoVoSheng1);
             }
@@ -487,6 +498,7 @@ public class DataCenterRest {
         map.put("dd",dd);
         map.put("zj",zj);
         map.put("jg",jg);
+        map.put("jq",jq);
         map.put("zs",projectInfoList.size());
         map.put("map",warehouseInfoVoSheng1s);
         return rb.success().setData(map);
@@ -514,18 +526,26 @@ public class DataCenterRest {
         ResultBean rb=new ResultBean();
         Map<String,Object> map=new HashMap<>();
         IndexVo vo=ShRequester.getscreen$enterprise$index(query);
+        IndexVo vo1=ShRequester.screen$screenIndex(query);
 //        map.put("enterprise_month",vo.getEnterprise_month());
 //        map.put("enterprise_year",vo.getEnterprise_year());
         map.put("enterprise_month",new BigDecimal(vo.getEnterprise_month()).setScale(0,RoundingMode.HALF_UP));
         map.put("enterprise_year",new BigDecimal(vo.getEnterprise_year()).setScale(0, RoundingMode.HALF_UP));
+        map.put("person_month",new BigDecimal(vo1.getPerson_month()).setScale(0,RoundingMode.HALF_UP));
+        map.put("person_year",new BigDecimal(vo1.getPerson_year()).setScale(0, RoundingMode.HALF_UP));
         List<String> name =new ArrayList<>();
         List<BigDecimal> enterprise_power =new ArrayList<>();
+        List<BigDecimal> person_power =new ArrayList<>();
         for (NearVo nearVo : vo.getNear_day()) {
             name.add(nearVo.getName());
             enterprise_power.add(nearVo.getEnterprise_power());
         }
+        for (NearVo nearVo : vo1.getNear_day()) {
+            person_power.add(nearVo.getPerson_power());
+        }
         map.put("name",name);
         map.put("enterprise_power",enterprise_power);
+        map.put("person_power",person_power);
         return rb.success().setData(map);
     }
     @ApiOperation("项目规格")
@@ -721,7 +741,20 @@ public class DataCenterRest {
         LoginVo vo=ShRequester.loginTZ();
         return rb.success().setData(vo);
     }
-
+    @ApiOperation("监控根据")
+    @GetMapping("/getMonitorToken")
+    public ResultBean token( ){
+        ResultBean rb=new ResultBean();
+        BaseResponse<String> vos=ShRequester.monitor$get_token();
+        return rb.success().setData(vos.getData());
+    }
+    @ApiOperation("监控根据")
+    @GetMapping("/getMonitorInfo")
+    public ResultBean getMonitorInfo(@RequestParam("orderSid") String orderSid){
+        ResultBean rb=new ResultBean();
+        BaseResponse<BaseResponseListObj<MonitorGetInfo>> vos=ShRequester.monitor$get_info(orderSid);
+        return rb.success().setData(vos.getData().getList());
+    }
     @ApiOperation("dingshi")
     @GetMapping("/rr")
     @Scheduled(cron = "1 0 0 * * ? ")

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/datacenter/GoodsDetailsVo.java

@@ -0,0 +1,14 @@
+package com.yxt.supervise.report.biz.datacenter;
+
+import lombok.Data;
+
+/**
+ * @author wangpengfei
+ * @date 2024/11/8 16:56
+ */
+@Data
+public class GoodsDetailsVo {
+    private String goodsDetail;
+    private String supplierName;
+    private String supplierType;
+}

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/datacenter/ProjectDetailsVo.java

@@ -33,6 +33,7 @@ public class ProjectDetailsVo {
     private String supplierName;
     private String supplierType;
     private String goodsDetail;
+    private List<GoodsDetailsVo> goodsDetails=new ArrayList<>();
     private String tbdate;//放款日期
     private BigDecimal money=new BigDecimal(0);//用信金额
     @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/datacenter/WarehouseInfoVoSheng.java

@@ -17,5 +17,6 @@ public class WarehouseInfoVoSheng {
     private Integer dd=0;
     private Integer zj=0;
     private Integer jg=0;
+    private Integer jq=0;
 
 }

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/datacenter/WarehouseInfoVoSheng1.java

@@ -17,5 +17,6 @@ public class WarehouseInfoVoSheng1 {
     private Integer dd=0;
     private Integer zj=0;
     private Integer jg=0;
+    private Integer jq=0;
 
 }

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/ds/crm/CrmMapper.java

@@ -103,7 +103,7 @@ public interface CrmMapper extends BaseMapper<ProjectInfo> {
             "where a.enterpriseSid=#{enterpriseSid} and a.projectSid!='d8bf7556-6db4-46b1-87eb-f3e9f93d330f' ")
     List<ProjectInfo> getProjectcs(@Param("enterpriseSid") String enterpriseSid);
     @Select("select a.* from project_phase_dictionary a " +
-            "where a.enterpriseSid=#{enterpriseSid}")
+            "where a.enterpriseSid=#{enterpriseSid} and nodeKey!='结清'")
     List<ProjectInfo> getNodeValue(@Param("enterpriseSid") String enterpriseSid);
 
     @Select("select count(sid) from enterprise_project where enterpriseSid=#{enterpriseSid}")

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/shanhai/ShRequester.java

@@ -19,6 +19,9 @@ public class ShRequester {
     private static String system$order$index = "/api/system/order/index"; //工商业数据大屏
     private static String system$index$login = "/api/system/index/login"; //工商业数据大屏
     private static String get_order_list = "/api/screen/enterprise/get_order_list"; //工商业数据大屏
+    private static String monitor$get_info = "/api/system/monitor/get_info"; //项目监控设备列表
+    private static String monitor$get_token = "/api/system/monitor/get_token"; //项目监控设备列表
+    private static String screen$screenIndex = "/api/screen/screen/index"; //户用
     /**
      * 1.工商业数据大屏
      *
@@ -36,6 +39,19 @@ public class ShRequester {
 
         return applyMaterial;
     }
+
+    public static IndexVo screen$screenIndex(IndexQuery reqParams) {
+        Map<String, Object> param = null;
+        A c =new A();
+        if (reqParams != null)
+            param = BeanUtil.beanToMap(reqParams);
+        BaseResponse<BaseResponseListObj<IndexVo>> resp = new BaseResponse<>();
+        String s = ShHttp.dopost(screen$screenIndex, param);
+        JSONObject jsonObject=new JSONObject(s);
+        IndexVo applyMaterial = JSONUtil.toBean(jsonObject, IndexVo.class);
+
+        return applyMaterial;
+    }
     public static BaseResponse<BaseResponseListObj<OrderIndexVo>> getsystem$order$index(IndexQuery reqParams) {
         BaseResponse<BaseResponseListObj<OrderIndexVo>> resp = new BaseResponse<>();
         BaseResponseListObj<OrderIndexVo> respObj = new BaseResponseListObj<>();
@@ -72,7 +88,35 @@ public class ShRequester {
         resp.setData(respObj);
         return resp;
     }
-
+    public static BaseResponse<String>  monitor$get_token() {
+        BaseResponse<BaseResponseListObj<OrderIndexVo>> resp = new BaseResponse<>();
+        BaseResponseListObj<OrderIndexVo> respObj = new BaseResponseListObj<>();
+        Map<String, Object> param = null;
+        String s = ShHttp.doGet(monitor$get_token, param);
+        JSONObject jsonObject=new JSONObject(s);
+        BaseResponse<String> baseResponse = JSONUtil.toBean(jsonObject, BaseResponse.class);
+//        BaseResponse<String> baseResponse = toBean(s, resp, respObj);
+        return  baseResponse;
+    }
+    public static BaseResponse<BaseResponseListObj<MonitorGetInfo>> monitor$get_info(String orderSid) {
+        BaseResponse<BaseResponseListObj<MonitorGetInfo>> resp = new BaseResponse<>();
+        BaseResponseListObj<MonitorGetInfo> respObj = new BaseResponseListObj<>();
+        Map<String, Object> param = new HashMap<>();
+        param.put("order_id",orderSid);
+        String s = ShHttp.doGet(monitor$get_info, param);
+        BaseResponse<BaseResponseListObj<JSONObject>> baseResponse = toBean(s, resp, respObj);
+        List<JSONObject> list = baseResponse.getData().getList();
+        List<MonitorGetInfo> outStocks = new ArrayList<>();
+        if(list!=null){
+            for (JSONObject jsonObject : list) {
+                MonitorGetInfo outStock = JSONUtil.toBean(jsonObject, MonitorGetInfo.class);
+                outStocks.add(outStock);
+            }
+        }
+        respObj.setList(outStocks);
+        resp.setData(respObj);
+        return resp;
+    }
     //        BaseResponse<BaseResponseListObj<OutStock>> resp = new BaseResponse<>();
     //        BaseResponseListObj<OutStock> respObj = new BaseResponseListObj<>();
     //        Map<String, Object> param = null;

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/shanhai/resp/IndexVo.java

@@ -6,13 +6,16 @@ import lombok.Data;
 import java.util.List;
 
 @Data
-@ApiModel(value = "待配货列表")
+@ApiModel(value = "电站发电量")
 public class IndexVo {
 
 
     private String enterprise_month; // 月
     private String enterprise_year; // 年,
     private String enterprise_day; //日
+    private String person_month; // 月
+    private String person_year; // 年,
+    private String person_day; //日
     private List<NearVo> near_day; // "",
 
 

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/shanhai/resp/MonitorGetInfo.java

@@ -0,0 +1,22 @@
+package com.yxt.supervise.report.shanhai.resp;
+
+import lombok.Data;
+
+/**
+ * @author wangpengfei
+ * @date 2024/11/15 14:00
+ */
+@Data
+public class MonitorGetInfo {
+    private String channelNo;
+    private String deviceSerial;
+    private String name;
+    private String ptz_45;
+    private String ptz_left_right;
+    private String ptz_top_bottom;
+    private String ptz_zoom;
+    private String signal;
+    private String status;
+    private String support_sensibility_adjust;
+    private String url;
+}

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/shanhai/resp/NearVo.java

@@ -12,4 +12,5 @@ import java.math.BigDecimal;
 public class NearVo {
     private String name;
     private BigDecimal enterprise_power=new BigDecimal(0);//
+    private BigDecimal person_power=new BigDecimal(0);//
 }