Browse Source

12月4日消费精网号传递

milestone-20251205-消费
sunjiabei 1 month ago
parent
commit
86a1151181
  1. 1
      src/main/java/com/example/demo/service/Temporary/RedService.java
  2. 20
      src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java

1
src/main/java/com/example/demo/service/Temporary/RedService.java

@ -17,4 +17,5 @@ public interface RedService {
void addAmount(Integer jwcode,BigDecimal sum, Integer type); void addAmount(Integer jwcode,BigDecimal sum, Integer type);
String sendJwcode(Integer jwcode); String sendJwcode(Integer jwcode);
String sendConsumeJwcode(Integer jwcode, Integer price);
} }

20
src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java

@ -108,7 +108,27 @@ public class RedServiceImpl implements RedService {
return "{\"success\":false,\"msg\":\"网络异常\"}"; return "{\"success\":false,\"msg\":\"网络异常\"}";
} }
} }
@Override
public String sendConsumeJwcode(Integer jwcode, Integer price) {
try {
String body = JSON.toJSONString(java.util.Map.of("jwcode", jwcode,"price",price));
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(BASE_URLProd + PATH)) //URL记得换
.header("Content-Type", "application/json")
.POST(HttpRequest.BodyPublishers.ofString(body))
.build();
HttpResponse<String> resp = CLIENT.send(request, HttpResponse.BodyHandlers.ofString());
if (resp.statusCode() != 200) {
log.warn("红包接口异常,status:{},body:{}", resp.statusCode(), resp.body());
}
return resp.body();
} catch (IOException | InterruptedException e) {
log.error("调用红包接口失败,jwcode:{}", jwcode, e);
return "{\"success\":false,\"msg\":\"网络异常\"}";
}
}
// --- 校验方法 --- // --- 校验方法 ---
private void validateParams(Integer jwcode, Integer type, BigDecimal delta) { private void validateParams(Integer jwcode, Integer type, BigDecimal delta) {

Loading…
Cancel
Save