|
@@ -209,14 +209,16 @@ public class AmsExecuteRecordServiceImpl extends SuperWhaleServiceImpl<AmsExecut
|
|
|
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
|
|
|
-// );
|
|
|
+ executeRecord.setExecuteStatus(0);
|
|
|
+ this.updateById(executeRecord);
|
|
|
+ runTask(
|
|
|
+ executeRecord.getIntervalMin(),
|
|
|
+ executeRecord.getIntervalMax(),
|
|
|
+ executeRecord.getExecuteId(),
|
|
|
+ task.getTaskCode(),
|
|
|
+ JSON.parseArray(executeRecord.getAirdropParams(), AirdropParam.class),
|
|
|
+ wallets
|
|
|
+ );
|
|
|
|
|
|
}
|
|
|
|