package com.taoke.autopay.controller;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.google.gson.TypeAdapter;
|
import com.google.gson.stream.JsonReader;
|
import com.google.gson.stream.JsonWriter;
|
import com.taoke.autopay.dao.credit.CreditExchangeRecordMapper;
|
import com.taoke.autopay.dao.credit.UserCreditRecordMapper;
|
import com.taoke.autopay.dto.admin.CreditInfoDto;
|
import com.taoke.autopay.entity.SystemConfigKeyEnum;
|
import com.taoke.autopay.entity.WxUserInfo;
|
import com.taoke.autopay.entity.credit.CreditExchangeRecord;
|
import com.taoke.autopay.entity.credit.UserAlipayBinding;
|
import com.taoke.autopay.entity.credit.UserCreditBalance;
|
import com.taoke.autopay.entity.credit.UserCreditRecord;
|
import com.taoke.autopay.exception.UserCreditExchangeException;
|
import com.taoke.autopay.manager.UserCreditExchangeManager;
|
import com.taoke.autopay.service.SystemConfigService;
|
import com.taoke.autopay.service.credit.CreditExchangeRecordService;
|
import com.taoke.autopay.service.credit.UserAlipayBindingService;
|
import com.taoke.autopay.service.credit.UserCreditBalanceService;
|
import com.taoke.autopay.service.credit.UserCreditRecordService;
|
import com.taoke.autopay.utils.Constant;
|
import com.taoke.autopay.utils.JsonUtil;
|
import com.taoke.autopay.utils.StringUtil;
|
import net.sf.json.JSONObject;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpSession;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.Date;
|
import java.util.List;
|
|
@RestController
|
@RequestMapping("/credit/api")
|
public class CreditController {
|
|
private static final Logger logger = LoggerFactory.getLogger(CreditController.class);
|
|
@Resource
|
private UserCreditBalanceService userCreditBalanceService;
|
|
@Resource
|
private UserCreditExchangeManager userCreditExchangeManager;
|
|
@Resource
|
private CreditExchangeRecordService creditExchangeRecordService;
|
|
@Resource
|
private UserAlipayBindingService userAlipayBindingService;
|
|
@Resource
|
private UserCreditRecordService userCreditRecordService;
|
|
@Resource
|
private CreditExchangeRecordService userCreditExchangeRecordService;
|
|
@Resource
|
private SystemConfigService systemConfigService;
|
|
private final Gson gson = new GsonBuilder().registerTypeAdapter(BigDecimal.class, new TypeAdapter<BigDecimal>() {
|
@Override
|
public void write(JsonWriter out, BigDecimal value) throws IOException {
|
String desc = "";
|
if (value != null) {
|
out.value(value.setScale(2, RoundingMode.HALF_UP).toString());
|
} else {
|
out.value("");
|
}
|
}
|
|
@Override
|
public BigDecimal read(JsonReader in) throws IOException {
|
return new BigDecimal("0");
|
}
|
}).create();
|
|
private Long getUserId(HttpSession session) {
|
WxUserInfo user = (WxUserInfo) session.getAttribute(Constant.SESSION_KEY_USER);
|
if (user != null) {
|
return user.getId();
|
}
|
return null;
|
}
|
|
private String getLoginLinkContent() {
|
String redictLink = systemConfigService.getValueCache(SystemConfigKeyEnum.WX_REDIRECT_LINK);
|
redictLink = redictLink.replace("snsapi_base", "snsapi_userinfo");
|
// 没有登录，返回登录链接
|
JSONObject root = new JSONObject();
|
root.put("link", redictLink);
|
return JsonUtil.loadTrueResult(Constant.RESULT_CODE_NEED_LOGIN, root);
|
}
|
|
/**
|
* 获取积分信息接口
|
* 返回积分余额，剩余积分可兑换的红包，正在兑换中的积分数量
|
*/
|
@RequestMapping("/info")
|
public String getCreditInfo(HttpSession session) {
|
Long userId = getUserId(session);
|
if (userId == null) {
|
return getLoginLinkContent();
|
}
|
int balanceAmount = 0;
|
UserCreditBalance balance = userCreditBalanceService.getCreditBalanceByUserId(userId);
|
if (balance != null) {
|
balanceAmount = balance.getCreditBalance();
|
}
|
|
BigDecimal money = new BigDecimal(0);
|
try {
|
money = userCreditExchangeManager.calculateExchangeAmount(userId, balanceAmount, false);
|
} catch (UserCreditExchangeException e) {
|
throw new RuntimeException(e);
|
}
|
|
List<CreditExchangeRecord> recordList = creditExchangeRecordService.listExchangeRecords(CreditExchangeRecordMapper.DaoQuery.builder()
|
.uid(userId)
|
.exchangeStatus(CreditExchangeRecord.STATUS_NOT_VERIFY)
|
.count(100)
|
.build());
|
int exchaningCredits = 0;
|
if (recordList != null) {
|
for (CreditExchangeRecord record : recordList) {
|
exchaningCredits += record.getConsumedCredits();
|
}
|
}
|
|
|
try {
|
return JsonUtil.loadTrueResult(gson.toJson(CreditInfoDto.builder()
|
.balance(balanceAmount)
|
.exchangeMoney(money)
|
.exchangingCredits(exchaningCredits)
|
.build()));
|
} catch (Exception e) {
|
logger.error("获取积分信息失败", e);
|
return JsonUtil.loadFalseResult("获取积分信息失败");
|
}
|
}
|
|
/**
|
* 获取支付宝绑定信息
|
*/
|
@RequestMapping("/getAlipayBinding")
|
public String getAlipayBinding(HttpSession session) {
|
Long uid = getUserId(session);
|
if (uid == null) {
|
return getLoginLinkContent();
|
}
|
|
List<UserAlipayBinding> alipayBindings = userAlipayBindingService.getBindingsByUid(uid);
|
if (alipayBindings == null || alipayBindings.isEmpty()) {
|
return JsonUtil.loadFalseResult("用户未绑定支付宝账户");
|
}
|
try {
|
return JsonUtil.loadTrueResult(alipayBindings.get(0));
|
} catch (Exception e) {
|
logger.error("获取支付宝绑定信息失败", e);
|
return JsonUtil.loadFalseResult("获取支付宝绑定信息失败");
|
}
|
}
|
|
/**
|
* 修改支付宝绑定信息
|
*/
|
@PostMapping("/updateAlipayBinding")
|
public String updateAlipayBinding(String alipayName, String alipayAccount, HttpSession session) {
|
Long userId = getUserId(session);
|
if (userId == null) {
|
return getLoginLinkContent();
|
}
|
|
List<UserAlipayBinding> alipayBindings = userAlipayBindingService.getBindingsByUid(userId);
|
if (alipayBindings != null && !alipayBindings.isEmpty()) {
|
userAlipayBindingService.updateBinding(UserAlipayBinding.builder()
|
.id(alipayBindings.get(0).getId())
|
.alipayName(alipayName)
|
.alipayAccount(alipayAccount)
|
.updateTime(new Date())
|
.build());
|
} else {
|
userAlipayBindingService.addBinding(UserAlipayBinding.builder()
|
.uid(userId)
|
.alipayName(alipayName)
|
.alipayAccount(alipayAccount)
|
.createTime(new Date())
|
.build());
|
}
|
return JsonUtil.loadTrueResult("修改成功");
|
|
}
|
|
/**
|
* 获取积分记录接口（可分页）
|
*/
|
@RequestMapping("/records")
|
public String getCreditRecords(@RequestParam(defaultValue = "1") int page,
|
@RequestParam(defaultValue = "10") int pageSize,
|
HttpSession session) {
|
Long userId = getUserId(session);
|
if (userId == null) {
|
return getLoginLinkContent();
|
}
|
UserCreditRecordMapper.DaoQuery query = UserCreditRecordMapper.DaoQuery.builder()
|
.uid(userId)
|
.start((long) (page - 1) * pageSize)
|
.count(pageSize)
|
.build();
|
List<UserCreditRecord> recordList = userCreditRecordService.listCreditRecords(query);
|
long count = userCreditRecordService.countCreditRecords(query);
|
JSONObject root = new JSONObject();
|
root.put("list", gson.toJson(recordList));
|
root.put("count", count);
|
return JsonUtil.loadTrueResult(root);
|
}
|
|
/**
|
* 积分兑换接口
|
*/
|
@PostMapping("/exchange")
|
public String exchangeCredits(@RequestParam int credits, HttpSession session) {
|
Long userId = getUserId(session);
|
if (userId == null) {
|
return getLoginLinkContent();
|
}
|
|
try {
|
userCreditExchangeManager.exchangeCredit(CreditExchangeRecord.builder()
|
.consumedCredits(credits)
|
.uid(userId)
|
.exchangeType(CreditExchangeRecord.ExchangeType.FUND_EXCHANGE)
|
.createTime(new Date())
|
.build());
|
return JsonUtil.loadTrueResult("兑换成功");
|
} catch (UserCreditExchangeException e) {
|
logger.error("积分兑换失败", e);
|
return JsonUtil.loadFalseResult(e.getMessage());
|
} catch (Exception e) {
|
logger.error("积分兑换失败", e);
|
return JsonUtil.loadFalseResult("兑换失败，请稍后重试");
|
}
|
}
|
|
/**
|
* 积分兑换接口（可分页）
|
*/
|
@PostMapping("/exchange_records")
|
public String exchangeCredits(
|
@RequestParam(defaultValue = "1") int page,
|
@RequestParam(defaultValue = "10") int pageSize,
|
HttpSession session) {
|
Long userId = getUserId(session);
|
if (userId == null) {
|
return getLoginLinkContent();
|
}
|
CreditExchangeRecordMapper.DaoQuery query = CreditExchangeRecordMapper.DaoQuery.builder()
|
.uid(userId)
|
.start((long) (page - 1) * pageSize)
|
.count(pageSize)
|
.build();
|
List<CreditExchangeRecord> recordList = userCreditExchangeRecordService.listExchangeRecords(query);
|
long count = userCreditExchangeRecordService.countExchangeRecords(query);
|
JSONObject root = new JSONObject();
|
root.put("list", gson.toJson(recordList));
|
root.put("count", count);
|
return JsonUtil.loadTrueResult(root);
|
}
|
}
|
