<?php
|
/**
|
* Created by PhpStorm.
|
* User: 风哀伤
|
* Date: 2019/5/14
|
* Time: 10:01
|
* @copyright: ©2019 浙江禾匠信息科技
|
* @link: http://www.zjhejiang.com
|
*/
|
|
namespace app\jobs;
|
|
|
use app\models\Mall;
|
use app\models\Share;
|
use app\models\ShareOrder;
|
use yii\base\BaseObject;
|
use yii\queue\JobInterface;
|
|
/**
|
* @property Mall $mall
|
* @property ShareOrder $shareOrder
|
* 分销订单总数：
|
* 按订单来算即一个订单最多算一个分销订单；
|
* 取消的订单不算分销订单；
|
* 当订单中有商品发生退款时，
|
* 若订单中其他商品还有分销商品则仍算一个分销订单，
|
* 若没有则不算分销订单；
|
* ---------------------
|
* 分销总佣金：
|
* 订单取消或退款时，需要将相应商品的佣金减去；
|
*/
|
class ChangeShareOrderJob extends BaseJob implements JobInterface
|
{
|
public $mall;
|
public $shareOrder;
|
public $before;
|
public $order;
|
public $beforeList;
|
public $type = 'add';
|
private $allOrder; // 是否计算总订单
|
|
public function execute($queue)
|
{
|
$this->setRequest();
|
\Yii::$app->setMall(Mall::findOne($this->mall->id));
|
$t = \Yii::$app->db->beginTransaction();
|
try {
|
$this->search('first_parent_id', 'first_price');
|
$this->search('second_parent_id', 'second_price');
|
$this->search('third_parent_id', 'third_price');
|
$t->commit();
|
} catch (\Exception $exception) {
|
$t->rollBack();
|
\Yii::error('分销记录：');
|
\Yii::error($exception);
|
}
|
}
|
|
/**
|
* @param $idKey
|
* @param $priceKey
|
* @throws \Exception
|
*/
|
public function search($idKey, $priceKey)
|
{
|
if ($this->order) {
|
$shareOrderList = ShareOrder::find()->where([
|
'mall_id' => $this->order->mall_id,
|
'order_id' => $this->order->id,
|
'user_id' => $this->order->user_id,
|
'is_delete' => 0,
|
])->all();
|
$beforeList = $this->beforeList;
|
$this->allOrder = true;
|
} else {
|
$shareOrderList = [$this->shareOrder];
|
$beforeList = [$this->before];
|
$other = ShareOrder::find()->where([
|
'mall_id' => $this->order->mall_id,
|
'order_id' => $this->order->id,
|
'user_id' => $this->order->user_id,
|
'is_delete' => 0,
|
])->andWhere(['!=', 'id', $this->shareOrder->id])->all();
|
if (empty($other)) {
|
// 没有其他的分销订单，需要计算总订单
|
$this->allOrder = true;
|
} else {
|
$this->allOrder = false;
|
}
|
}
|
foreach ($shareOrderList as $shareOrder) {
|
if ($shareOrder[$idKey]) {
|
if ($this->type === 'add') {
|
$beforeUserId = 0;
|
$beforeMoney = 0;
|
if (!empty($beforeList)) {
|
$before = null;
|
foreach ($beforeList as $before) {
|
if ($before['id'] == $shareOrder['id']) {
|
$beforeUserId = $before[$idKey];
|
$beforeMoney = $before[$priceKey];
|
break;
|
}
|
}
|
}
|
$this->add($shareOrder[$idKey], $shareOrder[$priceKey], $beforeUserId, $beforeMoney);
|
} elseif ($this->type === 'sub') {
|
$this->sub($shareOrder[$idKey], $shareOrder[$priceKey]);
|
} else {
|
throw new \Exception('错误的状态');
|
}
|
}
|
}
|
}
|
|
/**
|
* @param $afterUserId
|
* @param $afterMoney
|
* @param int $beforeUserId
|
* @param int $beforeMoney
|
* @throws \Exception
|
* 增加分销商分销订单总数及总佣金
|
*/
|
public function add($afterUserId, $afterMoney, $beforeUserId = 0, $beforeMoney = 0)
|
{
|
$after = Share::findOne(['user_id' => $afterUserId]);
|
if ($beforeUserId) {
|
if ($afterUserId == $beforeUserId) {
|
$afterMoney = floatval($after->all_money) + $afterMoney - $beforeMoney;
|
} else {
|
$before = Share::findOne(['user_id' => $beforeUserId]);
|
$beforeMoney = floatval($before->all_money) - min(floatval($before->all_money), $beforeMoney);
|
$before->all_money = price_format($beforeMoney);
|
if ($this->allOrder) {
|
$before->all_order = intval($before->all_order - min($before->all_order, 1));
|
$after->all_order += 1;
|
}
|
if (!$before->save()) {
|
throw new \Exception('分销保存出错');
|
}
|
$afterMoney = floatval($after->all_money) + $afterMoney;
|
}
|
} else {
|
if ($this->allOrder) {
|
$after->all_order += 1;
|
}
|
$afterMoney = floatval($after->all_money) + $afterMoney;
|
}
|
$after->all_money = price_format($afterMoney);
|
if (!$after->save()) {
|
throw new \Exception('分销保存出错');
|
}
|
$this->allOrder = false;
|
}
|
|
/**
|
* @param $userId
|
* @param $money
|
* @throws \Exception
|
* 减少分销商分销订单总数及总佣金
|
*/
|
public function sub($userId, $money)
|
{
|
$before = Share::findOne(['user_id' => $userId]);
|
$beforeMoney = floatval($before->all_money) - min(floatval($before->all_money), $money);
|
$before->all_money = price_format($beforeMoney);
|
if ($this->allOrder) {
|
$before->all_order = intval($before->all_order - min($before->all_order, 1));
|
}
|
if (!$before->save()) {
|
throw new \Exception('分销保存出错');
|
}
|
$this->allOrder = false;
|
}
|
}
|
