|
@@ -0,0 +1,1705 @@
|
|
|
+package data_manage
|
|
|
+
|
|
|
+import (
|
|
|
+ "encoding/json"
|
|
|
+ "eta/eta_api/controllers"
|
|
|
+ "eta/eta_api/models"
|
|
|
+ "eta/eta_api/models/data_manage"
|
|
|
+ "eta/eta_api/models/mgo"
|
|
|
+ "eta/eta_api/services/data"
|
|
|
+ "eta/eta_api/utils"
|
|
|
+ "fmt"
|
|
|
+ "github.com/rdlucklib/rdluck_tools/paging"
|
|
|
+ "github.com/shopspring/decimal"
|
|
|
+ "go.mongodb.org/mongo-driver/bson"
|
|
|
+ "sort"
|
|
|
+ "strconv"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+)
|
|
|
+
|
|
|
+
|
|
|
+type BaseFromThsHfController struct {
|
|
|
+ controllers.BaseAuthController
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Search() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfSearchEdbReq
|
|
|
+ if e := this.ParseForm(¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析失败, err: %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.StockCode = strings.TrimSpace(params.StockCode)
|
|
|
+ if params.StockCode == "" {
|
|
|
+ br.Msg = "请输入证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ stockCodes := strings.Split(params.StockCode, ",")
|
|
|
+ if len(stockCodes) == 0 {
|
|
|
+ br.Msg = "请输入证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(stockCodes) > 10 {
|
|
|
+ br.Msg = "最多输入10个证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.EdbCode = strings.TrimSpace(params.EdbCode)
|
|
|
+ if params.EdbCode == "" {
|
|
|
+ br.Msg = "请输入指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbCodes := strings.Split(params.EdbCode, ",")
|
|
|
+ if len(edbCodes) == 0 {
|
|
|
+ br.Msg = "请输入指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(edbCodes) > 20 {
|
|
|
+ br.Msg = "最多选择/输入20个指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.StartTime == "" {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ _, e := time.ParseInLocation(utils.FormatDateTime, params.StartTime, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "起始时间格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("起始时间格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if params.EndTime != "" {
|
|
|
+ _, e := time.ParseInLocation(utils.FormatDateTime, params.EndTime, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "截止时间格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("截止时间格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if params.EndTime == "" {
|
|
|
+ params.EndTime = time.Now().Local().Format(utils.FormatDateTime)
|
|
|
+ }
|
|
|
+ if !utils.InArrayByInt(data_manage.ThsHfPeriodArr, params.Interval) {
|
|
|
+ br.Msg = "时间周期有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("时间周期有误, Interval: %d", params.Interval)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.CPS != "" && !utils.InArrayByStr(data_manage.ThsHfCPSArr, params.CPS) {
|
|
|
+ br.Msg = "复权方式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("复权方式有误, CPS: %s", params.CPS)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.BaseDate != "" {
|
|
|
+ _, e = time.ParseInLocation(utils.FormatDate, params.BaseDate, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "复权基点格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("复权基点格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if params.Fill != "" && !utils.InArrayByStr(data_manage.ThsHfFillArr, params.Fill) {
|
|
|
+ br.Msg = "非交易间隔处理有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("非交易间隔处理有误, Fill: %s", params.Fill)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ checkResp, indexExists, e := data.CheckExistThsHfEdb(stockCodes, edbCodes)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("校验已存在的高频指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(checkResp.ExistIndex) > 0 && checkResp.ExistAll {
|
|
|
+ br.Msg = "指标均已存在"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := make([]*data_manage.ThsHfSearchEdbResp, 0)
|
|
|
+
|
|
|
+
|
|
|
+ indexes, e := data.GetEdbDataThsHf(params)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "未搜索到指标"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取高频指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(indexes) == 0 {
|
|
|
+ br.Msg = "未搜索到指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range indexes {
|
|
|
+
|
|
|
+ k := fmt.Sprintf("%s-%s", v.StockCode, v.EdbCode)
|
|
|
+ if indexExists[k] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ suffix := data_manage.ThsHfEdbCodeCn[v.EdbCode]
|
|
|
+ if suffix == "" {
|
|
|
+ suffix = v.EdbCode
|
|
|
+ }
|
|
|
+ indexName := fmt.Sprintf("%s%dm%s", v.StockCode, params.Interval, suffix)
|
|
|
+
|
|
|
+ item := new(data_manage.ThsHfSearchEdbResp)
|
|
|
+ item.StockCode = v.StockCode
|
|
|
+ item.EdbCode = v.EdbCode
|
|
|
+ item.IndexName = indexName
|
|
|
+ item.Frequency = params.Interval
|
|
|
+
|
|
|
+
|
|
|
+ var limit int
|
|
|
+ sort.Slice(v.IndexData, func(i, j int) bool {
|
|
|
+ return v.IndexData[i].DataTime.After(v.IndexData[j].DataTime)
|
|
|
+ })
|
|
|
+ for _, d := range v.IndexData {
|
|
|
+ if limit > 100 {
|
|
|
+ break
|
|
|
+ }
|
|
|
+ limit += 1
|
|
|
+ strVal := decimal.NewFromFloat(d.Value).Round(4).String()
|
|
|
+ item.IndexData = append(item.IndexData, data_manage.ThsHfSearchEdbData{
|
|
|
+ DataTime: d.DataTime.Format(utils.FormatDateTime),
|
|
|
+ Value: strVal,
|
|
|
+ })
|
|
|
+ }
|
|
|
+ resp = append(resp, item)
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) ExistCheck() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfSearchEdbReq
|
|
|
+ if e := this.ParseForm(¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析失败, err: %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.StockCode = strings.TrimSpace(params.StockCode)
|
|
|
+ if params.StockCode == "" {
|
|
|
+ br.Msg = "请输入证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ stockCodes := strings.Split(params.StockCode, ",")
|
|
|
+ if len(stockCodes) == 0 {
|
|
|
+ br.Msg = "请输入证券代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.EdbCode = strings.TrimSpace(params.EdbCode)
|
|
|
+ if params.EdbCode == "" {
|
|
|
+ br.Msg = "请输入指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ edbCodes := strings.Split(params.EdbCode, ",")
|
|
|
+ if len(edbCodes) == 0 {
|
|
|
+ br.Msg = "请输入指标代码"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ resp, _, e := data.CheckExistThsHfEdb(stockCodes, edbCodes)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("校验已存在的高频指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) List() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexListForm
|
|
|
+ if e := this.ParseForm(¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析失败, err: %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.SortField > 0 && !utils.InArrayByInt([]int{1, 2, 3, 4}, params.SortField) {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, SortField: %d", params.SortField)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.SortType > 0 && !utils.InArrayByInt([]int{1, 2}, params.SortType) {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, SortType: %d", params.SortType)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ resp := new(data_manage.ThsHfIndexPageListResp)
|
|
|
+ resp.List = make([]*data_manage.BaseFromThsHfIndexItem, 0)
|
|
|
+
|
|
|
+
|
|
|
+ classifyOb := new(data_manage.BaseFromThsHfClassify)
|
|
|
+
|
|
|
+ classifyIdItem := make(map[int]*data_manage.BaseFromThsHfClassify)
|
|
|
+ {
|
|
|
+ list, e := classifyOb.GetItemsByCondition(``, make([]interface{}, 0), []string{classifyOb.Cols().PrimaryId, classifyOb.Cols().ClassifyName, classifyOb.Cols().ClassifyNameEn, classifyOb.Cols().LevelPath}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取分类列表失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range list {
|
|
|
+ classifyIdItem[v.BaseFromThsHfClassifyId] = v
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ var (
|
|
|
+ cond string
|
|
|
+ pars []interface{}
|
|
|
+ listOrder string
|
|
|
+ )
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ {
|
|
|
+
|
|
|
+ if params.ClassifyId != "" {
|
|
|
+ classifyIdArr := strings.Split(params.ClassifyId, ",")
|
|
|
+ classifyIds := make([]int, 0)
|
|
|
+ for _, v := range classifyIdArr {
|
|
|
+ t, _ := strconv.Atoi(v)
|
|
|
+ if t > 0 {
|
|
|
+ classifyIds = append(classifyIds, t)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if len(classifyIds) == 0 {
|
|
|
+ page := paging.GetPaging(params.CurrentIndex, params.PageSize, 0)
|
|
|
+ resp.Paging = page
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().BaseFromThsHfClassifyId, utils.GetOrmInReplace(len(classifyIds)))
|
|
|
+ pars = append(pars, classifyIds)
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ if params.Frequency != "" {
|
|
|
+ frequencyArr := strings.Split(params.Frequency, ",")
|
|
|
+ if len(frequencyArr) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().Frequency, utils.GetOrmInReplace(len(frequencyArr)))
|
|
|
+ pars = append(pars, frequencyArr)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if params.SysAdminId != "" {
|
|
|
+ adminIdArr := strings.Split(params.SysAdminId, ",")
|
|
|
+ adminIds := make([]int, 0)
|
|
|
+ for _, v := range adminIdArr {
|
|
|
+ t, _ := strconv.Atoi(v)
|
|
|
+ if t > 0 {
|
|
|
+ adminIds = append(adminIds, t)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if len(adminIds) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().SysUserId, utils.GetOrmInReplace(len(adminIds)))
|
|
|
+ pars = append(pars, adminIds)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ params.Keywords = strings.TrimSpace(params.Keywords)
|
|
|
+ if params.Keywords != "" {
|
|
|
+ cond += fmt.Sprintf(" AND (%s LIKE ? OR %s LIKE ?)", indexOb.Cols().IndexCode, indexOb.Cols().IndexName)
|
|
|
+ kw := fmt.Sprint("%", params.Keywords, "%")
|
|
|
+ pars = append(pars, kw, kw)
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.SortField > 0 && params.SortType > 0 {
|
|
|
+ fieldMap := map[int]string{1: indexOb.Cols().StartDate, 2: indexOb.Cols().EndDate, 3: indexOb.Cols().ModifyTime, 4: indexOb.Cols().LatestValue}
|
|
|
+ typeMap := map[int]string{1: "ASC", 2: "DESC"}
|
|
|
+ listOrder = fmt.Sprintf("%s %s", fieldMap[params.SortField], typeMap[params.SortType])
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ total, e := indexOb.GetCountByCondition(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标总数失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if total <= 0 {
|
|
|
+ page := paging.GetPaging(params.CurrentIndex, params.PageSize, 0)
|
|
|
+ resp.Paging = page
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ var startSize int
|
|
|
+ if params.PageSize <= 0 {
|
|
|
+ params.PageSize = utils.PageSize20
|
|
|
+ }
|
|
|
+ if params.CurrentIndex <= 0 {
|
|
|
+ params.CurrentIndex = 1
|
|
|
+ }
|
|
|
+ startSize = utils.StartIndex(params.CurrentIndex, params.PageSize)
|
|
|
+ items, e := indexOb.GetPageItemsByCondition(cond, pars, []string{}, listOrder, startSize, params.PageSize)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标列表失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range items {
|
|
|
+ t := v.Format2Item()
|
|
|
+
|
|
|
+ classify := classifyIdItem[v.BaseFromThsHfClassifyId]
|
|
|
+ levelArr := make([]string, 0)
|
|
|
+ if classify != nil && classify.LevelPath != "" {
|
|
|
+ arr := strings.Split(classify.LevelPath, ",")
|
|
|
+ for _, a := range arr {
|
|
|
+ i, _ := strconv.Atoi(a)
|
|
|
+ if classifyIdItem[i] != nil {
|
|
|
+ if this.Lang == utils.EnLangVersion {
|
|
|
+ levelArr = append(levelArr, classifyIdItem[i].ClassifyNameEn)
|
|
|
+ } else {
|
|
|
+ levelArr = append(levelArr, classifyIdItem[i].ClassifyName)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ t.ClassifyPath = strings.Join(levelArr, "/")
|
|
|
+ resp.List = append(resp.List, t)
|
|
|
+ }
|
|
|
+
|
|
|
+ page := paging.GetPaging(params.CurrentIndex, params.PageSize, total)
|
|
|
+ resp.Paging = page
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Add() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfAddEdbReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.StartTime == "" {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ _, e := time.ParseInLocation(utils.FormatDateTime, params.StartTime, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "起始时间格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("起始时间格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.EndTime != "" {
|
|
|
+ _, e := time.ParseInLocation(utils.FormatDateTime, params.EndTime, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "截止时间格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("截止时间格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if !utils.InArrayByInt(data_manage.ThsHfPeriodArr, params.Interval) {
|
|
|
+ br.Msg = "时间周期有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("时间周期有误, Interval: %d", params.Interval)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.CPS != "" && !utils.InArrayByStr(data_manage.ThsHfCPSArr, params.CPS) {
|
|
|
+ br.Msg = "复权方式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("复权方式有误, CPS: %s", params.CPS)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.BaseDate != "" {
|
|
|
+ _, e = time.ParseInLocation(utils.FormatDate, params.BaseDate, time.Local)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "复权基点格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("复权基点格式有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if params.Fill != "" && !utils.InArrayByStr(data_manage.ThsHfFillArr, params.Fill) {
|
|
|
+ br.Msg = "非交易间隔处理有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("非交易间隔处理有误, Fill: %s", params.Fill)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(params.IndexList) == 0 {
|
|
|
+ br.Msg = "请选择指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ formExist := make(map[string]bool)
|
|
|
+ indexNames := make([]string, 0)
|
|
|
+ classifyIds := make([]int, 0)
|
|
|
+ for _, v := range params.IndexList {
|
|
|
+ if v.ClassifyId <= 0 {
|
|
|
+ br.Msg = "请选择分类"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if !utils.InArrayByInt(classifyIds, v.ClassifyId) {
|
|
|
+ classifyIds = append(classifyIds, v.ClassifyId)
|
|
|
+ }
|
|
|
+ if v.Unit == "" {
|
|
|
+ br.Msg = "请输入单位"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ v.IndexName = strings.TrimSpace(v.IndexName)
|
|
|
+ if v.IndexName == "" {
|
|
|
+ br.Msg = "请输入指标名称"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if formExist[v.IndexName] {
|
|
|
+ br.Msg = "指标名称重复, 请重新输入"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ formExist[v.IndexName] = true
|
|
|
+ indexNames = append(indexNames, v.IndexName)
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ classifyOb := new(data_manage.BaseFromThsHfClassify)
|
|
|
+ {
|
|
|
+ cond := fmt.Sprintf(` AND %s IN (%s)`, classifyOb.Cols().PrimaryId, utils.GetOrmInReplace(len(classifyIds)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, classifyIds)
|
|
|
+ list, e := classifyOb.GetItemsByCondition(cond, pars, []string{classifyOb.Cols().PrimaryId, classifyOb.Cols().ClassifyName}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("查询分类失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ classifyMap := make(map[int]*data_manage.BaseFromThsHfClassify)
|
|
|
+ for _, v := range list {
|
|
|
+ classifyMap[v.BaseFromThsHfClassifyId] = v
|
|
|
+ }
|
|
|
+ for _, v := range params.IndexList {
|
|
|
+ t := classifyMap[v.ClassifyId]
|
|
|
+ if t == nil {
|
|
|
+ br.Msg = fmt.Sprintf("%s分类不存在, 请重新选择或刷新页面", t.ClassifyName)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ {
|
|
|
+ cond := fmt.Sprintf(` AND %s IN (%s)`, indexOb.Cols().IndexName, utils.GetOrmInReplace(len(indexNames)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, indexNames)
|
|
|
+ list, e := indexOb.GetItemsByCondition(cond, pars, []string{indexOb.Cols().IndexName}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("查询指标名称失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(list) > 0 {
|
|
|
+ tips := "以下指标名称重复, 请重新输入: \n"
|
|
|
+ for _, v := range list {
|
|
|
+ tips += fmt.Sprintf("%s\n", v.IndexName)
|
|
|
+ }
|
|
|
+ br.Msg = tips
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ for _, v := range params.IndexList {
|
|
|
+ var req data_manage.ThsHfBaseAddReq
|
|
|
+ req.StartTime = params.StartTime
|
|
|
+ req.EndTime = params.EndTime
|
|
|
+ req.Interval = params.Interval
|
|
|
+ req.Fill = params.Fill
|
|
|
+ req.CPS = params.CPS
|
|
|
+ req.BaseDate = params.BaseDate
|
|
|
+ req.SysAdminId = sysUser.AdminId
|
|
|
+ req.SysAdminName = sysUser.RealName
|
|
|
+ req.ClassifyId = v.ClassifyId
|
|
|
+ req.Unit = v.Unit
|
|
|
+ req.IndexName = v.IndexName
|
|
|
+ req.Frequency = v.Frequency
|
|
|
+ req.StockCode = v.StockCode
|
|
|
+ req.EdbCode = v.EdbCode
|
|
|
+ _, e = data.BaseAddThsHf(req)
|
|
|
+ if e != nil {
|
|
|
+ utils.FileLog.Info(fmt.Sprintf("BaseAddThsHf err: %v", e))
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Edit() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexEditReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.IndexId <= 0 {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, IndexId: %d", params.IndexId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.IndexName = strings.TrimSpace(params.IndexName)
|
|
|
+ if params.IndexName == "" {
|
|
|
+ br.Msg = "请输入指标名称"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.ClassifyId <= 0 {
|
|
|
+ br.Msg = "请选择分类"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ params.Unit = strings.TrimSpace(params.Unit)
|
|
|
+ if params.Unit == "" {
|
|
|
+ br.Msg = "请输入单位"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ item, e := indexOb.GetItemById(params.IndexId)
|
|
|
+ if e != nil {
|
|
|
+ if e.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "指标不存在, 请刷新页面"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ classifyOb := new(data_manage.BaseFromThsHfClassify)
|
|
|
+ _, e = classifyOb.GetItemById(params.ClassifyId)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "分类有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("分类信息有误, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ {
|
|
|
+ cond := fmt.Sprintf(" AND %s = ? AND %s <> ?", indexOb.Cols().IndexName, indexOb.Cols().PrimaryId)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, params.IndexName, params.IndexId)
|
|
|
+ count, e := indexOb.GetCountByCondition(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取重名指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if count > 0 {
|
|
|
+ br.Msg = "指标名称已存在, 请重新输入"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ item.IndexName = params.IndexName
|
|
|
+ item.BaseFromThsHfClassifyId = params.ClassifyId
|
|
|
+ item.Unit = params.Unit
|
|
|
+ item.ModifyTime = time.Now().Local()
|
|
|
+ updateCols := []string{item.Cols().IndexName, item.Cols().BaseFromThsHfClassifyId, item.Cols().Unit, item.Cols().ModifyTime}
|
|
|
+ if e = item.Update(updateCols); e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("更新指标信息失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Detail() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ indexId, _ := this.GetInt("IndexId")
|
|
|
+ if indexId <= 0 {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, IndexId: %d", indexId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ dataDate := this.GetString("DataDate")
|
|
|
+ if dataDate != "" {
|
|
|
+ _, e := time.Parse(utils.FormatDate, dataDate)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "数据日期格式有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("数据日期格式有误, DataDate: %s", dataDate)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ item, e := indexOb.GetItemById(indexId)
|
|
|
+ if e != nil {
|
|
|
+ if e.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "指标不存在, 请刷新页面"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ indexItem := item.Format2Item()
|
|
|
+ if item.EndDate.IsZero() {
|
|
|
+ item.EndDate = time.Now()
|
|
|
+ }
|
|
|
+
|
|
|
+ if dataDate == "" {
|
|
|
+ dataDate = item.EndDate.Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ startTime := fmt.Sprintf("%s 00:00:00", dataDate)
|
|
|
+ endTime := fmt.Sprintf("%s 23:59:59", dataDate)
|
|
|
+
|
|
|
+
|
|
|
+ dataList, e := data.GetThsHfBaseIndexData(indexItem.IndexCode, startTime, endTime)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标数据失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ type DetailResp struct {
|
|
|
+ Index *data_manage.BaseFromThsHfIndexItem
|
|
|
+ DataDate string `description:"数据日期"`
|
|
|
+ DataList []*data_manage.BaseFromThsHfDataItem
|
|
|
+ }
|
|
|
+ resp := new(DetailResp)
|
|
|
+ resp.Index = indexItem
|
|
|
+ resp.DataDate = dataDate
|
|
|
+ resp.DataList = dataList
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Refresh() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexOptReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.IndexId <= 0 {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, IndexId: %d", params.IndexId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ _, e := indexOb.GetItemById(params.IndexId)
|
|
|
+ if e != nil {
|
|
|
+ if e.Error() == utils.ErrNoRow() {
|
|
|
+ br.Msg = "指标不存在, 请刷新页面"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ indexIds := []int{params.IndexId}
|
|
|
+ _, e = data.RefreshBaseThsHfIndex(indexIds, 1)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "刷新失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("刷新指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Remove() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexOptReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.IndexId <= 0 {
|
|
|
+ br.Msg = "参数有误"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数有误, IndexId: %d", params.IndexId)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ item, e := indexOb.GetItemById(params.IndexId)
|
|
|
+ if e != nil {
|
|
|
+ if e.Error() == utils.ErrNoRow() {
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ edbMappingOb := new(data_manage.BaseFromEdbMapping)
|
|
|
+ {
|
|
|
+ cond := fmt.Sprintf(" AND %s = ?", edbMappingOb.Cols().BaseIndexCode)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, item.IndexCode)
|
|
|
+ count, e := edbMappingOb.GetCountByCondition(cond, pars)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取源指标关联失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if count > 0 {
|
|
|
+ br.Msg = "指标已被引用, 不允许删除"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if e = item.Remove(); e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("删除指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if utils.UseMongo {
|
|
|
+ mogDataObj := mgo.BaseFromThsHfData{}
|
|
|
+ if e = mogDataObj.RemoveMany(bson.M{"index_code": item.IndexCode}); e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("删除指标数据失败-Mgo, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ dataOb := new(data_manage.BaseFromThsHfData)
|
|
|
+ cond := fmt.Sprintf(" %s = ?", dataOb.Cols().BaseFromThsHfIndexId)
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, params.IndexId)
|
|
|
+ if e = dataOb.RemoveByCondition(cond, pars); e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("删除指标数据失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) ListChoice() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexListChoiceReq
|
|
|
+ if e := this.ParseForm(¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析失败, err: %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var listIds []int
|
|
|
+ if params.ListIds != "" {
|
|
|
+ strArr := strings.Split(params.ListIds, ",")
|
|
|
+ for _, v := range strArr {
|
|
|
+ t, _ := strconv.Atoi(v)
|
|
|
+ if t > 0 {
|
|
|
+ listIds = append(listIds, t)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ var (
|
|
|
+ cond string
|
|
|
+ pars []interface{}
|
|
|
+ )
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ resp := make([]*data_manage.ThsHfIndexListChoiceItem, 0)
|
|
|
+
|
|
|
+
|
|
|
+ if !params.SelectAll {
|
|
|
+ if len(listIds) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().PrimaryId, utils.GetOrmInReplace(len(listIds)))
|
|
|
+ pars = append(pars, listIds)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.SelectAll {
|
|
|
+
|
|
|
+ classifyOb := new(data_manage.BaseFromThsHfClassify)
|
|
|
+ classifies := make([]*data_manage.BaseFromThsHfClassify, 0)
|
|
|
+ classifyIdItem := make(map[int]*data_manage.BaseFromThsHfClassify)
|
|
|
+ {
|
|
|
+ list, e := classifyOb.GetItemsByCondition(``, make([]interface{}, 0), []string{classifyOb.Cols().PrimaryId, classifyOb.Cols().ClassifyName, classifyOb.Cols().ClassifyNameEn, classifyOb.Cols().LevelPath}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取分类列表失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range list {
|
|
|
+ classifyIdItem[v.BaseFromThsHfClassifyId] = v
|
|
|
+ }
|
|
|
+ classifies = list
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.ClassifyId != "" {
|
|
|
+ classifyIdArr := strings.Split(params.ClassifyId, ",")
|
|
|
+ classifyIds := make([]int, 0)
|
|
|
+ for _, v := range classifyIdArr {
|
|
|
+ t, _ := strconv.Atoi(v)
|
|
|
+ if t > 0 {
|
|
|
+ classifyIds = append(classifyIds, t)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if len(classifyIds) > 0 && !params.IncludeChild {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().BaseFromThsHfClassifyId, utils.GetOrmInReplace(len(classifyIds)))
|
|
|
+ pars = append(pars, classifyIds)
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if len(classifyIds) > 0 && params.IncludeChild {
|
|
|
+ queryClassifyIds := make([]int, 0)
|
|
|
+ queryClassifyExist := make(map[int]bool)
|
|
|
+
|
|
|
+ for _, v := range classifyIds {
|
|
|
+
|
|
|
+ for _, cv := range classifies {
|
|
|
+ if queryClassifyExist[cv.BaseFromThsHfClassifyId] {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ if cv.LevelPath == "" {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ strArr := strings.Split(cv.LevelPath, ",")
|
|
|
+ if len(strArr) == 0 {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ for _, sv := range strArr {
|
|
|
+ tv, _ := strconv.Atoi(sv)
|
|
|
+ if tv == v {
|
|
|
+ queryClassifyIds = append(queryClassifyIds, cv.BaseFromThsHfClassifyId)
|
|
|
+ queryClassifyExist[cv.BaseFromThsHfClassifyId] = true
|
|
|
+ break
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(queryClassifyIds) == 0 {
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().BaseFromThsHfClassifyId, utils.GetOrmInReplace(len(queryClassifyIds)))
|
|
|
+ pars = append(pars, queryClassifyIds)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if params.Frequency != "" {
|
|
|
+ frequencyArr := strings.Split(params.Frequency, ",")
|
|
|
+ if len(frequencyArr) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().Frequency, utils.GetOrmInReplace(len(frequencyArr)))
|
|
|
+ pars = append(pars, frequencyArr)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if params.SysAdminId != "" {
|
|
|
+ adminIdArr := strings.Split(params.SysAdminId, ",")
|
|
|
+ adminIds := make([]int, 0)
|
|
|
+ for _, v := range adminIdArr {
|
|
|
+ t, _ := strconv.Atoi(v)
|
|
|
+ if t > 0 {
|
|
|
+ adminIds = append(adminIds, t)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if len(adminIds) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().SysUserId, utils.GetOrmInReplace(len(adminIds)))
|
|
|
+ pars = append(pars, adminIds)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ params.Keywords = strings.TrimSpace(params.Keywords)
|
|
|
+ if params.Keywords != "" {
|
|
|
+ cond += fmt.Sprintf(" AND (%s LIKE ? OR %s LIKE ?)", indexOb.Cols().IndexCode, indexOb.Cols().IndexName)
|
|
|
+ kw := fmt.Sprint("%", params.Keywords, "%")
|
|
|
+ pars = append(pars, kw, kw)
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if len(listIds) > 0 {
|
|
|
+ cond += fmt.Sprintf(" AND %s NOT IN (%s)", indexOb.Cols().PrimaryId, utils.GetOrmInReplace(len(listIds)))
|
|
|
+ pars = append(pars, listIds)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ fields := []string{indexOb.Cols().PrimaryId, indexOb.Cols().IndexCode, indexOb.Cols().IndexName}
|
|
|
+ list, e := indexOb.GetItemsByCondition(cond, pars, fields, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(list) > 500 {
|
|
|
+ br.Msg = "选择指标超过500个, 请重新选择"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range list {
|
|
|
+ resp = append(resp, &data_manage.ThsHfIndexListChoiceItem{
|
|
|
+ IndexId: v.BaseFromThsHfIndexId,
|
|
|
+ IndexCode: v.IndexCode,
|
|
|
+ IndexName: v.IndexName,
|
|
|
+ })
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) MultiOpt() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexMultiOptReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if !utils.InArrayByInt([]int{1, 2, 3}, params.OptType) {
|
|
|
+ br.Msg = "请选择操作类型"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(params.IndexIds) == 0 {
|
|
|
+ br.Msg = "请选择指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.OptType == 1 && params.MoveClassifyId <= 0 {
|
|
|
+ br.Msg = "请选择分类"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if params.OptType == 3 && !utils.InArrayByInt([]int{1, 2}, params.RefreshType) {
|
|
|
+ br.Msg = "请选择刷新方式"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ resp := new(data_manage.ThsHfIndexMultiOptResp)
|
|
|
+
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ indexMap := make(map[int]*data_manage.BaseFromThsHfIndex)
|
|
|
+ {
|
|
|
+ cond := fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().PrimaryId, utils.GetOrmInReplace(len(params.IndexIds)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, params.IndexIds)
|
|
|
+ list, e := indexOb.GetItemsByCondition(cond, pars, []string{indexOb.Cols().PrimaryId, indexOb.Cols().IndexCode, indexOb.Cols().IndexName}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "删除失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取源指标列表失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range list {
|
|
|
+ indexMap[v.BaseFromThsHfIndexId] = v
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.OptType == 1 {
|
|
|
+ if e := indexOb.UpdateClassifyMulti(params.IndexIds, params.MoveClassifyId); e != nil {
|
|
|
+ br.Msg = "移动失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("批量移动分类失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.OptType == 2 {
|
|
|
+
|
|
|
+ usedIndexIds := make([]int, 0)
|
|
|
+ {
|
|
|
+ edbMappingOb := new(data_manage.BaseFromEdbMapping)
|
|
|
+ cond := fmt.Sprintf(" AND %s IN (%s)", edbMappingOb.Cols().BaseFromIndexId, utils.GetOrmInReplace(len(params.IndexIds)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, params.IndexIds)
|
|
|
+ list, e := edbMappingOb.GetItemsByCondition(cond, pars, []string{}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "删除失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取源指标关联失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range list {
|
|
|
+ if !utils.InArrayByInt(usedIndexIds, v.BaseFromIndexId) {
|
|
|
+ usedIndexIds = append(usedIndexIds, v.BaseFromIndexId)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ removeIndexIds := params.IndexIds
|
|
|
+ if len(usedIndexIds) > 0 {
|
|
|
+ removeIndexIds = utils.MinusInt(params.IndexIds, usedIndexIds)
|
|
|
+
|
|
|
+
|
|
|
+ for _, v := range usedIndexIds {
|
|
|
+ t := indexMap[v]
|
|
|
+ if t == nil {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ resp.Fail = append(resp.Fail, &data_manage.ThsHfIndexBaseInfo{
|
|
|
+ IndexId: v,
|
|
|
+ IndexCode: t.IndexCode,
|
|
|
+ IndexName: t.IndexName,
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if len(removeIndexIds) > 0 {
|
|
|
+ if e := indexOb.MultiRemove(removeIndexIds); e != nil {
|
|
|
+ br.Msg = "删除失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("批量删除指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if utils.UseMongo {
|
|
|
+ mogDataObj := mgo.BaseFromThsHfData{}
|
|
|
+ for _, v := range removeIndexIds {
|
|
|
+ if e := mogDataObj.RemoveMany(bson.M{"base_from_ths_hf_index_id": v}); e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("批量删除指标数据失败-Mgo, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ dataOb := new(data_manage.BaseFromThsHfData)
|
|
|
+ cond := fmt.Sprintf(" %s IN (%s)", dataOb.Cols().BaseFromThsHfIndexId, utils.GetOrmInReplace(len(removeIndexIds)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, removeIndexIds)
|
|
|
+ if e := dataOb.RemoveByCondition(cond, pars); e != nil {
|
|
|
+ br.Msg = "删除失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("批量删除指标数据失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ for _, v := range removeIndexIds {
|
|
|
+ t := indexMap[v]
|
|
|
+ if t == nil {
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ resp.Success = append(resp.Success, &data_manage.ThsHfIndexBaseInfo{
|
|
|
+ IndexId: v,
|
|
|
+ IndexCode: t.IndexCode,
|
|
|
+ IndexName: t.IndexName,
|
|
|
+ })
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ if params.OptType == 3 {
|
|
|
+ isAsync, e := data.RefreshBaseThsHfIndex(params.IndexIds, params.RefreshType)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "刷新失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("批量刷新指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if isAsync {
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功, 刷新指标较多, 请10分钟后查看"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Save2EdbPre() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexMultiSave2EdbPreReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(params.IndexIds) == 0 {
|
|
|
+ br.Msg = "请选择指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ convertRule := params.ConvertRule
|
|
|
+ if convertRule.ConvertType != 1 && convertRule.ConvertType != 2 {
|
|
|
+ br.Msg = "请选择数据转换方式"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ var (
|
|
|
+ suffixName string
|
|
|
+ startTimeCn string
|
|
|
+ endTimeCn string
|
|
|
+ calculateCn string
|
|
|
+ )
|
|
|
+ dayMap := map[int]string{1: "当日", 2: "前日"}
|
|
|
+ calculateMap := map[int]string{1: "均值", 2: "最大值", 3: "最小值"}
|
|
|
+ if convertRule.ConvertType == 1 {
|
|
|
+ if convertRule.ConvertFixed.FixedDay != 1 && convertRule.ConvertFixed.FixedDay != 2 {
|
|
|
+ br.Msg = "请选择指定时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertFixed.FixedTime == "" {
|
|
|
+ br.Msg = "请选择指定时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ timePrefix := time.Now().Local().Format(utils.FormatDate)
|
|
|
+ st := fmt.Sprintf("%s %s", timePrefix, convertRule.ConvertFixed.FixedTime)
|
|
|
+ startTime, e := time.Parse(utils.FormatDateTime, st)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "指定时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ startTimeCn = fmt.Sprintf("%s%s", dayMap[convertRule.ConvertFixed.FixedDay], startTime.Format("15点04"))
|
|
|
+ }
|
|
|
+ if convertRule.ConvertType == 2 {
|
|
|
+ if convertRule.ConvertArea.StartDay != 1 && convertRule.ConvertArea.StartDay != 2 {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.StartTime == "" {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var startTimePre string
|
|
|
+ if convertRule.ConvertArea.StartDay == 1 {
|
|
|
+ startTimePre = time.Now().Local().Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.StartDay == 2 {
|
|
|
+ startTimePre = time.Now().Local().AddDate(0, 0, -1).Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ st := fmt.Sprintf("%s %s", startTimePre, convertRule.ConvertArea.StartTime)
|
|
|
+ startTime, e := time.Parse(utils.FormatDateTime, st)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "起始时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ startTimeCn = fmt.Sprintf("%s%s", dayMap[convertRule.ConvertArea.StartDay], startTime.Format("15点04"))
|
|
|
+
|
|
|
+ if convertRule.ConvertArea.EndDay != 1 && convertRule.ConvertArea.EndDay != 2 {
|
|
|
+ br.Msg = "请选择截止时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.EndTime == "" {
|
|
|
+ br.Msg = "请选择截止时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var endTimePre string
|
|
|
+ if convertRule.ConvertArea.EndDay == 1 {
|
|
|
+ endTimePre = time.Now().Local().Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.EndDay == 2 {
|
|
|
+ endTimePre = time.Now().Local().AddDate(0, 0, -1).Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ ed := fmt.Sprintf("%s %s", endTimePre, convertRule.ConvertArea.EndTime)
|
|
|
+ endTime, e := time.Parse(utils.FormatDateTime, ed)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "截止时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ endTimeCn = fmt.Sprintf("至%s%s", dayMap[convertRule.ConvertArea.EndDay], endTime.Format("15点04"))
|
|
|
+ if startTime.After(endTime) {
|
|
|
+ br.Msg = "起始日期不可早于截止日期"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ calculateCn = calculateMap[convertRule.ConvertArea.CalculateType]
|
|
|
+ }
|
|
|
+ suffixName = fmt.Sprint(startTimeCn, endTimeCn, calculateCn)
|
|
|
+
|
|
|
+
|
|
|
+ indexOb := new(data_manage.BaseFromThsHfIndex)
|
|
|
+ cond := fmt.Sprintf(" AND %s IN (%s)", indexOb.Cols().PrimaryId, utils.GetOrmInReplace(len(params.IndexIds)))
|
|
|
+ pars := make([]interface{}, 0)
|
|
|
+ pars = append(pars, params.IndexIds)
|
|
|
+ list, e := indexOb.GetItemsByCondition(cond, pars, []string{}, "")
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ resp := make([]*data_manage.ThsHfIndexMultiSave2EdbPreItem, 0)
|
|
|
+ for _, v := range list {
|
|
|
+ t := new(data_manage.ThsHfIndexMultiSave2EdbPreItem)
|
|
|
+ t.IndexId = v.BaseFromThsHfIndexId
|
|
|
+ t.IndexCode = v.IndexCode
|
|
|
+ t.IndexName = v.IndexName
|
|
|
+ edbCn := data_manage.ThsHfEdbCodeCn[v.Indicator]
|
|
|
+ if edbCn == "" {
|
|
|
+ edbCn = v.Indicator
|
|
|
+ }
|
|
|
+ t.NewIndexName = fmt.Sprint(v.StockCode, v.Frequency, edbCn, suffixName)
|
|
|
+ t.StockCode = v.StockCode
|
|
|
+ t.EdbCode = v.Indicator
|
|
|
+ t.Unit = v.Unit
|
|
|
+ t.Frequency = v.Frequency
|
|
|
+ t.NewFrequency = "日度"
|
|
|
+ resp = append(resp, t)
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func (this *BaseFromThsHfController) Save2Edb() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+ defer func() {
|
|
|
+ if br.ErrMsg == "" {
|
|
|
+ br.IsSendEmail = false
|
|
|
+ }
|
|
|
+ this.Data["json"] = br
|
|
|
+ this.ServeJSON()
|
|
|
+ }()
|
|
|
+ sysUser := this.SysUser
|
|
|
+ if sysUser == nil {
|
|
|
+ br.Msg = "请登录"
|
|
|
+ br.ErrMsg = "请登录,SysUser Is Empty"
|
|
|
+ br.Ret = 408
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var params data_manage.ThsHfIndexMultiSave2EdbReq
|
|
|
+ if e := json.Unmarshal(this.Ctx.Input.RequestBody, ¶ms); e != nil {
|
|
|
+ br.Msg = "参数解析异常"
|
|
|
+ br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if len(params.NewIndexes) == 0 {
|
|
|
+ br.Msg = "请选择指标"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ convertRule := params.ConvertRule
|
|
|
+ if convertRule.ConvertType != 1 && convertRule.ConvertType != 2 {
|
|
|
+ br.Msg = "请选择数据转换方式"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertType == 1 {
|
|
|
+ if convertRule.ConvertFixed.FixedDay != 1 && convertRule.ConvertFixed.FixedDay != 2 {
|
|
|
+ br.Msg = "请选择指定时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertFixed.FixedTime == "" {
|
|
|
+ br.Msg = "请选择指定时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ timePrefix := time.Now().Local().Format(utils.FormatDate)
|
|
|
+ st := fmt.Sprintf("%s %s", timePrefix, convertRule.ConvertFixed.FixedTime)
|
|
|
+ _, e := time.Parse(utils.FormatDateTime, st)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "指定时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if convertRule.ConvertType == 2 {
|
|
|
+ if convertRule.ConvertArea.StartDay != 1 && convertRule.ConvertArea.StartDay != 2 {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.StartTime == "" {
|
|
|
+ br.Msg = "请选择起始时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var startTimePre string
|
|
|
+ if convertRule.ConvertArea.StartDay == 1 {
|
|
|
+ startTimePre = time.Now().Local().Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.StartDay == 2 {
|
|
|
+ startTimePre = time.Now().Local().AddDate(0, 0, -1).Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ st := fmt.Sprintf("%s %s", startTimePre, convertRule.ConvertArea.StartTime)
|
|
|
+ startTime, e := time.Parse(utils.FormatDateTime, st)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "起始时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ if convertRule.ConvertArea.EndDay != 1 && convertRule.ConvertArea.EndDay != 2 {
|
|
|
+ br.Msg = "请选择截止时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.EndTime == "" {
|
|
|
+ br.Msg = "请选择截止时间"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ var endTimePre string
|
|
|
+ if convertRule.ConvertArea.EndDay == 1 {
|
|
|
+ endTimePre = time.Now().Local().Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ if convertRule.ConvertArea.EndDay == 2 {
|
|
|
+ endTimePre = time.Now().Local().AddDate(0, 0, -1).Format(utils.FormatDate)
|
|
|
+ }
|
|
|
+ ed := fmt.Sprintf("%s %s", endTimePre, convertRule.ConvertArea.EndTime)
|
|
|
+ endTime, e := time.Parse(utils.FormatDateTime, ed)
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "截止时间格式有误"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ if startTime.After(endTime) {
|
|
|
+ br.Msg = "起始日期不可早于截止日期"
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ resp := new(data_manage.ThsHfIndexMultiSave2EdbResp)
|
|
|
+
|
|
|
+
|
|
|
+ edbNameExist := make(map[string]bool)
|
|
|
+ {
|
|
|
+ items, e := data_manage.GetEdbInfoFieldList(``, make([]interface{}, 0), []string{"edb_name"})
|
|
|
+ if e != nil {
|
|
|
+ br.Msg = "操作失败"
|
|
|
+ br.ErrMsg = fmt.Sprintf("获取指标名称列表失败, %v", e)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ for _, v := range items {
|
|
|
+ edbNameExist[v.EdbName] = true
|
|
|
+ }
|
|
|
+ }
|
|
|
+ for _, v := range params.NewIndexes {
|
|
|
+ if edbNameExist[v.NewIndexName] {
|
|
|
+ resp.Exist = append(resp.Exist, v)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if len(resp.Exist) > 0 {
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "含重复指标名称"
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ for _, v := range params.NewIndexes {
|
|
|
+ var r data_manage.ThsHfIndexMultiSave2EdbLibReq
|
|
|
+ r.ConvertRule = convertRule
|
|
|
+ v.SysAdminId = sysUser.AdminId
|
|
|
+ v.SysAdminName = sysUser.RealName
|
|
|
+ r.NewIndex = v
|
|
|
+ b, e := json.Marshal(r)
|
|
|
+ if e != nil {
|
|
|
+ v.Tips = "新增失败"
|
|
|
+ v.ErrMsg = e.Error()
|
|
|
+ resp.Fail = append(resp.Fail, v)
|
|
|
+ continue
|
|
|
+ }
|
|
|
+
|
|
|
+ res, e := data.AddBaseEdbInfo(string(b), utils.DATA_SOURCE_THS, utils.DATA_SUB_SOURCE_HIGH_FREQUENCY, this.Lang)
|
|
|
+ if e != nil {
|
|
|
+ v.Tips = "新增失败"
|
|
|
+ v.ErrMsg = fmt.Sprintf("AddBaseEdbInfo, err: %v", e)
|
|
|
+ resp.Fail = append(resp.Fail, v)
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ if res.Ret != 200 {
|
|
|
+ v.Tips = res.Msg
|
|
|
+ v.ErrMsg = fmt.Sprintf("AddBaseEdbInfo, Ret: %d, ErrMsg: %s", res.Ret, res.ErrMsg)
|
|
|
+ resp.Fail = append(resp.Fail, v)
|
|
|
+ continue
|
|
|
+ }
|
|
|
+ v.Tips = "新增成功"
|
|
|
+ resp.Success = append(resp.Success, v)
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Data = resp
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "操作成功"
|
|
|
+}
|