445 lines
14 KiB
PHP
445 lines
14 KiB
PHP
<?php
|
||
/**
|
||
* Author:
|
||
* Date: 2017/5/24
|
||
* Time: 下午5:08
|
||
*/
|
||
|
||
namespace app\common\services\finance;
|
||
|
||
|
||
use app\common\events\member\MemberBalanceChangeEvent;
|
||
use app\common\events\member\MemberBalanceDeficiencyEvent;
|
||
use app\common\events\MessageEvent;
|
||
use app\common\exceptions\AppException;
|
||
use app\common\models\finance\Balance;
|
||
use app\common\models\Member;
|
||
use app\common\services\credit\ConstService;
|
||
use app\common\services\credit\Credit;
|
||
use app\common\models\notice\MinAppTemplateMessage;
|
||
use app\common\services\MessageService as MsgService;
|
||
use app\common\models\notice\MessageTemp;
|
||
use app\common\services\notice\official\BalanceChangeNotice;
|
||
use app\common\services\notice\official\BalanceDeficiencyNotice;
|
||
use app\common\services\txyunsms\SmsSingleSender;
|
||
|
||
class BalanceChange extends Credit
|
||
{
|
||
|
||
private $new_value;
|
||
|
||
private $balanceSet = array();
|
||
|
||
/**
|
||
* 实现基类中的抽象方法
|
||
* 通过基类 data 中的 member_id 获取会员信息
|
||
* @return mixed
|
||
*/
|
||
public function getMemberModel()
|
||
{
|
||
return $this->memberModel = Member::select('uid', 'avatar', 'mobile', 'nickname', 'realname', 'credit2')->where('uid', $this->data['member_id'])->lockForUpdate()->first() ?: false;
|
||
}
|
||
|
||
/**
|
||
* 实现基类中的抽象方法
|
||
* 记录数据写入
|
||
* @return bool|\Illuminate\Support\MessageBag|string
|
||
*/
|
||
public function recordSave()
|
||
{
|
||
$recordModel = new Balance();
|
||
|
||
$recordModel->fill($this->getRecordData());
|
||
$validator = $recordModel->validator();
|
||
if ($validator->fails()) {
|
||
return $validator->messages();
|
||
}
|
||
return $recordModel->save() ? true : '明细记录写入出错';
|
||
}
|
||
|
||
/**
|
||
* 实现基类中的抽项方法
|
||
* @return bool|string
|
||
*/
|
||
public function updateMemberCredit()
|
||
{
|
||
$this->memberModel->credit2 = $this->new_value;
|
||
if ($this->memberModel->save()) {
|
||
$this->sendSmsMessage();
|
||
$this->sendMessage();
|
||
event(new MemberBalanceChangeEvent($this->memberModel, $this->new_value, $this->change_value, $this->source, $this->recordData));
|
||
return true;
|
||
}
|
||
return '写入会员余额失败';
|
||
//return $this->memberModel->save() ? true : '写入会员余额失败';
|
||
}
|
||
|
||
|
||
/**
|
||
* @return bool
|
||
* @throws AppException
|
||
*/
|
||
public function validatorData()
|
||
{
|
||
$this->new_value = bcadd($this->memberModel->credit2, $this->change_value, 2);
|
||
if ($this->new_value < 0) {
|
||
throw new AppException("用户（{$this->memberModel->uid}）余额（{$this->memberModel->credit2}）不足({$this->change_value})");
|
||
}
|
||
if (!$this->relation()) {
|
||
throw new AppException('该订单已经提交过，不能重复使用');
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
/**
|
||
* 实现基类中的抽项方法
|
||
* @return bool
|
||
* @throws AppException
|
||
*/
|
||
public function validatorOzy()
|
||
{
|
||
return true;
|
||
}
|
||
|
||
|
||
public function transfer(array $data)
|
||
{
|
||
if (!$data['recipient']) {
|
||
throw new AppException('被转让者不存在');
|
||
}
|
||
|
||
$result = parent::transfer($data);
|
||
|
||
$data['member_id'] = $data['recipient'];
|
||
return $result === true ? $this->addition($data) : $result;
|
||
}
|
||
|
||
|
||
//通用
|
||
public function universal(array $data)
|
||
{
|
||
if (!isset($data['source']) || !isset($data['type'])) {
|
||
throw new AppException('变动类型、业务类型必须设置');
|
||
}
|
||
$this->source = $data['source'];
|
||
|
||
// 1为收入 2为支出
|
||
return $data['type'] == 1 ? $this->addition($data) : $this->subtraction($data);
|
||
}
|
||
|
||
/**
|
||
*
|
||
* 直播打赏
|
||
* @param array $data
|
||
* @return bool|string
|
||
* @throws AppException
|
||
*/
|
||
public function roomReward(array $data)
|
||
{
|
||
if (!$data['recipient']) {
|
||
throw new AppException('被转让者不存在');
|
||
}
|
||
|
||
$result = parent::RoomRewardTransfer($data);
|
||
|
||
$data['member_id'] = $data['recipient'];
|
||
$money = floor(($data['change_value'] * ($data['code_proportion'] / 100)) * 100) / 100;
|
||
$data['change_value'] = $money;
|
||
return $result === true ? parent::RoomRewardRecipient($data) : $result;
|
||
}
|
||
|
||
public function incomeWithdrawAward(array $data)
|
||
{
|
||
$this->source = ConstService::SOURCE_INCOME_WITHDRAW_AWARD;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function pointTransfer(array $data)
|
||
{
|
||
$this->source = ConstService::SOURCE_POINT_TRANSFER;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function parentPayment(array $data)
|
||
{
|
||
$this->source = ConstService::PARENT_PAYMENT_REWARD;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function groupWorkAward(array $data)
|
||
{
|
||
$this->source = ConstService::GROUP_WORK_AWARD;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function groupWorkHeadAward(array $data)
|
||
{
|
||
$this->source = ConstService::GROUP_WORK_HEAD_AWARD;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function groupWorkParentAward(array $data)
|
||
{
|
||
$this->source = ConstService::GROUP_WORK_PARENT_AWARD;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function ownerOrder(array $data)
|
||
{
|
||
$this->source = ConstService::OWNER_ORDER_WITHHOLD;
|
||
|
||
return $this->subtraction($data);
|
||
}
|
||
|
||
public function ownerOrderSettle(array $data)
|
||
{
|
||
$this->source = ConstService::OWNER_ORDER_SETTLE;
|
||
|
||
return $this->addition($data);
|
||
}
|
||
|
||
public function convert(array $data)
|
||
{
|
||
$result = parent::convert($data);
|
||
return $result;
|
||
}
|
||
|
||
public function convertCancel(array $data)
|
||
{
|
||
$result = parent::convertCancel($data);
|
||
return $result;
|
||
}
|
||
|
||
public function deduct(array $data)
|
||
{
|
||
$result = parent::consume($data);
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 检测单号是否可用，为空则生成唯一单号
|
||
* @return bool|string
|
||
*/
|
||
private function relation()
|
||
{
|
||
if ($this->data['relation']) {
|
||
$result = Balance::ofOrderSn($this->data['relation'])->ofSource($this->source)->ofMemberId($this->data['member_id'])->first();
|
||
//dd($result);
|
||
if ($result) {
|
||
return false;
|
||
}
|
||
return $this->data['relation'];
|
||
}
|
||
return $this->createOrderSN();
|
||
}
|
||
|
||
/**
|
||
* 生成唯一单号
|
||
* @return string
|
||
*/
|
||
public function createOrderSN()
|
||
{
|
||
$ordersn = createNo('BC', true);
|
||
while (1) {
|
||
if (!Balance::ofOrderSn($ordersn)->first()) {
|
||
break;
|
||
}
|
||
$ordersn = createNo('BC', true);
|
||
}
|
||
return $ordersn;
|
||
}
|
||
|
||
protected $recordData;
|
||
|
||
/**
|
||
* 明细记录 data 数组
|
||
* @return array
|
||
*/
|
||
private function getRecordData()
|
||
{
|
||
$thirdStatus = empty($this->data['thirdStatus']) ? 1 : $this->data['thirdStatus'];
|
||
|
||
$this->recordData = [
|
||
'uniacid' => \YunShop::app()->uniacid,
|
||
'member_id' => $this->memberModel->uid,
|
||
'old_money' => $this->memberModel->credit2 ?: 0,
|
||
'change_money' => $this->change_value,
|
||
'new_money' => $this->new_value,
|
||
'type' => $this->type,
|
||
'service_type' => $this->source,
|
||
'serial_number' => $this->relation(),
|
||
'operator' => $this->data['operator'],
|
||
'operator_id' => $this->data['operator_id'],
|
||
'remark' => $this->data['remark'],
|
||
'thirdStatus' => $thirdStatus
|
||
];
|
||
|
||
return $this->recordData;
|
||
}
|
||
|
||
/**
|
||
* 余额变动消息通知
|
||
*/
|
||
private function sendMessage()
|
||
{
|
||
date_default_timezone_set('PRC');
|
||
if ($this->change_value == 0) {
|
||
//余额变动为0，无需发送消息
|
||
return;
|
||
}
|
||
$balanceNotice = new BalanceChangeNotice($this->memberModel, $this->new_value, $this->change_value, $this->source);
|
||
$balanceNotice->sendMessage();
|
||
|
||
$this->balanceSet = \Setting::get('finance.balance');
|
||
//检查余额是否达到下限
|
||
|
||
if ($this->balanceSet['blance_floor'] > $this->new_value && $this->balanceSet['blance_floor_on'] == 1) {
|
||
$this->checkBalanceFloor();
|
||
}
|
||
return;
|
||
if ($this->change_value == 0) {
|
||
return;
|
||
}
|
||
|
||
$template_id = \Setting::get('shop.notice')['balance_change'];
|
||
\Log::info('余额变动通知', $template_id);
|
||
$params = [
|
||
['name' => '商城名称', 'value' => \Setting::get('shop.shop')['name']],
|
||
['name' => '昵称', 'value' => $this->memberModel->nickname],
|
||
['name' => '时间', 'value' => date('Y-m-d H:i', time())],
|
||
['name' => '余额变动金额', 'value' => $this->change_value],
|
||
['name' => '余额变动类型', 'value' => (new ConstService(''))->sourceComment()[$this->source]],
|
||
['name' => '变动后余额数值', 'value' => $this->new_value]
|
||
];
|
||
$news_link = MessageTemp::find($template_id)->news_link;
|
||
$news_link = $news_link ?: '';
|
||
event(new MessageEvent($this->memberModel->uid, $template_id, $params, $url = $news_link));
|
||
|
||
//小程序消息通知
|
||
$is_open = MinAppTemplateMessage::getTitle('账户余额提醒');
|
||
if (!$is_open->is_open) {
|
||
return;
|
||
}
|
||
$miniParams = [
|
||
'keyword1' => ['value' => $this->memberModel->nickname],// 会员昵称
|
||
'keyword2' => ['value' => date('Y-m-d H:i', time())],//变动时间
|
||
'keyword3' => ['value' => $this->change_value],// 变动金额
|
||
'keyword4' => ['value' => $this->new_value],// 当前余额
|
||
'keyword5' => ['value' => (new ConstService(''))->sourceComment()[$this->source]],// 变动类型
|
||
];
|
||
$this->miniSendToShops($is_open->template_id, $miniParams, $this->memberModel->uid);
|
||
}
|
||
|
||
protected function miniSendToShops($templateId, $msg, $uid)
|
||
{
|
||
if (empty($templateId)) {
|
||
return;
|
||
}
|
||
|
||
\Log::debug('===============', [$templateId]);
|
||
MsgService::MiniNotice($templateId, $msg, $uid);
|
||
}
|
||
|
||
//余额下限消息通知
|
||
public function checkBalanceFloor()
|
||
{
|
||
if (!$this->balanceSet['blance_floor']) {
|
||
return true;
|
||
}
|
||
|
||
//未设置直接报错
|
||
if (empty($this->balanceSet['balance_message_type'])) {
|
||
return true;
|
||
}
|
||
|
||
//只有三种情况
|
||
if (in_array($this->balanceSet['balance_message_type'], [1, 2, 3]) != true) {
|
||
return true;
|
||
}
|
||
|
||
//指定会员等级
|
||
if ($this->balanceSet['balance_message_type'] == 2) {
|
||
if ($this->memberModel->yzMember->level_id != $this->balanceSet['level_limit']) {
|
||
return true;
|
||
}
|
||
}
|
||
|
||
//指定会员
|
||
if ($this->balanceSet['balance_message_type'] == 1) {
|
||
if (in_array($this->memberModel->uid, explode(',', $this->balanceSet['uids'])) != true) {
|
||
return true;
|
||
}
|
||
}
|
||
|
||
//指定会员分组
|
||
if ($this->balanceSet['balance_message_type'] == 3) {
|
||
if ($this->memberModel->yzMember->group_id != $this->balanceSet['group_type']) {
|
||
return true;
|
||
}
|
||
}
|
||
|
||
event(new MemberBalanceDeficiencyEvent($this->memberModel, $this->balanceSet, $this->new_value)); //会员余额不足事件
|
||
|
||
$template_id = \Setting::get('shop.notice')['balance_deficiency'];
|
||
if (!$template_id) {
|
||
return true;
|
||
}
|
||
$balanceNotice = new BalanceDeficiencyNotice($this->memberModel, $this->balanceSet, $this->new_value);
|
||
$balanceNotice->sendMessage();
|
||
// $params = [
|
||
// ['name' => '商城名称', 'value' => \Setting::get('shop.shop')['name']],
|
||
// ['name' => '昵称', 'value' => $this->memberModel->nickname],
|
||
// ['name' => '时间', 'value' => date('Y-m-d H:i', time())],
|
||
// ['name' => '通知额度', 'value' => $this->balanceSet['blance_floor']],
|
||
// ['name' => '当前余额', 'value' => $this->new_value]
|
||
// ];
|
||
// $news_link = MessageTemp::find($template_id)->news_link;
|
||
// $news_link = $news_link ?: '';
|
||
// event(new MessageEvent($this->memberModel->uid, $template_id, $params, $url = $news_link));
|
||
}
|
||
|
||
/**
|
||
* 充值短信
|
||
* @return bool
|
||
*/
|
||
private function sendSmsMessage()
|
||
{
|
||
try {
|
||
if ($this->source != 1) {
|
||
// \Log::debug('不是充值不需要发送短信');
|
||
return true;
|
||
}
|
||
|
||
if (!$this->memberModel->mobile) {
|
||
\Log::debug('未获取到该会员手机号');
|
||
return true;
|
||
}
|
||
$name = \Setting::get('shop.shop')['name'];
|
||
$data = array( // 短信模板中字段的值
|
||
'preshop' => $name,
|
||
'date' => date("m月d日", time()),
|
||
'amount' => $this->change_value,
|
||
'amounts' => $this->new_value,
|
||
);
|
||
$res = app('sms')->sendMemberRecharge($this->memberModel->mobile, $data);
|
||
if ($res['status'] == 0) {
|
||
\Log::debug('会员充值短信通知发送失败', $res['json']);
|
||
}
|
||
return true;
|
||
} catch (\Exception $e) {
|
||
\Log::debug($e->getMessage());
|
||
return true;
|
||
}
|
||
|
||
}
|
||
|
||
|
||
}
|