记得上下班打卡 | git大法好,push需谨慎

Commit 52da284e authored by 姜秀龙's avatar 姜秀龙

离线支付-迈之屏蔽前端不需要的接口,完善对款

parent d4535a94
...@@ -31,7 +31,7 @@ public interface IGoblinRechargeWristbandService extends IService<GoblinRecharge ...@@ -31,7 +31,7 @@ public interface IGoblinRechargeWristbandService extends IService<GoblinRecharge
DeviceRecordResponse getDeviceRecord(String cardno, Integer page); DeviceRecordResponse getDeviceRecord(String cardno, Integer page);
ChangeDeviceStatusResponse changeDeviceStatus(String cardno, int type); ChangeDeviceStatusResponse changeDeviceStatus(String orderId, int type);
Boolean refundRes(); Boolean refundRes();
} }
...@@ -46,7 +46,7 @@ public class GoblinRechargeAmountController { ...@@ -46,7 +46,7 @@ public class GoblinRechargeAmountController {
} }
} }
@PostMapping("order/create") /*@PostMapping("order/create")
@ApiOperation("创建订单") @ApiOperation("创建订单")
public ResponseDto<String> createOrder(@RequestBody OrderParam param) { public ResponseDto<String> createOrder(@RequestBody OrderParam param) {
OrderResponse res = iGoblinRechargeWristbandService.createOrder(param); OrderResponse res = iGoblinRechargeWristbandService.createOrder(param);
...@@ -55,9 +55,9 @@ public class GoblinRechargeAmountController { ...@@ -55,9 +55,9 @@ public class GoblinRechargeAmountController {
} else { } else {
return ResponseDto.failure(res.getMsg()); return ResponseDto.failure(res.getMsg());
} }
} }*/
@PostMapping("order/info") /*@PostMapping("order/info")
@ApiOperation("订单查询") @ApiOperation("订单查询")
public ResponseDto<List<OrderInfoResponse.OrderList>> getOrder(@RequestBody OrderInfoParam param) { public ResponseDto<List<OrderInfoResponse.OrderList>> getOrder(@RequestBody OrderInfoParam param) {
OrderInfoResponse res = iGoblinRechargeWristbandService.getOrder(param); OrderInfoResponse res = iGoblinRechargeWristbandService.getOrder(param);
...@@ -66,7 +66,7 @@ public class GoblinRechargeAmountController { ...@@ -66,7 +66,7 @@ public class GoblinRechargeAmountController {
} else { } else {
return ResponseDto.failure(); return ResponseDto.failure();
} }
} }*/
@GetMapping("order/qrcode") @GetMapping("order/qrcode")
@ApiOperation("获取二维码字符串") @ApiOperation("获取二维码字符串")
...@@ -82,10 +82,10 @@ public class GoblinRechargeAmountController { ...@@ -82,10 +82,10 @@ public class GoblinRechargeAmountController {
} }
} }
@GetMapping("device/mumber") /*@GetMapping("device/mumber")
@ApiOperation("获取设备编号列表") @ApiOperation("获取设备编号列表")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "param", required = true, name = "operationNo", value = "分订单号"), @ApiImplicitParam(type = "param", required = true, name = "operationNo", value = "活动号"),
}) })
public ResponseDto<Boolean> getDeviceNumber( public ResponseDto<Boolean> getDeviceNumber(
@NotNull(message = "参数无效") @RequestParam("operationNo") Integer operationNo @NotNull(message = "参数无效") @RequestParam("operationNo") Integer operationNo
...@@ -96,7 +96,7 @@ public class GoblinRechargeAmountController { ...@@ -96,7 +96,7 @@ public class GoblinRechargeAmountController {
} else { } else {
return ResponseDto.failure(); return ResponseDto.failure();
} }
} }*/
@GetMapping("device/balance") @GetMapping("device/balance")
@ApiOperation("获取余额") @ApiOperation("获取余额")
...@@ -135,12 +135,12 @@ public class GoblinRechargeAmountController { ...@@ -135,12 +135,12 @@ public class GoblinRechargeAmountController {
@GetMapping("order/refund/apply") @GetMapping("order/refund/apply")
@ApiOperation("退款申请") @ApiOperation("退款申请")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(type = "param", required = true, name = "cardno", value = "设备编号"), @ApiImplicitParam(type = "param", required = true, name = "orderId", value = "订单编号"),
}) })
public ResponseDto<ChangeDeviceStatusResponse> refundApply( public ResponseDto<ChangeDeviceStatusResponse> refundApply(
@NotBlank(message = "参数无效:cardno") @RequestParam("cardno") String cardno @NotBlank(message = "参数无效:orderId") @RequestParam("orderId") String orderId
) { ) {
ChangeDeviceStatusResponse res = iGoblinRechargeWristbandService.changeDeviceStatus(cardno, 1); ChangeDeviceStatusResponse res = iGoblinRechargeWristbandService.changeDeviceStatus(orderId, 1);
if (null != res && res.getErrcode() == 200) { if (null != res && res.getErrcode() == 200) {
return ResponseDto.success(res); return ResponseDto.success(res);
} else { } else {
...@@ -148,7 +148,7 @@ public class GoblinRechargeAmountController { ...@@ -148,7 +148,7 @@ public class GoblinRechargeAmountController {
} }
} }
@GetMapping("order/refund/result") /*@GetMapping("order/refund/result")
@ApiOperation("退款结果查询") @ApiOperation("退款结果查询")
public ResponseDto<Boolean> refundRes() { public ResponseDto<Boolean> refundRes() {
Boolean res = iGoblinRechargeWristbandService.refundRes(); Boolean res = iGoblinRechargeWristbandService.refundRes();
...@@ -157,6 +157,6 @@ public class GoblinRechargeAmountController { ...@@ -157,6 +157,6 @@ public class GoblinRechargeAmountController {
} else { } else {
return ResponseDto.failure(); return ResponseDto.failure();
} }
} }*/
} }
...@@ -188,11 +188,28 @@ public class GoblinRechargeWristbandServiceImpl extends ServiceImpl<GoblinRechar ...@@ -188,11 +188,28 @@ public class GoblinRechargeWristbandServiceImpl extends ServiceImpl<GoblinRechar
} }
@Override @Override
public ChangeDeviceStatusResponse changeDeviceStatus(String cardno, int type) { public ChangeDeviceStatusResponse changeDeviceStatus(String orderId, int type) {
GoblinBraceletOrderVo orderVo = goblinRedisUtils.getBraceletOrderVo(orderId);
String cardno = orderVo.getCardno();
String accessToken = this.getAccessToken(); String accessToken = this.getAccessToken();
if (null != accessToken) { if (null != accessToken) {
// todo 更改订单状态为退款中 ChangeDeviceStatusResponse response = thirdMaiZhiUtils.changeDeviceStatus(accessToken, cardno, type);
return thirdMaiZhiUtils.changeDeviceStatus(accessToken, cardno, type); if (response.getErrcode() == 200) {
orderVo.setStatus(3);
orderVo.setRefundStatus(0);
goblinRedisUtils.setBraceletOrderVo(orderVo);
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("goblin_bracelet_order_update_refund"));
LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();
sqlDataOrder.add(new Object[]{
orderVo.getStatus(), orderVo.getRefundStatus(), "", LocalDateTime.now(), orderId
});
queueUtils.sendMsgByRedis(
MQConst.GoblinQueue.GOBLIN_NFT_ORDER.getKey(),
SqlMapping.gets(sqls, sqlDataOrder)
);
}
} }
return null; return null;
} }
...@@ -210,10 +227,26 @@ public class GoblinRechargeWristbandServiceImpl extends ServiceImpl<GoblinRechar ...@@ -210,10 +227,26 @@ public class GoblinRechargeWristbandServiceImpl extends ServiceImpl<GoblinRechar
if (null != res && res.getErrcode() == 200) { if (null != res && res.getErrcode() == 200) {
GoblinBraceletOrderVo orderVo = goblinRedisUtils.getBraceletOrderVo(orderId); GoblinBraceletOrderVo orderVo = goblinRedisUtils.getBraceletOrderVo(orderId);
if (res.getStatus() == 1) { if (res.getStatus() == 1) {
orderVo.setStatus(4);
orderVo.setRefundStatus(1);
orderVo.setRefundStatusNote("");
} else if (res.getStatus() == 2) { } else if (res.getStatus() == 2) {
orderVo.setStatus(7);
orderVo.setRefundStatus(2);
orderVo.setRefundStatusNote(res.getNote());
} }
goblinRedisUtils.setBraceletOrderVo(orderVo);
LinkedList<String> sqls = CollectionUtil.linkedListString();
sqls.add(SqlMapping.get("goblin_bracelet_order_update_refund"));
LinkedList<Object[]> sqlDataOrder = CollectionUtil.linkedListObjectArr();
sqlDataOrder.add(new Object[]{
orderVo.getStatus(), orderVo.getRefundStatus(), orderVo.getRefundStatusNote(), LocalDateTime.now()
});
queueUtils.sendMsgByRedis(
MQConst.GoblinQueue.GOBLIN_NFT_ORDER.getKey(),
SqlMapping.gets(sqls, sqlDataOrder)
);
} }
} }
} }
......
...@@ -200,4 +200,5 @@ goblin_bracelet_order_insert = INSERT INTO `goblin_bracelet_order`(`order_id`, ` ...@@ -200,4 +200,5 @@ goblin_bracelet_order_insert = INSERT INTO `goblin_bracelet_order`(`order_id`, `
gpblin_bracelet_order_update= update goblin_bracelet_order set out_trans_id=?, end_time=?, acct_date=?, price_actual=?, time_pay=?, updated_at=? where order_id=? gpblin_bracelet_order_update= update goblin_bracelet_order set out_trans_id=?, end_time=?, acct_date=?, price_actual=?, time_pay=?, updated_at=? where order_id=?
goblin_bracelet_order_entities_insert = INSERT INTO `goblin_bracelet_order_entities`(`order_entities_id`, `order_id`, `goods_type`, `goods_id`, `goods_name`, `goods_price`, `status`, `pay_status`, `created_at`, `updated_at`) VALUES (?,?,?,?,?,?,?,?,?,?) goblin_bracelet_order_entities_insert = INSERT INTO `goblin_bracelet_order_entities`(`order_entities_id`, `order_id`, `goods_type`, `goods_id`, `goods_name`, `goods_price`, `status`, `pay_status`, `created_at`, `updated_at`) VALUES (?,?,?,?,?,?,?,?,?,?)
goblin_bracelet_order_update_cardno=UPDATE goblin_bracelet_order SET cardno=?,updated_at=? WHERE order_id=? goblin_bracelet_order_update_cardno=UPDATE goblin_bracelet_order SET cardno=?,updated_at=? WHERE order_id=?
goblin_bracelet_order_update_refund=UPDATE goblin_bracelet_order SET status=?,refund_status=?,refund_status_note=?,updated_at=? WHERE order_id=?
goblie_bracelet_order_entities_update = update goblin_bracelet_order_entities set status=?, pay_status=?, updated_at=? where order_entities_id=? goblie_bracelet_order_entities_update = update goblin_bracelet_order_entities set status=?, pay_status=?, updated_at=? where order_entities_id=?
\ No newline at end of file
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