数据上报
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

79 lines
2.3 KiB

package adaptors
import (
"encoding/json"
"fmt"
"goUpload/models"
"goUpload/utils"
"log"
"strings"
"time"
)
// Adaptor_ZD_MYX 振动DAAS数据 转换 湘潭健康监测平台
type Adaptor_ZD_MYX struct {
IdMap map[string]string
}
func (the Adaptor_ZD_MYX) Transform(rawMsg string) []byte {
zd := models.ZD{}
json.Unmarshal([]byte(rawMsg), &zd)
return the.ZDtoMYCInflux(zd)
}
func (the Adaptor_ZD_MYX) ZDtoMYCInflux(zd models.ZD) (result []byte) {
Atime := time.UnixMilli(zd.Ticks)
var sensorAccDataList = zd.AccValues
sensorCode := the.getSensorId(zd.Module)
if sensorCode == "" || len(sensorAccDataList) < 5 {
log.Printf("振动DAAS 设备[%s] 无匹配的明月峡id,请检查配置文件", zd.Module)
return
}
//振动DAAS数据 分为3种 :
// 1. 用来计算索力 2.用来计算梁体振动 3.用来船撞振动
//由于 船撞/地震振动监测 和 主梁振动监测 都是共用DAAS 无法区分监测类型,通过测点来获取表名
//测点如 CZDZJC001 表=CZDZJC, 测点ZLZDJC001 表=ZLZDJC
tableName := sensorCode[:6]
var sqlBuilder strings.Builder
sensorType := sensorCode[:2]
switch sensorType {
case "SL":
tableName = "XLSSLJC"
slTimeNanosecond := Atime.Add(-8 * time.Hour).UnixNano()
sqlBuilder.WriteString(fmt.Sprintf("%s,sensor_id=%s value=%f %d", tableName, sensorCode, zd.ThemeValue[0], slTimeNanosecond))
default:
switch sensorType {
case "CZ":
tableName = "CZDZJC"
case "ZD":
tableName = "ZLZDJC"
default:
log.Printf("无法识别的 sensorType=%s", sensorType)
}
for i, sensorData := range sensorAccDataList {
timeSpan := i * 1000000000 / zd.Frequency
dataTimeNanosecond := Atime.Add(-8 * time.Hour).Add(time.Nanosecond * time.Duration(timeSpan)).UnixNano()
sqlBuilder.WriteString(fmt.Sprintf("%s,sensor_id=%s value=%f %d", tableName, sensorCode, sensorData, dataTimeNanosecond))
sqlBuilder.WriteString("\n")
}
}
sqlBuilder.WriteString("\n")
sqlStr := sqlBuilder.String()
log.Printf("ZD [%s]-[%s]报文=\n %s... 设备时间%v", zd.Module, sensorCode, utils.LimitStringLength(sqlStr, 200), Atime)
result = []byte(sqlStr)
return result
}
func (the Adaptor_ZD_MYX) getSensorId(rawSensorName string) string {
v, isValid := the.IdMap[rawSensorName]
if !isValid {
v = ""
}
return v
}