1
zj
2024-06-05 c0b9a0978838536d21eeb4ab3ae5f29fa0d5dcc9
src/main/java/com/nq/service/impl/UserStockSubscribeServiceImpl.java
@@ -6,10 +6,7 @@
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.StockMapper;
import com.nq.dao.StockSubscribeMapper;
import com.nq.dao.UserMapper;
import com.nq.dao.UserStockSubscribeMapper;
import com.nq.dao.*;
import com.nq.enums.EStockType;
import com.nq.enums.EUserAssets;
import com.nq.pojo.*;
@@ -48,7 +45,8 @@
    @Resource
    UserMapper userMapper;
    @Resource
    AgentUserMapper agentUserMapper;
    @Autowired
    ISiteMessageService iSiteMessageService;
    @Autowired
@@ -103,9 +101,8 @@
                if (stockSubscribe == null) {
                    return ServerResponse.createByErrorMsg("新的股票代码不存在",request);
                }
                if (model.getApplyNums() == null || model.getApplyNums() > stockSubscribe.getOrderNumber()|| model.getApplyNums() < 500) {
                    return ServerResponse.createByErrorMsg("最小起订量是500,最大值"
                            + stockSubscribe.getOrderNumber(),request);
                if (model.getApplyNums() == null || model.getApplyNums() > stockSubscribe.getOrderNumber() || model.getApplyNums() < stockSubscribe.getMinOrderNumber()) {
                    return ServerResponse.createByErrorMsg("申购失败,最小申购数量:"+stockSubscribe.getMinOrderNumber()+",最大申购数量:"+stockSubscribe.getOrderNumber(),request);
                }
                if (stockSubscribe.getType() == 2) {
                    int u = userMapper.updateById(user);
@@ -265,7 +262,7 @@
        if(model!=null){
            //所有人发站内信
            if(model.getUserId() == 0){
                List<User> users = this.userMapper.listByAdmin(null, null, null, null);
                List<User> users = this.userMapper.listByAdmin(null, null, null, null,null);
                for(int k=0;k<users.size();k++){
                    User user = users.get(k);
                    SiteMessage siteMessage = new SiteMessage();