重新发送消息

mp-quartz/src/main/java/com/qs/mp/quartz/task/OperateToolTask.java

@@ -0,0 +1,39 @@
+package com.qs.mp.quartz.task;
+
+import com.qs.mp.common.enums.MqTopicType;
+import com.qs.mp.common.pulsar.PulsarClientService;
+import com.qs.mp.common.utils.LogUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * 后台人工操作入口
+ *
+ * @author zhongcp
+ * @Date 2022/3/17
+ */
+@Component("operateToolTask")
+public class OperateToolTask {
+
+  protected final Logger logger = LoggerFactory.getLogger(this.getClass().getSimpleName());
+
+  @Autowired
+  private PulsarClientService pulsarClientService;
+
+  /**
+   * 重新发送消息
+   */
+  public void resendTicketPayMsg(String orderId) {
+    LogUtil.info(logger, "...重新发送盲票支付消息任务开始...");
+
+    try {
+      pulsarClientService.producer(MqTopicType.ticket_pay, orderId);
+    } catch (Exception e) {
+      LogUtil.error(logger, e, "重新发送盲票支付消息异常。orderId:{0}", orderId);
+    }
+
+    LogUtil.info(logger, "...重新发送盲票支付消息任务结束...");
+  }
+}