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;

     }
 }