no message

controllers/cygx/rai_serve.go

@@ -0,0 +1,108 @@
+package cygx
+
+import (
+	"hongze/hz_crm_api/controllers"
+	"hongze/hz_crm_api/models"
+	"hongze/hz_crm_api/models/cygx"
+	"strings"
+)
+
+// 权益服务类型
+type RaiServeCoAntroller struct {
+	controllers.BaseAuthController
+}
+
+// @Title 服务类型列表
+// @Description 服务类型列表接口
+// @Success 200 {object} cygx.RaiServeTypeListResp
+// @router /rai_serve/type_list [get]
+func (this *RaiServeCoAntroller) TypeList() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	sysUser := this.SysUser
+	if sysUser == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	resp := new(cygx.RaiServeTypeListResp)
+	var condition string
+	list, err := cygx.GetRaiServeTypeRespList(condition)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "获取数据失败，Err:" + err.Error()
+		return
+	}
+	resp.List = list
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}
+
+// @Title 标签搜索
+// @Description 标签搜索接口
+// @Param   KeyWord   query   string  false       "搜索关键词"
+// @Success 200 {object} cygx.ActivityCcustomerTypeList
+// @router /rai_serve/search_tag [get]
+func (this *RaiServeCoAntroller) List() {
+	br := new(models.BaseResponse).Init()
+	defer func() {
+		this.Data["json"] = br
+		this.ServeJSON()
+	}()
+	sysUser := this.SysUser
+	if sysUser == nil {
+		br.Msg = "请登录"
+		br.ErrMsg = "请登录，SysUser Is Empty"
+		br.Ret = 408
+		return
+	}
+	keyWord := this.GetString("KeyWord")
+	if keyWord == "" {
+		br.Msg = "请输入搜索关键词"
+		return
+	}
+	resp := new(cygx.RaiServeTagListResp)
+	list, err := cygx.GetRaiServeSearchTagRespList(keyWord)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "获取数据失败，Err:" + err.Error()
+		return
+	}
+	//如果有固收或者策略就去查询行业表
+	if strings.Contains("固收", keyWord) || strings.Contains("策略", keyWord) {
+		var condition string
+		var pars []interface{}
+		keyWord = "%" + keyWord + "%"
+		condition = ` AND  product_id  = 2 AND  permission_name  IN ('策略','固收')   AND permission_name LIKE ?  `
+		pars = append(pars, keyWord)
+
+		listChartPermission, err := models.GetChartPermissionListByCondition(condition, pars)
+		if err != nil {
+			br.Msg = "获取失败"
+			br.ErrMsg = "获取数据失败，GetChartPermissionListByCondition Err:" + err.Error()
+			return
+		}
+		for _, v := range listChartPermission {
+
+			item := new(cygx.RaiServeTagResp)
+			item.TagType = 3
+			item.TagId = v.ChartPermissionId
+			item.TagName = v.PermissionName
+			list = append(list, item)
+		}
+	}
+	if len(list) == 0 {
+		list = make([]*cygx.RaiServeTagResp, 0)
+	}
+	resp.List = list
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}

models/chart_permission.go

@@ -178,3 +178,14 @@ func GetChartPermissionListRaiSubjectivity() (items []*ChartPermission, err erro
 	_, err = o.Raw(sql).QueryRows(&items)
 	return
 }
+
+func GetChartPermissionListByCondition(condition string, pars []interface{}) (items []*ChartPermission, err error) {
+	o := orm.NewOrm()
+	sql := `SELECT * FROM chart_permission WHERE  parent_id > 0 `
+	if condition != `` {
+		sql += condition
+	}
+	sql += `  ORDER BY sort ASC `
+	_, err = o.Raw(sql, pars).QueryRows(&items)
+	return
+}

models/cygx/rai_serve_bill.go

@@ -0,0 +1,66 @@
+package cygx
+
+import "github.com/beego/beego/v2/client/orm"
+
+type RaiServeTypeResp struct {
+	ServeTypeId   int    `description:"服务类型id"`
+	ServeTypeName string `description:"服务类型名称"`
+}
+
+type RaiServeTypeListResp struct {
+	List []*RaiServeTypeResp
+}
+
+// 服务类型列表
+func GetRaiServeTypeRespList(condition string) (items []*RaiServeTypeResp, err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	sql := `SELECT * FROM cygx_rai_serve_type WHERE  1= 1 `
+	if condition != "" {
+		sql += condition
+	}
+	sql += `  ORDER BY sort DESC  LIMIT  100 `
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}
+
+type RaiServeTagResp struct {
+	TagType int    `description:"标签类型"`
+	TagId   int    `description:"标签ID"`
+	TagName string `description:"标签名称"`
+}
+
+type RaiServeTagListResp struct {
+	List []*RaiServeTagResp
+}
+
+// 服务类型列表
+func GetRaiServeSearchTagRespList(keywords string) (items []*RaiServeTagResp, err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	sql := `SELECT
+			1 AS tag_type,
+			i.industrial_management_id AS tag_id,
+			i.industry_name AS tag_name,
+			i.create_time 
+		FROM
+			cygx_industrial_management AS i 
+		WHERE
+			1 = 1 
+			AND i.chart_permission_id IN ( 19, 20, 21, 22 ) 
+			AND i.industry_name LIKE '%` + keywords + `%' UNION ALL
+		SELECT
+			2 AS tag_type,
+			s.industrial_subject_id AS tag_id,
+			s.subject_name AS tag_name,
+			s.create_time 
+		FROM
+			cygx_industrial_subject AS s
+			INNER JOIN cygx_industrial_management AS i ON i.industrial_management_id = s.industrial_management_id 
+		WHERE
+			1 = 1 
+			AND i.chart_permission_id IN ( 19, 20, 21, 22 ) 
+			AND s.subject_name LIKE  '%` + keywords + `%'
+		ORDER BY
+			create_time ASC `
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}

routers/commentsRouter.go

@@ -2293,6 +2293,24 @@ func init() {
             Filters: nil,
             Params: nil})
 
+    beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"],
+        beego.ControllerComments{
+            Method: "List",
+            Router: `/rai_serve/search_tag`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
+    beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:RaiServeCoAntroller"],
+        beego.ControllerComments{
+            Method: "TypeList",
+            Router: `/rai_serve/type_list`,
+            AllowHTTPMethods: []string{"get"},
+            MethodParams: param.Make(),
+            Filters: nil,
+            Params: nil})
+
     beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:ReportArticleController"] = append(beego.GlobalControllerRouter["hongze/hz_crm_api/controllers/cygx:ReportArticleController"],
         beego.ControllerComments{
             Method: "ExportList",

routers/router.go

@@ -162,6 +162,7 @@ func init() {
 				&cygx.UserAdminShareHistoryController{},
 				&cygx.EnterScoreController{},
 				&cygx.OrderController{},
+				&cygx.RaiServeCoAntroller{},
 			),
 		),
 		web.NSNamespace("/advisory",