package com.nq.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.google.common.collect.Lists; import com.nq.common.ServerResponse; import com.nq.common.lanage.MessageLocaleResolver; import com.nq.dao.StockMapper; import com.nq.dao.UserCashDetailMapper; import com.nq.dao.UserFundsPositionMapper; import com.nq.dao.UserMapper; import com.nq.pojo.*; import com.nq.service.*; import com.nq.utils.DateTimeUtil; import com.nq.utils.KeyUtils; import com.nq.utils.stock.BuyAndSellUtils; import com.nq.utils.stock.GeneratePosition; import com.nq.utils.stock.sina.SinaStockApi; import com.nq.vo.position.PositionProfitVO; import com.nq.vo.position.UserPositionVO; import com.nq.vo.stock.StockListVO; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.math.BigDecimal; import java.util.Calendar; import java.util.Date; import java.util.List; /** * 分仓交易 * @author lr * @date 2020/07/24 */ @Service("IUserFundsPositionService") public class UserFundsPositionServiceImpl implements IUserFundsPositionService { private static final Logger log = LoggerFactory.getLogger(UserPositionServiceImpl.class); @Resource private UserFundsPositionMapper userFundsPositionMapper; @Autowired UserMapper userMapper; @Autowired UserCashDetailMapper userCashDetailMapper; @Autowired StockMapper stockMapper; @Autowired ISiteProductService iSiteProductService; @Autowired IUserService iUserService; @Autowired ISiteSettingService iSiteSettingService; @Autowired IStockService iStockService; @Autowired ISiteSpreadService iSiteSpreadService; @Autowired IAgentAgencyFeeService iAgentAgencyFeeService; @Override public ServerResponse insert(UserFundsPosition model, HttpServletRequest request) { int ret = 0; if (model == null) { return ServerResponse.createByErrorMsg("Order abnormal, please try again later！",request.getHeader(MessageLocaleResolver.LANG)); } ret = userFundsPositionMapper.insert(model); if(ret>0){ return ServerResponse.createBySuccessMsg("Order successful！",request.getHeader(MessageLocaleResolver.LANG)); } else { return ServerResponse.createByErrorMsg("Order failed, please try again later！",request.getHeader(MessageLocaleResolver.LANG)); } } @Override public int update(UserFundsPosition model) { int ret = userFundsPositionMapper.update(model); return ret>0 ? ret: 0; } /** * 分仓交易-保存 */ @Override public ServerResponse save(UserFundsPosition model,HttpServletRequest request) { int ret = 0; if(model!=null && model.getId()>0){ ret = userFundsPositionMapper.update(model); } else{ ret = userFundsPositionMapper.insert(model); } if(ret>0){ return ServerResponse.createBySuccessMsg("Successful operation",request.getHeader(MessageLocaleResolver.LANG)); } return ServerResponse.createByErrorMsg("operation failed",request.getHeader(MessageLocaleResolver.LANG)); } /*分仓交易-查询列表*/ @Override public ServerResponse getList(int pageNum, int pageSize, String keyword, HttpServletRequest request){ PageHelper.startPage(pageNum, pageSize); List listData = this.userFundsPositionMapper.pageList(pageNum, pageSize, keyword); PageInfo pageInfo = new PageInfo(listData); pageInfo.setList(listData); return ServerResponse.createBySuccess(pageInfo); } /*分仓交易-查询详情*/ @Override public ServerResponse getDetail(int id) { return ServerResponse.createBySuccess(this.userFundsPositionMapper.load(id)); } /** * 分仓交易-入仓 */ @Transactional public ServerResponse buyFunds(Integer stockId, Integer buyNum, Integer buyType, Integer lever, Integer subaccountNumber, HttpServletRequest request) throws Exception { // 判断周末不能买 Date today = new Date(); Calendar c = Calendar.getInstance(); c.setTime(today); int weekday = c.get(Calendar.DAY_OF_WEEK); /*实名认证开关开启*/ SiteProduct siteProduct = iSiteProductService.getProductSetting(); User user = this.iUserService.getCurrentRefreshUser(request); if (user == null){ return ServerResponse.createBySuccessMsg("please log in first",request.getHeader(MessageLocaleResolver.LANG)); } if (siteProduct.getRealNameDisplay() && (StringUtils.isBlank(user.getRealName()) || StringUtils.isBlank(user.getIdCard()))) { return ServerResponse.createByErrorMsg("Order failed, please authenticate with your real name first",request.getHeader(MessageLocaleResolver.LANG)); } if(siteProduct.getHolidayDisplay()){ return ServerResponse.createByErrorMsg("No trading allowed on weekends or holidays！",request.getHeader(MessageLocaleResolver.LANG)); } BigDecimal user_enable_amt = user.getEnableAmt(); log.info("用户 {} 下单，股票id = {} ，数量 = {} , 方向 = {} , 杠杆 = {}", new Object[]{user .getId(), stockId, buyNum, buyType, lever}); if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) { return ServerResponse.createByErrorMsg("The order failed and the account has been locked.",request.getHeader(MessageLocaleResolver.LANG)); } SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting(); if (siteSetting == null) { log.error("下单出错，网站设置表不存在"); return ServerResponse.createByErrorMsg("Order failed, system setting error",request.getHeader(MessageLocaleResolver.LANG)); } String am_begin = siteSetting.getTransAmBegin(); String am_end = siteSetting.getTransAmEnd(); String pm_begin = siteSetting.getTransPmBegin(); String pm_end = siteSetting.getTransPmEnd(); boolean am_flag = BuyAndSellUtils.isTransTime(am_begin, am_end); boolean pm_flag = BuyAndSellUtils.isTransTime(pm_begin, pm_end); log.info("是否在上午交易时间 = {} 是否在下午交易时间 = {}", Boolean.valueOf(am_flag), Boolean.valueOf(pm_flag)); if (!am_flag && !pm_flag) { return ServerResponse.createByErrorMsg("Order failed, not within trading hours",request.getHeader(MessageLocaleResolver.LANG)); } Stock stock = null; ServerResponse stock_res = this.iStockService.findStockById(stockId); if (!stock_res.isSuccess()) { return ServerResponse.createByErrorMsg("Failed to place order, wrong stock code",request.getHeader(MessageLocaleResolver.LANG)); } stock = (Stock) stock_res.getData(); if (stock.getIsLock().intValue() != 0) { return ServerResponse.createByErrorMsg("The order failed and the current stock cannot be traded.",request.getHeader(MessageLocaleResolver.LANG)); } /*List dbPosition = findPositionByStockCodeAndTimes(siteSetting.getBuySameTimes().intValue(), stock .getStockCode(), user.getId()); if (dbPosition.size() >= siteSetting.getBuySameNums().intValue()) { return ServerResponse.createByErrorMsg("频繁交易," + siteSetting.getBuySameTimes() + "分钟内同一股票持仓不得超过" + siteSetting .getBuySameNums() + "条"); } Integer transNum = findPositionNumByTimes(siteSetting.getBuyNumTimes().intValue(), user.getId()); if (transNum.intValue() / 100 >= siteSetting.getBuyNumLots().intValue()) { return ServerResponse.createByErrorMsg("频繁交易," + siteSetting .getBuyNumTimes() + "分钟内不能超过" + siteSetting.getBuyNumLots() + "手"); }*/ if (buyNum.intValue() < siteSetting.getBuyMinNum().intValue()) { return ServerResponse.createByErrorMsg("The order failed, the purchase quantity is less than" + siteSetting .getBuyMinNum() + "share",request.getHeader(MessageLocaleResolver.LANG)); } if (buyNum.intValue() > siteSetting.getBuyMaxNum().intValue()) { return ServerResponse.createByErrorMsg("Order failed, purchase quantity is large" + siteSetting .getBuyMaxNum() + "share",request.getHeader(MessageLocaleResolver.LANG)); } StockListVO stockListVO = SinaStockApi.assembleInStockListVO(stock); BigDecimal now_price = new BigDecimal(stockListVO.getNowPrice()); if (now_price.compareTo(new BigDecimal("0")) == 0) { return ServerResponse.createByErrorMsg("Quote 0, please try again later",request.getHeader(MessageLocaleResolver.LANG)); } double stock_crease = stockListVO.getHcrate().doubleValue(); BigDecimal maxRisePercent = new BigDecimal("0"); if (stock.getStockPlate() != null) { maxRisePercent = new BigDecimal("0.2"); log.info("【科创股票】"); } else { maxRisePercent = new BigDecimal("0.1"); log.info("【普通A股】"); } BigDecimal zsPrice = new BigDecimal(stockListVO.getPreclose_px()); BigDecimal ztPrice = zsPrice.multiply(maxRisePercent).add(zsPrice); ztPrice = ztPrice.setScale(2, 4); BigDecimal chaPrice = ztPrice.subtract(zsPrice); BigDecimal ztRate = chaPrice.multiply(new BigDecimal("100")).divide(zsPrice, 2, 4); log.info("当前涨跌幅 = {} % , 涨停幅度 = {} %", Double.valueOf(stock_crease), ztRate); if ((new BigDecimal(String.valueOf(stock_crease))).compareTo(ztRate) == 0 && buyType .intValue() == 0) { return ServerResponse.createByErrorMsg("The current stock has reached the daily limit and cannot be purchased.",request.getHeader(MessageLocaleResolver.LANG)); } if (stock.getStockPlate() == null) { int maxcrease = siteSetting.getCreaseMaxPercent().intValue(); if (stock_crease > 0.0D && stock_crease >= maxcrease) { return ServerResponse.createByErrorMsg("The order failed, the current price of the stock increased:" + stock_crease + "," + "greater than the maximum increase:" + maxcrease,request.getHeader(MessageLocaleResolver.LANG)); } if (stock_crease < 0.0D && Math.abs(stock_crease) > maxcrease) { return ServerResponse.createByErrorMsg("The order failed, and the stock is currently falling.:" + stock_crease + "," + "greater than the maximum drop:" + maxcrease,request.getHeader(MessageLocaleResolver.LANG)); } } else { int maxcrease = siteSetting.getKcCreaseMaxPercent().intValue(); if (stock_crease > 0.0D && stock_crease >= maxcrease) { return ServerResponse.createByErrorMsg("The order failed, and science and technology innovation stocks are currently rising" + ":" + stock_crease + ",greater than the maximum increase:" + maxcrease,request.getHeader(MessageLocaleResolver.LANG)); } if (stock_crease < 0.0D && Math.abs(stock_crease) > maxcrease) { return ServerResponse.createByErrorMsg("The order failed, and science and technology innovation stocks are currently falling.:" + stock_crease + "," + "greater than the maximum drop:" + maxcrease,request.getHeader(MessageLocaleResolver.LANG)); } } ServerResponse serverResponse = this.iStockService.selectRateByDaysAndStockCode(stock .getStockCode(), siteSetting.getStockDays().intValue()); if (!serverResponse.isSuccess()) { return serverResponse; } BigDecimal daysRate = (BigDecimal) serverResponse.getData(); log.info("股票 {} ， {} 天内 涨幅 {} , 设置的涨幅 = {}", new Object[]{stock.getStockCode(), siteSetting .getStockDays(), daysRate, siteSetting.getStockRate()}); if (daysRate != null && siteSetting.getStockRate().compareTo(daysRate) == -1) { return serverResponse.createByErrorMsg(siteSetting.getStockDays() + "The increase within a day exceeds " + siteSetting .getStockRate() + "Cannot trade",request.getHeader(MessageLocaleResolver.LANG)); } BigDecimal buy_amt = now_price.multiply(new BigDecimal(buyNum.intValue())).divide(new BigDecimal(lever.intValue())).setScale(2, 4); BigDecimal buy_amt_autual = now_price.multiply(new BigDecimal(buyNum.intValue())).divide(new BigDecimal(lever.intValue()), 2, 4); int compareInt = buy_amt_autual.compareTo(new BigDecimal(siteSetting.getBuyMinAmt().intValue())); if (compareInt == -1) { return ServerResponse.createByErrorMsg("The order failed, the purchase amount is less than" + siteSetting .getBuyMinAmt() + "Yuan",request.getHeader(MessageLocaleResolver.LANG)); } BigDecimal max_buy_amt = user_enable_amt.multiply(siteSetting.getBuyMaxAmtPercent()); int compareCwInt = buy_amt_autual.compareTo(max_buy_amt); if (compareCwInt == 1) { return ServerResponse.createByErrorMsg("The order failed and cannot exceed the available funds." + siteSetting .getBuyMaxAmtPercent().multiply(new BigDecimal("100")) + "%",request.getHeader(MessageLocaleResolver.LANG)); } int compareUserAmtInt = user_enable_amt.compareTo(buy_amt_autual); log.info("用户可用金额 = {} 实际购买金额 = {}", user_enable_amt, buy_amt_autual); log.info("比较 用户金额 和 实际 购买金额 = {}", Integer.valueOf(compareUserAmtInt)); if (compareUserAmtInt == -1) { return ServerResponse.createByErrorMsg("The order failed and the available financing amount is less than" + buy_amt_autual + "Yuan",request.getHeader(MessageLocaleResolver.LANG)); } if (user.getUserIndexAmt().compareTo(new BigDecimal("0")) == -1) { return ServerResponse.createByErrorMsg("Failure, the total index capital is less than 0",request.getHeader(MessageLocaleResolver.LANG)); } if (user.getUserFutAmt().compareTo(new BigDecimal("0")) == -1) { return ServerResponse.createByErrorMsg("Failure, total futures funds are less than 0",request.getHeader(MessageLocaleResolver.LANG)); } UserFundsPosition userPosition = new UserFundsPosition(); userPosition.setPositionType(user.getAccountType()); userPosition.setPositionSn(KeyUtils.getUniqueKey()); userPosition.setUserId(user.getId()); userPosition.setNickName(user.getRealName()); userPosition.setAgentId(user.getAgentId()); userPosition.setStockId(stock.getId()); userPosition.setStockCode(stock.getStockCode()); userPosition.setStockName(stock.getStockName()); userPosition.setStockGid(stock.getStockGid()); userPosition.setStockSpell(stock.getStockSpell()); userPosition.setBuyOrderId(GeneratePosition.getPositionId()); userPosition.setBuyOrderTime(new Date()); userPosition.setBuyOrderPrice(now_price); userPosition.setOrderDirection((buyType.intValue() == 0) ? "买涨" : "买跌"); userPosition.setOrderNum(buyNum); userPosition.setSubaccountNumber(subaccountNumber); if (stock.getStockPlate() != null) { userPosition.setStockPlate(stock.getStockPlate()); } userPosition.setIsLock(Integer.valueOf(0)); userPosition.setOrderLever(lever); userPosition.setOrderTotalPrice(buy_amt); BigDecimal buy_fee_amt = buy_amt.multiply(siteSetting.getBuyFee()).setScale(2, 4); log.info("用户购买手续费（配资后总资金 * 百分比） = {}", buy_fee_amt); userPosition.setOrderFee(buy_fee_amt); BigDecimal buy_yhs_amt = buy_amt.multiply(siteSetting.getDutyFee()).setScale(2, 4); log.info("用户购买印花税（配资后总资金 * 百分比） = {}", buy_yhs_amt); userPosition.setOrderSpread(buy_yhs_amt); SiteSpread siteSpread = iSiteSpreadService.findSpreadRateOne(new BigDecimal(stock_crease), buy_amt, stock.getStockCode(), now_price); BigDecimal spread_rate_amt = buy_amt.multiply(siteSpread.getSpreadRate()).setScale(2, 4); log.info("用户购买点差费（配资后总资金 * 百分比{}） = {}", siteSpread.getSpreadRate(), spread_rate_amt); userPosition.setSpreadRatePrice(spread_rate_amt); BigDecimal profit_and_lose = new BigDecimal("0"); userPosition.setProfitAndLose(profit_and_lose); BigDecimal all_profit_and_lose = profit_and_lose.subtract(buy_fee_amt).subtract(buy_yhs_amt).subtract(spread_rate_amt); userPosition.setAllProfitAndLose(all_profit_and_lose); userPosition.setOrderStayDays(Integer.valueOf(0)); userPosition.setOrderStayFee(new BigDecimal("0")); int insertPositionCount = 0; this.userFundsPositionMapper.insert(userPosition); insertPositionCount = userPosition.getId(); if (insertPositionCount > 0) { //修改用户可用余额= 当前余额-下单金额-买入手续费-印花税-点差费 BigDecimal reckon_enable = user_enable_amt.subtract(buy_amt_autual).subtract(buy_fee_amt).subtract(buy_yhs_amt).subtract(spread_rate_amt); user.setEnableAmt(reckon_enable); /*int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user); if (updateUserCount > 0) { log.info("【用户交易下单】修改用户金额成功"); } else { log.error("用户交易下单】修改用户金额出错"); throw new Exception("用户交易下单】修改用户金额出错"); }*/ //核算代理收入-入仓手续费 //iAgentAgencyFeeService.AgencyFeeIncome(1,userPosition.getPositionSn()); log.info("【用户交易下单】保存持仓记录成功"); } else { log.error("用户交易下单】保存持仓记录出错"); throw new Exception("用户交易下单】保存持仓记录出错"); } return ServerResponse.createBySuccessMsg("Order successful",request.getHeader(MessageLocaleResolver.LANG)); } /* * 分仓交易-用户平仓操作 * */ @Transactional public ServerResponse sellFunds(String positionSn, int doType,HttpServletRequest request) throws Exception { log.info("【用户交易平仓】 positionSn = {} ， dotype = {}", positionSn, Integer.valueOf(doType)); String lanage = request.getHeader(MessageLocaleResolver.LANG); SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting(); if (siteSetting == null) { log.error("平仓出错，网站设置表不存在"); return ServerResponse.createByErrorMsg("Order failed, system setting error",lanage); } if (doType != 0) { String am_begin = siteSetting.getTransAmBegin(); String am_end = siteSetting.getTransAmEnd(); String pm_begin = siteSetting.getTransPmBegin(); String pm_end = siteSetting.getTransPmEnd(); boolean am_flag = BuyAndSellUtils.isTransTime(am_begin, am_end); boolean pm_flag = BuyAndSellUtils.isTransTime(pm_begin, pm_end); log.info("是否在上午交易时间 = {} 是否在下午交易时间 = {}", Boolean.valueOf(am_flag), Boolean.valueOf(pm_flag)); if (!am_flag && !pm_flag) { return ServerResponse.createByErrorMsg("Failed to close position, not within trading hours",lanage); } } UserFundsPosition userPosition = this.userFundsPositionMapper.findPositionBySn(positionSn); if (userPosition == null) { return ServerResponse.createByErrorMsg("Failed to close the position, the order does not exist",lanage); } User user = this.userMapper.selectByPrimaryKey(userPosition.getUserId()); /*实名认证开关开启*/ SiteProduct siteProduct = iSiteProductService.getProductSetting(); if (siteProduct.getRealNameDisplay() && user.getIsLock().intValue() == 1) { return ServerResponse.createByErrorMsg("Position closing failed, user has been locked",lanage); } if(siteProduct.getHolidayDisplay()){ return ServerResponse.createByErrorMsg("No trading allowed on weekends or holidays！",lanage); } if (userPosition.getSellOrderId() != null) { return ServerResponse.createByErrorMsg("Failed to close the position, this order has been closed",lanage); } if (1 == userPosition.getIsLock().intValue()) { return ServerResponse.createByErrorMsg("平仓失败 " + userPosition.getLockMsg(),lanage); } if (!DateTimeUtil.isCanSell(userPosition.getBuyOrderTime(), siteSetting.getCantSellTimes().intValue())) { return ServerResponse.createByErrorMsg(siteSetting.getCantSellTimes() + "分钟内不能平仓",lanage); } Stock stock = stockMapper.selectOne(new QueryWrapper().eq("stock_code",userPosition.getStockCode())); StockListVO stockListVO = SinaStockApi.assembleInStockListVO(stock); BigDecimal now_price = new BigDecimal(stockListVO.getNowPrice()); if (now_price.compareTo(new BigDecimal("0")) != 1) { log.error("股票 = {} 收到报价 = {}", userPosition.getStockName(), now_price); return ServerResponse.createByErrorMsg("Quote 0, position closing failed, please try again later.",lanage); } double stock_crease = stockListVO.getHcrate().doubleValue(); BigDecimal zsPrice = new BigDecimal(stockListVO.getPreclose_px()); BigDecimal ztPrice = zsPrice.multiply(new BigDecimal("0.1")).add(zsPrice); ztPrice = ztPrice.setScale(2, 4); BigDecimal chaPrice = ztPrice.subtract(zsPrice); BigDecimal ztRate = chaPrice.multiply(new BigDecimal("100")).divide(zsPrice, 2, 4); ztRate = ztRate.negate(); log.info("股票当前涨跌幅 = {} 跌停幅度 = {}", Double.valueOf(stock_crease), ztRate); if ((new BigDecimal(String.valueOf(stock_crease))).compareTo(ztRate) == 0 && "买涨" .equals(userPosition.getOrderDirection())) { return ServerResponse.createByErrorMsg("The current stock has reached the limit and cannot be sold.",lanage); } Integer buy_num = userPosition.getOrderNum(); BigDecimal all_buy_amt = userPosition.getOrderTotalPrice(); BigDecimal all_sell_amt = now_price.multiply(new BigDecimal(buy_num.intValue())); BigDecimal profitLoss = new BigDecimal("0"); if ("买涨".equals(userPosition.getOrderDirection())) { log.info("买卖方向：{}", "涨"); profitLoss = all_sell_amt.subtract(all_buy_amt); } else { log.info("买卖方向：{}", "跌"); profitLoss = all_buy_amt.subtract(all_sell_amt); } log.info("买入总金额 = {} , 卖出总金额 = {} , 盈亏 = {}", new Object[]{all_buy_amt, all_sell_amt, profitLoss}); BigDecimal user_all_amt = user.getUserAmt(); BigDecimal user_enable_amt = user.getEnableAmt(); log.info("用户原本总资金 = {} , 可用 = {}", user_all_amt, user_enable_amt); BigDecimal buy_fee_amt = userPosition.getOrderFee(); log.info("买入手续费 = {}", buy_fee_amt); BigDecimal orderSpread = userPosition.getOrderSpread(); log.info("印花税 = {}", orderSpread); BigDecimal orderStayFee = userPosition.getOrderStayFee(); log.info("留仓费 = {}", orderStayFee); BigDecimal spreadRatePrice = userPosition.getSpreadRatePrice(); log.info("点差费 = {}", spreadRatePrice); BigDecimal sell_fee_amt = all_sell_amt.multiply(siteSetting.getSellFee()).setScale(2, 4); log.info("卖出手续费 = {}", sell_fee_amt); BigDecimal all_fee_amt = buy_fee_amt.add(sell_fee_amt).add(orderSpread).add(orderStayFee).add(spreadRatePrice); log.info("总的手续费费用 = {}", all_fee_amt); userPosition.setSellOrderId(GeneratePosition.getPositionId()); userPosition.setSellOrderPrice(now_price); userPosition.setSellOrderTime(new Date()); BigDecimal order_fee_all = buy_fee_amt.add(sell_fee_amt); userPosition.setOrderFee(order_fee_all); userPosition.setProfitAndLose(profitLoss); BigDecimal all_profit = profitLoss.subtract(all_fee_amt); userPosition.setAllProfitAndLose(all_profit); int updatePositionCount = this.userFundsPositionMapper.update(userPosition); if (updatePositionCount > 0) { log.info("【用户平仓】修改浮动盈亏记录成功"); } else { log.error("用户平仓】修改浮动盈亏记录出错"); throw new Exception("用户平仓】修改浮动盈亏记录出错"); } BigDecimal freez_amt = all_buy_amt.divide(new BigDecimal(userPosition.getOrderLever().intValue()), 2, 4); BigDecimal reckon_all = user_all_amt.add(all_profit); BigDecimal reckon_enable = user_enable_amt.add(all_profit).add(freez_amt); log.info("用户平仓后的总资金 = {} , 可用资金 = {}", reckon_all, reckon_enable); user.setUserAmt(reckon_all); user.setEnableAmt(reckon_enable); /*int updateUserCount = this.userMapper.updateByPrimaryKeySelective(user); if (updateUserCount > 0) { log.info("【用户平仓】修改用户金额成功"); } else { log.error("用户平仓】修改用户金额出错"); throw new Exception("用户平仓】修改用户金额出错"); }*/ UserCashDetail ucd = new UserCashDetail(); ucd.setPositionId(userPosition.getId()); ucd.setAgentId(user.getAgentId()); ucd.setAgentName(user.getAgentName()); ucd.setUserId(user.getId()); ucd.setUserName(user.getRealName()); ucd.setDeType("配资总盈亏"); ucd.setDeAmt(all_profit); ucd.setDeSummary("卖出股票，" + userPosition.getStockCode() + "/" + userPosition.getStockName() + ",占用本金：" + freez_amt + ",总手续费：" + all_fee_amt + ",留仓费：" + orderStayFee+ ",印花税：" + orderSpread + ",点差费：" + spreadRatePrice + ",盈亏：" + profitLoss + "，总盈亏：" + all_profit); ucd.setAddTime(new Date()); ucd.setIsRead(Integer.valueOf(0)); int insertSxfCount = this.userCashDetailMapper.insert(ucd); if (insertSxfCount > 0) { /*//核算代理收入-平仓手续费 iAgentAgencyFeeService.AgencyFeeIncome(2,userPosition.getPositionSn()); //核算代理收入-分红 iAgentAgencyFeeService.AgencyFeeIncome(4,userPosition.getPositionSn());*/ log.info("【用户平仓】保存明细记录成功"); } else { log.error("用户平仓】保存明细记录出错"); throw new Exception("用户平仓】保存明细记录出错"); } return ServerResponse.createBySuccessMsg("Closed position successfully！",lanage); } /* * 分仓交易-查询所有平仓/持仓信息 * */ public ServerResponse findMyPositionByCodeAndSpell(String stockCode, String stockSpell, Integer state, HttpServletRequest request, int pageNum, int pageSize) { User user = this.iUserService.getCurrentUser(request); PageHelper.startPage(pageNum, pageSize); List userPositions = this.userFundsPositionMapper.findMyPositionByCodeAndSpell(user.getId(), stockCode, stockSpell, state); List userPositionVOS = Lists.newArrayList(); if (userPositions.size() > 0) { for (UserFundsPosition position : userPositions) { UserPositionVO userPositionVO = assembleUserPositionVO(position); userPositionVOS.add(userPositionVO); } } PageInfo pageInfo = new PageInfo(userPositions); pageInfo.setList(userPositionVOS); return ServerResponse.createBySuccess(pageInfo); } /*根据分仓配资代码查询用户最早入仓股票*/ public ServerResponse findUserFundsPositionByCode(HttpServletRequest request, String fundsCode) { User user = this.iUserService.getCurrentRefreshUser(request); if (user == null){ return ServerResponse.createBySuccessMsg("please log in first",request.getHeader(MessageLocaleResolver.LANG)); } UserFundsPosition position = this.userFundsPositionMapper.findUserFundsPositionByCode(user.getId(), fundsCode); List userPositionVOS = Lists.newArrayList(); UserPositionVO userPositionVO = null; if(position != null){ userPositionVO = assembleUserPositionVO(position); } userPositionVOS.add(userPositionVO); PageInfo pageInfo = new PageInfo(); pageInfo.setList(userPositionVOS); return ServerResponse.createBySuccess(pageInfo); } private UserPositionVO assembleUserPositionVO(UserFundsPosition position) { UserPositionVO userPositionVO = new UserPositionVO(); userPositionVO.setId(position.getId()); userPositionVO.setPositionType(position.getPositionType()); userPositionVO.setPositionSn(position.getPositionSn()); userPositionVO.setUserId(position.getUserId()); userPositionVO.setNickName(position.getNickName()); userPositionVO.setAgentId(position.getAgentId()); userPositionVO.setStockName(position.getStockName()); userPositionVO.setStockCode(position.getStockCode()); userPositionVO.setStockGid(position.getStockGid()); userPositionVO.setStockSpell(position.getStockSpell()); userPositionVO.setBuyOrderId(position.getBuyOrderId()); userPositionVO.setBuyOrderTime(position.getBuyOrderTime()); userPositionVO.setBuyOrderPrice(position.getBuyOrderPrice()); userPositionVO.setSellOrderId(position.getSellOrderId()); userPositionVO.setSellOrderTime(position.getSellOrderTime()); userPositionVO.setSellOrderPrice(position.getSellOrderPrice()); // userPositionVO.setProfitTargetPrice(position.getProfitTargetPrice()); // userPositionVO.setStopTargetPrice(position.getStopTargetPrice()); userPositionVO.setOrderDirection(position.getOrderDirection()); userPositionVO.setOrderNum(position.getOrderNum()); userPositionVO.setOrderLever(position.getOrderLever()); userPositionVO.setOrderTotalPrice(position.getOrderTotalPrice()); userPositionVO.setOrderFee(position.getOrderFee()); userPositionVO.setOrderSpread(position.getOrderSpread()); userPositionVO.setOrderStayFee(position.getOrderStayFee()); userPositionVO.setOrderStayDays(position.getOrderStayDays()); userPositionVO.setStockPlate(position.getStockPlate()); userPositionVO.setSpreadRatePrice(position.getSpreadRatePrice()); PositionProfitVO positionProfitVO = getPositionProfitVO(position); userPositionVO.setProfitAndLose(positionProfitVO.getProfitAndLose()); userPositionVO.setAllProfitAndLose(positionProfitVO.getAllProfitAndLose()); userPositionVO.setNow_price(positionProfitVO.getNowPrice()); return userPositionVO; } private PositionProfitVO getPositionProfitVO(UserFundsPosition position) { BigDecimal profitAndLose = new BigDecimal("0"); BigDecimal allProfitAndLose = new BigDecimal("0"); String nowPrice = ""; if (position.getSellOrderId() != null) { BigDecimal subPrice = position.getSellOrderPrice().subtract(position.getBuyOrderPrice()); profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())); if ("买跌".equals(position.getOrderDirection())) { profitAndLose = profitAndLose.negate(); } allProfitAndLose = profitAndLose.subtract(position.getOrderFee()).subtract(position.getOrderSpread()).subtract(position.getOrderStayFee()).subtract(position.getSpreadRatePrice()); } else { Stock stock = stockMapper.selectOne(new QueryWrapper().eq("stock_code",position.getStockCode())); StockListVO stockListVO = SinaStockApi.assembleInStockListVO(stock); nowPrice = stockListVO.getNowPrice(); BigDecimal subPrice = (new BigDecimal(nowPrice)).subtract(position.getBuyOrderPrice()); profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())); if ("买跌".equals(position.getOrderDirection())) { profitAndLose = profitAndLose.negate(); } //总盈亏= 浮动盈亏 – 手续费 – 印花税 – 留仓费 – 点差费 allProfitAndLose = profitAndLose.subtract(position.getOrderFee()).subtract(position.getOrderSpread()).subtract(position.getOrderStayFee()).subtract(position.getSpreadRatePrice()); } PositionProfitVO positionProfitVO = new PositionProfitVO(); positionProfitVO.setProfitAndLose(profitAndLose); positionProfitVO.setAllProfitAndLose(allProfitAndLose); positionProfitVO.setNowPrice(nowPrice); return positionProfitVO; } }