fix:商机情报消息推送

rpc/internal/common/task.go

@@ -94,6 +94,16 @@ func PushData(users []string, data *[]map[string]interface{}) {
 	}
 
 	if len(ids) > 0 {
+		var bits []string
+		for _, i2 := range ids {
+			bits = append(bits, fmt.Sprintf("toUInt64(%d)", i2))
+		}
+		err := entity.ClickhouseConn.Exec(context.Background(), fmt.Sprintf(`alter table message_summary UPDATE msg_bitmap = bitmapOr(msg_bitmap,bitmapBuild([%s])) where group_id = %d`, strings.Join(bits, ","), 5))
+		if err != nil {
+			log.Println("message_summary err=== ", err.Error())
+			return
+		}
+
 		var userIds []string
 		for k, user := range users {
 			userIds = append(userIds, user)
@@ -102,7 +112,6 @@ func PushData(users []string, data *[]map[string]interface{}) {
 				userIds = []string{}
 			}
 		}
-
 	}
 }