package com.yami.trading.admin.controller.item;
|
|
import javax.validation.Valid;
|
|
import cn.hutool.core.util.StrUtil;
|
import com.google.common.collect.Lists;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.bean.item.dto.ItemConfig;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.lang.LangUtils;
|
import com.yami.trading.common.query.QueryWrapperGenerator;
|
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.service.user.UserService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.yami.trading.bean.item.dto.ItemDTO;
|
import com.yami.trading.bean.item.mapstruct.ItemWrapper;
|
import com.yami.trading.service.item.ItemService;
|
import com.yami.trading.bean.item.query.ItemQuery;
|
|
|
|
|
/**
|
* 产品Controller
|
* @author lucas
|
* @version 2023-03-10
|
*/
|
|
@Api(tags ="永续合约管理和行情品种")
|
@RestController
|
@RequestMapping(value = "normal/adminItemAction!")
|
public class AdminItemController {
|
|
@Autowired
|
private ItemService itemService;
|
|
@Autowired
|
private ItemWrapper itemWrapper;
|
@Autowired
|
private UserService userService;
|
|
/**
|
* 产品列表数据
|
*/
|
@ApiOperation(value = "永续合约列表，配置列表")
|
@GetMapping("list")
|
public Result<IPage<ItemDTO>> list(ItemQuery itemQuery, Page<ItemDTO> page) throws Exception {
|
QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition (itemQuery, ItemQuery.class);
|
IPage<ItemDTO> result = itemService.findPage (page, queryWrapper);
|
return Result.ok (result);
|
}
|
|
@ApiOperation(value = "设置前端显示状态,返回修改后的状态")
|
@GetMapping("setShowStatus")
|
public Result<String> setShowStatus(String symbol, String showStatus) throws Exception {
|
Item bySymbol = itemService.findBySymbol(symbol);
|
if(bySymbol == null){
|
throw new YamiShopBindException( symbol + "不存在");
|
}
|
Item update = new Item();
|
update.setUuid(bySymbol.getUuid());
|
update.setShowStatus(showStatus);
|
|
itemService.updateById(update);
|
return Result.ok(showStatus);
|
}
|
|
@ApiOperation(value = "设置交易状态, 返回修改后的状态")
|
@GetMapping("setTradeStatus")
|
public Result<String> setTradeStatus(String symbol, String tradeStatus) throws Exception {
|
Item bySymbol = itemService.findBySymbol(symbol);
|
if(bySymbol == null){
|
throw new YamiShopBindException( symbol + "不存在");
|
}
|
Item update = new Item();
|
update.setUuid(bySymbol.getUuid());
|
update.setTradeStatus(tradeStatus);
|
|
itemService.updateById(update);
|
return Result.ok(tradeStatus);
|
}
|
/**
|
* 根据Id获取产品数据
|
*/
|
@ApiOperation(value = "根据Id获取产品数据")
|
@GetMapping("queryById")
|
public Result<ItemDTO> queryById(String id) {
|
return Result.ok ( itemService.findById ( id ) );
|
}
|
|
/**
|
* 保存产品
|
*/
|
@ApiOperation(value = "保存产品")
|
@PostMapping("save")
|
public Result <String> save(@Valid @RequestBody Item item) {
|
//新增或编辑表单保存
|
itemService.saveOrUpdate (item);
|
return Result.ok ( "保存产品成功" );
|
}
|
|
/**
|
* 保存产品
|
*/
|
@ApiOperation(value = "保存配置")
|
@PostMapping("addConfig.action")
|
public Result <String> addConfig(@Valid @RequestBody ItemConfig itemConfig) {
|
//userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemConfig.getLoginSafeword());
|
if(StrUtil.isNotBlank(itemConfig.getUuid())){
|
throw new YamiShopBindException("新增配置不要传入uuid");
|
}
|
Item bySymbol = itemService.findBySymbol(itemConfig.getSymbol());
|
if(bySymbol != null){
|
throw new YamiShopBindException("代码已经存在");
|
}
|
Item item = itemWrapper.toEntity(itemConfig);
|
//新增或编辑表单保存
|
itemService.save (item);
|
// todo log
|
return Result.ok ( "保存行情品种成功" );
|
}
|
|
|
/**
|
* 保存永续合约
|
*/
|
@ApiOperation(value = "保存永续合约")
|
@PostMapping("add.action")
|
public Result <String> addConfig(@Valid @RequestBody ItemDTO itemDTO) {
|
//userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemDTO.getLoginSafeword());
|
if(StrUtil.isNotBlank(itemDTO.getUuid())){
|
throw new YamiShopBindException("新增配置不要传入uuid");
|
}
|
Item bySymbol = itemService.findBySymbol(itemDTO.getSymbol());
|
if(bySymbol != null){
|
throw new YamiShopBindException("代码已经存在");
|
}
|
Item item = itemWrapper.toEntity(itemDTO);
|
//新增或编辑表单保存
|
itemService.save (item);
|
// todo log
|
return Result.ok ( "保存永续合约成功" );
|
}
|
|
/**
|
* 保存产品
|
*/
|
@ApiOperation(value = "更新产品/修改交易对/修改状态")
|
@PostMapping("update.action")
|
public Result <String> updateConfig(@Valid @RequestBody ItemDTO itemDTO) {
|
// userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemDTO.getLoginSafeword());
|
if(StrUtil.isBlank(itemDTO.getUuid())){
|
throw new YamiShopBindException("更新数据时候uuid不能为空");
|
}
|
Item byId = itemService.getById(itemDTO.getUuid());
|
if(byId == null){
|
throw new YamiShopBindException("更新永续合约不存在");
|
}
|
// 新老代码不等
|
if (!byId.getSymbol().equalsIgnoreCase(itemDTO.getSymbol())) {
|
// 且老的名称已经存在
|
Item bySymbol = itemService.findBySymbol(itemDTO.getSymbol());
|
if(bySymbol != null ){
|
throw new YamiShopBindException("被更新的永续合约已经存在");
|
}
|
}
|
Item item = itemWrapper.toEntity(itemDTO);
|
//新增或编辑表单保存
|
itemService.saveOrUpdate (item);
|
// todo log
|
return Result.ok ( "保存行情永续合约成功" );
|
}
|
|
/**
|
* 保存产品
|
*/
|
@ApiOperation(value = "更新配置")
|
@PostMapping("updateConfig.action")
|
public Result <String> updateConfig(@Valid @RequestBody ItemConfig itemConfig) {
|
//userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemConfig.getLoginSafeword());
|
if(StrUtil.isBlank(itemConfig.getUuid())){
|
throw new YamiShopBindException("更新数据时候uuid不能为空");
|
}
|
Item byId = itemService.getById(itemConfig.getUuid());
|
if(byId == null){
|
throw new YamiShopBindException("更新品种不存在");
|
}
|
// 新老代码不等
|
if (!byId.getSymbol().equalsIgnoreCase(itemConfig.getSymbol())) {
|
// 且老的名称已经存在
|
Item bySymbol = itemService.findBySymbol(itemConfig.getSymbol());
|
if(bySymbol != null ){
|
throw new YamiShopBindException("被更新的品种已经存在");
|
}
|
}
|
Item item = itemWrapper.toEntity(itemConfig);
|
//新增或编辑表单保存
|
itemService.saveOrUpdate (item);
|
// todo log
|
return Result.ok ( "保存行情品种成功" );
|
}
|
/**
|
* 删除产品
|
*/
|
@ApiOperation(value = "删除产品")
|
@DeleteMapping("delete")
|
public Result <String> delete(String ids) {
|
String idArray[] = ids.split(",");
|
itemService.removeByIds ( Lists.newArrayList ( idArray ) );
|
return Result.ok( "删除产品成功" );
|
}
|
|
}
|
