|
|
@@ -5,6 +5,8 @@ import (
|
|
|
"eta/eta_api/models/data_manage"
|
|
|
"eta/eta_api/utils"
|
|
|
"fmt"
|
|
|
+ "github.com/rdlucklib/rdluck_tools/paging"
|
|
|
+ "strings"
|
|
|
)
|
|
|
|
|
|
// RefreshSourceList
|
|
|
@@ -220,8 +222,6 @@ func (c *EdbInfoController) RefreshClassifyList() {
|
|
|
br.Data = list
|
|
|
}
|
|
|
|
|
|
-// 生成多层级列表的函数
|
|
|
-
|
|
|
// 生成多层级列表的递归函数
|
|
|
func buildTree(items []*data_manage.BaseClassifyItems, parentId int) []*data_manage.BaseClassifyItems {
|
|
|
var result []*data_manage.BaseClassifyItems
|
|
|
@@ -239,3 +239,193 @@ func buildTree(items []*data_manage.BaseClassifyItems, parentId int) []*data_man
|
|
|
|
|
|
return result
|
|
|
}
|
|
|
+
|
|
|
+// RefreshEdbList
|
|
|
+// @Title 获取待配置的指标列表接口
|
|
|
+// @Description 获取待配置的指标列表接口
|
|
|
+// @Param Source query int true "来源:1:同花顺,2:wind,3:彭博"
|
|
|
+// @Param SubSource query int true "来源:0:经济数据库,1:日期序列"
|
|
|
+// @Param ClassifyId query int false "分类ID"
|
|
|
+// @Param TerminalCode query string false "终端编码"
|
|
|
+// @Param SysUserId query string false "创建人"
|
|
|
+// @Param Frequency query string false "频度"
|
|
|
+// @Param Keyword query string false "关键词"
|
|
|
+// @Success 200 {object} data_manage.RefreshBaseEdbInfoResp
|
|
|
+// @router /edb_info/refresh/edb_list [get]
|
|
|
+func (c *EdbInfoController) RefreshEdbList() {
|
|
|
+ br := new(models.BaseResponse).Init()
|
|
|
+
|
|
|
+ defer func() {
|
|
|
+ c.Data["json"] = br
|
|
|
+ c.ServeJSON()
|
|
|
+ }()
|
|
|
+
|
|
|
+ source, _ := c.GetInt("Source")
|
|
|
+ subSource, _ := c.GetInt("SubSource")
|
|
|
+ classifyId, _ := c.GetInt("ClassifyId")
|
|
|
+ terminalCode := c.GetString("TerminalCode")
|
|
|
+ sysUserId := c.GetString("SysUserId")
|
|
|
+ frequency := c.GetString("Frequency")
|
|
|
+ keyword := c.GetString("Keyword")
|
|
|
+
|
|
|
+ pageSize, _ := c.GetInt("PageSize")
|
|
|
+ currentIndex, _ := c.GetInt("CurrentIndex")
|
|
|
+ var startSize int
|
|
|
+
|
|
|
+ if pageSize <= 0 {
|
|
|
+ pageSize = utils.PageSize20
|
|
|
+ }
|
|
|
+ if currentIndex <= 0 {
|
|
|
+ currentIndex = 1
|
|
|
+ }
|
|
|
+ startSize = utils.StartIndex(currentIndex, pageSize)
|
|
|
+
|
|
|
+ var pars []interface{}
|
|
|
+ var condition string
|
|
|
+
|
|
|
+ var total int
|
|
|
+ list := make([]*data_manage.BaseEdbInfo, 0)
|
|
|
+ var err error
|
|
|
+
|
|
|
+ switch source {
|
|
|
+ case utils.DATA_SOURCE_MYSTEEL_CHEMICAL: // 钢联
|
|
|
+ if classifyId > 0 {
|
|
|
+ condition += " AND base_from_mysteel_chemical_classify_id = ? "
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if terminalCode != `` {
|
|
|
+ condition += " AND terminal_code = ? "
|
|
|
+ pars = append(pars, terminalCode)
|
|
|
+ }
|
|
|
+ if sysUserId != `` {
|
|
|
+ sysUserIdSlice := strings.Split(sysUserId, ",")
|
|
|
+ condition += ` AND sys_user_id IN (` + utils.GetOrmInReplace(len(sysUserIdSlice)) + `)`
|
|
|
+ pars = append(pars, sysUserIdSlice)
|
|
|
+ }
|
|
|
+ if frequency != `` {
|
|
|
+ condition += " AND frequency = ? "
|
|
|
+ pars = append(pars, frequency)
|
|
|
+ }
|
|
|
+ if keyword != `` {
|
|
|
+ keywordSlice := strings.Split(keyword, ",")
|
|
|
+ if len(keywordSlice) > 0 {
|
|
|
+ tmpConditionSlice := make([]string, 0)
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` index_name like ? or index_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+
|
|
|
+ for _, v := range keywordSlice {
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` index_name like ? or index_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, v, 2)
|
|
|
+ }
|
|
|
+ condition += ` AND (` + strings.Join(tmpConditionSlice, " or ") + `)`
|
|
|
+
|
|
|
+ } else {
|
|
|
+ condition += ` index_name like ? or index_code like ? `
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ total, list, err = data_manage.GetMysteelChemicalBaseInfo(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取数据失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ case utils.DATA_SOURCE_YS: // 有色
|
|
|
+ if classifyId > 0 {
|
|
|
+ condition += " AND classify_id = ? "
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if terminalCode != `` {
|
|
|
+ condition += " AND terminal_code = ? "
|
|
|
+ pars = append(pars, terminalCode)
|
|
|
+ }
|
|
|
+ if frequency != `` {
|
|
|
+ condition += " AND frequency = ? "
|
|
|
+ pars = append(pars, frequency)
|
|
|
+ }
|
|
|
+ if keyword != `` {
|
|
|
+ keywordSlice := strings.Split(keyword, ",")
|
|
|
+ if len(keywordSlice) > 0 {
|
|
|
+ tmpConditionSlice := make([]string, 0)
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` index_name like ? or index_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+
|
|
|
+ for _, v := range keywordSlice {
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` index_name like ? or index_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, v, 2)
|
|
|
+ }
|
|
|
+ condition += ` AND (` + strings.Join(tmpConditionSlice, " or ") + `)`
|
|
|
+
|
|
|
+ } else {
|
|
|
+ condition += ` index_name like ? or index_code like ? `
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ total, list, err = data_manage.GetSmmBaseInfo(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取数据失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ default:
|
|
|
+ condition += ` AND source = ? AND sub_source = ? `
|
|
|
+ pars = append(pars, source, subSource)
|
|
|
+
|
|
|
+ if classifyId > 0 {
|
|
|
+ condition += " AND classify_id = ? "
|
|
|
+ pars = append(pars, classifyId)
|
|
|
+ }
|
|
|
+ if terminalCode != `` {
|
|
|
+ condition += " AND terminal_code = ? "
|
|
|
+ pars = append(pars, terminalCode)
|
|
|
+ }
|
|
|
+ if sysUserId != `` {
|
|
|
+ sysUserIdSlice := strings.Split(sysUserId, ",")
|
|
|
+ condition += ` AND sys_user_id IN (` + utils.GetOrmInReplace(len(sysUserIdSlice)) + `)`
|
|
|
+ pars = append(pars, sysUserIdSlice)
|
|
|
+ }
|
|
|
+ if frequency != `` {
|
|
|
+ condition += " AND frequency = ? "
|
|
|
+ pars = append(pars, frequency)
|
|
|
+ }
|
|
|
+ if keyword != `` {
|
|
|
+ keywordSlice := strings.Split(keyword, ",")
|
|
|
+ if len(keywordSlice) > 0 {
|
|
|
+ tmpConditionSlice := make([]string, 0)
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` edb_name like ? or edb_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+
|
|
|
+ for _, v := range keywordSlice {
|
|
|
+ tmpConditionSlice = append(tmpConditionSlice, ` edb_name like ? or edb_code like ? `)
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, v, 2)
|
|
|
+ }
|
|
|
+ condition += ` AND (` + strings.Join(tmpConditionSlice, " or ") + `)`
|
|
|
+
|
|
|
+ } else {
|
|
|
+ condition += ` edb_name like ? or edb_code like ? `
|
|
|
+ pars = utils.GetLikeKeywordPars(pars, keyword, 2)
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ total, list, err = data_manage.GetEdbBaseInfo(condition, pars, startSize, pageSize)
|
|
|
+ if err != nil && err.Error() != utils.ErrNoRow() {
|
|
|
+ br.Msg = "获取失败"
|
|
|
+ br.ErrMsg = "获取数据失败，Err:" + err.Error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ page := paging.GetPaging(currentIndex, pageSize, total)
|
|
|
+
|
|
|
+ resp := data_manage.RefreshBaseEdbInfoResp{
|
|
|
+ Paging: page,
|
|
|
+ List: list,
|
|
|
+ }
|
|
|
+
|
|
|
+ br.Ret = 200
|
|
|
+ br.Success = true
|
|
|
+ br.Msg = "获取成功"
|
|
|
+ br.Data = resp
|
|
|
+}
|
