瀏覽代碼

wip:修改查询未订阅列表

wangkaiyue 2 年之前
父節點
當前提交
7eb18e1d05
共有 2 個文件被更改,包括 4 次插入13 次删除
  1. 1 12
      jyBXSubscribe/rpc/bxsubscribe.go
  2. 3 1
      jyBXSubscribe/rpc/model/staffSubscribe.go

+ 1 - 12
jyBXSubscribe/rpc/bxsubscribe.go

@@ -36,18 +36,7 @@ func main() {
 	//初始化日志信息
 	conf.MustLoad(*logFile, &IC.Logc)
 	IC.InitC()
-	// 部门
-	//total, list := model.GetStaffSubscribeList(15799, 5889, "", 0, 0, 0, 5)
-	//// 管理员
-	////total, list := model.GetStaffSubscribeList(15799, 5886, "", 0, 1, 0, 5)
-	//if total > 0 {
-	//	for _, i2 := range list {
-	//		g.Dump(i2)
-	//	}
-	//}
-	//
-	//g.Dump(model.GetStaffSubscribeDetail(15799, 5889, "ABCYGZBfzxYGTc7AlV6dXECMzMoDjRmZnNgPD8jLSEeZ3tpZSslNzg7IndcSXI9OAU3IQJZQA2e"))
-	//return
+
 	go func() {
 		err := endless.ListenAndServe(":"+MC.InterfaceToStr(IC.C.Webrpcport), nil, func() {})
 		if err != nil {

+ 3 - 1
jyBXSubscribe/rpc/model/staffSubscribe.go

@@ -119,7 +119,9 @@ WHERE`
 		queryArr = append(queryArr, ` rule_id is  null `)
 	}
 	// 个人订阅过滤
-	if pStatus != 0 && len(pSubscribeList) > 0 {
+	if pStatus == 1 && len(pSubscribeList) == 0 {
+		return 0, nil
+	} else if pStatus != 0 && len(pSubscribeList) > 0 {
 		tStr := ``
 		for i, v := range pSubscribeList {
 			if i != 0 {