package com.panzhihua.service_dangjian.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
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.IntegratingTaskVO;
import com.panzhihua.common.model.vos.community.building.NewFightConvenientMerchantVO;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_dangjian.dao.ComActIntegralUsersMapper;
import com.panzhihua.service_dangjian.entity.ComActIntegralUser;
import com.panzhihua.service_dangjian.entity.ComActIntegralUserTrade;
import com.panzhihua.service_dangjian.entity.IntegratingTask;
import com.panzhihua.service_dangjian.entity.NewFightConvenientMerchant;
import com.panzhihua.service_dangjian.service.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

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


@Slf4j
@Service
public class ComActIntegralUsersServiceImpl extends ServiceImpl<ComActIntegralUsersMapper,
        ComActIntegralUser> implements ComActIntegralUsersService
{


    @Resource
    private ComActIntegralUsersService integralUsersService;

    @Resource
    private ComActIntegralUserTradeDaoService tradeDaoService;

    @Resource
    private ComActIntegralUserChangeDAOService changeDAOService;


    @Resource
    private NewFightIntegratingTaskService taskService;

    @Resource
    private NewFightConvenientMerchantService merchantService;


    @Override
    public R upIntegral(NewFightIntegral item)
    {

        // 需要给用户增加的积分数量
        Integer amount = 0;
        // 查询用户积分账户
        ComActIntegralUser integralUserDO =
                integralUsersService.getOne(new QueryWrapper<ComActIntegralUser>().lambda()
                        .eq(ComActIntegralUser::getUserId, item.getUserId())
                        .eq(ComActIntegralUser::getCommunityId, item.getCommunityId()));

        if (integralUserDO == null) {
            integralUserDO = new ComActIntegralUser();
            integralUserDO.setCommunityId(Long.valueOf(item.getCommunityId()));
            integralUserDO.setUserId(Long.valueOf(item.getUserId()));
            integralUserDO.setCreateAt(new Date());
            integralUserDO.setStatus(ComActIntegralUser.status.yes);
            integralUserDO.setIntegralSum(0);
            integralUserDO.setIntegralAvailableSum(0);
            integralUserDO.setIntegralFrozenSum(0);
            integralUserDO.setIntegralParty(0);
            integralUserDO.setIntegralAvailableParty(0);
            integralUserDO.setIntegralFrozenParty(0);
            integralUserDO.setIntegralVolunteer(0);
            integralUserDO.setIntegralAvailableVolunteer(0);
            integralUserDO.setIntegralFrozenVolunteer(0);
            integralUserDO.setIntegralResident(0);
            integralUserDO.setIntegralAvailableResident(0);
            integralUserDO.setIntegralFrozenResident(0);
            integralUsersService.save(integralUserDO);
        }


        if (integralUserDO.getStatus().equals(ComActIntegralUser.status.no)) {
            log.error("用户钱包已被禁用，记录积分失败，用户id：" + item.getUserId());
            return R.fail("用户钱包已被禁用，记录积分失败，用户id：" + item.getUserId());
        }

        Long integralId = integralUserDO.getId();
        // 记录变动前钱包金额
        Integer integralSum = integralUserDO.getIntegralSum();
        Integer integralAvailableSum = integralUserDO.getIntegralAvailableSum();
        Integer integralFrozenSum = integralUserDO.getIntegralFrozenSum();
        Integer integralParty = integralUserDO.getIntegralParty();
        Integer integralAvailableParty = integralUserDO.getIntegralAvailableParty();
        Integer integralFrozenParty = integralUserDO.getIntegralFrozenParty();
        Integer integralVolunteer = integralUserDO.getIntegralVolunteer();
        Integer integralAvailableVolunteer = integralUserDO.getIntegralAvailableVolunteer();
        Integer integralFrozenVolunteer = integralUserDO.getIntegralFrozenVolunteer();
        Integer integralResident = integralUserDO.getIntegralResident();
        Integer integralAvailableResident = integralUserDO.getIntegralAvailableResident();
        Integer integralFrozenResident = integralUserDO.getIntegralFrozenResident();

        //业务类型 9商城积分兑换  10商家线下积分兑换  11花城登录  12 查看问题清单 "
        //            "13查看需求清单  14 查看报道服务活动  15查看微心愿  16 查看随手拍   17 每日签到 18 上传“随手拍”或“微心愿
        switch (item.getType())
        {
            case "9":
                //商城积分兑换
                //积分总数加减
                break;
            case "10":
                //商家线下积分兑换  增加
                //商家积分增加
                NewFightConvenientMerchant merchant=merchantService.selectMerchantById(item.getMerchantId());
                int allMoney=0;
                if(!StringUtils.isEmpty(merchant.getBusinessCredit()))
                {
                    allMoney=Integer.valueOf(merchant.getBusinessCredit());
                }
                if (item.getAddOrReduce() == ComActIntegralUserTrade.changeType.add)
                {
                    allMoney=allMoney+Integer.valueOf(item.getIntegralNum());

                }
                else
                {
                    //商家积分减少
                    allMoney=allMoney-Integer.valueOf(item.getIntegralNum());
                }
                NewFightConvenientMerchantVO merchantVO=new NewFightConvenientMerchantVO();
                merchantVO.setId(merchant.getId());
                merchantVO.setBusinessCredit(allMoney+"");
                merchantService.editData(merchantVO);
                break;
            case "11":
                //花城登录
                item.setRemark("花城登录");
                IntegratingTask task=taskService.getDetails(item.getUserId(),
                        item.getCommunityId(),item.getType());
                if(task!=null && StringUtils.equals("2",task.getIsDraw()) )
                {
                    return R.ok();
                }

                item.setAddOrReduce(1);
                item.setIntegralNum("2");

                IntegratingTaskVO taskVO=new IntegratingTaskVO();
                taskVO.setIsDraw("2");
                taskVO.setId(item.getTaskId());
                taskService.editData(taskVO);
                break;
            case "12":
                // 查看问题清单
                item.setRemark("查看问题清单");
                item.setAddOrReduce(1);
                item.setIntegralNum("1");
                IntegratingTaskVO taskVO2=new IntegratingTaskVO();
                taskVO2.setIsDraw("2");
                taskVO2.setId(item.getTaskId());
                taskService.editData(taskVO2);
                break;
            case "13":
                //13查看需求清单
                item.setRemark("查看需求清单");
                item.setAddOrReduce(1);
                item.setIntegralNum("1");
                IntegratingTaskVO taskVO13=new IntegratingTaskVO();
                taskVO13.setIsDraw("2");
                taskVO13.setId(item.getTaskId());
                taskService.editData(taskVO13);
                break;
            case "14":
                //查看报道服务活动
                item.setRemark("查看需求清单");
                item.setAddOrReduce(1);
                item.setIntegralNum("1");
                IntegratingTaskVO taskVO14=new IntegratingTaskVO();
                taskVO14.setIsDraw("2");
                taskVO14.setId(item.getTaskId());
                taskService.editData(taskVO14);
                break;
            case "15":
                //15查看微心愿
                item.setRemark("查看微心愿");
                item.setAddOrReduce(1);
                item.setIntegralNum("1");
                IntegratingTaskVO taskVO15=new IntegratingTaskVO();
                taskVO15.setIsDraw("2");
                taskVO15.setId(item.getTaskId());
                taskService.editData(taskVO15);
                break;
            case "16":
                //查看随手拍
                item.setRemark("查看随手拍");
                item.setAddOrReduce(1);
                item.setIntegralNum("1");
                IntegratingTaskVO taskVO16=new IntegratingTaskVO();
                taskVO16.setIsDraw("2");
                taskVO16.setId(item.getTaskId());
                taskService.editData(taskVO16);
                break;
            case "17":
                //每日签到
//                IntegratingTask task2=taskService.getDetails(item.getUserId(),
//                        item.getCommunityId(),item.getType());
//                if(task2!=null && StringUtils.equals("2",task2.getIsDraw()) )
//                {
//                    return R.ok();
//                }
                item.setRemark("每日签到");
                item.setAddOrReduce(1);
//                IntegratingTaskVO taskVO2=new IntegratingTaskVO();
//                taskVO2.setIsDraw("2");
//                taskVO2.setId(item.getTaskId());
//                taskService.editData(taskVO2);
                break;
            case "18":
                //上传“随手拍”或“微心愿
                item.setRemark("上传“随手拍”或“微心愿");
                item.setAddOrReduce(1);
                item.setIntegralNum("2");
                break;
        }

        // 根据不同身份，计算钱包金额
//        if (identityType.equals(ComActIntegralUserTrade.identityType.jm)) {
//            int integralResidentNow = addIntegral(integralResident + amount);
//            if (amount < 0) {
//                reduceAmount = integralResident - integralResidentNow;
//            }
//            integralUserDO.setIntegralResident(integralResidentNow);
//            integralUserDO.setIntegralAvailableResident(addIntegral(integralUserDO.getIntegralAvailableResident() + amount));
//        } else if (identityType.equals(ComActIntegralUserTradeDO.identityType.dy)) {
//            int integralPartyNow = addIntegral(integralParty + amount);
//            if (amount < 0) {
//                reduceAmount = integralParty - integralPartyNow;
//            }
//            integralUserDO.setIntegralParty(integralPartyNow);
//            integralUserDO.setIntegralAvailableParty(addIntegral(integralUserDO.getIntegralAvailableParty() + amount));
//        } else if (identityType.equals(ComActIntegralUserTradeDO.identityType.zyz)) {
//            int integralVolunteerNow = addIntegral(integralVolunteer + amount);
//            if (amount < 0) {
//                reduceAmount = integralVolunteer - integralVolunteerNow;
//            }
//            integralUserDO.setIntegralVolunteer(integralVolunteerNow);
//            integralUserDO.setIntegralAvailableVolunteer(addIntegral(integralUserDO.getIntegralAvailableVolunteer() + amount));
//        }

        //获取积分
        if(!StringUtils.isEmpty(item.getIntegralNum()))
        {
            amount=Integer.valueOf(item.getIntegralNum());
        }


        //积分总数加减
        if (item.getAddOrReduce() == ComActIntegralUserTrade.changeType.add)
        {
            int integralResidentNow = addIntegral(integralResident + amount);
            integralUserDO.setIntegralResident(integralResidentNow);
            integralUserDO.setIntegralAvailableResident(addIntegral(integralUserDO.getIntegralAvailableResident() + amount));

        }
        else {

            int integralResidentNow = addIntegral(integralResident - amount);
            integralUserDO.setIntegralResident(integralResidentNow);
            integralUserDO.setIntegralAvailableResident(addIntegral(integralUserDO.getIntegralAvailableResident() - amount));
        }


        //积分总数加减
        if (item.getAddOrReduce() == ComActIntegralUserTrade.changeType.reduce)
        {
//            integralUserDO.setIntegralSum(addIntegral(integralSum - amount));
            integralUserDO.setIntegralAvailableSum(addIntegral(integralAvailableSum - amount));
        }
        else {
            integralUserDO.setIntegralSum(addIntegral(integralSum + amount));
            integralUserDO.setIntegralAvailableSum(addIntegral(integralAvailableSum + amount));
        }
        integralUserDO.setUpdateAt(new Date());

        // 更新钱包
        integralUsersService.updateById(integralUserDO);

        // 增加积分账户交易记录
        Long tradeId = tradeDaoService.addIntegralTradeRecord(Long.valueOf(item.getUserId()), integralId, Long.valueOf(item.getCommunityId()),
                Long.valueOf(item.getServiceId()), Integer.valueOf(item.getType()), Integer.valueOf(item.getIntegralNum()),
                item.getAddOrReduce(), item.getRemark(), Integer.valueOf(item.getIdentityType()), 2L);

        // 增加积分账户变更记录
        changeDAOService.addIntegralUserChangeRecord(Long.valueOf(item.getUserId()), integralId,
                Long.valueOf(item.getCommunityId()), integralSum,
                integralUserDO.getIntegralSum(), integralAvailableSum, integralUserDO.getIntegralAvailableSum(),
                integralFrozenSum, integralUserDO.getIntegralFrozenSum(), integralParty, integralUserDO.getIntegralParty(),
                integralAvailableParty, integralUserDO.getIntegralAvailableParty(), integralFrozenParty,
                integralUserDO.getIntegralFrozenParty(), integralVolunteer, integralUserDO.getIntegralVolunteer(),
                integralAvailableVolunteer, integralUserDO.getIntegralAvailableVolunteer(), integralFrozenVolunteer,
                integralUserDO.getIntegralFrozenVolunteer(), integralResident, integralUserDO.getIntegralResident(),
                integralAvailableResident, integralUserDO.getIntegralAvailableResident(), integralFrozenResident,
                integralUserDO.getIntegralFrozenResident(), tradeId);

        return R.ok();
    }



    private int addIntegral(int integral) {
        return integral > 0 ? integral : 0;
    }

}