|
|
@@ -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.Put(cacheKey, "1", time.Hour*24)
|
|
|
+ err := utils.Rc.LPush(cacheKey, message)
|
|
|
if err != nil {
|
|
|
errMsgList = append(errMsgList, fmt.Sprintf("添加巡检消息通知失败: recordId=%d, adminId=%d, edb_code=%s, err=%v",
|
|
|
record.InspectionRecordId, adminId, edbInfo.EdbCode, err))
|
