From a0b7214e89c4abd596ce8ad5ab115e9c7ea3dcda Mon Sep 17 00:00:00 2001
From: 于紫祥_1901 <email@yuzixiang_1910>
Date: Thu, 13 Aug 2020 10:12:56 +0800
Subject: [PATCH] 风场图update

---
 src/main/java/com/moral/service/impl/DeviceServiceImpl.java |  181 +++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 175 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/moral/service/impl/DeviceServiceImpl.java b/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
index 5eb9c1c..6fd1dc4 100644
--- a/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/DeviceServiceImpl.java
@@ -1,16 +1,12 @@
 package com.moral.service.impl;
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 import javax.annotation.Resource;
 import javax.validation.constraints.NotNull;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.TypeReference;
 import com.github.pagehelper.Page;
 import com.github.pagehelper.PageHelper;
@@ -22,6 +18,7 @@
 import com.moral.common.util.RedisUtils;
 import com.moral.common.util.ValidateUtil;
 import com.moral.entity.Device;
+import com.moral.entity.DeviceAndWind;
 import com.moral.entity.DeviceProperty;
 import com.moral.entity.MonitorPoint;
 import com.moral.mapper.DeviceMapper;
@@ -32,6 +29,7 @@
 import com.moral.mapper.OrganizationMapper;
 import com.moral.service.AccountService;
 import com.moral.service.DeviceService;
+import com.moral.util.LatLngTransformation;
 import com.moral.util.TkMybatisUtils;
 
 import org.apache.commons.collections.MapUtils;
@@ -703,4 +701,175 @@
         Map<String, Object> deviceMap = deviceMapper.selectAllFieldByMac(parameters);
         return deviceMap;
     }
+
+    @Override
+    public List<DeviceAndWind> getAllDevice() {
+        return deviceMapper.getAllDevice();
+    }
+
+    @Override
+    public List<String> getAllMac() {
+        return deviceMapper.getAllMac();
+    }
+
+    @Override
+    public Device byMacGetDevice(String mac) {
+        return deviceMapper.byMacGetDevice(mac);
+    }
+
+    @Override
+    public List byMonitorIdGetDeviceAndWind(String id,String time,String tab) {
+        List<DeviceAndWind> deviceAndWinds=deviceMapper.byMonitorIdGetDeviceAndWind(Integer.parseInt(id),time,tab);
+        System.out.println(time);
+        List loList=new ArrayList();
+        List laList=new ArrayList();
+        Double U=0.0;
+        Double V=0.0;
+        log.info(deviceAndWinds.size());
+        for (DeviceAndWind andWind : deviceAndWinds) {
+            Double lo=andWind.getLongitude();
+            Double la=andWind.getLatitude();
+            List list= LatLngTransformation.Convert_BD09_To_GCJ02(la,lo);
+            Double transLo=(Double) list.get(0);
+            Double transLa=(Double) list.get(1);
+            loList.add(transLo);
+            laList.add(transLa);
+        }
+          Double  loma= (Double) Collections.max(loList);
+          Double  lomi= (Double) Collections.min(loList);
+          Double  lama= (Double) Collections.max(laList);
+          Double  lami= (Double) Collections.min(laList);
+        Map laLaMap=new HashMap();
+        laLaMap.put("maxLo",loma);
+        laLaMap.put("minLo",lomi);
+        laLaMap.put("maxLa",lama);
+        laLaMap.put("minLa",lami);
+
+        Double lo1=lomi-250*0.00001141;
+        Double lo2=loma+250*0.00001141;
+        Double la2=lami-250*0.00000899;
+        Double la1=lama+250*0.00000899;
+
+        Double dx=0.00001141*20;
+        Double dy=0.00000899*20;
+        int nx=(int) Math.floor((lo2-lo1)/dx);
+        int ny=(int) Math.floor((la1-la2)/dy);
+        String header1 = "\"" + "header" + "\"" + ": " + "{" + "\"" + "parameterUnit" + "\"" + ": " + "\"" + "m/s" + "\"" + ", " + "\"" + "parameterNumber" + "\"" + ": " + 2 +
+                ", " + "\"" + "dx" + "\"" + ": " + dx + ", " + "\"" + "dy" + "\"" + ": " + dy +
+                ", " + "\"" + "parameterNumberName" + "\"" + ": " + "\"" + "eastward_wind" + "\"" + ", " + "\"" + "la1" + "\"" + ": " + la1 + ", " + "\"" + "la2" + "\"" + ": " + la2 +
+                ", " + "\"" + "parameterCategory" + "\"" + ": " + 2 + ", " + "\"" + "lo1" + "\"" + ": " + lo1 + ", " + "\"" + "lo2" + "\"" + ": " + lo2 +
+                ", " + "\"" + "nx" + "\"" + ": " + nx + ", " + "\"" + "ny" + "\"" + ": " + ny + ", " + "\"" + "refTime" + "\"" + ": " + "\"" + "2020-07-22 23:00:00" + "\"" + "}";
+
+        String header2 = "\"" + "header" + "\"" + ": " + "{" + "\"" + "parameterUnit" + "\"" + ": " + "\"" + "m/s" + "\"" + ", " + "\"" + "parameterNumber" + "\"" + ": " + 3 +
+                ", " + "\"" + "dx" + "\"" + ": " + dx + ", " + "\"" + "dy" + "\"" + ": " + dy +
+                ", " + "\"" + "parameterNumberName" + "\"" + ": " + "\"" + "eastward_wind" + "\"" + ", " + "\"" + "la1" + "\"" + ": " + la1 + ", " + "\"" + "la2" + "\"" + ": " + la2 +
+                ", " + "\"" + "parameterCategory" + "\"" + ": " + 2 + ", " + "\"" + "lo1" + "\"" + ": " + lo1 + ", " + "\"" + "lo2" + "\"" + ": " + lo2 +
+                ", " + "\"" + "nx" + "\"" + ": " + nx + ", " + "\"" + "ny" + "\"" + ": " + ny + ", " + "\"" + "refTime" + "\"" + ": " + "\"" + "2020-07-22 23:00:00" + "\"" + "}";
+
+        List<Double> uList=new ArrayList<Double> ();
+        List<Double>  vList=new ArrayList<Double> ();
+        int x=0;
+        int y=0;
+        List<Map> mapList=new ArrayList<Map>();
+
+        for (int j = 0; j <deviceAndWinds.size() ; j++) {
+            Map<String,Double> map=new HashMap<String,Double> ();
+            Double windDir= deviceAndWinds.get(j).getWindDir();
+
+            Double windSpeed=deviceAndWinds.get(j).getWindSpeed();
+            if (windDir==null){
+                windDir=0.0;
+                windSpeed=0.0;
+            }
+            Double tvoc=deviceAndWinds.get(j).getTVoc();
+
+            List list= LatLngTransformation.Convert_BD09_To_GCJ02(deviceAndWinds.get(j).getLatitude(),deviceAndWinds.get(j).getLongitude());
+            Double transLo=(Double) list.get(0);
+            Double transLa=(Double) list.get(1);
+            if (tvoc==null){
+                tvoc=0.0;
+            }
+            Double dir = (270.0 - windDir * Math.PI / 180.0);
+
+            U = windSpeed * Math.cos(dir);
+            V = windSpeed * Math.sin(dir);
+            map.put("lo",transLo);
+            map.put("la",transLa);
+            map.put("U",U);
+            map.put("V",V);
+            mapList.add(map);
+        }
+        for (int i = 0; i <mapList.size() ; i++) {
+            Double lo= (Double) mapList.get(i).get("lo");
+            Double la= (Double) mapList.get(i).get("la");
+            x= (int) Math.floor((lo-lo1)/dx);
+            y=Math.abs((int)Math.floor((la-la1)/dy));
+            //y=Math.floor(Math.abs(la-la1)/dy);
+            U=(Double) mapList.get(i).get("U");
+            V=(Double) mapList.get(i).get("V");
+            if (i==0){
+                for (int j = 0; j <nx*ny ; j++) {
+                    uList.add(0.0);
+                    vList.add(0.0);
+                }
+            }
+            for (int j = 0; j <nx*ny ; j++) {
+                if (i==0){
+                    if ((y>=2 && j==(y)*nx+x)){
+                        int k;
+                        for (k = j-2*nx; k <=j+2*nx ;k=k+nx) {
+                            uList.set(k,U);
+                            uList.set(k-1,U);
+                            uList.set(k-2,U);
+                            uList.set(k+1,U);
+                            uList.set(k+2,U);
+                            vList.set(k,V);
+                            vList.set(k-1,V);
+                            vList.set(k-2,V);
+                            vList.set(k+1,V);
+                            vList.set(k+2,V);
+                        }
+                    }
+                }else {
+                    if (y>=1 && j==y*nx+x && uList.get(j)==0.0 && vList.get(j)==0.0){
+                        int k;
+                        for (k = j-2*nx; k <=j+2*nx ;) {
+                            uList.set(k-1,U);
+                            uList.set(k-2,U);
+                            uList.set(k+1,U);
+                            uList.set(k+2,U);
+                            vList.set(k-1,V);
+                            vList.set(k-2,V);
+                            vList.set(k+1,V);
+                            vList.set(k+2,V);
+                            k=k+nx;
+                        }
+                        uList.set(j,U);
+                        vList.set(j,V);
+                    }
+                }
+            }
+        }
+        String uData = "\"" + "data" + "\"" + ": " + uList;
+        String vData = "\"" + "data" + "\"" + ": " + vList;
+        String s1 = "[" + "{" + header1 + ", " + uData + "}" + ", " + "{" + header2 + ", " + vData + "}" + "]";
+        JSONArray jsonArray = JSONArray.parseArray(s1);
+        MonitorPoint monitorPoint=monitorPointMapper.byIdGetMonitorPoint(Integer.parseInt(id));
+        Double monitorLo=monitorPoint.getLongitude();
+        Double monitorLa=monitorPoint.getLatitude();
+        List transList= LatLngTransformation.Convert_BD09_To_GCJ02(monitorLa,monitorLo);
+        Double transLo=(Double) transList.get(0);
+        Double transLa=(Double) transList.get(1);
+        List list=new ArrayList();
+        list.add(jsonArray);
+        list.add(transLo);
+        list.add(transLa);
+        list.add(laLaMap);
+        return list;
+    }
+
+    @Override
+    public DeviceAndWind getDeviceAndWindByMac(String mac,String time,String table) {
+        return deviceMapper.getDeviceAndWindByMac(mac,time,table);
+    }
 }

--
Gitblit v1.8.0