首先我们在user_strategy_export表加了mq_state字段，用来记录消息发送状态。整个流程是这样的：当用户抽中奖品后，系统会先在数据库生成中奖记录，此时mq_state是待发送状态（0）。然后通过KafkaProducer发送发货消息，如果发送成功就把状态改成1，失败就改成2。这里