3 Commits

  1. 3
      src/main/java/com/example/demo/service/Temporary/RedService.java
  2. 22
      src/main/java/com/example/demo/serviceImpl/Temporary/RedServiceImpl.java

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

@ -15,6 +15,7 @@ import java.math.BigDecimal;
public interface RedService {
BigDecimal selectSum(Integer jwcode, Integer type);
void addAmount(Integer jwcode,BigDecimal sum, Integer type);
void addAmount(Integer jwcode,BigDecimal sum, Integer type);
String sendJwcode(Integer jwcode);
String sendConsumeJwcode(Integer jwcode, Integer price);
}

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

@ -39,7 +39,7 @@ public class RedServiceImpl implements RedService {
private String BASE_URLProd ;
private static final String BASE_URLDev = "http://gf977328.natappfree.cc";
private static final String PATH = "/api/coupon/IssueRechargeRedPacket";
private static final String CONSUME_PATH = "/api/coupon/updateCostRedPacket";
private static final HttpClient CLIENT = HttpClient.newHttpClient();
@Autowired
@ -108,7 +108,27 @@ public class RedServiceImpl implements RedService {
return "{\"success\":false,\"msg\":\"网络异常\"}";
}
}
@Override
public String sendConsumeJwcode(Integer jwcode, Integer price) {
try {
String body = JSON.toJSONString(java.util.Map.of("jwcode", jwcode,"discount",price));
HttpRequest request = HttpRequest.newBuilder()
.uri(URI.create(BASE_URLProd + CONSUME_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) {

Loading…
Cancel
Save