434 lines
19 KiB
PHP
434 lines
19 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace app\crm\service;
|
||
|
|
|
||
|
|
use app\common\model\StockOrderAccounts;
|
||
|
|
use app\common\model\StockOrderItemOptions;
|
||
|
|
use app\common\model\StockOrderItems;
|
||
|
|
use app\common\validate\StockOrdersValidate;
|
||
|
|
use app\common\traits\crud\CrudServiceTrait;
|
||
|
|
use app\common\model\StockOrders;
|
||
|
|
use app\common\model\SysCurrency;
|
||
|
|
use support\Request;
|
||
|
|
use app\common\model\User;
|
||
|
|
use support\exception\BusinessException;
|
||
|
|
use support\Db;
|
||
|
|
|
||
|
|
class StockOrdersService
|
||
|
|
{
|
||
|
|
|
||
|
|
use CrudServiceTrait;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 指定当前要操作的模型
|
||
|
|
*/
|
||
|
|
protected string $modelClass = StockOrders::class;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 验证器
|
||
|
|
*/
|
||
|
|
protected $validator = StockOrdersValidate::class;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取验证器
|
||
|
|
*/
|
||
|
|
public function getValidator()
|
||
|
|
{
|
||
|
|
return new $this->validator;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
protected function buildQueryConfig(Request $request, string $scene = 'index'): array
|
||
|
|
{
|
||
|
|
$p = $request->all();
|
||
|
|
|
||
|
|
$config = [];
|
||
|
|
$config['model'] = $this->modelClass;
|
||
|
|
switch ($scene) {
|
||
|
|
case 'index':
|
||
|
|
|
||
|
|
// ====== ====== 筛选 ====== ======
|
||
|
|
// 业务id
|
||
|
|
if (isset($p['salesperson_id']) && $p['salesperson_id']) {
|
||
|
|
$config['where']['salesperson_id'] = $p['salesperson_id'];
|
||
|
|
}
|
||
|
|
// 初、终版
|
||
|
|
$config['where']['is_final'] = $p['is_final'] ?? 0;
|
||
|
|
// 关键字
|
||
|
|
if (isset($p['keyword']) && $p['keyword']) {
|
||
|
|
$k = '%' . $p['keyword'] . '%';
|
||
|
|
foreach (['pi_no', 'order_no', 'customer_snapshot'] as $col) {
|
||
|
|
$config['orWhere'][] = [$col, 'like', $k];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$config['order']['id'] = 'desc';
|
||
|
|
|
||
|
|
$config['where']['salesperson_id'] = $request->user->uid;
|
||
|
|
break;
|
||
|
|
case 'print':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
break;
|
||
|
|
case 'show':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
|
||
|
|
$config['with'][] = 'items';
|
||
|
|
$config['with'][] = 'items.options';
|
||
|
|
$config['with'][] = 'items.moneyValues';
|
||
|
|
$config['with'][] = 'accounts';
|
||
|
|
$config['with'][] = 'moneyValues';
|
||
|
|
$config['with'][] = 'salesperson';
|
||
|
|
break;
|
||
|
|
case 'store':
|
||
|
|
break;
|
||
|
|
case 'update':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
break;
|
||
|
|
case 'destroy':
|
||
|
|
$config['where']['id'] = $p['id'];
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
return $config;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public function serviceStore(Request $request, array $data = [])
|
||
|
|
{
|
||
|
|
// 关联表较多，增加事务处理
|
||
|
|
return Db::transaction(function () use ($request, $data) {
|
||
|
|
$data = $this->preProcess('Store', $data, $request);
|
||
|
|
$dl = $this->getDataLimitFromRequest($request);
|
||
|
|
$created = $this->logicCreate($data, $dl); // 表1
|
||
|
|
|
||
|
|
// 车辆
|
||
|
|
$cifTotalAmount = 0;
|
||
|
|
$cifTotalAmountRate = 0;
|
||
|
|
$cifTotalAmountCurrency = 'CNY';
|
||
|
|
// $profit = 0;
|
||
|
|
foreach ($data['veh_list'] as $veh) {
|
||
|
|
$veh['order_id'] = $created->id;
|
||
|
|
|
||
|
|
// 唯一标识
|
||
|
|
$uniqueIdStr = "";
|
||
|
|
$uniqueIdStr .= $veh['sku_id'];
|
||
|
|
$uniqueIdStr .= $veh['model_snapshot'];
|
||
|
|
$uniqueIdStr .= $veh['color_interior_code'];
|
||
|
|
$uniqueIdStr .= $veh['color_exterior_code'];
|
||
|
|
$uniqueIdStr .= $veh['mileage'];
|
||
|
|
$uniqueIdStr .= json($veh['modify_list']);
|
||
|
|
$veh['unique_id'] = md5($uniqueIdStr);
|
||
|
|
$item = StockOrderItems::create($veh); // 表2
|
||
|
|
|
||
|
|
// 金额 // 表3
|
||
|
|
// $item->addMoney('official_price', $veh['official_price']['currency'], $veh['official_price']['amount'], $veh['official_price']['rate'], '官方指导价');
|
||
|
|
// $item->addMoney('discount_price', $veh['discount_price']['currency'], $veh['discount_price']['amount'], $veh['discount_price']['rate'], '优惠价');
|
||
|
|
if ($veh['unit_price']['amount']) {
|
||
|
|
$item->addMoney('unit_price', $veh['unit_price']['currency'], $veh['unit_price']['amount'], $veh['unit_price']['rate'], '单价');
|
||
|
|
}
|
||
|
|
if ($veh['total_price']['amount']) {
|
||
|
|
$item->addMoney('total_price', $veh['total_price']['currency'], $veh['total_price']['amount'], $veh['total_price']['rate'], '总价');
|
||
|
|
}
|
||
|
|
if ($veh['handling_fee']['amount']) {
|
||
|
|
$item->addMoney('handling_fee', $veh['handling_fee']['currency'], $veh['handling_fee']['amount'], $veh['handling_fee']['rate'], '手续费');
|
||
|
|
}
|
||
|
|
if ($veh['fob_transport_fee']['amount']) {
|
||
|
|
$item->addMoney('fob_transport_fee', $veh['fob_transport_fee']['currency'], $veh['fob_transport_fee']['amount'], $veh['fob_transport_fee']['rate'], 'FOB运输费');
|
||
|
|
}
|
||
|
|
if ($veh['port_misc_fee']['amount']) {
|
||
|
|
$item->addMoney('port_misc_fee', $veh['port_misc_fee']['currency'], $veh['port_misc_fee']['amount'], $veh['port_misc_fee']['rate'], '港杂');
|
||
|
|
}
|
||
|
|
if ($veh['retrofit_fee']['amount']) {
|
||
|
|
$item->addMoney('retrofit_fee', $veh['retrofit_fee']['currency'], $veh['retrofit_fee']['amount'], $veh['retrofit_fee']['rate'], '改装费');
|
||
|
|
}
|
||
|
|
|
||
|
|
// 二手车 or 新车
|
||
|
|
if ($veh['mileage'] > 0) {
|
||
|
|
if ($veh['listing_price']['amount']) {
|
||
|
|
$item->addMoney('listing_price', $veh['listing_price']['currency'], $veh['listing_price']['amount'], $veh['listing_price']['rate'], '二手挂牌价');
|
||
|
|
}
|
||
|
|
if ($veh['reduction_price']['amount']) {
|
||
|
|
$item->addMoney('reduction_price', $veh['reduction_price']['currency'], $veh['reduction_price']['amount'], $veh['reduction_price']['rate'], '二手减价');
|
||
|
|
}
|
||
|
|
|
||
|
|
$ttPrice = ($veh['listing_price']['amount'] / $created->contract_exchange_rate);
|
||
|
|
$ddPrice = $veh['reduction_price']['amount'];
|
||
|
|
} else {
|
||
|
|
if ($veh['official_price']['amount']) {
|
||
|
|
$item->addMoney('official_price', $veh['official_price']['currency'], $veh['official_price']['amount'], $veh['official_price']['rate'], '官方指导价');
|
||
|
|
}
|
||
|
|
if ($veh['discount_price']['amount'] ) {
|
||
|
|
$item->addMoney('discount_price', $veh['discount_price']['currency'], $veh['discount_price']['amount'], $veh['discount_price']['rate'], '优惠价');
|
||
|
|
}
|
||
|
|
|
||
|
|
$ttPrice = ($veh['official_price']['amount'] / $created->contract_exchange_rate);
|
||
|
|
$ddPrice = $veh['discount_price']['amount'];
|
||
|
|
}
|
||
|
|
|
||
|
|
// 利润
|
||
|
|
$profit = (float)$veh['unit_price']['amount'] - (float)$ttPrice - (float)$ddPrice - (float)$veh['handling_fee']['amount'] - (float)$veh['fob_transport_fee']['amount'] - (float)$veh['port_misc_fee']['amount'] - (float)$veh['retrofit_fee']['amount'];
|
||
|
|
$item->addMoney('profit', $veh['unit_price']['currency'], $profit, $veh['unit_price']['rate'], '利润');
|
||
|
|
|
||
|
|
// cif_total_amount
|
||
|
|
$cifTotalAmount += $veh['total_price']['amount'];
|
||
|
|
$cifTotalAmountRate = $veh['retrofit_fee']['rate'];
|
||
|
|
$cifTotalAmountCurrency = $veh['retrofit_fee']['currency'];
|
||
|
|
|
||
|
|
// 改装
|
||
|
|
if (count($veh['modify_list']) > 0) {
|
||
|
|
foreach ($veh['modify_list'] as $modify) {
|
||
|
|
$modify['order_item_id'] = $item->id;
|
||
|
|
StockOrderItemOptions::create($modify); // 表4
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// 计算&&插入 表1
|
||
|
|
$created->addMoney('cif_total_amount', $cifTotalAmountCurrency, $cifTotalAmount, $cifTotalAmountRate, '合计到岸价');
|
||
|
|
|
||
|
|
// 账户
|
||
|
|
if (count($data['account_list']) > 0) {
|
||
|
|
foreach ($data['account_list'] as $account) {
|
||
|
|
$account['order_id'] = $created->id;
|
||
|
|
$account['remit_date'] = strtotime($account['remit_date']);
|
||
|
|
StockOrderAccounts::create($account); // 表5
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return $this->postProcess('Store', $created);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
public function beforeServiceStore($data, Request $request)
|
||
|
|
{
|
||
|
|
$userId = $request->user->uid;
|
||
|
|
|
||
|
|
$data['order_no'] = generateStockNo();
|
||
|
|
$data['biz_date'] = strtotime($data['biz_date']);
|
||
|
|
$data['eta_ship_date'] = strtotime($data['eta_ship_date']);
|
||
|
|
$data['latest_arrival_date'] = strtotime($data['latest_arrival_date']);
|
||
|
|
$data['salesperson_id'] = $userId;
|
||
|
|
$data['salesperson_snapshot'] = User::where('id', $userId)->value('name') ?? '';
|
||
|
|
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function afterServiceStore($res)
|
||
|
|
{
|
||
|
|
// 处理原单
|
||
|
|
if ($res->is_final == 1 && $res->object_id > 0) {
|
||
|
|
$order = StockOrders::find($res->object_id);
|
||
|
|
$order->is_use = 1;
|
||
|
|
$order->object_id = $res->id;
|
||
|
|
if (!$order->save()) {
|
||
|
|
flg('备货单【'.$order->order_no.'】创建终版成功，但更新原单失败');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
// 启动审批
|
||
|
|
$appro = new \app\common\utils\approval\service\ApprovalFlowService();
|
||
|
|
$result = $appro->start('stock_order_flow', 'stock_orders', $res->id, $res->toArray(), $res->salesperson_id);
|
||
|
|
var_dump($result);
|
||
|
|
|
||
|
|
// 异步生成pdf文件
|
||
|
|
\Webman\RedisQueue\Redis::send('stock-order-pdf', ['id'=>$res->id]);
|
||
|
|
return $res;
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public function createdPdfFile($id)
|
||
|
|
{
|
||
|
|
$config = [];
|
||
|
|
$config['model'] = $this->modelClass;
|
||
|
|
$config['where']['id'] = $id;
|
||
|
|
$config['with'][] = 'items';
|
||
|
|
$config['with'][] = 'items.options';
|
||
|
|
$config['with'][] = 'items.moneyValues';
|
||
|
|
$config['with'][] = 'accounts';
|
||
|
|
$config['with'][] = 'moneyValues';
|
||
|
|
$config['with'][] = 'salesperson';
|
||
|
|
$item = $this->logicShow($config);
|
||
|
|
$pdfData = $this->pdfData($item);
|
||
|
|
|
||
|
|
// 渲染模板为最终HTML
|
||
|
|
$tplPath = app_path('common/utils/pdf/template/stockOrder.stub');
|
||
|
|
$html = \app\common\utils\pdf\service\PdfHelper::render($tplPath, ['data' => $pdfData]);
|
||
|
|
|
||
|
|
// 生成PDF
|
||
|
|
$driver = new \app\common\utils\pdf\service\MpdfDriver();
|
||
|
|
$pdfBin = $driver->htmlToPdf($html);
|
||
|
|
|
||
|
|
// 存储
|
||
|
|
$dir = public_path('pdf').'/';
|
||
|
|
$fileName = ($pdfData['order_no'] ?? date('YmdHis')) . '.pdf';
|
||
|
|
|
||
|
|
// 本地保存
|
||
|
|
\app\common\utils\pdf\service\PdfStorage::saveBinary(
|
||
|
|
$pdfBin,
|
||
|
|
$dir,
|
||
|
|
$fileName
|
||
|
|
);
|
||
|
|
|
||
|
|
// // 在线预览
|
||
|
|
// return new \support\Response(200, [
|
||
|
|
// 'Content-Type' => 'application/pdf',
|
||
|
|
// 'Content-Disposition' => 'inline; filename="stock-order.pdf"',
|
||
|
|
// ], $pdfBin);
|
||
|
|
|
||
|
|
// $url = [
|
||
|
|
// 'file_name' => $fileName,
|
||
|
|
// 'file_url' => getenv('MAIN_DOMAIN').'/pdf/'.$fileName
|
||
|
|
// ];
|
||
|
|
|
||
|
|
// 上传云端
|
||
|
|
$param = [
|
||
|
|
'path' => $dir . $fileName,
|
||
|
|
'scene' => 'stock_orders',
|
||
|
|
'category' => 'pdf',
|
||
|
|
'original_name' => $fileName
|
||
|
|
];
|
||
|
|
$up = new \app\common\service\UploadService();
|
||
|
|
$res = $up->uploadLocalFile($param);
|
||
|
|
|
||
|
|
@unlink($dir . $fileName);
|
||
|
|
|
||
|
|
// 更新文件地址
|
||
|
|
$item->file_url = $res['file_name'];
|
||
|
|
$item->save();
|
||
|
|
|
||
|
|
return $res;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function servicePrint(Request $request)
|
||
|
|
{
|
||
|
|
$config = $this->buildQueryConfig($request, 'show');
|
||
|
|
$item = $this->logicShow($config);
|
||
|
|
return $this->postProcess('Print', $item);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
public function pdfData($item)
|
||
|
|
{
|
||
|
|
$vehList = [];
|
||
|
|
$index = 0;
|
||
|
|
foreach ($item->items as $k => $v) {
|
||
|
|
// 存在则数量加1
|
||
|
|
if (count($vehList) > 0 && isset($vehList[$v->unique_id])) {
|
||
|
|
$vehList[$v->unique_id]['num'] += 1;
|
||
|
|
$vehList[$v->unique_id]['total_price'] += $vehList[$v->unique_id]['unit_price'];
|
||
|
|
$vehList[$v->unique_id]['total_price_text'] = $vehList[$v->unique_id]['total_price_symbol'].number_format($vehList[$v->unique_id]['total_price'], 2, '.', ',');
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
$index += 1;
|
||
|
|
// 处理金额
|
||
|
|
$mv = [];
|
||
|
|
foreach ($v->moneyValues as $money) {
|
||
|
|
$mv[$money->field] = [
|
||
|
|
'currency' => $money->currency,
|
||
|
|
'amount' => $money->amount,
|
||
|
|
'rate' => $money->exchange_rate,
|
||
|
|
'currency_symbol' => SysCurrency::where('currency_code', $money->currency)->value('currency_symbol'),
|
||
|
|
];
|
||
|
|
}
|
||
|
|
// 处理改装
|
||
|
|
$mfy = '';
|
||
|
|
foreach ($v->options as $my) {
|
||
|
|
$mfy .= $my->option_name_snapshot.' ';
|
||
|
|
}
|
||
|
|
|
||
|
|
// 处理结果集
|
||
|
|
$vehList[$v->unique_id] = [
|
||
|
|
'index' => $index,
|
||
|
|
'model_snapshot' => $v->model_snapshot,
|
||
|
|
'color_interior_snapshot' => $v->color_interior_snapshot,
|
||
|
|
'color_exterior_snapshot' => $v->color_exterior_snapshot,
|
||
|
|
'num' => 1,
|
||
|
|
'modify' => $mfy,
|
||
|
|
'mileage' => $v->mileage,
|
||
|
|
'unit_price' => $mv['unit_price']['amount'],
|
||
|
|
'total_price' => $mv['total_price']['amount'],
|
||
|
|
'unit_price_symbol' => $mv['unit_price']['currency_symbol'],
|
||
|
|
'total_price_symbol' => $mv['total_price']['currency_symbol'],
|
||
|
|
'unit_price_text' => $mv['unit_price']['currency_symbol'].number_format($mv['unit_price']['amount'], 2, '.', ','),
|
||
|
|
'total_price_text' => $mv['total_price']['currency_symbol'].number_format($mv['total_price']['amount'], 2, '.', ',')
|
||
|
|
];
|
||
|
|
|
||
|
|
// 根据里程处理 新车or二手车
|
||
|
|
if ($v->mileage > 0) {
|
||
|
|
if (isset($mv['reduction_price'])) {
|
||
|
|
$vehList[$v->unique_id]['reduction_price'] = $mv['reduction_price']['amount'];
|
||
|
|
$vehList[$v->unique_id]['reduction_price_symbol'] = $mv['reduction_price']['currency_symbol'];
|
||
|
|
$vehList[$v->unique_id]['reduction_price_text'] = $mv['reduction_price']['currency_symbol'].number_format($mv['reduction_price']['amount'], 2, '.', ',');
|
||
|
|
}
|
||
|
|
$vehList[$v->unique_id]['listing_price'] = $mv['listing_price']['amount'];
|
||
|
|
$vehList[$v->unique_id]['listing_price_symbol'] = $mv['listing_price']['currency_symbol'];
|
||
|
|
$vehList[$v->unique_id]['listing_price_text'] = $mv['listing_price']['currency_symbol'].number_format($mv['listing_price']['amount'], 2, '.', ',');
|
||
|
|
} else {
|
||
|
|
if (isset($mv['discount_price'])) {
|
||
|
|
$vehList[$v->unique_id]['discount_price'] = $mv['discount_price']['amount'];
|
||
|
|
$vehList[$v->unique_id]['discount_price_symbol'] = $mv['discount_price']['currency_symbol'];
|
||
|
|
$vehList[$v->unique_id]['discount_price_text'] = $mv['discount_price']['currency_symbol'].number_format($mv['discount_price']['amount'], 2, '.', ',');
|
||
|
|
}
|
||
|
|
$vehList[$v->unique_id]['official_price'] = $mv['official_price']['amount'];
|
||
|
|
$vehList[$v->unique_id]['official_price_symbol'] = $mv['official_price']['currency_symbol'];
|
||
|
|
$vehList[$v->unique_id]['official_price_text'] = $mv['official_price']['currency_symbol'].number_format($mv['official_price']['amount'], 2, '.', ',');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$accList = [];
|
||
|
|
$accIndex = 1;
|
||
|
|
foreach ($item->accounts as $k => $v) {
|
||
|
|
$accList[] = [
|
||
|
|
'index' => '收款'.$k + 1,
|
||
|
|
'remit_country_name_snapshot' => $v->remit_country_name_snapshot,
|
||
|
|
'remit_date' => date('Y-m-d', $v->remit_date),
|
||
|
|
'currency_name_snapshot' => $v->currency_name_snapshot,
|
||
|
|
'account_name_snapshot' => $v->account_name_snapshot,
|
||
|
|
'remitter_name' => $v->remitter_name,
|
||
|
|
'amount' => $v->amount,
|
||
|
|
];
|
||
|
|
$accIndex += 1;
|
||
|
|
}
|
||
|
|
|
||
|
|
$cifTotalAmount = 0.00;
|
||
|
|
if ($item->moneyValues) {
|
||
|
|
$cifTotalAmountSysboml = SysCurrency::where('currency_code', $item->moneyValues->currency)->value('currency_symbol');
|
||
|
|
$cifTotalAmount = $cifTotalAmountSysboml.sprintf("%.2f", $item->moneyValues->amount, $item->moneyValues->exchange_rate);
|
||
|
|
}
|
||
|
|
|
||
|
|
$veh = [
|
||
|
|
'order_no' => $item->order_no,
|
||
|
|
'salesperson_snapshot' => $item->salesperson_snapshot,
|
||
|
|
// 'sign_img' => $item->salesperson->sign_img,
|
||
|
|
'sign_img_url' => (!empty($item->salesperson->sign_img))?(new \app\common\service\OssService)->generatePrivateUrl($item->salesperson->sign_img):'',
|
||
|
|
'created_at' => date('Y-m-d', strtotime($item->created_at)),
|
||
|
|
|
||
|
|
'pi_no' => $item->pi_no,
|
||
|
|
'biz_date' => date('Y-m-d', $item->biz_date),
|
||
|
|
'clearance_country_snapshot' => $item->clearance_country_snapshot,
|
||
|
|
'customer_source_snapshot' => $item->customer_source_snapshot,
|
||
|
|
'customer_snapshot' => $item->customer_snapshot,
|
||
|
|
'customer_country_snapshot' => $item->customer_country_snapshot,
|
||
|
|
|
||
|
|
// 订单项
|
||
|
|
'veh_list' => $vehList,
|
||
|
|
|
||
|
|
'contract_exchange_rate' => $item->contract_exchange_rate,
|
||
|
|
'cif_total_amount' => $item->cif_total_amount,
|
||
|
|
|
||
|
|
'declarant_name' => $item->declarant_name,
|
||
|
|
'eta_ship_date' => date('Y-m-d', $item->eta_ship_date),
|
||
|
|
'shipping_method_snapshot' => $item->shipping_method_snapshot,
|
||
|
|
'domestic_port_snapshot' => $item->domestic_port_snapshot,
|
||
|
|
'trade_term_snapshot' => $item->trade_term_snapshot,
|
||
|
|
'clearance_port_snapshot' => $item->clearance_port_snapshot,
|
||
|
|
'latest_arrival_date' => date('Y-m-d', $item->latest_arrival_date),
|
||
|
|
|
||
|
|
// 账户
|
||
|
|
'account_list' => $accList,
|
||
|
|
'acc_index' => $accIndex,
|
||
|
|
'cif_total_amount' => $cifTotalAmount
|
||
|
|
];
|
||
|
|
|
||
|
|
return $veh;
|
||
|
|
}
|
||
|
|
}
|