package org.example.ssmico.demos.web.controller;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import org.example.ssmico.demos.web.entity.IcoNewCurrency;
|
import org.example.ssmico.demos.web.service.IcoNewCurrencySerivce;
|
import org.example.ssmico.demos.web.util.DateUtils;
|
import org.example.ssmico.demos.web.util.ResultObject;
|
import org.example.ssmico.demos.web.util.ServerResponse;
|
import org.example.ssmico.demos.web.vo.IcoNewCurrencyVo;
|
import org.modelmapper.ModelMapper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
|
import static cn.hutool.json.XMLTokener.entity;
|
|
/**
|
* @program: dabao
|
* @description: 新币
|
* @create: 2024-04-10 14:41
|
**/
|
@Controller
|
@RequestMapping({"/wap/api/icoNewCurrency"})
|
@CrossOrigin
|
public class IcoNewCurrencyController {
|
|
@Autowired
|
private IcoNewCurrencySerivce icoNewCurrencySerivce;
|
|
/**
|
* 新币添加
|
* @param icoNewCurrencyVo
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/add.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ServerResponse add(@RequestBody IcoNewCurrencyVo icoNewCurrencyVo) {
|
try {
|
IcoNewCurrency icoNewCurrency = new ModelMapper().map(icoNewCurrencyVo, IcoNewCurrency.class);
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getListingTime())){
|
icoNewCurrency.setListingTime(DateUtils.toDateHms(icoNewCurrencyVo.getListingTime()));
|
}
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getApplicationStartTime())){
|
icoNewCurrency.setApplicationStartTime(DateUtils.toDateHms(icoNewCurrencyVo.getApplicationStartTime()));
|
}
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getApplicationEndTime())){
|
icoNewCurrency.setApplicationEndTime(DateUtils.toDateHms(icoNewCurrencyVo.getApplicationEndTime()));
|
}
|
long count = icoNewCurrencySerivce.count(new LambdaQueryWrapper<IcoNewCurrency>()
|
.eq(IcoNewCurrency::getTokenCode,icoNewCurrency.getTokenCode()).eq(IcoNewCurrency::getType,icoNewCurrency.getType()));
|
|
if (count > 0) {
|
return ServerResponse.createByErrorMsg("已存在");
|
}
|
return ServerResponse.createBySuccess(icoNewCurrencySerivce.save(icoNewCurrency));
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
return ServerResponse.createBySuccess();
|
}
|
|
/**
|
* 新币分页查询
|
* @param tokenCode
|
* @param pageNo
|
* @param request
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getPageList.action", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
|
public ServerResponse getPageList(String tokenCode, Integer pageNo, Integer size) {
|
// 判断pageNo和size是否为空，为空则设置默认值
|
if (null == pageNo || null == size) {
|
pageNo = 1;
|
size = 10;
|
}
|
// 创建分页对象
|
Page<IcoNewCurrency> page = new Page<>(pageNo, size);
|
// 构造查询条件
|
LambdaQueryWrapper<IcoNewCurrency> queryWrapper = new LambdaQueryWrapper<>();
|
if (StringUtils.isNotBlank(tokenCode)) {
|
queryWrapper.eq(IcoNewCurrency::getTokenCode, tokenCode);
|
}
|
// 分页查询数据
|
Page<IcoNewCurrency> pageList = icoNewCurrencySerivce.page(page, queryWrapper);
|
// 返回结果
|
return ServerResponse.createBySuccess(pageList);
|
}
|
|
|
/**
|
* app获取新股
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getList.action", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
|
public ResultObject getList(Integer type) {
|
LambdaQueryWrapper<IcoNewCurrency> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(IcoNewCurrency::getListingStatus,1);
|
queryWrapper.gt(IcoNewCurrency::getListingTime,new Date());
|
if(null != type && type != 0){
|
queryWrapper.eq(IcoNewCurrency::getType, type);
|
queryWrapper.or(a->a.eq(IcoNewCurrency::getType,type).isNull(IcoNewCurrency::getListingTime));
|
}else{
|
queryWrapper.or(a->a.isNull(IcoNewCurrency::getListingTime));
|
}
|
|
queryWrapper.groupBy(IcoNewCurrency::getTokenCode)
|
.orderByAsc(IcoNewCurrency::getListingTime);
|
List<IcoNewCurrency> list = icoNewCurrencySerivce.list(queryWrapper);
|
ResultObject resultObject = new ResultObject();
|
resultObject.setData(list);
|
return resultObject;
|
}
|
|
/**
|
* app获取未上市新股
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getUnlisted.action", method = RequestMethod.GET, produces = "application/json;charset=UTF-8")
|
public ResultObject getUnlisted() {
|
LambdaQueryWrapper<IcoNewCurrency> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(IcoNewCurrency::getListingStatus,1).gt(IcoNewCurrency::getListingTime,new Date()).or(a->a.eq(IcoNewCurrency::getListingStatus,1).isNull(IcoNewCurrency::getListingTime));
|
List<IcoNewCurrency> list = icoNewCurrencySerivce.list(queryWrapper);
|
ResultObject resultObject = new ResultObject();
|
resultObject.setData(list);
|
return resultObject;
|
}
|
|
/**
|
* 修改ico
|
* @param icoNewCurrencyVo
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/update.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ServerResponse update(@RequestBody IcoNewCurrencyVo icoNewCurrencyVo) {
|
try {
|
IcoNewCurrency icoNewCurrency = new ModelMapper().map(icoNewCurrencyVo, IcoNewCurrency.class);
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getListingTime())){
|
icoNewCurrency.setListingTime(DateUtils.toDateHms(icoNewCurrencyVo.getListingTime()));
|
}
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getApplicationStartTime())){
|
icoNewCurrency.setApplicationStartTime(DateUtils.toDateHms(icoNewCurrencyVo.getApplicationStartTime()));
|
}
|
if(StringUtils.isNotBlank(icoNewCurrencyVo.getApplicationEndTime())){
|
icoNewCurrency.setApplicationEndTime(DateUtils.toDateHms(icoNewCurrencyVo.getApplicationEndTime()));
|
}
|
long count = icoNewCurrencySerivce.count(new LambdaQueryWrapper<IcoNewCurrency>()
|
.eq(IcoNewCurrency::getTokenCode,icoNewCurrency.getTokenCode())
|
.ne(IcoNewCurrency::getId, icoNewCurrency.getId())
|
.eq(IcoNewCurrency::getType,icoNewCurrency.getType()));
|
if (count > 0) {
|
return ServerResponse.createByErrorMsg("已存在");
|
}
|
icoNewCurrencySerivce.updateById(icoNewCurrency);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
return ServerResponse.createBySuccess();
|
}
|
|
/**
|
* 获取ICO
|
* @param id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/getById.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ServerResponse<IcoNewCurrency> getById(String id) {
|
return ServerResponse.createBySuccess(icoNewCurrencySerivce.getById(id));
|
}
|
|
/**
|
* 删除ico
|
* @param id
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping(value = "/deleteById.action", method = RequestMethod.POST, produces = "application/json;charset=UTF-8")
|
public ServerResponse deleteById(String id) {
|
icoNewCurrencySerivce.removeById(id);
|
return ServerResponse.createBySuccess();
|
}
|
|
}
|
