123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179 |
- package data
- import (
- "encoding/json"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/http"
- "hongze/hz_crm_api/models/data_manage"
- "hongze/hz_crm_api/utils"
- "reflect"
- "strings"
- "time"
- )
- type EdbDataFromLt struct {
- Close map[int64]interface{} `json:"CLOSE"`
- }
- func GetEdbDataByLt(edbCode, startDate, endDate string) (searchItem *data_manage.EdbInfoSearch, err error) {
-
- ltDataList, err := QueryEdbDataByLt(edbCode, startDate, endDate)
- if err != nil {
- return
- }
- searchItem = new(data_manage.EdbInfoSearch)
- searchItem.EdbCode = edbCode
- if len(ltDataList) > 0 {
- var isAdd bool
- addSql := ` INSERT INTO edb_data_lt(edb_info_id,edb_code,data_time,value,create_time,modify_time,status,data_timestamp) values `
- nowStr := time.Now().Format(utils.FormatDateTime)
- dataList := make([]*data_manage.EdbInfoSearchData, 0)
- for timestampInt, edbValue := range ltDataList {
- dataTime := time.Unix(timestampInt/1000, 0)
-
- valType := reflect.TypeOf(edbValue)
- if valType == nil {
- continue
- }
- if valType.String() != "float64" {
- continue
- }
- sValue := edbValue.(float64)
- eDate := dataTime.Format(utils.FormatDate)
- if err != nil {
- return nil, err
- }
- timestamp := dataTime.UnixNano() / 1e6
- timeStr := fmt.Sprintf("%d", timestamp)
- addSql += "("
- addSql += "0," + "'" + edbCode + "'" + "," + "'" + eDate + "'" + "," + utils.SubFloatToString(sValue, 20) + "," + "'" + nowStr + "'" +
- "," + "'" + nowStr + "'" + "," + "0" + "," + "'" + timeStr + "'"
- addSql += "),"
- isAdd = true
- }
- if isAdd {
- addSql = strings.TrimRight(addSql, ",")
- err = data_manage.AddEdbDataLtBySql(addSql)
- if err != nil {
- utils.FileLogData.Info("AddEdbDataLtBySql Err:%s", err.Error())
- return
- }
- }
- size := utils.EDB_DATA_LIMIT
- dataList, err := data_manage.GetEdbDataAllByEdbCode(edbCode, utils.DATA_SOURCE_LT, size)
- if err != nil {
- utils.FileLogData.Info("GetEdbDataLtByCode Err:%s", err.Error())
- return searchItem, err
- }
- edbInfoMaxAndMinInfo, err := data_manage.GetEdbInfoMaxAndMinInfo(utils.DATA_SOURCE_LT, edbCode)
- if err != nil {
- return searchItem, err
- }
- searchItem.DataList = dataList
- searchItem.StartDate = edbInfoMaxAndMinInfo.MinDate
- searchItem.EndDate = edbInfoMaxAndMinInfo.MaxDate
- }
- if searchItem.DataList == nil {
- searchItem.DataList = make([]*data_manage.EdbInfoSearchData, 0)
- }
- return
- }
- func RefreshEdbDataByLt(edbInfoId int, edbCode, startDate, endDate string) (err error) {
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- return
- }
- func QueryEdbDataByLt(edbCode, startDate, endDate string) (dataList map[int64]interface{}, err error) {
- dataList = make(map[int64]interface{})
- ltUrl := utils.Hz_Data_LT_Url + `edbInfo/ek?EdbCode=%s&StartDate=%s&EndDate=%s`
- ltUrl = fmt.Sprintf(ltUrl, edbCode, startDate, endDate)
- utils.FileLogData.Info("ltUrl:%s", ltUrl)
- body, err := http.Get(ltUrl)
- utils.FileLogData.Info("lt result:%s", string(body))
- if err != nil {
- return
- }
-
- item := new(EdbDataFromLt)
- err = json.Unmarshal(body, &item)
- if err != nil {
- return
- }
- dataList = item.Close
- return
- }
|