|
|
@@ -24,320 +24,12 @@ use App\Traits\ServiceAppAop;
|
|
|
class OrderIssueService
|
|
|
{
|
|
|
use ServiceAppAop;
|
|
|
- public function __construct()
|
|
|
- {
|
|
|
- app()->bind("orderService", OrderService::class);
|
|
|
- app()->bind("rejectedService", RejectedService::class);
|
|
|
- app()->bind("orderPackageCommoditiesService", OrderPackageCommoditiesService::class);
|
|
|
- }
|
|
|
|
|
|
public function insert($params)
|
|
|
{
|
|
|
OrderIssue::query()->insert($params);
|
|
|
}
|
|
|
|
|
|
- public function getQuery(array $arr, array $condition = null)
|
|
|
- {
|
|
|
- if (!isset($condition)) {
|
|
|
- $condition = $arr;
|
|
|
- }
|
|
|
- $user = Auth::user();
|
|
|
- $owner_ids = $user ? app('UserService')->getPermittingOwnerIds($user) : [];
|
|
|
- if ($condition['owner_id'] ?? false) {
|
|
|
- $owner_ids = explode(',', $condition['owner_id']);
|
|
|
- }
|
|
|
- $query = OrderIssue::with(['top', 'userWorkgroups', 'issueType', 'logs' => function ($query) use ($arr) {
|
|
|
- $query->with('user')->orderByDesc('created_at');
|
|
|
- }, 'order' => function ($query) {
|
|
|
- $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity' => function ($query) {
|
|
|
- $query->with('barcodes');
|
|
|
- }]);
|
|
|
- }, 'orderIssueRejectedBills.rejectedBill' => function ($query) {
|
|
|
- $query->with(['items.quality']);
|
|
|
- }, 'secondOrder' => function ($query) {
|
|
|
- $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity' => function ($query) {
|
|
|
- $query->with('barcodes');
|
|
|
- }]);
|
|
|
- }])->whereHas('order.owner', function ($query) use ($owner_ids) {
|
|
|
- $query->whereIn('id', $owner_ids);
|
|
|
- });
|
|
|
- if ($arr['log_content'] ?? false) {
|
|
|
- $query->whereHas('logs', function ($query) use ($arr) {
|
|
|
- $query->where('content', 'like', $arr['log_content']);
|
|
|
- if ($arr['addtime'] ?? false) {
|
|
|
- $query->where('created_at', '>=', Carbon::now()->subDays($arr['addtime']));
|
|
|
- } else {
|
|
|
- $query->where('created_at', '>=', Carbon::now()->subDays(31));
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- if (isset($arr['is_imported'])) {
|
|
|
- $query->where('imported_status', $arr['is_imported']);
|
|
|
- }
|
|
|
-
|
|
|
- if (isset($arr['is_new_rejecting'])) {
|
|
|
- $query->where('is_new_rejecting', '=', $arr['is_new_rejecting']);
|
|
|
- }
|
|
|
-
|
|
|
- if (isset($arr['logistic_id'])) {
|
|
|
- $query->whereHas('order', function ($query) use ($arr) {
|
|
|
- $query->where('logistic_id', $arr['logistic_id']);
|
|
|
- });
|
|
|
- }
|
|
|
- if (isset($arr['custom_code'])) {
|
|
|
- $query->where('custom_code', $arr['custom_code']);
|
|
|
- }
|
|
|
- if(isset($arr['hiddenTag'])){
|
|
|
- $query->where('hidden_tag', $arr['hiddenTag']);
|
|
|
- }else{
|
|
|
- $query->whereNull('hidden_tag');
|
|
|
- }
|
|
|
- $query->selectRaw('order_issues.* ,order_issue_on_tops.id top_id ,order_issue_on_tops.remark,order_issue_on_tops.updated_at top_update')
|
|
|
- ->leftJoin('order_issue_on_tops', 'order_issue_on_tops.order_issue_id', '=', 'order_issues.id')
|
|
|
- ->whereNull('order_issue_on_tops.deleted_at')
|
|
|
- ->orderBy('order_issue_on_tops.updated_at', 'desc');
|
|
|
- $query->orderBy('order_issues.id', 'desc');
|
|
|
- return $query;
|
|
|
- }
|
|
|
-
|
|
|
- private function getOrderQuery(array $arr, $query)
|
|
|
- {
|
|
|
- $query->whereHas('order', function ($query) use ($arr) {
|
|
|
- if ($arr['client_code'] ?? false) {
|
|
|
- return $this->searchWay($query, $arr['client_code'], 'client_code');
|
|
|
- }
|
|
|
- if ($arr['consignee_name'] ?? false) {
|
|
|
- return $this->searchWay($query, $arr['consignee_name'], 'consignee_name');
|
|
|
- }
|
|
|
- if ($arr['consignee_phone'] ?? false) {
|
|
|
- return $this->searchWay($query, $arr['consignee_phone'], 'consignee_phone');
|
|
|
- }
|
|
|
- if ($arr['logistic_number'] ?? false) {
|
|
|
- $logistic_number = $arr['logistic_number'];
|
|
|
- $query->whereHas('packages', function ($query) use ($logistic_number) {
|
|
|
- return $this->searchWay($query, $logistic_number, 'logistic_number');
|
|
|
- });
|
|
|
- }
|
|
|
- if (($arr['good_barcode'] ?? false) || ($arr['good_name'] ?? false)) {
|
|
|
- $query->whereHas('packages.commodities.commodity', function ($query) use ($arr) {
|
|
|
- if ($arr['good_barcode'] ?? false) {
|
|
|
- return $this->searchWay($query, $arr['good_barcode'], 'sku');
|
|
|
- }
|
|
|
- if ($arr['good_name'] ?? false) {
|
|
|
- $query->where('name', 'like', '%' . $arr['good_name'] . '%');
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- });
|
|
|
- if ($arr['send_client_code'] ?? false) {
|
|
|
- $query->whereHas('secondOrder', function ($query) use ($arr) {
|
|
|
- return $this->searchWay($query, $arr['send_client_code'], 'client_code');
|
|
|
- });
|
|
|
- }
|
|
|
- return $query;
|
|
|
- }
|
|
|
-
|
|
|
- public function getRejectedBillQuery(array $arr, $query)
|
|
|
- {
|
|
|
- if (($arr['logistic_number_return'] ?? false) || ($arr['id_quality_label'] ?? false)) {
|
|
|
- $order_issue_rejected_bill_query = OrderIssueRejectedBill::query()->selectRaw('order_issue_id');
|
|
|
- if(isset($arr['id_quality_label'])){
|
|
|
- $rejected_bill_item_query = RejectedBillItem::query()->selectRaw('id_rejected_bill')->where('rejected_bill_items.id_quality_label',$arr['id_quality_label']);
|
|
|
- $rejected_bill_query = RejectedBill::query()->selectRaw('rejected_bills.logistic_number_return')->whereIn('rejected_bills.id',$rejected_bill_item_query);
|
|
|
- $order_issue_rejected_bill_query->whereIn('order_issue_rejected_bill.logistic_number_return',$rejected_bill_query);
|
|
|
- }
|
|
|
- if(isset($arr['logistic_number_return'])){
|
|
|
- $this->searchWay($order_issue_rejected_bill_query,$arr['logistic_number_return'],'logistic_number_return');
|
|
|
- }
|
|
|
- $query->whereIn('order_issues.id',$order_issue_rejected_bill_query);
|
|
|
- }
|
|
|
- return $query;
|
|
|
- }
|
|
|
-
|
|
|
- public function getConditionQuery(array $arr, array $condition = null)
|
|
|
- {
|
|
|
- /** @var Builder $query */
|
|
|
- $query = $this->getQuery($arr, $condition);
|
|
|
- $query = $this->getOrderQuery($condition ?? $arr, $query);
|
|
|
- $query = $this->getRejectedBillQuery($condition ?? $arr, $query);
|
|
|
- if (!isset($condition)) {
|
|
|
- $condition = $arr;
|
|
|
- }
|
|
|
- if ($condition['id'] ?? false) {
|
|
|
- $query->whereIn('order_issues.id', explode(',', $condition['id']));
|
|
|
- }
|
|
|
- if (isset($condition['created_at_start'])) {
|
|
|
- $query->where('order_issues.created_at', '>=', $condition['created_at_start'] . " 00:00:00");
|
|
|
- }
|
|
|
- if (isset($condition['created_at_end'])) {
|
|
|
- $query->where('order_issues.created_at', '<=', $condition['created_at_end'] . " 23:59:59");
|
|
|
- }
|
|
|
- if (isset($condition['final_status'])) {
|
|
|
- if ($condition['final_status'] == 'null') {
|
|
|
- $query->whereNull('final_status');
|
|
|
- } else {
|
|
|
- $query->where('final_status', $condition['final_status']);
|
|
|
- }
|
|
|
- }
|
|
|
- if (isset($condition['order_issue_type_id'])) {
|
|
|
- $type_ids = explode(',',$condition['order_issue_type_id']);
|
|
|
- $query->whereIn('order_issue_type_id', $type_ids);
|
|
|
- }
|
|
|
- if (!($condition['is_handle'] ?? false) && !($condition['final_status'] ?? false)) {
|
|
|
- if (!(isset($condition['settlement_at_start']) || isset($condition['settlement_at_end']))) {
|
|
|
- $query->where(function ($query) {
|
|
|
- $query->whereNotIn('final_status',['已解决','已归档'])->orWhereNull('final_status');
|
|
|
- });
|
|
|
- }
|
|
|
- }
|
|
|
- if (isset($condition['logistic_indemnity_money'])) {
|
|
|
- if($condition['logistic_indemnity_money']== '是'){
|
|
|
- $query->whereNotNull('logistic_indemnity_money');
|
|
|
- }elseif($condition['logistic_indemnity_money']== '否'){
|
|
|
- $query->whereNull('logistic_indemnity_money');
|
|
|
- }
|
|
|
- }
|
|
|
- if (isset($condition['baoshi_indemnity_money'])) {
|
|
|
- if($condition['baoshi_indemnity_money']== '是'){
|
|
|
- $query->whereNotNull('baoshi_indemnity_money');
|
|
|
- }elseif($condition['baoshi_indemnity_money']== '否'){
|
|
|
- $query->whereNull('baoshi_indemnity_money');
|
|
|
- }
|
|
|
- }
|
|
|
- if (isset($condition['rejectingStatus'])) {
|
|
|
- $query->where('rejecting_status',$condition['rejectingStatus']);
|
|
|
- }
|
|
|
- if (isset($condition['order_issue_ids'])) {
|
|
|
- $orderIssuesId = $condition['order_issue_ids'];
|
|
|
- if (is_string($orderIssuesId)) {
|
|
|
- $orderIssuesId = explode(',', $orderIssuesId);
|
|
|
- }
|
|
|
- $query->whereIn('order_issues.id', $orderIssuesId);
|
|
|
- }
|
|
|
- if (isset($condition['settlement_at_start']) || isset($condition['settlement_at_end'])) {
|
|
|
- $query->whereHas('logs', function ($query) use ($condition) {
|
|
|
- if (isset($condition['settlement_at_start'])) {
|
|
|
- $query->where('created_at', '>=', $condition['settlement_at_start'] . ' 00:00:00')->where('type', '结束');
|
|
|
- }
|
|
|
- if (isset($condition['settlement_at_end'])) {
|
|
|
- $query->where('created_at', '<=', $condition['settlement_at_end'] . ' 23:59:59')->where('type', '结束');
|
|
|
- }
|
|
|
- });
|
|
|
- }
|
|
|
- if(isset($condition['sendOrderClientCode'])){
|
|
|
- $query->whereHas('secondOrder',function($query)use($condition){
|
|
|
- $this->searchWay($query,$condition['sendOrderClientCode'],'client_code');
|
|
|
- });
|
|
|
- $query->orWhere('second_client_no',$condition['sendOrderClientCode']);
|
|
|
- }
|
|
|
- if(isset($condition['sendOrderLogisticNumber'])){
|
|
|
- $query->whereHas('secondOrder.packages',function($query)use($condition){
|
|
|
- $this->searchWay($query,$condition['sendOrderLogisticNumber'],'logistic_number');
|
|
|
- });
|
|
|
- $query->orWhere('second_logistic_number',$condition['sendOrderLogisticNumber']);
|
|
|
- }
|
|
|
- if (isset($condition['finance_confirm'])) {
|
|
|
- $query->where('finance_confirm', $condition['finance_confirm']);
|
|
|
- }
|
|
|
- if (isset($condition['user_workgroups'])) {
|
|
|
-
|
|
|
- if (is_string($condition['user_workgroups'])) {
|
|
|
- $userWorkgroupIds = explode(',', $condition['user_workgroups']);
|
|
|
- }
|
|
|
- $query->whereHas('userWorkgroups', function ($query) use ($userWorkgroupIds) {
|
|
|
- $query->whereIn('id', $userWorkgroupIds);
|
|
|
- });
|
|
|
- }
|
|
|
- //根据店铺名称模糊筛选
|
|
|
- if (isset($condition['shop_name'])) {
|
|
|
- $query->whereHas('order.shop', function ($query) use ($condition) {
|
|
|
- $this->searchWay($query, $condition['shop_name'].'%', 'name');
|
|
|
- });
|
|
|
- if (isset($condition['shop_name_limit_time'])) {
|
|
|
- $query->Where('order_issues.created_at','>=', Carbon::now()->subDays($condition['shop_name_limit_time']));
|
|
|
- } else {
|
|
|
- $query->Where('order_issues.created_at','>=', Carbon::now()->subDays(31));
|
|
|
- }
|
|
|
- }
|
|
|
- return $query;
|
|
|
- }
|
|
|
-
|
|
|
- private function isSearchLike($str)
|
|
|
- {
|
|
|
- if (substr($str, 0, 1) == "%" || substr($str, strlen($str) - 1, 1) == "%") {
|
|
|
- return true;
|
|
|
- }
|
|
|
- return false;
|
|
|
- }
|
|
|
-
|
|
|
- private function searchWay($query, $param, $column)
|
|
|
- {
|
|
|
- if ($this->isSearchLike($param)) {
|
|
|
- $query->where($column, 'like', $param);
|
|
|
- } else {
|
|
|
- $query->whereIn($column, array_filter(preg_split('/[,, ]+/is', $param)));
|
|
|
- }
|
|
|
- return $query;
|
|
|
- }
|
|
|
-
|
|
|
- public function getSqlList(array $params)
|
|
|
- {
|
|
|
- $orderPackageSql = OrderPackage::query()->selectRaw('order_packages.logistic_number order_package_logistic_number')
|
|
|
- ->leftJoin('order_package_commodities','order_packages.id','order_package_commodities.order_package_id')
|
|
|
- ->selectRaw('order_package_commodities.amount commodity_amount')
|
|
|
- ->leftJoin('commodities','order_package_commodities.commodity_id','commodities.id')
|
|
|
- ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')
|
|
|
- ->leftJoin('order_issues','order_packages.order_id','order_issues.order_id')
|
|
|
- ->selectRaw('order_issues.id order_issue_id')
|
|
|
- ->sql();
|
|
|
- $secondOrderPackageSql = Order::query()->from('order_packages','s_o_p')->selectRaw('s_o_p.logistic_number')
|
|
|
- ->leftJoin("orders as o_d","s_o_p.order_id","o_d.id")
|
|
|
- ->leftJoin('order_package_commodities as s_o_p_c','s_o_p_c.order_package_id','s_o_p.id')
|
|
|
- ->selectRaw('s_o_p_c.amount s_o_p_c_amount')
|
|
|
- ->leftJoin('commodities as s_c','s_o_p_c.commodity_id','s_c.id')
|
|
|
- ->selectRaw('s_c.sku s_c_sku,s_c.name s_c_name')
|
|
|
- ->leftJoin('order_issues','o_d.client_code','order_issues.second_client_no')
|
|
|
- ->selectRaw('order_issues.id order_issue_id')
|
|
|
- ->sql();
|
|
|
- $rejectedBillItemSql = RejectedBillItem::query()->selectRaw('rejected_bill_items.remark,rejected_bill_items.amount rejected_bill_amount,rejected_bill_items.name_goods,rejected_bill_items.barcode_goods')
|
|
|
- ->leftJoin('rejected_bills',"rejected_bill_items.id_rejected_bill","rejected_bills.id")
|
|
|
- ->leftJoin('order_issues','rejected_bills.logistic_number_return','order_issues.logistic_number_return')
|
|
|
- ->selectRaw('order_issues.id order_issue_id')
|
|
|
- ->sql();
|
|
|
- $logSql = OrderIssueProcessLog::query()->selectRaw('order_issue_process_logs.content log_content,order_issue_process_logs.type log_type')
|
|
|
- ->leftJoin('users','order_issue_process_logs.user_id','users.id')
|
|
|
- ->selectRaw('users.name user_name')
|
|
|
- ->leftJoin('order_issues','order_issue_process_logs.order_issue_id','order_issues.id')
|
|
|
- ->selectRaw('order_issues.id order_issue_id')
|
|
|
- ->sql();
|
|
|
- $column = "order_issues.id,order_issues.rejected_bill_id,order_issues.rejecting_status,order_issues.created_at order_issues_created_at,order_issues.result_explain,order_issues.final_status,";
|
|
|
- $column .= "order_issues.logistic_indemnity_money,order_issues.logistic_express_remission,order_issues.baoshi_indemnity_money,order_issues.baoshi_express_remission";
|
|
|
- $orderIssueSql = $this->getConditionQuery($params)->selectRaw($column)
|
|
|
- ->leftJoin('order_issue_types','order_issues.order_issue_type_id','order_issue_types.id')
|
|
|
- ->selectRaw('order_issue_types.`name` order_issue_type_name')
|
|
|
- ->leftJoin('orders','order_issues.order_id','orders.id')
|
|
|
- ->selectRaw('orders.id order_id,orders.address,orders.district,orders.city,orders.province,orders.consignee_phone,orders.consignee_name,orders.client_code,orders.created_at order_created_at')
|
|
|
- ->leftJoin('logistics','logistics.id','orders.logistic_id')
|
|
|
- ->selectRaw('logistics.name logistic_name')
|
|
|
- ->leftJoin('owners','owners.id','orders.owner_id')
|
|
|
- ->selectRaw('owners.name owner_name')
|
|
|
- ->leftJoin('shops','orders.shop_id','shops.id')
|
|
|
- ->selectRaw('shops.name shop_name')
|
|
|
- ->leftJoin('orders as s_o','s_o.client_code','order_issues.second_client_no')
|
|
|
- ->selectRaw('s_o.id s_o_id,s_o.client_code s_o_client_code')
|
|
|
- ->leftJoin('logistics as s_logistics','s_o.logistic_id','s_logistics.id')
|
|
|
- ->selectRaw('s_logistics.name s_logistics_name')
|
|
|
- ->leftJoin('user_workgroups','user_workgroups.id','order_issues.user_workgroup_id')
|
|
|
- ->selectRaw('user_workgroups.name user_workgroup_name')
|
|
|
- ->sql();
|
|
|
- return compact('orderPackageSql','secondOrderPackageSql','orderIssueSql','rejectedBillItemSql','logSql');
|
|
|
- }
|
|
|
-
|
|
|
- public function paginate(array $params)
|
|
|
- {
|
|
|
- return $query = $this->getConditionQuery($params)->paginate($params['paginate'] ?? 50);
|
|
|
- }
|
|
|
-
|
|
|
public function orderIssueTag(array $params)
|
|
|
{
|
|
|
$orderNos = $params['orderNos'];
|
|
|
@@ -567,7 +259,6 @@ class OrderIssueService
|
|
|
return ['success' => true, 'order' => $order];
|
|
|
}
|
|
|
|
|
|
-
|
|
|
public function createOrderIssue($logisticNumber, $type, $result_explain, $importedStatus = '正常', $custom_code = null,$hiddenTag = null)
|
|
|
{
|
|
|
$orderHeaders = OracleDOCOrderHeader::query()->with(['oracleDOCOrderDetails', 'actAllocationDetails', 'oracleBASCode','orderType'])
|
|
|
@@ -630,12 +321,6 @@ class OrderIssueService
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- public function getJsonObj(array $params)
|
|
|
- {
|
|
|
- return $this->getConditionQuery($params)->get();
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
public function getRecycleBinPaginate($params){
|
|
|
return OrderIssue::query()
|
|
|
->with(['order'=>function($query){
|