数据导入

web/gdsx-ghost/src/main/java/com/gyee/ghost/controller/ghost/GhostController.java

@@ -14,7 +14,7 @@ import com.gyee.ghost.model.auto.vo.FaultrecordCheckeVo;
 import com.gyee.ghost.model.auto.vo.FaultrecordVo;
 import com.gyee.ghost.service.auto.GhostService;
 import com.gyee.ghost.service.auto.IFaultrecordService;
-import com.gyee.ghost.service.auto.IWindturbineinfodayService;
+import com.gyee.ghost.service.auto.IWindpowerinfodayService;
 import com.gyee.ghost.util.realtimesource.ExcelUtils;
 import com.gyee.ghost.vo.InvolvedVo;
 import com.gyee.ghost.vo.NatureVo;
@@ -40,7 +40,7 @@ public class GhostController {
     @Resource
     private GhostService ghostService;
     @Resource
-    private IWindturbineinfodayService windturbineinfodayService;
+    private IWindpowerinfodayService windpowerinfodayService;
     @Resource
     private IFaultrecordService faultrecordService;
     @GetMapping("/wplist")
@@ -444,16 +444,16 @@ public class GhostController {
                         Date begin =vo.getBegindate();
 
 
-                        QueryWrapper<Windturbineinfoday> windturbineinfodayQueryWrapper = new QueryWrapper<>();
+                        QueryWrapper<Windpowerinfoday> windturbineinfodayQueryWrapper = new QueryWrapper<>();
                         windturbineinfodayQueryWrapper.eq("recorddate",begin);
-                        List<Windturbineinfoday> windturbineinfodayList = windturbineinfodayService.list(windturbineinfodayQueryWrapper);
+                        List<Windpowerinfoday> windturbineinfodayList = windpowerinfodayService.list(windturbineinfodayQueryWrapper);
 
-                        Map<String,Windturbineinfoday> wtdaymap=new HashMap<>();
+                        Map<String,Windpowerinfoday> wtdaymap=new HashMap<>();
                         if(!windturbineinfodayList.isEmpty())
                         {
-                            for ( Windturbineinfoday wtday:windturbineinfodayList)
+                            for ( Windpowerinfoday wtday:windturbineinfodayList)
                             {
-                                wtdaymap.put(wtday.getWindturbineid(),wtday);
+                                wtdaymap.put(wtday.getWindpowerstationid(),wtday);
                             }
                         }
 
@@ -465,13 +465,18 @@ public class GhostController {
 
                                 if(wtdaymap.containsKey(fr.getWtid()))
                                 {
-                                    Windturbineinfoday wtday=wtdaymap.get(fr.getWtid());
+                                    Windpowerinfoday wpday=wtdaymap.get(fr.getWtid());
 
-                                    double rfdl= wtday.getGeneratingcapacity();
-                                    double ssdl = new BigDecimal(rfdl).divide(new BigDecimal(24), 2, RoundingMode.HALF_EVEN).multiply(new BigDecimal(gzsc)).doubleValue();
-                                    fr.setPowerloss(StringUtils.round(ssdl,2));
+                                    if(CacheContext.wpwtlsmap.containsKey(wpday.getWindpowerstationid()))
+                                    {
+                                        List<Windturbine> wtls=CacheContext.wpwtlsmap.get(wpday.getWindpowerstationid());
+                                        double rfdl= wpday.getGeneratingcapacity();
+                                        double ssdl = new BigDecimal(rfdl).divide(new BigDecimal(wtls.size()), 2, RoundingMode.HALF_EVEN).divide(new BigDecimal(24), 2, RoundingMode.HALF_EVEN).multiply(new BigDecimal(gzsc)).doubleValue();
+                                        fr.setPowerloss(StringUtils.round(ssdl,2));
+
+                                        faultrecordService.saveOrUpdate(fr);
+                                    }
 
-                                    faultrecordService.saveOrUpdate(fr);
                                 }
                             }
                         }

web/gdsx-ghost/src/main/java/com/gyee/ghost/init/CacheContext.java

@@ -52,6 +52,8 @@ public class CacheContext implements CommandLineRunner {
     public static Map<String,Windturbine> wtnamemap = new HashMap<>();
     public static Map<String,Project> promap = new HashMap<>();
     public static Map<String,Windpowerstation> wpmap = new HashMap<>();
+
+    public static Map<String,List<Windturbine>> wpwtlsmap = new HashMap<>();
     public static List<Windpowerstation> wpls = new ArrayList<>();
     public static Map<String,String> stopmap = new HashMap<>();
 
@@ -72,6 +74,18 @@ public class CacheContext implements CommandLineRunner {
         wtls.stream().forEach(wt->{
 
             wtmap.put(wt.getId(),wt);
+
+            if(wpwtlsmap.containsKey(wt.getWindpowerstationid()))
+            {
+                List<Windturbine> ls=wpwtlsmap.get(wt.getWindpowerstationid());
+                ls.add(wt);
+
+            }else
+            {
+                List<Windturbine> ls=new ArrayList<>();
+                ls.add(wt);
+                wpwtlsmap.put(wt.getWindpowerstationid(),ls);
+            }
             wtnamemap.put(wt.getName(),wt);
             Double powerproduction = equipmentmodelList.stream().filter(e -> e.getId().equals(wt.getModelid())).findFirst().get().getPowerproduction();
             wtcap.put(wt.getId(),powerproduction);

web/gdsx-ghost/src/main/java/com/gyee/ghost/service/auto/GhostService.java

@@ -77,16 +77,16 @@ public class GhostService {
         resultList=faultrecordService.list(listQw);
 
 
-        QueryWrapper<Windturbineinfoday> windturbineinfodayQueryWrapper = new QueryWrapper<>();
+        QueryWrapper<Windpowerinfoday> windturbineinfodayQueryWrapper = new QueryWrapper<>();
         windturbineinfodayQueryWrapper.eq("recorddate",begin);
-        List<Windturbineinfoday> windturbineinfodayList = windturbineinfodayService.list(windturbineinfodayQueryWrapper);
+        List<Windpowerinfoday> windturbineinfodayList = windpowerinfodayService.list(windturbineinfodayQueryWrapper);
 
-        Map<String,Windturbineinfoday> wtdaymap=new HashMap<>();
+        Map<String,Windpowerinfoday> wtdaymap=new HashMap<>();
         if(!windturbineinfodayList.isEmpty())
         {
-            for ( Windturbineinfoday wtday:windturbineinfodayList)
+            for ( Windpowerinfoday wtday:windturbineinfodayList)
             {
-                wtdaymap.put(wtday.getWindturbineid(),wtday);
+                wtdaymap.put(wtday.getWindpowerstationid(),wtday);
             }
         }
 
@@ -98,13 +98,18 @@ public class GhostService {
 
                 if(wtdaymap.containsKey(fr.getWtid()))
                 {
-                    Windturbineinfoday wtday=wtdaymap.get(fr.getWtid());
+                    Windpowerinfoday wpday=wtdaymap.get(fr.getWtid());
 
-                   double rfdl= wtday.getGeneratingcapacity();
-                   double ssdl = new BigDecimal(rfdl).divide(new BigDecimal(24), 2, RoundingMode.HALF_EVEN).multiply(new BigDecimal(gzsc)).doubleValue();
-                   fr.setPowerloss(StringUtils.round(ssdl,2));
+                    if(CacheContext.wpwtlsmap.containsKey(wpday.getWindpowerstationid()))
+                    {
+                        List<Windturbine> wtls=CacheContext.wpwtlsmap.get(wpday.getWindpowerstationid());
+                        double rfdl= wpday.getGeneratingcapacity();
+                        double ssdl = new BigDecimal(rfdl).divide(new BigDecimal(wtls.size()), 2, RoundingMode.HALF_EVEN).divide(new BigDecimal(24), 2, RoundingMode.HALF_EVEN).multiply(new BigDecimal(gzsc)).doubleValue();
+                        fr.setPowerloss(StringUtils.round(ssdl,2));
+
+                        faultrecordService.saveOrUpdate(fr);
+                    }
 
-                    faultrecordService.saveOrUpdate(fr);
                 }
             }
         }