| | |
| | | |
| | | |
| | | @Transactional |
| | | public ServerResponse flyPay(Integer payType, String payAmt, String currency, HttpServletRequest request) { |
| | | public ServerResponse flyPay(String payAmt, HttpServletRequest request) { |
| | | User user = iUserService.getCurrentUser(request); |
| | | SitePay sitePay = sitePayMapper.selectById(payType); |
| | | UserRecharge userRecharge = new UserRecharge(); |
| | | userRecharge.setUserId(user.getId()); |
| | | userRecharge.setNickName(user.getRealName()); |
| | | userRecharge.setAgentId(user.getAgentId()); |
| | | String ordersn = KeyUtils.getRechargeOrderSn(); |
| | | userRecharge.setOrderSn(ordersn); |
| | | userRecharge.setPayChannel(sitePay.getChannelName()); |
| | | userRecharge.setPayChannel("カスタマーサービスに連絡して入金"); |
| | | userRecharge.setPayAmt(new BigDecimal(payAmt)); |
| | | userRecharge.setOrderStatus(Integer.valueOf(0)); |
| | | userRecharge.setAddTime(new Date()); |
| | | userRecharge.setPayId(payType); |
| | | userRecharge.setImg(currency); |
| | | userRechargeMapper.insert(userRecharge); |
| | | return ServerResponse.createBySuccess( ((SiteInfo)siteInfoService.getInfo(request).getData()).getOnlineService()); |
| | | return ServerResponse.createBySuccess(); |
| | | } |
| | | |
| | | |
| | |
| | | } |
| | | UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<>(UserAssets.class) |
| | | .eq(UserAssets::getUserId, paymentRecharge.getUserId()) |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | .eq(UserAssets::getAccectType, "JP") |
| | | ); |
| | | ServerResponse serverResponse = iUserAssetsServices.updateUserAssets(userAssets.getId(), vo.getOriAmount().toString(), "2"); |
| | | if(serverResponse.getStatus() == 0){ |
| | |
| | | .eq(PaymentRecharge::getStatus,1) |
| | | .last("limit 1") |
| | | ); |
| | | |
| | | |
| | | if(!vo.getStatus().equals("payin_ing")){ |
| | | log.error("充值2回调交易中:"+vo.toString()); |
| | | return; |
| | |
| | | } |
| | | UserAssets userAssets = userAssetsMapper.selectOne(new LambdaQueryWrapper<>(UserAssets.class) |
| | | .eq(UserAssets::getUserId, paymentRecharge.getUserId()) |
| | | .eq(UserAssets::getAccectType, "IN") |
| | | .eq(UserAssets::getAccectType, "JP") |
| | | ); |
| | | ServerResponse serverResponse = iUserAssetsServices.updateUserAssets(userAssets.getId(), vo.getAccount_fee().toString(), "2"); |
| | | if(serverResponse.getStatus() == 0){ |