Commit b845affe by xiangkun.gu

新增现现金支付设置轮循队列的暴露接口

parent d04a4ccb
......@@ -120,4 +120,14 @@ public class ExposureOrderController {
return ResponseUtil.success(fmId);
}
/**
* 现金支付,设置轮循队列
*/
@ApiAnnotation(logMessage = "现金支付,设置轮循队列")
@PostMapping("/putRoundRobin")
public BaseResponse putRoundRobin(@Validated @LogParams @RequestBody PutRoundRobinVo putRoundRobinVo) {
payService.putRoundRobin(putRoundRobinVo);
return ResponseUtil.success();
}
}
package cn.freemud.entities.vo;
import lombok.Data;
@Data
public class PutRoundRobinVo {
private String partnerId;
private String storeId;
private String fmId;
private String orderCode;
private Byte index;
private String ebCode;
}
......@@ -19,6 +19,7 @@ import cn.freemud.entities.dto.pay.svc.SVCCardAmountRequestDto;
import cn.freemud.entities.dto.pay.svc.SVCCardAmountResponseDto;
import cn.freemud.entities.vo.CreateOrderResponseVo;
import cn.freemud.entities.vo.PaysuccessNoticeMessage;
import cn.freemud.entities.vo.PutRoundRobinVo;
import cn.freemud.entities.vo.order.CreateOrderUnionPayCardVo;
import cn.freemud.entities.vo.order.PlugInParameter;
import cn.freemud.enums.*;
......@@ -1503,4 +1504,16 @@ public class PayServiceImpl {
String fmId = "SPAY" + ValidationCode.getRandomUuid();
return fmId;
}
public void putRoundRobin(PutRoundRobinVo putRoundRobinVo) {
redisCache.save(RedisUtil.getPaymentTransIdOrderKey(putRoundRobinVo.getEbCode()), putRoundRobinVo.getOrderCode(), 1L, TimeUnit.DAYS);
//加入轮训队列
this.putDelMq(putRoundRobinVo.getPartnerId(),
putRoundRobinVo.getStoreId(),
putRoundRobinVo.getFmId(),
putRoundRobinVo.getOrderCode(),
(int) putRoundRobinVo.getIndex());
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment