package com.nq.service.impl;
|
|
import com.github.pagehelper.PageHelper;
|
|
import com.github.pagehelper.PageInfo;
|
|
import com.google.common.collect.Lists;
|
|
import com.google.gson.Gson;
|
import com.nq.common.ServerResponse;
|
|
import com.nq.dao.StockMapper;
|
|
import com.nq.dao.StockOptionMapper;
|
|
import com.nq.pojo.*;
|
|
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.StockListVO;
|
import com.nq.vo.stock.StockOptionListVO;
|
|
import com.nq.vo.stock.StockVO;
|
|
import java.math.BigDecimal;
|
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("請先登錄");
|
}
|
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) {
|
|
StockOption stockOption = this.stockOptionMapper.isOption(uid, code);
|
|
if (stockOption == null) {
|
|
return ServerResponse.createBySuccessMsg("未添加");
|
|
}
|
|
return ServerResponse.createByErrorMsg("已添加");
|
|
}
|
|
public String isMyOption(Integer uid, String code) {
|
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());
|
|
StockListVO stockVO = null;
|
Stock stock = stockMapper.findStockByCode(option.getStockCode());
|
stockVO = getStockRealTime(stock);
|
|
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 stock1 = this.stockMapper.selectByPrimaryKey(option.getStockId());
|
|
stockOptionListVO.setStock_plate(stock1.getStockPlate()==null?"":stock.getStockPlate());
|
|
stockOptionListVO.setStock_type(stock1.getStockType());
|
|
|
return stockOptionListVO;
|
|
}
|
|
public static StockListVO getStockRealTime(Stock stock) {
|
|
if (stock == null) {
|
return null;
|
}
|
StockListVO stockListVO = new StockListVO();
|
try {
|
StockRealTimeBean realTimeStock = new Gson().fromJson(RedisShardedPoolUtils.get("instockDetail:"+ stock.getStockCode()), StockRealTimeBean.class);
|
stockListVO.setHcrate(new BigDecimal(realTimeStock.getPcp().replace("%", "")));
|
stockListVO.setNowPrice(realTimeStock.getLast());
|
stockListVO.setToday_max(realTimeStock.getHigh());
|
stockListVO.setToday_min(realTimeStock.getLow());
|
stockListVO.setOpen_px(realTimeStock.getBid());
|
stockListVO.setPreclose_px(realTimeStock.getPc());
|
stockListVO.setBusiness_amount(realTimeStock.getAsk());
|
stockListVO.setBusiness_balance("");
|
stockListVO.setName(stock.getStockName());
|
stockListVO.setCode(stock.getStockCode());
|
stockListVO.setSpell(stock.getStockSpell());
|
stockListVO.setGid(stock.getStockGid().toUpperCase());
|
stockListVO.setStock_plate(stock.getStockPlate());
|
stockListVO.setStock_type(stock.getStockType());
|
} catch (Exception e) {
|
e.printStackTrace();
|
|
return null;
|
}
|
|
|
return stockListVO;
|
}
|
|
}
|
