120 lines
3.8 KiB
PHP
120 lines
3.8 KiB
PHP
<?php
|
||
/**
|
||
* Author:
|
||
* Date: 2018/9/19
|
||
* Time: 下午3:37
|
||
*/
|
||
|
||
namespace app\Jobs;
|
||
|
||
|
||
use app\backend\modules\charts\models\OrderIncomeCount;
|
||
use app\common\events\order\CreatedOrderPluginBonusEvent;
|
||
use app\common\models\Order;
|
||
use app\common\models\order\OrderPluginBonus;
|
||
use Illuminate\Bus\Queueable;
|
||
use Illuminate\Queue\SerializesModels;
|
||
use Illuminate\Queue\InteractsWithQueue;
|
||
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
use Illuminate\Support\Facades\DB;
|
||
use Illuminate\Support\Facades\Schema;
|
||
|
||
class OrderBonusJob implements ShouldQueue
|
||
{
|
||
use InteractsWithQueue, Queueable, SerializesModels;
|
||
|
||
protected $tableName;
|
||
protected $code;
|
||
protected $foreignKey;
|
||
protected $localKey;
|
||
protected $amountColumn;
|
||
protected $orderModel;
|
||
protected $totalDividend;
|
||
protected $condition;
|
||
|
||
public function __construct($tableName, $code, $foreignKey, $localKey, $amountColumn, $orderModel, $totalDividend = 0, $condition = null)
|
||
{
|
||
//跟订单使用同个队列运行，防止产生相同的orderIncome
|
||
$queueCount = Order::queueCount();
|
||
if ($queueCount) {
|
||
$this->queue = 'order:' . ($orderModel->id % Order::queueCount());
|
||
}
|
||
$this->tableName = $tableName;
|
||
$this->code = $code;
|
||
$this->foreignKey = $foreignKey;
|
||
$this->localKey = $localKey;
|
||
$this->amountColumn = $amountColumn;
|
||
$this->orderModel = Order::find($orderModel->id);
|
||
$this->totalDividend = $totalDividend;
|
||
$this->condition = $condition;
|
||
}
|
||
|
||
public function handle()
|
||
{
|
||
// 验证表是否存在
|
||
$exists_table = Schema::hasTable($this->tableName);
|
||
if (!$exists_table) {
|
||
return;
|
||
}
|
||
$build = DB::table($this->tableName)
|
||
->select()
|
||
->where($this->foreignKey, (string)$this->orderModel[$this->localKey]);
|
||
|
||
//分红条件
|
||
if ($this->condition) {
|
||
$build = $build->where($this->condition);
|
||
}
|
||
// 分红记录IDs
|
||
$ids = $build->pluck('id');
|
||
// 分红总和
|
||
$sum = $build->sum($this->amountColumn);
|
||
if ($sum == 0) {
|
||
return;
|
||
}
|
||
|
||
$undividend = 0;
|
||
if ($this->totalDividend) {
|
||
$undividend = $this->totalDividend - $sum;
|
||
}
|
||
\Log::info($this->code . '分红插入表');
|
||
|
||
// 存入订单插件分红记录表
|
||
$model = OrderPluginBonus::addRow([
|
||
'order_id' => $this->orderModel->id,
|
||
'uniacid' => $this->orderModel->uniacid,
|
||
'table_name' => $this->tableName,
|
||
'ids' => $ids,
|
||
'code' => $this->code,
|
||
'amount' => $sum,
|
||
'undividend' => $undividend,
|
||
'status' => 0,
|
||
'price' => $this->orderModel->price,
|
||
'member_id' => $this->orderModel->uid,
|
||
'order_sn' => $this->orderModel->order_sn,
|
||
]);
|
||
|
||
|
||
if ($model) {
|
||
$this->addCount($sum, $undividend);
|
||
}
|
||
|
||
// 暂时不用, 门店利润 在 门店订单结算时重新计算, 各个插件产生分红的事件监听不同.
|
||
// 如果后期插件统一事件产生分红,再启用此事件
|
||
//event(new CreatedOrderPluginBonusEvent($model));
|
||
}
|
||
|
||
public function addCount($sum, $undividend)
|
||
{
|
||
// $count = 1;
|
||
$field = str_replace('-', '_', $this->code);
|
||
$order_income = OrderIncomeCount::where('order_id', $this->orderModel->id)->first();
|
||
|
||
if (!$order_income) {
|
||
\Log::debug('订单分红统计，缺少订单ID' . $this->orderModel->id . '的数据');
|
||
$order_income = (new OrderCountContentJob($this->orderModel))->handle();
|
||
}
|
||
$order_income->$field = $sum;
|
||
$order_income->undividend += $undividend;
|
||
$order_income->save();
|
||
}
|
||
} |