package com.yami.trading.admin.controller.data;
|
|
import cn.hutool.core.bean.BeanUtil;
|
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.admin.dto.AdminMarketQuotationsCalculateDto;
|
import com.yami.trading.admin.dto.AdminMarketQuotationsUpdateDto;
|
import com.yami.trading.admin.facade.MarketQuotationsFacade;
|
import com.yami.trading.bean.item.dto.ItemDTO;
|
import com.yami.trading.bean.item.dto.MarketQuotations;
|
import com.yami.trading.bean.item.dto.MarketQuotationsAdjust;
|
import com.yami.trading.bean.item.query.ItemQuery;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.query.QueryWrapperGenerator;
|
import com.yami.trading.service.item.ItemService;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.validation.annotation.Validated;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.validation.constraints.NotEmpty;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Validated
|
@RestController
|
@CrossOrigin
|
@RequestMapping("normal/adminMarketQuotationsManageAction!")
|
@Api(tags = "行情数据调整")
|
@Slf4j
|
public class AdminMarketQuotationsManageController {
|
@Autowired
|
private MarketQuotationsFacade marketQuotationsFacade;
|
@Autowired
|
private ItemService itemService;
|
|
/**
|
* 列表
|
*/
|
@ApiOperation(value = "列表查询")
|
@GetMapping("list.action")
|
public Result<IPage<MarketQuotations>> list(ItemQuery itemQuery, Page<ItemDTO> page) throws Exception {
|
QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition(itemQuery, ItemQuery.class);
|
IPage<ItemDTO> result = itemService.findPage(page, queryWrapper);
|
List<String> symbols = result.getRecords().stream().map(ItemDTO::getSymbol).collect(Collectors.toList());
|
IPage<MarketQuotations> marketQuotationsPages = new Page<MarketQuotations>();
|
BeanUtil.copyProperties(result, marketQuotationsPages);
|
marketQuotationsPages.setRecords(marketQuotationsFacade.marketQuotationsList(symbols));
|
return Result.succeed(marketQuotationsPages);
|
}
|
|
/**
|
* 行情管理-调整弹框显示
|
*/
|
@ApiOperation(value = "查询当前值")
|
@GetMapping("showModal.action")
|
public Result<MarketQuotationsAdjust> showModal(@NotEmpty @RequestParam(required = true) String symbol) {
|
return Result.succeed(marketQuotationsFacade.getDetails(symbol));
|
}
|
|
|
/**
|
* 页面计算
|
*/
|
@ApiOperation(value = "预计算值")
|
@PostMapping("getValue.action")
|
public Result<Map<String, String>> getValue(@RequestBody AdminMarketQuotationsCalculateDto dto) {
|
return Result.succeed(marketQuotationsFacade.calculateValue(dto.getSymbol(), dto.getType(), dto.getValue()));
|
}
|
|
/**
|
* 调整计算
|
*/
|
@ApiOperation(value = "调整值")
|
@PostMapping("adjust.action")
|
public Result<String> adjust(@RequestBody AdminMarketQuotationsUpdateDto adminMarketQuotationsUpdateDto) {
|
// if(!itemService.isOpen(adminMarketQuotationsUpdateDto.getSymbol())){
|
// throw new YamiShopBindException("当前休市状态");
|
// }
|
marketQuotationsFacade.adjust(adminMarketQuotationsUpdateDto.getSymbol(), adminMarketQuotationsUpdateDto.getSecond(), adminMarketQuotationsUpdateDto.getValue());
|
return Result.succeed("操作成功");
|
}
|
}
|
