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.dao.StockFuturesMapper;

import com.nq.pojo.StockCoin;

import com.nq.pojo.StockFutures;

import com.nq.pojo.User;
import com.nq.service.IStockCoinService;

import com.nq.service.IStockFuturesService;

import com.nq.service.IStockOptionService;
import com.nq.service.IUserService;
import com.nq.utils.http.HttpClientRequest;

import com.nq.utils.PropertiesUtil;

import com.nq.vo.foreigncurrency.ExchangeVO;

import com.nq.vo.stockfutures.FuturesAdminListVO;

import com.nq.vo.stockfutures.FuturesVO;

import com.nq.vo.stockfutures.StockFuturesListVO;

import java.math.BigDecimal;

import java.util.Date;

import java.util.List;

import org.apache.commons.lang3.StringUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;

import javax.servlet.http.HttpServletRequest;


@Service("iStockFuturesService")

public class StockFuturesServiceImpl implements IStockFuturesService {

    private static final Logger log = LoggerFactory.getLogger(StockFuturesServiceImpl.class);

    @Autowired
    StockFuturesMapper stockFuturesMapper;

    @Autowired
    IStockCoinService iStockCoinService;

    @Autowired
    IUserService iUserService;

    @Autowired
    IStockOptionService iStockOptionService;


    public ServerResponse listByAdmin(String fuName, String fuCode,Integer homeShow,Integer listShow,Integer transState, int pageNum, int pageSize) {

        PageHelper.startPage(pageNum, pageSize);

        List<StockFutures> stockFutures = this.stockFuturesMapper.listByAdmin(fuName, fuCode,homeShow,listShow,transState);


        List<FuturesAdminListVO> futuresAdminListVOS = Lists.newArrayList();

        for (StockFutures stockFuture : stockFutures) {


            FuturesAdminListVO futuresAdminListVO = assembleFuturesAdminListVO(stockFuture);

            futuresAdminListVOS.add(futuresAdminListVO);

        }


        PageInfo pageInfo = new PageInfo(stockFutures);

        pageInfo.setList(futuresAdminListVOS);

        return ServerResponse.createBySuccess(pageInfo);

    }

    private FuturesAdminListVO assembleFuturesAdminListVO(StockFutures stockFutures) {

        FuturesAdminListVO futuresAdminListVO = new FuturesAdminListVO();


        futuresAdminListVO.setId(stockFutures.getId());

        futuresAdminListVO.setFuturesName(stockFutures.getFuturesName());

        futuresAdminListVO.setFuturesCode(stockFutures.getFuturesCode());

        futuresAdminListVO.setFuturesGid(stockFutures.getFuturesGid());

        futuresAdminListVO.setFuturesUnit(stockFutures.getFuturesUnit());

        futuresAdminListVO.setFuturesStandard(stockFutures.getFuturesStandard());

        futuresAdminListVO.setCoinCode(stockFutures.getCoinCode());

        futuresAdminListVO.setHomeShow(stockFutures.getHomeShow());

        futuresAdminListVO.setListShow(stockFutures.getListShow());

        futuresAdminListVO.setDepositAmt(stockFutures.getDepositAmt());

        futuresAdminListVO.setTransFee(stockFutures.getTransFee());

        futuresAdminListVO.setMinNum(stockFutures.getMinNum());

        futuresAdminListVO.setMaxNum(stockFutures.getMaxNum());

        futuresAdminListVO.setTransState(stockFutures.getTransState());

        futuresAdminListVO.setTransAmBegin(stockFutures.getTransAmBegin());

        futuresAdminListVO.setTransAmEnd(stockFutures.getTransAmEnd());

        futuresAdminListVO.setTransPmBegin(stockFutures.getTransPmBegin());

        futuresAdminListVO.setTransPmEnd(stockFutures.getTransPmEnd());

        futuresAdminListVO.setAddTime(stockFutures.getAddTime());

        futuresAdminListVO.setTDesc(stockFutures.gettDesc());

        futuresAdminListVO.setTransPmBegin2(stockFutures.getTransPmBegin2());
        futuresAdminListVO.setTransPmEnd2(stockFutures.getTransPmEnd2());
        futuresAdminListVO.setEachPoint(stockFutures.getEachPoint());


        FuturesVO futuresVO = querySingleMarket(stockFutures.getFuturesGid());

        if (futuresVO != null) {

            futuresAdminListVO.setNow_price(futuresVO.getNowPrice());

            futuresAdminListVO.setLast_close(futuresVO.getLastClose());

        }


        BigDecimal coinRate = new BigDecimal("0");

        ServerResponse serverResponse = getExchangeRate(stockFutures.getCoinCode());

        if (serverResponse.isSuccess()) {

            coinRate = (BigDecimal) serverResponse.getData();

        }

        futuresAdminListVO.setCoinRate(coinRate);


        return futuresAdminListVO;

    }


    public ServerResponse add(StockFutures stockFutures) {

        if (StringUtils.isBlank(stockFutures.getFuturesName()) ||

                StringUtils.isBlank(stockFutures.getFuturesCode())) {

            return ServerResponse.createByErrorMsg("参数不能为空");

        }


        StockFutures fuName = this.stockFuturesMapper.selectFuturesByName(stockFutures.getFuturesName());

        if (fuName != null) {

            return ServerResponse.createByErrorMsg("产品名不能重复");

        }


        StockFutures fuCode = this.stockFuturesMapper.selectFuturesByCode(stockFutures.getFuturesCode());

        if (fuCode != null) {

            return ServerResponse.createByErrorMsg("代码不能重复");

        }


        StockCoin stockCoin = this.iStockCoinService.selectCoinByCode(stockFutures.getCoinCode());

        if (stockCoin == null) {

            return ServerResponse.createByErrorMsg("基币不存在");

        }


        stockFutures.setAddTime(new Date());


        int insertCount = this.stockFuturesMapper.insert(stockFutures);

        if (insertCount > 0) {

            return ServerResponse.createBySuccessMsg("添加成功");

        }

        return ServerResponse.createByErrorMsg("添加失败");

    }


    public ServerResponse update(StockFutures stockFutures) {

        if (stockFutures.getId() == null) {

            return ServerResponse.createByErrorMsg("修改id不能为空");

        }


        StockFutures dbFutures = this.stockFuturesMapper.selectByPrimaryKey(stockFutures.getId());

        if (dbFutures == null) {

            return ServerResponse.createByErrorMsg("产品不存在");

        }


        if (stockFutures.getFuturesName() != null) {

            return ServerResponse.createByErrorMsg("产品名不能修改");

        }


        if (stockFutures.getFuturesCode() != null) {

            return ServerResponse.createByErrorMsg("产品代码不能修改");

        }


        if (stockFutures.getFuturesGid() != null) {

            return ServerResponse.createByErrorMsg("Gid不能修改");

        }


        int updateCount = this.stockFuturesMapper.updateByPrimaryKeySelective(stockFutures);

        if (updateCount > 0) {

            return ServerResponse.createBySuccessMsg("修改成功");

        }

        return ServerResponse.createByErrorMsg("修改失败");

    }


    public ServerResponse queryHome() {

        List<StockFutures> list = this.stockFuturesMapper.queryHome();


        List<StockFuturesListVO> stockFuturesListVOS = Lists.newArrayList();

        for (StockFutures stockFutures : list) {


            StockFuturesListVO stockFuturesListVO = assembleStockFuturesListVO(stockFutures);

            stockFuturesListVOS.add(stockFuturesListVO);

        }

        return ServerResponse.createBySuccess(stockFuturesListVOS);

    }


    public ServerResponse queryList(HttpServletRequest request) {

        List<StockFutures> list = this.stockFuturesMapper.queryList();


        List<StockFuturesListVO> stockFuturesListVOS = Lists.newArrayList();
        User user = iUserService.getCurrentUser(request);
        if (user == null ){
            return ServerResponse.createBySuccessMsg("請先登錄");
        }
        for (StockFutures stockFutures : list) {


            StockFuturesListVO stockFuturesListVO = assembleStockFuturesListVO(stockFutures);
            //是否添加自选
            if(user == null){
                stockFuturesListVO.setIsOption("0");
            } else {
                stockFuturesListVO.setIsOption(iStockOptionService.isMyOption(user.getId(), stockFutures.getFuturesCode()));
            }


            stockFuturesListVOS.add(stockFuturesListVO);

        }

        return ServerResponse.createBySuccess(stockFuturesListVOS);

    }

    private StockFuturesListVO assembleStockFuturesListVO(StockFutures stockFutures) {

        StockFuturesListVO stockFuturesListVO = new StockFuturesListVO();


        stockFuturesListVO.setId(stockFutures.getId());

        stockFuturesListVO.setFuturesName(stockFutures.getFuturesName());

        stockFuturesListVO.setFuturesCode(stockFutures.getFuturesCode());

        stockFuturesListVO.setFuturesGid(stockFutures.getFuturesGid());

        stockFuturesListVO.setFuturesUnit(stockFutures.getFuturesUnit());

        stockFuturesListVO.setFuturesStandard(stockFutures.getFuturesStandard());

        stockFuturesListVO.setCoinCode(stockFutures.getCoinCode());

        stockFuturesListVO.setHomeShow(stockFutures.getHomeShow());

        stockFuturesListVO.setListShow(stockFutures.getListShow());

        stockFuturesListVO.setDepositAmt(stockFutures.getDepositAmt());

        stockFuturesListVO.setTransFee(stockFutures.getTransFee());

        stockFuturesListVO.setMinNum(stockFutures.getMinNum());

        stockFuturesListVO.setMaxNum(stockFutures.getMaxNum());

        stockFuturesListVO.setTransState(stockFutures.getTransState());

        stockFuturesListVO.setTransAmBegin(stockFutures.getTransAmBegin());

        stockFuturesListVO.setTransAmEnd(stockFutures.getTransAmEnd());

        stockFuturesListVO.setTransPmBegin(stockFutures.getTransPmBegin());

        stockFuturesListVO.setTransPmEnd(stockFutures.getTransPmEnd());

        stockFuturesListVO.setAddTime(stockFutures.getAddTime());

        stockFuturesListVO.setTDesc(stockFutures.gettDesc());


        FuturesVO futuresVO = querySingleMarket(stockFutures.getFuturesGid());

        if (futuresVO != null) {

            stockFuturesListVO.setNowPrice(futuresVO.getNowPrice());
            stockFuturesListVO.setLastClose(futuresVO.getLastClose());
        }


        BigDecimal coinRate = new BigDecimal("0");

        ServerResponse serverResponse = getExchangeRate(stockFutures.getCoinCode());

        if (serverResponse.isSuccess()) {

            coinRate = (BigDecimal) serverResponse.getData();

        }

        stockFuturesListVO.setCoinRate(coinRate);


        return stockFuturesListVO;

    }


    public ServerResponse queryTrans(Integer futuresId) {

        StockFutures stockFutures = this.stockFuturesMapper.selectByPrimaryKey(futuresId);

        if (1 == stockFutures.getTransState().intValue()) {

            return ServerResponse.createBySuccessMsg("可交易");

        }

        return ServerResponse.createByErrorMsg("不可交易");

    }


    public FuturesVO querySingleMarket(String futuresGid) {

        String market_url = PropertiesUtil.getProperty("sina.single.futures.url");

        String result = null;

        try {

            market_url = market_url + futuresGid;

            result = HttpClientRequest.doGet(market_url);

        } catch (Exception e) {

            log.error("获取 期货行情 出错 e = {}", e);

        }


        FuturesVO futuresVO = null;

        try {

            if (StringUtils.isNotBlank(result)) {

                result = result.substring(result.indexOf("\"") + 1, result

                        .lastIndexOf("\""));


                futuresVO = new FuturesVO();

                if (result.contains(",")) {

                    String[] sh01_arr = result.split(",");

                    futuresVO.setNowPrice(sh01_arr[0]);

                    futuresVO.setLastClose(sh01_arr[1]);

                    futuresVO.setBuyPrice(sh01_arr[2]);

                    futuresVO.setSellPrice(sh01_arr[3]);

                    futuresVO.setMaxPrice(sh01_arr[4]);

                    futuresVO.setMinPrice(sh01_arr[5]);

                    futuresVO.setHourTime(sh01_arr[6]);

                    futuresVO.setTodayOpen(sh01_arr[7]);

                    futuresVO.setExtra1(sh01_arr[8]);

                    futuresVO.setExtra2(sh01_arr[9]);

                    futuresVO.setExtra3(sh01_arr[10]);

                    futuresVO.setDayTime(sh01_arr[11]);

                    futuresVO.setName(sh01_arr[12]);

                }

            }

        } catch (Exception e) {

            log.error("转换 期货行情 出错 str = {} ,  e = {}", result, e);

        }

        return futuresVO;

    }


    public ServerResponse<ExchangeVO> queryExchangeVO(String coinCode) {

        StockCoin stockCoin = this.iStockCoinService.selectCoinByCode(coinCode);

        if (stockCoin == null) {

            return ServerResponse.createByErrorMsg("不存在该币种");

        }

        if (stockCoin.getCoinGid() == null) {

            return ServerResponse.createByErrorMsg("coin gid 为空");

        }


        String market_url = PropertiesUtil.getProperty("sina.single.exchange.url");

        String result = null;

        try {

            market_url = market_url + stockCoin.getCoinGid();

            result = HttpClientRequest.doGet(market_url);

        } catch (Exception e) {

            log.error("获取 外汇 行情 出错 e = {}", e);

        }


        ExchangeVO exchangeVO = null;

        try {

            if (StringUtils.isNotBlank(result)) {

                result = result.substring(result.indexOf("\"") + 1, result

                        .lastIndexOf("\""));


                exchangeVO = new ExchangeVO();

                if (result.contains(",")) {

                    String[] sh01_arr = result.split(",");

                    exchangeVO.setHourTime(sh01_arr[0]);

                    exchangeVO.setExtra1(sh01_arr[1]);

                    exchangeVO.setExtra2(sh01_arr[2]);

                    exchangeVO.setLastClose(sh01_arr[3]);

                    exchangeVO.setBofu(sh01_arr[4]);

                    exchangeVO.setTodayOpen(sh01_arr[5]);

                    exchangeVO.setMaxPrice(sh01_arr[6]);

                    exchangeVO.setMinPrice(sh01_arr[7]);

                    exchangeVO.setNowPrice(sh01_arr[8]);

                    exchangeVO.setName(sh01_arr[9]);

                }

            }

        } catch (Exception e) {

            log.error("转换 外汇行情 出错 str = {} ,  e = {}", result, e);

        }

        return ServerResponse.createBySuccess(exchangeVO);

    }


    public ServerResponse<BigDecimal> getExchangeRate(String coinCode) {

        StockCoin stockCoin = this.iStockCoinService.selectCoinByCode(coinCode);

        if (stockCoin == null) {

            return ServerResponse.createByErrorMsg("基币设置错误");

        }


        BigDecimal exchangeRate = null;

        ExchangeVO exchangeVO = null;

        if (stockCoin.getDynamicRate().intValue() == 0) {


            ServerResponse serverResponse = queryExchangeVO(coinCode);

            if (serverResponse.isSuccess()) {

                exchangeVO = (ExchangeVO) serverResponse.getData();

                exchangeRate = new BigDecimal(exchangeVO.getNowPrice());

            } else {

                return ServerResponse.createByErrorMsg(serverResponse.getMsg());

            }

        } else {


            exchangeRate = stockCoin.getDefaultRate();

        }


        exchangeRate = exchangeRate.setScale(2, 4);


        return ServerResponse.createBySuccess(exchangeRate);

    }


    public StockFutures selectFuturesById(Integer futuresId) {
        return this.stockFuturesMapper.selectByPrimaryKey(futuresId);
    }


    public StockFutures selectFuturesByCode(String futuresCode) {
        return this.stockFuturesMapper.selectFuturesByCode(futuresCode);
    }

}