package com.nq.service.impl;
|
|
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.StockOptionMapper;
|
|
import com.nq.pojo.Stock;
|
|
import com.nq.pojo.StockOption;
|
|
import com.nq.pojo.User;
|
|
import com.nq.service.IStockOptionService;
|
|
import com.nq.service.IUserService;
|
|
import com.nq.utils.redis.RedisShardedPoolUtils;
|
import com.nq.utils.stock.sina.SinaStockApi;
|
|
import com.nq.vo.stock.StockOptionListVO;
|
|
import com.nq.vo.stock.StockVO;
|
|
import java.util.List;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
|
@Service("iStockOptionService")
|
|
public class StockOptionServiceImpl implements IStockOptionService {
|
|
private static final Logger log = LoggerFactory.getLogger(StockOptionServiceImpl.class);
|
|
@Autowired
|
StockOptionMapper stockOptionMapper;
|
|
@Autowired
|
IUserService iUserService;
|
|
@Autowired
|
StockMapper stockMapper;
|
|
public ServerResponse<PageInfo> findMyStockOptions(String keyWords, HttpServletRequest request, int pageNum, int pageSize) {
|
|
PageHelper.startPage(pageNum, pageSize);
|
User user = this.iUserService.getCurrentUser(request);
|
|
if (user == null ){
|
return ServerResponse.createBySuccessMsg("please log in first",request.getHeader(MessageLocaleResolver.LANG));
|
}
|
List<StockOption> stockOptions = this.stockOptionMapper.findMyOptionByKeywords(user.getId(), keyWords);
|
|
List<StockOptionListVO> stockOptionListVOS = Lists.newArrayList();
|
for (StockOption option : stockOptions) {
|
StockOptionListVO stockOptionListVO = assembleStockOptionListVO(option);
|
stockOptionListVO.setIsOption("1");
|
stockOptionListVOS.add(stockOptionListVO);
|
}
|
PageInfo pageInfo = new PageInfo(stockOptions);
|
|
pageInfo.setList(stockOptionListVOS);
|
|
return ServerResponse.createBySuccess(pageInfo);
|
|
}
|
|
public ServerResponse isOption(Integer uid, String code,HttpServletRequest request) {
|
|
StockOption stockOption = this.stockOptionMapper.isOption(uid, code);
|
|
if (stockOption == null) {
|
|
return ServerResponse.createBySuccessMsg("Not added",request.getHeader(MessageLocaleResolver.LANG));
|
|
}
|
|
return ServerResponse.createByErrorMsg("added",request.getHeader(MessageLocaleResolver.LANG));
|
|
}
|
|
public String isMyOption(Integer uid, String code,HttpServletRequest request) {
|
StockOption stockOption = this.stockOptionMapper.isOption(uid, code);
|
if (stockOption == null) {
|
return "0";
|
}
|
return "1";
|
|
}
|
|
private StockOptionListVO assembleStockOptionListVO(StockOption option) {
|
|
StockOptionListVO stockOptionListVO = new StockOptionListVO();
|
|
|
|
stockOptionListVO.setId(option.getId().intValue());
|
|
stockOptionListVO.setStockName(option.getStockName());
|
|
stockOptionListVO.setStockCode(option.getStockCode());
|
|
stockOptionListVO.setStockGid(option.getStockGid());
|
|
StockVO stockVO = null;
|
if(option.getStockGid().contains("hf")){
|
// stockVO = SinaStockApi.assembleStockFuturesVO(SinaStockApi.getSinaStock(option.getStockGid()));
|
}else if(option.getStockGid().contains("hk")){
|
//如果gid末尾是zs，说明是指数，不是股票
|
// if(option.getStockGid().endsWith("zs")) {
|
// //gid去掉末尾的zs
|
// stockVO = SinaStockApi.otherStockVO(RedisShardedPoolUtils.get(option.getStockGid().substring(0, option.getStockGid().length() - 2), 3));
|
// }else {
|
stockVO = SinaStockApi.otherStockVO(RedisShardedPoolUtils.get(option.getStockGid(), 1));
|
// }
|
}else if (option.getStockGid().contains("us")){
|
// if(option.getStockGid().endsWith("zs")) {
|
// //gid去掉末尾的zs
|
// stockVO = SinaStockApi.otherStockVO(RedisShardedPoolUtils.get(option.getStockGid().substring(0, option.getStockGid().length() - 2), 3));
|
// }else {
|
stockVO = SinaStockApi.otherStockVO(RedisShardedPoolUtils.get(option.getStockGid(), 2));
|
// }
|
} else {
|
// if (option.getStockGid().endsWith("zs")) {
|
// //gid去掉末尾的zs
|
// stockVO = SinaStockApi.otherStockVO(RedisShardedPoolUtils.get(option.getStockGid().substring(0, option.getStockGid().length() - 2), 3));
|
// } else {
|
// stockVO = SinaStockApi.assembleStockVO(SinaStockApi.getSinaStock(option.getStockGid()));
|
}
|
|
stockOptionListVO.setNowPrice(stockVO.getNowPrice());
|
|
stockOptionListVO.setHcrate(stockVO.getHcrate().toString());
|
|
stockOptionListVO.setPreclose_px(stockVO.getPreclose_px());
|
|
stockOptionListVO.setOpen_px(stockVO.getOpen_px());
|
|
stockOptionListVO.setType(stockVO.getType());
|
|
Stock stock = this.stockMapper.selectByPrimaryKey(option.getStockId());
|
|
stockOptionListVO.setStock_plate(stock.getStockPlate()==null?"":stock.getStockPlate());
|
|
stockOptionListVO.setStock_type(stock.getStockType());
|
|
|
return stockOptionListVO;
|
|
}
|
}
|
