fangwei-api/app/Http/Controllers/GoodSendController.php

<?php

namespace App\Http\Controllers;

use App\Events\ReturnGoodLog;
use App\Events\SendGoodLogEvent;
use App\Jobs\GoodSendJobs;
use App\Models\DeviceAccount;
use App\Models\Express;
use App\Models\GoodSelect;
use App\Models\OrderTest;
use App\Models\Select;
use App\Models\User;
use Carbon\Carbon;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Crypt;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Validator;

class GoodSendController extends Controller
{
    /**公司扫码快递单*/
    public function get_express(Request $request)
    {
        $u_id=Auth::user()->id;
        $users=User::find($u_id);
        if ($users->mobile==17333738670){
            return $this->error(500214,'','账号暂停使用');
        }
        Log::error($request->all());
        Log::error($u_id);
//        $re=DB::table('newexpress')->where('express_num','like',"%".$request->express_number."%")->first();
//        if ($re){
//            $data['belong_user_nickname'] = '';
//            $data['belong_user_mobile'] = '';
//            $data['address_name'] = '';
//            $data['belong_user_id'] = '';
//            $data['user_id'] = '';
//            $order=OrderTest::where('order_num',$re->order_num)->first();
//            if (!$order){
////                $res=DB::table('newexpress_copy1')->where('express_num',$request->express_number)->first();
////                $user=User::where('mobile',$res->mobile)->first();
//                if (!$order){
//                    return  $this->error(50214,'','订单号：'.$re->order_num.'不存在');
//                }
//            }
//            $user=User::find($order->good_user_id);
//            $data['user_id'] = $user->id;
//            $data['belong_user_nickname'] = $user->remark_name;
//            $data['belong_user_mobile'] = $user->mobile;
//            $data['belong_user_avatar'] = $user->headimgurl;
//            $data['belong_user_id'] = $user->id;
//            return $this->success($data);
//        }

        $datas = Express::where('express_number', $request->express_number)->first();
        if (!$datas){
            $nums=mb_substr($request->express_number,0,1);
            Log::error($nums.'sss');
            if ($nums==7){
                $num=(int)$request->express_number;
                $datas = Express::where('express_number','=',$num)->first();
            }
        }
        $data['belong_user_nickname'] = '';
        $data['belong_user_mobile'] = '';
        $data['address_name'] = '';
        $data['belong_user_id'] = '';
        $data['user_id'] = '';

        if ($datas) {
            $order = OrderTest::with(['get_good_user', 'get_address_user'])->find($datas->order_id);
            $data['user_id'] = $order->user_id;
            if ($order->get_good_user) {
                $data['belong_user_nickname'] = $order->get_good_user->nickname;
                $data['belong_user_mobile'] = $order->get_good_user->mobile;
                $data['belong_user_avatar'] = $order->get_good_user->headimgurl;
                $data['belong_user_id'] = $order->get_good_user->id;
            }
            if ($order->get_address_user) {
                $data['address_name'] = $order->get_address_user->username;
            }
            return $this->success($data);
        } else {
            return $this->error(50023, '', '请检查快递单号是否正确');
        }
    }

    /*四种商品的选择**/
    public function get_good()
    {
        $re = GoodSelect::select('id', 'name as good_name')->orderByDesc('rank')->where('status',0)->get();
        return $this->success($re);
    }

    /****/

    public function JudgePhone($phone){
        if ($phone=='15220141101'){
            $name='公司';
        }elseif ($phone=='17333738670'){
            $name='吴桥仓库';
        }else{
            $name=DeviceAccount::where('mobile',$phone)->orwhere('phone',$phone)->where('status',0)->value('name');
        }
        return $name;
    }

    /**公司发货**/
    public function send_goods(Request $request)
    {
        $input = $request->all();
        $u_id=Auth::user()->id;
        $users=User::find($u_id);
        if ($users->mobile==17333738670){
            return $this->error(500214,'','账号暂停使用');
        }
        $name=$this->JudgePhone($users->mobile);
        $user = User::where('id', $request->id)->first();
        Log::error($input['code']);
        Log::error($u_id);
        $code = json_decode($input['code']);

        DB::beginTransaction();
        try {
            foreach ($code as $ks => $vs) {
                $good=GoodSelect::where('id',$ks)->select('good_name')->first();
                foreach ($vs as $k=>$v){
                    $v=trim($v);
                    $re = Select::where('code', $v)->first();
                    if ($re) {
                        //小码发货
                        if ($re->is_lowest == 1) {
                            $re->user_id = $user->id;
                            $re->track_status = 2;
                            $re->com_binding = 0;
                            $re->is_true = 0;
                            $re->good_select_id = $ks;
                            $num = $this->update_full($re->pid);
                            if ($num == 300) {
                                return $this->error(50021, '', '修改状态出错');
                            }
                            $data = [
                                'op_name' => $name,
                                'op_phone' => $users->mobile,
                                'op_id' => 0,
                                'good_name'=>$good->good_name,
                                'accept_name' => $user->nickname,
                                'accept_phone' => $user->mobile,
                                'accept_id' => $user->id,
                                'type' => 1,
                                'select_id' => $re->id
                            ];
                            if (!$re->save()) {
                                throw new \Exception(1);
                            }
                            event(new SendGoodLogEvent($data));
                        } else {//中码或者大码发货
                            $num = $this->is_full($v);
                            if ($num == 300) {
                                return $this->error(50026, '', '小码已经部分发货，不能扫描中码或者大码进行发货');
                            }
                            if ($re->level != 1) {
                                $re->user_id = $request->id;
                                $re->com_binding = 0;
                                $re->is_true = 0;
                                $re->good_select_id = $ks;
                                if (!$re->save()) {
                                    throw new \Exception('1');
                                }
                                $num = $this->update_full($re->pid);
                                if ($num == 300) {
                                    throw new \Exception(1);
                                }
                                $data = [
                                    'op_name' => $name,
                                    'op_phone' => $users->mobile,
                                    'op_id' => 0,
                                    'good_name'=>$good->good_name,
                                    'accept_name' => $user->nickname,
                                    'accept_phone' => $user->mobile,
                                    'accept_id' => $user->id,
                                    'type' => 1,
                                    'select_id' => $re->id
                                ];
                                event(new SendGoodLogEvent($data));
                                $level_data = Select::where('pid', $re->sort)->get();
                                foreach ($level_data as $ke => $va) {
                                    $res = Select::where('code', $va->code)->first();
                                    $res->user_id = $request->id;
                                    $res->com_binding = 0;
                                    $res->is_true = 0;
                                    $res->good_select_id = $ks;
                                    if (!$res->save()) {
                                        throw new \Exception(1);
                                    }
                                    $data = [
                                        'op_name' => $name,
                                        'op_phone' => $users->mobile,
                                        'op_id' => 0,
                                        'good_name'=>$good->good_name,
                                        'accept_name' => $user->nickname,
                                        'accept_phone' => $user->mobile,
                                        'accept_id' => $user->id,
                                        'type' => 1,
                                        'select_id' => $va->id
                                    ];
                                    event(new SendGoodLogEvent($data));
                                }
                            } else {
                                /***大码发货，并记录日志情况*/
                                $re->user_id = $request->id;
                                $re->com_binding = 0;
                                $re->is_true = 0;
                                $re->good_select_id = $ks;
                                if (!$re->save()) {
                                    throw new \Exception('1');
                                }
                                $data = [
                                    'op_name' => $name,
                                    'op_phone' => $users->mobile,
                                    'op_id' => 0,
                                    'good_name'=>$good->good_name,
                                    'accept_name' => $user->nickname,
                                    'accept_phone' => $user->mobile,
                                    'accept_id' => $user->id,
                                    'type' => 1,
                                    'select_id' => $re->id
                                ];
                                event(new SendGoodLogEvent($data));

                                /**查询**/
                                $level_data = Select::where('pid', $re->sort)->get();
                                foreach ($level_data as $ke => $va) {
                                    /***修改所属者*/
                                    $res = Select::where('code', $va->code)->first();
                                    $res->user_id = $request->id;
                                    $res->com_binding = 0;
                                    $res->is_true = 0;
                                    $res->good_select_id = $ks;
                                    if (!$res->save()) {
                                        throw new \Exception(1);
                                    }
                                    $data = [
                                        'op_name' => $name,
                                        'op_phone' => $users->mobile,
                                        'op_id' => 0,
                                        'good_name'=>$good->good_name,
                                        'accept_name' => $user->nickname,
                                        'accept_phone' => $user->mobile,
                                        'accept_id' => $user->id,
                                        'type' => 1,
                                        'select_id' => $va->id
                                    ];
                                    event(new SendGoodLogEvent($data));


                                    /**如果现在的等级不是最低级，则执行下面的内容**/
                                    if ($va->is_lowest != 1) {
                                        $ress = Select::where('pid', $va->sort)->get();
                                        foreach ($ress as $kes => $vas) {
                                            $resss = Select::where('code', $vas->code)->first();
                                            $resss->user_id = $request->id;
                                            $resss->com_binding = 0;
                                            $resss->is_true = 0;
                                            $resss->good_select_id = $ks;
                                            if (!$resss->save()) {
                                                throw new \Exception(1);
                                            }
                                            $data = [
                                                'op_name' => $name,
                                                'op_phone' => $users->mobile,
                                                'op_id' => 0,
                                                'accept_name' => $user->nickname,
                                                'accept_phone' => $user->mobile,
                                                'accept_id' => $user->id,
                                                'type' => 1,
                                                'good_name'=>$good->good_name,
                                                'select_id' => $vas->id
                                            ];
                                            event(new SendGoodLogEvent($data));
                                        }
                                    }
                                }
                            }
                        }
                    }
                    else {
                        Log::error($k+1);
                        if ($ks==1){
                            $m='精装版';
                        }elseif ($ks==2){
                            $m='简约版';
                        }elseif ($ks==3){
                            $m='高腰版';
                        }elseif ($ks==4){
                            $m='纯棉版';
                        }elseif ($ks==9){
                            $m='青春版';
                        }elseif ($ks==6){
                            $m='精装版G';
                        }elseif ($ks==7){
                            $m='简约版G';
                        }elseif ($ks==8){
                            $m='高腰版G';
                        }elseif ($ks==10){
                            $m='青春版G';
                        }elseif($ks==11){
                            $m='纯棉赠';
                        }elseif($ks==12){
                            $m='青春赠';
                        }elseif($ks==13){
                            $m='简约赠';
                        }
                        else{
                            $m='精装（赠）';
                        }
                        Log::info($v.'没有查到相应的信息');
                        return $this->error(4000101, ['code'=>$v], '没有查到二维码对应的信息，请删除'.$m.'中第'.($k+1).'个数据重新提交。并将对应的货物单独取出');
                    }
                }

            }
            DB::commit();
            return $this->success([]);
        } catch (\Exception $exception) {
            DB::rollBack();
            Log::error($exception);
            return $this->error(40023, '', '发货失败，请重新尝试');
        }
    }



    public function send_goods_new(Request $request)
    {
        $input = $request->all();
        Log::error($input);
        $u_id=Auth::user()->id;
        $users=User::find($u_id);
        if ($users->mobile==17333738670){
            return $this->error(500214,'','账号暂停使用');
        }
        $name=$this->JudgePhone($users->mobile);
        $user = User::where('id', $request->id)->first();
        Log::error($input['code']);
        $code = json_decode($input['code']);
//        $code=$input['code'];

        DB::beginTransaction();
        try {
            foreach ($code as $ks => $vs) {
                $good=GoodSelect::where('id',$ks)->select('good_name')->first();
                foreach ($vs as $k=>$v){
                    $v=trim($v);
                    $re = Select::where('code', $v)->first();
                    if ($re) {
                        //小码发货
                        if ($re->is_lowest == 1) {
                            $re->user_id = $user->id;
                            $re->track_status = 2;
                            $re->com_binding = 0;
                            $re->is_true = 0;
                            $re->good_select_id = $ks;
                            $num = $this->update_full($re->pid);
                            if ($num == 300) {
                                return $this->error(50021, '', '修改状态出错');
                            }
                            $data = [
                                'op_name' => $name,
                                'op_phone' => $users->mobile,
                                'op_id' => 0,
                                'good_name'=>$good->good_name,
                                'accept_name' => $user->nickname,
                                'accept_phone' => $user->mobile,
                                'accept_id' => $user->id,
                                'type' => 1,
                                'select_id' => $re->id
                            ];
                            if (!$re->save()) {
                                throw new \Exception(1);
                            }
                            event(new SendGoodLogEvent($data));
                        } else {//中码或者大码发货
                            $num = $this->is_full($v);
                            if ($num == 300) {
                                return $this->error(50026, '', '小码已经部分发货，不能扫描中码或者大码进行发货');
                            }
                            if ($re->level != 1) {
                                $re->user_id = $request->id;
                                $re->com_binding = 0;
                                $re->is_true = 0;
                                $re->good_select_id = $ks;
                                if (!$re->save()) {
                                    throw new \Exception('1');
                                }
                                $num = $this->update_full($re->pid);
                                if ($num == 300) {
                                    throw new \Exception(1);
                                }
                                $data = [
                                    'op_name' => $name,
                                    'op_phone' => $users->mobile,
                                    'op_id' => 0,
                                    'good_name'=>$good->good_name,
                                    'accept_name' => $user->nickname,
                                    'accept_phone' => $user->mobile,
                                    'accept_id' => $user->id,
                                    'type' => 1,
                                    'select_id' => $re->id
                                ];
                                event(new SendGoodLogEvent($data));
                                $level_data = Select::where('pid', $re->sort)->get();
                                foreach ($level_data as $ke => $va) {
                                    $res = Select::where('code', $va->code)->first();
                                    $res->user_id = $request->id;
                                    $res->com_binding = 0;
                                    $res->is_true = 0;
                                    $res->good_select_id = $ks;
                                    if (!$res->save()) {
                                        throw new \Exception(1);
                                    }
                                    $data = [
                                        'op_name' => $name,
                                        'op_phone' => $users->mobile,
                                        'op_id' => 0,
                                        'good_name'=>$good->good_name,
                                        'accept_name' => $user->nickname,
                                        'accept_phone' => $user->mobile,
                                        'accept_id' => $user->id,
                                        'type' => 1,
                                        'select_id' => $va->id
                                    ];
                                    event(new SendGoodLogEvent($data));
                                }
                            } else {
                                /***大码发货，并记录日志情况*/
                                $re->user_id = $request->id;
                                $re->com_binding = 0;
                                $re->is_true = 0;
                                $re->good_select_id = $ks;
                                if (!$re->save()) {
                                    throw new \Exception('1');
                                }
                                $data = [
                                    'op_name' => $name,
                                    'op_phone' => $users->mobile,
                                    'op_id' => 0,
                                    'good_name'=>$good->good_name,
                                    'accept_name' => $user->nickname,
                                    'accept_phone' => $user->mobile,
                                    'accept_id' => $user->id,
                                    'type' => 1,
                                    'select_id' => $re->id
                                ];
                                event(new SendGoodLogEvent($data));

                                /**查询**/
                                $level_data = Select::where('pid', $re->sort)->get();
                                foreach ($level_data as $ke => $va) {
                                    /***修改所有所属者*/
                                    $res = Select::where('code', $va->code)->first();
                                    $res->user_id = $request->id;
                                    $res->com_binding = 0;
                                    $res->is_true = 0;
                                    $res->good_select_id = $ks;
                                    if (!$res->save()) {
                                        throw new \Exception(1);
                                    }
                                    $data = [
                                        'op_name' => $name,
                                        'op_phone' => $users->mobile,
                                        'op_id' => 0,
                                        'good_name'=>$good->good_name,
                                        'accept_name' => $user->nickname,
                                        'accept_phone' => $user->mobile,
                                        'accept_id' => $user->id,
                                        'type' => 1,
                                        'select_id' => $va->id
                                    ];
                                    event(new SendGoodLogEvent($data));


                                    /**如果现在的等级不是最低级，则执行下面的内容**/
                                    if ($va->is_lowest != 1) {
                                        $ress = Select::where('pid', $va->sort)->get();
                                        foreach ($ress as $kes => $vas) {
                                            $resss = Select::where('code', $vas->code)->first();
                                            $resss->user_id = $request->id;
                                            $resss->com_binding = 0;
                                            $resss->is_true = 0;
                                            $resss->good_select_id = $ks;
                                            if (!$resss->save()) {
                                                throw new \Exception(1);
                                            }
                                            $data = [
                                                'op_name' => $name,
                                                'op_phone' => $users->mobile,
                                                'op_id' => 0,
                                                'accept_name' => $user->nickname,
                                                'accept_phone' => $user->mobile,
                                                'accept_id' => $user->id,
                                                'type' => 1,
                                                'good_name'=>$good->good_name,
                                                'select_id' => $vas->id
                                            ];
                                            event(new SendGoodLogEvent($data));
                                        }
                                    }
                                }
                            }
                        }
                    } else {
                        Log::error($k+1);
                        if ($ks==1){
                            $m='精装版';
                        }elseif ($ks==2){
                            $m='简约版';
                        }elseif ($ks==3){
                            $m='高腰版';
                        }elseif ($ks==4){
                            $m='纯棉版';
                        }elseif ($ks==9){
                            $m='青春版';
                        }elseif ($ks==6){
                            $m='精装版G';
                        }elseif ($ks==7){
                            $m='简约版G';
                        }elseif ($ks==8){
                            $m='高腰版G';
                        }elseif ($ks==10){
                            $m='青春版G';
                        }else{
                            $m='精装（赠）';
                        }
                        Log::info($v.'没有查到相应的信息');
                        return $this->error(4000101, ['code'=>$v], '没有查到二维码对应的信息，请删除'.$m.'中第'.($k+1).'个数据重新提交。并将对应的货物单独取出');
                    }
                }

            }
            DB::commit();
            return $this->success([]);
        } catch (\Exception $exception) {
            DB::rollBack();
            Log::error($exception);
            return $this->error(40023, '', '发货失败，请重新尝试');
        }
    }


    /**子码同时发货**/
    public function send_child_good($id, $user_id, $good_select_id)
    {
        DB::beginTransaction();
        try {
            //查找下一级
            $data = Select::where('pid', $id)->get();
            //当前货物信息
            $re = Select::where('sort', '=', $id)->first();
            //中码发货时
            if ($re->level != 1) {
                //修改中码所属大码的状态
                $num = $this->update_full($re->pid);
                if ($num == 300) {
                    throw new \Exception(1);
                }
            }
            foreach ($data as $k => $v) {
                if ($v->is_lowest != 1) {
                    $num = $this->send_child_good($v->id, $user_id, $good_select_id);
                    if ($num == 300) {
                        throw new \Exception(1);
                    }
                }
                $se = Select::find($v->id);
                $se->track_status = 2;
                $se->com_binding = 0;
                $se->user_id = $user_id;
                $se->good_select_id = $good_select_id;
                if (!$se->save()) {
                    throw new \Exception('1');
                }
                $user_s = User::find($user_id);
                $data = [
                    'op_name' => '公司',
                    'op_phone' => '',
                    'op_id' => '',
                    'accept_name' => $user_s->nickname,
                    'accept_phone' => $user_s->mobile,
                    'accept_id' => $user_s->id,
                    'type' => 1,
                    'select_id' => $v->id
                ];
                event(new SendGoodLogEvent($data));
            }
            DB::commit();
            return 200;
        } catch (\Exception $exception) {
            DB::rollBack();
            return 300;
        }

    }


    public function user_send_good(Request $request)
    {
        return $this->success([]);

    }

    /**代理发货子码跟着发货（已取消）**/

    public function user_send_goods($pid, $user_id, $id, $type = 0)
    {
        //查找下一级
        $data = Select::where('pid', $pid)->get();
        //当前货物信息
        $re = Select::where('sort', '=', $pid)->first();
        //中码发货时
        if ($type == 0) {
            if ($re->level != 1) {
                //修改中码所属大码的状态
                $num = $this->update_full($re->pid);
                if ($num == 300) {
                    throw new \Exception(1);
                }
            }
        }

        foreach ($data as $k => $v) {
            if ($v->is_lowest != 1) {
                $num = $this->user_send_goods($v->sort, $user_id, $id);
                if ($num == 300) {
                    throw new \Exception(1);
                }
            }
            $se = Select::find($v->id);
            $se->track_status = 2;
            $se->user_id = $user_id;
            if (!$se->save()) {
                Log::error('走了这里（所属者的改变）');
                throw new \Exception('1');
            }
            $users = User::find($id);
            $user_s = User::find($user_id);
            $data = [
                'op_name' => $users->nickname,
                'op_phone' => $users->mobile,
                'op_id' => $users->id,
                'accept_name' => $user_s->nickname,
                'accept_phone' => $user_s->mobile,
                'accept_id' => $user_s->id,
                'type' => 0,
                'select_id' => $v->id
            ];
            event(new SendGoodLogEvent($data));
        }
    }

    /**小码发货时更改中码和大码**/
    public function update_full($pid)
    {
        DB::beginTransaction();
        try {
            $re = Select::where('sort', '=', $pid)->first();
            $re->is_full = 1;
            if (!$re->save()) {
                throw new \Exception('1');
            }
            if ($re->level != 1) {
                $this->update_full($re->pid);
            }
            DB::commit();
            return 200;
        } catch (\Exception $exception) {
            DB::rollBack();
            Log::error($exception);
            return 300;
        }
    }



    public function get_lower_user(Request $request)
    {
        return $this->success_list([]);
    }

    /**查询**/

    public function get_lower_users(Request $request)
    {
        Log::error($request->all());
        if ($request->has('type')) {
            if ($request->type == 0) {
                return $this->success_list([]);

            } else {
                $search_name = $request->search_name;
                $user = User::where('nickname', 'like', '%' . $search_name . '%')->orwhere('realname', 'like', '%' . $search_name . '%')->orwhere('mobile', 'like', "%$search_name");
//                $user = User::where('nickname', 'like', '%' . $search_name . '%')->orwhere('mobile', 'like', '%' . $search_name . '%');
                $count = $user->get()->count();
                $user = $user->select('mobile as phone','uuid', 'nickname', 'realname', 'id', 'headimgurl as avatar','level')->take(30)->skip(($request->page - 1) * 30)->get();
                foreach ($user as $k=>$v){
                    try {
                        $user[$k]->phone=Crypt::decryptString($v->uuid);
                    }catch (\Exception $exception){

                    }
                }
                return $this->success_list($user, '', $count);
            }
        }

    }

    /**检查是够已经发货**/

    public function is_full($code)
    {
        $re = Select::where('code', $code)->first();
        if ($re->is_full == 1) {
            return 300;
        }
        return 200;
    }

    /**代理退货**/
    public function user_return_good(Request $request)
    {
            return $this->error(40029, '', '暂未查询到相应的信息');
    }

    /**检查是否为真**/
    public function is_true($code)
    {
        $re = Select::where('code', $code)->first();
        if ($re->is_true == 1) {
            return 300;
        }
        return 200;
    }

    /**检查用户**/
    public function check_user_level($id, $user_id)
    {
        if ($id == $user_id) {
            return ['code' => 50026, 'message' => '你不能对自己的货物进行退货操作'];
        }

        return ['code' => 200];
    }


    public function new_send_good(Request $request)
    {
        if ($request->id) {
            return $this->error(50026, '', '请选择代理进行发货');
        }
        DB::beginTransaction();
        try {

        } catch (\Exception $exception) {

        }
    }

    /*
     * 新版发货
     * **/

    public function new_send(Request $request){

    }


    public function send_goodss(Request $request)
    {
        $input = $request->all();
        $code = json_decode($input['code']);
        $codes=array_merge($code[1],$code[2],$code[3],$code[4]);
        $r=Select::whereIn('code',$codes)->where('is_full',1)->first();
        if($r){
            return $this->error(50021, '', '小码已经部分发货，不能扫描中码或者大码进行发货');
        }
        $count=Select::whereIn('code',$codes)->count();
        if ($count!=count($codes)){
            return $this->error(40023, '', '没有查到二维码对应的信息，请重试');
        }

        GoodSendJobs::dispatch($input);
        return $this->success([]);
    }

}