|
|
@@ -7,6 +7,7 @@ use App\OrderIssue;
|
|
|
use App\OrderIssueType;
|
|
|
use App\Traits\ServiceAppAop;
|
|
|
use App\WorkOrder;
|
|
|
+use App\WorkOrderType;
|
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
|
use Illuminate\Support\Carbon;
|
|
|
use Illuminate\Support\Facades\Auth;
|
|
|
@@ -17,70 +18,81 @@ class WorkOrderService
|
|
|
|
|
|
protected $modelClass = WorkOrder::class;
|
|
|
|
|
|
+ protected $work_type_relation = [
|
|
|
+ '拦截' => '订单拦截',
|
|
|
+ '信息更改' => '订单收件信息修改',
|
|
|
+ '其他' => '订单其他异常',
|
|
|
+ '快递异常' => '订单快递异常',
|
|
|
+ '错漏发' => '快递错漏发',
|
|
|
+ '破损' => '快递破损',
|
|
|
+ ];
|
|
|
+
|
|
|
/**
|
|
|
- * 订单拦截 工单
|
|
|
- * @param $workOrderType
|
|
|
- * @param $uniquelyTags
|
|
|
- * @param int $status
|
|
|
- * @param int $grad
|
|
|
- * @return array
|
|
|
+ * 生成工单
|
|
|
+ * @param $params
|
|
|
+ * @return array|bool[]
|
|
|
*/
|
|
|
- public function interceptOrder($workOrderType, $uniquelyTags, int $grad = 1, int $status = 1): array
|
|
|
+ public function build($params): array
|
|
|
{
|
|
|
- app("OrderService")->syncOrderByCodes($uniquelyTags); // 同步订单
|
|
|
- $creator_id = Auth::user()['id']; // 创建人
|
|
|
- if (is_string($uniquelyTags)) $uniquelyTags = [$uniquelyTags];
|
|
|
- if (!$uniquelyTags) return ['success' => false, 'message' => '订单号为空'];
|
|
|
- $orders = Order::query()->whereIn('code', $uniquelyTags)->get();
|
|
|
- $created_at = Carbon::now();
|
|
|
- foreach ($uniquelyTags as $uniquelyTag) {
|
|
|
- $order = $orders->where('code', $uniquelyTag)->first();
|
|
|
- $params[] = [
|
|
|
+ $types = [];
|
|
|
+ $work_order_types = [];
|
|
|
+ $data = Carbon::now();
|
|
|
+ $creator_id = Auth::user()['id'];
|
|
|
+ $parent = WorkOrderType::query()->firstOrCreate(['name' => '订单','prent_id' => 0,'level' => 1]);
|
|
|
+ foreach ($params as $param) {
|
|
|
+ $order = Order::query()->where('code',$param['order_no'])->first();
|
|
|
+ $type_name = $param['order_issue_type'];
|
|
|
+ if (!$param['order_issue_type']) {
|
|
|
+ $order_issue_type_id = 0;
|
|
|
+ $work_order_type_id = 0;
|
|
|
+ } else {
|
|
|
+ if (!array_key_exists($type_name,$types)){
|
|
|
+ $types[$type_name] = OrderIssueType::query()->where('name',$type_name)->first();
|
|
|
+ $work_order_type_name = $this->work_type_relation[$type_name] ?? $type_name;
|
|
|
+ $work_order_types[$type_name] = WorkOrderType::query()->firstOrCreate(
|
|
|
+ ['name' => $work_order_type_name],
|
|
|
+ ['prent_id' =>$parent['id'],'table_name' => 'orders','level' => 2]
|
|
|
+ );
|
|
|
+ }
|
|
|
+ $order_issue_type_id = $types[$type_name]['id'] ?? 0;
|
|
|
+ $work_order_type_id = $work_order_types[$type_name]['id'] ?? 0;
|
|
|
+ }
|
|
|
+ switch ($type_name) {
|
|
|
+ case '拦截':
|
|
|
+ $remark = "拦截订单:".$order->client_code ?? '';
|
|
|
+ break;
|
|
|
+ case '信息更改':
|
|
|
+ case '其他':
|
|
|
+ case '快递异常':
|
|
|
+ case '错漏发':
|
|
|
+ case '破损':
|
|
|
+ $remark = $param['remark'] ?? '';
|
|
|
+ break;
|
|
|
+ default:
|
|
|
+ $work_order_type_id = 0;
|
|
|
+ $remark = $param['remark'] ?? '';
|
|
|
+ $order_issue_type_id = 0;
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ $inner_params[] = [
|
|
|
+ 'order_id' => $order['id'],
|
|
|
'creator_id' => $creator_id,
|
|
|
- 'work_order_type_id' => $workOrderType->id,
|
|
|
- 'grad' => $grad,
|
|
|
- 'remark' => "{$workOrderType->name}:{$uniquelyTag}",
|
|
|
- 'outer_table_name' => $workOrderType->table_name ?? 'orders',
|
|
|
- 'order_id' => $order->id ?? '',
|
|
|
- 'uniquely_tag' => $uniquelyTag,
|
|
|
- 'status' => $status,
|
|
|
- 'created_at' => $created_at,
|
|
|
+ 'work_order_type_id' => $work_order_type_id ?? 0,
|
|
|
+ 'grad' => $param['grad'] ?? 1,
|
|
|
+ 'remark' => $remark,
|
|
|
+ 'outer_table_name' => 'orders',
|
|
|
+ 'order_issue_type_id' => $order_issue_type_id ?? 0,
|
|
|
+ 'uniquely_tag' => $order['code'] ?? null,
|
|
|
+ 'status' => 1,
|
|
|
+ 'created_at' => $data,
|
|
|
+ 'updated_at' => $data,
|
|
|
];
|
|
|
}
|
|
|
- if (isset($params)) WorkOrder::query()->insert($params);
|
|
|
- return ['success' => true];
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 创建 信息更改 工单
|
|
|
- * @param $workOrderType
|
|
|
- * @param $uniquelyTag
|
|
|
- * @param $remake
|
|
|
- * @param int $grad
|
|
|
- * @param int $status
|
|
|
- * @return bool[]
|
|
|
- */
|
|
|
- public function editOrder($workOrderType, $uniquelyTag,$remake,int $grad = 1,int $status = 1) :array
|
|
|
- {
|
|
|
- app("OrderService")->syncOrderByCodes([$uniquelyTag]); // 同步订单
|
|
|
- $creator_id = Auth::user()['id']; // 创建人
|
|
|
- $order = Order::query()->where('code',$uniquelyTag)->first();
|
|
|
-
|
|
|
- if (!$order) return ['success' => false,'message' => '对应订单未找到'];
|
|
|
- WorkOrder::query()->create(
|
|
|
- [
|
|
|
- 'creator_id' => $creator_id,
|
|
|
- 'work_order_type_id' => $workOrderType->id,
|
|
|
- 'grad' => $grad,
|
|
|
- 'remark' => $remake,
|
|
|
- 'outer_table_name' => $workOrderType->table_name ?? 'orders',
|
|
|
- 'order_id' => $order->id ?? '',
|
|
|
- 'uniquely_tag' => $uniquelyTag,
|
|
|
- 'status' => $status,
|
|
|
- 'created_at' => Carbon::now(),
|
|
|
- ]
|
|
|
- );
|
|
|
- return ['success' => true];
|
|
|
+ if (isset($inner_params)){
|
|
|
+ WorkOrder::query()->insert($inner_params);
|
|
|
+ return ['success' => true];
|
|
|
+ }
|
|
|
+ return ['success' => false,'message' => '参数异常'];
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
@@ -93,7 +105,7 @@ class WorkOrderService
|
|
|
$wordOrder->update(['reviewer_id' => Auth::user()['id'], 'review_at' => Carbon::now(), 'status' => 2,]);
|
|
|
$wordOrder = WorkOrder::query()->with(['type', 'creator', 'order' => function ($query) {
|
|
|
/** @var $query Builder */
|
|
|
- $query->with('packages', 'issue','logistic');
|
|
|
+ $query->with('packages', 'issue', 'logistic');
|
|
|
}, 'reviewer'])->find($wordOrder['id']);
|
|
|
return ['success' => true, 'data' => $wordOrder];
|
|
|
}
|
|
|
@@ -105,57 +117,36 @@ class WorkOrderService
|
|
|
*/
|
|
|
public function batchReview($workOrders): array
|
|
|
{
|
|
|
- $ids = $workOrders->map(function($item){return $item->id;})->toArray();
|
|
|
- WorkOrder::query()->whereIn('id',$ids)->update(['review_at' => Carbon::now(),'reviewer' => Auth::user()['id']]);
|
|
|
+ $ids = $workOrders->map(function ($item) {
|
|
|
+ return $item->id;
|
|
|
+ })->toArray();
|
|
|
+ WorkOrder::query()->whereIn('id', $ids)->update(['review_at' => Carbon::now(), 'reviewer_id' => Auth::user()['id']]);
|
|
|
$wordOrder = WorkOrder::query()->with(['type', 'creator', 'order' => function ($query) {
|
|
|
/** @var $query Builder */
|
|
|
- $query->with('packages', 'issue','logistic');
|
|
|
+ $query->with('packages', 'issue', 'logistic');
|
|
|
}, 'reviewer'])->find($ids);
|
|
|
return ['success' => true, 'data' => $wordOrder];
|
|
|
}
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
- * 拦截工单
|
|
|
* 生成问题件
|
|
|
* @param $work_orders
|
|
|
- * @return array|bool[]
|
|
|
+ * @return array
|
|
|
*/
|
|
|
- public function createOrderIssue($work_orders): array
|
|
|
+ public function buildOrderIssue($work_orders): array
|
|
|
{
|
|
|
- $order_ids = $work_orders->map(function ($item) {
|
|
|
- return $item->order_id;
|
|
|
- });
|
|
|
-
|
|
|
- $order_issues = OrderIssue::query()->with('order')->whereIn('order_id', $order_ids)->get();
|
|
|
-
|
|
|
- $codes = $order_issues->map(function ($item) {
|
|
|
- return $item->order->code;
|
|
|
- })->toArray();
|
|
|
- if (count($codes) > 0)
|
|
|
- return ['success' => false, 'message' => '对应【' . join(',', $codes) . '】订单已有问题件'];
|
|
|
-
|
|
|
- $orders = Order::query()->select('code')->whereIn('id', $order_ids)->get();
|
|
|
-
|
|
|
- $order_headers = app(OracleDOCOrderHeaderService::class)->getQuery()->whereIn('orderNo', $orders)->get(); // 获取
|
|
|
-
|
|
|
- $order_issue_type = OrderIssueType::query()->where('name', '拦截')->first(); // 问题件类型
|
|
|
-
|
|
|
- $result = app('OrderIssueService')->createOrderIssueByWmsOrder($order_headers, $order_issue_type->id, '拦截工单');
|
|
|
-
|
|
|
- if (!$result) return ['success' => false, 'message' => '生成对应问题件失败'];
|
|
|
-
|
|
|
- $work_orders = WorkOrder::query()->with(['type', 'creator', 'order' => function ($query) {
|
|
|
- /** @var $query Builder */
|
|
|
- $query->with('packages', 'issue','logistic');
|
|
|
- }, 'reviewer'])
|
|
|
- ->where('outer_table_name', 'orders')
|
|
|
- ->whereIn('order_id', $order_ids)
|
|
|
- ->get();
|
|
|
-
|
|
|
- return ['success' => true, 'data' => $work_orders];
|
|
|
+ foreach ($work_orders as $work_order) {
|
|
|
+ $inner_params[] = [
|
|
|
+ 'order_id' => $work_order->order_id,
|
|
|
+ 'order_issue_type_id' => $work_order->order_issue_type_id,
|
|
|
+ 'result_explain' => $work_order->remark,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ if (!isset($inner_params)) return ['success' => false,'message' => '创建问题件失败'];
|
|
|
+ return app('OrderIssueService')->buildOrderIssue($inner_params);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
/**
|
|
|
* 按 指定工单类型 和 唯一标识 确认工单是否存在
|
|
|
* @param $work_order_type_id
|
|
|
@@ -176,4 +167,24 @@ class WorkOrderService
|
|
|
}
|
|
|
return ['success' => false];
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 标记已有 问题件的工单
|
|
|
+ * @param $workOrders
|
|
|
+ */
|
|
|
+ public function tags(&$workOrders)
|
|
|
+ {
|
|
|
+ $order_ids = $workOrders->map(function($item){
|
|
|
+ return $item->order_id;
|
|
|
+ });
|
|
|
+ $order_issues = OrderIssue::query()->whereIn('order_id',$order_ids)->get();
|
|
|
+ foreach ($order_issues as $order_issue) {
|
|
|
+ $codes[$order_issue->order_id] = true;
|
|
|
+ }
|
|
|
+ if (!isset($codes))return;
|
|
|
+ foreach ($workOrders as &$workOrder) {
|
|
|
+ if (array_key_exists($workOrder->order_id,$codes))$workOrder->is_issue_order= true;
|
|
|
+ else $workOrder->is_issue_order= false;
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|