fix: 扫描库表补偿发货单MQ消息

lottery-application/src/main/java/com/seamew/lottery/application/mq/consumer/KafkaConsumer.java

@@ -51,7 +51,7 @@ public class KafkaConsumer {
             }
 
             // 3. 打印日志
-            log.info("消费MQ消息，完成 topic：{} bizId：{} 发奖结果：{}", record.topic(), invoiceVO.getUId(), JSON.toJSONString(distributionRes));
+            log.info("消费MQ消息，完成 topic：{} message：{} 发奖结果：{}", record.topic(), JSON.toJSONString(invoiceVO), JSON.toJSONString(distributionRes));
 
             // 4. 消息消费完成
             ack.acknowledge();

lottery-interfaces/src/main/resources/mybatis/mapper/UserStrategyExport_Mapper.xml

@@ -60,6 +60,7 @@
         FROM user_strategy_export
         WHERE mq_state = 2
            OR (mq_state = 0 AND now() - create_time > 1800000)
+           OR grant_state = 0
     </select>
 
 </mapper>

lottery-interfaces/src/test/java/com/seamew/lottery/test/application/ActivityProcessTest.java

@@ -65,7 +65,7 @@ public class ActivityProcessTest {
         // while (true) {
         //     Thread.sleep(30000);
         // }
-        List<InvoiceVO> invoiceVOList = activityPartake.scanInvoiceMqState(1, 0);
+        List<InvoiceVO> invoiceVOList = activityPartake.scanInvoiceMqState(2, 0);
         log.info("size:{}", invoiceVOList.size());
     }