瀏覽代碼

no message

xingzai 7 月之前
父節點
當前提交
197e043b52
共有 4 個文件被更改,包括 87 次插入22 次删除
  1. 59 22
      controllers/cygx/rai_serve.go
  2. 14 0
      models/chart_permission.go
  3. 5 0
      models/cygx/rai_serve_bill.go
  4. 9 0
      routers/commentsRouter.go

+ 59 - 22
controllers/cygx/rai_serve.go

@@ -147,25 +147,26 @@ func (this *RaiServeCoAntroller) SearchTagCalendar() {
 	var permissionName []string
 	for _, v := range askEmailList {
 		permissionName = append(permissionName, v.ChartPermissionName)
-		if v.ChartPermissionName == "策略" {
+		if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
 			hasCelue = true
 		}
 	}
 
+	var permissionNameSql []string
+	for _, v := range permissionName {
+		permissionNameSql = append(permissionNameSql, "'"+v+"'")
+	}
+	chartList, err := models.GetChartPermissionByNamesByRai(permissionNameSql)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "获取数据失败,GetChartPermissionByNames Err:" + err.Error()
+		return
+	}
+
 	var list []*cygx.RaiServeTagResp
 	resp := new(cygx.RaiServeTagListResp)
 	if hasCelue {
-		var condition string
-		var pars []interface{}
-		keyWord = "%" + keyWord + "%"
-		condition = ` AND  product_id  = 2 AND  permission_name  IN ('策略')   `
-		listChartPermission, err := models.GetChartPermissionListByCondition(condition, pars)
-		if err != nil {
-			br.Msg = "获取失败"
-			br.ErrMsg = "获取数据失败,GetChartPermissionListByCondition Err:" + err.Error()
-			return
-		}
-		for _, v := range listChartPermission {
+		for _, v := range chartList {
 			item := new(cygx.RaiServeTagResp)
 			item.TagType = 3
 			item.TagId = v.ChartPermissionId
@@ -177,16 +178,6 @@ func (this *RaiServeCoAntroller) SearchTagCalendar() {
 			br.Msg = "请输入搜索关键词"
 			return
 		}
-		var permissionNameSql []string
-		for _, v := range permissionName {
-			permissionNameSql = append(permissionNameSql, "'"+v+"'")
-		}
-		chartList, err := models.GetChartPermissionByNames(permissionNameSql)
-		if err != nil {
-			br.Msg = "获取失败"
-			br.ErrMsg = "获取数据失败,GetChartPermissionByNames Err:" + err.Error()
-			return
-		}
 
 		var permissionId []string
 		for _, v := range chartList {
@@ -214,6 +205,52 @@ func (this *RaiServeCoAntroller) SearchTagCalendar() {
 	br.Data = resp
 }
 
+// @Title 校验是否属于策略固收
+// @Description 校验是否属于策略固收接口
+// @Param   ResearcherId   query   int  false       "研究员ID"
+// @Success 200 {object} cygx.RaiServeTagListResp
+// @router /rai_serve/chcck_PermissionName [get]
+func (this *RaiServeCoAntroller) ChcckPermissionName() {
+	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
+	}
+
+	researcherId := this.GetString("ResearcherId")
+	askEmailList, err := cygx.GetAskEmailListByAdminIds(researcherId)
+	if err != nil {
+		br.Msg = "获取失败"
+		br.ErrMsg = "GetAskEmailCountByCelue,Err:" + err.Error()
+		return
+	}
+
+	var belong bool
+	var permissionNameResp []string
+	var permissionNames []string
+	for _, v := range askEmailList {
+		permissionNames = append(permissionNames, v.ChartPermissionName)
+		if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
+			belong = true
+			permissionNameResp = append(permissionNameResp, v.ChartPermissionName)
+		}
+	}
+	resp := new(cygx.ChekChartPermissionNameResp)
+	resp.Belong = belong
+	resp.ChartPermissionName = strings.Join(permissionNameResp, ",")
+	br.Ret = 200
+	br.Success = true
+	br.Msg = "获取成功"
+	br.Data = resp
+}
+
 // @Title 权益服务统计列表
 // @Description 权益服务统计列表接口
 // @Param   PageSize   query   int  true       "每页数据条数"

+ 14 - 0
models/chart_permission.go

@@ -156,6 +156,20 @@ func GetChartPermissionByNames(permissionNames []string) (list []*ChartPermissio
 	return
 }
 
+func GetChartPermissionByNamesByRai(permissionNames []string) (list []*ChartPermission, err error) {
+	qb, _ := orm.NewQueryBuilder("mysql")
+	// 构建查询对象
+	qb.Select("*").From("chart_permission").
+		Where("parent_id > 0 AND  product_id = 2 and chart_permission_name").In(permissionNames...)
+	// 导出 SQL 语句
+	sql := qb.String()
+
+	// 执行 SQL 语句
+	o := orm.NewOrm()
+	_, err = o.Raw(sql).QueryRows(&list)
+	return
+}
+
 // GetChartPermissionList 获取品种权限列表
 func GetChartPermissionList() (list []*ChartPermission, err error) {
 	o := orm.NewOrm()

+ 5 - 0
models/cygx/rai_serve_bill.go

@@ -33,6 +33,11 @@ type RaiServeTagResp struct {
 	Md5Key  string `description:"加密key,前端找参数当唯一索引值使用"`
 }
 
+type ChekChartPermissionNameResp struct {
+	ChartPermissionName string `description:"权限名称"`
+	Belong              bool   `description:"权限名称"`
+}
+
 type RaiServeTagListResp struct {
 	List []*RaiServeTagResp
 }

+ 9 - 0
routers/commentsRouter.go

@@ -2302,6 +2302,15 @@ 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: "ChcckPermissionName",
+            Router: `/rai_serve/chcck_PermissionName`,
+            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: "CoverageRate",