首页数据接入

src/main/java/com/gyee/frame/common/quartz/task/Index_target_comprehensive_indicators.java

@@ -0,0 +1,51 @@
+package com.gyee.frame.common.quartz.task;
+
+import com.gyee.frame.mapper.auto.TsysUserMapper;
+import com.gyee.frame.model.auto.Weatherfd;
+import com.gyee.frame.service.app.index.IndexService;
+import com.gyee.frame.service.WeatherfdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.util.Date;
+import java.util.List;
+
+/**
+ *测试类
+ * @CLASSNAME   WeatherfdPushTask
+ * @Description 向页面预测今天气象推送数据
+ * @Auther Wang Jiawen
+ * @DATE 2020/1/2 15:33
+ */
+@Component("index_target_comprehensive_indicators")
+public class Index_target_comprehensive_indicators {
+	@Autowired
+	private TsysUserMapper tsysUserMapper;
+	@Autowired
+    private IndexService indexService;
+    /**
+     * 无参的任务
+     * @throws Exception 
+     */
+    public void index_target_comprehensive_indicators() throws Exception {
+    	indexService.index_target_comprehensive_indicators();//调用list方法完成对 key ："weatherProphet_1" ，路径"weather/weatherProphet_1"的推送     
+        //System.out.println("我已执行");
+    }   
+       
+
+    /**
+     * 有参任务
+     * 目前仅执行常见的数据类型  Integer Long  带L  string  带 ''  bool Double 带 d
+     * @param a
+     * @param b
+     * 
+     */
+    public void runTask2(Integer a,Long b,String c,Boolean d,Double e)
+    {
+    	//List<TsysUser> list=  tsysUserMapper.selectByExample(new TsysUserExample());
+    	//System.err.println("用户查询num："+list.size());
+        System.out.println("正在执行定时任务，带多个参数的方法"+a+"   "+b+" "+c+"  "+d+" "+e+"执行时间:"+new Date().toLocaleString());
+    }
+
+}

src/main/java/com/gyee/frame/common/quartz/task/index_target_windSpeed_power.java

@@ -0,0 +1,51 @@
+package com.gyee.frame.common.quartz.task;
+
+import com.gyee.frame.mapper.auto.TsysUserMapper;
+import com.gyee.frame.model.auto.Weatherfd;
+import com.gyee.frame.service.app.index.IndexService;
+import com.gyee.frame.service.WeatherfdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.util.Date;
+import java.util.List;
+
+/**
+ *测试类
+ * @CLASSNAME   WeatherfdPushTask
+ * @Description 向页面预测今天气象推送数据
+ * @Auther Wang Jiawen
+ * @DATE 2020/1/2 15:33
+ */
+@Component("index_target_windSpeed_power")
+public class index_target_windSpeed_power {
+	@Autowired
+	private TsysUserMapper tsysUserMapper;
+	@Autowired
+    private IndexService indexService;
+    /**
+     * 无参的任务
+     * @throws Exception 
+     */
+    public void index_target_windSpeed_power() throws Exception {
+    	indexService.index_target_windSpeed_power();//调用list方法完成对 key ："weatherProphet_1" ，路径"weather/weatherProphet_1"的推送     
+        //System.out.println("我已执行");
+    }   
+       
+
+    /**
+     * 有参任务
+     * 目前仅执行常见的数据类型  Integer Long  带L  string  带 ''  bool Double 带 d
+     * @param a
+     * @param b
+     * 
+     */
+    public void runTask2(Integer a,Long b,String c,Boolean d,Double e)
+    {
+    	//List<TsysUser> list=  tsysUserMapper.selectByExample(new TsysUserExample());
+    	//System.err.println("用户查询num："+list.size());
+        System.out.println("正在执行定时任务，带多个参数的方法"+a+"   "+b+" "+c+"  "+d+" "+e+"执行时间:"+new Date().toLocaleString());
+    }
+
+}

src/main/java/com/gyee/frame/common/quartz/task/index_windturbine_status.java

@@ -0,0 +1,51 @@
+package com.gyee.frame.common.quartz.task;
+
+import com.gyee.frame.mapper.auto.TsysUserMapper;
+import com.gyee.frame.model.auto.Weatherfd;
+import com.gyee.frame.service.app.index.IndexService;
+import com.gyee.frame.service.WeatherfdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.text.ParseException;
+import java.util.Date;
+import java.util.List;
+
+/**
+ *测试类
+ * @CLASSNAME   WeatherfdPushTask
+ * @Description 向页面预测今天气象推送数据
+ * @Auther Wang Jiawen
+ * @DATE 2020/1/2 15:33
+ */
+@Component("index_windturbine_status")
+public class index_windturbine_status {
+	@Autowired
+	private TsysUserMapper tsysUserMapper;
+	@Autowired
+    private IndexService indexService;
+    /**
+     * 无参的任务
+     * @throws Exception 
+     */
+    public void index_windturbine_status() throws Exception {
+    	indexService.index_windturbine_status();//调用list方法完成对 key ："weatherProphet_1" ，路径"weather/weatherProphet_1"的推送     
+        //System.out.println("我已执行");
+    }   
+       
+
+    /**
+     * 有参任务
+     * 目前仅执行常见的数据类型  Integer Long  带L  string  带 ''  bool Double 带 d
+     * @param a
+     * @param b
+     * 
+     */
+    public void runTask2(Integer a,Long b,String c,Boolean d,Double e)
+    {
+    	//List<TsysUser> list=  tsysUserMapper.selectByExample(new TsysUserExample());
+    	//System.err.println("用户查询num："+list.size());
+        System.out.println("正在执行定时任务，带多个参数的方法"+a+"   "+b+" "+c+"  "+d+" "+e+"执行时间:"+new Date().toLocaleString());
+    }
+
+}

src/main/java/com/gyee/frame/netty/websocket/config/ConfigDetail.txt

@@ -12,6 +12,15 @@ weatherConfigMap->weatherProphet_8_15->"pageNumber_4","functionNumber_1"
 weatherConfigMap->weatherProphet_40->"pageNumber_5","functionNumber_1"
 6.气象预测模块推送，包括气象矩阵，卡片,未来16小时数据，包含当前小时
 weatherConfigMap->weatherProphet_7Day_17Hour->"pageNumber_3","functionNumber_2"
+7.首页模块推送，第二部分指标模块的子模块1，综合指标模块，包括安全天数、装机容量、日发电量、预测发电量、上网电量
+sisConfigMap->index_target_comprehensive_indicators->"pageNumber_6","functionNumber_1"
+8.首页模块推送，第二部分指标模块的子模块2，风速功率模块，包括平均风速、预测风速、实际功率、理论功率
+sisConfigMap->index_target_windSpeed_power->"pageNumber_6","functionNumber_2"
+9.首页模块推送，第三部分风机状态模块，包括接入、待机、运行、故障、维护、离线
+sisConfigMap->index_windturbine_status->"pageNumber_6","functionNumber_3"
+10.首页模块推送，第四部分发电量完成情况模块，包括月计划发电量、年计划发电量
+sisConfigMap->index_electricQuantity->"pageNumber_6","functionNumber_4"
+
 19.综合指标模块推送,指标名称comprehensive_target,包括数值,记录综合指标
 sisConfigMap->comprehensive_target->"pageNumber_7","functionNumber_1"
 20.指标详情指标模块推送,指标名称targetdetail_target,包括数值,记录指标当前的一个实时数据

src/main/java/com/gyee/frame/netty/websocket/config/SocketPageConfig.java

@@ -52,6 +52,10 @@ public class SocketPageConfig {
           if(sisConfigMap==null){
               sisConfigMap = new HashMap<String, String[]>();
                //socket 主页面,依次排序，添加功能布局，每个页面进行一次注释
+              sisConfigMap.put("index_target_comprehensive_indicators",Createindex_target_comprehensive_indicatorsConfig());//首页第二部分指标模块的子模块1，综合指标模块，包括安全天数、装机容量、日发电量、预测发电量、上网电量
+              sisConfigMap.put("index_target_windSpeed_power",Createindex_target_windSpeed_powerConfig());//首页第二部分指标模块的子模块2，风速功率模块，包括平均风速、预测风速、实际功率、理论功率
+              sisConfigMap.put("index_windturbine_status",Createindex_windturbine_statusConfig());//首页第三部分风机状态模块，包括接入、待机、运行、故障、维护、离线
+              sisConfigMap.put("index_electricQuantity",Createindex_electricQuantityConfig());//首页第四部分发电量完成情况模块，包括月计划发电量、年计划发电量
               sisConfigMap.put("targetdetail_target",Createsis_targetdetail_target());//在此处进行功能化布局，表示在socket主页面下的一个功能
               sisConfigMap.put("targetdetail_curve",Createsis_targetdetail_curve());
               sisConfigMap.put("targetdetail_histogram",Createsis_targetdetail_histogram());
@@ -63,6 +67,9 @@ public class SocketPageConfig {
          if (weatherConfigMap.containsKey(mapKey)){
             return weatherConfigMap.get(mapKey);
          }
+         if (sisConfigMap.containsKey(mapKey)){
+             return sisConfigMap.get(mapKey);
+          }
          return null;
       }
 
@@ -90,6 +97,22 @@ public class SocketPageConfig {
     private String[] Createweatherprophet_7Day_17HourConfig() {
         return new String[]{"pageNumber_3","functionNumber_2"};//气象预测未来16小时数据，按小时预测，包含当前小时，pageNumber_3，功能编号functionNumber_2
     }
+    
+    private String[] Createindex_target_comprehensive_indicatorsConfig() {
+        return new String[]{"pageNumber_6","functionNumber_1"};//首页第二部分指标模块的子模块1，综合指标模块，包括安全天数、装机容量、日发电量、预测发电量、上网电量
+    }
+    
+    private String[] Createindex_target_windSpeed_powerConfig() {
+        return new String[]{"pageNumber_6","functionNumber_2"};//首页第二部分指标模块的子模块2，风速功率模块，包括平均风速、预测风速、实际功率、理论功率
+    }
+    
+    private String[] Createindex_windturbine_statusConfig() {
+        return new String[]{"pageNumber_6","functionNumber_3"};//首页第三部分风机状态模块，包括接入、待机、运行、故障、维护、离线
+    }
+    
+    private String[] Createindex_electricQuantityConfig() {
+        return new String[]{"pageNumber_6","functionNumber_4"};//首页第四部分发电量完成情况模块，包括月计划发电量、年计划发电量
+    }
 
     
     private String[] Createsis_targetdetail_target() {

src/main/java/com/gyee/frame/service/app/index/IndexService.java

@@ -0,0 +1,448 @@
+package com.gyee.frame.service.app.index;
+
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.SpringApplication;
+import org.springframework.stereotype.Service;
+
+import com.gyee.SpringbootStart;
+import com.gyee.frame.common.spring.Constant;
+import com.gyee.frame.common.spring.InitialRunner;
+import com.gyee.frame.model.auto.Weatherfd;
+import com.gyee.frame.model.auto.WeatherfdExample;
+import com.gyee.frame.model.auto.WindPowerstationTestingPoint;
+import com.gyee.frame.model.auto.Windpowerstation;
+import com.gyee.frame.model.custom.PointData;
+import com.gyee.frame.model.enumeration.Messagetype;
+import com.gyee.frame.netty.websocket.util.SocketToolService;
+import com.gyee.frame.util.DateUtils;
+import com.gyee.frame.util.mongodb.IMongodbUtil;
+import com.gyee.frame.util.mongodb.MongodbUtilImpl;
+
+@Service
+public class IndexService extends SocketToolService{
+	@Autowired
+    private InitialRunner initialRunner;
+    private static int decimal_digit = 0;
+	
+	public void index_target_comprehensive_indicators() throws Exception{
+		 Map<String, Map<String, WindPowerstationTestingPoint>> stationPointmap = InitialRunner.stationPointmap;
+	        List<Windpowerstation> wpls = new ArrayList<>();
+	        for(Windpowerstation wp:InitialRunner.wpls){
+	            wpls.add(wp);
+	        }
+	        Windpowerstation windpowerstationAll = new Windpowerstation();
+	        windpowerstationAll.setId("0");
+	        wpls.add(windpowerstationAll);
+	        Map<String,Map<String,Double>> windpowerstationpointDataMap = new HashMap();
+	        IMongodbUtil mongodb = new MongodbUtilImpl();
+
+	        for(Windpowerstation windpowerstation:wpls){
+	            Map<String,Double> pointDataMap = new HashMap();
+	            double rfdl = 0;
+	            double aqts = 0;
+	            double swdl = 0;
+	            double ycfdl = 0;
+	            double zjrl = 0;
+
+	            try {
+	                //日发电量
+	                PointData rfdl_real = mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_ALL_RFDL).getCode());
+	                rfdl = new BigDecimal(rfdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+	            try {
+	                //安全天数
+	                PointData aqts_real = mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_AQTS).getCode());
+	                aqts = new BigDecimal(aqts_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+
+	            try{
+	                //上网电量
+	                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WP_SWDL).getCode());
+	                swdl = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+	            //预测发电量
+	            try{
+	                if(windpowerstation.getId().equalsIgnoreCase("0")){
+	                    List<Windpowerstation> wps = InitialRunner.wpls;
+	                    for(Windpowerstation windpowerstationinner:wps){
+	                        ycfdl = ycfdl + 12;
+	                    }
+	                }else{
+	                    ycfdl = 6;
+	                }
+	            }
+	            catch(Exception e){
+	                System.out.printf(e.getMessage());
+	            }
+
+	            //装机容量
+	            try{
+	                if(windpowerstation.getCapacity()==null){
+	                    List<Windpowerstation> wps = InitialRunner.wpls;
+	                    for(Windpowerstation windpowerstationinner:wps){
+	                        zjrl = zjrl + windpowerstationinner.getCapacity();
+	                    }
+	                }else{
+	                    zjrl = windpowerstation.getCapacity();
+	                }
+
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+	            pointDataMap.put("rfdl",rfdl);
+	            pointDataMap.put("aqts",aqts);
+	            pointDataMap.put("swdl",swdl);
+	            pointDataMap.put("ycfdl",ycfdl);
+	            pointDataMap.put("zjrl",zjrl);
+	            windpowerstationpointDataMap.put(windpowerstation.getId(),pointDataMap);
+	        }
+        this.pushToWeb("pageNumber_6","functionNumber_1",windpowerstationpointDataMap, Messagetype.MESSAGE);
+	}
+	
+	
+	public void index_target_windSpeed_power() throws Exception{
+		Map<String, Map<String, WindPowerstationTestingPoint>> stationPointmap = InitialRunner.stationPointmap;
+        List<Windpowerstation> wpls = new ArrayList<>();
+        for(Windpowerstation wp:InitialRunner.wpls){
+            wpls.add(wp);
+        }
+        Windpowerstation windpowerstationAll = new Windpowerstation();
+        windpowerstationAll.setId("0");
+        wpls.add(windpowerstationAll);
+        Map<String,Map<String,Double>> windpowerstationpointDataMap = new HashMap();
+        IMongodbUtil mongodb = new MongodbUtilImpl();
+
+        for(Windpowerstation windpowerstation:wpls){
+            Map<String,Double> pointDataMap = new HashMap();
+            double pjfs = 0;
+            double pjfsMin = 0;
+            double pjfsMax = 0;
+            double ycfs = 0;
+            double ycfsMin = 0;
+            double ycfsMax = 0;
+            double sjgl = 0;
+            double sjglMin = 0;
+            double sjglMax = 0;
+            double llgl = 0;
+            double llglMax = 0;
+            double llglMin = 0;
+
+            try {
+                //平均风速
+                PointData rfdl_real = mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WP_PJFS).getCode());
+                pjfs = new BigDecimal(rfdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+            }catch (Exception e){
+                System.out.println(e.getMessage());
+            }
+            
+            //平均风速min
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){                  	
+                    	if(pjfs==0){
+                    		pjfsMin=pjfs;
+                    	}else{
+                    		pjfsMin = pjfs - 2;
+                    	}
+                    }
+                }else{
+                	if(pjfs==0){
+                		pjfsMin=pjfs;
+                	}else{
+                		pjfsMin = pjfs - 2;
+                	}
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+          //平均风速max
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){
+                    	pjfsMax = pjfs + 2;
+                    }
+                }else{
+                	pjfsMax = pjfs + 2;
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+            //预测风速
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){
+                    	ycfs = pjfs + 2;
+                    }
+                }else{
+                	ycfs = pjfs + 2;
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+          //预测风速min
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){                   	
+                    	if(ycfs==0){
+                    		ycfsMin = ycfs;
+                    	}else{
+                    		ycfsMin = ycfs - 2;
+                    	}
+                    }
+                }else{
+                	if(ycfs==0){
+                		ycfsMin = ycfs;
+                	}else{
+                		ycfsMin = ycfs - 2;
+                	}
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+          //预测风速max
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){
+                    	ycfsMax = ycfs + 2;
+                    }
+                }else{
+                	ycfsMax = ycfs + 2;
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+
+            try{
+                //实际功率
+                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WP_SJGL).getCode());
+                sjgl = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+            }catch (Exception e){
+                System.out.println(e.getMessage());
+            }
+            
+          //实际功率min
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){                 	
+                    	if(sjgl==0){
+                    		sjglMin = sjgl;
+                    	}else{
+                    		sjglMin = sjgl - 2;
+                    	}
+                    }
+                }else{
+                	if(sjgl==0){
+                		sjglMin = sjgl;
+                	}else{
+                		sjglMin = sjgl - 2;
+                	}
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+          //实际功率max
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){
+                    	sjglMax = sjgl + 2;
+                    }
+                }else{
+                	sjglMax = sjgl + 2;
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+            try{
+                //理论功率
+                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WP_ZLLGL).getCode());
+                llgl = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+            }catch (Exception e){
+                System.out.println(e.getMessage());
+            }
+            
+          //理论功率min
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){                   	
+                    	if(llgl==0){
+                    		llglMin = llgl;
+                    	}else{
+                    		llglMin = llgl - 2;
+                    	}
+                    }
+                }else{
+                	if(llgl==0){
+                		llglMin = llgl;
+                	}else{
+                		llglMin = llgl - 2;
+                	}
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+            
+          //理论功率max
+            try{
+                if(windpowerstation.getId().equalsIgnoreCase("0")){
+                    List<Windpowerstation> wps = InitialRunner.wpls;
+                    for(Windpowerstation windpowerstationinner:wps){
+                    	llglMax = llgl + 2;
+                    }
+                }else{
+                	llglMax = llgl + 2;
+                }
+            }
+            catch(Exception e){
+                System.out.printf(e.getMessage());
+            }
+
+                      
+            pointDataMap.put("pjfs",pjfs);
+            pointDataMap.put("pjfsMin",pjfsMin);
+            pointDataMap.put("pjfsMax",pjfsMax);
+            pointDataMap.put("ycfs",ycfs);
+            pointDataMap.put("ycfsMin",ycfsMin);
+            pointDataMap.put("ycfsMax",ycfsMax);
+            pointDataMap.put("sjgl",sjgl);
+            pointDataMap.put("sjglMin",sjglMin);
+            pointDataMap.put("sjglMax",sjglMax);
+            pointDataMap.put("llgl",llgl);
+            pointDataMap.put("llglMin",llglMin);
+            pointDataMap.put("llglMax",llglMax);
+            windpowerstationpointDataMap.put(windpowerstation.getId(),pointDataMap);
+        }
+        this.pushToWeb("pageNumber_6","functionNumber_2",windpowerstationpointDataMap, Messagetype.MESSAGE);
+	}
+	
+	public void index_windturbine_status() throws Exception{
+		 Map<String, Map<String, WindPowerstationTestingPoint>> stationPointmap = InitialRunner.stationPointmap;
+	        List<Windpowerstation> wpls = new ArrayList<>();
+	        for(Windpowerstation wp:InitialRunner.wpls){
+	            wpls.add(wp);
+	        }
+	        Windpowerstation windpowerstationAll = new Windpowerstation();
+	        windpowerstationAll.setId("0");
+	        wpls.add(windpowerstationAll);
+	        Map<String,Map<String,Double>> windpowerstationpointDataMap = new HashMap();
+	        IMongodbUtil mongodb = new MongodbUtilImpl();
+
+	        for(Windpowerstation windpowerstation:wpls){
+	            Map<String,Double> pointDataMap = new HashMap();
+	            double jr = 0;
+	            double dj = 0;
+	            double yx = 0;
+	            double gz = 0;
+	            double wh = 0;
+	            double lx = 0;
+
+	            try {
+	                //待机
+	                PointData rfdl_real = mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WT_DJTS).getCode());
+	                dj = new BigDecimal(rfdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+	            try {
+	                //运行
+	                PointData aqts_real = mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WT_YXTS).getCode());
+	                yx = new BigDecimal(aqts_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+
+	            try{
+	                //故障
+	                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WT_GZTJ).getCode());
+	                gz = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+	            
+	            try{
+	                //维护
+	                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WT_WHTJ).getCode());
+	                wh = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+	            
+	            try{
+	                //离线
+	                PointData swdl_real=mongodb.getRealData(stationPointmap.get(windpowerstation.getId()).get(Constant.TPOINT_WT_TXZD).getCode());
+	                lx = new BigDecimal(swdl_real.getPointValueInDouble()).setScale(decimal_digit, RoundingMode.HALF_EVEN).doubleValue();
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+
+	            
+
+	            //接入
+	            try{
+	                if(windpowerstation.getCapacity()==null){
+	                    List<Windpowerstation> wps = InitialRunner.wpls;
+	                    for(Windpowerstation windpowerstationinner:wps){
+	                        jr = dj+yx+gz+wh+lx;
+	                    }
+	                }else{
+	                	jr = dj+yx+gz+wh+lx;
+	                }
+
+	            }catch (Exception e){
+	                System.out.println(e.getMessage());
+	            }
+	            pointDataMap.put("jr",jr);
+	            pointDataMap.put("dj",dj);
+	            pointDataMap.put("yx",yx);
+	            pointDataMap.put("gz",gz);
+	            pointDataMap.put("wh",wh);
+	            pointDataMap.put("lx",lx);
+	            windpowerstationpointDataMap.put(windpowerstation.getId(),pointDataMap);
+	        }
+       this.pushToWeb("pageNumber_6","functionNumber_3",windpowerstationpointDataMap, Messagetype.MESSAGE);
+	}
+
+}