package com.yami.trading.api.controller.trader;
|
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.trader.domain.Trader;
|
import com.yami.trading.bean.trader.domain.TraderFollowUser;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.web.ResultObject;
|
import com.yami.trading.security.common.util.SecurityUtils;
|
import com.yami.trading.service.trader.TraderFollowUserService;
|
import com.yami.trading.service.trader.TraderService;
|
import com.yami.trading.service.user.UserService;
|
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.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
/**
|
* 用户准备跟随交易员api接口
|
*/
|
@RestController
|
@CrossOrigin
|
@RequestMapping()
|
public class ApiTraderFollowUserController {
|
private static final long serialVersionUID = 623416500874018208L;
|
/**
|
* 交易员api接口
|
*/
|
private static Log logger = LogFactory.getLog(ApiTraderFollowUserController.class);
|
|
@Autowired
|
private TraderFollowUserService traderFollowUserService;
|
|
@Autowired
|
private TraderService traderService;
|
|
@Autowired
|
private UserService userService;
|
|
// private String trader_id;
|
//
|
// private String trader_name;
|
//
|
// /**
|
// * 跟随购买品种 symbol
|
// */
|
// private String symbol;
|
// /**
|
// * 跟单固定张数/固定比例---选择 1,固定张数�?2，固定比�?
|
// */
|
// private String follow_type;
|
//
|
// /**
|
// * 跟单张数或比�?---具体�?
|
// */
|
// private double volume;
|
// /**
|
// * �?大持仓张�?
|
// */
|
// private double volume_max;
|
// /**
|
// * 止盈百分�?
|
// */
|
// private double stop_profit;
|
// /**
|
// * 止损百分�?
|
// */
|
// private double stop_loss;
|
|
private final String action = "/api/traderFollowUser!";
|
|
/**
|
* 用户跟随交易员
|
*/
|
@RequestMapping(action + "save.action")
|
public Object saveCreate(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
String follow_type = request.getParameter("follow_type");
|
String stop_loss = request.getParameter("stop_loss");
|
String stop_profit = request.getParameter("stop_profit");
|
String symbol = request.getParameter("symbol");
|
String volume = request.getParameter("volume");
|
String volume_max = request.getParameter("volume_max");
|
String trader_id = request.getParameter("trader_id");
|
|
String partyId = SecurityUtils.getCurrentUserId();
|
try {
|
|
// Object object = this.sessionTokenService.cacheGet(session_token);
|
// this.sessionTokenService.del(session_token);
|
// if ((object == null) || (!this.getLoginPartyId().equals((String) object))) {
|
// resultObject.setCode("1");
|
// resultObject.setMsg("请稍后再试");
|
// return resultObject;
|
// }
|
|
User user = userService.getById(partyId);
|
|
// if (!party.getKyc_authority()) {
|
// resultObject.setCode("401");
|
// resultObject.setMsg(error);
|
// this.result = JsonUtils.getJsonString(resultObject);
|
// out.println(this.result);
|
// return null;
|
// }
|
TraderFollowUser entity = new TraderFollowUser();
|
entity.setPartyId(partyId);
|
entity.setUsername(user.getUserName());
|
/**
|
* 跟单固定张数/固定比例---选择 1,固定张数量，固定比例
|
*/
|
entity.setFollowType(follow_type);
|
entity.setStopLoss(Double.parseDouble(stop_loss));
|
entity.setStopProfit(Double.parseDouble(stop_profit));
|
entity.setSymbol(symbol);
|
entity.setVolume(Double.parseDouble(volume));
|
entity.setVolumeMax(Double.parseDouble(volume_max));
|
/**
|
* 状态 是否还在跟随状随 1,跟随，取消跟随
|
*/
|
entity.setState("1");
|
|
this.traderFollowUserService.save(entity, trader_id);
|
resultObject.setCode("0");
|
} catch (BusinessException e) {
|
resultObject.setCode(e.getSign() + "");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", e.fillInStackTrace());
|
} finally {
|
|
}
|
|
return resultObject;
|
}
|
|
@RequestMapping(action + "choose.action")
|
public Object chooseDays(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
String daysSetting = request.getParameter("daysSetting");
|
String partyId = SecurityUtils.getCurrentUserId();
|
User user = userService.findByUserId(partyId);
|
user.setDaysSetting(daysSetting);
|
|
userService.updateById(user);
|
|
resultObject.setCode("0");
|
resultObject.setMsg("设置成功!");
|
|
return resultObject;
|
}
|
|
@RequestMapping(action + "changeFollow.action")
|
public Object changeFollow(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
String follow_type = request.getParameter("follow_type");
|
String stop_loss = request.getParameter("stop_loss");
|
String stop_profit = request.getParameter("stop_profit");
|
String symbol = request.getParameter("symbol");
|
String volume = request.getParameter("volume");
|
String volume_max = request.getParameter("volume_max");
|
String trader_id = request.getParameter("trader_id");
|
|
String partyId = SecurityUtils.getCurrentUserId();
|
try {
|
|
// Object object = this.sessionTokenService.cacheGet(session_token);
|
// this.sessionTokenService.del(session_token);
|
// if ((object == null) || (!this.getLoginPartyId().equals((String) object))) {
|
// resultObject.setCode("1");
|
// resultObject.setMsg("请稍后再试");
|
// return resultObject;
|
// }
|
|
User user = userService.getById(partyId);
|
// if (!party.getKyc_authority()) {
|
// resultObject.setCode("401");
|
// resultObject.setMsg(error);
|
// this.result = JsonUtils.getJsonString(resultObject);
|
// out.println(this.result);
|
// return null;
|
// }
|
Trader trader = this.traderService.findById(trader_id);
|
TraderFollowUser entity = this.traderFollowUserService.findByPartyIdAndTrader_partyId(partyId,
|
trader.getPartyId());
|
/**
|
* 跟单固定张数/固定比例---选择 1,固定张数�?2，固定比�?
|
*/
|
entity.setFollowType(follow_type);
|
entity.setStopLoss(Double.parseDouble(stop_loss));
|
entity.setStopProfit(Double.parseDouble(stop_profit));
|
entity.setSymbol(symbol);
|
entity.setVolume(Double.parseDouble(volume));
|
entity.setVolumeMax(Double.parseDouble(volume_max));
|
/**
|
* 状�?? 是否还在跟随状�?? 1,跟随�?2，取消跟�?
|
*/
|
entity.setState("1");
|
|
this.traderFollowUserService.update(entity);
|
resultObject.setCode("0");
|
} catch (BusinessException e) {
|
resultObject.setCode(e.getSign() + "");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", e.fillInStackTrace());
|
} finally {
|
|
}
|
|
return resultObject;
|
}
|
|
/**
|
* 取消跟随
|
*/
|
@RequestMapping(action + "cancelFollow.action")
|
public Object cancelFollow(HttpServletRequest request) {
|
ResultObject resultObject = new ResultObject();
|
String trader_id = request.getParameter("trader_id");
|
|
String partyId = SecurityUtils.getCurrentUserId();
|
try {
|
Trader trader = traderService.findById(trader_id);
|
TraderFollowUser traderFollowUser = this.traderFollowUserService.findByPartyIdAndTrader_partyId(partyId,
|
trader.getPartyId().toString());
|
if (traderFollowUser != null) {
|
this.traderFollowUserService.deleteCancel(traderFollowUser.getUuid());
|
}
|
|
resultObject.setCode("0");
|
} catch (BusinessException e) {
|
resultObject.setCode(e.getSign() + "");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", e.fillInStackTrace());
|
} finally {
|
|
}
|
|
return resultObject;
|
}
|
|
}
|
