package org.example.ssmico.demos.web.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.serializer.SerializerFeature;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import lombok.extern.slf4j.Slf4j;
|
import org.example.ssmico.demos.web.entity.*;
|
import org.example.ssmico.demos.web.mapper.*;
|
import org.example.ssmico.demos.web.service.SctUserSerivce;
|
import org.example.ssmico.demos.web.service.impl.IcoOrderServiceImpl;
|
import org.example.ssmico.demos.web.util.*;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import project.wallet.Wallet;
|
import project.wallet.WalletExtend;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
import java.util.stream.Collectors;
|
|
/**
|
* @program: dabao
|
* @description: ico订单
|
* @create: 2024-04-10 15:48
|
**/
|
@Slf4j
|
@Controller
|
@RequestMapping({"/wap/api/icoOrder"})
|
@CrossOrigin
|
public class IcoOrderController {
|
|
@Autowired
|
private IcoOrderServiceImpl service;
|
|
@Autowired
|
private IcoNewCurrencyMapper icoNewCurrencyMapper;
|
|
@Autowired
|
private TWalletMapper tWalletMapper;
|
|
@Autowired
|
private IcoOrderMapper mapper;
|
|
@Autowired
|
private TMoneyLogMapper tMoneyLogMapper;
|
|
@Autowired
|
private SctUserSerivce sctUserSerivce;
|
|
@Autowired
|
private WalletExtendMapper walletExtendMapper;
|
|
/**
|
* app 申购/配售
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/appAdd.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ResultObject appAdd(IcoOrder icoOrder, HttpServletRequest request) throws Exception {
|
ResultObject resultObject = new ResultObject();
|
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
|
String lang = request.getHeader("lang");
|
try {
|
|
String token = request.getParameter("token");
|
String userId = RedisShardedPoolUtils.get("TOKEN_" + token);
|
// String userId = "232a10b2485531e99713c66bd9ddb4e0";
|
userId = userId.replace("\"","");
|
icoOrder.setUserId(userId);
|
resultObject = service.add(icoOrder,lang);
|
} catch (Exception e) {
|
e.printStackTrace();
|
resultObject.setCode("1");
|
resultObject.setMsg(googleTranslateUtil.translate("程序错误",lang));
|
}
|
return resultObject;
|
}
|
|
/**
|
* app 获取用户申购/配售订单
|
*
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getList.action", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
|
public ResultObject getList(Integer orderType, HttpServletRequest request) throws Exception {
|
String lang = request.getHeader("lang");
|
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
|
ResultObject resultObject = new ResultObject();
|
try {
|
String token = request.getParameter("token");
|
String userId = RedisShardedPoolUtils.get("TOKEN_" + token);
|
// String userId = "232a10b2485531e99713c66bd9ddb4e0";
|
userId = userId.replace("\"","");
|
List<IcoOrder> list = service.list(new LambdaQueryWrapper<IcoOrder>().eq(IcoOrder::getOrderType, orderType)
|
.eq(IcoOrder::getUserId, userId).orderByDesc(IcoOrder::getCreateTime));
|
resultObject.setData(list);
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(googleTranslateUtil.translate("程序错误",lang));
|
}
|
return resultObject;
|
}
|
|
/**
|
* pc 获取用户申购/配售订单
|
*
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getPageList.action", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
|
public ServerResponse getPageList(String tokenCode,Integer orderType, String userName, Integer pageNo, Integer size) {
|
if (null == pageNo || null == size) {
|
pageNo = 1;
|
size = 10;
|
}
|
LambdaQueryWrapper<SctUser> userQueryWrapper = new LambdaQueryWrapper();
|
if(StringUtils.isNotBlank(userName)){
|
userQueryWrapper.like(SctUser::getUsername,userName);
|
}
|
List<SctUser> userList = sctUserSerivce.list(userQueryWrapper);
|
List<String> ids = userList.stream().map(SctUser::getPartyUuid).collect(Collectors.toList());
|
Map<String, SctUser> userMap =
|
userList.stream().collect(Collectors.toMap(
|
SctUser::getPartyUuid,
|
obj -> obj,
|
(key1 , key2) -> key1
|
));
|
if(CollectionUtils.isEmpty(ids)){
|
return ServerResponse.createBySuccess();
|
}
|
// 创建分页对象
|
Page<IcoOrder> page = new Page<>(pageNo, size);
|
// 构造查询条件
|
LambdaQueryWrapper<IcoOrder> queryWrapper = new LambdaQueryWrapper<>();
|
if (StringUtils.isNotBlank(tokenCode)) {
|
queryWrapper.eq(IcoOrder::getTokenCode, tokenCode);
|
}
|
if(null != orderType){
|
queryWrapper.eq(IcoOrder::getOrderType,orderType);
|
}
|
queryWrapper.in(IcoOrder::getUserId,ids);
|
queryWrapper.orderByDesc(IcoOrder::getCreateTime);
|
// 分页查询数据
|
Page<IcoOrder> pageList = service.page(page, queryWrapper);
|
pageList.getRecords().forEach(f->{
|
SctUser one = userMap.get(f.getUserId());
|
if(null != one){
|
f.setUserName(one.getUsername());
|
}
|
});
|
return ServerResponse.createBySuccess(pageList);
|
}
|
|
/**
|
* pc ico认缴
|
*
|
* @param id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/subscribe.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ServerResponse subscribe(Integer id){
|
String lang = "zh-CN";
|
ResultObject result = new ResultObject();
|
try {
|
result = service.subscribe(id,lang);
|
if(result.getCode().equals("1")){
|
return ServerResponse.createByErrorMsg(result.getMsg());
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
result.setCode("1");
|
result.setMsg("程序错误");
|
}
|
return ServerResponse.createBySuccess();
|
}
|
|
/**
|
* app ico认缴
|
*
|
* @param id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/appSubscribe.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ResultObject appSubscribe(Integer id,HttpServletRequest request) throws Exception {
|
String lang = request.getHeader("lang");
|
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
|
ResultObject resultObject = new ResultObject();
|
try {
|
resultObject = service.subscribe(id, lang);
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(googleTranslateUtil.translate("程序错误",lang));
|
}
|
return resultObject;
|
}
|
|
/**
|
* pc ico客户中签
|
*
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/winBallot.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
@Transactional
|
public ServerResponse winBallot(IcoOrder icoOrder) {
|
IcoOrder order = mapper.selectById(icoOrder.getId());
|
if (null == order) {
|
return ServerResponse.createByErrorMsg("当前订单不存在");
|
}
|
IcoNewCurrency icoNewCurrency = icoNewCurrencyMapper.selectById(order.getIcoNewCurrencyId());
|
if(new Date().getTime() >= icoNewCurrency.getListingTime().getTime()){
|
return ServerResponse.createByErrorMsg("该币已经上市不能操作中签");
|
}
|
//判断是认购还是配售
|
if(order.getOrderType() == 2){
|
|
if(icoOrder.getLotteryQuantity() > order.getLotteryQuantity()){
|
return ServerResponse.createByErrorMsg("中签数量不能大于用户配售数量");
|
}
|
|
|
|
Wallet tWallet = tWalletMapper.selectOne(new LambdaQueryWrapper<Wallet>().eq(Wallet::getPartyId, order.getUserId()).last(" limit 1"));
|
if(null == tWallet){
|
return ServerResponse.createByErrorMsg("资金账户不存在");
|
}
|
//配售总价
|
Double totalPlacingPrice = icoNewCurrency.getIssuePrice()*order.getLotteryQuantity();
|
//中签总价
|
Double winningTotalPrice = icoNewCurrency.getIssuePrice()*icoOrder.getLotteryQuantity();
|
Double subtract = totalPlacingPrice-winningTotalPrice;;
|
tWallet.setMoney(tWallet.getMoney()+subtract);
|
tWalletMapper.updateById(tWallet);
|
String jsonString = JSON.toJSONString(tWallet, SerializerFeature.WriteClassName);
|
RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_PARTY_ID + tWallet.getPartyId().toString(),jsonString);
|
TMoneyLog tMoneyLog = new TMoneyLog();
|
String msg = "ICO认缴，订单id"+icoOrder.getId();
|
tMoneyLog.setUuid(UUID.randomUUID().toString().replace("-", ""));
|
tMoneyLog.setLog(msg);
|
tMoneyLog.setWallettype("USDT");
|
tMoneyLog.setPartyId(order.getUserId());
|
tMoneyLog.setAmount(totalPlacingPrice);
|
tMoneyLog.setAmountBefore(totalPlacingPrice);
|
tMoneyLog.setAmountAfter(tWallet.getMoney());
|
tMoneyLog.setContentType("ICO");
|
tMoneyLog.setCategory("中签");
|
tMoneyLog.setCreateTime(new Date());
|
tMoneyLogMapper.insert(tMoneyLog);
|
order.setStatus(3);
|
order.setLotteryQuantity(icoOrder.getLotteryQuantity());
|
|
WalletExtend walletExtend = walletExtendMapper.selectOne(new LambdaQueryWrapper<WalletExtend>()
|
.eq(WalletExtend::getPartyId, order.getUserId())
|
.eq(WalletExtend::getWallettype, order.getTokenCode()));
|
if(null != walletExtend){
|
System.out.println("=--------->"+walletExtend+"-----"+icoOrder.getLotteryQuantity());
|
double mount = walletExtend.getFrozenAmount() + icoOrder.getLotteryQuantity();
|
System.out.println("中签叠加---->"+mount);
|
walletExtend.setFrozenAmount(mount);
|
}else{
|
walletExtend = new WalletExtend();
|
walletExtend.setUuid(ApplicationUtil.getCurrentTimeUUID());
|
walletExtend.setPartyId(order.getUserId());
|
walletExtend.setWallettype(order.getTokenCode());
|
walletExtend.setFrozenAmount(order.getLotteryQuantity());
|
walletExtendMapper.insert(walletExtend);
|
String json = JSON.toJSONString(walletExtend, SerializerFeature.WriteClassName);
|
RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_EXTEND_PARTY_ID + walletExtend.getPartyId() + walletExtend.getWallettype(), json);
|
}
|
String json = JSON.toJSONString(walletExtend, SerializerFeature.WriteClassName);
|
walletExtendMapper.update(walletExtend,new LambdaUpdateWrapper<WalletExtend>().eq(WalletExtend::getUuid,walletExtend.getUuid()));
|
RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_EXTEND_PARTY_ID + walletExtend.getPartyId() + walletExtend.getWallettype(),json);
|
}else{
|
order.setStatus(2);
|
order.setLotteryQuantity(icoOrder.getLotteryQuantity());
|
}
|
service.updateById(order);
|
return ServerResponse.createBySuccess();
|
}
|
|
}
|
