hz_crm_api/services/cygx/report_selection.go

package cygx

import (
	"errors"
	"fmt"
	"hongze/hz_crm_api/models/cygx"
	"hongze/hz_crm_api/services/alarm_msg"
	"strings"
	"time"
)

//func init() {
//	UpdateReportSelectionSubjectNameList()
//}

// 获取报告精选最新一期标的名称
func UpdateReportSelectionSubjectNameList() {
	time.Sleep(2 * time.Second)
	var err error
	defer func() {
		if err != nil {
			fmt.Println("err：", err)
			go alarm_msg.SendAlarmMsg("获取报告精选最新一期标的名称，UpdateReportSelectionSubjectNameList Err："+err.Error(), 3)
		}
	}()
	detail, e := cygx.GetCygxReportSelectionInfoBestNew()
	if e != nil {
		err = errors.New("GetCygxReportSelectionInfoBestNew, Err: " + e.Error())
		return
	}

	articleId := detail.ArticleId
	listSelectionLog, e := cygx.GetReportSelectionlogListAll(articleId)
	if e != nil {
		err = errors.New("GetReportSelectionlogListAll, Err: " + e.Error())
		return
	}

	var keyNames []string
	for _, v := range listSelectionLog {
		if v.ThirdName != "" {
			keyNames = append(keyNames, v.ThirdName)
		} else if v.SubjectName != "" {
			keyNames = append(keyNames, v.SubjectName)
		} else {
			keyNames = append(keyNames, v.IndustrialManagementNames)
		}
	}

	keyNameStr := strings.Join(keyNames, ",")
	keyNameStr = strings.Replace(keyNameStr, "/", ",", -1)
	e = cygx.CygxConfigUpdateByCode(keyNameStr, "cygx_report_selection_subject")
	if e != nil {
		err = errors.New("CygxConfigUpdateByCode, Err: " + e.Error())
		return
	}
	return

}