新增文件订阅

controller/index/index.go

@@ -155,7 +155,6 @@ func (s *IndexController) Refresh(c *gin.Context) {
 		resp.FailData("参数解析失败", errs.Translate(global.Trans), c)
 		return
 	}
-	//services.MysteelChemicalRefresh(req.MergeFilePath)
 	services.AddIndexRefreshToLpush(req.MergeFilePath)
 	resp.Ok("保存成功", c)
 	return

services/index_queue.go

@@ -18,14 +18,12 @@ func AutoRefresh() {
 			fmt.Println("[AutoRefresh]", err)
 		}
 	}()
-	i := 0
 	for {
-		i++
-		fmt.Println(i)
 		msg, err := sub.ReceiveMessage(context.TODO())
 		if err != nil {
 			fmt.Println("sub err:" + err.Error())
 		}
+		fmt.Println("sub:", msg.Payload)
 		IndexHandle(msg.Payload)
 
 		//global.Rc.Brpop(utils.REFRESH_INDEX, func(b []byte) {