TongbuOrder/app/Jobs/TongbuOrderNewJob.php

<?php

namespace App\Jobs;

use App\Models\Activity;
use App\Models\Address;
use App\Models\Gifts;
use App\Models\Goods;
use App\Models\Order;
use App\Models\OrderDetail;
use App\Models\OrderGift;
use App\Models\User;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class TongbuOrderNewJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    protected $data;
    public function __construct($data)
    {
        $this->data=$data;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
       $data_info=$this->data;
//       Log::error($data_info);
       $id=$data_info['id'];
       $info=json_decode($data_info['data'],true);
        $type=$info['Type'];
        $order_arr=explode('-',$info['Code']);
        if (count($order_arr)>1){
            Log::error($info['Code']);
            return null;
        }
        if ($type==3){
            $order=Order::where('order_num',$info['Code'])->first();
            if ($order){
                if (!$order->is_deleted){
                    if ($order->pay_money>0){
                        $order->wait_back_money=$order->pay_money;
                        $order->pay_status=3;
                    }
                }
                $order->is_deleted=1;
                $order->save();
            }
            DB::connection('mysql_w')->table('data_or')
                ->where('id',$id)
                ->update(['status'=>1,'type'=>$type]);
            return;
        }
        $this->DelOrder([$info['data']],mb_substr($info['Domain'],0,-1));
        DB::connection('mysql_w')->table('data_or')
            ->where('id',$id)
            ->update(['status'=>1,'type'=>$type]);
    }



    protected function DelOrder($arr,$url){
        if (!$arr){
            return;
        }
//        Log::error($arr);
        try {
            $activity_id=Activity::where('is_ing',1)->value('id');
            foreach ($arr as $k=>$v){
                //批发商
                $Sourcemobile=$v['SourceCustomerModel']['Telephone'];
                $Sourcenickname=$v['SourceCustomerModel']['CustomerName'];
                $Sourcecode=$v['SourceCustomerModel']['AuthorizationCode'];
                $user=User::where('auth_code',$Sourcecode)->first();
                Log::info($Sourcecode);
                if (!$user){
                    $user=new User();
                    $user->name=$Sourcenickname;
                    $user->nickname=$Sourcenickname;
                    $user->realname=$Sourcenickname;
                    $user->remark_name=$Sourcenickname;
                    $user->mobile=$Sourcemobile;
                    $user->uuid=$Sourcemobile;
                    $user->auth_code=$Sourcecode;
                    $user->level=3;
                    $user->url=$url;
                    $user->save();
                }
                $TopCode=$v['TopCustomerModel']['AuthorizationCode'];
                $belongUser=User::where('auth_code',$TopCode)->first();
                if (!$belongUser){
                    //经销商
                    $belongUser=new User();
                    $belongUser->name=$v['TopCustomerModel']['CustomerName'];
                    $belongUser->nickname=$v['TopCustomerModel']['CustomerName'];
                    $belongUser->realname=$v['TopCustomerModel']['CustomerName'];
                    $belongUser->remark_name=$v['TopCustomerModel']['CustomerName'];
                    $belongUser->mobile=$v['TopCustomerModel']['Telephone'];
                    $belongUser->uuid=$v['TopCustomerModel']['Telephone'];
                    $belongUser->auth_code=$TopCode;
                    $belongUser->level=2;
                    $belongUser->url=$url;
                    $belongUser->save();
                }

                $order_num=$v['Code'];
                Log::info($order_num);
                $order=Order::where('order_num',$order_num)->first();
                if ($order){
                    $address=Address::where('id',$order->address_id)->first();
                    $address->user_id=$user->id;
                    $address->username=$v['AddressDetail']['Name'];
                    $address->mobile=$v['AddressDetail']['Phone'];
                    $address->province=$v['AddressDetail']['Province'];
                    $address->city=$v['AddressDetail']['City'];
                    $address->town=$v['AddressDetail']['District'];
                    $address->address=$v['AddressDetail']['Address'];
                    $address->type=0;
                    $address->save();
                    if ($order->money!=$v['TotalCash']){
                        OrderDetail::where('order_id',$order->id)->delete();
                    }
                    $order->money=$v['TotalCash'];
                    if ($order->money==$order->pay_money){
                        $order->no_pay_money=0;//未支付变为0
                        $order->pay_status=2;//支付状态2，为全部支付
                        $order->wait_back_money=0;//待退回金额为0
                    }elseif ($order->money<$order->pay_money){//订单金额小于支付金额
                        $order->no_pay_money=0;//未支付金额变为0
                        $order->pay_status=3;//支付状态3，待退款状态
                        $order->wait_back_money=$order->pay_money-$order->money;//待退款金额为支付金额减去订单金额
                    }elseif ($order->money>$order->pay_money){//订单金额大于支付金额
                        if ($order->pay_money==0){//如果支付金额为0
                            $order->pay_status=0;//则支付状态0，未支付
                        }else{
                            $order->pay_status=1;//否则支付状态1，部分支付
                        }
                        $order->no_pay_money=$order->money-$order->pay_money;//未支付金额等于订单金额减去支付金额
                        $order->wait_back_money=0;//待退款为0
                    }

                    $order->total=$v['TotalQty'];
                    $order->State=$v['State'];
                    $order->save();
                    $detail=$v['OrderDetail'];
                    $activity_status=false;
                    $orderdrtail_id=[];
                    foreach ($detail as $ke=>$va){
                        if ($va['IsGift']){
                            $activity_status=true;
                            $gift_name=$va['ProductName'];
                            $num=$va['Qty'];
                            $gift=Gifts::where('name',$gift_name)->where('activity_id',$activity_id)->first();

                            $ordergift=OrderGift::where('order_id',$order->id)
                                ->where('gift_id',$gift->id)->first();
                            if (!$ordergift){
                                $ordergift=new OrderGift();
                            }
                            $order->total-=$num;
                            $order->save();
                            $ordergift->gift_id=$gift->id;
                            $ordergift->order_id=$order->id;
                            $ordergift->activity_id=$activity_id;
                            $ordergift->num=$num;
                            $ordergift->limit_num=1;
                            $ordergift->save();
                        }else{
//                        Log::error($va);

                            $GroupID=$va['ProductGroupSKUID'];
                            $num=$va['Qty'];
                            $goods=Goods::where('groupID',$GroupID)->first();
                            if (!$goods){
                                Log::error('不存在商品'.$GroupID);
                            }

                            $orderDetail=OrderDetail::where('order_id',$order->id)
                                ->where('goods_id',$goods->id)->first();
                            if (!$orderDetail){
                                $orderDetail=new OrderDetail();
                            }
                            $orderDetail->order_id=$order->id;
                            $orderDetail->goods_id=$goods->id;
                            $orderDetail->num=$num;
                            $orderDetail->goods_price=$goods->money;
                            $orderDetail->money=$num*$goods->money;
                            $orderDetail->goods_name=$goods->name;
                            $orderDetail->goods_size=$goods->size;
                            $orderDetail->goods_unit=$goods->unit;
                            $orderDetail->goods_sku='';
                            $orderDetail->save();
                            $order_id[]=$orderDetail->id;
                        }

                    }

                }else{
                    $address=new Address();
                    $address->user_id=$user->id;
                    $address->username=$v['AddressDetail']['Name'];
                    $address->mobile=$v['AddressDetail']['Phone'];
                    $address->province=$v['AddressDetail']['Province'];
                    $address->city=$v['AddressDetail']['City'];
                    $address->town=$v['AddressDetail']['District'];
                    $address->address=$v['AddressDetail']['Address'];
                    $address->type=0;
                    $address->uid=$belongUser->id;
                    $address->save();

                    $order=new Order();
                    $order->order_num=$order_num;
                    $order->money=$v['TotalCash'];
                    $order->no_pay_money=$v['TotalCash'];
                    $order->user_id=$user->id;
                    $order->total=$v['TotalQty'];
                    $order->created_at=$v['CreateDate'];
                    $order->ZDL_id=$v['CustomerOrderID'];
                    $order->url=$url;
                    $order->State=$v['State'];
                    $order->address_id=$address->id;
                    $order->good_user_id=$belongUser->id;
                    if ($v['State']=='7'){
                        $order->is_deleted=1;
                    }
                    $order->save();
                    $detail=$v['OrderDetail'];
                    $activity_status=false;
                    foreach ($detail as $ke=>$va){
                        if ($va['IsGift']){
                            $activity_status=true;
                            $gift_name=$va['ProductName'];
                            $num=$va['Qty'];
                            $gift=Gifts::where('name',$gift_name)->where('activity_id',$activity_id)->first();
                            $ordergift=new OrderGift();
                            $ordergift->gift_id=$gift->id;
                            $ordergift->order_id=$order->id;
                            $ordergift->activity_id=$activity_id;
                            $ordergift->num=$num;
                            $ordergift->limit_num=1;
                            $ordergift->save();
                            $order->total-=$num;
                            $order->save();
                        }else{
                            $GroupID=$va['ProductGroupSKUID'];
                            $num=$va['Qty'];
                            $goods=Goods::where('groupID',$GroupID)->first();
                            if (!$goods){
                                Log::error('不存在该商品'.$GroupID);
                            }
                            $orderDetail=new OrderDetail();
                            $orderDetail->order_id=$order->id;
                            $orderDetail->goods_id=$goods->id;
                            $orderDetail->num=$num;
                            $orderDetail->goods_price=$goods->money;
                            $orderDetail->money=$num*$goods->money;
                            $orderDetail->goods_name=$goods->name;
                            $orderDetail->goods_size=$goods->size;
                            $orderDetail->goods_unit=$goods->unit;
                            $orderDetail->goods_sku='';
                            $orderDetail->save();
                        }

                    }
                    if ($activity_status){
                        $order->activity_id=$activity_id;
                        $order->save();
                    }
                }

            }
        }catch (\Exception $exception){
            Log::error($arr);
//            DB::table('data_in')
//                ->insert(['uuid'=>$data_id]);
            Log::error($exception->getMessage());
        }

    }
}