package org.example.ssmico.demos.web.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.example.ssmico.demos.web.entity.*;
import org.example.ssmico.demos.web.mapper.IcoNewCurrencyMapper;
import org.example.ssmico.demos.web.mapper.IcoOrderMapper;
import org.example.ssmico.demos.web.mapper.WalletExtendMapper;
import org.example.ssmico.demos.web.service.IcoOrderService;
import org.example.ssmico.demos.web.service.TMoneyLogService;
import org.example.ssmico.demos.web.service.TWalletService;
import org.example.ssmico.demos.web.util.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import project.wallet.Wallet;
import project.wallet.WalletExtend;

import java.util.Date;
import java.util.UUID;

/**
 * @program: ssh
 * @description:
 * @create: 2024-04-11 13:02
 **/
@Service
public class IcoOrderServiceImpl  extends ServiceImpl<IcoOrderMapper, IcoOrder> implements IcoOrderService {

    @Autowired
    private IcoNewCurrencyMapper mapper;

    @Autowired
    private TWalletService tWalletService;

    @Autowired
    private TMoneyLogService tMoneyLogService;

    @Autowired
    private WalletExtendMapper walletExtendMapper;

    @Override
    @Transactional
    public ResultObject subscribe(Integer id, String lang) throws Exception {
        ResultObject resultObject = new ResultObject();
        GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
        IcoOrder icoOrder = getById(id);
        if(null == icoOrder){
            resultObject.setCode("1");
            resultObject.setMsg(googleTranslateUtil.translate("当前订单不存在",lang));
            return resultObject;
        }

        Wallet tWallet = tWalletService.getOne(new LambdaQueryWrapper<Wallet>().eq(Wallet::getPartyId, icoOrder.getUserId()).last(" limit 1"));
        if(null == tWallet){
            resultObject.setCode("1");
            resultObject.setMsg(googleTranslateUtil.translate("用户资金不存在",lang));
            return resultObject;
        }

        IcoNewCurrency icoNewCurrency = mapper.selectById(icoOrder.getIcoNewCurrencyId());

        //中签总价
        Double totalPlacingPrice = icoNewCurrency.getIssuePrice()*icoOrder.getLotteryQuantity();
        if(tWallet.getMoney() < totalPlacingPrice){
            resultObject.setCode("1");
            resultObject.setMsg(googleTranslateUtil.translate("余额不足",lang));
            return resultObject;
        }

        double money = tWallet.getMoney();

        tWallet.setMoney(tWallet.getMoney()-totalPlacingPrice);
        tWalletService.updateById(tWallet);
        String jsonString = JSON.toJSONString(tWallet, SerializerFeature.WriteClassName);
        RedisShardedPoolUtils.set( WalletRedisKeys.WALLET_PARTY_ID + tWallet.getPartyId().toString(),jsonString);
        TMoneyLog tMoneyLog = new TMoneyLog();
        String msg = "ICO认缴，订单id"+icoOrder.getId();
        tMoneyLog.setUuid(UUID.randomUUID().toString().replace("-", ""));
        tMoneyLog.setLog(msg);
        tMoneyLog.setWallettype("USDT");
        tMoneyLog.setPartyId(icoOrder.getUserId());
        tMoneyLog.setAmount(totalPlacingPrice);
        tMoneyLog.setAmountBefore(money);
        tMoneyLog.setAmountAfter(tWallet.getMoney());
        tMoneyLog.setContentType("ICO");
        tMoneyLog.setCategory("认缴");
        tMoneyLog.setCreateTime(new Date());
        tMoneyLogService.save(tMoneyLog);

        WalletExtend walletExtend = walletExtendMapper.selectOne(new LambdaQueryWrapper<WalletExtend>()
                .eq(WalletExtend::getPartyId, icoOrder.getUserId())
                .eq(WalletExtend::getWallettype, icoOrder.getTokenCode()));
        if(null != walletExtend){
            double mount = walletExtend.getFrozenAmount() + icoOrder.getLotteryQuantity();
            System.out.println("认缴叠加-----"+mount);
            walletExtend.setFrozenAmount(mount);
        }else{
            walletExtend = new WalletExtend();
            walletExtend.setUuid(ApplicationUtil.getCurrentTimeUUID());
            walletExtend.setPartyId(icoOrder.getUserId());
            walletExtend.setWallettype(icoOrder.getTokenCode());
            walletExtend.setFrozenAmount(icoOrder.getLotteryQuantity());
            walletExtendMapper.insert(walletExtend);
            String json = JSON.toJSONString(walletExtend, SerializerFeature.WriteClassName);
            RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_EXTEND_PARTY_ID + walletExtend.getPartyId() + walletExtend.getWallettype(), json);
        }
        String json = JSON.toJSONString(walletExtend, SerializerFeature.WriteClassName);
        walletExtendMapper.update(walletExtend,new LambdaUpdateWrapper<WalletExtend>().eq(WalletExtend::getUuid,walletExtend.getUuid()));
        RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_EXTEND_PARTY_ID + walletExtend.getPartyId() + walletExtend.getWallettype(),json);

        icoOrder.setStatus(3);
        icoOrder.setIsCompleted(1);
        updateById(icoOrder);
        return resultObject;
    }

    @Override
    @Transactional
    public ResultObject add(IcoOrder icoOrder,String lang) throws Exception {
        GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
        ResultObject resultObject = new ResultObject();

        //判断是否在申购时间
        IcoNewCurrency icoNewCurrency = mapper.selectById( icoOrder.getIcoNewCurrencyId());
//        if(System.currentTimeMillis() < icoNewCurrency.getApplicationStartTime().getTime()){
//            resultObject.setCode("1");
//            resultObject.setMsg(googleTranslateUtil.translate("未到申购时间",lang));
//            return resultObject;
//        }else if(System.currentTimeMillis() > icoNewCurrency.getApplicationEndTime().getTime()){
//            resultObject.setCode("1");
//            resultObject.setMsg(googleTranslateUtil.translate("已过申购时间",lang));
//            return resultObject;
//        }
        icoOrder.setNewCoinName(icoNewCurrency.getNewCoinName());
        if(icoOrder.getOrderType() == 2){
            Wallet tWallet = tWalletService.getOne(new LambdaQueryWrapper<Wallet>().eq(Wallet::getPartyId, icoOrder.getUserId()).last(" limit 1 "));
            if(null == tWallet){
                resultObject.setCode("1");
                resultObject.setMsg(googleTranslateUtil.translate("资金账户不存在",lang));
                return resultObject;
            }
            //中签总价
            Double totalPlacingPrice = icoNewCurrency.getIssuePrice()*icoOrder.getLotteryQuantity();
            if(tWallet.getMoney() < totalPlacingPrice){
                resultObject.setCode("1");
                resultObject.setMsg(googleTranslateUtil.translate("余额不足",lang));
                return resultObject;
            }
            double amountafter = tWallet.getMoney();

            tWallet.setMoney(tWallet.getMoney()-totalPlacingPrice);
            tWalletService.update(tWallet,new LambdaUpdateWrapper<Wallet>().eq(Wallet::getUuid,tWallet.getUuid()));
            String jsonString = JSON.toJSONString(tWallet, SerializerFeature.WriteClassName);
            RedisShardedPoolUtils.set(WalletRedisKeys.WALLET_PARTY_ID + tWallet.getPartyId().toString(), jsonString);

            icoOrder.setStatus(1);
            icoOrder.setIsCompleted(1);
            save(icoOrder);
            TMoneyLog tMoneyLog = new TMoneyLog();
            String msg = "ICO配售，订单id"+icoOrder.getId();
            tMoneyLog.setUuid(UUID.randomUUID().toString().replace("-", ""));
            tMoneyLog.setLog(msg);
            tMoneyLog.setWallettype("USDT");
            tMoneyLog.setPartyId(icoOrder.getUserId());
            tMoneyLog.setAmount(totalPlacingPrice);
            tMoneyLog.setAmountBefore(amountafter);
            tMoneyLog.setAmountAfter(tWallet.getMoney());
            tMoneyLog.setContentType("ICO");
            tMoneyLog.setCategory("配售");
            tMoneyLog.setCreateTime(new Date());
            tMoneyLogService.save(tMoneyLog);
            return resultObject;
        }else{
            icoOrder.setStatus(1);
            icoOrder.setIsCompleted(0);
        }

        long count = count(new LambdaQueryWrapper<IcoOrder>()
                .eq(IcoOrder::getIcoNewCurrencyId, icoOrder.getIcoNewCurrencyId())
                .eq(IcoOrder::getUserId,icoOrder.getUserId()));
        if (count > 0) {
            resultObject.setCode("1");
            resultObject.setMsg(googleTranslateUtil.translate("申购单已存在，请勿重复申购",lang));
            return resultObject;
        }
        save(icoOrder);
        return resultObject;
    }


}