diff --git a/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClient.java b/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClient.java new file mode 100644 index 00000000..91b620f4 --- /dev/null +++ b/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClient.java @@ -0,0 +1,15 @@ +package com.red.circle.external.inner.endpoint.binance; + +import com.red.circle.external.inner.endpoint.binance.api.BinanceClientApi; +import com.red.circle.external.inner.endpoint.censor.api.CensorImageClientApi; +import org.springframework.cloud.openfeign.FeignClient; + +/** + * 图片安全鉴定. + * + * @author pengliang on 2023/10/17 + */ +@FeignClient(name = "binanceClient", url = "${feign.external.url}" + + CensorImageClientApi.API_PREFIX) +public interface BinanceClient extends BinanceClientApi { +} diff --git a/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/api/BinanceClientApi.java b/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/api/BinanceClientApi.java new file mode 100644 index 00000000..6030b2c6 --- /dev/null +++ b/rc-service/rc-inner-api/external-inner/external-inner-api/src/main/java/com/red/circle/external/inner/endpoint/binance/api/BinanceClientApi.java @@ -0,0 +1,31 @@ +package com.red.circle.external.inner.endpoint.binance.api; + +import com.red.circle.framework.dto.ResultResponse; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestParam; + +import java.io.UnsupportedEncodingException; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; + +/** + * 图片安全鉴定. + * + * @author pengliang on 2023/10/17 + */ +public interface BinanceClientApi { + + String API_PREFIX = "/binance/client"; + + /** + * 鉴定. + * + * @param txId 被鉴定的图片url + */ + @GetMapping("/deposit/history") + ResultResponse depositHistory(@RequestParam("txId") String txId); + + @GetMapping("/transactions") + ResultResponse transactions(@RequestParam("orderId") String orderId) + throws UnsupportedEncodingException, NoSuchAlgorithmException, InvalidKeyException; +} diff --git a/rc-service/rc-inner-api/other-inner/other-inner-model/src/main/java/com/red/circle/other/inner/enums/freight/FreightPolicyEnum.java b/rc-service/rc-inner-api/other-inner/other-inner-model/src/main/java/com/red/circle/other/inner/enums/freight/FreightPolicyEnum.java new file mode 100644 index 00000000..89514eac --- /dev/null +++ b/rc-service/rc-inner-api/other-inner/other-inner-model/src/main/java/com/red/circle/other/inner/enums/freight/FreightPolicyEnum.java @@ -0,0 +1,54 @@ +package com.red.circle.other.inner.enums.freight; + + +import java.math.BigDecimal; +import java.math.RoundingMode; + +/** + * 币商政策. + * + * @author pengliang on 2019/10/24 14:35 + */ +public enum FreightPolicyEnum { + + G(0, 10000), + + F(100, 11300), + + E(300, 11400), + + D(500, 11500), + + C(1000, 11600), + + B(2000, 12000), + + A(3000, 12200), + + S(5000, 12500); + + + private final Integer price; + + private final Integer ratio; + + FreightPolicyEnum(Integer price, Integer ratio) { + this.price = price; + this.ratio = ratio; + } + + public static BigDecimal earnPoints(BigDecimal amount) { + FreightPolicyEnum[] values = FreightPolicyEnum.values(); + for (int i = values.length - 1; i >= 0; i--) { + FreightPolicyEnum value = values[i]; + if (value.price.compareTo(amount.intValue()) <= 0) { + return amount.multiply(new BigDecimal(value.ratio)).setScale(0, RoundingMode.FLOOR); + } + } + return BigDecimal.ZERO; + } + + public static void main(String[] args) { + System.out.println(FreightPolicyEnum.earnPoints(new BigDecimal(12))); + } +} diff --git a/rc-service/rc-service-external/external-infrastructure/pom.xml b/rc-service/rc-service-external/external-infrastructure/pom.xml index 5628b86e..be5796e8 100644 --- a/rc-service/rc-service-external/external-infrastructure/pom.xml +++ b/rc-service/rc-service-external/external-infrastructure/pom.xml @@ -51,6 +51,30 @@ component-push + + io.github.binance + binance-pay + 2.0.0 + + + + io.github.binance + binance-wallet + 1.1.0 + + + + com.squareup.okhttp3 + okhttp + 4.12.0 + + + + com.squareup.okhttp3 + logging-interceptor + 4.12.0 + + diff --git a/rc-service/rc-service-external/external-infrastructure/src/main/java/com/red/circle/external/infra/props/BinanceProperties.java b/rc-service/rc-service-external/external-infrastructure/src/main/java/com/red/circle/external/infra/props/BinanceProperties.java new file mode 100644 index 00000000..8562bfc8 --- /dev/null +++ b/rc-service/rc-service-external/external-infrastructure/src/main/java/com/red/circle/external/infra/props/BinanceProperties.java @@ -0,0 +1,23 @@ +package com.red.circle.external.infra.props; + +import lombok.AccessLevel; +import lombok.Data; +import lombok.experimental.FieldDefaults; +import org.springframework.boot.context.properties.ConfigurationProperties; +import org.springframework.stereotype.Component; + +/** + * @author pengliang on 2023/9/21 + */ +@Data +@FieldDefaults(level = AccessLevel.PRIVATE) +@Component +@ConfigurationProperties(BinanceProperties.PREFIX) +public class BinanceProperties { + + public final static String PREFIX = "red-circle.binance"; + + String url; + String apiKey; + String secretKey; +} diff --git a/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClientEndpoint.java b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClientEndpoint.java new file mode 100644 index 00000000..bb3b395f --- /dev/null +++ b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/endpoint/binance/BinanceClientEndpoint.java @@ -0,0 +1,40 @@ +package com.red.circle.external.inner.endpoint.binance; + +import com.red.circle.external.inner.endpoint.binance.api.BinanceClientApi; +import com.red.circle.external.inner.endpoint.censor.api.CensorImageClientApi; +import com.red.circle.external.inner.service.binance.BinanceClientService; +import com.red.circle.framework.dto.ResultResponse; +import lombok.RequiredArgsConstructor; +import org.springframework.http.MediaType; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.io.UnsupportedEncodingException; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; + +/** + * 图片安全鉴定. + * + * @author pengliang on 2023/10/17 + */ +@Validated +@RestController +@RequestMapping(value = CensorImageClientApi.API_PREFIX, produces = MediaType.APPLICATION_JSON_VALUE) +@RequiredArgsConstructor +public class BinanceClientEndpoint implements BinanceClientApi { + + private final BinanceClientService binanceClientService; + + @Override + public ResultResponse depositHistory(String txId) { + return ResultResponse.success(binanceClientService.depositHistory(txId)); + } + + @Override + public ResultResponse transactions(String orderId) + throws UnsupportedEncodingException, NoSuchAlgorithmException, InvalidKeyException { + return ResultResponse.success(binanceClientService.transactions(orderId)); + } +} diff --git a/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/BinanceClientService.java b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/BinanceClientService.java new file mode 100644 index 00000000..8995f1f5 --- /dev/null +++ b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/BinanceClientService.java @@ -0,0 +1,19 @@ +package com.red.circle.external.inner.service.binance; + + +import java.io.UnsupportedEncodingException; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; + +/** + * minimax 相关服务. + * + * @author pengliang on 2021/3/25 + */ +public interface BinanceClientService { + + String depositHistory(String txId); + + String transactions(String orderId) + throws UnsupportedEncodingException, InvalidKeyException, NoSuchAlgorithmException; +} diff --git a/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/impl/BinanceClientServiceImpl.java b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/impl/BinanceClientServiceImpl.java new file mode 100644 index 00000000..2928badb --- /dev/null +++ b/rc-service/rc-service-external/external-inner-endpoint/src/main/java/com/red/circle/external/inner/service/binance/impl/BinanceClientServiceImpl.java @@ -0,0 +1,191 @@ +package com.red.circle.external.inner.service.binance.impl; + +import com.binance.connector.client.common.ApiClient; +import com.binance.connector.client.common.ApiResponse; +import com.binance.connector.client.common.auth.BinanceAuthenticationFactory; +import com.binance.connector.client.common.configuration.ClientConfiguration; +import com.binance.connector.client.common.configuration.SignatureConfiguration; +import com.binance.connector.client.wallet.rest.api.CapitalApi; +import com.binance.connector.client.wallet.rest.model.DepositHistoryResponse; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.red.circle.external.infra.props.BinanceProperties; +import com.red.circle.external.inner.service.binance.BinanceClientService; +import com.red.circle.tool.core.collection.CollectionUtils; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import okhttp3.OkHttpClient; +import okhttp3.Request; +import okhttp3.Response; +import org.apache.commons.codec.binary.Hex; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Service; + +import javax.crypto.Mac; +import javax.crypto.spec.SecretKeySpec; +import java.io.IOException; +import java.io.UnsupportedEncodingException; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; +import java.util.*; + +/** + * minimax 实现. + * + * @author pengliang on 2023/7/12 + */ +@Slf4j +@Service +@RequiredArgsConstructor +public class BinanceClientServiceImpl implements BinanceClientService { + + private final BinanceProperties binanceProperties; + + + @Override + public String depositHistory(String txId) { + if (StringUtils.isBlank(txId)) { + return ""; + } + ClientConfiguration clientConfiguration = new ClientConfiguration(); + clientConfiguration.setUrl(binanceProperties.getUrl()); + SignatureConfiguration signatureConfiguration = new SignatureConfiguration(); + signatureConfiguration.setApiKey(binanceProperties.getApiKey()); + signatureConfiguration.setSecretKey(binanceProperties.getSecretKey()); + clientConfiguration.setSignatureConfiguration(signatureConfiguration); + ApiClient apiClient = new ApiClient(clientConfiguration, new BinanceAuthenticationFactory()); + CapitalApi api = new CapitalApi(apiClient); + // 获取当前时间戳（毫秒级） + long currentTimeStamp = System.currentTimeMillis(); + + // 计算24小时前的时间戳（毫秒级） + long twentyFourHoursInMillis = 24 * 60 * 60 * 1000L; + long twentyFourHoursAgoTimeStamp = currentTimeStamp - twentyFourHoursInMillis; + + ApiResponse depositHistoryResponseApiResponse = + api.depositHistory(true, "USDT", 1L, twentyFourHoursAgoTimeStamp, currentTimeStamp, 0L, 1000L, 5000L, txId); + try { + return depositHistoryResponseApiResponse.getData().get(0).getAmount(); + } catch (Exception e) { + return ""; + } + + } + + @Override + public String transactions(String orderId) + throws UnsupportedEncodingException, InvalidKeyException, NoSuchAlgorithmException { + long currentTimeStamp = System.currentTimeMillis(); + + long twentyFourHoursInMillis = 24 * 60 * 60 * 1000L; + long twentyFourHoursAgoTimeStamp = currentTimeStamp - twentyFourHoursInMillis; + + Map params = new HashMap<>(); + params.put("timestamp", String.valueOf(System.currentTimeMillis())); + params.put("recvWindow", "5000"); + params.put("startTime", String.valueOf(twentyFourHoursAgoTimeStamp)); + params.put("endTime", String.valueOf(currentTimeStamp)); + + List sortedKeys = new ArrayList<>(params.keySet()); + Collections.sort(sortedKeys); + StringBuilder queryString = new StringBuilder(); + for (String key : sortedKeys) { + if (!queryString.isEmpty()) { + queryString.append("&"); + } + queryString.append(java.net.URLEncoder.encode(key, "UTF-8")) + .append("=") + .append(java.net.URLEncoder.encode(params.get(key), "UTF-8")); + } + + Mac hmacSha256 = Mac.getInstance("HmacSHA256"); + SecretKeySpec secretKey = new SecretKeySpec(binanceProperties.getSecretKey().getBytes("UTF-8"), "HmacSHA256"); + hmacSha256.init(secretKey); + byte[] signatureBytes = hmacSha256.doFinal(queryString.toString().getBytes("UTF-8")); + String signature = Hex.encodeHexString(signatureBytes); + + OkHttpClient client = new OkHttpClient(); + String finalUrl = binanceProperties.getUrl() + "/sapi/v1/pay/transactions" + "?" + queryString + "&signature=" + signature; + Request request = new Request.Builder() + .url(finalUrl) + .addHeader("X-MBX-APIKEY", binanceProperties.getApiKey()) + .build(); + + try (Response response = client.newCall(request).execute()) { + assert response.body() != null; + String string = response.body().string(); + Map map = parseOrderIdAndAmount(string); + return CollectionUtils.isEmpty(map) ? "" : map.get(orderId); + } catch (IOException e) { + return ""; + } + } + + public static Map parseOrderIdAndAmount(String responseBody) { + Map orderMap = new HashMap<>(); + + try { + // 创建ObjectMapper实例 + ObjectMapper objectMapper = new ObjectMapper(); + + // 解析JSON + JsonNode rootNode = objectMapper.readTree(responseBody); + + // 获取data数组 + JsonNode dataNode = rootNode.get("data"); + + // 检查data是否存在且是数组 + if (dataNode != null && dataNode.isArray()) { + // 遍历数组中的每个元素 + for (JsonNode node : dataNode) { + // 提取orderId + JsonNode orderIdNode = node.get("orderId"); + // 提取amount + JsonNode amountNode = node.get("amount"); + + // 只有当两个字段都存在且为字符串类型时才添加到Map + if (orderIdNode != null && orderIdNode.isTextual() && + amountNode != null && amountNode.isTextual()) { + orderMap.put(orderIdNode.asText(), amountNode.asText()); + } + } + } + } catch (Exception e) { + return orderMap; + } + return orderMap; + } + + public static void main(String[] args) { + ClientConfiguration clientConfiguration = new ClientConfiguration(); + clientConfiguration.setUrl("https://api.binance.com"); + SignatureConfiguration signatureConfiguration = new SignatureConfiguration(); + signatureConfiguration.setApiKey("币安的Key"); + signatureConfiguration.setSecretKey("币安的密钥"); + clientConfiguration.setSignatureConfiguration(signatureConfiguration); + + ApiClient apiClient = new ApiClient(clientConfiguration, new BinanceAuthenticationFactory()); + + CapitalApi api = new CapitalApi(apiClient); + + // 获取当前时间戳（毫秒级） + long currentTimeStamp = System.currentTimeMillis(); + + // 计算24小时前的时间戳（毫秒级） + long twentyFourHoursInMillis = 24 * 60 * 60 * 1000L; + long twentyFourHoursAgoTimeStamp = currentTimeStamp - twentyFourHoursInMillis; + + + System.out.println("currentTimeStamp: " + currentTimeStamp); + System.out.println("twentyFourHoursAgoTimeStamp: " + twentyFourHoursAgoTimeStamp); + + ApiResponse depositHistoryResponseApiResponse = + api.depositHistory(true, "USDT", 1L, twentyFourHoursAgoTimeStamp, currentTimeStamp, 0L, 1000L, 5000L, ""); + + System.out.println(depositHistoryResponseApiResponse.getStatusCode()); + System.out.println(depositHistoryResponseApiResponse.getData().get(0).getAmount()); + + + } + +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/FreightRechargeCmdExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/FreightRechargeCmdExe.java new file mode 100644 index 00000000..316cf184 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/user/FreightRechargeCmdExe.java @@ -0,0 +1,205 @@ +package com.red.circle.other.app.command.user; + +import com.red.circle.common.business.core.enums.SysOriginPlatformEnum; +import com.red.circle.component.redis.service.RedisService; +import com.red.circle.external.inner.endpoint.binance.BinanceClient; +import com.red.circle.framework.core.asserts.ResponseAssert; +import com.red.circle.framework.core.response.CommonErrorCode; +import com.red.circle.order.inner.endpoint.UserFreightRechargeRecordClient; +import com.red.circle.other.app.dto.cmd.user.user.FreightRechargeCmd; +import com.red.circle.other.app.scheduler.MyAmazingBot; +import com.red.circle.other.domain.gateway.user.UserProfileGateway; +import com.red.circle.other.domain.model.user.UserProfile; +import com.red.circle.other.inner.asserts.ImErrorCode; +import com.red.circle.other.inner.asserts.user.UserErrorCode; +import com.red.circle.other.inner.endpoint.material.props.BadgeBackpackClient; +import com.red.circle.other.inner.endpoint.material.props.BadgeSourceClient; +import com.red.circle.other.inner.enums.freight.FreightPolicyEnum; +import com.red.circle.tool.core.num.ArithmeticUtils; +import com.red.circle.wallet.inner.endpoint.freight.FreightGoldClient; +import com.red.circle.wallet.inner.error.FreightErrorCode; +import com.red.circle.wallet.inner.model.cmd.AddFreightBalanceRunningWaterCmd; +import com.red.circle.wallet.inner.model.cmd.FreightAgentReviewCmd; +import com.red.circle.wallet.inner.model.dto.UserFreightBalanceDTO; +import com.red.circle.wallet.inner.model.enums.FreightBalanceOrigin; +import lombok.RequiredArgsConstructor; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Component; + +import java.io.UnsupportedEncodingException; +import java.math.BigDecimal; +import java.math.RoundingMode; +import java.security.InvalidKeyException; +import java.security.NoSuchAlgorithmException; +import java.util.Objects; +import java.util.Optional; + +/** + * @author longli on 2024/3/22 + */ + +@Component +@RequiredArgsConstructor +public class FreightRechargeCmdExe { + + private final BadgeBackpackClient badgeBackpackClient; + private final RedisService redisService; + private final UserProfileGateway userProfileGateway; + private final BinanceClient binanceClient; + private final FreightGoldClient freightGoldClient; + private final UserFreightRechargeRecordClient userFreightRechargeRecordClient; + private final BadgeSourceClient badgeSourceClient; + + public void recharge(FreightRechargeCmd cmd) { + UserProfile userProfile = userProfileGateway.getByUserId(cmd.getReqUserId()); + ResponseAssert.notNull(ImErrorCode.NOT_FOUND_USER_INFO, userProfile); + ResponseAssert.isTrue(UserErrorCode.USER_INFO_NOT_FOUND, + Objects.equals(userProfile.getOriginSys(), cmd.requireReqSysOrigin())); + + ResponseAssert.isFalse(FreightErrorCode.THE_GOLD_COINS_HAVE_ARRIVED, freightGoldClient.existsRecord(cmd.getTxId()).getBody()); + + String lockKey = "back_send_freight_ship:" + cmd.getTxId(); + try { + // 操作冲突 + ResponseAssert.isTrue(CommonErrorCode.OPERATION_CONFLICT, redisService.lock(lockKey, 60)); + + String dollar = ""; + if (cmd.getTxId().length() == 18) { + dollar = binanceClient.transactions(cmd.getTxId()).getBody(); + } else { + dollar = binanceClient.depositHistory(cmd.getTxId()).getBody(); + } + ResponseAssert.isTrue(FreightErrorCode.INCORRECT_ORDER_NUMBER, StringUtils.isNotBlank(dollar)); + + BigDecimal bigDecimal = new BigDecimal(dollar); + + BigDecimal earnPoints = FreightPolicyEnum.earnPoints(bigDecimal); + + BigDecimal rechargeRatio = freightGoldClient.rechargeRatio(cmd.getReqUserId()).getBody(); + if (rechargeRatio.compareTo(BigDecimal.ZERO) > 0) { + earnPoints = bigDecimal.multiply(rechargeRatio).setScale(0, RoundingMode.FLOOR); + } + + // 操作失败 + ResponseAssert.isTrue(CommonErrorCode.OPERATING_FAILURE, + incrCandyBalance(cmd.requireReqSysOrigin(), cmd.getReqUserId(), earnPoints)); + + StringBuilder stringBuilder = new StringBuilder(); + stringBuilder.append("Hooka 币商充值").append("\n") + .append("用户ID:").append(userProfile.getAccount()).append("\n") + .append("充值金额: ").append(bigDecimal).append("\n") + .append("自动到账金币: ").append(earnPoints).append("\n") + .append("订单号: ").append(cmd.getTxId()); + sendTelegram(stringBuilder); + + // 插入流水 + if (ArithmeticUtils.gte(earnPoints, BigDecimal.ONE)) { + + BigDecimal balance = getAvailableBalance(cmd.getReqUserId()); + + freightGoldClient.addRunningWater(new AddFreightBalanceRunningWaterCmd() + + .setSysOrigin(cmd.requireReqSysOrigin()) + .setUserId(cmd.getReqUserId()) + .setAcceptUserId(cmd.getReqUserId()) + .setType(0) + .setQuantity(earnPoints) + .setUsdQuantity(BigDecimal.ZERO) + .setBalance(balance) + .setRechargeType("USDT-进货") + .setAmount(bigDecimal) + .setOrigin(FreightBalanceOrigin.PURCHASE.name()) + .setRemark(cmd.getTxId()) + .setCreateUser(cmd.getReqUserId()) + .setUpdateUser(cmd.getReqUserId())); + + // 记录充值金额: 货运代理充值500以上则发送货运代理徽章 + BigDecimal amount = userFreightRechargeRecordClient.inrNowMonthAmount(cmd.getReqUserId(), + ArithmeticUtils.lteZero(bigDecimal) ? BigDecimal.ZERO : bigDecimal) + .getBody(); + sendFreightShipBadge(cmd.getReqUserId(), amount); + } + } catch (UnsupportedEncodingException | NoSuchAlgorithmException | InvalidKeyException e) { + throw new RuntimeException(e); + } finally { + redisService.unlock(lockKey); + } + + } + + private void sendTelegram(StringBuilder stringBuilder) { + //机器人来咯 + MyAmazingBot myAmazingBot = new MyAmazingBot(); + myAmazingBot.sendMsg("机器人群组", stringBuilder.toString()); + } + + private BigDecimal getAvailableBalance(Long userId) { + return Optional.ofNullable( + ResponseAssert.requiredSuccess(freightGoldClient.getFreightBalance(userId))) + .map(balance -> balance.getEarnPoints() + .subtract(balance.getConsumptionPoints()) + .setScale(2, RoundingMode.DOWN)) + .orElse(BigDecimal.ZERO); + } + + /** + * 余额如果大于1250则发送货运代理徽章. + * + * @param userId 代理用户id. + * @param balance 代理余额. + */ + public void sendFreightShipBadge(Long userId, BigDecimal balance) { + + if (Objects.isNull(balance)) { + return; + } + + Long freightBadgeId = getFreightBadgeId(); + if (Objects.isNull(freightBadgeId)) { + return; + } + if (balance.compareTo(BigDecimal.valueOf(500)) < 0) { + return; + } + badgeBackpackClient.giveBadgePermanent(freightBadgeId, userId); + + } + + private boolean incrCandyBalance(String sysOrigin, Long userId, + BigDecimal quantity) { + UserFreightBalanceDTO freightBalance = freightGoldClient.getFreightBalance(userId) + .getBody(); + + if (Objects.isNull(freightBalance)) { + + ResponseAssert.isFalse( + UserErrorCode.USER_IS_SELLER, ResponseAssert.requiredSuccess( + freightGoldClient.existsSeller(userId))); + + //获得货运代理徽章 + Long badgeId = getFreightBadgeId(); + if (Objects.nonNull(badgeId) && quantity.compareTo(BigDecimal.valueOf(1250)) >= 0) { + //发送货运代理徽章 + badgeBackpackClient.giveBadgePermanent(badgeId, userId); + } + + // 增加新开货运代理审查记录 + freightGoldClient.addFreightAgentReview(new FreightAgentReviewCmd() + .setSysOrigin(sysOrigin) + .setUserId(userId) + ); + + } + if (Objects.equals(Boolean.TRUE, ResponseAssert.requiredSuccess( + freightGoldClient.incrCandyBalance(SysOriginPlatformEnum.valueOf(sysOrigin), userId, + quantity)))) { + return Boolean.TRUE; + } + + return Boolean.FALSE; + } + + private Long getFreightBadgeId() { + return badgeSourceClient.getFreightBadgeId().getBody(); + } +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/user/user/FreightRechargeCmd.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/user/user/FreightRechargeCmd.java new file mode 100644 index 00000000..a57fb9ee --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/user/user/FreightRechargeCmd.java @@ -0,0 +1,22 @@ +package com.red.circle.other.app.dto.cmd.user.user; + +import com.red.circle.common.business.dto.cmd.AppExtCommand; +import jakarta.validation.constraints.NotBlank; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + *

+ * 填写邀请用户. + *

+ * + * @author pengshigang + * @since 2023-12-20 + */ +@Data +@EqualsAndHashCode(callSuper = false) +public class FreightRechargeCmd extends AppExtCommand { + + @NotBlank(message = "txId required.") + private String txId; +}