package com.yami.trading.admin.controller.syspara;
|
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.common.domain.Result;
|
|
import javax.validation.Valid;
|
|
import com.google.common.collect.Lists;
|
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 org.springframework.dao.DuplicateKeyException;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.security.access.prepost.PreAuthorize;
|
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.syspara.domain.OpenClose;
|
|
import com.yami.trading.bean.syspara.dto.OpenCloseDTO;
|
import com.yami.trading.bean.syspara.mapstruct.OpenCloseWrapper;
|
import com.yami.trading.service.syspara.OpenCloseService;
|
import com.yami.trading.bean.syspara.query.OpenCloseQuery;
|
|
import java.util.List;
|
import java.util.stream.Stream;
|
|
|
/**
|
* 开盘停盘时间设置Controller
|
*
|
* @author lucas
|
* @version 2023-05-20
|
*/
|
|
@Api(tags = "开盘停盘时间设置")
|
@RestController
|
@CrossOrigin
|
@RequestMapping(value = "/syspara/openClose")
|
public class OpenCloseController {
|
|
@Autowired
|
private OpenCloseService openCloseService;
|
|
@Autowired
|
private OpenCloseWrapper openCloseWrapper;
|
@Autowired
|
private ItemService itemService;
|
|
/**
|
* 开盘停盘时间设置列表数据
|
*/
|
@ApiOperation(value = "查询开盘停盘时间设置列表数据")
|
@GetMapping("list")
|
public Result<IPage<OpenClose>> list(OpenCloseQuery openCloseQuery, Page<OpenClose> page) throws Exception {
|
QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition(openCloseQuery, OpenCloseQuery.class);
|
IPage<OpenClose> result = openCloseService.page(page, queryWrapper);
|
List<OpenClose> records = result.getRecords();
|
for(OpenClose record: records){
|
Item bySymbol = itemService.findBySymbol(record.getSymbol());
|
if(bySymbol != null){
|
record.setSymbolName(bySymbol.getName());
|
}
|
}
|
return Result.ok(result);
|
}
|
|
|
/**
|
* 根据Id获取开盘停盘时间设置数据
|
*/
|
@ApiOperation(value = "根据Id获取开盘停盘时间设置数据")
|
@GetMapping("queryById")
|
public Result<OpenCloseDTO> queryById(String id) {
|
return Result.ok(openCloseWrapper.toDTO(openCloseService.getById(id)));
|
}
|
|
/**
|
* 保存开盘停盘时间设置
|
*/
|
@ApiOperation(value = "保存开盘停盘时间设置")
|
@PostMapping("save")
|
public Result<String> save(@Valid @RequestBody OpenCloseDTO openCloseDTO) {
|
//新增或编辑表单保存
|
OpenClose entity = openCloseWrapper.toEntity(openCloseDTO);
|
entity.setCloseTs( openCloseDTO.getCloseBjDate().getTime());
|
entity.setOpenTs(openCloseDTO.getOpenBjDate().getTime());
|
try {
|
openCloseService.saveOrUpdate(entity);
|
}catch (DuplicateKeyException e){
|
return Result.failed("当前币对所在时段已经配置过开盘时间了");
|
|
}
|
return Result.ok("保存开盘停盘时间设置成功");
|
}
|
|
|
/**
|
* 删除开盘停盘时间设置
|
*/
|
@ApiOperation(value = "删除开盘停盘时间设置")
|
@DeleteMapping("delete")
|
public Result<String> delete(String ids) {
|
String idArray[] = ids.split(",");
|
openCloseService.removeByIds(Lists.newArrayList(idArray));
|
return Result.ok("删除开盘停盘时间设置成功");
|
}
|
|
}
|
