package com.panzhihua.service_dangjian.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.panzhihua.common.model.dtos.partybuilding.NewFightIntegral;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.community.building.NewFightShoppingOrderVO;
import com.panzhihua.common.model.vos.user.SysUserNoticeVO;
import com.panzhihua.common.service.user.UserService;
import com.panzhihua.common.utlis.Snowflake;
import com.panzhihua.service_dangjian.dao.NewFightShoppingOrderDao;
import com.panzhihua.service_dangjian.entity.ComActIntegralUser;
import com.panzhihua.service_dangjian.entity.NewFightShopping;
import com.panzhihua.service_dangjian.entity.NewFightShoppingOrder;
import com.panzhihua.service_dangjian.service.*;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Date;


@Slf4j
@Service
public class NewFightShoppingOrderServiceImpl extends ServiceImpl<NewFightShoppingOrderDao,
        NewFightShoppingOrder> implements NewFightShoppingOrderService
{

    @Resource
    private NewFightShoppingService shoppingService;

    @Resource
    private ComActIntegralUsersService integralUsersService;

    @Resource
    private UserService userService;

    @Override
    public R getList(int pageNum,int pageSize,String userId,String goodsId,String orderNumber,
                     String goodName,String name,String cancelType,String communityId,String merchantId,String orderType)
    {
        Page page = new Page<NewFightShopping>(pageNum,pageSize);
        return R.ok(baseMapper.getList(page,userId,goodsId,orderNumber,goodName,name,cancelType,
                communityId, merchantId,orderType));
    }

    @Override
    public NewFightShoppingOrder getDetails(String id,String communityId) {
        return baseMapper.getDetails(id,communityId);
    }


    @Override
    public R addData(NewFightShoppingOrderVO item)
    {
        item.setOrderNumber(Snowflake.getId()+"");


        // 查询用户积分账户
        ComActIntegralUser integralUserDO =
                integralUsersService.getOne(new QueryWrapper<ComActIntegralUser>().lambda()
                        .eq(ComActIntegralUser::getUserId, item.getUserId())
                        .eq(ComActIntegralUser::getCommunityId, item.getCommunityId()));

        int allMoney=0;
        int getMoney=0;

        if(integralUserDO==null)
        {
            return R.fail("积分不足！");
        }
        allMoney=integralUserDO.getIntegralAvailableSum();


        //判断是线上下单  还是商家线下下单  1线上   2线下
        if(StringUtils.equals("2",item.getOrderType()))
        {
            getMoney=Integer.valueOf(item.getPalyMoney());
        }
        else
        {
            NewFightShopping goods=shoppingService.getDetails(item.getGoodsId());
            getMoney=Integer.valueOf(goods.getGoodPrice());
        }


        if(getMoney>allMoney)
        {
            return R.fail("积分不足！");
        }

        item.setCancelType("0");
        item.setPalyMoney(getMoney+"");
        int num= baseMapper.addData(item);
        if(num>0)
        {
            //修改个人积分总额
            allMoney=allMoney-getMoney;
            NewFightIntegral integral=new NewFightIntegral();
            integral.setIntegralNum(allMoney+"");
            integral.setAddOrReduce(2);
            integral.setCommunityId(item.getCommunityId());
            integral.setUserId(item.getUserId());
            if(StringUtils.equals("1",item.getOrderType()))
            {

                integral.setType("9");
                integral.setIdentityType("1");
                integral.setRemark("积分兑换商品");
            }
            else
            {

                integral.setType("10");
                integral.setIdentityType("1");
                integral.setRemark("商家兑换商品");
                integral.setMerchantId(item.getMerchantId());
                integral.setIntegralNum(item.getPalyMoney());



                SysUserNoticeVO sysUserNoticeVO = new SysUserNoticeVO();
                sysUserNoticeVO.setUserId(Long.valueOf(item.getUserId()));
                sysUserNoticeVO.setType(4);
                sysUserNoticeVO.setTitle("商家兑换成功");
                sysUserNoticeVO.setBusinessType(14);
                sysUserNoticeVO.setBusinessTitle(item.getRemark());
                sysUserNoticeVO
                        .setBusinessContent(String.format("兑换商品%s", item.getRemark()));
                sysUserNoticeVO.setStatus(0);
                sysUserNoticeVO.setBusinessStatus(1);
                sysUserNoticeVO.setBusinessId(Long.valueOf(item.getId()));
                sysUserNoticeVO.setActivityType(4);
                R r2 = userService.addNotice(sysUserNoticeVO);
                if (R.isOk(r2)) {
                    log.info("新增兑换商品通知成功【{}】", JSONObject.toJSONString(sysUserNoticeVO));
                }
            }
            integralUsersService.upIntegral(integral);

            return R.ok();
        }
        return R.fail("添加失败");
    }

    @Override
    public R editData(NewFightShoppingOrderVO item) {
        int num= baseMapper.editData(item);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("失败");
    }

    @Override
    public R cancelOrder(String orderId,String communityId)
    {
        NewFightShoppingOrder order=baseMapper.getDetails(orderId,communityId);

        if(!StringUtils.equals("0",order.getCancelType()))
        {
            return R.fail("订单不是待核销状态");
        }

        NewFightShoppingOrderVO orderVO=new NewFightShoppingOrderVO();
        orderVO.setId(orderId);
        orderVO.setCancelType("2");
        orderVO.setAbolishTime(new Date());
        int num=baseMapper.editData(orderVO);
        if(num>0)
        {
            // 查询用户积分账户
            ComActIntegralUser integralUserDO =
                    integralUsersService.getOne(new QueryWrapper<ComActIntegralUser>().lambda()
                            .eq(ComActIntegralUser::getUserId, order.getUserId())
                            .eq(ComActIntegralUser::getCommunityId, order.getCommunityId()));

            int allMoney=0;
            int getMoney=Integer.valueOf(order.getPalyMoney());

            allMoney=integralUserDO.getIntegralAvailableSum();

            //修改个人金汇币总额
            allMoney=allMoney+getMoney;

            NewFightIntegral integral=new NewFightIntegral();

            integral.setIntegralNum(allMoney+"");
            integral.setAddOrReduce(1);
            integral.setCommunityId(order.getCommunityId());
            integral.setUserId(order.getUserId());

            if(StringUtils.equals("1",order.getOrderType()))
            {
                integral.setType("9");
                integral.setIdentityType("1");
                integral.setRemark("积分兑换商品取消");
            }
            else
            {
                integral.setType("10");
                integral.setIdentityType("1");
                integral.setRemark("商家兑换商品取消");
                integral.setMerchantId(order.getMerchantId());
                integral.setIntegralNum(order.getPalyMoney());
            }
            integralUsersService.upIntegral(integral);

            return R.ok();
        }
        return R.fail("取消失败");
    }

    @Override
    public R expurgateData(String id,String communityId)
    {
        NewFightShoppingOrder order=baseMapper.getDetails(id,communityId);

        if(StringUtils.equals("0",order.getCancelType()))
        {
            return R.fail("待核销订单不能删除");
        }

        int num= baseMapper.expurgateData(id);
        if(num>0)
        {
            return R.ok();
        }
        return R.fail("添加失败");
    }
}