光伏矩阵、计划电量、性能等级评估等代码提交

web/runeconomy-xk/pom.xml

@@ -18,7 +18,11 @@
             <artifactId>easyexcel</artifactId>
             <version>3.2.0</version>
         </dependency>
-
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper</artifactId>
+            <version>5.1.4</version>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/ProBasicProjectPlanController.java

@@ -0,0 +1,147 @@
+package com.gyee.runeconomy.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.gyee.common.config.R;
+import com.gyee.common.model.StringUtils;
+import com.gyee.runeconomy.dto.ResultMsg;
+import com.gyee.runeconomy.model.auto.ProBasicProjectPlan;
+import com.gyee.runeconomy.service.auto.IProBasicProjectPlanService;
+import com.gyee.runeconomy.util.ExcelUtils;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.List;
+
+@RestController
+@RequestMapping("//pro-basic-project-plan")
+@Api(value = "工程期次计划电量配置" ,tags =  "工程期次计划电量配置")
+public class ProBasicProjectPlanController {
+    @Resource
+    private IProBasicProjectPlanService proBasicProjectPlanService;
+
+    /**
+     * 查询
+     * @param id
+     * @param projectId
+     * @param windpowerstationId
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @GetMapping(value = "/list")
+    @ApiOperation(value = "工程计划电量-列表", notes = "工程计划电量-列表")
+    public R findList(@RequestParam(value = "id", required = false) String id,
+                      @RequestParam(value = "projectId", required = false) String projectId,
+                      @RequestParam(value = "windpowerstationId", required = false) String windpowerstationId,
+                      @RequestParam(value = "year", required = false) String year,
+                      @RequestParam(value = "month", required = false) String month,
+                      @RequestParam(value = "modificationTime", required = false) String modificationTime,
+                      @RequestParam(value = "pageNum", required = true) String pageNum,
+                      @RequestParam(value = "pageSize", required = true) String pageSize) {
+        IPage<ProBasicProjectPlan> list = proBasicProjectPlanService.List(id, projectId, windpowerstationId, year, month,modificationTime,pageNum, pageSize);
+        if (null != list) {
+            return R.ok().data(list);
+        } else {
+            return R.error().data("查询失败！");
+        }
+    }
+
+    /**
+     * 新增
+     * @param proBasicProjectPlan
+     * @return
+     */
+    @PostMapping(value = "/add")
+    @ApiOperation(value = "工程计划电量-新增or修改", notes = "工程计划电量-新增or修改")
+    public R addAll(@RequestBody ProBasicProjectPlan proBasicProjectPlan){
+
+        boolean b = proBasicProjectPlanService.saveOrUpdate(proBasicProjectPlan);
+        if (b){
+            return R.ok().data(b);
+        }else {
+            return R.error().data("保存失败！");
+        }
+    }
+
+    /**
+     * 删除
+     * @param ids
+     * @return
+     */
+    @DeleteMapping(value = "/remove-ProjectPlan/{ids}")
+    @ApiOperation(value = "工程计划电量-删除", notes = "工程计划电量-删除")
+    public  R deleteAll(@PathVariable("ids") String ids) {
+        String[] strings = ids.split(",");
+
+        boolean  b = proBasicProjectPlanService.removeByIds(Arrays.asList(strings));
+
+        if (b) {
+            return R.ok().data(b);
+        } else {
+            return R.error().data("删除失败！");
+        }
+    }
+
+    /**
+     * 获得导入模版
+     * @param response
+     * @throws IOException
+     */
+//    @GetMapping("/get-import-template")
+//    @ApiOperation(value = "获得导入模板")
+//    public void importTemplate(HttpServletResponse response) throws IOException {
+//        // 手动创建导出 demo
+//        Date current = com.gyee.common.util.DateUtils.getCurrentDate();
+//        Calendar calendar = Calendar.getInstance();
+//        calendar.setTime(current);
+//        calendar.add(Calendar.DAY_OF_MONTH, -1);
+//        Date previousDay = calendar.getTime();
+//
+//        List<ProBasicProjectPlan> list = Arrays.asList(
+//                ProBasicProjectPlan.builder().id("").generatingCapacity(1.0).maintenancePowe("2.0").month("3").year("2023").outageHours(4.0).windpowerstationId("SXJ_KGDL_GJY_FDC_STA").projectId("SXJ_KGDL_GJYF03_EG").modificationTime(DateUtils.truncate(previousDay)).build()
+//
+//        );
+//
+//        // 输出
+//        ExcelUtils.write(response, "导入模板.xls", "导入模板", ProBasicProjectPlan.class, list);
+//    }
+
+    /**
+     * 导入
+     * @param file
+     * @return
+     * @throws Exception
+     */
+    @PostMapping("/import")
+    @ApiOperation(value = "导入",notes = "导入")
+    public com.gyee.runeconomy.dto.R importExcel(@RequestParam("file") MultipartFile file) throws Exception {
+        List<ProBasicProjectPlan> list = ExcelUtils.read(file, ProBasicProjectPlan.class);
+
+        if(StringUtils.notEmp(list) && !list.isEmpty())
+        {
+            for(ProBasicProjectPlan vo:list)
+            {
+                vo.setId(StringUtils.getUUID());
+//                vo.setOperationTime(new Date());
+
+//                List<ProBasicProjectPlan > ls=ProBasicProjectPlan.getByDateAndName(vo.getName(),vo.getRecordDate());
+//                if(ls.isEmpty())
+//                {
+                    proBasicProjectPlanService.save(vo);
+//                }
+
+            }
+        }
+        if (StringUtils.isNotNull(list)) {
+            return com.gyee.runeconomy.dto.R.data(ResultMsg.ok(list));
+        } else {
+            return com.gyee.runeconomy.dto.R.error(ResultMsg.error());
+        }
+    }
+
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/ProEconEquipmentInfoDayTopController.java

@@ -50,9 +50,10 @@ public class ProEconEquipmentInfoDayTopController {
             @RequestParam(value = "windpowerstationId", required = false) String windpowerstationId,
             @RequestParam(value = "types", required = true) Integer types,
             @RequestParam(value = "staType", required = true) String staType,
-            @RequestParam(value = "date", required = true) String date) {
+            @RequestParam(value = "pageNum", required = true) Integer pageNum,
+            @RequestParam(value = "pageSize", required = true) Integer pageSize){
 
-        List<ProEconEquipmentInfoDayTop> list = proEconEquipmentInfoDayTopService.getEquipmentInfoDayTopList(companyId, windpowerstationId, types, staType, date);
+        List<ProEconEquipmentInfoDayTop> list = proEconEquipmentInfoDayTopService.getEquipmentInfoDayTopList(companyId, windpowerstationId, types, staType,pageNum,pageSize);
         if (null != list) {
             return R.data(ResultMsg.ok(list));
         } else {

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/controller/monitor/PhotovoltaicmatrixController.java

@@ -0,0 +1,55 @@
+package com.gyee.runeconomy.controller.monitor;
+
+import com.gyee.runeconomy.dto.AjaxResult;
+import com.gyee.runeconomy.service.monitor.PhotovoltaicmatrixService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 光伏矩阵展示
+ */
+
+@Controller
+@RequestMapping("/Photovoltaic")
+@Api(value = "光伏矩阵", tags = "光伏矩阵")
+public class PhotovoltaicmatrixController {
+    @Autowired
+    private PhotovoltaicmatrixService photovoltaicmatrixService;
+
+    /**
+     *
+     * @param wpId
+     * @return
+     * @throws Exception
+     */
+    @GetMapping("/monitor")
+    @ResponseBody
+    @ApiOperation(value = "首页", notes = "首页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "wpId", value = "场站编号", required = true, dataType = "string", paramType = "query")})
+
+    public AjaxResult getinformation(String wpId) throws Exception {
+
+        Map<String, String> map = new HashMap<>();
+        if (!wpId.isEmpty()) {
+            map = photovoltaicmatrixService.getcockpit(wpId);
+        }
+        if (null != map) {
+            return AjaxResult.successData(200, map);
+        } else {
+            return AjaxResult.error(500, "操作失败");
+        }
+
+    }
+
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/EquipmentJzVo.java

@@ -0,0 +1,54 @@
+package com.gyee.runeconomy.dto;
+
+public class EquipmentJzVo {
+
+    private String name;
+
+    private String id;
+
+    private Double yggl;
+
+    private Double rfdl;
+
+    private Double yxzt;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Double getYggl() {
+        return yggl;
+    }
+
+    public void setYggl(Double yggl) {
+        this.yggl = yggl;
+    }
+
+    public Double getRfdl() {
+        return rfdl;
+    }
+
+    public void setRfdl(Double rfdl) {
+        this.rfdl = rfdl;
+    }
+
+    public Double getYxzt() {
+        return yxzt;
+    }
+
+    public void setYxzt(Double yxzt) {
+        this.yxzt = yxzt;
+    }
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/dto/EquipmentZcVo.java

@@ -0,0 +1,54 @@
+package com.gyee.runeconomy.dto;
+
+public class EquipmentZcVo {
+
+    private String name;
+
+    private String id;
+
+    private Double zfdl;
+
+    private Double rfdl;
+
+    private Double yxzt;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public Double getZfdl() {
+        return zfdl;
+    }
+
+    public void setZfdl(Double zfdl) {
+        this.zfdl = zfdl;
+    }
+
+    public Double getRfdl() {
+        return rfdl;
+    }
+
+    public void setRfdl(Double rfdl) {
+        this.rfdl = rfdl;
+    }
+
+    public Double getYxzt() {
+        return yxzt;
+    }
+
+    public void setYxzt(Double yxzt) {
+        this.yxzt = yxzt;
+    }
+}

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/model/auto/ProBasicProjectPlan.java

@@ -1,11 +1,12 @@
 package com.gyee.runeconomy.model.auto;
 
 
+import com.alibaba.excel.annotation.ExcelProperty;
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
-import lombok.Data;
-import lombok.EqualsAndHashCode;
+import lombok.*;
+import lombok.experimental.Accessors;
 
 /**
  * <p>
@@ -16,7 +17,11 @@ import lombok.EqualsAndHashCode;
  * @since 2022-10-21
  */
 @Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
 @EqualsAndHashCode(callSuper = true)
+@Accessors(chain = false) // 设置 chain = false，避免用户导入有问题
 public class ProBasicProjectPlan extends Model {
 
     private static final long serialVersionUID = 1L;
@@ -24,38 +29,58 @@ public class ProBasicProjectPlan extends Model {
     /**
      * 编号
      */
+    @ExcelProperty("编号")
     @TableId(value = "ID",type = IdType.ASSIGN_ID)
     private String id;
 
     /**
      * 工程编号
      */
+    @ExcelProperty("期次")
     private String projectId;
 
     /**
      * 计划发电量
      */
+    @ExcelProperty("计划发电量")
     private Double generatingCapacity;
 
     /**
      * 计划停运小时
      */
+    @ExcelProperty("计划停运小时")
     private Double outageHours;
 
     /**
      * 年
      */
+    @ExcelProperty("年份")
     private String year;
 
     /**
      * 月
      */
+    @ExcelProperty("月份")
     private String month;
 
     /**
      * 场站编号（冗余）
      */
+    @ExcelProperty("场站")
     private String windpowerstationId;
 
+//    /**
+//     * 检修电量
+//     */
+//    @ExcelProperty("检修电量")
+//    private String maintenancePowe;
+//
+//    /**
+//     * 修改时间
+//     */
+//    @ExcelProperty("修改时间")
+//    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+//    private Date modificationTime;
+
 
 }

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/IProBasicProjectPlanService.java

@@ -1,7 +1,8 @@
 package com.gyee.runeconomy.service.auto;
 
-import com.gyee.runeconomy.model.auto.ProBasicProjectPlan;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.gyee.runeconomy.model.auto.ProBasicProjectPlan;
 
 import java.util.List;
 
@@ -17,4 +18,6 @@ public interface IProBasicProjectPlanService extends IService<ProBasicProjectPla
     public List<ProBasicProjectPlan> getProjectPlanList(String year, String pageNum, String pageSize);
     List<ProBasicProjectPlan> getList(String year);
     List<ProBasicProjectPlan> getmonthList(String month);
+
+    IPage<ProBasicProjectPlan> List(String id, String projectId, String windpowerstationId, String  year, String month,String modificationTime, String pageNum, String pageSize);
 }

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/IProEconEquipmentInfoDayTopService.java

@@ -18,7 +18,7 @@ public interface IProEconEquipmentInfoDayTopService extends IService<ProEconEqui
 
 
     /** 管理列表*/
-    List<ProEconEquipmentInfoDayTop> getEquipmentInfoDayTopList(String companyId, String windpowerstationId, Integer types, String staType, String date);
+    List<ProEconEquipmentInfoDayTop> getEquipmentInfoDayTopList(String companyId, String windpowerstationId, Integer types, String staType,Integer pageNum,Integer pageSize);
 
 
     /** 历史数据 */

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/impl/ProBasicProjectPlanServiceImpl.java

@@ -3,15 +3,18 @@ package com.gyee.runeconomy.service.auto.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.common.model.StringUtils;
 import com.gyee.common.util.SortUtils;
-import com.gyee.runeconomy.model.auto.ProBasicProjectPlan;
 import com.gyee.runeconomy.mapper.auto.ProBasicProjectPlanMapper;
+import com.gyee.runeconomy.model.auto.ProBasicProjectPlan;
 import com.gyee.runeconomy.service.auto.IProBasicProjectPlanService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.Calendar;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -59,4 +62,40 @@ public class ProBasicProjectPlanServiceImpl extends ServiceImpl<ProBasicProjectP
         List<ProBasicProjectPlan> list = baseMapper.selectList(qw);
         return list;
     }
+
+    @Override
+    public IPage<ProBasicProjectPlan> List(String id, String projectId, String windpowerstationId, String  year, String month, String modificationTime, String pageNum, String pageSize) {
+        QueryWrapper<ProBasicProjectPlan> qw = new QueryWrapper<>();
+
+        if (StringUtils.isNotEmpty(id)){
+            qw.eq("id",id);
+        }
+
+        if (StringUtils.isNotEmpty(projectId)){
+            qw.like("project_id",projectId);
+        }
+
+        if (StringUtils.isNotEmpty(windpowerstationId)){
+            qw.like("windpowerstation_id",windpowerstationId);
+        }
+
+        if (StringUtils.isNotEmpty(year)){
+            qw.eq("year",year);
+        }
+
+        if (StringUtils.isNotEmpty(month)){
+            qw.eq("month",month);
+        }
+        if (StringUtils.isNotEmpty(modificationTime)){
+            try {
+                Date beginDate = new SimpleDateFormat("yyyy-MM-dd").parse(modificationTime);
+                qw.ge("modification_time", beginDate);
+            } catch (ParseException e) {
+                e.printStackTrace();
+            }
+        }
+        Page<ProBasicProjectPlan> page = new Page<>(Integer.parseInt(pageNum),Integer.parseInt(pageSize));
+        IPage<ProBasicProjectPlan> ProjectPlanPage = getBaseMapper().selectPage(page, qw);
+        return ProjectPlanPage;
+    }
 }

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/auto/impl/ProEconEquipmentInfoDayTopServiceImpl.java

@@ -1,26 +1,27 @@
 package com.gyee.runeconomy.service.auto.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.common.model.StringUtils;
 import com.gyee.common.util.DateUtils;
 import com.gyee.common.vo.healthmanager.CompareVo;
 import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.mapper.auto.ProEconEquipmentInfoDayTopMapper;
 import com.gyee.runeconomy.model.auto.ProBasicPowerstation;
 import com.gyee.runeconomy.model.auto.ProEconEquipmentInfoDayTop;
-import com.gyee.runeconomy.mapper.auto.ProEconEquipmentInfoDayTopMapper;
 import com.gyee.runeconomy.service.TokenService;
 import com.gyee.runeconomy.service.auto.IProEconEquipmentInfoDayTopService;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.time.LocalDate;
+import java.time.Year;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -37,14 +38,20 @@ public class ProEconEquipmentInfoDayTopServiceImpl extends ServiceImpl<ProEconEq
 
     @Resource
     private TokenService tokenService;
+    @Resource
+    private ProEconEquipmentInfoDayTopMapper proEconEquipmentInfoDayTopMapper;
     @Override
-    public List<ProEconEquipmentInfoDayTop> getEquipmentInfoDayTopList(String companyId, String windpowerstationId, Integer types, String staType, String date) {
+    public List<ProEconEquipmentInfoDayTop> getEquipmentInfoDayTopList(String companyId, String windpowerstationId, Integer types, String staType,Integer pageNum,Integer pageSize) {
 
         QueryWrapper<ProEconEquipmentInfoDayTop> qw = new QueryWrapper<>();
-
+        Page<ProEconEquipmentInfoDayTop> page = new Page<>(pageNum, pageSize);
+        LocalDate today = LocalDate.now();
+        Calendar calendar = Calendar.getInstance();
+        int currentMonth = calendar.get(Calendar.MONTH) + 1;
+        Year currentYear = Year.now();
 
         List<String> wpids = new ArrayList<>();
- 
+
         HttpServletRequest request = ((ServletRequestAttributes) (RequestContextHolder.currentRequestAttributes())).getRequest();
         List<ProBasicPowerstation> wplist = tokenService.getWpls(request);
         //场站模糊查询
@@ -67,15 +74,32 @@ public class ProEconEquipmentInfoDayTopServiceImpl extends ServiceImpl<ProEconEq
         if (wpids.size() > 0) {
             qw.lambda().in(ProEconEquipmentInfoDayTop::getWindpowerstationId, wpids);
         }
-        if (StringUtils.isNotEmpty(date)) {
-            qw.lambda().eq(ProEconEquipmentInfoDayTop::getRecordDate, DateUtils.parseDate(date));
+//        if (StringUtils.isNotEmpty(date)) {
+//            qw.lambda().eq(ProEconEquipmentInfoDayTop::getRecordDate, DateUtils.parseDate(date));
+//        }
+        if (null != types && types.equals(1)) {
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getRecordDate, today);
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getTypes, 1);
         }
-        if (null != types) {
-            qw.lambda().eq(ProEconEquipmentInfoDayTop::getTypes, types);
+        if (null != types && types.equals(2)) {
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getMonth, currentMonth);
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getYear, currentYear);
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getTypes, 2);
         }
+        if (null != types && types.equals(3)) {
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getYear, currentYear);
+            qw.lambda().eq(ProEconEquipmentInfoDayTop::getTypes, 3);
+        }
+
 
         qw.lambda().orderByAsc(ProEconEquipmentInfoDayTop::getWindturbineId);
-        List<ProEconEquipmentInfoDayTop> list = baseMapper.selectList(qw);
+
+//        Page<ProEconEquipmentInfoDayTop> resultPage = proEconEquipmentInfoDayTopMapper.selectPage(page, qw);
+//        List<ProEconEquipmentInfoDayTop> list = resultPage.getRecords();
+        IPage<ProEconEquipmentInfoDayTop> resultPage = getBaseMapper().selectPage(page, qw);
+        List<ProEconEquipmentInfoDayTop> list = resultPage.getRecords();
+
+//        List<ProEconEquipmentInfoDayTop> list = baseMapper.selectList(qw);
         list.stream().forEach(i->{
             i.setNemCode(CacheContext.wtmap.get(i.getWindturbineId()).getAname());
         });

web/runeconomy-xk/src/main/java/com/gyee/runeconomy/service/monitor/PhotovoltaicmatrixService.java

@@ -0,0 +1,108 @@
+package com.gyee.runeconomy.service.monitor;
+
+import com.gyee.common.contant.ContantXk;
+import com.gyee.runeconomy.dto.EquipmentJzVo;
+import com.gyee.runeconomy.dto.EquipmentZcVo;
+import com.gyee.runeconomy.init.CacheContext;
+import com.gyee.runeconomy.model.auto.*;
+import com.gyee.runeconomy.service.auto.impl.ProBasicEquipmentPointServiceImpl;
+import com.gyee.runeconomy.util.MathUtil;
+import com.gyee.runeconomy.util.realtimesource.IEdosUtil;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@Service
+public class PhotovoltaicmatrixService {
+    @Resource
+    private IEdosUtil edosUtil;
+
+    @Resource
+    private ProBasicEquipmentPointServiceImpl proBasicEquipmentPointService;
+
+    Map<String, Object> map = new HashMap<>();
+
+
+    public Map getcockpit(String wpId) throws Exception {
+
+        List<ProBasicPowerstation> wpls = CacheContext.wpls;
+        List<ProBasicEquipment> wtls = CacheContext.wtls;
+        List<ProBasicSquare> sqls = CacheContext.sqls;
+
+        Map<String, List> jzmap = new LinkedHashMap<>();
+        List<EquipmentJzVo> jzlist;
+
+        Map<String, List> zcmap = new LinkedHashMap<>();
+        List<EquipmentZcVo> zclist;
+
+        double zcrfdl = 0.0;
+        double jzrfdl = 0.0;
+        double jzmxzt = 0.0;
+        double zcmxzt = 0.0;
+        double yggl = 0.0;
+        double zfdl = 0.0;
+
+        for (ProBasicPowerstation wp : wpls) {
+            if (wp.getId().contains(wpId)) {
+                //查询场站下集中、组串方阵
+                List<ProBasicSquare> zcls = sqls.stream().filter(c -> c.getTypes().equals("ZC") && c.getWindpowerstationId().equals(wpId)).collect(Collectors.toList());
+                List<ProBasicSquare> jzls = sqls.stream().filter(c -> c.getTypes().equals("JZ") && c.getWindpowerstationId().equals(wpId)).collect(Collectors.toList());
+                List<ProBasicEquipment> sbls = wtls.stream().filter(w -> w.getWindpowerstationId().equals(wpId)).collect(Collectors.toList());
+
+                jzmap = new LinkedHashMap<>();
+                for (ProBasicSquare jz : jzls) {
+                    jzlist = new ArrayList<>();
+                    for (ProBasicEquipment wt : sbls) {
+                        if (wt.getSquareId().equals(jz.getId())) {
+                            EquipmentJzVo vo = new EquipmentJzVo();
+                            ProBasicEquipmentPoint rfdlvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.RFDL);
+                            jzrfdl = edosUtil.getRealData(rfdlvalue).getPointValueInDouble();
+                            ProBasicEquipmentPoint ygglvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.RPJGL);
+                            yggl = edosUtil.getRealData(ygglvalue).getPointValueInDouble();
+                            ProBasicEquipmentPoint mxztvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.MXZT);
+                            jzmxzt = edosUtil.getRealData(mxztvalue).getPointValueInDouble();
+
+                            vo.setName(wt.getName());
+                            vo.setId(wt.getId());
+                            vo.setRfdl(MathUtil.twoBit(jzrfdl));
+                            vo.setYggl(MathUtil.twoBit(yggl));
+                            vo.setYxzt(MathUtil.twoBit(jzmxzt));
+                            jzlist.add(vo);
+                        }
+                    }
+                    jzmap.put(jz.getId(), jzlist);
+                }
+                map.put("jz", jzmap);
+
+                zcmap = new LinkedHashMap<>();
+                for (ProBasicSquare zc : zcls) {
+                    zclist = new ArrayList<>();
+                    for (ProBasicEquipment wt : sbls) {
+                        if (wt.getSquareId().equals(zc.getId())) {
+                            EquipmentZcVo vo = new EquipmentZcVo();
+                            ProBasicEquipmentPoint zcrfdlvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.RFDL);
+                            zcrfdl = edosUtil.getRealData(zcrfdlvalue).getPointValueInDouble();
+                            ProBasicEquipmentPoint zfdlvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.RZFDL);
+                            zfdl = edosUtil.getRealData(zfdlvalue).getPointValueInDouble();
+                            ProBasicEquipmentPoint mxztvalue = proBasicEquipmentPointService.getEquipmentPoint(wt.getId(), ContantXk.MXZT);
+                            zcmxzt = edosUtil.getRealData(mxztvalue).getPointValueInDouble();
+
+                            vo.setName(wt.getName());
+                            vo.setId(wt.getId());
+                            vo.setRfdl(MathUtil.twoBit(zcrfdl));
+                            vo.setZfdl(MathUtil.twoBit(zfdl));
+                            vo.setYxzt(MathUtil.twoBit(zcmxzt));
+                            zclist.add(vo);
+                        }
+                    }
+                    zcmap.put(zc.getId(), zclist);
+                }
+                map.put("zc", zcmap);
+            }
+        }
+
+        return map;
+    }
+}