trading-order-admin/src/main/java/com/yami/trading/admin/controller/dz/AdminStockDzController.java
@@ -1,6 +1,9 @@ package com.yami.trading.admin.controller.dz; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.yami.trading.bean.dz.StockDz; import com.yami.trading.common.constants.Constants; import com.yami.trading.common.domain.Result; import com.yami.trading.service.dz.StockDzService; import io.swagger.annotations.Api; @@ -9,6 +12,7 @@ import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; @RestController @CrossOrigin @@ -30,7 +34,7 @@ public Result getDzListByAdmin(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "5") int pageSize, @RequestParam(value = "keywords", required = false)String keywords) { return stockDzService.getDzListByAdmin(pageNum, pageSize, keywords); return stockDzService.getDzListByAdmin(pageNum, pageSize, keywords, Constants.US_STOCKS); } /** @@ -70,4 +74,27 @@ return stockDzService.updByAdmin(model); } @ApiOperation("大宗交易审核列表") @RequestMapping({"getDzCheckList.do"}) @ResponseBody public Result getDzCheckList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "15") int pageSize, @RequestParam(value = "state", required = false) String state, @RequestParam(value = "stockCode", required = false)String stockCode) { return stockDzService.getDzCheckList(pageNum, pageSize, state, stockCode, Constants.US_STOCKS); } //大宗审核 @RequestMapping({"dzCheck.do"}) @ResponseBody public Result check(@RequestParam(value = "id") String id, @RequestParam(value = "checkType") Integer checkType, @RequestParam(value = "orderNum") Double orderNum) { if(checkType != 2 && (id == null || checkType == null || orderNum == null)){ return Result.failed("参数不能为空"); } return stockDzService.dzCheck(id, checkType, orderNum); } } trading-order-admin/src/main/java/com/yami/trading/api/controller/dz/ApiStockDzController.java
@@ -1,13 +1,19 @@ package com.yami.trading.api.controller.dz; import com.yami.trading.common.constants.Constants; import com.yami.trading.common.domain.Result; import com.yami.trading.common.exception.YamiShopBindException; import com.yami.trading.security.common.util.SecurityUtils; import com.yami.trading.service.dz.StockDzService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; @RestController @CrossOrigin @@ -19,6 +25,9 @@ @Resource StockDzService stockDzService; private static final ThreadLocal<Boolean> orderCreated = ThreadLocal.withInitial(() -> false); private final Lock lock = new ReentrantLock(); /** * 大宗交易 列表 * @param pageNum @@ -27,30 +36,63 @@ * @param keyWords 搜索内容 * @return */ @ApiOperation("大宗交易列表") @PostMapping({"getDzList.do"}) @ResponseBody public Result getDzList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "5") int pageSize, @RequestParam(value = "orderBy", required = false) String orderBy, @RequestParam(value = "keyWords", required = false) String keyWords, HttpServletRequest request) { return stockDzService.getDzList(pageNum, pageSize, orderBy,keyWords , request); @RequestParam(value = "keyWords", required = false) String keyWords) { return stockDzService.getDzList(pageNum, pageSize, orderBy,keyWords, Constants.US_STOCKS); } /** * 大宗下单 */ @RequestMapping({"buyStockDz.do"}) @ResponseBody public Result buyDz(@RequestParam("dzId") String dzId, @RequestParam("password") String password,@RequestParam("num") double num) { lock.lock(); try { if (orderCreated.get()) { throw new YamiShopBindException("当前交易人数过多，请稍后重试"); } orderCreated.set(true); String partyId = SecurityUtils.getCurrentUserId(); if (partyId == null || partyId.isEmpty()) { throw new YamiShopBindException("请先登录"); } return stockDzService.buyDz(dzId, password, num, partyId); } catch (Exception e) { log.error(e.getMessage()); } finally{ lock.unlock(); orderCreated.set(false); } throw new YamiShopBindException("订单异常，请稍后重试"); } /** * 大宗交易订单列表 * @param pageNum * @param pageSize * @param status 状态 //0：待审核 1：成功 2：失败 * @param state * @return */ /*@RequestMapping({"getDzOrderList.do"}) */ @ApiOperation("大宗交易订单列表") @RequestMapping({"getDzOrderList.do"}) @ResponseBody public Result getDzOrderList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, @RequestParam(value = "pageSize", defaultValue = "5") int pageSize, @RequestParam(value = "status", required = false) Integer status, HttpServletRequest request) { return iUserPositionService.getDzOrderList(pageNum, pageSize, status, request); }*/ @RequestParam(value = "state", required = false) String state) { String partyId = SecurityUtils.getCurrentUserId(); if (partyId == null || partyId.isEmpty()) { throw new YamiShopBindException("请先登录"); } return stockDzService.getDzOrderList(pageNum, pageSize, state, partyId, Constants.US_STOCKS); } } trading-order-bean/src/main/java/com/yami/trading/bean/dz/ExchangeApplyOrderDz.java
New file @@ -0,0 +1,63 @@ package com.yami.trading.bean.dz; import com.baomidou.mybatisplus.annotation.FieldFill; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import com.yami.trading.common.domain.UUIDEntity; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.util.Date; @Data @TableName("t_exchange_apply_order_dz") public class ExchangeApplyOrderDz extends UUIDEntity { private static final long serialVersionUID = -7263336511778693149L; public final static String STATE_SUBMITTED = "submitted"; public final static String STATE_SUCCEED = "succeed"; public final static String STATE_FAILED = "failed"; public final static String OFFSET_OPEN = "open"; public final static String OFFSET_CLOSE = "close"; public final static String ORDER_PRICE_TYPE_LIMIT = "limit"; public final static String ORDER_PRICE_TYPE_OPPONENT = "opponent"; @ApiModelProperty("userId") private String partyId; @ApiModelProperty("关联dzid") private String dzId; @ApiModelProperty("订单号") private String orderNo; @ApiModelProperty("股票代码") private String symbol; @ApiModelProperty("币种数量") private double symbolValue; @ApiModelProperty("委托数量") private Double volume; @ApiModelProperty("手续费") private double fee; @ApiModelProperty("交易价格") private Double price; @ApiModelProperty("状态.submitted 已提交，succeed 成功， failed 失败") private String state = "submitted"; private Date createTime; /** * 创建日期 */ @TableField(fill = FieldFill.INSERT) private Long createTimeTs; /** * 更新日期 */ @TableField(fill = FieldFill.INSERT_UPDATE) private Long updateTimeTs; } trading-order-bean/src/main/java/com/yami/trading/bean/dz/StockDz.java
@@ -14,13 +14,14 @@ @Data public class StockDz extends UUIDEntity { private static final long serialVersionUID = 1L; private String stockName; private String stockCode; //美股US_STOCKS ETF indices private String stockType; private String stockGid; private String stockSpell; @@ -30,11 +31,6 @@ @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date addTime; /*点差费率*/ private BigDecimal spreadRate; // 涨幅比例 private BigDecimal increaseRatio; //最小购买数量 private Integer stockNum; @TableField(updateStrategy = FieldStrategy.IGNORED) @@ -43,7 +39,6 @@ private Date startTime; @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss") private Date endTime; private BigDecimal discount; /** * 周期 @@ -54,7 +49,7 @@ * 大宗审核开关（0：关闭 1：打开） */ private Integer switchType = 0; private static final long serialVersionUID = 1L; //价格 private BigDecimal nowPrice;
New file @@ -0,0 +1,22 @@ package com.yami.trading.bean.dz.dto; import com.baomidou.mybatisplus.annotation.FieldFill; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import com.yami.trading.bean.dz.ExchangeApplyOrderDz; import com.yami.trading.common.domain.UUIDEntity; import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiOperation; import lombok.Data; import java.util.Date; @Data public class ExchangeApplyOrderDzDto extends ExchangeApplyOrderDz { @ApiModelProperty("用户名") private String userName; @ApiModelProperty("UID") private String userCode; } trading-order-service/src/main/java/com/yami/trading/dao/dz/ExchangeApplyOrderDzMapper.java
New file @@ -0,0 +1,10 @@ package com.yami.trading.dao.dz; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.yami.trading.bean.dz.ExchangeApplyOrderDz; public interface ExchangeApplyOrderDzMapper extends BaseMapper<ExchangeApplyOrderDz> { } trading-order-service/src/main/java/com/yami/trading/dao/dz/StockDzMapper.java
@@ -12,9 +12,21 @@ Page findStockTypeDz(Page page, @Param("orderBy") String orderBy, @Param("keyWords") String keyWords , @Param("formatDate") String formatDate); @Param("formatDate") String formatDate, @Param("stockType") String stockType); Page getDzListByAdmin(Page page, @Param("keyWords") String keyWords); @Param("keyWords") String keyWords, @Param("stockType") String stockType); Page getDzOrderList(Page page, @Param("state") String state, @Param("userId") String userId, @Param("stockType") String stockType); Page getDzCheckList(Page page, @Param("state") String state, @Param("stockCode") String stockCode, @Param("stockType") String stockType); } trading-order-service/src/main/java/com/yami/trading/service/dz/StockDzService.java
@@ -9,14 +9,22 @@ public interface StockDzService extends IService<StockDz> { Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, HttpServletRequest request); Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, String stockType); Result addByAdmin(String stockCode, String stockNum, String password, String startTime, String endTime, String discount,Integer period,String nowPrice,Integer switchType); Result getDzListByAdmin(int pageNum, int pageSize, String keywords); Result getDzListByAdmin(int pageNum, int pageSize, String keywords, String stockType); Result updByAdmin(StockDz model); Result deleteByAdmin(String id); Result getDzOrderList(int pageNum, int pageSize, String state, String userId, String stockType); Result getDzCheckList(int pageNum, int pageSize, String state, String stockCode, String stockType); Result buyDz(String dzId, String password, double num, String partyId); Result dzCheck(String id, Integer checkType, double num); } trading-order-service/src/main/java/com/yami/trading/service/dz/impl/StockDzServiceImpl.java
@@ -7,18 +7,37 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yami.trading.bean.dz.ExchangeApplyOrderDz; import com.yami.trading.bean.dz.StockDz; import com.yami.trading.bean.item.domain.Item; import com.yami.trading.bean.model.MoneyLog; import com.yami.trading.bean.model.User; import com.yami.trading.bean.model.Wallet; import com.yami.trading.bean.syspara.domain.Syspara; import com.yami.trading.common.constants.Constants; import com.yami.trading.common.domain.Result; import com.yami.trading.common.exception.YamiShopBindException; import com.yami.trading.common.util.Arith; import com.yami.trading.common.util.RandomUtil; import com.yami.trading.dao.dz.ExchangeApplyOrderDzMapper; import com.yami.trading.dao.dz.StockDzMapper; import com.yami.trading.service.MoneyLogService; import com.yami.trading.service.WalletService; import com.yami.trading.service.dz.StockDzService; import com.yami.trading.service.item.ItemService; import com.yami.trading.service.syspara.SysparaService; import com.yami.trading.service.user.UserService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; 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.Arrays; import java.util.Date; import java.util.List; import java.util.Objects; @Service @Slf4j @@ -27,12 +46,30 @@ @Resource private StockDzMapper stockDzMapper; @Resource private UserService userService; @Resource private SysparaService sysparaService; @Resource private WalletService walletService; @Resource private ExchangeApplyOrderDzMapper exchangeApplyOrderDzMapper; @Resource private MoneyLogService moneyLogService; @Resource private ItemService itemService; @Override public Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, HttpServletRequest request) { public Result getDzList(int pageNum, int pageSize, String orderBy, String keyWords, String stockType) { try { String formatDate = DateUtil.format(new Date(), DatePattern.NORM_DATETIME_PATTERN); Page page = new Page(pageNum, pageSize); stockDzMapper.findStockTypeDz(page,orderBy,keyWords,formatDate); stockDzMapper.findStockTypeDz(page,orderBy,keyWords,formatDate, stockType); return Result.succeed(page); } catch (Exception e) { log.error(e.getMessage()); @@ -52,21 +89,19 @@ return Result.failed("股票代码已存在"); } Item item = itemService.findBySymbol(stockCode); if(item == null){ return Result.failed("不存在该股票"); } StockDz stockDz = new StockDz(); /*stockDz.setStockName(stock.getStockName()); stockDz.setStockCode(stock.getStockCode()); stockDz.setStockType(stock.getStockType()); stockDz.setStockGid(stock.getStockGid()); stockDz.setStockSpell(stock.getStockSpell()); stockDz.setIsLock(stock.getIsLock()); stockDz.setSpreadRate(stock.getSpreadRate());*/ stockDz.setStockCode(stockCode); stockDz.setStockName(item.getSymbolFullName()); stockDz.setStockCode(item.getSymbol()); stockDz.setStockType(item.getType()); stockDz.setStockSpell(item.getSymbolData()); stockDz.setIsLock(1); stockDz.setIsShow(1); stockDz.setAddTime(new Date()); stockDz.setIncreaseRatio(BigDecimal.ZERO); stockDz.setStockNum(Integer.valueOf(stockNum)); stockDz.setPassword(password); stockDz.setStartTime(DateUtil.parseDateTime(startTime)); @@ -82,10 +117,10 @@ } @Override public Result getDzListByAdmin(int pageNum, int pageSize, String Keywords) { public Result getDzListByAdmin(int pageNum, int pageSize, String Keywords, String stockType) { try { Page page = new Page(pageNum, pageSize); stockDzMapper.getDzListByAdmin(page, Keywords); stockDzMapper.getDzListByAdmin(page, Keywords, stockType); return Result.succeed(page); } catch (Exception e) { log.error(e.getMessage()); @@ -101,6 +136,20 @@ if(count > 0){ return Result.failed("股票代码已存在"); } Item item = itemService.findBySymbol(model.getStockCode()); if(item == null){ return Result.failed("不存在该股票"); } StockDz stockDz = stockDzMapper.selectById(model.getUuid()); if(stockDz == null){ return Result.failed("不存在该大宗信息"); } model.setStockName(item.getSymbolFullName()); model.setStockCode(item.getSymbol()); model.setStockType(item.getType()); model.setStockSpell(item.getSymbolData()); return stockDzMapper.updateById(model) > 0 ? Result.succeed("修改成功") : Result.failed("修改失败"); } @@ -113,6 +162,206 @@ return Result.failed("删除失败"); } @Override public Result getDzOrderList(int pageNum, int pageSize, String state, String userId, String stockType) { try { Page page = new Page(pageNum, pageSize); stockDzMapper.getDzOrderList(page ,state, userId, stockType); return Result.succeed(page); } catch (Exception e) { log.error(e.getMessage()); } return Result.failed("获取失败"); } @Override public Result getDzCheckList(int pageNum, int pageSize, String state, String stockCode, String stockType) { try { Page page = new Page(pageNum, pageSize); stockDzMapper.getDzCheckList(page ,state, stockCode, stockType); return Result.succeed(page); } catch (Exception e) { log.error(e.getMessage()); } return Result.failed("获取失败"); } @Transactional @Override public Result buyDz(String dzId, String password, double num, String partyId) { try { if (num <= 0) { throw new YamiShopBindException("请输入正确的货币数量"); } User party = userService.getById(partyId); if (!party.isEnabled()) { throw new YamiShopBindException("用户已禁用"); } Syspara syspara = sysparaService.find("stop_user_internet"); String stopUserInternet = syspara.getSvalue(); if (org.apache.commons.lang3.StringUtils.isNotEmpty(stopUserInternet)) { String[] stopUsers = stopUserInternet.split(","); if (Arrays.asList(stopUsers).contains(party.getUserName())) { throw new YamiShopBindException("无网络"); } } StockDz stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("uuid", dzId)); if (stockDz == null) { throw new YamiShopBindException("大宗不存在"); } if (StringUtils.isNotEmpty(stockDz.getPassword()) && !Objects.equals(stockDz.getPassword(), password)) { throw new YamiShopBindException("密码错误"); } if (stockDz.getIsLock() != null && stockDz.getIsLock() != 0) { throw new YamiShopBindException("股票被锁定,不能购买"); } if(stockDz.getStartTime().getTime() > new Date().getTime() || stockDz.getEndTime().getTime() < new Date().getTime()){ throw new YamiShopBindException("不在内幕交易时间之内"); } BigDecimal nowPrice = stockDz.getNowPrice(); if (nowPrice.compareTo(new BigDecimal("0")) == 0) { throw new YamiShopBindException("股票价格0,请重试"); } if (stockDz.getStockNum() > num) { throw new YamiShopBindException("最小购买数据" + stockDz.getStockNum()); } Wallet wallet = this.walletService.saveWalletByPartyId(partyId); BigDecimal buyAmt = nowPrice.multiply(new BigDecimal(num)); //手续费比率 Double feeRate = sysparaService.find("exchange_apply_order_dz_buy_fee").getDouble(); BigDecimal orderFree = buyAmt.multiply(BigDecimal.valueOf(feeRate)); BigDecimal orderAmt = buyAmt.add(orderFree); if (wallet.getMoney().compareTo(orderAmt) < 0) { throw new YamiShopBindException("订单失败，资金不足"); } BigDecimal amountBefore = wallet.getMoney(); ExchangeApplyOrderDz order = new ExchangeApplyOrderDz(); order.setPartyId(partyId); order.setSymbol(stockDz.getStockCode()); order.setSymbolValue(num); order.setVolume(buyAmt.doubleValue()); order.setPrice(nowPrice.doubleValue()); order.setOrderNo(com.yami.trading.common.util.DateUtil.getToday("yyMMddHHmmss") + RandomUtil.getRandomNum(8)); order.setFee(orderFree.doubleValue()); order.setCreateTime(new Date()); //判断审核开关 if(stockDz.getSwitchType() == 1) { order.setState(ExchangeApplyOrderDz.STATE_SUBMITTED); exchangeApplyOrderDzMapper.insert(order); return Result.succeed("购买成功，等待审核"); } order.setState(ExchangeApplyOrderDz.STATE_SUCCEED); exchangeApplyOrderDzMapper.insert(order); walletService.update(wallet.getUserId(), Arith.sub(0, orderAmt.doubleValue())); //TODO 转持仓 MoneyLog log = new MoneyLog(); log.setCategory(Constants.MONEYLOG_CATEGORY_EXCHANGE); String name = Constants.MONEYLOG_MAP.get(Constants.US_STOCKS); String type2 = Constants.MONEYLOG_MAP_TYPE.get(Constants.US_STOCKS); log.setAmountBefore(amountBefore); log.setAmount(orderAmt.negate()); log.setAmountAfter(amountBefore.subtract(orderAmt)); log.setLog(name + type2 + "大宗交易买入" + "，订单号[" + order.getOrderNo() + "]"); log.setUserId(order.getPartyId()); log.setWalletType(Constants.WALLET); log.setSymbol(stockDz.getStockCode()); log.setContentType(type2 + Constants.MONEYLOG_CONTENT_OPEN); log.setCreateTime(new Date()); log.setUpdateTime(new Date()); moneyLogService.save(log); return Result.succeed("购买成功"); } catch (Exception e) { log.error(e.getMessage()); } return Result.failed("操作失败"); } @Transactional @Override public Result dzCheck(String id, Integer checkType, double orderNum) { try { ExchangeApplyOrderDz order = exchangeApplyOrderDzMapper.selectById(id); if (order == null) { throw new YamiShopBindException("订单不存在"); } if (!order.getState().equals(ExchangeApplyOrderDz.STATE_SUBMITTED)) { throw new YamiShopBindException("订单已审核"); } //1.通过 2.拒绝 if (checkType == 2) { order.setState(ExchangeApplyOrderDz.STATE_FAILED); exchangeApplyOrderDzMapper.updateById(order); throw new YamiShopBindException("审核成功"); } if (orderNum > order.getSymbolValue()) { throw new YamiShopBindException("输入数量大于用户买入数量"); } StockDz stockDz = this.stockDzMapper.selectOne(new QueryWrapper<StockDz>().eq("id", order.getDzId())); if (stockDz == null) { throw new YamiShopBindException("大宗不存在"); } BigDecimal nowPrice = stockDz.getNowPrice(); if (nowPrice.compareTo(new BigDecimal("0")) == 0) { throw new YamiShopBindException("股票价格0,请重试"); } Wallet wallet = this.walletService.saveWalletByPartyId(order.getPartyId()); BigDecimal buyAmt = nowPrice.multiply(new BigDecimal(orderNum)); //手续费比率 Double feeRate = sysparaService.find("exchange_apply_order_dz_buy_fee").getDouble(); BigDecimal orderFree = buyAmt.multiply(BigDecimal.valueOf(feeRate)); BigDecimal orderAmt = buyAmt.add(orderFree); if (wallet.getMoney().compareTo(orderAmt) < 0) { throw new YamiShopBindException("订单失败，资金不足"); } BigDecimal amountBefore = wallet.getMoney(); order.setSymbolValue(orderNum); order.setVolume(buyAmt.doubleValue()); order.setFee(orderFree.doubleValue()); order.setState(ExchangeApplyOrderDz.STATE_SUCCEED); exchangeApplyOrderDzMapper.updateById(order); walletService.update(wallet.getUserId(), Arith.sub(0, orderAmt.doubleValue())); //TODO 转持仓 MoneyLog log = new MoneyLog(); log.setCategory(Constants.MONEYLOG_CATEGORY_EXCHANGE); String name = Constants.MONEYLOG_MAP.get(Constants.US_STOCKS); String type2 = Constants.MONEYLOG_MAP_TYPE.get(Constants.US_STOCKS); log.setAmountBefore(amountBefore); log.setAmount(orderAmt.negate()); log.setAmountAfter(amountBefore.subtract(orderAmt)); log.setLog(name + type2 + "大宗交易买入" + "，订单号[" + order.getOrderNo() + "]"); log.setUserId(order.getPartyId()); log.setWalletType(Constants.WALLET); log.setSymbol(stockDz.getStockCode()); log.setContentType(type2 + Constants.MONEYLOG_CONTENT_OPEN); log.setCreateTime(new Date()); log.setUpdateTime(new Date()); moneyLogService.save(log); return Result.succeed("审核成功,订单已转客户持仓"); } catch (Exception e) { log.error(e.getMessage()); } return Result.failed("操作失败"); } } trading-order-service/src/main/resources/mapper/dz/StockDzMapper.xml
@@ -10,6 +10,10 @@ WHERE start_time < #{formatDate} AND end_time > #{formatDate} <if test="stockType != null and stockType != '' "> AND stock_type = #{stockType} </if> <if test="keyWords != null and keyWords != '' "> AND (stock_spell LIKE #{keyWords} OR stock_name LIKE #{keyWords}) </if> @@ -30,10 +34,49 @@ * FROM t_stock_dz WHERE 1=1 <if test="stockType != null and stockType != '' "> AND stock_type = #{stockType} </if> <if test="keyWords != null and keyWords != '' "> AND (stock_code LIKE #{keyWords} OR stock_name LIKE #{keyWords}) </if> ORDER BY add_time DESC </select> <select id="getDzOrderList" resultType="com.yami.trading.bean.dz.ExchangeApplyOrderDz" parameterType="map"> SELECT * FROM t_exchange_apply_order_dz WHERE 1=1 <if test="stockType != null and stockType != '' "> AND stock_type = #{stockType} </if> <if test="state != null and state != ''"> AND t.state = #{state} </if> <if test="userId != null and userId != '' "> AND party_id = #{userId} </if> ORDER BY create_time DESC </select> <select id="getDzCheckList" resultType="com.yami.trading.bean.dz.dto.ExchangeApplyOrderDzDto" parameterType="map"> SELECT t.*,u.user_name,u.user_code,s.stock_type FROM t_exchange_apply_order_dz t LEFT JOIN tz_user u ON t.party_id = u.user_id LEFT JOIN t_stock_dz s ON s.uuid = t.dz_id WHERE 1=1 <if test="state != null and state != ''"> AND t.state = #{state} </if> <if test="stockCode != null and stockCode != '' "> AND t.symbol = #{stockCode} </if> <if test="stockType != null and stockType != '' "> AND s.stock_type = #{stockType} </if> ORDER BY t.create_time DESC </select> </mapper>
