package com.yeshi.buwan.controller;
|
|
import com.google.gson.Gson;
|
import com.google.gson.annotations.SerializedName;
|
import com.yeshi.buwan.service.inter.order.OrderService;
|
import com.yeshi.buwan.util.RedisManager;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
@Controller
|
@RequestMapping("apple")
|
public class AppleController {
|
Logger logger = LoggerFactory.getLogger(AppleController.class);
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private OrderService orderService;
|
|
private String getRequestBody(HttpServletRequest request) {
|
try {
|
byte[] buffer = new byte[2048];
|
StringBuilder stringBuilder = new StringBuilder();
|
int readBytes;
|
while ((readBytes = request.getInputStream().read(buffer)) > 0) {
|
stringBuilder.append(new String(buffer, 0, readBytes));
|
}
|
|
return stringBuilder.toString();
|
} catch (Exception var4) {
|
return null;
|
}
|
}
|
|
/**
|
* 字段说明：https://developer.apple.com/documentation/appstoreservernotifications/responsebody
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping("notify")
|
public void notify(HttpServletRequest request, HttpServletResponse response) {
|
String content = getRequestBody(request);
|
logger.info("回调内容为：{}", content);
|
|
ResponseBody responseBody = new Gson().fromJson(content, ResponseBody.class);
|
//获取内容
|
switch (responseBody.getNotificationType()) {
|
//初次购买订阅
|
case "INITIAL_BUY":
|
|
|
break;
|
|
//表示已成功自动续订过去未能续订的过期订阅。
|
case "DID_RECOVER":
|
break;
|
|
//表示客户的订阅已成功自动续订新的交易时段。
|
case "DID_RENEW":
|
break;
|
}
|
|
|
}
|
|
private class ResponseBody {
|
@SerializedName("auto_renew_product_id")
|
private String productId;
|
@SerializedName("notification_type")
|
private String notificationType;
|
@SerializedName("original_transaction_id")
|
private long originalTransactionId;
|
@SerializedName("unified_receipt")
|
private String unifiedReceipt;
|
//Sandbox, PROD
|
private String environment;
|
@SerializedName("bid")
|
private String bundleId;
|
@SerializedName("bvrs")
|
private String version;
|
@SerializedName("auto_renew_status")
|
private boolean status;
|
|
public String getProductId() {
|
return productId;
|
}
|
|
public void setProductId(String productId) {
|
this.productId = productId;
|
}
|
|
public String getNotificationType() {
|
return notificationType;
|
}
|
|
public void setNotificationType(String notificationType) {
|
this.notificationType = notificationType;
|
}
|
|
public long getOriginalTransactionId() {
|
return originalTransactionId;
|
}
|
|
public void setOriginalTransactionId(long originalTransactionId) {
|
this.originalTransactionId = originalTransactionId;
|
}
|
|
public String getUnifiedReceipt() {
|
return unifiedReceipt;
|
}
|
|
public void setUnifiedReceipt(String unifiedReceipt) {
|
this.unifiedReceipt = unifiedReceipt;
|
}
|
|
public String getEnvironment() {
|
return environment;
|
}
|
|
public void setEnvironment(String environment) {
|
this.environment = environment;
|
}
|
|
public String getBundleId() {
|
return bundleId;
|
}
|
|
public void setBundleId(String bundleId) {
|
this.bundleId = bundleId;
|
}
|
|
public String getVersion() {
|
return version;
|
}
|
|
public void setVersion(String version) {
|
this.version = version;
|
}
|
|
public boolean isStatus() {
|
return status;
|
}
|
|
public void setStatus(boolean status) {
|
this.status = status;
|
}
|
}
|
|
|
}
|
