beauti-nof/application/admin/controller/MobileApi.php

<?php

namespace app\admin\controller;

use app\admin\model\Admin;
use app\admin\model\AdminLog;
use app\admin\model\Mobile as MO;
use app\admin\model\MobileExportLog;
use app\common\controller\Backend;
use app\common\library\MobileConstant;
use app\common\model\SysConfig;
use app\common\service\MobileImport;
use app\service\EsMobileService;
use think\Db;
use think\Loader;

/**
 *
 *
 * @icon fa fa-mobile
 */
class MobileApi extends Backend
{
    const TYPE=MO::API;
    protected $noNeedRight=['mobile_rules','status','constant','exclude_nums'];
    /**
     * Mobile模型对象
     * @var \app\admin\model\Mobile
     */
    protected $model = null;
    protected $relationSearch=true;
    public function _initialize()
    {
        //ini_set('memory_limit',-1);
        parent::_initialize();
        $this->model = new \app\admin\model\Mobile;
        $this->assign('status',\app\common\model\Mobile::$status);
        $this->assign('network',MobileConstant::getNetworkString());
        $this->assign('network_color',MobileConstant::getNetworkColor());
        $this->assign('network_select',MobileConstant::getNetworkSelect());
    }
    /**
     * api号码管理
     */
    public function index()
    {
        //设置过滤方法
        $this->request->filter(['strip_tags', 'trim']);
        list($where, $sort, $order, $offset, $limit,$page) = $this->buildindexparams();

        if($this->request->get('export')==1 && $this->auth->check('mobile/_mobile_export')){
            if(MobileExportLog::exists()){
                die('有未完成导出，请稍后再试');
            }
            $export=MobileExportLog::make($this->admin('id'));
            ini_set('memory_limit',-1);
            ini_set('max_execution_time',0);
            $db=Db::name('mobile');
            $db->getConnection()->setConfig('resultset_type','array');
            $list= $db
                ->where($where)
                ->where('mobile.type',self::TYPE)
                ->orderRaw($this->getOrder())
                ->buildSql();
            //dd($list);
            $export['sql']=$list;
            $export->save();
            die('已添加到导出日志，请稍后查看');
        }

        if ($this->request->isAjax()) {
            //如果发送的来源是Selectpage，则转发到Selectpage
            if ($this->request->request('keyField')) {
                return $this->selectpage();
            }

            $deleteMode=input('_delete_condition');
            if($deleteMode==='true'){
                if(!$this->auth->check('mobile/del_condition')){
                    $this->error('您无权进行此操作');
                }
                $num=$this->model
                    ->alias(null)
                    ->where('mobile.type',self::TYPE)
                    ->where($where)
                    ->delete();
                AdminLog::record('根据条件删除号码');
                \app\common\model\Mobile::deleteOtherTableInfo();
                $deleteConditionMsg=sprintf("成功删除%d个号码",$num);
            }

            if(!$this->admin('is_sub')){
                $list = $this->model
                    ->with(['info','proxy'])
                    ->where($where)
                    ->where('mobile.type',self::TYPE)
                    ->orderRaw($this->getOrder())
                    ->page($page)
                    ->limit($limit)
                    ->select();
            }else{
                $list=$this->model
                    ->with(['info'])
                    ->field('mobile.*')
                    ->where($where)
                    ->where('mobile.type',self::TYPE)
                    ->orderRaw($this->getOrder())
                    ->page($page)
                    ->limit($limit)
                    ->select();
            }

            foreach ($list as $row) {
                $rules=[];
                foreach (MobileConstant::getFilters() as $rule=>$field){
                    foreach (array_values($field) as $column){
                        if($row[$column]==1){
                            $rules[]=$rule;
                        }
                    }
                }
                $row['rules']=array_values(array_unique($rules));
            }

            $result = array("total" => EsMobileService::count(self::TYPE), "rows" => $list,'input'=>input(),'delete_condition_msg'=>$deleteConditionMsg??null,'url'=>$this->request->url().'&export=1');

            return json($result);
        }
        $this->assign('no_type',array_column(MobileConstant::getNoType(),'name','id'));
        $this->assign('filters',MobileConstant::getFilters());
        return $this->view->fetch();
    }
    protected function getOrder(){
        $filter=json_decode(input('filter'),true);
        $default='mobile.id desc';
        return $default;
        if(!$filter||empty($filter['no'])){
            return $default;
        }
        $value=str_replace('%','',$filter['no']);
        if(!$value){
            return $default;
        }
        $lastNum=substr($value,-1);
        if(strlen($value)==1){
            return "FIELD(`mobile.filter_no_pos_11`,$lastNum) DESC";
        }else{
            $arr=[];
            $numLen=strlen($value);
            $idx=1;
            for ($i=11;$i>=2;$i--){
                if($idx>$numLen){
                    break;
                }
                $numPos=$value[$numLen-$idx];
                $arr[]="FIELD(mobile.filter_no_pos_{$i},$numPos) DESC";
                $idx++;
            }

            return implode(',',$arr);
        }
    }
    protected function buildindexparams($searchfields = null, $relationSearch = null)
    {
        $searchfields = is_null($searchfields) ? $this->searchFields : $searchfields;
        $relationSearch = is_null($relationSearch) ? $this->relationSearch : $relationSearch;
        $search = $this->request->get("search", '');
        $filter = $this->request->get("filter", '');
        $op = $this->request->get("op", '', 'trim');
        $sort = $this->request->get("sort", !empty($this->model) && $this->model->getPk() ? $this->model->getPk() : 'id');
        $order = $this->request->get("order", "DESC");
        $offset = $this->request->get("offset/d", 0);
        $limit = $this->request->get("limit/d", 999999);
        //新增自动计算页码
        $page = $limit ? intval($offset / $limit) + 1 : 1;
        if ($this->request->has("page")) {
            $page = $this->request->get("page/d", 1);
        }
        $this->request->get([config('paginate.var_page') => $page]);
        $filter = (array)json_decode($filter, true);
        $op = (array)json_decode($op, true);
        $filter = $filter ? $filter : [];
        $where = [];
        $alias = [];
        $bind = [];
        $name = '';
        $aliasName = '';
        if (!empty($this->model) && $this->relationSearch) {
            $name = $this->model->getTable();
            $alias[$name] = Loader::parseName(basename(str_replace('\\', '/', get_class($this->model))));
            $aliasName = $alias[$name] . '.';
        }
        $sortArr = explode(',', $sort);
        foreach ($sortArr as $index => & $item) {
            $item = stripos($item, ".") === false ? $aliasName . trim($item) : $item;
        }
        unset($item);
        $sort = implode(',', $sortArr);
        $adminIds = $this->getDataLimitAdminIds();
        if (is_array($adminIds)) {
            $where[] = [$aliasName . $this->dataLimitField, 'in', $adminIds];
        }
        if ($search) {
            $searcharr = is_array($searchfields) ? $searchfields : explode(',', $searchfields);
            foreach ($searcharr as $k => &$v) {
                $v = stripos($v, ".") === false ? $aliasName . $v : $v;
            }
            unset($v);
            $where[] = [implode("|", $searcharr), "LIKE", "%{$search}%"];
        }
        $index = 0;
        foreach ($filter as $k => $v) {
            if($k=='rules'){
                continue;
            }
            if (!preg_match('/^[a-zA-Z0-9_\-.]+$/', $k)) {
                continue;
            }
            $sym = isset($op[$k]) ? $op[$k] : '=';
            if (stripos($k, ".") === false) {
                $k = $aliasName . $k;
            }
            $v = !is_array($v) ? trim($v) : $v;
            $sym = strtoupper(isset($op[$k]) ? $op[$k] : $sym);
            //null和空字符串特殊处理
            if (!is_array($v)) {
                if (in_array(strtoupper($v), ['NULL', 'NOT NULL'])) {
                    $sym = strtoupper($v);
                }
                if (in_array($v, ['""', "''"])) {
                    $v = '';
                    $sym = '=';
                }
            }

            switch ($sym) {
                case '=':
                case '<>':
                    $where[] = [$k, $sym, (string)$v];
                    break;
                case 'LIKE':
                case 'NOT LIKE':
                case 'LIKE %...%':
                case 'NOT LIKE %...%':
                    $where[] = [$k, trim(str_replace('%...%', '', $sym)), "%{$v}%"];
                    break;
                case '>':
                case '>=':
                case '<':
                case '<=':
                    $where[] = [$k, $sym, intval($v)];
                    break;
                case 'FINDIN':
                case 'FINDINSET':
                case 'FIND_IN_SET':
                    $v = is_array($v) ? $v : explode(',', str_replace(' ', ',', $v));
                    $findArr = array_values($v);
                    foreach ($findArr as $idx => $item) {
                        $bindName = "item_" . $index . "_" . $idx;
                        $bind[$bindName] = $item;
                        $where[] = "FIND_IN_SET(:{$bindName}, `" . str_replace('.', '`.`', $k) . "`)";
                    }
                    break;
                case 'IN':
                case 'IN(...)':
                case 'NOT IN':
                case 'NOT IN(...)':
                    $where[] = [$k, str_replace('(...)', '', $sym), is_array($v) ? $v : explode(',', $v)];
                    break;
                case 'BETWEEN':
                case 'NOT BETWEEN':
                    $arr = array_slice(explode(',', $v), 0, 2);
                    if (stripos($v, ',') === false || !array_filter($arr)) {
                        continue 2;
                    }
                    //当出现一边为空时改变操作符
                    if ($arr[0] === '') {
                        $sym = $sym == 'BETWEEN' ? '<=' : '>';
                        $arr = $arr[1];
                    } elseif ($arr[1] === '') {
                        $sym = $sym == 'BETWEEN' ? '>=' : '<';
                        $arr = $arr[0];
                    }
                    $where[] = [$k, $sym, $arr];
                    break;
                case 'RANGE':
                case 'NOT RANGE':
                    $v = str_replace(' - ', ',', $v);
                    $arr = array_slice(explode(',', $v), 0, 2);
                    if (stripos($v, ',') === false || !array_filter($arr)) {
                        continue 2;
                    }
                    //当出现一边为空时改变操作符
                    if ($arr[0] === '') {
                        $sym = $sym == 'RANGE' ? '<=' : '>';
                        $arr = $arr[1];
                    } elseif ($arr[1] === '') {
                        $sym = $sym == 'RANGE' ? '>=' : '<';
                        $arr = $arr[0];
                    }
                    $tableArr = explode('.', $k);
                    if (count($tableArr) > 1 && $tableArr[0] != $name && !in_array($tableArr[0], $alias) && !empty($this->model)) {
                        //修复关联模型下时间无法搜索的BUG
                        $relation = Loader::parseName($tableArr[0], 1, false);
                        $alias[$this->model->$relation()->getTable()] = $tableArr[0];
                    }
                    $where[] = [$k, str_replace('RANGE', 'BETWEEN', $sym) . ' TIME', $arr];
                    break;
                case 'NULL':
                case 'IS NULL':
                case 'NOT NULL':
                case 'IS NOT NULL':
                    $where[] = [$k, strtolower(str_replace('IS ', '', $sym))];
                    break;
                default:
                    break;
            }
            $index++;
        }
        if (!empty($this->model)) {
            $this->model->alias($alias);
        }
        if(isset($filter['rules']) && $filter['rules']){
            $temp=[];
            foreach (MobileConstant::getFilters()[$filter['rules']] as $pos=>$column){
                $temp[]=$column;
            }
            $flip=array_flip($temp);

            if(isset($filter['filter_first_last'])){
                if($filter['filter_first_last']==1){
                    $where[] = [$temp[1],1];
                }elseif ($filter['filter_first_last']==2){
                    $where[] = [$temp[0],1];
                }
            }else {
                $where[] = [implode("|", $temp), 1];
            }
        }

        $model = $this->model;
        $where = function ($query) use ($where, $alias, $bind, &$model,$filter) {
            if (!empty($model)) {
                $model->alias($alias);
                $model->bind($bind);
            }
            foreach ($where as $k => $v) {
                if (is_array($v)) {
                    if(in_array($v[0],['mobile_sub.sub_top_time','mobile_sub.sub_rec_time'])){
                        if($v[2]) {
                            $query->whereIn($v[0], 1);
                        }else{
                            $query->where(function ($query)use ($v){
                                $query->whereRaw("{$v[0]}=0 or {$v[0]} is null");
                            });
                        }
                        continue;
                    }elseif ($v[0]=='proxy.nickname'){
                        $proxy_id=Admin::where('proxy',1)->where('nickname','like',"%{$v[2]}%")->column('id')?:[0];
                        $query->whereIn('proxy_id',$proxy_id);
                        continue;
                    }elseif ($v[0]=='mobile.exclude_nums'){
                        $arr=explode(',',$v[2]);
                        foreach ($arr as $num){
                            if(!is_numeric($num)){
                                continue;
                            }
                            $query->where(sprintf("filter_num_%s",$num),0);
                        }
                        continue;
                    }elseif ($v[0]=='mobile.filter_first_last'){
                        continue;
                    }elseif ($v[0]=='mobile.no'){
                        $noSearch=$filter['no'];
                        if(isset($filter['filter_first_last'])){
                            if($filter['filter_first_last']==1) {
                                $noPad = str_pad($noSearch, 11, 'a',STR_PAD_LEFT);
                                for ($i = 11; $i >1; $i--) {
                                    if ($noPad[$i-1] !== 'a') {
                                        $query->where("filter_no_pos_{$i}", $noPad[$i-1]);
                                    }
                                }
                            }elseif ($filter['filter_first_last']==2){
                                $query->where('filter_no_pos_11','<>',$noSearch[strlen($noSearch)-1])->whereRaw("LOCATE('{$noSearch}',no)");
                            }
                        }else{
                            //$query->where('no','like',"%{$noSearch}%");
                            $query->whereRaw("LOCATE('{$noSearch}',no)");
                        }
                        continue;
                    }
                    call_user_func_array([$query, 'where'], $v);
                } else {
                    $query->where($v);
                }
            }

            $precise_search=input('precise_search/a');
            if(is_array($precise_search) && $precise_search){
                foreach ($precise_search as $idx=>$num){
                    if(!is_numeric($num)){
                        continue;
                    }
                    $query->where(sprintf('mobile.filter_no_pos_%d',$idx),(int)$num);
                }
            }
        };
        return [$where, $sort, $order, $offset, $limit, $page, $alias, $bind];
    }
    #规则定价
    public function price(){
        if($this->request->isGet()){
            $this->assign('rules',MobileConstant::getRuleKeys());
            $this->assign('row',SysConfig::look('api_rule_price',[]));
            return $this->fetch();
        }
        $rules=input('row/a');
        SysConfig::set('api_rule_price',$rules);
        $this->success();
    }
    public function del_all(){
        $data=['num'=>0];
        $data['num']= MO::where('type',self::TYPE)->delete();
        \app\common\model\Mobile::deleteOtherTableInfo();
        EsMobileService::clear(self::TYPE);
        AdminLog::record('清空号码');
        $this->success('',null,$data);
    }

    /**
     *  上架
     * @param $ids
     */
    public function up($ids){
        $mobiles=MO::where('type',self::TYPE)->whereIn('id',$ids)->select();
        foreach ($mobiles as $mobile){
            $mobile['type']=$mobile::BEAUTI;
            $mobile->save();
        }
        $this->success();
    }

    /**
     *  上架
     * @param $ids
     */
    public function all_up(){
        $ids=MO::where('type',self::TYPE)->column('id');

        // 改db
        (new MO)->where(['type'=>self::TYPE])->update(['type'=>MO::BEAUTI]);
        // 改es
        EsMobileService::updateById($ids,['type'=>MO::BEAUTI]);

        AdminLog::record('全部导入靓号');
        $this->success();
    }
}