package com.yami.trading.admin.controller.trader;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.yami.trading.admin.model.TraderOrderListModel;
|
import com.yami.trading.admin.model.trader.TraderOrderModel;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.trader.domain.Trader;
|
import com.yami.trading.bean.trader.domain.TraderOrder;
|
import com.yami.trading.common.domain.Result;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.util.StringUtils;
|
import com.yami.trading.service.item.ItemService;
|
import com.yami.trading.service.trader.AdminTraderOrderService;
|
import com.yami.trading.service.trader.AdminTraderService;
|
import com.yami.trading.service.user.UserService;
|
import io.swagger.annotations.Api;
|
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.LogFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.validation.Valid;
|
import java.text.SimpleDateFormat;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
|
@RestController
|
@CrossOrigin
|
@RequestMapping()
|
@Api(tags = "交易员订单管理")
|
public class AdminTraderOrderController {
|
private static Log logger = LogFactory.getLog(AdminTraderOrderController.class);
|
|
Map<String,String> item_map = new HashMap<String,String>();
|
|
@Autowired
|
private AdminTraderService adminTraderService;
|
|
@Autowired
|
private AdminTraderOrderService adminTraderOrderService;
|
|
@Autowired
|
private ItemService itemService;
|
|
@Autowired
|
private UserService userService;
|
|
private final String action = "/normal/adminTraderOrder!";
|
|
@RequestMapping(action + "list.action")
|
public Result list(TraderOrderListModel model, Page page) {
|
|
page = this.adminTraderOrderService.pagedQuery(page, model.getName_para(), model.getUsername_para(), model.getRolename_para());
|
|
HashMap<String,Object> resultDict=new HashMap<String,Object>();
|
resultDict.put("pageSize", page.getSize());
|
resultDict.put("pageNo", page.getCurrent());
|
resultDict.put("page", page);
|
|
return Result.succeed(resultDict, "获取数据成功");
|
}
|
|
// @RequestMapping(action + "toAdd.action")
|
// public String toAdd() {
|
// return "add";
|
// }
|
|
|
|
@RequestMapping(action + "add.action")
|
public Result add(@RequestBody TraderOrderModel model) {
|
String usercode = model.getUsercode();
|
|
String symbol = model.getSymbol();
|
String profit = model.getProfit();
|
String change_ratio = model.getChangeRatio();
|
String close_avg_price = model.getCloseAvgPrice();
|
String trade_avg_price = model.getTradeAvgPrice();
|
String close_time = model.getCloseTime();
|
String create_time = model.getCreateTime();
|
String direction = model.getDirection();
|
String lever_rate = model.getLeverRate();
|
String state = model.getState();
|
String volume_open = model.getVolumeOpen();
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
try {
|
|
String error = verification(usercode, symbol, profit, change_ratio, close_avg_price, trade_avg_price, close_time, create_time, direction, lever_rate, state, volume_open);
|
if (!StringUtils.isNullOrEmpty(error)) throw new BusinessException(error);
|
|
User party = userService.findUserByUserCode(usercode);
|
if (party == null ) {
|
error = "交易员UID不存在!";
|
throw new BusinessException(error);
|
}
|
|
Trader trader = this.adminTraderService.findByPartyId(party.getUserId());
|
if (trader == null) {
|
error = "交易员不存在!";
|
throw new BusinessException(error);
|
}
|
|
TraderOrder entity = new TraderOrder();
|
entity.setPartyId(party.getUserId());
|
|
entity.setSymbol(symbol);
|
entity.setProfit(Double.parseDouble(profit));
|
entity.setChangeRatio(Double.parseDouble(change_ratio));
|
entity.setCloseAvgPrice(Double.parseDouble(close_avg_price));
|
entity.setTradeAvgPrice(Double.parseDouble(trade_avg_price));
|
entity.setCloseTime(sdf.parse(close_time));
|
entity.setCreateTime(sdf.parse(create_time));
|
entity.setDirection(direction);
|
entity.setLeverRate(Double.parseDouble(lever_rate));
|
entity.setProfit(Double.parseDouble(profit));
|
entity.setState(state);
|
entity.setVolumeOpen(Double.parseDouble(volume_open));
|
|
|
this.adminTraderOrderService.save(entity);
|
} catch (BusinessException e) {
|
return Result.failed("1", e.getMessage());
|
} catch (Throwable t) {
|
logger.error("error ", t);
|
return Result.failed("1", t.getMessage());
|
}
|
return Result.succeed("添加成功!", "0");
|
}
|
|
// private String verificationUpdate() {
|
// if (StringUtils.isEmptyString(this.usercode))
|
// return "请输入交易员UID";
|
// if (StringUtils.isEmptyString(this.symbol))
|
// return "请输入品�?";
|
// if (this.create_time == null)
|
// return "请输入开仓时�?";
|
// if (this.close_time == null)
|
// return "请输入平仓时�?";
|
//
|
// if (this.lever_rate <= 0 || this.lever_rate %1 != 0)
|
// return "杠杆倍数不能小于等于0,并且不能有小�?";
|
// if (this.volume_open <= 0 || this.volume_open %1 != 0)
|
// return "委托数量不能小于等于0,并且不能有小�?";
|
// if (this.trade_avg_price < 0)
|
// return "买入价格不能小于0";
|
// if (this.close_avg_price < 0)
|
// return "平常价格不能小于0";
|
// return null;
|
// }
|
|
@RequestMapping(action + "toUpdate.action")
|
public Result toUpdate(HttpServletRequest request) {
|
|
String id = request.getParameter("uuid");
|
|
TraderOrder entity = adminTraderOrderService.findById(id);
|
User user = userService.findByUserId(entity.getPartyId());
|
entity.setUsercode(user.getUserCode());
|
// User party = userService.cacheUserBy(entity.getPartyId().toString());
|
|
// this.usercode = party.getUsercode();
|
//
|
// this.symbol = entity.getSymbol();
|
// this.profit = entity.getProfit();
|
// this.change_ratio = entity.getChange_ratio();
|
// this.close_avg_price = entity.getClose_avg_price();
|
// this.trade_avg_price = entity.getTrade_avg_price();
|
// this.close_time = entity.getClose_time();
|
// this.create_time = entity.getCreate_time();
|
// this.direction = entity.getDirection();
|
// this.lever_rate = entity.getLever_rate();
|
// this.profit = entity.getProfit();
|
// this.state = entity.getState();
|
// this.volume_open = entity.getVolume_open();
|
//
|
// return "update";
|
return Result.succeed(entity, "获取数据成功!");
|
}
|
|
@RequestMapping(action + "update.action")
|
public Result update(@RequestBody TraderOrderModel model) {
|
String id = model.getUuid();
|
String usercode = model.getUsercode();
|
|
String symbol = model.getSymbol();
|
String profit = model.getProfit();
|
String change_ratio = model.getChangeRatio();
|
String close_avg_price = model.getCloseAvgPrice();
|
String trade_avg_price = model.getTradeAvgPrice();
|
String close_time = model.getCloseTime();
|
String create_time = model.getCreateTime();
|
String direction = model.getDirection();
|
String lever_rate = model.getLeverRate();
|
String state = model.getState();
|
String volume_open = model.getVolumeOpen();
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
try {
|
String error = verification(usercode, symbol, profit, change_ratio, close_avg_price, trade_avg_price, close_time, create_time, direction, lever_rate, state, volume_open);
|
if (!StringUtils.isNullOrEmpty(error)) throw new BusinessException(error);
|
|
TraderOrder entity = adminTraderOrderService.findById(id);
|
|
|
entity.setSymbol(symbol);
|
entity.setProfit(Double.parseDouble(profit));
|
entity.setChangeRatio(Double.parseDouble(change_ratio));
|
entity.setCloseAvgPrice(Double.parseDouble(close_avg_price));
|
entity.setTradeAvgPrice(Double.parseDouble(trade_avg_price));
|
entity.setCloseTime(sdf.parse(close_time));
|
entity.setCreateTime(sdf.parse(create_time));
|
entity.setDirection(direction);
|
entity.setLeverRate(Double.parseDouble(lever_rate));
|
entity.setProfit(Double.parseDouble(profit));
|
entity.setState(state);
|
entity.setVolumeOpen(Double.parseDouble(volume_open));
|
|
this.adminTraderOrderService.update(entity);
|
return Result.succeed("更新成功!", "0");
|
} catch (BusinessException e) {
|
return Result.failed("1", e.getMessage());
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
return Result.failed("1", t.getMessage());
|
}
|
}
|
|
@RequestMapping(action + "delete.action")
|
public Result toDelete(HttpServletRequest request) {
|
String id = request.getParameter("uuid");
|
try {
|
|
this.adminTraderOrderService.delete(id);
|
return Result.succeed("删除成功!");
|
} catch (BusinessException e) {
|
return Result.failed("1", e.getMessage());
|
} catch (Throwable t) {
|
logger.error("update error ", t);
|
return Result.failed("1", t.getMessage());
|
}
|
}
|
|
|
private String verification(String usercode, String symbol, String profit, String change_ratio, String close_avg_price, String trade_avg_price,
|
String close_time, String create_time, String direction, String lever_rate, String state, String volume_open) {
|
|
if (StringUtils.isEmptyString(usercode))
|
return "请输入交易员UID";
|
if (StringUtils.isEmptyString(symbol))
|
return "请输入品种";
|
if (create_time == null)
|
return "请输入开仓时间";
|
if (close_time == null)
|
return "请输入平仓时间";
|
|
if (Double.parseDouble(lever_rate) <= 0 || Double.parseDouble(lever_rate) %1 != 0)
|
return "杠杆倍数不能小于等于0,并且不能有小数";
|
if (Double.parseDouble(volume_open) <= 0 || Double.parseDouble(volume_open) %1 != 0)
|
return "委托数量不能小于等于0,并且不能有数";
|
if (Double.parseDouble(trade_avg_price) < 0)
|
return "买入价格不能小于0";
|
if (Double.parseDouble(close_avg_price) < 0)
|
return "平常价格不能小于0";
|
|
return null;
|
}
|
|
|
public Map<String, String> getItem_map() {
|
List<Item> items = this.itemService.cacheGetAll();
|
if(items != null) {
|
for(Item item :items) {
|
this.item_map.put(item.getSymbol().toString(), item.getName().toString());
|
|
}
|
}
|
return item_map;
|
}
|
|
public void setItem_map(Map<String, String> item_map) {
|
this.item_map = item_map;
|
}
|
|
|
}
|
