<?php
/**
 * Created by PhpStorm.
 * Author: 芸众商城 www.yunzshop.com
 * Date: 2017/5/15
 * Time: 上午8:56
 */

namespace app\common\services\credit;


use app\common\events\finance\LoveChangeEvent;
use app\common\exceptions\ShopException;
use app\framework\Support\Facades\Log;
use Illuminate\Support\Facades\DB;

abstract class Credit
{
    protected $data = [];

    protected $type = ConstService::TYPE_INCOME;

    protected $source;

    protected $change_value;


    protected $memberModel;

    //abstract function changeValue();

    abstract function getMemberModel();

    abstract function recordSave();

    abstract function updateMemberCredit();

    abstract function validatorData();

    //abstract function validatorOzy();

    /**
     * 打赏接口
     * @param array $data
     * @return string
     */
    public function giveReward(array $data)
    {
        $this->source = ConstService::KART_GIVE_REWARD;
        return $this->addition($data);
    }

    /**
     * 充值接口
     * @param array $data
     * @return string
     */
    public function recharge(array $data)
    {
        $this->source = ConstService::SOURCE_RECHARGE;
        return $this->addition($data);
    }

    /**
     * 后台扣除
     * @param array $data
     * @return string
     */
    public function rechargeMinus(array $data)
    {
        $this->source = ConstService::SOURCE_RECHARGE_MINUS;
        return $this->subtraction($data);
    }

    /**
     * 自定义 source 参数,消费接口
     * @param array $data
     * @return string
     */
    public function customConsume(array $data)
    {
        if ($data['source']) {
            $this->source = $data['source'];
        } else {
            $this->source = ConstService::SOURCE_CONSUME;
        }

        return $this->subtraction($data);
    }

    /**
     * 消费接口
     * @param array $data
     * @return string
     */
    public function consume(array $data)
    {
        $this->source = ConstService::SOURCE_CONSUME;
        return $this->subtraction($data);
    }

    /**
     * 转让接口
     * @param array $data
     * @return string
     */
    public function transfer(array $data)
    {
        $this->source = ConstService::SOURCE_TRANSFER;
        return $this->subtraction($data);
    }

    /**
     * 余额转化爱心值
     * @param array $data
     * @return bool|string
     */
    public function convert(array $data)
    {
        $this->source = ConstService::SOURCE_CONVERT;
        return $this->subtraction($data);
    }

    /**
     * 余额转化爱心值回滚
     * @param array $data
     * @return bool|string
     */
    public function convertCancel(array $data)
    {
        $this->source = ConstService::SOURCE_CONVERT_CANCEL;
        return $this->addition($data);
    }

    /**
     * 转让收入接口
     * @param array $data
     * @return string
     */
    public function recipient(array $data)
    {
        $this->source = ConstService::SOURCE_TRANSFER;
        return $this->addition($data);
    }

    /**
     * 抵扣接口
     * @param array $data
     * @return string
     */
    public function deduction(array $data)
    {
        $this->source = ConstService::SOURCE_DEDUCTION;
        return $this->subtraction($data);
    }

    /**
     * 奖励接口
     * @param array $data
     * @return string
     */
    public function award(array $data)
    {
        $this->source = ConstService::SOURCE_AWARD;
        if ($data['source']) {
            $this->source = $data['source'];
        }
        return $this->addition($data);
    }

    /**
     * 充值消费积分赠送爱心值
     * @param array $data
     * @return string
     */
    public function integralAward(array $data)
    {
        $this->source = ConstService::SOURCE_AWARD;
        return $this->addition($data);
    }

    /**
     * 提现接口
     * @param array $data
     * @return string
     */
    public function withdrawal(array $data)
    {
        $this->source = ConstService::SOURCE_WITHDRAWAL;
        return $this->subtraction($data);
    }

    /**
     * 提现至………（余额）………接口
     * @param array $data
     * @return string
     */
    public function income(array $data)
    {
        $this->source = ConstService::SOURCE_INCOME;
        return $this->addition($data);
    }

    /**
     * 抵扣取消回滚接口
     * @param array $data
     * @return string
     */
    public function cancelDeduction(array $data)
    {
        $this->source = ConstService::SOURCE_CANCEL_DEDUCTION;
        return $this->addition($data);
    }

    /**
     * 奖励取消回滚接口
     * @param array $data
     * @return string
     */
    public function cancelAward(array $data)
    {
        $this->source = ConstService::SOURCE_CANCEL_AWARD;
        return $this->subtraction($data);
    }

    /**
     * 消费取消回滚接口
     * @param array $data
     * @return string
     */
    public function cancelConsume(array $data)
    {
        \Log::debug("消费取消回滚接口", $data);
        $this->source = ConstService::SOURCE_CANCEL_CONSUME;
        return $this->addition($data);
    }

    /**
     * 抽奖获得余额
     * @param array $data
     * @return string
     */
    public function DrawGet(array $data)
    {
        $this->source = ConstService::SOURCE_DRAW_CHARGE;
        return $this->addition($data);
    }

    /**
     * 抽奖奖励余额
     * @param array $data
     * @return string
     */
    public function DrawReward(array $data)
    {
        $this->source = ConstService::SOURCE_DRAW_REWARD;
        return $this->addition($data);
    }

    /**
     * 新人奖奖励余额
     * @param array $data
     * @return string
     */
    public function NewMemberPrizeReward(array $data)
    {
        $this->source = ConstService::SOURCE_NEW_MEMBER_PRIZE;
        return $this->addition($data);
    }

    //第三方同步
    public function ThirdSynchronization(array $data)
    {
        $this->source = ConstService::SOURCE_THIRD_SYN;
        return $this->addition($data);
    }

    /**
     * 直播会员观看获得余额
     * @param array $data
     * @return string
     */
    public function RoomMemberActivity(array $data)
    {
        $this->source = ConstService::ROOM_MEMBER_ACTIVITY;
        return $this->addition($data);
    }

    /**
     * 直播会员观看获得余额
     * @param array $data
     * @return string
     */
    public function RoomActivity(array $data)
    {
        $this->source = ConstService::ROOM_ACTIVITY;
        return $this->addition($data);
    }

    /**
     * 直播会员观看获得余额
     * @param array $data
     * @return string
     */
    public function RoomAnchorActivity(array $data)
    {
        $this->source = ConstService::ROOM_ANCHOR_ACTIVITY;
        return $this->addition($data);
    }

    /**
     * 直播打赏支出
     * @param array $data
     * @return string
     */
    public function RoomRewardTransfer(array $data)
    {
        $this->source = ConstService::ROOM_REWARD_TRANSFER;
        return $this->subtraction($data);
    }

    /**
     * 直播打赏收入
     * @param array $data
     * @return string
     */
    public function RoomRewardRecipient(array $data)
    {
        $this->source = ConstService::ROOM_REWARD_RECIPIENT;
        return $this->addition($data);
    }

    /**
     * 层链充值
     * @param array $data
     * @return string
     */
    public function LayerChainRecharge(array $data)
    {
        $this->source = ConstService::LAYER_CHAIN_RECHARGE;
        return $this->addition($data);
    }

    /**
     * 拼团成功奖励
     * @param array $data
     * @return string
     */
    public function FightGroupsSuccessReward(array $data)
    {
        $this->source = ConstService::FIGHT_GROUPS_SUCCESS_REWARD;
        return $this->addition($data);
    }

    /**
     * 拼团抽奖奖励
     * @param array $data
     * @return string
     */
    public function FightGroupsLotterySuccessReward(array $data)
    {
        $this->source = $data['source'];
        return $this->addition($data);
    }

    /**
     * 拼团抽奖奖励余额
     * @param array $data
     * @return bool|string
     */
    public function FightGroupsLotteryComfortReward(array $data)
    {
        $this->source = $data['source'];

        return $this->addition($data);
    }

    /**
     * 加入付费圈子奖励
     * @param array $data
     * @return string
     */
    public function CircleAddReward(array $data)
    {
        $this->source = $data['source'];
        return $this->addition($data);
    }

    /**
     * 抢团成功奖励
     * @param array $data
     * @return string
     */
    public function SnatchRegimentSuccessReward(array $data)
    {
        $this->source = ConstService::SNATCH_REGIMENT_SUCCESS_AWARD;
        return $this->addition($data);
    }

    /**
     * 星拼乐成功奖励
     * @param array $data
     * @return string
     */
    public function StarSpellSuccessReward(array $data)
    {
        $this->source = ConstService::STAR_SPELL_SUCCESS_AWARD;
        return $this->addition($data);
    }

    /**
     * 抽奖奖励
     * @param array $data
     * @return string
     */
    public function LuckDrawReward(array $data)
    {
        $this->source = ConstService::LUCK_DRAW_AWARD;
        return $this->addition($data);
    }

    /**
     * 社群接龙奖励
     * @param array $data
     * @return string
     */
    public function CommunityRelayAward(array $data)
    {
        $this->source = ConstService::COMMUNITY_RELAY_AWARD;
        return $this->addition($data);
    }

    /**
     * 信用值中南呗转入
     * @param array $data
     * @return string
     */
    public function CreditZnbTransfer(array $data)
    {
        $this->source = ConstService::CREDIT_ZNB_TRANSFER;
        return $this->addition($data);
    }

    /**
     * 投放广告插件-获得红包
     * @param array $data
     * @return string
     */
    public function AdServingRedpackReward(array $data)
    {
        $this->source = ConstService::AD_SERVING_REDPACK_REWARD;
        return $this->addition($data);
    }

    /**
     * 投放广告插件-投放广告扣除金额
     * @param array $data
     * @return string
     */
    public function AdServingPutInAdvertisingDeduct(array $data)
    {
        $this->source = ConstService::AD_SERVING_PUT_IN_ADVERTISING_DEDUCT;
        return $this->subtraction($data);
    }

    /**
     * 投放广告插件-退款
     * @param array $data
     * @return string
     */
    public function AdServingRefund(array $data)
    {
        $this->source = ConstService::AD_SERVING_REFUND;
        return $this->addition($data);
    }


    public function CpsSubPlatformReward(array $data)
    {
        $this->source = ConstService::CPS_SUB_PLATFORM;
        return $this->addition($data);
    }

    /**
     * 珍惠拼 - 退团
     * @param array $data
     * @return string
     */
    public function ZhpQuitGroupRefund(array $data)
    {
        $this->source = ConstService::ZHP_QUIT_GROUP_REFUND;
        return $this->addition($data);
    }

  /**
     * 拼团成团奖-上级奖励
     * @param array $data
     * @return string
     */
    public function FightGroupsOperatorsParentReward(array $data)
    {
        $this->source = ConstService::FIGHT_GROUPS_OPERATORS_SETTLE_REWARD;
        return $this->addition($data);
    }

   /**
     * 爱心值转余额
     * @param array $data
     * @return string
     */
    public function LoveToBalance(array $data)
    {
        $this->source = ConstService::LOVE_TO_BALANCE;
        return $this->addition($data);
    }

    /**
     * 珍惠拼 - 易货
     * @param array $data
     * @return string
     */
    public function zhpBarterReward(array $data)
    {
        $this->source = ConstService::ZHP_BARTER;
        return $this->addition($data);
    }

   /**
     * 群拓客奖励-进群奖励
     * @param array $data
     * @return bool|string
     */
    public function groupChatActivity(array $data)
    {
        $this->source = ConstService::GROUP_CHAT_ACTIVITY;
        return $this->addition($data);
    }

   /* 企业微信好友裂变活动奖励
     * @param array $data
     * @return string
     */
    public function CustomerIncreaseAward(array $data)
    {
        $this->source = ConstService::CUSTOMER_INCREASE_REWARD;
        return $this->addition($data);
    }

    /**
     * 每日红包转入
     * @param array $data
     * @return string
     */
    public function RedPacketReward(array $data)
    {
        $this->source = ConstService::RED_PACKET_REWARD;
        return $this->addition($data);
    }

    /**
     * 珍惠拼-统一时间奖励
     * @param array $data
     * @return string
     */
    public function ZhpUnifyReward(array $data)
    {
        $this->source = ConstService::ZHP_UNIFY_REWARD;
        return $this->addition($data);
    }

    /**
     * ywm-拼团成功奖励
     * @param array $data
     * @return string
     */
    public function YwmFightGroupsSuccessReward(array $data)
    {
        $this->source = ConstService::YWM_FIGHT_GROUPS_SUCCESS_REWARD;
        return $this->addition($data);
    }

    /**
     * 直播-拼手气红包发放接口
     * @param array $data
     * @return string
     */
    public function roomRedPackSend(array $data)
    {
        $this->source = ConstService::ROOM_REDPACK_SEND;
        return $this->subtraction($data);
    }

    /**
     * 直播-拼手气红包领取接口
     * @param array $data
     * @return string
     */
    public function roomRedPackReceive(array $data)
    {
        $this->source = ConstService::ROOM_REDPACK_RECEIVE;
        return $this->addition($data);
    }

    /**
     * 直播-拼手气红包退还接口
     * @param array $data
     * @return string
     */
    public function roomRedPackRefund(array $data)
    {
        $this->source = ConstService::ROOM_REDPACK_REFUND;
        return $this->addition($data);
    }

    /*
     * 新客裂变奖励
     * @param array $data
     * @return string
     */
    public function newcomerFissionReward(array $data)
    {
        $this->source = ConstService::NEWCOMER_FISSION_REWARD;
        return $this->addition($data);
    }

    /*
   * 存货服务奖励
   * @param array $data
   * @return string
   */
    public function stockServiceReward(array $data)
    {
        $this->source = ConstService::STOCK_SERVICE_BACK;
        return $this->addition($data);
    }

    /**
     * 手签协议奖励
     * @param array $data
     * @return string
     */
    public function handSignProtocolReward(array $data)
    {
        $this->source = ConstService::HAND_SIGN_PROTOCOL;
        return $this->addition($data);
    }

    /**
     * 活动排行榜额度不足扣除
     * @param array $data
     * @return string
     */
    public function activityRankingQuotaDissatisfy(array $data)
    {
        $this->source = ConstService::ACTIVITY_RANKING_QUOTA_DISSATISFY;
        return $this->subtraction($data);
    }

    /**
     * 会员合并转入
     * @param array $data
     * @return string
     */
    public function memberMerge(array $data)
    {
        $this->source = ConstService::MEMBER_MERGE;
        return $this->addition($data);
    }

    //加法
    protected function addition($data)
    {
        if (!isset($data['change_value']) || $data['change_value'] < 0) {
            return '变动值必须是正数';
        }

        $this->data = $data;
        $this->type = ConstService::TYPE_INCOME;
        $this->change_value = $this->data['change_value'];
        \Log::debug("监听加法", $this->change_value);

        event(new LoveChangeEvent($data['member_id']));

        return $this->result();
    }

    //加法
    protected function ozyAddition($data)
    {
        if (!isset($data['change_value']) || $data['change_value'] < 0) {
            return '变动值必须是正数';
        }

        $this->data = $data;
        $this->type = ConstService::TYPE_INCOME;
        $this->change_value = $this->data['change_value'];
        \Log::debug("监听加法", $this->change_value);

        event(new LoveChangeEvent($data['member_id']));

        return $this->result();
    }

    //减法
    protected function subtraction($data)
    {
        if (!isset($data['change_value']) || $data['change_value'] < 0) {
            return '变动值必须是正数';
        }
        $this->data = $data;
        $this->type = ConstService::TYPE_EXPENDITURE;
        $this->change_value = -$this->data['change_value'];

        return $this->result();
    }

    protected function ozySubtraction($data)
    {
        if (!isset($data['change_value']) || $data['change_value'] < 0) {
            return '变动值必须是正数';
        }
        $this->data = $data;
        $this->type = ConstService::TYPE_EXPENDITURE;
        $this->change_value = -$this->data['change_value'];

        return $this->result();
    }

    //余额提现驳回
    public function rejected($data)
    {
        $this->source = ConstService::SOURCE_REJECTED;
        return $this->addition($data);
    }

    //批量充值正数
    public function excelRecharge(array $data)
    {
        $this->source = ConstService::SOURCE_EXCEL_RECHARGE;

        return $this->addition($data);
    }

    //批量充值负数
    public function excelRechargeSubtraction(array $data)
    {
        $this->source = ConstService::SOURCE_EXCEL_RECHARGE;

        return $this->subtraction($data);
    }

    // 个人红包发放
    public function redpackUserSend(array $data)
    {
        $this->source = ConstService::REDPACK_USER_SEND;

        return $this->subtraction($data);
    }

    /**
     * 企业微信好友分裂活动奖励
     * @param array $data
     * @return string
     */
    public function customerIncreaseReward(array $data)
    {
        $this->source = ConstService::CUSTOMER_INCREASE_REWARD;
        return $this->addition($data);
    }

    protected function result()
    {
        if (!(double)$this->data['change_value']) return true;

        DB::transaction(function () {
            $this->_result();
        });
        return true;
    }

    //todo 应该改为私有
    protected function _result()
    {
        $this->memberModel = $this->getMemberModel();
        if (!$this->memberModel) {
            throw new ShopException("未获取到会员数据");
        }
        $validator = $this->validatorData();
        if (!($validator === true)) {
            throw new ShopException("$validator");
        }

        $result = $this->recordSave();
        if (!$result) {
            throw new ShopException("数据写入错误：CREDIT_RECORD");
        }

        $result = $this->updateMemberCredit();
        if (!$result) {
            throw new ShopException("数据写入错误：CREDIT_UPDATE");
        }
        return true;
    }

    /**
     * 拓客活动余额奖励
     * @param array $data
     * @return string
     */
    public function activityRewardBalance(array $data)
    {
        $this->source = $data['source'];
        return $this->addition($data);
    }
}