<?php
// +----------------------------------------------------------------------
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.crmeb.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
// +----------------------------------------------------------------------
// | Author: CRMEB Team <admin@crmeb.com>
// +----------------------------------------------------------------------
namespace app\services\supplier;

use app\dao\supplier\SystemSupplierDao;
use app\dao\system\admin\SystemAdminDao;
use app\services\BaseServices;
use app\services\order\StoreOrderServices;
use app\services\order\StoreOrderRefundServices;
use app\services\product\branch\StoreBranchProductServices;
use app\services\system\attachment\SystemAttachmentServices;
use app\services\system\SystemUserApplyServices;
use crmeb\exceptions\AdminException;
use think\exception\ValidateException;

/**
 * 供应商
 * Class SystemSupplierServices
 * @package app\services\supplier
 * @mixin SystemSupplierDao
 */
class SystemSupplierServices extends BaseServices{
    protected $adminDao = NULL;
    /**
     * 构造方法
     * SystemSupplierServices constructor.
     * @param SystemSupplierDao $dao
     * @param SystemAdminDao    $adminDao
     */
    public function __construct(SystemSupplierDao $dao,SystemAdminDao $adminDao){
        $this->dao      = $dao;
        $this->adminDao = $adminDao;
    }
    /**
     * 获取供应商
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\DataNotFoundException
     */
    public function getSupplierInfo(int $id,string $field = '*',array $with = []){
        $info = $this->dao->getOne(['id' => $id,'is_del' => 0],$field,$with);
        if(!$info){
            throw new ValidateException('供应商不存在');
        }
        return $info;
    }
    /**
     * 供应商列表
     * @param array $where
     * @param array $field
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getSupplierList(array $where,array $field = ['*']){
        [$page,$limit] = $this->getPageValue();
        $list = $this->dao->getSupplierList($where,$field,$page,$limit);
        if($list){
            $prefix = config('admin.supplier_prefix');
            foreach($list as &$item){
                if(isset($item['add_time']) && $item['add_time']) $item['_add_time'] = date('Y-m-d H:i:s',$item['add_time']);
                $item['prefix'] = $prefix;
            }
        }
        $count = $this->dao->count($where);
        return compact('list','count');
    }
    /**
     * 修改管理员
     * @param array $data
     * @return mixed
     */
    public function save(int $id,array $data){
        if(!$supplierInfo = $this->dao->get($id)){
            throw new AdminException('供应商不存在,无法修改');
        }
        if($supplierInfo->is_del){
            throw new AdminException('供应商已经删除');
        }
        if(!$adminInfo = $this->adminDao->get($supplierInfo['admin_id'])){
            throw new AdminException('管理员不存在,无法修改');
        }
        if($adminInfo->is_del){
            throw new AdminException('管理员已经删除');
        }
        //修改账号
        if(isset($data['account']) && $data['account'] != $adminInfo->account && $this->adminDao->isAccountUsable($data['account'],$supplierInfo['admin_id'],4)){
            throw new AdminException('管理员账号已存在');
        }
        return $this->transaction(function() use ($id,$data,$adminInfo,$supplierInfo){

            $adminData = [
                'pwd'       => $this->passwordHash($data['pwd']),
                'real_name' => $data['name'] ?? $adminInfo->real_name,
                'phone'     => $data['phone'] ?? $adminInfo->phone,
                'account'   => $data['account'] ?? $adminInfo->account
            ];
            // 修改管理员
            $res = $this->adminDao->update($adminInfo['id'],$adminData);
            if(!$res) throw new AdminException('管理员修改失败');
            // 修改供应商
            unset($data['pwd'],$data['conf_pwd'],$data['account']);
            $this->dao->update($id,$data);
            $res1 = $supplierInfo->save();
            if(!$res1) throw new AdminException('供应商修改失败');
            return TRUE;
        });
    }
    /**
     * @param int $id
     * @return mixed
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function delete(int $id){
        if(!$supplierInfo = $this->dao->get($id)){
            throw new AdminException('供应商不存在,无法修改');
        }
        if($supplierInfo->is_del){
            throw new AdminException('供应商已经删除');
        }
        if(!$adminInfo = $this->adminDao->get($supplierInfo['admin_id'])){
            throw new AdminException('管理员不存在,无法删除');
        }
        if($adminInfo->is_del){
            throw new AdminException('管理员已经删除');
        }
        /** @var StoreOrderServices $storeOrderServices */
        $storeOrderServices = app()->make(StoreOrderServices::class);
        $orderCount         = $storeOrderServices->count(['supplier_id' => $id,'status' => 0]);
        if(!$orderCount){
            $orderCount = $storeOrderServices->count(['supplier_id' => $id,'status' => 1]);
            if(!$orderCount){
                $orderCount = $storeOrderServices->count(['supplier_id' => $id,'status' => 5]);
            }
        }
        if($orderCount){
            return $this->fail('删除失败,该供应商还有待处理订单');
        }
        return $this->transaction(function() use ($id,$supplierInfo,$adminInfo){
            $adminInfo->status = 0;
            $adminInfo->is_del = 1;
            // 修改管理员
            $res = $adminInfo->save();
            if(!$res) throw new AdminException('管理员删除失败');
            $supplierInfo->is_show = 0;
            $supplierInfo->is_del  = 1;
            // 修改供应商
            $res1 = $supplierInfo->save();
            if(!$res1) throw new AdminException('供应商删除失败');
            /** @var StoreBranchProductServices $storeBranchProducesServices */
            $storeBranchProducesServices = app()->make(StoreBranchProductServices::class);
            //删除供应商商品
            $storeBranchProducesServices->deleteProducts([],2,$id);
            /** @var SystemAttachmentServices $attach */
            $attach = app()->make(SystemAttachmentServices::class);
            //删除附件
            $attach->delAttachment([],4,$id);
            return TRUE;
        });
    }
    /**
     * 平台供应商运营统计
     * @param int   $supplierId
     * @param array $time
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function supplierChart(int $supplierId,array $time){
        $list = $this->dao->getSupplierList(['is_del' => 0,'is_show' => 1],['id','supplier_name']);
        /** @var StoreOrderServices $orderServices */
        $orderServices = app()->make(StoreOrderServices::class);
        /** @var  StoreOrderRefundServices $orderRefundServices */
        $orderRefundServices = app()->make(StoreOrderRefundServices::class);
        $where               = ['time' => $time];
        $order_where  = ['paid' => 1,'pid' => 0,'is_del' => 0,'is_system_del' => 0,'refund_status' => [0,3]];
        $refund_where = ['refund_type' => 6];
        foreach($list as &$item){
            $supplier_where             = ['supplier_id' => $item['id']];
            $item['order_price']        = $orderServices->sum($where + $supplier_where + $order_where,'pay_price',TRUE);
            $item['order_count']        = $orderServices->count($where + $supplier_where + $order_where);
            $item['refund_order_price'] = $orderRefundServices->sum($where + $supplier_where + $refund_where,'refunded_price',TRUE);
            $item['refund_order_count'] = $orderRefundServices->count($where + $supplier_where + $refund_where);
        }
        return $list;
    }
    /**
     * 供应商选择列表
     * @param array $where
     * @param array $field
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function getSupplierSearch(array $where,array $field = ['*']){
        return $this->dao->getSupplierList($where,$field,0,0);
    }
    /**
     * 供应商入住审核通过创建数据
     * @param int   $applyId
     * @param array $info
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function verifyAgreeCreate(int $applyId,array $info = []){
        if(!$applyId){
            throw new ValidateException('缺少申请ID');
        }
        /** @var SystemUserApplyServices $applyServices */
        $applyServices = app()->make(SystemUserApplyServices::class);
        if(!$info){
            $info = $applyServices->get($applyId);
            if(!$info){
                throw new ValidateException('申请数据不存在');
            }
            $info = $info->toArray();
        }
        $data        = [
            'supplier_name' => $info['system_name'],
            'account'       => $this->getAccount($info['phone']),
            'phone'         => $info['phone'],
            'name'          => $info['name'],
            'pwd'           => substr($info['phone'],-6)
        ];

        // todo  版本迭代  当前功能暂不可用
        throw new ValidateException('开发中...');
        // $supplier_id = $this->create($data);
        // return $this->dao->get($supplier_id)->toArray();
    }
    /**
     * 获取同意申请 创建账号
     * @param string $phone
     * @return string
     */
    public function getAccount(string $phone){
        $account = '';
        if($phone){
            //当前手机号当作账号是否存在
            $adminDCount = $this->adminDao->count(['account' => $phone,'admin_type' => 4,'is_del' => 0]);
            $account     = $phone;
            if($adminDCount){
                $account = $account.'_'.$adminDCount;
            }
        }
        return $account;
    }


    //////////////////////////////////////////////////////////////////////////////////

    /**
     * Common: 添加供应商
     * Author: wu-hui
     * Time: 2024/01/17 11:43
     * @param array $data
     * @return mixed
     */
    public function create(array $data){
        return $this->transaction(function() use ($data){
            // 添加供应商信息
            $relation_id = $this->dao->save($data['accountInfo'])->id;
            if(!$relation_id) throw new AdminException('供应商添加失败');
            // 添加账号信息
            $accountPassword = $data['accountPassword'];
            $adminId = (int)$this->adminDao->getModel()->insertGetId([
                'pwd'         => $this->passwordHash($accountPassword['supplier_password']),
                'admin_type'  => 4,
                'account'     => $accountPassword['supplier_account'],
                'roles'       => 1,
                'real_name'   => $data['accountInfo']['supplier_name'],
                'phone'       => $data['accountInfo']['phone'],
                'level'       => 0,
                'relation_id' => $relation_id
            ]);
            if($adminId <= 0) throw new AdminException('管理员添加失败');
            // 修改超级管理员关联
            $this->dao->update($relation_id,['admin_id' => (int)$adminId]);

            return $relation_id;
        });
    }
    /**
     * Common: 修改供应商信息
     * Author: wu-hui
     * Time: 2024/01/29 13:46
     * @param array $data
     * @return mixed
     */
    public function editInfo(array $data){
        return $this->transaction(function() use ($data){
            // 修改供应商信息
            $res = $this->dao->update($data['supplierId'],$data['accountInfo']);
            if(!$res) throw new AdminException('供应商信息修改失败');
            // 修改账号信息
            $accountPassword = $data['accountPassword'];
            if(!empty($accountPassword['supplier_account']) && !empty($accountPassword['supplier_password'])){

                debug("开发中......");
                // $systemAdmin =
                // $this->adminDao->update();
                // $adminId = (int)$this->adminDao->getModel()->insertGetId([
                //     'pwd'         => $this->passwordHash($accountPassword['supplier_password']),
                //     'admin_type'  => 4,
                //     'account'     => $accountPassword['supplier_account'],
                //     'roles'       => 1,
                //     'real_name'   => $data['accountInfo']['supplier_name'],
                //     'phone'       => $data['accountInfo']['phone'],
                //     'level'       => 0,
                //     'relation_id' => $relation_id
                // ]);
                // if($adminId <= 0) throw new AdminException('管理员添加失败');

            }

            return true;
        });
    }
    /**
     * Common: 某个数据是否已经存在
     * Author: wu-hui
     * Time: 2024/01/17 10:28
     * @param     $field
     * @param     $fieldValue
     * @param int $supplierId
     * @return bool
     */
    public function isHave($field,$fieldValue,int $supplierId = 0):bool{
        $count = $this->dao->getModel()
            ->where($field,$fieldValue)
            ->when($supplierId > 0,function($query) use ($supplierId){
                $query->where('id','<>',$supplierId);
            })
            ->count();
        return $count > 0;
    }
    /**
     * Common: 账号是否存在
     * Author: wu-hui
     * Time: 2024/01/17 10:53
     * @param     $account
     * @param int $supplierId
     * @return bool
     */
    public function accountIsHas($account,int $supplierId = 0):bool{
        $count = $this->adminDao->getModel()
            ->where('account',$account)
            ->where('admin_type',4)
            ->where('is_del',0)
            ->when($supplierId > 0,function($query) use ($supplierId){
                $query->where('relation_id','<>',$supplierId);
            })
            ->count();
        return $count > 0;
    }


    /**
     * Common: 获取列表
     * Author: wu-hui
     * Time: 2024/01/17 14:28
     * @param        $search
     * @param        $page
     * @param        $limit
     * @param string $field
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function supplierList($search, $page, $limit, $field = '*'){
        $query = $this->dao->searchModel($search);
        $list = $query
            ->field($field)
            ->order('sort desc,add_time desc,id desc')
            ->page($page, $limit)
            ->select();
        $count = $query->count();

        return compact('count', 'list');
    }
    /**
     * Common: 获取单条信息
     * Author: wu-hui
     * Time: 2024/01/29 11:33
     * @param $search
     * @return array
     */
    public function getSingleInfo($search){
        return $this->dao->searchModel($search)->findOrEmpty()->toArray();
    }


}