工作台-右侧数据展示

.gitignore

@@ -1 +1,4 @@
 /build/
+log
+.idea
+go.sum

app/device/controller/workbenchController.go

@@ -41,7 +41,7 @@ func (c *workbenchCtl) Aqi(ctx *gin.Context) {
 	value, _ := ctx.Get(middleware.Authorization)
 	claims := value.(*middleware.Claims)
 
-	alarms, err := service.WorkbenchService.CountAlarm(claims.TenantId)
+	alarms, err := service.WorkbenchService.Aqi(claims.TenantId)
 	if err != nil {
 		ctx.JSON(http.StatusOK, err)
 		return

app/device/dao/optoSensoDao.go

@@ -116,3 +116,19 @@ func (c OptoSensor) GetAll() []*OptoSensor {
 		c.IsDeleted).Find(&devices)
 	return devices
 }
+
+func (c OptoSensor) getList(optoSensor OptoSensor) []OptoSensorVO {
+	var optoSensorVO []OptoSensorVO
+	tenantId := optoSensor.TenantId
+	if tenantId == 0 {
+		tenantId = c.TenantId
+	}
+	optoSensor.TenantId = tenantId
+	where := ""
+	if optoSensor.IsDefault == 1 {
+		where = "and a.is_default=1"
+	}
+	Db.Debug().Raw("SELECT a.*, v3.id brand, v4.id model, lamp.district_name FROM device_opto_sensor a LEFT JOIN device_vendor v3 ON v3.id = a.brand_id LEFT JOIN device_vendor v4 ON v4.id = a.model_id LEFT JOIN device_lamp_pole lamp ON lamp.id = a.lamp_pole_id WHERE a.is_deleted = 0 " + where).Scan(&optoSensorVO)
+
+	return optoSensorVO
+}

app/device/dao/workbenchDao.go

@@ -1,5 +1,9 @@
 package dao
 
+import (
+	"strings"
+)
+
 type CountDevice struct {
 	CountNum   int    `json:"countNum"`
 	DeviceType string `json:"deviceType"`
@@ -75,3 +79,65 @@ func GetNotification(tenantId int) (*Notification, error) {
 	var notification Notification
 	return &notification, nil
 }
+
+type AqiData struct {
+	Name string
+	Aqi  float64
+}
+type OptoSensorVO struct {
+	OptoSensor
+	Ids                   string `json:"ids"`                   //用于查询多个ID
+	Brand                 string `json:"brand"`                 //品牌名称
+	Model                 string `json:"model"`                 //型号名称
+	RunState              string `json:"runState"`              //运行状态
+	NetworkState          int    `json:"networkState"`          //网络状态
+	RealTimeTemperature   string `json:"realTimeTemperature"`   //实时温度
+	RealTimeWindSpeed     string `json:"realTimeWindSpeed"`     //实时风速
+	AirQuality            string `json:"airQuality"`            //空气质量等级
+	AirIndex              int    `json:"airIndex"`              //空气质量指数
+	IlluminationIntensity string `json:"illuminationIntensity"` //光照强度
+	Pm25                  string `json:"pm25"`                  //PM2.5
+	Pm10                  string `json:"pm10"`                  //PM10
+	Humidity              string `json:"humidity"`              //湿度
+	Pressure              string `json:"pressure"`              //气压
+	Noise                 string `json:"noise"`                 //噪音
+	Direction             string `json:"direction"`             //风向
+	EndLineTime           string `json:"endLineTime"`           //最后在线时间
+	QueryGatewayIds       string `json:"queryGatewayIds"`       //虚拟字段---用作网关调用这里关联
+	GatewayName           string `json:"gatewayName"`           //所属网关名称
+	GatewaySn             string `json:"gatewaySn"`             //所属网关编码
+	DistrictName          string `json:"districtName"`          //所在区(AQI展示)
+
+}
+
+func GetAqi(tenantId int) (*OptoSensorVO, error) {
+	var sensorVO OptoSensorVO
+	var optoSensor OptoSensor
+	optoSensor.TenantId = tenantId
+	optoSensor.IsDefault = 1
+	isSet := len(optoSensor.GetDevicesByTenantId())
+	if isSet == 0 {
+		optoSensor.IsDefault = 0
+	}
+	list := optoSensor.getList(optoSensor)
+	if isSet == 0 {
+		for _, sensor := range list {
+			if sensor.NetworkState == 1 {
+				sensorVO = sensor
+				break
+			}
+		}
+	} else {
+		if len(list) != 0 {
+			sensorVO = list[0]
+		}
+	}
+	if sensorVO.RealTimeTemperature != "" {
+		temp := strings.Split(sensorVO.RealTimeTemperature, " ")
+		if len(temp) == 2 {
+			temperature := temp[0] + " " + temp[1]
+			sensorVO.RealTimeTemperature = temperature
+		}
+	}
+	return &sensorVO, nil
+}

app/device/service/workbenchService.go

@@ -1,6 +1,8 @@
 package service
 
 import (
+	"fmt"
+	dataDao "iot_manager_service/app/data/dao"
 	"iot_manager_service/app/device/dao"
 	"iot_manager_service/app/device/model"
 	"iot_manager_service/util/common"
@@ -47,3 +49,36 @@ func (s *workbenchService) LightRate(tenantId int) (*model.RspLightRate, *common
 	var rsp model.RspLightRate
 	return &rsp, nil
 }
+
+//工作台-采集点
+func (s *workbenchService) Aqi(tenantId int) (interface{}, interface{}) {
+	aqi, err := dao.GetAqi(tenantId)
+	if err != nil {
+		return nil, common.FailResponse(err.Error(), nil)
+	}
+	s.getNewsDate(aqi)
+	return aqi, nil
+}
+
+func (s *workbenchService) getNewsDate(vo *dao.OptoSensorVO) *dao.OptoSensorVO {
+	//var meteorologicalDataList []omodel.EnvironmentDetail
+	//meteorologicalDataVO := omodel.EnvironmentDetail{}
+	//meteorologicalDataVO.Sn = vo.Sn
+	//meteorologicalDataList = append(meteorologicalDataList, meteorologicalDataVO)
+	devId := vo.ID
+	environmentData := dataDao.EnvironmentData{DeviceId: devId}
+	environmentData.Get()
+	vo.RealTimeTemperature = fmt.Sprintf("%.2f ℃", environmentData.Temperature)
+	vo.Pm25 = fmt.Sprintf("%.2f ug/m³", environmentData.Pm25)
+	vo.AirIndex = int(environmentData.Air)
+	vo.AirQuality = common.CalculateAirQuality(string(fmt.Sprintf("%.2f", environmentData.Air)))
+	vo.EndLineTime = vo.UpdateTime.Format("2006-01-02 15:04:05")
+	vo.Humidity = fmt.Sprintf("%.2f", environmentData.Humidity)
+	vo.Pm10 = fmt.Sprintf("%.2f", environmentData.Pm10)
+	vo.Noise = fmt.Sprintf("%.2f", environmentData.Noise)
+
+	vo.Pressure = fmt.Sprintf("%.2f", environmentData.Hpa)                                       //大气压
+	vo.Direction = common.CalculateDirection(environmentData.WindDirection)                      //风向
+	vo.RealTimeWindSpeed = common.CalculateSpeed(fmt.Sprintf("%.2f", environmentData.WindSpeed)) //风力等级
+	return vo
+}

main.go

@@ -17,6 +17,7 @@ import (
 	"iot_manager_service/util/logger"
 	"iot_manager_service/util/minio"
 	"net/url"
+	"os"
 	"time"
 )
 
@@ -46,6 +47,10 @@ func initDB() {
 		LogLevel:      gormLogger.Info,
 		Colorful:      true,
 	})
+	// 如果是本地开发环境 则 打印gorm 查询日志到控制台
+	if os.Getenv("DEV_ENV") == "1" {
+		logCfg = gormLogger.Default
+	}
 	db, err := gorm.Open(mysql.New(mysql.Config{
 		DSN: dsn,
 	}), &gorm.Config{Logger: logCfg})

util/common/aqiUtil.go

@@ -0,0 +1,290 @@
+package common
+
+import (
+	"fmt"
+	"iot_manager_service/app/device/dao"
+	"math"
+	"sort"
+	"strconv"
+)
+
+//计算空气质量转换等级
+func CalculateAirQuality(airQuality string) string {
+	d, err := strconv.ParseFloat(airQuality, 64)
+	if err != nil {
+		panic(err.Error())
+	}
+	val := "-"
+	if d <= 50 {
+		val = "优"
+	} else if d > 50 && d <= 100 {
+		val = "良"
+	} else if d > 100 && d <= 150 {
+		val = "轻度污染"
+	} else if d > 150 && d <= 200 {
+		val = "中度污染"
+	} else if d > 200 && d < 300 {
+		val = "重度污染"
+	} else if d > 300 {
+		val = "严重污染"
+	}
+	return val
+}
+
+// 计算aqi值对应的等级
+func getPollutionDegree(aqi float64) int {
+	pollutionDegree := 1
+	if aqi <= 50 {
+		pollutionDegree = 1
+	} else if aqi > 50 && aqi <= 100 {
+		pollutionDegree = 2
+	} else if aqi > 100 && aqi <= 150 {
+		pollutionDegree = 3
+	} else if aqi > 150 && aqi <= 200 {
+		pollutionDegree = 4
+	} else if aqi > 200 && aqi <= 300 {
+		pollutionDegree = 5
+	} else if aqi > 300 {
+		pollutionDegree = 6
+	}
+	return pollutionDegree
+}
+
+// 计算aqi值对应的等级
+func getDegree(pollutionDegree int) string {
+	if pollutionDegree == 1 {
+		return "优"
+	} else if pollutionDegree == 2 {
+		return "良"
+	} else if pollutionDegree == 3 {
+		return "轻度污染"
+	} else if pollutionDegree == 4 {
+		return "中度污染"
+	} else if pollutionDegree == 5 {
+		return "重度污染"
+	} else if pollutionDegree == 6 {
+		return "严重污染"
+	}
+	return "数据错误"
+}
+
+/**
+ * 计算每种污染物项目 P的空气质量分指数
+ *
+ * @param cp 污染物项目P的质量浓度
+ * @param r  污染物项目P所在数组中的行号
+ * @return
+ */
+func countPerIaqi(cp float64, r int) float64 {
+	bph := 0   // 与 cp相近的污染物浓度限值的高位值
+	bpl := 0   // 与 cp相近的污染物浓度限值的低位值
+	iaqih := 0 // 与 bph对应的空气质量分指数
+	iaqil := 0 // 与 bpl对应的空气质量分指数
+	iaqip := 0 // 当前污染物项目P的空气质量分指数
+	// 空气质量分指数及对应的污染物项目浓度限值
+	aqiArr := [][]int{{0, 50, 100, 150, 200, 300, 400, 500}, {0, 35, 75, 115, 150, 250, 350, 500},
+		{0, 50, 150, 250, 350, 420, 500, 600}, {0, 2, 4, 14, 24, 36, 48, 60},
+		{0, 40, 80, 180, 280, 565, 750, 940}, {0, 160, 200, 300, 400, 800, 1000, 1200},
+		{0, 50, 150, 475, 800, 1600, 2100, 2620}, {0, 100, 160, 215, 265, 800}}
+
+	min := aqiArr[r][0]
+	index := len(aqiArr[r]) - 1
+	max := aqiArr[r][index]
+	if cp <= float64(min) || cp >= float64(max) {
+		return 0
+	} else {
+		// 对每种污染物的bph、bpl、iaqih、iaqil进行赋值
+		for i := 0; i < r+1; i++ {
+			for j := 0; j < len(aqiArr[0]); j++ {
+				if cp < float64(aqiArr[i][j]) {
+					bph = aqiArr[i][j]
+					bpl = aqiArr[i][j-1]
+					iaqih = aqiArr[0][j]
+					iaqil = aqiArr[0][j-1]
+					break
+				}
+			}
+		}
+		// 计算污染物项目 P的空气质量分指数
+		iaqip = (iaqih-iaqil)/(bph-bpl)*(int(cp)-bpl) + iaqil
+		bg := math.Ceil(float64(iaqip))
+		float, err := strconv.ParseFloat(fmt.Sprintf("%.4f", bg), 64)
+		if err != nil {
+			panic(err.Error())
+		}
+		return float
+	}
+}
+
+/**
+ * 根据提供污染物的各项指标，对AQI进行计算
+ *
+ * @param pmtw PM2.5
+ * @param pmte PM10
+ * @param co   一氧化碳浓度
+ * @param no2  二氧化氮浓度
+ * @param o3   臭氧浓度
+ * @param so2  二氧化硫浓度
+ * @return
+ */
+func CountAqi(pmtw float64, pmte float64, co float64, no2 float64, o3 float64, so2 float64) *dao.AqiData {
+	var pmtwIaqi float64 = getPm25IAQI(pmtw)
+	var pmteIaqi float64 = getPm10IAQI(pmte)
+	var coIaqi float64 = getCoIAQI(co)
+	var no2Iaqi float64 = getNo2IAQI(no2)
+	var o3Iaqi float64 = getO3OneHourIAQI(o3)
+	var so2Iaqi float64 = getSo2IAQI(so2)
+	var aList []dao.AqiData
+	//// 初始化对象数组
+	if pmtwIaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "PM2.5", Aqi: pmtwIaqi})
+	}
+	if pmteIaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "PM10", Aqi: pmteIaqi})
+	}
+	if coIaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "CO", Aqi: coIaqi})
+	}
+	if no2Iaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "NO2", Aqi: no2Iaqi})
+	}
+	if o3Iaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "O3", Aqi: o3Iaqi})
+	}
+	if so2Iaqi != 0 {
+		aList = append(aList, dao.AqiData{Name: "SO2", Aqi: so2Iaqi})
+	}
+	sort.Slice(aList, func(i, j int) bool {
+		f := aList[i].Aqi - aList[j].Aqi
+		if f > 0 {
+			return true
+		}
+		return false
+	})
+	var aqi dao.AqiData
+	if len(aList) > 0 {
+		aqi = aList[len(aList)-1]
+	} else {
+		aqi = dao.AqiData{"PM10", 0.0}
+	}
+	return &aqi
+}
+
+func getPm25IAQI(pmtw float64) float64 {
+	if pmtw > 0 {
+		return countPerIaqi(pmtw, 1)
+	}
+	return 0
+}
+
+func getPm10IAQI(pmte float64) float64 {
+	if pmte > 0 {
+		return countPerIaqi(pmte, 2)
+	}
+	return 0
+}
+
+func getCoIAQI(co float64) float64 {
+	if co > 0 {
+		return countPerIaqi(co, 3)
+	}
+	return 0
+}
+
+func getNo2IAQI(no2 float64) float64 {
+	if no2 > 0 {
+		return countPerIaqi(no2, 4)
+	}
+	return 0
+}
+
+func getO3OneHourIAQI(o3One float64) float64 {
+	if o3One > 0 {
+		return countPerIaqi(o3One, 5)
+	}
+	return 0
+}
+
+func getSo2IAQI(so2 float64) float64 {
+	if so2 > 0 {
+		return countPerIaqi(so2, 6)
+	}
+	return 0
+}
+
+/**
+ * 计算风向角度，转换成中文方向
+ *
+ * @param windDirection
+ * @return
+ */
+func CalculateDirection(windDirection string) string {
+	d, _ := strconv.ParseFloat(windDirection, 64)
+	val := "-"
+	if d > 337.5 || d < 22.5 {
+		//Namezh: "北", Name: "N", Center: 0, DirectionA: 337.5, DirectionB: 22.5
+		val = "北"
+	} else if d > 22.5 && d < 67.5 {
+		//Direction{Namezh: "东北", Name: "NE", Center: 45, DirectionA: 22.5, DirectionB: 67.5}
+		val = "东北"
+	} else if d > 67.5 && d < 112.5 {
+		//Namezh:"东", Name:"E", Center:90, DirectionA:67.5, DirectionB:112.5
+		val = "东"
+	} else if d > 112.5 && d < 157.5 {
+		//Namezh: "东南", Name: "SN", Center: 135, DirectionA: 112.5, DirectionB: 157.5
+		val = "东南"
+	} else if d > 157.5 && d < 202.5 {
+		//Namezh: "南", Name: "S", Center: 180, DirectionA: 157.5, DirectionB: 202.5
+		val = "南"
+	} else if d > 202.5 && d < 247.5 {
+		//Namezh: "西南", Name: "SW", Center: 225, DirectionA: 202.5, DirectionB: 247.5
+		val = "西南"
+	} else if d > 247.5 && d < 292.5 {
+		//Namezh: "西", Name: "W", Center: 270, DirectionA: 247.5, DirectionB: 292.5
+		val = "西"
+	} else if d > 292.5 && d < 337.5 {
+		//Namezh: "西北", Name: "NW", Center: 315, DirectionA: 292.5, DirectionB: 337.5
+		val = "西北"
+	}
+	return val
+}
+
+/**
+ * 计算风速等级
+ *
+ * @param speed
+ * @return
+ */
+func CalculateSpeed(speed string) string {
+	//风力等级范围
+	d, _ := strconv.ParseFloat(speed, 64)
+	val := "-"
+	if d >= 0.0 && d <= 0.2 {
+		val = "无风"
+	} else if d >= 0.3 && d <= 1.5 {
+		val = "软风(一级)"
+	} else if d >= 1.6 && d <= 3.3 {
+		val = "轻风(二级)"
+	} else if d >= 3.4 && d <= 5.4 {
+		val = "微风(三级)"
+	} else if d >= 5.5 && d <= 7.9 {
+		val = "和风(四级)"
+	} else if d >= 8.0 && d <= 10.7 {
+		val = "清劲风(五级)"
+	} else if d >= 10.8 && d <= 13.8 {
+		val = "强风(六级)"
+	} else if d >= 13.9 && d <= 17.1 {
+		val = "疾风(七级)"
+	} else if d >= 17.2 && d <= 20.7 {
+		val = "大风(八级)"
+	} else if d >= 20.8 && d <= 24.4 {
+		val = "烈风(九级)"
+	} else if d >= 24.5 && d <= 28.4 {
+		val = "狂风(十级)"
+	} else if d >= 28.5 && d <= 32.6 {
+		val = "暴风(11级)"
+	} else if d > 32.6 {
+		val = "台风(12级)"
+	}
+	return val
+}