增加电计量配置、增加xktj树

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/config/CacheContext.java

@@ -1,106 +1,123 @@
-//package com.gyee.backconfig.config;
-//
-//
-//
-//import com.gyee.common.model.auto.Windturbine;
-//import com.gyee.common.service.IWindturbineService;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.boot.CommandLineRunner;
-//import org.springframework.stereotype.Component;
-//
-//import javax.annotation.Resource;
-//import java.util.ArrayList;
-//import java.util.HashMap;
-//import java.util.List;
-//import java.util.Map;
-//
-//
-///**
-// * @ClassName : CacheContext
-// * @Author : wang
-// * @Date: 2022/9/26 9:35
-// * @Description : 缓存
-// */
-//@Component
-//public class CacheContext implements CommandLineRunner {
-//
-//
-//
-//
-//
-//    @Autowired
-//    private IRegionService regionService;//区域
-//
-//    @Resource
-//    private ICompanysService companysService;//公司
-//
-//    @Resource
-//    private IProjectService projectService;//期次
-//
-//    @Resource
-//    private ILineService lineService;//线路
-//
-//    @Resource
-//    private IWindpowerstationService windpowerstationService;//场站
-//
-//    @Autowired
-//    private IWindturbineService windturbineService;//风机
-//
-//
-//    public static   Map<String, Region> regionmap = new HashMap<>();
-//    public static List<Region> regions = new ArrayList<>();
-//
-//
-//    public static   Map<String, Line> linemap = new HashMap<>();
-//    public static List<Line> lines = new ArrayList<>();
-//
-//
-//    public static   Map<String, Windturbine> windturbinemap = new HashMap<>();
-//    public static List<Windturbine> windturbines = new ArrayList<>();
-//
-//    public static Map<String, Project> promap = new HashMap<>();
-//    public static List<Project> prols = new ArrayList<>();
-//    public static Map<String,Windpowerstation> wpmap = new HashMap<>();
-//    public static List<Windpowerstation> wpls = new ArrayList<>();
-//    public static Map<String, Companys> cpmap = new HashMap<>();
-//    public static List<Companys> cpls = new ArrayList<>();
-//
-//
-//    @Override
-//    public void run(String... args) throws Exception {
-//
-//        cpls = companysService.list();
-//        cpls.stream().forEach(Companys -> {
-//            cpmap.put(Companys.getId(),Companys);
-//        });
-//
-//        wpls = windpowerstationService.list();
-//        wpls.stream().forEach(windpowerstation -> {
-//            wpmap.put(windpowerstation.getId(),windpowerstation);
-//        });
-//
-//        prols = projectService.list();
-//        prols.stream().forEach(Project -> {
-//            promap.put(Project.getWindpowerstationid(),Project);
-//        });
-//
-//
-//        //区域
-//        regions = regionService.list();
-//        regions.stream().forEach(region -> {
-//            regionmap.put(region.getId(), region);
-//        });
-//
-//        //线路
-//        lines = lineService.list();
-//        lines.stream().forEach(line -> {
-//            linemap.put(line.getId(), line);
-//        });
-//
-//        //风机
-//        windturbines =  windturbineService.list();
-//        windturbines.stream().forEach(windturbine -> {
-//            windturbinemap.put(windturbine.getId(), windturbine);
-//        });
-//    }
-//}
+package com.gyee.backconfig.config;
+
+
+import com.gyee.backconfig.model.auto.*;
+import com.gyee.backconfig.service.auto.*;
+import com.gyee.common.model.auto.Windturbine;
+import com.gyee.common.service.IWindturbineService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * @ClassName : CacheContext
+ * @Author : wang
+ * @Date: 2022/9/26 9:35
+ * @Description : 缓存
+ */
+@Component
+public class CacheContext implements CommandLineRunner {
+
+    @Resource
+    private IProBasicEnergyGroupService proBasicEnergyGroupService;//集团
+
+    @Autowired
+    private IProBasicRegionService proBasicRegionService;//区域
+
+    @Resource
+    private IProBasicCompanyService proBasicCompanyService;//公司
+
+    @Resource
+    private IProBasicWindpowerstationService proBasicWindpowerstationService;//场站
+
+    @Resource
+    private IProBasicProjectService proBasicProjectService;//期次
+
+    @Resource
+    private IProBasicLineService proBasicLineService;//线路
+
+    @Autowired
+    private IProBasicWindturbineService proBasicWindturbineService;//风机
+
+    //集团
+    public static Map<String, ProBasicEnergyGroup> energymap = new HashMap<>();
+    public static List<ProBasicEnergyGroup> energy = new ArrayList<>();
+
+    //区域
+    public static Map<String, ProBasicRegion> regionmap = new HashMap<>();
+    public static List<ProBasicRegion> regions = new ArrayList<>();
+
+    //公司
+    public static Map<String, ProBasicCompany> cpmap = new HashMap<>();
+    public static List<ProBasicCompany> cpls = new ArrayList<>();
+
+    //场站
+    public static Map<String, ProBasicWindpowerstation> wpmap = new HashMap<>();
+    public static List<ProBasicWindpowerstation> wpls = new ArrayList<>();
+
+    //期次
+    public static Map<String, ProBasicProject> promap = new HashMap<>();
+    public static List<ProBasicProject> prols = new ArrayList<>();
+
+    //线路
+    public static Map<String, ProBasicLine> linemap = new HashMap<>();
+    public static List<ProBasicLine> lines = new ArrayList<>();
+
+    //风机
+    public static Map<String, ProBasicWindturbine> windturbinemap = new HashMap<>();
+    public static List<ProBasicWindturbine> windturbines = new ArrayList<>();
+
+
+    @Override
+    public void run(String... args) throws Exception {
+
+        //集团
+        energy = proBasicEnergyGroupService.list();
+        energy.stream().forEach(energy -> {
+            energymap.put(energy.getId(), energy);
+        });
+
+        //区域
+        regions = proBasicRegionService.list();
+        regions.stream().forEach(region -> {
+            regionmap.put(region.getGroupId(), region);
+        });
+
+        //公司
+        cpls = proBasicCompanyService.list();
+        cpls.stream().forEach(Companys -> {
+            cpmap.put(Companys.getRegionId(), Companys);
+        });
+
+        //场站
+        wpls = proBasicWindpowerstationService.list();
+        wpls.stream().forEach(windpowerstation -> {
+            wpmap.put(windpowerstation.getCompanyId(), windpowerstation);
+        });
+
+        //期次
+        prols = proBasicProjectService.list();
+        prols.stream().forEach(Project -> {
+            promap.put(Project.getWindpowerstationId(), Project);
+        });
+
+        //线路
+        lines = proBasicLineService.list();
+        lines.stream().forEach(line -> {
+            linemap.put(line.getId(), line);
+        });
+
+        //风机
+        windturbines = proBasicWindturbineService.list();
+        windturbines.stream().forEach(windturbine -> {
+            windturbinemap.put(windturbine.getId(), windturbine);
+        });
+    }
+}

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/controller/SttreeControllel.java

@@ -0,0 +1,39 @@
+package com.gyee.backconfig.controller;
+
+import com.gyee.backconfig.config.R;
+import com.gyee.backconfig.model.auto.ProBasicCompany;
+import com.gyee.backconfig.model.auto.ProBasicEnergyGroup;
+import com.gyee.backconfig.service.auto.SttreeService;
+import com.gyee.common.model.StringUtils;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * 树
+ */
+@RestController
+@RequestMapping("//sttree")
+public class SttreeControllel {
+    @Resource
+    private SttreeService sttreeService;
+
+
+    /**
+     * 层级树
+     *
+     * @return
+     */
+    @GetMapping(value = "/treels")
+    @ResponseBody
+    @CrossOrigin(origins = "*", maxAge = 3600)
+    public R wtls() {
+        List<ProBasicEnergyGroup> resultList = sttreeService.energytree();
+        if (StringUtils.isNotNull(resultList)) {
+            return com.gyee.backconfig.config.R.ok((int) resultList.size()).data(resultList);
+        } else {
+            return R.error().message("访问失败");
+        }
+    }
+}

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/model/auto/ProBasicCompany.java

@@ -1,8 +1,11 @@
 package com.gyee.backconfig.model.auto;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
 import lombok.Data;
@@ -145,5 +148,6 @@ public class ProBasicCompany extends Model {
 
     private Integer isAble;
 
-
+    @TableField(exist = false)
+    private List<ProBasicWindpowerstation> Children = new ArrayList<>();
 }

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/model/auto/ProBasicEnergyGroup.java

@@ -1,8 +1,11 @@
 package com.gyee.backconfig.model.auto;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
 import lombok.Data;
@@ -134,4 +137,7 @@ public class ProBasicEnergyGroup extends Model {
     private Integer jrNumber;
 
 //    private Integer isAble;
+
+    @TableField(exist = false)
+    private List<ProBasicRegion> Children = new ArrayList<>();
 }

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/model/auto/ProBasicProject.java

@@ -3,9 +3,13 @@ package com.gyee.backconfig.model.auto;
 import java.math.BigDecimal;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
 import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
@@ -99,5 +103,6 @@ public class ProBasicProject extends Model {
      */
     private String windsubStationId;
     private Integer isAble;
-
+    @TableField(exist = false)
+    private List<ProBasicLine> Children = new ArrayList<>();
 }

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/model/auto/ProBasicRegion.java

@@ -1,8 +1,11 @@
 package com.gyee.backconfig.model.auto;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
 import lombok.Data;
@@ -139,4 +142,7 @@ public class ProBasicRegion extends Model {
     private String groupId;
     private Integer isAble;
 
+    @TableField(exist = false)
+    private List<ProBasicCompany> Children = new ArrayList<>();
+
 }

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/model/auto/ProBasicWindpowerstation.java

@@ -1,8 +1,11 @@
 package com.gyee.backconfig.model.auto;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.extension.activerecord.Model;
 import lombok.Data;
@@ -134,4 +137,8 @@ public class ProBasicWindpowerstation extends Model {
     private String groupId;
 
     private Integer isAble;
+
+
+    @TableField(exist = false)
+    private List<ProBasicProject> Children = new ArrayList<>();
 }

web/backmanagerconfig-xktj/src/main/java/com/gyee/backconfig/service/auto/SttreeService.java

@@ -0,0 +1,77 @@
+package com.gyee.backconfig.service.auto;
+
+import com.gyee.backconfig.config.CacheContext;
+import com.gyee.backconfig.model.auto.*;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Scanner;
+import java.util.stream.Collectors;
+
+@Service
+public class SttreeService {
+    public List<ProBasicEnergyGroup>  energytree() {
+        List<ProBasicEnergyGroup> energyls = CacheContext.energy;//集团
+        List<ProBasicRegion> regionsls = CacheContext.regions;//区域
+        List<ProBasicCompany> cpls = CacheContext.cpls;//公司
+        List<ProBasicWindpowerstation> wpls = CacheContext.wpls;//场站
+        List<ProBasicProject> prols = CacheContext.prols;//期次
+        List<ProBasicLine> list = CacheContext.lines;//期次
+
+        if (energyls.get(0).getChildren().size() > 0) return energyls;
+
+        //集团-区域
+        energyls.forEach(regls -> {
+            List<ProBasicRegion> collect = regionsls.stream().filter(r -> r.getGroupId().equals(regls.getId())).collect(Collectors.toList());
+            regls.getChildren().addAll(collect);
+        });
+
+        //区域-公司
+        regionsls.forEach(cp -> {
+            List<ProBasicCompany> region = cpls.stream().filter(c -> null != c.getRegionId() && c.getRegionId().equals(cp.getId())).collect(Collectors.toList());
+            cp.getChildren().addAll(region);
+        });
+
+        //公司-场站
+        cpls.forEach(wp -> {
+            List<ProBasicWindpowerstation> co = wpls.stream().filter(w -> null != w.getCompanyId() && w.getCompanyId().equals(wp.getId())).collect(Collectors.toList());
+            wp.getChildren().addAll(co);
+        });
+
+        //场站-期次
+        wpls.forEach(pl -> {
+            List<ProBasicProject> cz = prols.stream().filter(p -> null != p.getWindpowerstationId() && p.getWindpowerstationId().equals(pl.getId())).collect(Collectors.toList());
+            pl.getChildren().addAll(cz);
+        });
+
+        //期次-线路
+        prols.forEach(ll -> {
+            List<ProBasicLine> lis = list.stream().filter(l -> null != l.getProjectId() && l.getProjectId().equals(ll.getId())).collect(Collectors.toList());
+            ll.getChildren().addAll(lis);
+        });
+
+//        List<List> xh = new ArrayList();
+//        xh.add(energyls);
+//        xh.add(regionsls);
+//        xh.add(cpls);
+//        xh.add(wpls);
+//        xh.add(prols);
+//
+//        Scanner sc = new Scanner(System.in);
+//        int ls = sc.nextInt();
+//
+//        switch (ls) {
+//            case 1:
+//                xh.get(0);
+//                break;
+//            case 2:
+//                xh.get(1);
+//                break;
+//            case 3:
+//                xh.get(2);
+//                break;
+//        }
+        return energyls;
+    }
+}

web/backmanagerconfig/src/main/java/com/gyee/backconfig/controller/MeterpointController.java

@@ -1,18 +1,17 @@
 package com.gyee.backconfig.controller;
 
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.gyee.backconfig.config.R;
 import com.gyee.backconfig.model.auto.Meterpoint;
 import com.gyee.backconfig.model.auto.Square;
 import com.gyee.backconfig.service.auto.IMeterpointService;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import com.gyee.common.model.StringUtils;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import java.util.Arrays;
 
 /**
  * <p>电计量点表
@@ -52,6 +51,56 @@ public class MeterpointController {
             return R.error().data("查询失败！");
         }
     }
+    /**
+     * 根据id查询
+     *
+     * @param id
+     * @return
+     */
+    @GetMapping(value = "/meterpoint/{id}")
+    public R findOne(@PathVariable("id") String id) {
+        QueryWrapper<Meterpoint> qw = new QueryWrapper<>();
+        qw.eq("id", id);
+        Meterpoint Square = meterpointService.getOne(qw);
+        if (StringUtils.isNotNull(Square)) {
+            return R.ok().data(Square);
+        } else {
+            return R.error().data("查询失败！");
+        }
+    }
+
+    /**
+     * 批量插入
+     *
+     * @param meterpoint
+     * @return
+     */
+    @PostMapping(value = "/save")
+    public R addAll(@RequestBody Meterpoint meterpoint) {
+        boolean b = meterpointService.saveOrUpdate(meterpoint);
+        if (b) {
+            return R.ok().data(b);
+        } else {
+            return R.error().data("保存失败！");
+        }
+    }
+
+    /**
+     * 批量删除
+     *
+     * @param ids
+     * @return
+     */
+    @DeleteMapping(value = "/remove-Squares/{ids}")
+    public R deleteAll(@PathVariable("ids") String ids) {
+        String[] strings = ids.split(",");
+        boolean b = meterpointService.removeByIds(Arrays.asList(strings));
+        if (b) {
+            return R.ok().data(b);
+        } else {
+            return R.error().data("删除失败！");
+        }
+    }
 
 
 }