Merge branch 'feature/eta2.5.9_inspection_stat' into debug

services/edb_inspection.go

@@ -277,7 +277,7 @@ func AddEdbInspectionRecord(cont context.Context) (err error) {
 				}else {
 					// 发送消息
 					cacheKey := fmt.Sprintf("%s%d", utils.CACHE_EDB_INSPECTION_MESSAGE, adminId)
-					err := utils.Rc.LPush(cacheKey, message)
+					err := utils.Rc.Put(cacheKey, "1", time.Hour*24)
 					if err != nil {
 						errMsgList = append(errMsgList, fmt.Sprintf("添加巡检消息通知失败: recordId=%d, adminId=%d, edb_code=%s, err=%v", 
 							record.InspectionRecordId, adminId, edbInfo.EdbCode, err))

utils/constants.go

@@ -158,7 +158,7 @@ const (
 const (
 	CACHE_CREATE_REPORT_IMGPDF_QUEUE = "eta_report:report_img_pdf_queue" // 生成报告长图PDF队列
 	CACHE_ETA_REPORT_KNOWLEDGE       = "eta:report:knowledge:op:"        //eta报告入知识库处理
-	CACHE_EDB_INSPECTION_MESSAGE            = "eta:edb_inspection:message:"          //巡检消息队列
+	CACHE_EDB_INSPECTION_MESSAGE            = "eta:edb:inspection:message:"          //巡检消息队列
 )
 
 // 商户号