UserService.php

<?php

namespace App\Admin\Service;

use App\Admin\Actions\OrderAuditAction;
use App\Admin\Actions\OrderReverseAuditAction;
use App\Admin\Actions\User\UserAssignAction;
use App\Admin\Actions\User\UserStatusAction;
use App\Admin\Actions\User\UserTransferAction;
use App\Models\Cms\CmsUser;
use App\Models\User;
use App\Models\UserAddress;
use Dcat\Admin\Grid;
use Dcat\Admin\Http\JsonResponse;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Validator;
use Symfony\Component\HttpFoundation\Response;

class UserService
{

    public static function userListFilter(Grid $grid)
    {
        $grid->filter(function ($filter) {
            $filter->expand(true);
            $filter->whereBetween('create_time', function ($q) {
                $start = strtotime($this->input['start'] ?? null);
                $end = strtotime($this->input['end'] ?? null);
                $q->whereBetween('create_time', [$start, $end]);
            })->datetime()->width(3);

            $filter->startWith('company_name')->width(2);
            $filter->startWith('user_sn')->width(2);
            $filter->startWith('name')->width(2);
            $filter->equal('status')->select(admin_trans('user.options.status'))->width(2);
            $filter->equal('sale_id', trans('user.fields.sale_name'))->select
            (CmsUserService::getCmsUserListByDepartmentType(1, 0))->width(3);
            $filter->equal('reg_source')->select(admin_trans('user.options.reg_source'))->width(2);
        });
    }

    public static function userListListField(Grid $grid)
    {
        $grid->column('company_name');
        $grid->column('user_sn')->link(function ($user_sn) use ($grid) {
            return admin_url("/users/{$this->id}");
        });
        $grid->column('name');
        $grid->column('phone');
        $grid->column('email');
        $grid->column('remark');
        $grid->column('sale_name');
        $grid->column('order_num_data')->display(function ($order_num_data) {
            $data = OrderService::getUserOrderStatistical([$this->id])[$this->id] ?? [
                    "pending" => 0,
                    "all"     => 0
                ];
            return "{$data['pending']}/{$data['all']}";
        });
        $grid->column('inquiry_num_data')->display(function ($order_num_data) {
            $data = InquiryService::getInquiryCountByUserIds([$this->id])[$this->id] ?? [
                    "pending" => 0,
                    "all"     => 0
                ];
            return "{$data['pending']}/{$data['all']}";
        });
        $grid->column('create_time')->display(function ($time) {
            return $time ? date('Y-m-d H:i:s', $time) : '';
        })->sortable();;
        $grid->column('status')->using(admin_trans('user.options.status'));
        //客户来源
        $grid->column('reg_source')->using(admin_trans('user.options.reg_source'));
    }

    public static function userListTool(Grid $grid)
    {
        $action = [new UserTransferAction()];
        if (getAdminUserId() == 1000 || checkPerm(User::SEM_USER_VIEW_SUB) || checkPerm(User::SEM_USER_VIEW_ALL)) {
            $action[] = new UserAssignAction();
        }
        $grid->tools($action);
    }

    public static function userListActions(Grid $grid)
    {
        $grid->setActionClass(Grid\Displayers\Actions::class);
        $grid->disableEditButton();
        $grid->actions(function (Grid\Displayers\Actions $actions) {
            $actions->disableDelete();
            $actions->disableEdit();
            $actions->disableQuickEdit();
            $actions->disableView();
            // 当前行的数据数组
//            $rowArray = $actions->row->toArray();
            // 获取当前行主键值
            $id = $actions->getKey();
            $actions->append('<a style="margin-right: 5px" href="' . admin_url("/users/{$id}") . '" class="btn btn-primary btn-sm
            btn-mini">' . admin_trans("detail") . '</a>');
            //状态按钮
            $actions->append(new UserStatusAction());
        });
    }

    public static function updateUserStatus($id, $status)
    {
        $update = [
            "status" => $status
        ];
        User::updateById($id, $update);
    }

    public static function createUserAndAddress($params)
    {
        try {
            DB::beginTransaction();
            //判断邮箱是否唯一
            $email = $params['email'] ?? '';
            $userInfo = User::getInfoByEmail($email);
            if ($userInfo) {
                throw new \Exception("user email already exists");
            }
            $userData = [
                "company_name" => $params["company_name"] ?? "",
                "user_sn"      => $params["user_sn"] ?? "",
                "first_name"   => $params["first_name"] ?? "",
                "last_name"    => $params["last_name"] ?? "",
                "phone"        => $params["phone"] ?? "",
                "email"        => $params["email"] ?? "",
                "name"         => $params["email"] ?? "",
                "reg_source"   => User::REG_SOURCE_MANUAL,
                "remark"       => $params["remark"] ?? "",
                "password"     => "",
                "status"       => User::STATUS_NORMAL,
                "sale_id"      => request()->user->userId ?? "1000",
                "sale_name"    => request()->user->name ?? "admin",
                "create_time"  => time(),
                "update_time"  => time(),
            ];
            $userId = User::insertData($userData);
            $userSn = self::generateSn($userId);
            User::updateById($userId, ["user_sn" => $userSn]);

            foreach ($params['user_address_list'] as $address) {
                if ($address['_remove_']) {
                    continue;
                }
                $validator = Validator::make($address, [
                    'first_name'     => 'required',
                    'last_name'      => 'required',
                    'email'          => 'required',
                    'phone'          => 'required',
                    'country'        => 'required',
                    'city'           => 'required',
                    'address_type'   => 'required',
                    'post_code'      => 'required',
                    'detail_address' => 'required',
                    'is_default'     => 'required',
                ]);
                if ($validator->fails()) {
                    $error = $validator->errors()->first();
                    throw new \Exception("user addressList failed:" . $error);
                }
                $addressData = [
                    "user_id"        => $userId,
                    "first_name"     => $address["first_name"] ?? "",
                    "last_name"      => $address["last_name"] ?? "",
                    "address_type"   => $address["address_type"] ?? "",
                    "company_name"   => $address["company_name"] ?? "",
                    "email"          => $address["email"] ?? "",
                    "phone"          => $address["phone"] ?? "",
                    "country"        => $address["country"] ?? "",
                    "province"       => $address["province"] ?? "",
                    "city"           => $address["city"] ?? "",
                    "post_code"      => $address["post_code"] ?? "",
                    "detail_address" => $address["detail_address"] ?? "",
                    "is_default"     => $address["is_default"] ?? "",
                    "create_time"    => time(),
                    "update_time"    => time(),
                ];
                $addressData['consignee'] = $addressData['first_name'] . " " . $addressData['last_name'];
                UserAddress::insertData($addressData);
            }


            DB::commit();
        } catch (\Throwable $throwable) {
            DB::rollBack();
            throw $throwable;
        }
    }

    public static function generateSn($userId)
    {
        $id = str_pad($userId, 6, 0, STR_PAD_LEFT);
        return 'SU' . $id;
    }

    public static function transferUser($ids, $saleId)
    {
        try {
            DB::beginTransaction();
            $saleInfo = CmsUser::getInfoByUserId($saleId);
            if (empty($saleInfo)) {
                throw new \Exception("saleId is not exist");
            }
            //更新客户的数据
            $userList = User::getListByIdArr($ids);
            //判断客户状态
            foreach ($userList as $user) {
                if ($user['status'] != User::STATUS_NORMAL) {
                    throw new \Exception("user:[{$user['user_sn']}] status is not normal");
                }
            }

            $userIds = array_column($userList, "id");
            $update = [
                "sale_id"   => $saleId,
                "sale_name" => $saleInfo["name"],
            ];
            User::updateByIdArr($userIds, $update);
            InquiryService::batchUpdateSalesId($saleId, $userIds);
            OrderService::changeOrderSales($userIds, $saleId, $saleInfo["name"]);

            DB::commit();
        } catch (\Throwable $throwable) {
            DB::rollBack();
            throw $throwable;
        }
    }


}