fix: 跨链

src/main/java/com/ichaoj/ams/service/impl/AmsExecuteRecordServiceImpl.java

@@ -30,6 +30,7 @@ import com.ichaoj.common.model.PublicPage;
 import com.ichaoj.common.model.PublicUserInfo;
 import com.ichaoj.mybatis.service.SuperWhaleServiceImpl;
 import com.ichaoj.web.context.SuperWhaleContext;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -51,6 +52,7 @@ import java.util.stream.Collectors;
  * @since 2023-05-18
  */
 @Service
+@Slf4j
 public class AmsExecuteRecordServiceImpl extends SuperWhaleServiceImpl<AmsExecuteRecordMapper, AmsExecuteRecord> implements IAmsExecuteRecordService {
     public static ThreadPoolExecutor taskThreadPool =
             new ThreadPoolExecutor(2 * Runtime.getRuntime().availableProcessors(),
@@ -203,15 +205,18 @@ public class AmsExecuteRecordServiceImpl extends SuperWhaleServiceImpl<AmsExecut
             return !b;
         }).collect(Collectors.toList());
         List<AirdropWallet> wallets = accountService.getAirdropAddressByAccount(accountNotExecList, userId, groupName, password);
+        String walletsStr = JSON.toJSONString(wallets);
+        log.info("Pending re-execution of wallet : {}", walletsStr);
+        log.info("The execution parameters are as follows : {}", executeRecord.getAirdropParams());
         AmsAirdropTask task = taskService.getById(executeRecord.getTaskId());
-        runTask(
-                executeRecord.getIntervalMin(),
-                executeRecord.getIntervalMax(),
-                executeRecord.getExecuteId(),
-                task.getTaskCode(),
-                JSON.parseArray(executeRecord.getAirdropParams(), AirdropParam.class),
-                wallets
-        );
+//        runTask(
+//                executeRecord.getIntervalMin(),
+//                executeRecord.getIntervalMax(),
+//                executeRecord.getExecuteId(),
+//                task.getTaskCode(),
+//                JSON.parseArray(executeRecord.getAirdropParams(), AirdropParam.class),
+//                wallets
+//        );
 
     }