1、用户详细信息添加国家、职业、用户名修改剩余次数
2、积分不够 返回异常提示类型更改 3、添加根据ip解析地理位置测试接口 4、更新积分刷新机制(每月1号0点刷新年费用户积分)
This commit is contained in:
@@ -18,9 +18,11 @@ public class AccountTask {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* 每周日晚上刷新 年付用户、月付用户的积分
|
* 每周日晚上刷新 年付用户、月付用户的积分
|
||||||
|
* 替换为
|
||||||
|
* 每个月月初只刷新年付用户的积分
|
||||||
*/
|
*/
|
||||||
// @Scheduled(cron = "59 59 23 ? * SUN")
|
|
||||||
// @Scheduled(cron = "59 59 23 * * ?")
|
// @Scheduled(cron = "59 59 23 * * ?")
|
||||||
|
@Scheduled(cron = "0 0 0 1 * ?")
|
||||||
public void refreshCreditsMonthly() {
|
public void refreshCreditsMonthly() {
|
||||||
log.info("每周日晚11:59:59刷新付费用户积分为 6000");
|
log.info("每周日晚11:59:59刷新付费用户积分为 6000");
|
||||||
accountService.refreshCreditsWeekly();
|
accountService.refreshCreditsWeekly();
|
||||||
|
|||||||
@@ -112,4 +112,10 @@ public class StripeController {
|
|||||||
return Response.success(stripeService.detachCustomerAllPaymentMethod(name, email));
|
return Response.success(stripeService.detachCustomerAllPaymentMethod(name, email));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ApiOperation("临时 获取ip")
|
||||||
|
@GetMapping("/getIp2")
|
||||||
|
public Response<String> getIp2(HttpServletRequest request) {
|
||||||
|
return Response.success(stripeService.getIp2(request));
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -57,6 +57,11 @@ public class Account implements Serializable {
|
|||||||
*/
|
*/
|
||||||
private String country;
|
private String country;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 职业
|
||||||
|
*/
|
||||||
|
private String occupation;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 账户有效期开始时间
|
* 账户有效期开始时间
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -3,13 +3,12 @@ package com.ai.da.model.vo;
|
|||||||
import com.ai.da.mapper.primary.entity.AccountExtend;
|
import com.ai.da.mapper.primary.entity.AccountExtend;
|
||||||
import io.swagger.annotations.ApiModel;
|
import io.swagger.annotations.ApiModel;
|
||||||
import io.swagger.annotations.ApiModelProperty;
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
import io.swagger.models.auth.In;
|
|
||||||
import lombok.AllArgsConstructor;
|
import lombok.AllArgsConstructor;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
import lombok.NoArgsConstructor;
|
import lombok.NoArgsConstructor;
|
||||||
|
|
||||||
import javax.validation.constraints.NotBlank;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
@AllArgsConstructor
|
@AllArgsConstructor
|
||||||
@NoArgsConstructor
|
@NoArgsConstructor
|
||||||
@@ -68,4 +67,10 @@ public class AccountLoginVO {
|
|||||||
// 是否是affiliate
|
// 是否是affiliate
|
||||||
private boolean isAffiliate = false;
|
private boolean isAffiliate = false;
|
||||||
|
|
||||||
|
private String country;
|
||||||
|
|
||||||
|
private String occupation;
|
||||||
|
|
||||||
|
private Map<String, Long> usernameModify;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -47,4 +47,6 @@ public interface StripeService {
|
|||||||
List<Map<String,String>> getCustomerPaymentMethod(String name, String email);
|
List<Map<String,String>> getCustomerPaymentMethod(String name, String email);
|
||||||
|
|
||||||
String detachCustomerAllPaymentMethod(String name, String email);
|
String detachCustomerAllPaymentMethod(String name, String email);
|
||||||
|
|
||||||
|
String getIp2(HttpServletRequest request);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1622,7 +1622,8 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
|
|||||||
// 刷新账号有效期截止之前的年付用户的积分
|
// 刷新账号有效期截止之前的年付用户的积分
|
||||||
long epochMilli = Instant.now().toEpochMilli();
|
long epochMilli = Instant.now().toEpochMilli();
|
||||||
accountUpdateWrapper.lambda().set(Account::getCredits, CreditsEventsEnum.INIT_WEEKLY.getValue())
|
accountUpdateWrapper.lambda().set(Account::getCredits, CreditsEventsEnum.INIT_WEEKLY.getValue())
|
||||||
.eq(Account::getSystemUser,1).or().eq(Account::getSystemUser,2)
|
.eq(Account::getSystemUser,1)
|
||||||
|
// .or().eq(Account::getSystemUser,2)
|
||||||
.gt(Account::getValidEndTime, epochMilli);
|
.gt(Account::getValidEndTime, epochMilli);
|
||||||
baseMapper.update(null,accountUpdateWrapper);
|
baseMapper.update(null,accountUpdateWrapper);
|
||||||
}
|
}
|
||||||
@@ -2462,6 +2463,8 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
|
|||||||
if (!Objects.isNull(affiliate) && affiliate.getStatus().equals("Active")) {
|
if (!Objects.isNull(affiliate) && affiliate.getStatus().equals("Active")) {
|
||||||
response.setAffiliate(true);
|
response.setAffiliate(true);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
response.setUsernameModify(getNicknameModifyTimes());
|
||||||
return response;
|
return response;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -2503,7 +2506,6 @@ public class AccountServiceImpl extends ServiceImpl<AccountMapper, Account> impl
|
|||||||
accountExtendInsert.setHeadImgUrl(pictureUrl);
|
accountExtendInsert.setHeadImgUrl(pictureUrl);
|
||||||
accountExtendInsert.setName(name);
|
accountExtendInsert.setName(name);
|
||||||
|
|
||||||
|
|
||||||
AuthPrincipalVo authPrincipalVo = UserContext.getUserHolder();
|
AuthPrincipalVo authPrincipalVo = UserContext.getUserHolder();
|
||||||
accountExtendInsert.setAccountId(authPrincipalVo.getId());
|
accountExtendInsert.setAccountId(authPrincipalVo.getId());
|
||||||
accountExtendMapper.insert(accountExtendInsert);
|
accountExtendMapper.insert(accountExtendInsert);
|
||||||
|
|||||||
@@ -592,7 +592,7 @@ public class GenerateServiceImpl extends ServiceImpl<GenerateMapper, Generate> i
|
|||||||
// 2、判断用户当前积分是否够本次生成消耗
|
// 2、判断用户当前积分是否够本次生成消耗
|
||||||
Boolean preDeduction = creditsService.creditsPreDeduction(creditsEventsEnum, 1);
|
Boolean preDeduction = creditsService.creditsPreDeduction(creditsEventsEnum, 1);
|
||||||
if (!preDeduction) {
|
if (!preDeduction) {
|
||||||
throw new BusinessException("remaining.credits.insufficient");
|
throw new BusinessException("remaining.credits.insufficient", ResultEnum.WARNING.getCode());
|
||||||
}
|
}
|
||||||
|
|
||||||
// 3、生成唯一id 使用uuid,由于uuid重复的几率很小,故取消对uuid重复性的校验
|
// 3、生成唯一id 使用uuid,由于uuid重复的几率很小,故取消对uuid重复性的校验
|
||||||
|
|||||||
@@ -5,6 +5,7 @@ import com.ai.da.common.constant.CommonConstant;
|
|||||||
import com.ai.da.common.context.UserContext;
|
import com.ai.da.common.context.UserContext;
|
||||||
import com.ai.da.common.enums.*;
|
import com.ai.da.common.enums.*;
|
||||||
import com.ai.da.common.utils.DateUtil;
|
import com.ai.da.common.utils.DateUtil;
|
||||||
|
import com.ai.da.common.utils.RequestInfoUtil;
|
||||||
import com.ai.da.common.utils.SendEmailUtil;
|
import com.ai.da.common.utils.SendEmailUtil;
|
||||||
import com.ai.da.mapper.primary.AccountMapper;
|
import com.ai.da.mapper.primary.AccountMapper;
|
||||||
import com.ai.da.mapper.primary.PaymentInfoMapper;
|
import com.ai.da.mapper.primary.PaymentInfoMapper;
|
||||||
@@ -17,6 +18,7 @@ import com.ai.da.model.dto.ProductPurchaseDTO;
|
|||||||
import com.ai.da.model.dto.SubscriptionEmailParamsDTO;
|
import com.ai.da.model.dto.SubscriptionEmailParamsDTO;
|
||||||
import com.ai.da.service.*;
|
import com.ai.da.service.*;
|
||||||
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSON;
|
||||||
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||||
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
||||||
import com.google.gson.Gson;
|
import com.google.gson.Gson;
|
||||||
@@ -36,8 +38,12 @@ import org.springframework.transaction.annotation.Transactional;
|
|||||||
|
|
||||||
import javax.annotation.Resource;
|
import javax.annotation.Resource;
|
||||||
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletRequest;
|
||||||
|
import java.io.BufferedReader;
|
||||||
|
import java.io.InputStreamReader;
|
||||||
import java.math.BigDecimal;
|
import java.math.BigDecimal;
|
||||||
import java.math.RoundingMode;
|
import java.math.RoundingMode;
|
||||||
|
import java.net.HttpURLConnection;
|
||||||
|
import java.net.URL;
|
||||||
import java.time.Instant;
|
import java.time.Instant;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.time.ZoneOffset;
|
import java.time.ZoneOffset;
|
||||||
@@ -1145,5 +1151,96 @@ public class StripeServiceImpl implements StripeService {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getIp2(HttpServletRequest request) {
|
||||||
|
/*String ip = request.getHeader("X-Forwarded-For");
|
||||||
|
String ipAddress = "";
|
||||||
|
if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){
|
||||||
|
//多次反向代理后会有多个ip值,第一个ip才是真实ip
|
||||||
|
int index = ip.indexOf(",");
|
||||||
|
if(index != -1){
|
||||||
|
ipAddress = ip.substring(0,index);
|
||||||
|
}else{
|
||||||
|
ipAddress = ip;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
ip = request.getHeader("X-Real-IP");
|
||||||
|
if(StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)){
|
||||||
|
ipAddress = ip;
|
||||||
|
}
|
||||||
|
if (!StringUtil.isNullOrEmpty(ipAddress)) {
|
||||||
|
getIPLocation(ipAddress);
|
||||||
|
}*/
|
||||||
|
String ipAddress = RequestInfoUtil.getIpAddress(request);
|
||||||
|
if (!StringUtil.isNullOrEmpty(ipAddress)) {
|
||||||
|
return getIPLocation(ipAddress);
|
||||||
|
}
|
||||||
|
|
||||||
|
return request.getRemoteAddr();
|
||||||
|
}
|
||||||
|
|
||||||
|
/* 免费 API 服务可能有请求频率限制,如果你需要处理大量 IP 地址,可能需要考虑使用付费服务或购买 IP 地理位置数据库。此外,始终要遵守 API 提供商的使用条款和隐私政策。*/
|
||||||
|
|
||||||
|
public String getIPLocation(String ip) {
|
||||||
|
// String ip = "117.143.125.1"; // 替换为你想查询的 IP 地址
|
||||||
|
// String ip = "194.5.48.180"; // 替换为你想查询的 IP 地址
|
||||||
|
String apiURL = "http://ip-api.com/json/" + ip;
|
||||||
|
|
||||||
|
try {
|
||||||
|
URL url = new URL(apiURL);
|
||||||
|
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
||||||
|
conn.setRequestMethod("GET");
|
||||||
|
conn.setRequestProperty("Accept", "application/json");
|
||||||
|
|
||||||
|
if (conn.getResponseCode() != 200) {
|
||||||
|
throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode());
|
||||||
|
}
|
||||||
|
|
||||||
|
BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
|
||||||
|
String output;
|
||||||
|
StringBuilder outputBuilder = new StringBuilder();
|
||||||
|
System.out.println("Output from Server .... \n");
|
||||||
|
while ((output = br.readLine()) != null) {
|
||||||
|
outputBuilder.append(output);
|
||||||
|
System.out.println(output);
|
||||||
|
}
|
||||||
|
conn.disconnect();
|
||||||
|
Map map = JSONObject.parseObject(outputBuilder.toString(), Map.class);
|
||||||
|
log.info("map: {}", map);
|
||||||
|
return JSON.toJSONString(map);
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void main(String[] args) {
|
||||||
|
String ip = "117.143.125.1"; // 替换为你想查询的 IP 地址
|
||||||
|
// String ip = "194.5.48.180"; // 替换为你想查询的 IP 地址
|
||||||
|
String apiURL = "http://ip-api.com/json/" + ip;
|
||||||
|
|
||||||
|
try {
|
||||||
|
URL url = new URL(apiURL);
|
||||||
|
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
||||||
|
conn.setRequestMethod("GET");
|
||||||
|
conn.setRequestProperty("Accept", "application/json");
|
||||||
|
|
||||||
|
if (conn.getResponseCode() != 200) {
|
||||||
|
throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode());
|
||||||
|
}
|
||||||
|
|
||||||
|
BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream()));
|
||||||
|
String output;
|
||||||
|
System.out.println("Output from Server .... \n");
|
||||||
|
StringBuilder outputBuilder = new StringBuilder();
|
||||||
|
while ((output = br.readLine()) != null) {
|
||||||
|
outputBuilder.append(output);
|
||||||
|
System.out.println(output);
|
||||||
|
}
|
||||||
|
conn.disconnect();
|
||||||
|
Map map = JSONObject.parseObject(outputBuilder.toString(), Map.class);
|
||||||
|
log.info("map: {}", map);
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user