SupplierAccountApiController.php

<?php

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use App\Http\Controllers\Filter\SupplierAccountFilter;
use App\Http\Services\LogService;
use App\Http\Services\SupplierAccountService;
use App\Http\Services\SupplierSubAccountService;
use App\Http\Transformers\SupplierLogTransformer;
use App\Http\Validators\SupplierAccountValidator;
use App\Model\LogModel;
use App\Model\RedisModel;
use App\Model\SupplierAccountModel;
use App\Model\SupplierChannelModel;
use App\Model\SupplierLogModel;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Redis;
use Illuminate\Support\Facades\Validator;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

//通用API,比如获取品牌列表,分类列表等
class SupplierAccountApiController extends Controller
{
    public function Entrance(Request $request, $id)
    {
        $this->$id($request, $id);
    }

    //获取供应商信息变更记录
    public function GetSupplierAccountList($request)
    {
        $service = new SupplierAccountService();
        $list = $service->getSupplierAccountList($request);
        $this->response(0, 'ok', $list['data'], $list['total']);
    }

    //添加
    public function AddSupplierAccount($request)
    {
        $data = $request->only([
            'supplier_code',
            'mobile',
            'password_raw',
            'a_type',
        ]);
        $validator = new SupplierAccountValidator();
        $check = $validator->checkSave($request);
        if ($check !== true) {
            $this->response(-1, $check);
        }
        $supplierModel = new SupplierChannelModel();
        $supplierId = $supplierModel->where('supplier_code', $data['supplier_code'])->value('supplier_id');
        $data['supplier_id'] = $supplierId;
        $data['a_type'] = empty($data['a_type']) ? 0 : 1;
        $data['create_time'] = time();
        $data['create_uid'] = $request->user->userId;
        $data['password'] = Hash::make($data['password_raw']);
        $model = new SupplierAccountModel();
        $id = $model->insertGetId($data);
        if ($id) {
            //还要插入一个redis
//            $redis = new RedisModel();
            $redis = Redis::connection('user');
            $redis->hset('yunxin_api_user_mobile', $data['mobile'], $id);
            $accountService = new SupplierAccountService();
            $accountService->pushToInitData($data['supplier_code']);
            $this->response(0, '添加成功');
        }
        $this->response(-1, '添加失败');
    }

    //修改
    public function UpdateSupplierAccount($request)
    {
        $data = $request->only([
            'id',
            'supplier_code',
            'mobile',
            'password_raw',
            'a_type',
        ]);
        $validator = new SupplierAccountValidator();
        $check = $validator->checkSave($request);
        if ($check !== true) {
            $this->response(-1, $check);
        }
        $supplierModel = new SupplierChannelModel();
        $supplierId = $supplierModel->where('supplier_code', $data['supplier_code'])->value('supplier_id');
        $data['supplier_id'] = $supplierId;
        $data['a_type'] = empty($data['a_type']) ? 0 : 1;
        $data['update_time'] = time();
        $data['create_uid'] = $request->user->userId;
        $data['password'] = Hash::make($data['password_raw']);
        $model = new SupplierAccountModel();
        $result = $model->where('id', $data['id'])->update($data);
        if ($result) {
            //还要插入一个redis
            $redis = Redis::connection('user');
            $redis->hset('yunxin_api_user_mobile', $data['mobile'], $data['id']);
            $accountService = new SupplierAccountService();
            $accountService->pushToInitData($data['supplier_code']);
            $this->response(0, '修改成功');
        }
        $this->response(-1, '修改失败', $result);
    }

    //启用
    public function EnableSupplierAccount($request)
    {
        $id = $request->get('id');
        $model = new SupplierAccountModel();
        $data['update_time'] = date('Y-m-d H:i:s');
        $data['a_status'] = 1;
        $result = $model->where('id', $id)->update($data);
        if ($result) {
            $this->response(0, '启用成功');
        }
        $this->response(-1, '启用失败', $result);
    }

    //禁用
    public function DisableSupplierAccount($request)
    {
        $id = $request->get('id');
        $model = new SupplierAccountModel();
        $data['update_time'] = date('Y-m-d H:i:s');
        $data['a_status'] = 0;
        $result = $model->where('id', $id)->update($data);
        if ($result) {
            $this->response(0, '禁用成功');
        }
        $this->response(-1, '禁用失败', $result);
    }

    //获取芯链账号
    public function GetSupplierAccount($request)
    {
        $id = $request->input('id');
        $type = $request->input('type');
        $account = SupplierAccountModel::where('id', $id)->first()->toArray();
        $logService = new LogService();
        $temp = ($type == 'mobile') ? '账号' : '密码';
        $content = $request->user->name . ' 查看了芯链账号的' . $temp;
        $logService->AddLog($account['supplier_id'], LogModel::VIEW_OPERATE, '查看供应商基本资料', $content);
        $this->response(0, 'ok', $account);
    }

    //子账号管理
    public function GetSupplierSubAccountList($request)
    {
        $map = $request->all();
        $result = (new SupplierSubAccountService())->getSupplierSubAccountList($map);
        $this->response(0, 'ok', $result['list'], $result['total']);
    }

    public function SaveSupplierSubAccount($request)
    {
        $data = $request->only([
            'account_id',
            'sbat_id',
            'mobile',
            'password_raw',
            'name',
            'email',
            'user_rule',
            'user_message_rule',
        ]);
        $rules = [
            "mobile" => "required|regex:/^1[0-9][0-9]{9}$/",
            "password_raw" => "required",
            "name" => "required",
            "email" => "required|email",
        ];
        $messages = [
            'supplier_code.required' => '请选择一个供应商',
            'mobile.required' => '登录账号不能为空',
            'mobile.regex' => '账号格式必须为手机号',
            'email.email' => '邮箱格式不对',
            'password_raw.required' => '账号密码不能为空',
        ];
        $validator = Validator::make($data, $rules, $messages);
        //判断联系方式的表单验证
        if ($validator->fails()) {
            $this->response(-1, $validator->errors()->first());
        }
        $data['user_rule'] = $data['user_rule'] ?: [];

        $data['user_rule'] = json_encode($data['user_rule']);
        $data['user_message_rule'] = $data['user_message_rule'] ?: [];
        $data['user_message_rule'] = json_encode($data['user_message_rule']);
        $accountId = $data['account_id'];
        unset($data['account_id']);
        if (empty($data['sbat_id'])) {
            unset($data['sbat_id']);
            $result = (new SupplierSubAccountService())->addSupplierSubAccount($accountId, $data);
        } else {
            $result = (new SupplierSubAccountService())->updateSupplierSubAccount($accountId, $data);
        }
        if ($result === true) {
            $this->response(0, '操作成功');
        } else {
            $this->response(-1, $result);
        }
    }

    //修改子账号状态
    public function ChangeSupplierSubAccountStatus($request)
    {
        $accountId = $request->input('account_id');
        $sbatId = $request->input('sbat_id');
        $status = $request->input('status');
        $result = (new SupplierSubAccountService())->changeSupplierSubAccountStatus($accountId, $sbatId, $status);
        if ($result === true) {
            $this->response(0, '操作成功');
        }
        $this->response(-1, '操作失败', $result);
    }

    //保存消息菜单
    public function SaveSupplierAccountMessagePerm($request)
    {
        $accountId = $request->get('account_id');
        $userMessageRule = $request->input('user_message_rule');
        $result = (new SupplierSubAccountService())->saveMessageMenu($accountId, $userMessageRule);
        if ($result === true) {
            $this->response(0, '保存成功');
        }
        $this->response(-1, '保存失败', $result);
    }
}