goInOut/adaptors/统一采集to江苏省农村公路桥梁监测.go

package adaptors

import (
	"bytes"
	"encoding/binary"
	"encoding/json"
	"fmt"
	"goInOut/models"
	"goInOut/utils"
	"log"
	"time"
)

// Adaptor_TYCJ_JSNCGLQL  数据 转换 江苏农村公路桥梁监测系统
type Adaptor_TYCJ_JSNCGLQL struct {
	IdMap      map[string]string
	BridgeCode string
}

func (the Adaptor_TYCJ_JSNCGLQL) Transform(inTopic, rawMsg string) []NeedPush {
	tycj := models.TYCJ{}
	json.Unmarshal([]byte(rawMsg), &tycj)
	return the.TYCJtoJSNCGLQL(tycj)
}

func (the Adaptor_TYCJ_JSNCGLQL) TYCJtoJSNCGLQL(tycj models.TYCJ) (result []NeedPush) {
	Atime, err := time.Parse("2006-01-02T15:04:05.000", tycj.SensorData.Time)
	if err != nil {
		log.Printf("统一采集 设备[%s] 数据时间 %s 解析错误", tycj.SensorData.Name, tycj.SensorData.Time)
		return
	}

	var sensorDataList []float32
	switch tycj.SensorData.FactorType {
	case models.TYCJ_FactorType_YLYB, models.TYCJ_FactorType_DTQYB: //应变23,挡土墙应变13    FS-BM50
		sensorDataList = append(sensorDataList, tycj.SensorData.Data.ThemeValues[0])
	case models.TYCJ_FactorType_QDQX: //桥墩倾斜20  X (mm)  Y (mm)
		sensorDataList = append(sensorDataList, tycj.SensorData.Data.ThemeValues[0])
		sensorDataList = append(sensorDataList, tycj.SensorData.Data.ThemeValues[1])
	default:
		log.Printf("监测因素[%d] 无匹配", tycj.SensorData.FactorType)
		return
	}
	var transBytes []byte
	//1.添加时间段
	transBytes = append(transBytes, the.getTimeBytes(Atime)...)
	//2.获取对方系统 id
	sensorCode := the.getSensorCode(tycj.SensorData.Name)
	if sensorCode == "" {
		log.Printf("统一采集 设备[%s] 无匹配的 江苏农村公路桥梁监测系统 测点id,请检查配置文件", tycj.SensorData.Name)
		return
	}

	topic := fmt.Sprintf("data/%s/%s", the.BridgeCode, sensorCode)

	for _, sensorData := range sensorDataList {

		//添加数据值段
		bs := utils.Float32ToBytes(sensorData)
		transBytes = append(transBytes, bs...)
	}
	result = append(result, NeedPush{
		Topic:   topic,
		Payload: transBytes,
	})

	return result
}
func (the Adaptor_TYCJ_JSNCGLQL) getSensorCode(rawSensorName string) string {
	v, isValid := the.IdMap[rawSensorName]
	if !isValid {
		v = ""
	}
	return v
}

func (the Adaptor_TYCJ_JSNCGLQL) getTimeBytes(sensorTime time.Time) []byte {

	year := uint16(sensorTime.Year())
	month := int8(sensorTime.Month())
	day := int8(sensorTime.Day())
	hour := int8(sensorTime.Hour())
	minute := int8(sensorTime.Minute())
	second := int8(sensorTime.Second())
	bytesBuffer := bytes.NewBuffer([]byte{})
	binary.Write(bytesBuffer, binary.BigEndian, year)
	binary.Write(bytesBuffer, binary.BigEndian, month)
	binary.Write(bytesBuffer, binary.BigEndian, day)
	binary.Write(bytesBuffer, binary.BigEndian, hour)
	binary.Write(bytesBuffer, binary.BigEndian, minute)
	binary.Write(bytesBuffer, binary.BigEndian, second)
	return bytesBuffer.Bytes()
}