|
@@ -610,16 +610,21 @@ public class CoreServiceImpl implements CoreService {
|
|
|
long createTimestamp = entry.getValue().get(0).getCreateTime().getTime();
|
|
|
long nowTimestamp = System.currentTimeMillis();
|
|
|
if (nowTimestamp - createTimestamp > TimeConstant.MILLISECOND_HOUR * 2) {
|
|
|
- PublishContentExample publishContentExample = new PublishContentExample();
|
|
|
- publishContentExample.createCriteria().andPushIdEqualTo(pushId);
|
|
|
- PublishContent update = new PublishContent();
|
|
|
if (StringUtils.isNotEmpty(pushStatusVO.getErrorMsg())) {
|
|
|
- update.setReason(pushStatusVO.getErrorMsg());
|
|
|
+ PublishContentExample publishContentExample = new PublishContentExample();
|
|
|
+ publishContentExample.createCriteria().andPushIdEqualTo(pushId);
|
|
|
+ PublishContent update = new PublishContent();
|
|
|
+ if (StringUtils.isNotEmpty(pushStatusVO.getErrorMsg())) {
|
|
|
+ update.setReason(pushStatusVO.getErrorMsg());
|
|
|
+ }
|
|
|
+ update.setStatus(3);
|
|
|
+ publishContentMapper.updateByExampleSelective(update, publishContentExample);
|
|
|
+ planAccountService.updateRetry(planAccount);
|
|
|
+ LarkRobotUtil.sendMessage("重试超过2h失败,pushId=", pushId);
|
|
|
+ } else {
|
|
|
+ long hour = (nowTimestamp - createTimestamp) / 1000 / 3600;
|
|
|
+ LarkRobotUtil.sendMessage("重试时间:" + hour + "pushId=", pushId);
|
|
|
}
|
|
|
- update.setStatus(3);
|
|
|
- publishContentMapper.updateByExampleSelective(update, publishContentExample);
|
|
|
- planAccountService.updateRetry(planAccount);
|
|
|
- LarkRobotUtil.sendMessage("重试超过2h失败,pushId=", pushId);
|
|
|
}
|
|
|
}
|
|
|
if (StringUtils.isNotEmpty(pushStatusVO.getErrorMsg()) && !pushStatusVO.getErrorMsg().contains("45028")) {
|