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;

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 {
        $res = Db::table("new_talent_zhiren")->where('id',$data['id'])->findOrEmpty();
        if($res){
            if($res['task_status'] != -1){
                return false;
            }
            $datas = getExcelDatas($res['task_file']);
            $datas = array_slice($datas, 1); //去标题
            $inserts = [];
            $street = Db::table("sys_dict")->where("pid",1655)->column("code","name");
            while ($row = array_shift($datas)) {
                $msg = [];
                $item = [];
                $cols = count($row);
                $item['data'] = 1;
                for ($i = 0; $i < $cols; $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{
                                $item['idCard'] = $row[$i];
                            }
                            break;
                        case 3:
                            $item['agentName'] = $row[$i];
                            break;
                        case 4:
                            $item['agentPhone'] = $row[$i];
                            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;
                    }
                }
                if(count($msg) >= 1){

                }

                $companyIds = [];
                $new = [];

                $new["companyIds"] = $companyIds ? implode(",", $companyIds) : null;
                $new["createTime"] = date("Y-m-d H:i:s");
                $inserts[] = $new;
            }

        }else{
            return false;
        }
    }
}