package com.gear.customer.swx.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.gear.common.constant.SwxConstons;
import com.gear.common.core.redis.RedisCache;
import com.gear.common.vo.Result;
import com.gear.customer.swx.biz.SwxBizIndex;
import com.gear.customer.swx.config.DelayQueueRabbitConfig;
import com.gear.customer.swx.vo.response.SwxContentsVo;
import com.gear.customer.swx.vo.response.SwxIndexMarketInfoVo;
import com.gear.customer.swx.vo.response.SwxIndexQueryMarketVo;
import com.gear.swx.domain.*;
import com.gear.swx.service.ISwxLoanRecordService;
import com.gear.swx.service.ISwxMoneyLogService;
import com.gear.swx.service.ISwxSmartOrderService;
import com.gear.swx.service.ISwxUserService;
import com.gear.swx.vo.SyncKValueFromLdVo;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.parameters.P;
import org.springframework.util.CollectionUtils;
import org.springframework.web.bind.annotation.*;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;

@RestController
@RequestMapping("/swx/customer/index")
public class SwxIndexController {

    @Autowired
    private SwxBizIndex swxBizIndex;

    @Autowired
    RabbitTemplate rabbitTemplate;

    @Autowired
    RedisCache redisCache;

    @Autowired
    private ISwxLoanRecordService swxLoanRecordService;

    @Autowired
    private ISwxUserService swxUserService;

    @Autowired
    private ISwxSmartOrderService swxSmartOrderService;

    @Autowired
    private ISwxMoneyLogService swxMoneyLogService;
    /**
     * 根据类型查询产品
     * @param type
     * @return
     */
    @GetMapping("/listMarketByType")
    public Result<List<SwxIndexQueryMarketVo>> listMarketByType(@RequestParam(value = "type",required = false)Integer type, @RequestParam(value = "canSmart",required = false)Integer canSamrt){
        return Result.OK(swxBizIndex.listMarketByType(type,canSamrt));
    }



    @GetMapping("/getMessage")
    public String getMessage(@RequestParam(value = "id",required = false)String  id){
        rabbitTemplate.convertAndSend(DelayQueueRabbitConfig.ORDER_EXCHANGE, DelayQueueRabbitConfig.ORDER_ROUTING_KEY, id, message->{
            message.getMessageProperties().setExpiration("3000"+"");
            return message;
        });
        return "ok";
    }


    @GetMapping("/getMarketInfo/{id}")
    public Result<SwxIndexMarketInfoVo> getMarketInfo(@PathVariable String id){
        return Result.OK(swxBizIndex.getMarketInfo(id));
    }


    @GetMapping("/getContractsByMarket/{mId}")
    public Result<SwxMarketContracts> getContractsByMarket(@PathVariable String mId){
        return Result.OK(swxBizIndex.getContractsByMarket(mId));
    }

    @GetMapping("/getOptionsByMarket/{mId}")
    public Result<SwxMarketOptions> getOptionsByMarket(@PathVariable String mId){
        return Result.OK(swxBizIndex.getOptionsByMarket(mId));
    }

    @GetMapping("/getSmartByMarket/{mId}")
    public Result<SwxMarketSmart> getSmartByMarket(@PathVariable String mId){
       return Result.OK(swxBizIndex.getSmartByMarket(mId));
    }
    @GetMapping("/getKValueByCodeAndDate")
    public Result<List<SyncKValueFromLdVo>> getKValueByCodeAndDate(@RequestParam("code")String code, @RequestParam("dateType")String dateType){
        return Result.OK(swxBizIndex.getKValueByCodeAndDate(code,dateType));
    }

    @GetMapping("/getParamByKey/{key}")
    public Result<SwxSettings> getParamByKey(@PathVariable String key){
        return Result.OK(swxBizIndex.getParamByKey(key));
    }

    @GetMapping("/listContents/{language}")
    public Result<List<SwxContentsVo>> listContents(@PathVariable Integer language){
        return Result.OK(swxBizIndex.listContents(language));
    }

    @GetMapping("/getContentsById/{id}")
    public Result<SwxContents> getContentsById(@PathVariable String id){
        return Result.OK(swxBizIndex.getContentsById(id));
    }

    @GetMapping("/listNft")
    public Result<List<SwxNft>> listNft(){
        return Result.OK(swxBizIndex.listNft());
    }



}