|
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.pay.service.notify;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.hutool.core.exceptions.ExceptionUtil;
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.http.HttpResponse;
|
|
|
import cn.hutool.http.HttpUtil;
|
|
|
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
|
|
@@ -42,7 +43,6 @@ import java.util.concurrent.CountDownLatch;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.addTime;
|
|
|
-import static cn.iocoder.yudao.framework.common.util.date.LocalDateTimeUtils.afterNow;
|
|
|
import static cn.iocoder.yudao.module.pay.framework.job.config.PayJobConfiguration.NOTIFY_THREAD_POOL_TASK_EXECUTOR;
|
|
|
|
|
|
/**
|
|
@@ -167,10 +167,11 @@ public class PayNotifyServiceImpl implements PayNotifyService {
|
|
|
payNotifyLockCoreRedisDAO.lock(task.getId(), NOTIFY_TIMEOUT_MILLIS, () -> {
|
|
|
// 校验,当前任务是否已经被通知过
|
|
|
// 虽然已经通过分布式加锁,但是可能同时满足通知的条件,然后都去获得锁。此时,第一个执行完后,第二个还是能拿到锁,然后会再执行一次。
|
|
|
+ // 因此,此处我们通过第 notifyTimes 通知次数是否匹配来判断
|
|
|
PayNotifyTaskDO dbTask = payNotifyTaskMapper.selectById(task.getId());
|
|
|
- if (afterNow(dbTask.getNextNotifyTime())) {
|
|
|
- log.info("[executeNotifySync][dbTask({}) 任务被忽略,原因是未到达下次通知时间,可能是因为并发执行了]",
|
|
|
- JsonUtils.toJsonString(dbTask));
|
|
|
+ if (ObjectUtil.notEqual(task.getNotifyTimes(), dbTask.getNotifyTimes())) {
|
|
|
+ log.warn("[executeNotifySync][task({}) 任务被忽略,原因是它的通知不是第 ({}) 次,可能是因为并发执行了]",
|
|
|
+ JsonUtils.toJsonString(task), dbTask.getNotifyTimes());
|
|
|
return;
|
|
|
}
|
|
|
|