member_id(); $param['sender_mobile'] = $minfo->mobile(); $param['sender_name'] = $minfo->nickname(); $param['make_type'] = \bonus\type::MakeShakeGainType; $name = $minfo->nickname(); $param['type_name'] = "从{$name}摇来的红包"; $ret = bonus_helper::make_bonus($param); if($ret != false) { $to_minfo = new member_info($to_id); $thief =$to_minfo->nickname(); $predo = new predeposit_helper($from_id); $predo->handout_bonus($amount,$ret['type_sn'],$thief,"{$thief}摇走了您{$amount}元的红包.",\bonus\type::MakeShakeGainType); bonus_helper::withold($from_id,$amount); $bonusex = bonus_helper::send($ret['type_sn'],array($to_id)); $push_param = array(); $push_param['member_id'] = $from_id; $push_param['text'] = "{$thief}偷走了您{$amount}元的红包."; $push_param['go_type'] = 'bonus'; QueueClient::push('upushSendMsg',$push_param); return $bonusex; } else { return false; } } public static function lost_bonus($from_id,$to_id,$amount) { Log::record("lost_bonus {$amount} {$from_id} {$to_id}",Log::DEBUG); $param = self::base_param($amount,1); $minfo = new member_info($from_id); $param['sender_id'] = $minfo->member_id(); $param['sender_mobile'] = $minfo->mobile(); $param['sender_name'] = $minfo->nickname(); $param['make_type'] = \bonus\type::MakeShakeLostType; $name = $minfo->nickname(); $param['type_name'] = "{$name}摇飞的红包"; $ret = bonus_helper::make_bonus($param); if($ret != false) { $to_info = new member_info($to_id); $predo = new predeposit_helper($from_id); $predo->handout_bonus($amount,$ret['type_sn'],$to_info->nickname(),"您摇丢了{$amount}的红包.",\bonus\type::MakeShakeLostType); bonus_helper::withold($from_id,$amount); $bonusex = bonus_helper::send($ret['type_sn'],array($to_id)); $push_param = array(); $push_param['member_id'] = $to_id; $push_param['text'] = "{$name}的{$amount}元的红包,在向您飞来~."; $push_param['go_type'] = 'bonus'; QueueClient::push('upushSendMsg',$push_param); return $bonusex; } else { return false; } } public static function share_bonus($member_id,$bonus_sn,&$msg) { $bonus = bonus\user_bonus::create_by_sn($bonus_sn); $amount = $bonus->remain_amount(); if($bonus->spend_over()) { $msg = "该红包现金已经花光了~"; return false; } $param = self::base_param($amount,1); $minfo = new member_info($member_id); $param['sender_id'] = $member_id; $param['sender_mobile'] = $minfo->mobile(); $param['sender_name'] = $minfo->nickname(); $param['make_type'] = \bonus\type::MakeSendType; $name = $minfo->nickname(); $param['type_name'] = "{$name}"; $ret = bonus_helper::make_bonus($param); if($ret != false) { $predo = new predeposit_helper($member_id); $predo->handout_bonus($amount,$ret['type_sn'],$minfo->nickname(),"您分享了{$amount}元的红包.",\bonus\type::MakeSendType); bonus_helper::withold_bonus($member_id,$bonus_sn); return $ret; } else { return false; } } public static function gain_sysBonus($to_id,$amount) { $param = self::base_param($amount,1); self::admin_param($param); $param['make_type'] = \bonus\type::MakeShakeGainType; $param['type_name'] = "从熊猫美妆摇来的红包"; $ret = bonus_helper::make_bonus($param); if($ret != false) { $bonusex = bonus_helper::send($ret['type_sn'],array($to_id)); return $bonusex; } else { return false; } } private static function pay_refund($member_id,$amount,$bonus_name) { $param = self::base_param($amount,1); self::admin_param($param); $param['make_type'] = \bonus\type::MakePayRefundType; $param['type_name'] = $bonus_name; $ret = bonus_helper::make_bonus($param); if($ret != false) { bonus_helper::send($ret['type_sn'],array($member_id)); $push_param = array(); $push_param['member_id'] = $member_id; $push_param['text'] = "购物退款通知:金额{$amount}元."; $push_param['go_type'] = 'bonus'; QueueClient::push('upushSendMsg',$push_param); } else { Log::record("给用户 {$member_id} 退款{$amount}失败."); } } private static function order_cancel($member_id,$amount,$bonus_name) { $param = self::base_param($amount,1); self::admin_param($param); $param['make_type'] = \bonus\type::MakeOrderCancelType; $param['type_name'] = $bonus_name; $ret = bonus_helper::make_bonus($param); if($ret != false) { bonus_helper::send($ret['type_sn'],array($member_id)); $push_param = array(); $push_param['member_id'] = $member_id; $push_param['text'] = "取消订单退款通知:金额{$amount}元."; $push_param['go_type'] = 'bonus'; QueueClient::push('upushSendMsg',$push_param); } else { Log::record("给用户 {$member_id} 退款{$amount}失败."); } } private static function bonus_refund($member_id,$amount,$bonus_name) { $param = self::base_param($amount,1); self::admin_param($param); $param['make_type'] = \bonus\type::MakeBonusRefundType; $param['type_name'] = $bonus_name; $ret = bonus_helper::make_bonus($param); if($ret != false) { $bonus = bonus_helper::send($ret['type_sn'],array($member_id)); if($bonus != false) { $push_param = array(); $push_param['member_id'] = $member_id; $push_param['text'] = "红包退还通知:您发送的红包已超过24小时,退还未被领取的金额{$amount}元,请在收支明细中查看."; $push_param['go_type'] = 'bonus'; QueueClient::push('upushSendMsg',$push_param); } } else { Log::record("给用户 {$member_id} 红包退款{$amount}失败."); } } public static function register_bonus($member_id,$amount) { $param = self::base_param($amount,1); self::admin_param($param); $param['make_type'] = \bonus\type::MakeRegister; $param['type_name'] = "新用户注册红包"; $ret = bonus_helper::make_bonus($param); if($ret != false) { $bonus = bonus_helper::send($ret['type_sn'],array($member_id)); return $bonus; } else { return false; } } public static function onPredeposit($change_type,$member_id,$pd_amount,$sn) { Log::record("onPredeposit {$change_type},{$member_id},{$pd_amount}",Log::DEBUG); if($change_type == 'order_pay') { bonus_helper::withold($member_id,$pd_amount); } elseif($change_type == 'order_freeze') { bonus_helper::withold($member_id,$pd_amount); } elseif($change_type == 'order_comb_pay') { } elseif($change_type == 'order_cancel') { // 发送给该用户一个同等额度的红包 self::order_cancel($member_id,$pd_amount,"退款红包"); } elseif($change_type == 'refund') { // 发送给该用户一个同等额度的红包 $order_sn = $sn; $order = order::create_by_sn($order_sn); if($order == false) { self::pay_refund($member_id,$pd_amount,"退款红包"); } else { self::pay_refund($member_id,$order->pd_amount(),"退款红包"); } } elseif($change_type == 'bonus_refund') { // 发送给该用户一个同等额度的红包 self::bonus_refund($member_id,$pd_amount,"红包过期未领退款"); } } }