package com.szwl.controller; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ArrayNode; import com.fasterxml.jackson.databind.node.JsonNodeFactory; import com.fasterxml.jackson.databind.node.ObjectNode; import com.szwl.common.AccessTokenCommon; import com.szwl.constant.AirwallexConstant; import com.szwl.feign.bean.SzwlFeign; import com.szwl.model.bean.PaymentIntentRequestBody; import com.szwl.model.bean.RefundRequestBody; import com.szwl.model.bo.R; import com.szwl.model.bo.ResponseModel; import com.szwl.model.dto.*; import com.szwl.model.entity.*; import com.szwl.model.utils.AccessTokenThreadUtil; import com.szwl.service.*; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Value; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.math.RoundingMode; import java.sql.Timestamp; import java.text.ParseException; import java.text.SimpleDateFormat; import java.time.OffsetDateTime; import java.time.format.DateTimeFormatter; import java.util.*; //@CrossOrigin @Api(value = "/api/airwallexPay", tags = {"空中云汇"}) @RestController @RequestMapping("/api/airwallexPay") @Slf4j public class AirwallexPayController { // @Value("${test.value:bbb}") // private String testValue; TAdminService tAdminService; AirwallexService airwallexService; TCoinOrderService tCoinOrderService; TOrderDetailsService tOrderDetailsService; TAirwallexPaymentService tAirwallexPaymentService; SzwlFeign szwlFeign; TAirwallexMchService airwallexMchService; TAirwallexWalletService airwallexWalletService; public AirwallexPayController(TAdminService tAdminService, AirwallexService airwallexService, TCoinOrderService tCoinOrderService, TOrderDetailsService tOrderDetailsService, TAirwallexPaymentService tAirwallexPaymentService, SzwlFeign szwlFeign, TAirwallexMchService airwallexMchService, TAirwallexWalletService airwallexWalletService) { this.tAdminService = tAdminService; this.airwallexService = airwallexService; this.tCoinOrderService = tCoinOrderService; this.tOrderDetailsService = tOrderDetailsService; this.tAirwallexPaymentService = tAirwallexPaymentService; this.szwlFeign = szwlFeign; this.airwallexMchService = airwallexMchService; this.airwallexWalletService = airwallexWalletService; } @ApiOperation(value = "创建收款人") @PostMapping("/caBeneficiary") public JsonNode caBeneficiary(@RequestBody CaBeneficiaryRequestDTO requestDTO) { BeneficiaryDTO beneficiary = requestDTO.getBeneficiary(); List paymentMethods = requestDTO.getPaymentMethods(); String nickname = requestDTO.getNickname(); String resp = airwallexService.caBeneficiary(beneficiary, nickname, paymentMethods); try { JsonNode jsonNode = new ObjectMapper().readTree(resp); return jsonNode; } catch (JsonProcessingException e) { e.printStackTrace(); } // JSONObject jsonObject = JSON.parseObject(resp); // String beneficiaryId = jsonObject.getString("beneficiary_id"); return null; } @ApiOperation(value = "获取authCode") @PostMapping("/getAuthCode") public JsonNode getAuthCode(@RequestBody GetAuthCodeDTO getAuthCodeDTO) { String codeChallenge = getAuthCodeDTO.getCodeChallenge(); String[] scope = getAuthCodeDTO.getScope(); String resp = airwallexService.getAuthCode(codeChallenge, scope); try { JsonNode jsonNode = new ObjectMapper().readTree(resp); return jsonNode; } catch (JsonProcessingException e) { e.printStackTrace(); } return null; } // @GetMapping("/getAccessToken") // public ResponseModel getAccessToken() { // String accessToken = airwallexService.getAccessToken(); // //获取到的accessToken可以放入内存或者存到数据库中，不用每次都获取 // return R.ok(accessToken); // } @ApiOperation(value = "获取token") @GetMapping("/getAccessToken") @Scheduled(cron = "0 0/20 * * * ?") public void getAccessToken() { AccessTokenCommon.ACCESS_TOKEN = AccessTokenThreadUtil.getAccessToken(); } /** * 创建付款意向 - 消费者发起 * * @param paymentIntentRequestBody * @return */ @ApiOperation(value = "Create a PaymentIntent") @PostMapping("/createAPaymentIntent") public R createAPaymentIntent(@RequestBody PaymentIntentRequestBody paymentIntentRequestBody) { log.info("发起支付请求"); // 先获取token // String accessToken = airwallexService.getAccessToken(); // new AccessTokenThreadUtil().run(); // String accessToken = AccessTokenCommon.ACCESS_TOKEN; // // if(accessToken == null || "".equals(accessToken)) { // accessToken = new AccessTokenThreadUtil().getAccessToken(); // return R.fail(L0006); // } // 如果是海外客户，使用的是 Airwallex ，就要判断他有没有设置分销 // 在 Airwallex 支付之前，要先判断 String createDate = paymentIntentRequestBody.getCreateDate(); BigDecimal amount = paymentIntentRequestBody.getAmount(); String currency = paymentIntentRequestBody.getCurrency(); String merchantOrderId = paymentIntentRequestBody.getMerchantOrderId(); // String requestId = paymentIntentRequestBody.getRequestId(); String requestId = UUID.randomUUID().toString().trim().replaceAll("-", ""); Long productId = paymentIntentRequestBody.getProductId(); String productName = paymentIntentRequestBody.getProductName(); String clientId = paymentIntentRequestBody.getClientId(); Long equipmentId = paymentIntentRequestBody.getEquipmentId(); Integer productNumber = paymentIntentRequestBody.getProductNumber(); // 生成订单编号 String sn = tCoinOrderService.initSn(equipmentId); // 七云还是申泽 TEquipment equipment = R.getDataIfSuccess(szwlFeign.findEquipmentByClientId(clientId)); if (equipment == null || equipmentId == null) { return R.fail("找不到设备"); } // System.out.println("设备信息：>>> " + equipment); String machineType = equipment.getMachineType(); // 设备类型 Long adminId = equipment.getAdminId(); if (adminId == null) { return R.fail("找不到设备商家"); } String adminIdStr = String.valueOf(adminId); // 根据 adminId 获取admin信息中的公司类型 TAdmin adminById = R.getDataIfSuccess(szwlFeign.getAdmin(adminIdStr)); // TAdmin byId = tAdminService.getById(adminId); String companyType = adminById.getCompanyType(); // 公司类型 // Airwallex 分账参数 ArrayNode altInfos = JsonNodeFactory.instance.arrayNode(); // Airwallex 分账明细 ObjectNode airDistributionDetails = JsonNodeFactory.instance.objectNode(); // 查找商品 ResponseModel product = szwlFeign.getProduct(String.valueOf(equipmentId), productName); // 获取关联设备的分销 TProportion proportion = R.getDataIfSuccess(szwlFeign.getProportion(String.valueOf(equipmentId))); airDistributionDetails = getDistributionDetails(proportion, amount); // 创建订单 TCoinOrder tCoinOrder = new TCoinOrder(); tCoinOrder.setAdminId(adminById.getId()); if (StringUtils.isNotEmpty(createDate)) { SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date parse = null; try { parse = simpleDateFormat.parse(createDate); } catch (ParseException e) { throw new RuntimeException(e); } tCoinOrder.setCreateDate(parse); tCoinOrder.setModifyDate(parse); } else { tCoinOrder.setCreateDate(new Date()); tCoinOrder.setModifyDate(new Date()); } tCoinOrder.setPayDate(new Date()); tCoinOrder.setSn(sn); tCoinOrder.setAmount(amount); tCoinOrder.setCurrency(currency); tCoinOrder.setMerchantOrderId(merchantOrderId); tCoinOrder.setRequestId(requestId); tCoinOrder.setProductId(productId); tCoinOrder.setProductName(productName); tCoinOrder.setProductNumber(productNumber); tCoinOrder.setClientId(clientId); tCoinOrder.setEquipmentId(equipmentId); // 设置订单支付状态,0未支付，1已支付，3已退款。 tCoinOrder.setStatus(0); tCoinOrder.setIsAir("1"); tCoinOrder.setAltInfo(altInfos.toString()); tCoinOrder.setMachineType(machineType); tCoinOrder.setCompanyType(companyType); tCoinOrder.setType(adminById.getType()); switch (adminById.getType()) { case 0: tCoinOrder.setAdminProportion(proportion.getAdminProportion()); tCoinOrder.setAgencyProportion(proportion.getAgencyProportion()); tCoinOrder.setAgencyId(proportion.getAgencyId()); break; case 1: tCoinOrder.setAdminProportion(proportion.getAdminProportion()); tCoinOrder.setAgencyProportion(proportion.getAgencyProportion()); tCoinOrder.setAgencyId(proportion.getAgencyId()); tCoinOrder.setMerchantProportion(proportion.getMerchantProportion()); tCoinOrder.setMerchantId(proportion.getMerchantId()); break; case 2: tCoinOrder.setAdminProportion(proportion.getAdminProportion()); tCoinOrder.setAgencyProportion(proportion.getAgencyProportion()); tCoinOrder.setAgencyId(proportion.getAgencyId()); tCoinOrder.setMerchantProportion(proportion.getMerchantProportion()); tCoinOrder.setMerchantId(proportion.getMerchantId()); tCoinOrder.setPersonageProportion(proportion.getPersonageProportion()); tCoinOrder.setPersonageId(proportion.getPersonageId()); break; default: // 如果类型不匹配任何 case，则执行默认逻辑 break; } tCoinOrder.setAltInfo(airDistributionDetails.toString()); // 订单明细表 TOrderDetails tOrderDetails = new TOrderDetails(); tOrderDetails.setId(merchantOrderId); tOrderDetails.setAdminId(adminById.getId()); tOrderDetails.setEquipmentId(equipmentId); if (StringUtils.isNotEmpty(createDate)) { SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Date parse = null; try { parse = simpleDateFormat.parse(createDate); } catch (ParseException e) { throw new RuntimeException(e); } tOrderDetails.setCreateDate(parse); } else { tOrderDetails.setCreateDate(new Date()); } tOrderDetails.setOrderSn(sn); tOrderDetails.setPrice(amount); tOrderDetails.setProductName(productName); tOrderDetails.setProductNo(product.getData().getNo()); tOrderDetails.setProductNumber(productNumber); tOrderDetails.setAmount(amount); tOrderDetails.setRefundStatus("0"); tOrderDetails.setCompanyType(companyType); tOrderDetails.setMachineType(machineType); String clientSix = clientId.substring(clientId.length() - 6); String productNameMerge = ""; if (productNumber > 1) { if (machineType == null || "0".equals(machineType)) { productNameMerge = "棉花糖-" + equipment.getName() + "-" + clientSix; } else { productNameMerge = "爆米花-" + equipment.getName() + "-" + clientSix; } } else { productNameMerge = productName + "-" + equipment.getName() + "-" + clientSix; } ObjectMapper mapper = new ObjectMapper(); ObjectNode order = mapper.createObjectNode(); ArrayNode products = mapper.createArrayNode(); ObjectNode airProduct = mapper.createObjectNode(); // Name of the product. Maximum of 255 characters. // airProduct.put("name", productNameMerge); // Product description. Maximum of 500 characters. airProduct.put("desc", productNameMerge); airProduct.put("quantity", productNumber); products.add(airProduct); order.set("products", products); // 返回payment intent id和client secret Map responseMap = airwallexService.caPaymentIntent(amount, currency, requestId, merchantOrderId, order); String paymentIntentId = (String) responseMap.get("id"); String clientSecret = (String) responseMap.get("client_secret"); // 把 paymentIntentId 保存到表中 tCoinOrder.setPaymentIntentId(paymentIntentId); // boolean save = tOrderAbroadService.save(tOrderAbroad); // System.out.println("将订单存入数据库：" + save); // 拼接二维码链接给前端 // String env = AirwallexConstant.ENV; // String mode = AirwallexConstant.MODE; // String locale = "it"; String qrUrl = AirwallexConstant.QR_URL; String QR = qrUrl + "?intent_id=" + paymentIntentId + "&client_secret=" + clientSecret + "¤cy=" + currency; // 将订单存入数据库 tCoinOrderService.save(tCoinOrder); tOrderDetailsService.save(tOrderDetails); return R.ok().setData(QR); } @ApiOperation(value = "获取支付订单的信息，订单状态") @GetMapping("/retrieveAPaymentIntent") public JSON retrieveAPaymentIntent(@RequestParam String id) { log.info("查询支付订单信息"); // 这里的intId指的是paymentIntendId，也是id String intentResp = airwallexService.retrieveAPaymentIntent(id); JSONObject jsonObject = JSON.parseObject(intentResp); // 取消订单的原因 // String cancellationReason = jsonObject.getString("cancellation_reason"); // 支付信息 String amount = jsonObject.getString("amount"); String currency = jsonObject.getString("currency"); String createdAt = jsonObject.getString("created_at"); String updatedAt = jsonObject.getString("updated_at"); String status = jsonObject.getString("status"); // String customer = jsonObject.getString("customer"); // JSONObject customerObj = JSON.parseObject(customer); // String address = customerObj.getString("address"); // TODO: 要改？？？ String type = jsonObject.getJSONObject("latest_payment_attempt").getJSONObject("payment_method").getString("type"); // JSONObject jsonObject4 = Optional.ofNullable(jsonObject) // .flatMap(jsonObject3 -> Optional.ofNullable(jsonObject3.getJSONObject("customer"))) // .flatMap(jsonObject3 -> Optional.ofNullable(jsonObject3.getJSONObject("address"))) // .flatMap(jsonObject3 -> Optional.ofNullable(jsonObject3.getJSONObject("state"))) // .orElse(null); // String state = JSON.toJSONString(jsonObject4); // JSONObject jsonObject3 = Optional.ofNullable(jsonObject) // .map(jsonObject1 -> jsonObject1.getJSONObject("latest_payment_attempt")) // .map(jsonObject1 -> jsonObject1.getJSONObject("payment_method")) // .map(jsonObject1 -> jsonObject1.getJSONObject("type")) // .orElse(null); // String state = JSON.toJSONString(jsonObject3); // JSONObject stateJson = Optional.ofNullable(jsonObject) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("customer"))) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("address"))) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("state"))) // .orElse(null); // String state = JSON.toJSONString(stateJson); // JSONObject cityJson = Optional.ofNullable(jsonObject) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("latest_payment_attempt"))) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("payment_method"))) // .flatMap(jsonObject1 -> Optional.ofNullable(jsonObject1.getJSONObject("id"))) // .orElse(null); // String city = JSON.toJSONString(cityJson); Map intentDetails = new HashMap<>(); intentDetails.put("amount", amount); intentDetails.put("currency", currency); // intentDetails.put("state",state); intentDetails.put("type", type); intentDetails.put("createdAt", createdAt); intentDetails.put("status", status); return new JSONObject(intentDetails); } @ApiOperation(value = "发起退款") @PostMapping("/createARefund") public ResponseModel createARefund(@RequestBody RefundRequestBody refundRequestBody) { log.info("发起退款"); String requestId = UUID.randomUUID().toString().trim().replaceAll("-", ""); // String requestId = refundRequestBody.getRequestId(); String paymentIntentId = refundRequestBody.getPaymentIntentId(); Date refundDate = refundRequestBody.getRefundDate(); // String reason = refundRequestBody.getReason(); // QueryWrapper tOrderAbroadQueryWrapper = new QueryWrapper<>(); // tOrderAbroadQueryWrapper.eq("request_id", requestId); // TOrderAbroad orderAbroad = tOrderAbroadService.getOne(tOrderAbroadQueryWrapper); LambdaQueryWrapper lambdaQueryWrapper = Wrappers.lambdaQuery(); lambdaQueryWrapper.eq(TCoinOrder::getPaymentIntentId, paymentIntentId); TCoinOrder coinOrder = tCoinOrderService.getOne(lambdaQueryWrapper); if (coinOrder == null) { return R.fail("订单为空/error"); } // 支付状态：退款中 coinOrder.setStatus(2); // 修改订单表 // SimpleDateFormat sdf = new SimpleDateFormat(); // sdf.applyPattern("yyyy-MM-dd HH:mm:ss"); // orderAbroad.setRefundDate(sdf.format(date)); // LocalDateTime localDateTime = LocalDateTime.now(); // DateTimeFormatter dtf = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); // String format = localDateTime.format(dtf); // 退款发起时间 coinOrder.setRefundDate(refundDate); tCoinOrderService.updateById(coinOrder); // TODO: 退款要扣除用户钱包中的金额，如果金额为0或者不足，改为负数？或者提示余额不足，联系商家手动退款 // 发起退款 // String refund = airwallexService.createARefund(requestId, paymentIntentId, reason); String refund = airwallexService.createARefund(requestId, paymentIntentId); System.out.println(refund); JSONObject jsonObject = JSON.parseObject(refund); String status = jsonObject.getString("status"); // orderAbroad.set; // tOrderAbroadService.updateById(orderAbroad); // switch (status) { // case "RECEIVED" : // System.out.println("退款被接收"); // break; // case "ACCEPTED" : // System.out.println("退款被接受"); // break; // case "SUCCEEDED" : // System.out.println("退款成功"); // break; // case "FAILED" : // System.out.println("退款失败"); // break; // } // if (!status.equals("FAILED")) { if (status.equals("RECEIVED") || status.equals("ACCEPTED") || status.equals("SUCCEEDED")) { String refundId = jsonObject.getString("id"); coinOrder.setRefundId(refundId); tCoinOrderService.updateById(coinOrder); return R.ok("退款处理中，请稍候查询"); } return R.fail("退款失败"); // if (Objects.equals(status, "SUCCEEDED")) { // String refundId = jsonObject.getString("id"); // orderAbroad.setRefundId(refundId); //// orderAbroad.setPayStatus(3); // tOrderAbroadService.updateById(orderAbroad); // return R.ok("退款申请中，请稍候查询"); // } else { // return R.ok("退款失败"); // } } @ApiOperation(value = "查询某笔退款详情") @GetMapping("/retrieveARefund/{id}") public Map retrieveARefund(@PathVariable("id") String refundId) { log.info("根据rfd_查询某笔退款详情"); // String requestId = UUID.randomUUID().toString().trim().replaceAll("-", ""); String refundResp = airwallexService.retrieveARefund(refundId); JSONObject jsonObject = JSON.parseObject(refundResp); String amount = jsonObject.getString("amount"); String status = jsonObject.getString("status"); String currency = jsonObject.getString("currency"); String paymentIntentId = jsonObject.getString("payment_intent_id"); String createdAt = jsonObject.getString("created_at"); Map hashMap = new HashMap<>(); hashMap.put("amount", amount); hashMap.put("status", status); hashMap.put("currency", currency); hashMap.put("payment_intent_id", paymentIntentId); hashMap.put("created_at", createdAt); // if (status.equals("SUCCEEDED")) { // // LambdaQueryWrapper lambdaQueryWrapper = Wrappers.lambdaQuery(); // lambdaQueryWrapper.eq(TOrderAbroad::getRefundId, refundId); // TOrderAbroad orderAbroad = tOrderAbroadService.getOne(lambdaQueryWrapper); // //// if (orderAbroad == null ) { //// return "订单为空/error"; //// } // if (Objects.isNull(orderAbroad)) { // return "订单为空/error"; // } // // 设置支付状态为 3已退款 // orderAbroad.setPayStatus(3); // tOrderAbroadService.updateById(orderAbroad); // } return hashMap; } @ApiOperation(value = "新建一笔付款,用于提现") @PostMapping("/caPayment") public R caPayment(@RequestBody CaPaymentRequestDTO caPaymentRequestDTO) { Long adminId = caPaymentRequestDTO.getAdminId(); String resp = airwallexService.caPayment(caPaymentRequestDTO); ObjectMapper objectMapper = new ObjectMapper(); JsonNode jsonNode = null; try { jsonNode = objectMapper.readTree(resp); } catch (JsonProcessingException e) { e.printStackTrace(); } // 断言确保 jsonNode 不为 null assert jsonNode != null; String paymentId = jsonNode.get("payment_id").asText(); String paymentCurrency = jsonNode.get("payment_currency").asText(); String paymentAmountStr = jsonNode.get("payment_amount").asText(); String beneficiaryId = jsonNode.get("beneficiary_id").asText(); String createdAtStr = jsonNode.get("created_at").asText(); // 保存支付提现明细 TAirwallexPayment tAirwallexPayment = new TAirwallexPayment(); tAirwallexPayment.setPaymentId(paymentId); tAirwallexPayment.setPaymentCurrency(paymentCurrency); BigDecimal paymentAmount = new BigDecimal(paymentAmountStr); tAirwallexPayment.setPaymentAmount(paymentAmount); tAirwallexPayment.setBeneficiaryId(beneficiaryId); DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ssZ"); OffsetDateTime createdAt = OffsetDateTime.parse(createdAtStr, formatter); Timestamp from = Timestamp.from(createdAt.toInstant()); tAirwallexPayment.setCreateTime(from); tAirwallexPayment.setAdminId(adminId); tAirwallexPaymentService.save(tAirwallexPayment); // TODO: 默认每次将余额全部提现,考虑货币 // tAirwallexWalletService.list() // LambdaQueryWrapper wrapper = Wrappers.lambdaQuery(); // wrapper.eq(TAirwallexWallet::getAdminId, adminId); //// List list = tAirwallexWalletService.list(wrapper); // TAirwallexWallet one = tAirwallexWalletService.getOne(wrapper); // String accountCurrency = one.getAccountCurrency(); // BigDecimal accountAmount = one.getAccountAmount(); // 先判断货币是否一样 // if (accountCurrency.equals(paymentCurrency)) { // accountAmount = accountAmount.subtract(paymentAmount); // } else { // // // } // 返回 payment_id return R.ok(paymentId); } @ApiOperation(value = "查询支付结果") @GetMapping("/getPaymentById/{payment_id}") public R getPaymentById(@PathVariable("payment_id") String paymentId) { String resp = airwallexService.getPaymentById(paymentId); return R.ok(resp); } @ApiOperation(value = "查询当前账户余额") @GetMapping("/getCurrentBalances") public R getCurrentBalances() { String resp = airwallexService.getCurrentBalances(); return R.ok(resp); } /** * 获取 Airwallex 分销明细 * * @param proportion * @param price * @return */ public ObjectNode getDistributionDetails(TProportion proportion, BigDecimal price) { // 获取分账有几方：0：分账方2个，1：分账方3个，2：分账方4个，3：分账方超4个 Integer type = proportion.getType(); // 空中云汇 分账明细参数 // ArrayNode altInfos = new ObjectMapper().createArrayNode(); ArrayNode altInfos = JsonNodeFactory.instance.arrayNode(); ObjectNode distributionDetails = JsonNodeFactory.instance.objectNode(); BigDecimal airProportion = null, // 空中云汇平台分销百分比，假设是0 selfProportion = null, // 商家自己的分销百分比 agencyProportion = null, // 一级分销商分销百分比 merchantProportion = null; // 二级分销商分销百分比 BigDecimal airAmount = null, // 空中云汇的钱，假设是0 selfAmount = null, // 商家自己所得的钱 agencyAmount = null, // 一级分销商所得的钱 merchantAmount = null; // 二级分销商所得的钱 TAirwallexWallet selfAirWallet = null, // 商家收款信息 agencyAirWallet = null, // 一级分销商收款信息 merchantAirWallet = null; // 二级分销商收款信息 ObjectNode airJson = null, // 空中云汇 selfJson = null, // 商家 agencyJson = null, // 一级 merchantJson = null; // 二级 // 取消平台扣手续费，将price四舍五入保留2位小数 BigDecimal cutPrice = price.setScale(2, RoundingMode.HALF_UP); BigDecimal refuseAmount = new BigDecimal(0.00); switch (type) { case 0: // 分账方有2个：申泽admin + 商家proportion // 目前都暂定空中云汇平台分销为 0 // airProportion = proportion.getAdminProportion(); // 申泽的分销 eg.1% 不显示 // adminProportion = proportion.getAdminProportion(); // 商家自己的分销 selfProportion = proportion.getProportion(); // 平台分销获得利润 // airAmount = cutPrice.multiply(airProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_UP); // 商家分销获得利润，五舍六入 selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); // Airwallex 平台收款信息表 // Long adminId = proportion.getAdminId(); // LambdaQueryWrapper wrapper = Wrappers.lambdaQuery(); // wrapper.eq(TAirwallexMch::getAdminId, proportion.getAdminId()); // selfAirMch = airwallexMchService.getOne(wrapper); // Airwallex 钱包信息 LambdaQueryWrapper query = Wrappers.lambdaQuery(); query.eq(TAirwallexWallet::getAdminId, proportion.getAdminId()); selfAirWallet = airwallexWalletService.getOne(query); // 平台分销 // airJson = JsonNodeFactory.instance.objectNode(); // // 分账方受益人编号 // airJson.put("altMchId", selfAirMch.getBeneficiaryId()); // // 受益人所分金额，单位美元$ // airJson.put("altAirAmount", airAmount.toString()); // altInfos.add(airJson); // 商家分销 selfJson = JsonNodeFactory.instance.objectNode(); selfJson.put("airBeneId", selfAirWallet.getAdminId()); // 受益人Bene编号，使用adminId selfJson.put("airAmount", selfAmount.toString()); altInfos.add(selfJson); break; case 1: // 分账方有3个：申泽admin + 商家proportion + 商家一级agency // 商家自己的分销 selfProportion = proportion.getProportion(); // 一级代理的分销 agencyProportion = proportion.getAgencyProportion(); // 商家分销获得利润 selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); // Airwallex 平台收款信息表 agencyAirWallet = airwallexWalletService.getAirWallet(proportion.getAgencyId()); selfAirWallet = airwallexWalletService.getAirWallet(proportion.getAdminId()); if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) { // 一级代理获得利润 agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); agencyJson = JsonNodeFactory.instance.objectNode(); agencyJson.put("airBeneId", agencyAirWallet.getAdminId()); agencyJson.put("airAmount", agencyAmount.toString()); altInfos.add(agencyJson); } // 商家自己获得利润 selfJson = JsonNodeFactory.instance.objectNode(); selfJson.put("airBeneId", selfAirWallet.getAdminId()); selfJson.put("airAmount", selfAmount.toString()); altInfos.add(selfJson); break; case 2: // 分账方有4个：申泽admin + 商家self + 商家一级agency + 商家二级merchant // 商家自己的分销 selfProportion = proportion.getProportion(); // 一级代理的分销 agencyProportion = proportion.getAgencyProportion(); // 二级代理的分销 merchantProportion = proportion.getMerchantProportion(); // 商家分销获得利润，五舍六入 selfAmount = cutPrice.multiply(selfProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); // Airwallex 平台收款信息表 Long adminId = proportion.getAdminId(); if (adminId != null) { selfAirWallet = airwallexWalletService.getAirWallet(adminId); System.out.println("selfAirWallet打印出来》》》" + selfAirWallet); } Long agencyId = proportion.getAgencyId(); if (agencyId != null) { agencyAirWallet = airwallexWalletService.getAirWallet(agencyId); System.out.println("agencyAirWallet打印出来》》》" + agencyAirWallet); } Long merchantId = proportion.getMerchantId(); if (merchantId != null ) { merchantAirWallet = airwallexWalletService.getAirWallet(merchantId); System.out.println("merchantAirWallet打印出来》》》" + merchantAirWallet); } if (!(agencyProportion.compareTo(refuseAmount) == 0 || agencyProportion == null)) { // 一级代理获得利润 agencyAmount = cutPrice.multiply(agencyProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); agencyJson = JsonNodeFactory.instance.objectNode(); agencyJson.put("airBeneId", agencyAirWallet.getAdminId()); agencyJson.put("airAmount", agencyAmount.toString()); altInfos.add(agencyJson); } if (!(merchantProportion.compareTo(refuseAmount) == 0 || merchantProportion == null)) { // 二级经销商获得利润 merchantAmount = cutPrice.multiply(merchantProportion.divide(new BigDecimal(100))).setScale(2, RoundingMode.HALF_DOWN); merchantJson = JsonNodeFactory.instance.objectNode(); merchantJson.put("airBeneId", merchantAirWallet.getAdminId()); merchantJson.put("airAmount", merchantAmount.toString()); altInfos.add(merchantJson); } // 商家自己获得利润 selfJson = JsonNodeFactory.instance.objectNode(); selfJson.put("airBeneId", selfAirWallet.getAdminId()); selfJson.put("airAmount", selfAmount.toString()); altInfos.add(selfJson); break; case 3: // 分账方超过4个：申泽admin + 商家self + 商家一级agency + 商家二级merchant + 商家三级personage // personageProportion = proportion.getPersonageProportion(); break; } // 计算airAmount的总和 BigDecimal sumAmount = BigDecimal.ZERO; Iterator iterator = altInfos.iterator(); while (iterator.hasNext()) { JsonNode jsonNode = iterator.next(); String airAmounts = jsonNode.get("airAmount").asText(); if (airAmounts.equals("0.00")) { iterator.remove(); } if (jsonNode.has("airAmount")) { BigDecimal airAmountSum = new BigDecimal(jsonNode.get("airAmount").asText()); sumAmount = sumAmount.add(airAmountSum); } } // 如果sumAmount大于原本price if (sumAmount.compareTo(price) > 0) { BigDecimal subtract = sumAmount.subtract(price); Iterator iterator1 = altInfos.iterator(); while (iterator1.hasNext()) { JsonNode jsonNode = iterator1.next(); String airBeneId = jsonNode.get("airBeneId").asText(); // String airBeneId1 = jsonNode.get("airBeneId").toString(); if (airBeneId.equals(AirwallexConstant.clientid)) { BigDecimal airAmount1 = new BigDecimal(jsonNode.get("airAmount").asText()); BigDecimal fixAirAmount = airAmount1.subtract(subtract).max(BigDecimal.ZERO); // ObjectMapper objectMapper = new ObjectMapper(); // ObjectNode objectNode = objectMapper.convertValue(jsonNode, ObjectNode.class); // objectNode.put("airAmount", fixAirAmount.toString()); ((ObjectNode) jsonNode).put("airAmount", fixAirAmount.toString()); break; } } } distributionDetails.put("alt_infos", altInfos); return distributionDetails; } // 查询实时汇率 // Retrieve an indicative MarketFX quote @ApiOperation(value = "查询实时汇率") @GetMapping("/getMarketFX") public Map getMarketFX(@RequestParam Map params) { String buyCurrency = params.get("buy_currency"); String sellCurrency = params.get("sell_currency"); BigDecimal buyAmount = new BigDecimal(params.get("buy_amount")); Map marketFX = airwallexService.getMarketFX(buyCurrency, sellCurrency, buyAmount); return marketFX; } }