修改.sql

liquidnet-bus-api/liquidnet-service-sweet-api/src/main/java/com/liquidnet/service/sweet/dto/param/poster/SweetStrawberryParam.java

@@ -37,7 +37,9 @@ public class SweetStrawberryParam implements Serializable {
     private String cityCode;
 
     @Valid
-    @ApiModelProperty(value = "阵容列表", example = "")
+    @ApiModelProperty(value = "阵容列表", example = "[{\"lineup\": [{\"lineupNum\": \"lineup1\", \"musicianId\": 9999, \"musicianName\": \"歌手1\"},\n" +
+            "{\"lineupNum\": \"lineup1\",\"musicianId\": 23233,\"musicianName\": \"歌手D\"}]},\n" +
+            "{\"lineup\": [{ \"lineupNum\": \"lineup2\",\"musicianId\": 1111,\"musicianName\": \"歌手2\"}]}]")
     @NotNull(message = "musicianList")
     private List<SweetStrawListParam> musicianList;
 
@@ -50,7 +52,4 @@ public class SweetStrawberryParam implements Serializable {
             return new SweetStrawberryParam();
         }
     }
-
-
-
 }
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetPosterRdsReceiverConfig.java

@@ -35,7 +35,7 @@ public class ConsumerSweetPosterRdsReceiverConfig {
     /*
     *
     * */
-    private Subscription receiveSqlRemind(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+    private Subscription posterSqlRemind(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
         return listenerContainer.receiveAutoAck(
                 Consumer.from(SWEET_POSTER.getGroup(), SWEET_POSTER.name() + t),
                 StreamOffset.create(SWEET_POSTER.getKey(), ReadOffset.lastConsumed()), consumerSweetPosterRdsReceiver
@@ -44,7 +44,7 @@ public class ConsumerSweetPosterRdsReceiverConfig {
     @Bean
     public Subscription subscriptionSqlRemind(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlRemind(listenerContainer, 1);
+        var subscription = posterSqlRemind(listenerContainer, 1);
         listenerContainer.start();
         return subscription;
     }
@@ -52,7 +52,7 @@ public class ConsumerSweetPosterRdsReceiverConfig {
     @Bean
     public Subscription subscriptionSqlRemind2(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlRemind(listenerContainer, 1);
+        var subscription = posterSqlRemind(listenerContainer, 1);
         listenerContainer.start();
         return subscription;
     }
@@ -60,7 +60,7 @@ public class ConsumerSweetPosterRdsReceiverConfig {
     @Bean
     public Subscription subscriptionSqlRemind3(RedisConnectionFactory factory) {
         var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlRemind(listenerContainer, 1);
+        var subscription = posterSqlRemind(listenerContainer, 1);
         listenerContainer.start();
         return subscription;
     }

liquidnet-bus-service/liquidnet-service-sweet/docu/db_20211205.sql

@@ -8,6 +8,7 @@ CREATE TABLE `sweet_strawberry_poster`
     `union_id`   varchar(200)    NOT NULL DEFAULT '' COMMENT 'union_id',
     `nickname`   varchar(255)    NOT NULL DEFAULT '' COMMENT '姓名',
     `city_name`  varchar(255)    NOT NULL DEFAULT '' COMMENT '城市',
+    `city_code`  varchar(255)    NOT NULL DEFAULT '' COMMENT  '城市code',
     `created_at` datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
     `updated_at` datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '更新时间',
     PRIMARY KEY (`mid`),
@@ -24,7 +25,7 @@ CREATE TABLE `sweet_strawberry_poster_lineup`
     `mid`           bigint unsigned NOT NULL AUTO_INCREMENT,
     `lineup_id`     varchar(255)    NOT NULL DEFAULT '' COMMENT 'lineup_id',
     `poster_id`     varchar(255)    NOT NULL DEFAULT '' COMMENT 'poster_id',
-    `lineup_num`    int             NOT NULL DEFAULT 0 COMMENT '阵容编号',
+    `lineup_num`    varchar(255)    NOT NULL DEFAULT 0 COMMENT '阵容编号',
     `musician_id`   int             NOT NULL DEFAULT 0 COMMENT '音乐人id',
     `musician_name` varchar(255)    NOT NULL DEFAULT '' COMMENT '音乐人姓名',
     `created_at`    datetime        NULL     DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',