report/app/job/Import.php

<?php

namespace app\job;

use think\queue\Job;
use think\facade\Log;
use think\facade\Db;
use app\common\api\ChuanglanSmsApi;
// 给类文件的命名空间起个别名
use PhpOffice\PhpSpreadsheet\Spreadsheet;
//Xlsx类  保存文件功能类
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;

class Import{

    public function fire(Job $job, $data) {
        if ($this->deal($data)) {
            Log::info(json_encode($data));
            $job->delete();
            return true;
        }
        Log::error(json_encode($data));
        if ($job->attempts() >= 3) {
            $job->delete();
            return false;
        }
        $job->release(10); //10秒后重试
    }

    /**
     * 处理业务逻辑
     * @param type $data
     * @return bool
     */
    public function deal($data): bool {
        $id = $data['id'];
        $res = Db::table("new_talent_zhiren")->where('id',$id)->findOrEmpty();
        if($res){
            if($res['task_status'] != -1){
                return false;
            }
            try{
                $spreadsheet = \PhpOffice\PhpSpreadsheet\IOFactory::load("/www/wwwroot/report/public/storage/".$res['task_file']);
                $sheet = $spreadsheet->getSheet(0);
                $datas = $sheet->toArray();
                $datas = array_slice($datas, 1); //去标题
                $street = Db::table("sys_dict")->where("pid",1655)->column("code","name");
                $index = 2;

                for ($index = 0;$index < count($datas);$index++){
                    $row = $datas[$index];
                    $msg = [];
                    $item = [];
                    for ($i = 0; $i < 11; $i++) {
                        switch ($i){
                            case 0:
                                if(in_array($row[$i],['企业用户','民办非企业','事业单位'])){
                                    if($row[$i] == '事业单位'){
                                        $item['special'] = 1;
                                    }else{
                                        $item['special'] = 0;
                                    }
                                }else{
                                    array_push($msg,"导入的机构类型不正确");
                                }
                                break;
                            case 1:
                                if(empty($row[$i])){
                                    array_push($msg,"机构名称不能为空");
                                }else{
                                    $info = Db::table("un_enterprise")->where('name',$row[$i])->findOrEmpty();
                                    if($info){
                                        array_push($msg,"机构名称已存在，请检查");
                                    }else{

                                        $isMatched = preg_match('/^[\x{4e00}-\x{9fa5}\(\)（）\da-zA-Z&]{2,50}$/u', $row[$i], $matches);
                                        if($isMatched){
                                            $item['name'] = $row[$i];
                                        }else{
                                            array_push($msg,"机构名称只能是中文或数字");
                                        }
                                    }
                                }
                                break;
                            case 2:
                                $info = Db::table("un_enterprise")->where('idCard',$row[$i])->findOrEmpty();
                                if($info){
                                    array_push($msg,"机构代码已存在，请检查");
                                }else{
                                    $isMatched = preg_match('/^([0-9A-HJ-NPQRTUWXY]{2}\d{6}[0-9A-HJ-NPQRTUWXY]{10}|[1-9]\d{14})$/', $row[$i], $matches);
                                    if($isMatched){
                                        $item['idCard'] = $row[$i];
                                    }else{
                                        array_push($msg,"组织机构代码证不正确");
                                    }
                                }
                                break;
                            case 3:
                                $item['agentName'] = $row[$i];
                                break;
                            case 4:
                                $isMatched = preg_match('/^1[3456789]\d{9}$/', $row[$i], $matches);
                                if($isMatched){
                                    $item['agentPhone'] = $row[$i];
                                }else{
                                    array_push($msg,"联系电话不正确");
                                }
                                break;
                            case 5:
                                $item['street'] = array_key_exists($row[$i],$street) ? $street[$row[$i]] : '00000';
                                break;
                            case 6:
                                $item['address'] = $row[$i];
                                break;
                            case 7:
                                $item['ephone'] = $row[$i];
                                break;
                            case 8:
                                $item['bankCard'] = $row[$i];
                                break;
                            case 9:
                                $item['bank'] = $row[$i];
                                break;
                            case 10:
                                $item['bankNetwork'] = $row[$i];
                                break;
                        }
                    }
                    var_dump($msg,($index+1));
                    if(count($msg) >= 1){
                        $sheet->setCellValue('L'.($index+2), '导入失败，失败原因：'.implode(";",$msg));
                    }else{
                        $item['id'] = getStringId();
                        $item['type'] = 1;
                        $item['source'] = 4;
                        $item['username'] = $item['idCard'];
                        $password = generate_password(8);
                        $item['password'] =  hash('md5', $password);
                        $item['createTime'] = date("Y-m-d H:i:s",time());
                        Db::table("un_enterprise")->insert($item);
                        $sheet->setCellValue('L'.($index+2), '导入成功，初始账号为：'.$item['idCard'].'，初始密码为：'.$password);
                    }
                }

                $writer = \PhpOffice\PhpSpreadsheet\IOFactory::createWriter($spreadsheet, 'Xlsx');
                $writer->save("/www/wwwroot/report/public/storage/".$res['task_file']);
                Db::table("new_talent_zhiren")->where('id',$id)->update(['task_result' => $res['task_file'],'task_status' => 1,'updateTime' => date("Y-m-d H:i:s",time())]);
                return true;
            }catch (\Exception $e){
                Db::table("new_talent_zhiren")->where('id',$data['id'])->update(['task_result' => $e->getMessage(),'status' => 0,'updateTime' => date("Y-m-d H:i:s",time())]);
                return false;
            }
        }else{
            return false;
        }
    }
}