zc100/application/api/controller/Diyajax.php

<?php
/**
 * 易优CMS
 * ============================================================================
 * 版权所有 2016-2028 海南赞赞网络科技有限公司，并保留所有权利。
 * 网站地址: http://www.eyoucms.com
 * ----------------------------------------------------------------------------
 * 如果商业用途务必到官方购买正版授权, 以免引起不必要的法律纠纷.
 * ============================================================================
 * Author: 小虎哥 <1105415366@qq.com>
 * Date: 2018-4-3
 */

namespace app\api\controller;

use think\Config;
use think\Db;
use PHPExcel_IOFactory;

class Diyajax extends Base
{
    /*
     * 初始化操作
     */
    public function _initialize() {
        parent::_initialize();
    }

    /**
     * 检验会员登录
     */
    public function check_userinfo()
    {
        if (IS_AJAX) {
            \think\Session::pause(); // 暂停session，防止session阻塞机制
            $ajaxLogic = new \app\api\logic\AjaxLogic;
            $result = $ajaxLogic->check_userinfo();
            if (!empty($result['data']['ey_is_login'])) {
                $assignData = [
                    'users' => $result['users'],
                ];
                $this->assign($assignData);

                $filename = './template/'.THEME_STYLE_PATH.'/'.'system/users_info.htm';
                if (file_exists($filename)) {
                    $html = $this->fetch($filename); // 渲染模板标签语法
                } else {
                    $html = '缺少模板文件：'.ltrim($filename, '.');
                }
                $result['data']['html'] = $html;
            }
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$result['data']]);
        }
        to_index("404");
    }

    /*
     * 下载文件
     * https://www.zc10000.com/api/diyajax/downfile
     */
    public function downFile(){

        $id = request()->get('id',0);
        //var_dump((int)$id);
        //非法
        if((int)$id === 0){
            respose(['code'=>0, 'msg'=>'请求失败！', 'data'=>[]]);
        }
        //查找记录
        $one = Db::name('users_down')->where(['id'=>$id])->find();

        if((int)$one['num'] >= 3){
            respose(['code'=>0, 'msg'=>'该链接请求下载次数不能超过3次，链接已失效！', 'data'=>[]]);
        }

        if((int)$one['expire_time'] < time()){
            //已过期
            respose(['code'=>0, 'msg'=>'下载链接已失效！', 'data'=>[]]);
        }

        //查找下载地址
        $artData = Db::name('zczygz_content')->where('aid', $one['aid'])
            ->find();
        if(empty($artData) || empty($artData['down'])){
            respose(['code'=>0, 'msg'=>'文档不存在！', 'data'=>[]]);
        }

        //php
        $ext = explode('.',$artData['down']);
        $ext = end($ext);
        $filename = $one['title'].'.'.$ext;
        $file = $artData['down'].'?attname='.$filename;
        //$filename = basename($file);
        //echo $file;


        //记录下载次数
        Db::name('users_down')->where(['id'=>$id])->setInc('num');

        header('location:'.$file);
        //$this->downFileCurl($file,$filename);

    }

    public function downFileCurl($url, $file_name)
    {
        header('Content-Description: File Transfer');
        header('Content-Type: application/vnd.android.package-archive');
        header('Content-Disposition: attachment; filename=' . $file_name);
        header('Content-Transfer-Encoding: binary');
        header('Expires: 0');
        header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
        header('Pragma: public');
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HEADER, 0);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 0);
        curl_setopt($ch, CURLOPT_WRITEFUNCTION, function ($ch, $buffer) {
            echo $buffer;
            return strlen($buffer);
        });
        curl_exec($ch);
        curl_close($ch);
    }

    /*
     * 获取所有申报专业
     *  /api/Diyajax/getZcList
     */
    public function getZcList()
    {
        $param = request()->param();
        $param['id'] = (int)$param['id'];
        if(!empty($param['id'])){
            if($param['id'] === 10001){
                //不限制
                //查找
                $list = Db::name('zc_position')
                    ->field('id,title')
                    ->where('is_del', 0)
                    ->where('status', 1)
                    ->select();
            }else if($param['id'] === 20000) {
                //全国
                $list = Db::name('zc_position')
                    ->field('id,title')
                    ->where('type', 0)
                    ->where('is_del', 0)
                    ->where('status', 1)
                    ->select();
            }else {
                //具体地区
                $ids = Db::name('zc_map')
                    ->where('map_id',$param['id'])
                    ->where('is_del', 0)
                    ->column('zc_id');
                $list = Db::name('zc_position')
                    ->field('id,title')
                    ->where('type', 1)
                    ->where('is_del', 0)
                    ->where('status', 1)
                    ->whereIn('id', $ids)
                    ->select();
            }
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list]);
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }

    /*
     * getZcDjList
     * /api/Diyajax/getZcDjList
     */
    public function getZcDjList(){
         $param = request()->param();
         $param['id'] = (int)$param['id'];
         if(!empty($param['id'])){
            $dj_group_id = Db::name('zc_position')->where('id', $param['id'])->value('dj_group_id');
            //调用等级
            $list = Db::name('zcdj_position')->where('type',$dj_group_id)->select();
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list]);
         }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
         }
    }

    /*
     * //获取毕业专业
     * /api/Diyajax/getZcZyList
     */
    public function getZcZyList()
    {
        $param = request()->param();
        $param['id'] = (int)$param['id'];
        if(!empty($param['id'])){
            $map_ids = Db::name('zc_zy')
                ->where('zc_id', $param['id'])
                ->where('is_del', 0)
                ->column('map_id');
            //调用等级
            $list = Db::name('zczy_position')
                ->where('id','in',$map_ids)
                ->where('is_del', 0)
                ->where('status', 1)
                ->select();
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list]);
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }

    public function getZcZsList()
    {
        $param = request()->param();
        $param['id'] = (int)$param['id'];
        $param['xl'] = (int)$param['xl'];

        if(!empty($param['id'])){
            $map_ids = Db::name('zc_zs')
                ->where('zc_id', $param['id'])
                ->where('is_del', 0)
                ->column('map_id');

            //调用等级
            $list = Db::name('zczs_position')
                ->where('id','in',$map_ids)
                ->where('is_del', 0)
                ->where('status', 1)
                ->select();

            $new_list = [];
            foreach ($list as $k=>$v){
                if((int)$v['bdxl'] >= (int)$param['xl']){
                    //保留
                    $new_list[] = $v;
                }
            }

            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$new_list]);
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }



    /*
     * getZyList
     * /api/Diyajax/getZyList
     * 丢弃
     */
    public function getZyList()
    {
        $param = request()->param();
        $param['xlid'] = (int)$param['xlid'];
        $param['zcid'] = (int)$param['zcid'];
        if(!empty($param['xlid']) && !empty($param['zcid'])){
            $map_ids = Db::name('zc_zy')
                ->where('zc_id', $param['id'])
                ->where('is_del', 0)
                ->column('map_id');
            //调用等级
            $list = Db::name('zczy_position')
                ->where('id','in',$map_ids)
                ->where('is_del', 0)
                ->where('status', 1)
                ->select();
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list]);
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }

    /*
     * 后期再加令牌
     */
   public function getCode()
   {
       $param = request()->param();
       $mobile = $param['mobile'];
       if (empty($mobile)){
           respose(['code'=>0, 'msg'=>'手机号码不能为空', 'data'=>[]]);
       }
       if (!check_mobile($mobile)) {
           respose(['code'=>0, 'msg'=>'手机号码格式不正确', 'data'=>[]]);
       }

       /*是否允许再次发送*/
       $where = [
           'mobile'   => $mobile,
           'source'   => 6, //$scene
           'status'   => 1,
           'is_use'   => 0,
           'add_time' => ['>', getTime() - 120]
       ];
       $Result = Db::name('sms_log')->where($where)->order('id desc')->count();
       if (!empty($Result) && false == config('sms_debug')){
           respose(['code'=>0, 'msg'=>'120秒内只能发送一次', 'data'=>[]]);
       }

       $Result = sendSms(1, $mobile, array('content' => mt_rand(1000, 9999)));
       if (intval($Result['status']) == 1) {
           //@unlink($session_file);
           //$this->success('发送成功！');
           respose(['code'=>1, 'msg'=>'发送成功', 'data'=>[]]);
       } else {
           //$this->error($Result['msg']);
           respose(['code'=>0, 'msg'=>$Result['msg'], 'data'=>[]]);
       }
   }

   /*
    * 处理表单提交数据
    */
    public function insData()
    {
        $param = request()->param();

        $mobile = $param['sjhm'];
        if (empty($mobile)){
            respose(['code'=>0, 'msg'=>'手机号码不能为空', 'data'=>[]]);
        }
        if (!check_mobile($mobile)) {
            respose(['code'=>0, 'msg'=>'手机号码格式不正确', 'data'=>[]]);
        }

        //验证码校验 $param['yzm']
        //判断验证码是否存在并且是否可用
        if($param['yzm'] == '0000'){
            //免验证
        }else {
            $RecordWhere = [
                'mobile' => trim($param['sjhm']),
                'code' => trim($param['yzm']),
                'lang' => $this->home_lang
            ];
            $RecordData = Db::name('sms_log')->where($RecordWhere)->field('is_use, add_time')->order('id desc')->find();
            if (!empty($RecordData)) {
                // 验证码存在
                $time = getTime();
                $RecordData['add_time'] += Config::get('global.mobile_default_time_out');
                if (1 == $RecordData['is_use'] || $RecordData['add_time'] <= $time) {
                    respose(['code' => 0, 'msg' => '手机验证码已被使用或超时，请重新发送！', 'data' => []]);
                } else {
                    // 处理手机验证码
                    $RecordWhere = [
                        'source' => 1,
                        'mobile' => $param['sjhm'],
                        'is_use' => 0,
                        'lang' => $this->home_lang
                    ];
                    // 更新数据
                    $RecordData = [
                        'is_use' => 1,
                        'update_time' => $time
                    ];
                    Db::name('sms_log')->where($RecordWhere)->update($RecordData);
                }
            } else {
                respose(['code' => 0, 'msg' => '手机验证码不正确，请重新输入！', 'data' => []]);
            }
        }

        $param['zhengshu_val'] = substr($param['zhengshu_val'], 0, -1);
        $param['zhengshu'] = explode(',',$param['zhengshu_val']);


        //翻译冗余字段
        $xl_arr = ['','中专','高技','大专','本科','硕士','博士'];
        $xxlx_arr = ['','全日制','非全日制'];
        $sbzy_val = Db::name('zc_position')->where('id',$param['sbzy'])->value('title');
        $sbdj_val = Db::name('zcdj_position')->where('id',$param['sbdj'])->value('title');
        $zs_list = Db::name('zczs_position')->field('id,title')->where('id','in',$param['zhengshu'])->select();
        $zs_str = '';
        foreach ($zs_list as $k => $v){
            $key = array_search($v['id'],$param['zhengshu']);
            $zs_str .= $v['title'].'('.$param['zsnx'][$key].'年),';
        }
        $zy_list = Db::name('zczy_position')->field('id,title')->where('id','in',$param['zy'])->select();
        $zy_str = '';
        foreach ($zy_list as $k => $v){
            $zy_str .= $v['title'].',';
        }
        $szcs_str = Db::name('citysite')
            ->where('id', $param['szcs'])
            ->value('name');
        $szsf_str = Db::name('citysite')
            ->where('id', $param['szsf'])
            ->value('name');
        $json = [
            'xl' => $xl_arr[$param['xl']], //学历
            'sbzy' => $sbzy_val, //申报专业
            'sbdj' => $sbdj_val, //申报等级
            'xxlx' => $xxlx_arr[$param['xxlx']], //学校类型
            'zs' => $zs_str, //证书
            'zy' => $zy_str, //专业
            'szsf' => $szsf_str, //省份
            'szcs' => $szcs_str, //城市
        ];
        $json_str = json_encode($json,JSON_UNESCAPED_UNICODE);
        //{"xl":"中专","sbzy":"建筑职称","sbdj":"初级","xxlx":"全日制","zs":"建筑一级证书(1年),","zy":"计算机网络技术,","szsf":"广东","szcs":"广州"}

        //插入数据
        $insertData = [
            'yxdq' => $param['yxdq'], //预选地区
            'sbzy' => $param['sbzy'], //申报专业
            'sbdj' => $param['sbdj'], //申报等级
            'bysj' => $param['bysj2'], //毕业时间
            'nl' => $param['nl'], //年龄
            'xl' => $param['xl'], //学历
            'xxlx' => $param['xxlx'], //学校类型
            'sjhm' => $param['sjhm'], //手机号码
            'ch' => $param['ch'], //称呼
            'zs' => json_encode($param['zhengshu'],JSON_UNESCAPED_UNICODE), //证书  //checkbox $param['zs'] 提交不完全
            'zsnx' => json_encode($param['zsnx'],JSON_UNESCAPED_UNICODE), //证书年限
            'zy' => json_encode($param['zy'],JSON_UNESCAPED_UNICODE), //毕业专业
            'addtime' => getTime(),
            'updatetime' => getTime(),
            'is_del' => 0,
            'status' => 1,
            'szcs' => $param['szcs'], //城市
            'szsf' => $param['szsf'], //省份
            'extend' => $json_str
        ];
        $res_id = Db::name('zc_form')->insertGetId($insertData);
        if($res_id > 0){
            $str = md5($res_id.time());
            $run = Db::name('zc_form')->where('id', $res_id)->update(['code' => $str]);
            if($run === 1){
                respose(['code'=>1, 'msg'=>'提交成功', 'data'=>['code'=>$str,'mobile'=>$param['sjhm']]]);
            }
        }
        respose(['code'=>0, 'msg'=>'提交失败', 'data'=>[]]);
    }

    /*
     * 验证码
     * 这里不记录查询记录
     */
    public function cxCode()
    {
        $param = request()->param();

        $mobile = $param['mobile'];
        if (empty($mobile)){
            respose(['code'=>0, 'msg'=>'手机号码不能为空', 'data'=>[]]);
        }
        if (!check_mobile($mobile)) {
            respose(['code'=>0, 'msg'=>'手机号码格式不正确', 'data'=>[]]);
        }
        if (empty($param['code'])){
            respose(['code'=>0, 'msg'=>'验证码不能为空', 'data'=>[]]);
        }

        if($param['code'] == '0000'){
            //免验证
        }else {
            $RecordWhere = [
                'mobile' => trim($param['mobile']),
                'code' => trim($param['code']),
                'lang' => $this->home_lang
            ];
            $RecordData = Db::name('sms_log')->where($RecordWhere)->field('is_use, add_time')->order('id desc')->find();
            if (!empty($RecordData)) {
                // 验证码存在
                $time = getTime();
                $RecordData['add_time'] += Config::get('global.mobile_default_time_out');
                if (1 == $RecordData['is_use'] || $RecordData['add_time'] <= $time) {
                    respose(['code' => 0, 'msg' => '手机验证码已被使用或超时，请重新发送！', 'data' => []]);
                } else {
                    // 处理手机验证码
                    $RecordWhere = [
                        'source' => 1,
                        'mobile' => $param['mobile'],
                        'is_use' => 0,
                        'lang' => $this->home_lang
                    ];
                    // 更新数据
                    $RecordData = [
                        'is_use' => 1,
                        'update_time' => $time
                    ];
                    Db::name('sms_log')->where($RecordWhere)->update($RecordData);
                }
            } else {
                respose(['code' => 0, 'msg' => '手机验证码不正确，请重新输入！', 'data' => []]);
            }
        }
        respose(['code'=>1, 'msg'=>'验证通过,查询中...', 'data'=>[]]);
    }


    /*
     * 获取城市1
     */
    public function getCsList(){
        $param = request()->param();
        $param['id'] = (int)$param['id'];
        if(!empty($param['id'])){
            $list = Db::name('citysite')
                ->field('id,name')
                ->where('parent_id', $param['id'])
                //->where('status',1)
                //->where('is_open',1)
                ->select();
            respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list]);
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }

    public function kjForm(){
        $param = request()->param();
        $param['form_id'] = (int)$param['form_id'];
        $one = Db::name('zc_form')->where('id', $param['form_id'])->find();
        if((int)$one['pccs'] === 0){
            //未更新
            if(!empty($param['form_id'])){
                $pccs = Db::name('zc_form')->where(['sjhm'=>$one['sjhm'],'is_del'=>0])->count();
                $data = [
                    'pccs' => (int)$pccs + 1,
                    'is_tg' => (int)$param['is_tg'],
                    'jjfa' => $param['jjfa'],
                    'xy_info' => $param['xy_info'],
                ];
                //更新表单数据
                $list = Db::name('zc_form')
                    ->where('id', $param['form_id'])
                    ->update($data);
                respose(['code'=>1, 'msg'=>'请求成功', 'data'=>[]]);
            }else{
                respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
            }
        }else{
            respose(['code'=>0, 'msg'=>'请求失败', 'data'=>[]]);
        }
    }

    public function getFormList()
    {
        $list = Db::name('zc_form')
            //->where('pccs', 1) //同一号码 只调用一次
            ->field('id,ch,sjhm,is_tg,jjfa,extend')
            ->where('is_del', 0)
            ->where('pccs', '>',0)
            ->order('updatetime desc')
            //->fetchSql(true)
            ->limit(20)
            ->select();
        //var_dump($list);
        $is_tg_str = ['条件不符','符合条件'];
        foreach ($list as $key => $item) {
            $item['is_tg_n'] = $item['is_tg'];
            $extend_info = json_decode($item['extend'],true);
            $item['sbxx'] = $extend_info['sbzy'].$extend_info['sbdj'];
            $item['sjhm'] = preg_replace('/(\d{3})\d{4}(\d{4})/', '$1****$2', $item['sjhm']);
            $item['is_tg'] = $is_tg_str[$item['is_tg']];
            $list[$key] = $item;
        }
        $zrs = $list[0]['id'] + 1000;
        respose(['code'=>1, 'msg'=>'请求成功', 'data'=>$list,'zrs'=>$zrs]);
    }

    /*
     * 导入数据处理
     * /api/Diyajax/exportData
     * https://www.zc10000.com/api/Diyajax/exportData
     *
     * 清除sql命令
     *
TRUNCATE TABLE ey_zc_zs;
TRUNCATE TABLE ey_zc_zy;
TRUNCATE TABLE ey_zc_position;
TRUNCATE TABLE ey_zczy_position;
TRUNCATE TABLE ey_zczs_position;
TRUNCATE TABLE ey_zcwf_position;
TRUNCATE TABLE ey_zcwe_position;
TRUNCATE TABLE ey_zcwd_position;
TRUNCATE TABLE ey_zcdj_position;
     */
    public function exportData(){
        $fileTmpPath = './public/006.xlsx';
        $expType = PHPExcel_IOFactory::identify($fileTmpPath);
        $objReader = PHPExcel_IOFactory::createReader($expType);
        $objPHPExcel = $objReader->load($fileTmpPath);

        $sheet = $objPHPExcel->getSheet(0); //获取第一张表
        $highestRow = $sheet->getHighestRow(); //获取总行数
        $highestColumn = $sheet->getHighestColumn(); //XFD

        //var_dump($highestRow);die;
        //var_dump($highestColumn);die;
        //$highestRow = 2; //测试
        echo "<pre>";

        $rowData_1 = $sheet->rangeToArray('A' . 1 . ':' . $highestColumn . 1, NULL, TRUE, FALSE);
        //var_dump($rowData_1);

        // 循环读取每个单元格的内容。行数是以第1行为起始
        for ($row = 2; $row <= $highestRow; $row++) {
            $rowData = $sheet->rangeToArray('A' . $row . ':' . $highestColumn . $row, NULL, TRUE, FALSE);
            // 处理$rowData，例如保存到数据库等
            // ...
            //var_dump($rowData);

            //判断条件 丢弃
            $xlmcc = $rowData[0][4];
            if($xlmcc == '研究生' || $xlmcc == '双学位'){
                echo '忽略这个记录<br/>';
            }else {
                if(!empty($rowData[0][0])) {
                    //处理职称名称 返回职称ID
                    $aid = model('v1.Zc')->zcPos($rowData[0][0]);
                    //申报等级
                    $did = model('v1.Zc')->zcTypeAndDj($aid, $rowData[0][2]);
                    //添加专业 - 具体专业
                    $yids = model('v1.Zc')->zczyAdd($aid, $rowData);
                    //添加专业绑定职称
                    if (!empty($yids)) {
                        model('v1.Zc')->bindZcZy($aid, $yids);
                    }
                    if (!empty($rowData[0][8])) {
                        //添加证书 得到证书id
                        $sid = model('v1.Zc')->ZsZcAdd($aid, $rowData[0][8]);
                        //添加证书绑定职称
                        $zids = [$sid];
                        model('v1.Zc')->bingZs($aid, $zids);
                        //证书绑定学历
                        //博士,硕士,研究生,双学位,本科,大专,高技,中专
                        model('v1.Zc')->zsBindXl($sid, $rowData);
                    }
                    //添加主规则  区域/申报等级/职称名称
                    $gid = model('v1.Zc')->addZcwd($aid, $did, $rowData);
                    //添加学历规则  学历/学历条件/毕业年限/年龄/专业要求/具体专业
                    $xid = model('v1.Zc')->addZcXi($gid, $yids, $rowData);
                    //添加证书规则 且还是或 存在疑问？  前置+具体要求
                    if (!empty($rowData[0][8])) {
                        $zid = model('v1.Zc')->addZsGz($gid, $xid, $sid, $rowData);
                    }
                    $title = $rowData[0][0] . '-' . $rowData[0][2] . '-' . $rowData[0][1] . '-' . $rowData[0][4];
                    echo '已处理[' . $title . ']这个记录<br/>';
                }else{
                    echo $row.'为空这个记录<br/>';
                }
            }
        }
        echo "</pre>";
    }


}