| | |
|---|
| | | double success_amount = amounts / Math.pow(10, decimals); |
|---|
| | | String address = map.get("address").toString(); |
|---|
| | | Integer status = Integer.valueOf(map.get("status").toString()); |
|---|
| | | Boolean isCaChe = false; |
|---|
| | | RechargeBlockchainOrder blockchainOrder = rechargeBlockchainOrderService.getOne(new LambdaQueryWrapper<>(RechargeBlockchainOrder.class) |
|---|
| | | .eq(RechargeBlockchainOrder::getSucceeded, 0) |
|---|
| | | .eq(RechargeBlockchainOrder::getChannelAddress, address).last(" limit 1 ")); |
|---|
| | | if(ObjectUtil.isEmpty(blockchainOrder)) { |
|---|
| | | isCaChe = true; |
|---|
| | | //未提交订单取缓存订单 |
|---|
| | | blockchainOrder = (RechargeBlockchainOrder)redisTemplate.opsForValue().get(address); |
|---|
| | | } |
|---|
| | |
|---|
| | | blockchainOrder.setSucceeded(0); |
|---|
| | | blockchainOrder.setChannelAddress(address); |
|---|
| | | blockchainOrder.setTx(""); |
|---|
| | | if (isCaChe) { |
|---|
| | | rechargeBlockchainOrderService.saveOrder(blockchainOrder); |
|---|
| | | } else { |
|---|
| | | rechargeBlockchainOrderService.saveOrUpdate(blockchainOrder); |
|---|
| | | //rechargeBlockchainOrderService.saveOrder(blockchainOrder); |
|---|
| | | } |
|---|
| | | User user = userService.getById(blockchainOrder.getPartyId()); |
|---|
| | | |
|---|
| | | log.info("===rechargeCallback==d=blockchainOrder：{}", blockchainOrder); |
|---|
