package com.yami.trading.admin.controller.ico;
|
|
import cn.hutool.core.date.DateTime;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.google.common.collect.Lists;
|
import com.yami.trading.bean.data.domain.Realtime;
|
import com.yami.trading.bean.ico.domain.Ico;
|
import com.yami.trading.bean.ico.domain.UserSubscription;
|
import com.yami.trading.bean.ico.dto.UserSubscriptionDTO;
|
import com.yami.trading.bean.ico.query.IcoQuery;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.bean.item.query.ItemQuery;
|
import com.yami.trading.common.config.RequestDataHelper;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.query.QueryWrapperGenerator;
|
import com.yami.trading.huobi.data.DataCache;
|
import com.yami.trading.security.common.util.SecurityUtils;
|
import com.yami.trading.service.data.RealtimeService;
|
import com.yami.trading.service.ico.IcoService;
|
import com.yami.trading.service.ico.UserSubscriptionService;
|
import com.yami.trading.service.item.ItemService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.validation.Valid;
|
import java.math.BigDecimal;
|
import java.time.Instant;
|
import java.util.Date;
|
|
|
@Api(tags ="新币管理")
|
@RestController
|
@RequestMapping(value = "normal/adminIcoAction!")
|
public class AdminIcoController {
|
|
@Autowired
|
private IcoService icoService;
|
|
@Autowired
|
private UserSubscriptionService userSubscriptionService;
|
|
@Autowired
|
ItemService itemService;
|
|
@Autowired
|
RealtimeService realtimeService;
|
|
/**
|
* 产品列表数据
|
*/
|
@ApiOperation(value = "新币列表")
|
@GetMapping("list")
|
public Result<Page<Ico>> list(ItemQuery icoQuery, Page<Ico> page) throws Exception {
|
QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition (icoQuery, ItemQuery.class);
|
queryWrapper.orderByDesc("market_date");
|
Page<Ico> result = icoService.page(page, queryWrapper);
|
return Result.ok(result);
|
}
|
|
/**
|
* 保存产品
|
*/
|
@ApiOperation(value = "保存新币")
|
@PostMapping("save")
|
public Result <String> save(@Valid @RequestBody Ico ico) {
|
long count;
|
if (ico.getId() == null) { //新增校验
|
count = icoService.count(new LambdaQueryWrapper<Ico>()
|
.eq(Ico::getSymbol, ico.getSymbol()).or().eq(Ico::getSymbolData, ico.getSymbolData()));
|
//产品表
|
long iCount = itemService.count(new LambdaQueryWrapper<Item>()
|
.eq(Item::getSymbol, ico.getSymbol()).or().eq(Item::getSymbolData, ico.getSymbolData()));
|
if(iCount > 0){
|
throw new YamiShopBindException("Product data already exists");
|
}
|
if(count > 0){
|
throw new YamiShopBindException("Token symbol or data source code already exists");
|
}
|
} else {
|
Ico model = icoService.getById(ico.getId());
|
if (model == null) {
|
throw new YamiShopBindException("Data does not exist");
|
}
|
Date now = Date.from(Instant.now());
|
if (model.getMarketDate() != null && model.getMarketDate().before(now)){
|
if (!model.getSymbol().equalsIgnoreCase(ico.getSymbol()) ||
|
!model.getSymbolData().equalsIgnoreCase(ico.getSymbolData())) {
|
throw new YamiShopBindException("Already listed, token symbol and data source code cannot be modified");
|
}
|
}
|
|
count = icoService.count(new LambdaQueryWrapper<Ico>()
|
.ne(Ico::getId, ico.getId())
|
.and(wrapper -> wrapper
|
.eq(Ico::getSymbol, ico.getSymbol())
|
.or()
|
.eq(Ico::getSymbolData, ico.getSymbolData())));
|
if(count > 0){
|
throw new YamiShopBindException("Token symbol or data source code already exists");
|
}
|
|
//更新ico实时价格
|
/*if (model.getUnitAmount().compareTo(BigDecimal.ZERO) >0 &&
|
model.getUnitAmount().compareTo(ico.getUnitAmount()) != 0){
|
String symbol = ico.getSymbol();
|
RequestDataHelper.set("symbol", symbol);
|
LambdaQueryWrapper<Realtime> queryWrapper = new LambdaQueryWrapper<Realtime>()
|
.eq(Realtime::getSymbol, symbol)
|
.orderByDesc(Realtime::getTs)
|
.last("LIMIT 1");
|
Realtime realtime = realtimeService.getOne(queryWrapper);
|
realtime.setClose(ico.getUnitAmount());
|
realtimeService.updateById(realtime);
|
RequestDataHelper.clear();
|
DataCache.putRealtime(symbol, realtime);
|
}*/
|
}
|
//新增或编辑表单保存
|
icoService.saveOrUpdate(ico);
|
return Result.ok ( "保存产品成功" );
|
}
|
|
/**
|
* 删除产品
|
*/
|
@ApiOperation(value = "删除新币")
|
@DeleteMapping("delete")
|
public Result <String> delete(Integer id) {
|
if (id == null) {
|
throw new YamiShopBindException("id is null");
|
}
|
QueryWrapper<UserSubscription> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("ico_project_id", id);
|
long count = userSubscriptionService.count(queryWrapper);
|
if (count > 0) {
|
throw new YamiShopBindException("Subscription records exist, deletion failed");
|
}
|
if (icoService.removeById(id)) {
|
return Result.ok("删除成功");
|
}
|
return Result.ok("删除失败");
|
|
}
|
|
@ApiOperation(value = "新币申购记录列表")
|
@GetMapping("recordList")
|
public Result<Page<UserSubscriptionDTO>> recordList(IcoQuery icoQuery, Page<UserSubscriptionDTO> page) throws Exception {
|
QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition (icoQuery, IcoQuery.class);
|
queryWrapper.eq("u.del_flag", "0");
|
queryWrapper.orderByDesc("created_at");
|
Page<UserSubscriptionDTO> result = userSubscriptionService.findPage(page, queryWrapper);
|
return Result.ok(result);
|
}
|
|
/**
|
* 修改新币记录
|
*/
|
@ApiOperation(value = "修改新币记录")
|
@PostMapping("updateRecord")
|
public Result <String> save(@RequestBody UserSubscription userSubscription) {
|
return icoService.updateRecord(userSubscription);
|
}
|
|
/**
|
* 删除新币记录
|
*/
|
@ApiOperation(value = "删除新币记录")
|
@DeleteMapping("deleteRecord")
|
public Result <String> deleteRecord(Integer id) {
|
userSubscriptionService.removeById(id);
|
return Result.ok("删除记录成功");
|
}
|
|
}
|
