package com.xcong.excoin.modules.member.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.xcong.excoin.common.entity.FebsResponse;
import com.xcong.excoin.common.entity.QueryRequest;
import com.xcong.excoin.modules.member.entity.MemberAccountMoneyChangeEntity;
import com.xcong.excoin.modules.member.entity.MemberEntity;
import com.xcong.excoin.modules.member.entity.MemberQuickBuySaleEntity;
import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;
import com.xcong.excoin.modules.member.mapper.MemberAccountMoneyChangeMapper;
import com.xcong.excoin.modules.member.mapper.MemberMapper;
import com.xcong.excoin.modules.member.mapper.MemberQuickBuySaleMapper;
import com.xcong.excoin.modules.member.mapper.MemberWalletCoinMapper;
import com.xcong.excoin.modules.member.service.IMemberService;
import com.xcong.excoin.modules.member.vo.MemberQuickBuySaleVo;

import lombok.RequiredArgsConstructor;
import java.math.BigDecimal;
import javax.validation.constraints.NotNull;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

/**
 * @author wzy
 * @date 2020-06-10
 **/
@Service
@RequiredArgsConstructor
public class MemberServiceImpl extends ServiceImpl<MemberMapper, MemberEntity> implements IMemberService {
	
	private final MemberQuickBuySaleMapper memberQuickBuySaleMapper;
	
	private final MemberWalletCoinMapper memberWalletCoinMapper;
	
	private final MemberAccountMoneyChangeMapper memberAccountMoneyChangeMapper;
	

    @Override
    public IPage<MemberEntity> findMemberListInPage(MemberEntity memberEntity, QueryRequest request) {
        Page<MemberEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
        return this.baseMapper.selectMemberListInPage(page, memberEntity);
    }

	@Override
	public IPage<MemberQuickBuySaleVo> findmemberQuickBuySaleListInPage(
			MemberQuickBuySaleEntity memberQuickBuySaleEntity, QueryRequest request) {
		Page<MemberQuickBuySaleEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
		IPage<MemberQuickBuySaleVo> findmemberQuickBuySaleListInPage = memberQuickBuySaleMapper.findmemberQuickBuySaleListInPage(page, memberQuickBuySaleEntity);
        return findmemberQuickBuySaleListInPage;
    }

	@Override
	@Transactional(rollbackFor = Exception.class)
	public FebsResponse memberChargeUsdtConfirm(Long id) {
		
		MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
		
		if(!MemberQuickBuySaleEntity.CHARGE_STATUS_PAID.equals(memberQuickBuySaleEntity.getOrderStatus())) {
			return new FebsResponse().message("只允许已付款状态操作");
		}
		
		Long memberId = memberQuickBuySaleEntity.getMemberId();
		BigDecimal amountUsdt = memberQuickBuySaleEntity.getAmountUsdt();
		String walletCode = "USDT";
		
		MemberEntity selectById = this.baseMapper.selectById(memberId);
		if(ObjectUtils.isEmpty(selectById)) {
			return new FebsResponse().message("用户已不存在");
		}
		//获取币币钱包
		MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinMapper.findWalletCoinByMemberIdAndWalletCode(memberId,walletCode);
		BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance();
		BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance();
		memberWalletCoinEntity.setAvailableBalance(availableBalance.add(amountUsdt));
		memberWalletCoinEntity.setTotalBalance(totalBalance.add(amountUsdt));
		// 更新
		memberWalletCoinMapper.updateById(memberWalletCoinEntity);
		// 更新状态
		memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_CHECKED);
		memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity);
		
		 //添加币币资金划转历史记录
		MemberAccountMoneyChangeEntity memberAccountMoneyChangeEntity = new MemberAccountMoneyChangeEntity();
        memberAccountMoneyChangeEntity.setContent("OTC转入");
        memberAccountMoneyChangeEntity.setMemberId(memberId);
        memberAccountMoneyChangeEntity.setAmount(amountUsdt);
        memberAccountMoneyChangeEntity.setStatus(MemberAccountMoneyChangeEntity.STATUS_SUCCESS_INTEGER);
        memberAccountMoneyChangeEntity.setSymbol("USDT");
        memberAccountMoneyChangeEntity.setType(MemberAccountMoneyChangeEntity.TYPE_WALLET_COIN);
        memberAccountMoneyChangeMapper.insert(memberAccountMoneyChangeEntity);
        /**
         * todo
		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");
		String chargeTime = format.format(memberQuickBuySaleEntity.getChargeTime()); // 将当前时间袼式化为指定的格式
		String usdt = memberQuickBuySaleEntity.getAmountUsdt()+"USDT";
		//发送短信提醒
		String smsContent = "【Excoin】尊敬的用户您好！您于"+chargeTime+"充值"+usdt+"已成功到账，请您及时查收！订单号为："+memberChargeUsdt.getOrderCode()+"。";
		SmsUtils.hxSmsSend(member.getPhone(), smsContent);
		
         */
		return new FebsResponse().message("拨币成功");
	}

	@Override
	@Transactional(rollbackFor = Exception.class)
	public FebsResponse memberChargeUsdtCancel(@NotNull(message = "{required}") Long id) {
		
		MemberQuickBuySaleEntity memberQuickBuySaleEntity = memberQuickBuySaleMapper.selectById(id);
		
		if(MemberQuickBuySaleEntity.CHARGE_STATUS_CHECKED.equals(memberQuickBuySaleEntity.getOrderStatus()) 
				|| MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_USER.equals(memberQuickBuySaleEntity.getOrderStatus())
				|| MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_SYSTEM.equals(memberQuickBuySaleEntity.getOrderStatus())) {
			return new FebsResponse().message("不允许系统撤单操作");
		}
		
		memberQuickBuySaleEntity.setOrderStatus(MemberQuickBuySaleEntity.CHARGE_STATUS_CANCEL_SYSTEM);
		memberQuickBuySaleMapper.updateById(memberQuickBuySaleEntity);
		return new FebsResponse().success();
		
	}
}