fix:商机情报消息推送

rpc/internal/common/task.go

@@ -207,8 +207,8 @@ func UpdateBatch(ids []string, msgLogId []int64) {
 	for _, i2 := range msgLogId {
 		bits = append(bits, fmt.Sprintf("toUInt64(%d)", i2))
 	}
-	log.Println(fmt.Sprintf(`alter table message_user_summary_test UPDATE allMsg = bitmapOr(allMsg,bitmapBuild([%s])) where userId in (%s)`, strings.Join(bits, ","), str))
-	err1 := entity.ClickhouseConn.Exec(context.Background(), fmt.Sprintf(`alter table message_user_summary_test UPDATE allMsg = bitmapOr(allMsg,bitmapBuild([%s])) where userId in (%s)`, strings.Join(bits, ","), str))
+	log.Println(fmt.Sprintf(`alter table message_user_summary UPDATE allMsg = bitmapOr(allMsg,bitmapBuild([%s])) where userId in (%s)`, strings.Join(bits, ","), str))
+	err1 := entity.ClickhouseConn.Exec(context.Background(), fmt.Sprintf(`alter table message_user_summary UPDATE allMsg = bitmapOr(allMsg,bitmapBuild([%s])) where userId in (%s)`, strings.Join(bits, ","), str))
 	if err1 != nil {
 		log.Printf("批量更新message_user_summary出错：%s", err1)
 		return