bnyer
/
bnyer-cloud
1
0
Fork 0
Code Issues Pull Requests Projects Releases 2 Wiki Activity
Browse Source

feature:添加定时任务

feature-1.1
Penny 3 years ago
parent
a90e43c27b
commit
42336a4efd
4 changed files with 21 additions and 22 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 29
      bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java
  2. 2
      bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
  3. 10
      bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/UnifiedPayController.java
  4. 2
      bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java

29
bnyer-services/bnyer-img/src/main/java/com/bnyer/img/service/impl/ImgMqMessageRecordServiceImpl.java
View File

@ -211,20 +211,21 @@ public class ImgMqMessageRecordServiceImpl implements ImgMqMessageRecordService
if(CollectionUtil.isNotEmpty(imgMqMessageRecords)){
for (ImgMqMessageRecord imgMqMessageRecord : imgMqMessageRecords) {
//判断消息是否超过30分钟，超过则改状态为INVALID废弃，否则调用发送消息方法
if(DateUtils.isLessThan30Min(imgMqMessageRecord.getCreateTime())){
String content = imgMqMessageRecord.getContent();
JSONObject jsonObject = JSON.parseObject(content);
String msg = jsonObject.getString("content");
MqRecordMessage message = new MqRecordMessage();
message.setId(imgMqMessageRecord.getId());
message.setContent(msg);
//少于30分钟，发送消息
sendAsyncMsg(imgMqMessageRecord.getTopic(),null,message);
}else{
//超过30分钟，修改状态为废弃
imgMqMessageRecord.setStatus(EnumMessageStatus.INVALID);
imgMqMessageRecordMapper.updateById(imgMqMessageRecord);
}
if(DateUtils.isLessThan30Min(imgMqMessageRecord.getCreateTime())){
String content = imgMqMessageRecord.getContent();
JSONObject jsonObject = JSON.parseObject(content);
String msg = jsonObject.getString("content");
MqRecordMessage message = new MqRecordMessage();
message.setId(imgMqMessageRecord.getId());
message.setReturnTopic(imgMqMessageRecord.getReturnTopic());
message.setContent(msg);
//少于30分钟，发送消息
sendAsyncMsg(imgMqMessageRecord.getTopic(),null,message);
}else{
//超过30分钟，修改状态为废弃
imgMqMessageRecord.setStatus(EnumMessageStatus.INVALID);
imgMqMessageRecordMapper.updateById(imgMqMessageRecord);
}
}
}
log.info("==============img服务消费补偿任务完成,耗时【{}】毫秒！===============",System.currentTimeMillis() - startTime);

2
bnyer-services/bnyer-order/src/main/java/com/bnyer/order/service/impl/OrderMqMessageRecordServiceImpl.java
View File

@ -5,7 +5,6 @@ import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.bnyer.common.core.domain.ImgMqMessageRecord;
import com.bnyer.common.core.domain.OrderMqMessageRecord;
import com.bnyer.common.core.enums.EnumMessageStatus;
import com.bnyer.common.core.utils.DateUtils;
@ -215,6 +214,7 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ
String msg = jsonObject.getString("content");
MqRecordMessage message = new MqRecordMessage();
message.setId(orderMqMessageRecord.getId());
message.setReturnTopic(orderMqMessageRecord.getReturnTopic());
message.setContent(msg);
//少于30分钟，发送消息
sendAsyncMsg(orderMqMessageRecord.getTopic(),null,message);

10
bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/controller/UnifiedPayController.java
View File

@ -5,15 +5,13 @@ import com.bnyer.common.core.enums.ResponseEnum;
import com.bnyer.common.core.exception.ServiceException;
import com.bnyer.common.core.utils.bean.EntityConvertUtil;
import com.bnyer.common.core.utils.ip.IpUtils;
import com.bnyer.pay.annotation.LimitRepeatRequest;
import com.bnyer.pay.bean.dto.QueryOrderDto;
import com.bnyer.pay.bean.dto.RefundDto;
import com.bnyer.pay.bean.dto.UnifiedOrderDto;
import com.bnyer.pay.bean.dto.QueryOrderDto;
import com.bnyer.pay.bean.dto.UnifiedOrderExtDto;
import com.bnyer.pay.bean.vo.ThirdRefundVo;
import com.bnyer.pay.service.UnifiedPayService;
import com.bnyer.pay.bean.vo.UnifiedOrderVo;
import com.bnyer.pay.bean.vo.QueryOrderVo;
import com.bnyer.pay.bean.vo.UnifiedOrderVo;
import com.bnyer.pay.service.UnifiedPayService;
import com.bnyer.pay.utils.PaymentRefundUtil;
import io.swagger.annotations.Api;
import io.swagger.v3.oas.annotations.Operation;
@ -59,7 +57,7 @@ public class UnifiedPayController {
return R.ok(queryOrderVo);
}
@LimitRepeatRequest(time = 10, message = "请勿频繁操作")
//@LimitRepeatRequest(time = 10, message = "请勿频繁操作")
@PostMapping("/refund")
@Operation(summary = "统一退款" , description = "统一退款")
public R<?> refund(@Valid @RequestBody RefundDto dto){

2
bnyer-services/bnyer-pay/src/main/java/com/bnyer/pay/service/impl/PayMqMessageRecordServiceImpl.java
View File

@ -5,7 +5,6 @@ import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.bnyer.common.core.domain.OrderMqMessageRecord;
import com.bnyer.common.core.domain.PayMqMessageRecord;
import com.bnyer.common.core.enums.EnumMessageStatus;
import com.bnyer.common.core.utils.DateUtils;
@ -216,6 +215,7 @@ public class PayMqMessageRecordServiceImpl implements PayMqMessageRecordService
String msg = jsonObject.getString("content");
MqRecordMessage message = new MqRecordMessage();
message.setId(payMqMessageRecord.getId());
message.setReturnTopic(payMqMessageRecord.getReturnTopic());
message.setContent(msg);
//少于30分钟，发送消息
sendAsyncMsg(payMqMessageRecord.getTopic(),null,message);

Write Preview
Loading…
Cancel
Save