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
}