fix: TxMsg doClear 方法取消参数，方便 xxl-job 执行

Author: cadecode

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/handler/AbstractTxMsgHandler.java

@@ -17,7 +17,7 @@ public abstract class AbstractTxMsgHandler {
 
     public abstract void doRetry();
 
-    public abstract void doClear(Long autoClearInterval);
+    public abstract void doClear();
 
     public abstract void checkBeforeSend(BaseTxMsg txMsg, MsgOption msgOption);
 

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/job/TxMsgJobRegister.java

@@ -29,17 +29,23 @@ public class TxMsgJobRegister {
 
     @EventListener(ApplicationStartedEvent.class)
     public void onApplicationStartedEvent() {
+        registerRetryJob();
+        registerAutoClearJob();
+    }
+
+    private void registerRetryJob() {
         // 消息定时 retry
-        log.info("TxMsg task do retry start, {}", txMsgProperties.getEnableRetry());
+        log.info("TxMsg task retry start, {}", txMsgProperties.getEnableRetry());
         if (ObjUtil.equals(txMsgProperties.getEnableRetry(), true)) {
             taskScheduler.scheduleWithFixedDelay(txMsgTaskHandler::doRetry, txMsgProperties.getRetryFixDelay());
         }
+    }
 
+    private void registerAutoClearJob() {
         // 消息定时清理
-        log.info("TxMsg task do clear start, {}", txMsgProperties.getAutoClear());
-        if (ObjUtil.equal(txMsgProperties.getAutoClear(), true)) {
-            taskScheduler.scheduleWithFixedDelay(() -> txMsgTaskHandler.doClear(txMsgProperties.getAutoClearInterval()),
-                    txMsgProperties.getClearFixDelay());
+        log.info("TxMsg task auto clear start, {}", txMsgProperties.getAutoClear());
+        if (ObjUtil.equals(txMsgProperties.getAutoClear(), true)) {
+            taskScheduler.scheduleWithFixedDelay(txMsgTaskHandler::doClear, txMsgProperties.getClearFixDelay());
         }
     }
 }

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/handler/MqTxMsgHandler.java

@@ -10,6 +10,7 @@
 import com.github.cadecode.uniboot.common.core.util.AssertUtil;
 import com.github.cadecode.uniboot.common.plugin.cache.util.KeyGeneUtil;
 import com.github.cadecode.uniboot.common.plugin.cache.util.RedisLockKit;
+import com.github.cadecode.uniboot.common.plugin.mq.config.TxMsgProperties;
 import com.github.cadecode.uniboot.common.plugin.mq.config.TxMsgProperties.MsgOption;
 import com.github.cadecode.uniboot.common.plugin.mq.exception.TxMsgException;
 import com.github.cadecode.uniboot.common.plugin.mq.handler.AbstractTxMsgHandler;
@@ -61,6 +62,8 @@ public class MqTxMsgHandler extends AbstractTxMsgHandler {
      */
     public static final String DEFAULT_TX_MSG_REPLY_TEXT = "DEFAULT_TX_MSG_REPLY";
 
+    private final TxMsgProperties txMsgProperties;
+
     private final RedisLockKit redisLockKit;
 
     private final PlgMqMsgService mqMsgService;
@@ -114,13 +117,13 @@ private boolean updateRetryTime(String txMsgId, int newLeftRetryTimes, Date newN
 
     @XxlJob("MqTxMsgAutoClear")
     @Override
-    public void doClear(Long autoClearInterval) {
+    public void doClear() {
         String lockKey = KeyGeneUtil.lockKey(LOCK_TX_MSG_DO_CLEAR);
         try {
             redisLockKit.lock(lockKey);
             Date currDate = new Date();
             // 查找指定时长之前的记录
-            DateTime lastDate = DateUtil.offset(currDate, DateField.MILLISECOND, -autoClearInterval.intValue());
+            DateTime lastDate = DateUtil.offset(currDate, DateField.MILLISECOND, -txMsgProperties.getAutoClearInterval().intValue());
             List<PlgMqMsg> msgList = mqMsgService.lambdaQuery()
                     .select(PlgMqMsg::getId)
                     .le(PlgMqMsg::getCreateTime, lastDate)