package com.gear.customer.swx.rabbitmq;

import com.gear.common.core.redis.RedisCache;
import com.gear.customer.swx.config.DelayQueueRabbitConfig;
import com.gear.customer.swx.vo.response.SwxUserInfoVo;
import com.gear.swx.domain.SwxMarket;
import com.gear.swx.domain.SwxOptionsOrder;
import com.gear.swx.domain.SwxUser;
import com.gear.swx.service.ISwxMarketService;
import com.gear.swx.service.ISwxOptionsOrderService;
import com.gear.swx.service.ISwxUserService;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

@Component
@RabbitListener(queues = DelayQueueRabbitConfig.DLX_QUEUE)
public class DirectReceiver {
    @Autowired
    RabbitTemplate rabbitTemplate;

    @Autowired
    private ISwxOptionsOrderService swxOptionsOrderService;

    @Autowired
    private RedisCache redisCache;

    @Autowired
    private ISwxMarketService swxMarketService;

    @Autowired
    private ISwxUserService swxUserService;
    @RabbitHandler
    public void process(Map<String,Object> messageMap) {
        System.out.println("消息体内容为："+messageMap);
        System.out.println("接收消息时间："+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        String id = (String)messageMap.get("id");
        Integer type = (Integer) messageMap.get("istrue");
        String userId = (String)messageMap.get("userId");
        if (type == 1){
            try{
                SwxOptionsOrder swxOptionsOrder = swxOptionsOrderService.getById(id);
                SwxMarket swxMarket = swxMarketService.getById(swxOptionsOrder.getMarketId());
                System.out.println("当前对象："+swxOptionsOrder);
                swxOptionsOrder.setStatus(1);
                swxOptionsOrder.setEndPriceTrue(new BigDecimal(redisCache.getCacheObject(swxMarket.getCode()+"CurrPrice")+""));
                if (swxOptionsOrder.getResultType() == 2){
                    swxOptionsOrder.setIncome(BigDecimal.ZERO.subtract(swxOptionsOrder.getAmount()));
                }
                swxOptionsOrderService.update(swxOptionsOrder);

                SwxUser swxUser = swxUserService.getById(swxOptionsOrder.getUserId());
                if (swxUser != null){
                    BigDecimal amount = null;
                    //判断如果赢了的话，修改用户余额
                    if(swxOptionsOrder.getResultType() == 1){
                        BigDecimal money = swxOptionsOrder.getAmount().add(swxOptionsOrder.getIncome());
                        amount = swxUser.getAmount().add(money);
                    }
                    BigDecimal profit = swxUser.getProfit().add(swxOptionsOrder.getIncome());
                    swxUserService.updateMoney(swxUser.getId(),amount,profit);
                }
                System.out.println("后续处理成功！");
            }catch (Exception e){
                System.out.println("消息监听处理失败。。。");
                System.out.println(e.getMessage());
            }
        }else{
            try {
                SwxOptionsOrder swxOptionsOrder = swxOptionsOrderService.getById(id);
                SwxMarket swxMarket = swxMarketService.getById(swxOptionsOrder.getMarketId());
                System.out.println("当前对象："+swxOptionsOrder);
                swxOptionsOrder.setStatus(1);
                swxOptionsOrder.setEndPriceTrue(redisCache.getCacheObject(swxMarket.getCode()+"CurrPrice")== null ? BigDecimal.ZERO : new BigDecimal(redisCache.getCacheObject(swxMarket.getCode()+"CurrPrice")+""));
                if (swxOptionsOrder.getResultType() == 2){
                    swxOptionsOrder.setIncome(BigDecimal.ZERO.subtract(swxOptionsOrder.getAmount()));
                }
                swxOptionsOrderService.update(swxOptionsOrder);
                //判断如果赢了的话，修改用户余额
                if(swxOptionsOrder.getResultType() == 1){
                    BigDecimal money = swxOptionsOrder.getAmount().add(swxOptionsOrder.getIncome());
                    SwxUserInfoVo infoVo = redisCache.getCacheObject("SWX-CUSTOMER-VERTURAL-"+userId);
                    if (infoVo != null){
                        Long userExprie = redisCache.getExpire("SWX-CUSTOMER-VERTURAL-"+userId);
                        infoVo.setVirtuallyAmount(infoVo.getVirtuallyAmount().add(money));
                        redisCache.setCacheObject("SWX-CUSTOMER-VERTURAL-"+userId,infoVo,userExprie,TimeUnit.SECONDS);
                    }
                }
                System.out.println("后续处理成功！");
            }catch (Exception e){
                System.out.println("消息监听处理失败。。。");
                System.out.println( e.toString());
            }
        }



    }

}