|
@@ -11,7 +11,7 @@ use PhpOffice\PhpSpreadsheet\Spreadsheet;
|
|
|
//Xlsx类 保存文件功能类
|
|
|
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
|
|
|
|
|
|
-class Import{
|
|
|
+class Import {
|
|
|
|
|
|
public function fire(Job $job, $data) {
|
|
|
if ($this->deal($data)) {
|
|
@@ -33,65 +33,65 @@ class Import{
|
|
|
* @return bool
|
|
|
*/
|
|
|
public function deal($data): bool {
|
|
|
- if($data['type'] == 1){
|
|
|
+ if ($data['type'] == 1) {
|
|
|
$id = $data['id'];
|
|
|
- $res = Db::table("new_talent_zhiren")->where('id',$id)->findOrEmpty();
|
|
|
- if($res){
|
|
|
- if($res['task_status'] != -1){
|
|
|
+ $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']);
|
|
|
+ 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");
|
|
|
+ $street = Db::table("sys_dict")->where("pid", 1655)->column("code", "name");
|
|
|
|
|
|
- for ($index = 0;$index < count($datas);$index++){
|
|
|
+ for ($index = 0; $index < count($datas); $index++) {
|
|
|
$row = $datas[$index];
|
|
|
$msg = [];
|
|
|
$item = [];
|
|
|
for ($i = 0; $i < 11; $i++) {
|
|
|
- switch ($i){
|
|
|
+ switch ($i) {
|
|
|
case 0:
|
|
|
- if(in_array($row[$i],['企业用户','民办非企业','事业单位'])){
|
|
|
- if($row[$i] == '事业单位'){
|
|
|
+ if (in_array($row[$i], ['企业用户', '民办非企业', '事业单位'])) {
|
|
|
+ if ($row[$i] == '事业单位') {
|
|
|
$item['special'] = 1;
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
$item['special'] = 0;
|
|
|
}
|
|
|
- }else{
|
|
|
- array_push($msg,"导入的机构类型不正确");
|
|
|
+ } 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{
|
|
|
+ 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){
|
|
|
+ if ($isMatched) {
|
|
|
$item['name'] = $row[$i];
|
|
|
- }else{
|
|
|
- array_push($msg,"机构名称只能是中文或数字");
|
|
|
+ } else {
|
|
|
+ array_push($msg, "机构名称只能是中文或数字");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case 2:
|
|
|
- $info = Db::table("un_enterprise")->where('idCard',$row[$i])->findOrEmpty();
|
|
|
- if($info){
|
|
|
- array_push($msg,"机构代码已存在,请检查");
|
|
|
- }else{
|
|
|
+ $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){
|
|
|
+ if ($isMatched) {
|
|
|
$item['idCard'] = $row[$i];
|
|
|
- }else{
|
|
|
- array_push($msg,"组织机构代码证不正确");
|
|
|
+ } else {
|
|
|
+ array_push($msg, "组织机构代码证不正确");
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
@@ -100,14 +100,14 @@ class Import{
|
|
|
break;
|
|
|
case 4:
|
|
|
$isMatched = preg_match('/^1[3456789]\d{9}$/', $row[$i], $matches);
|
|
|
- if($isMatched){
|
|
|
+ if ($isMatched) {
|
|
|
$item['agentPhone'] = $row[$i];
|
|
|
- }else{
|
|
|
- array_push($msg,"联系电话不正确");
|
|
|
+ } else {
|
|
|
+ array_push($msg, "联系电话不正确");
|
|
|
}
|
|
|
break;
|
|
|
case 5:
|
|
|
- $item['street'] = array_key_exists($row[$i],$street) ? $street[$row[$i]] : '00000';
|
|
|
+ $item['street'] = array_key_exists($row[$i], $street) ? $street[$row[$i]] : '00000';
|
|
|
break;
|
|
|
case 6:
|
|
|
$item['address'] = $row[$i];
|
|
@@ -126,49 +126,49 @@ class Import{
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
- if(count($msg) >= 1){
|
|
|
- $sheet->setCellValue('L'.($index+2), '导入失败,失败原因:'.implode(";",$msg));
|
|
|
- }else{
|
|
|
+ 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['password'] = hash('md5', $password);
|
|
|
$item['active'] = 1;
|
|
|
$item['checkState'] = 3;
|
|
|
- $item['createTime'] = date("Y-m-d H:i:s",time());
|
|
|
+ $item['createTime'] = date("Y-m-d H:i:s", time());
|
|
|
Db::table("un_enterprise")->insert($item);
|
|
|
- $sheet->setCellValue('L'.($index+2), '导入成功,初始账号为:'.$item['idCard'].',初始密码为:'.$password);
|
|
|
+ $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())]);
|
|
|
+ $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())]);
|
|
|
+ } 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{
|
|
|
+ } else {
|
|
|
return false;
|
|
|
}
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
$id = $data['id'];
|
|
|
- $res = Db::table("new_talent_zhiren")->where('id',$id)->findOrEmpty();
|
|
|
- if($res){
|
|
|
- if($res['task_status'] != -1){
|
|
|
+ $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']);
|
|
|
+ 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); //去标题
|
|
|
- $country = Db::table("sys_dict")->where("pid",35)->column("code","name");
|
|
|
+ $country = Db::table("sys_dict")->where("pid", 35)->column("code", "name");
|
|
|
|
|
|
- for ($index = 0;$index < count($datas);$index++){
|
|
|
+ for ($index = 0; $index < count($datas); $index++) {
|
|
|
$row = $datas[$index];
|
|
|
$msg = [];
|
|
|
$item = [];
|
|
@@ -176,69 +176,69 @@ class Import{
|
|
|
$enterprise_id = '';
|
|
|
$action = 'insert';
|
|
|
for ($i = 0; $i < 9; $i++) {
|
|
|
- switch ($i){
|
|
|
+ switch ($i) {
|
|
|
case 0:
|
|
|
- if(empty($row[$i])){
|
|
|
- array_push($msg,"机构名称不能为空");
|
|
|
- }else{
|
|
|
+ if (empty($row[$i])) {
|
|
|
+ array_push($msg, "机构名称不能为空");
|
|
|
+ } else {
|
|
|
$enterprise_name = $row[$i];
|
|
|
}
|
|
|
break;
|
|
|
case 1:
|
|
|
- $info = Db::table("un_enterprise")->where('idCard',$row[$i])->findOrEmpty();
|
|
|
- if(!$info){
|
|
|
- array_push($msg,"机构代码不存在,请检查");
|
|
|
- }else{
|
|
|
- if($info['name'] != $enterprise_name){
|
|
|
- array_push($msg,"机构代码与企业名称无法对应,请检查");
|
|
|
- }else{
|
|
|
+ $info = Db::table("un_enterprise")->where('idCard', $row[$i])->findOrEmpty();
|
|
|
+ if (!$info) {
|
|
|
+ array_push($msg, "机构代码不存在,请检查");
|
|
|
+ } else {
|
|
|
+ if ($info['name'] != $enterprise_name) {
|
|
|
+ array_push($msg, "机构代码与企业名称无法对应,请检查");
|
|
|
+ } else {
|
|
|
$item['enterprise_id'] = $enterprise_id = $info['id'];
|
|
|
}
|
|
|
}
|
|
|
break;
|
|
|
case 2:
|
|
|
- if(empty($row[$i])){
|
|
|
- array_push($msg,"人才姓名不能为空");
|
|
|
- }else{
|
|
|
+ if (empty($row[$i])) {
|
|
|
+ array_push($msg, "人才姓名不能为空");
|
|
|
+ } else {
|
|
|
$item['name'] = $row[$i];
|
|
|
}
|
|
|
break;
|
|
|
case 3:
|
|
|
- if(in_array($row[$i],['身份证','通行证','护照'])){
|
|
|
- $key = array_search($row[$i],['身份证','通行证','护照']);
|
|
|
- $item['card_type'] = $key +1;
|
|
|
- }else{
|
|
|
- array_push($msg,"人才的证件类型不正确");
|
|
|
+ if (in_array($row[$i], ['身份证', '通行证', '护照'])) {
|
|
|
+ $key = array_search($row[$i], ['身份证', '通行证', '护照']);
|
|
|
+ $item['card_type'] = $key + 1;
|
|
|
+ } else {
|
|
|
+ array_push($msg, "人才的证件类型不正确");
|
|
|
}
|
|
|
|
|
|
break;
|
|
|
case 4:
|
|
|
- if(empty($row[$i])){
|
|
|
- array_push($msg,"证件号码不能为空");
|
|
|
- }else{
|
|
|
- if(!isCreditNo($row[$i]) && $item['card_type'] == 1){
|
|
|
- array_push($msg,"证件号码不正确");
|
|
|
+ if (empty($row[$i])) {
|
|
|
+ array_push($msg, "证件号码不能为空");
|
|
|
+ } else {
|
|
|
+ if (!isCreditNo($row[$i]) && $item['card_type'] == 1) {
|
|
|
+ array_push($msg, "证件号码不正确");
|
|
|
}
|
|
|
- $talent_info = Db::table("new_talent_info")->where("card_number",$row[$i])->where('enterprise_id',$enterprise_id)->findOrEmpty();
|
|
|
- if($talent_info){
|
|
|
+ $talent_info = Db::table("new_talent_info")->where("card_number", $row[$i])->where('enterprise_id', $enterprise_id)->findOrEmpty();
|
|
|
+ if ($talent_info) {
|
|
|
$action = 'update';
|
|
|
}
|
|
|
$item['card_number'] = $row[$i];
|
|
|
}
|
|
|
break;
|
|
|
case 5:
|
|
|
- $item['nationality'] = array_key_exists($row[$i],$country) ? $country[$row[$i]] : 'other';
|
|
|
+ $item['nationality'] = array_key_exists($row[$i], $country) ? $country[$row[$i]] : 'other';
|
|
|
break;
|
|
|
case 6:
|
|
|
- if(!in_array($row[$i],['第一层次','第二层次','第三层次','第四层次','第五层次'])){
|
|
|
- array_push($msg,"人才层次不正确");
|
|
|
- }else{
|
|
|
- $key = array_search($row[$i],['第一层次','第二层次','第三层次','第四层次','第五层次']);
|
|
|
- $item['talent_arrange'] = $key +1;
|
|
|
+ if (!in_array($row[$i], ['第一层次', '第二层次', '第三层次', '第四层次', '第五层次'])) {
|
|
|
+ array_push($msg, "人才层次不正确");
|
|
|
+ } else {
|
|
|
+ $key = array_search($row[$i], ['第一层次', '第二层次', '第三层次', '第四层次', '第五层次']);
|
|
|
+ $item['talent_arrange'] = $key + 1;
|
|
|
}
|
|
|
break;
|
|
|
case 7:
|
|
|
- switch ($row[$i]){
|
|
|
+ switch ($row[$i]) {
|
|
|
case '福建省人才':
|
|
|
$item['source'] = 1;
|
|
|
break;
|
|
@@ -246,12 +246,12 @@ class Import{
|
|
|
$item['source'] = 2;
|
|
|
break;
|
|
|
default:
|
|
|
- array_push($msg,"人才来源不正确");
|
|
|
+ array_push($msg, "人才来源不正确");
|
|
|
break;
|
|
|
}
|
|
|
break;
|
|
|
case 8:
|
|
|
- switch ($item['source']){
|
|
|
+ switch ($item['source']) {
|
|
|
case '1':
|
|
|
$item['fujian_highcert_exptime'] = $row[$i];
|
|
|
break;
|
|
@@ -265,34 +265,38 @@ class Import{
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
+ $item["checkState"] = \app\common\api\TalentState::REVERIFY_PASS; //复审通过
|
|
|
+ $item["highProcess"] = 5; //最高进度
|
|
|
+ $item["isImport"] = 1;//导入人才的标志
|
|
|
+ $item["importCheckState"] = 1;//导入人才的状态,待提交补充
|
|
|
var_dump($item);
|
|
|
- if(count($msg) >= 1){
|
|
|
- $sheet->setCellValue('J'.($index+2), '导入失败,失败原因:'.implode(";",$msg));
|
|
|
- }else{
|
|
|
- if($action == 'update'){
|
|
|
- $item['updateTime'] = date("Y-m-d H:i:s",time());
|
|
|
- Db::table("new_talent_info")->where('id',$talent_info['id'])->update($item);
|
|
|
- $sheet->setCellValue('J'.($index+2), '更新成功');
|
|
|
- }else{
|
|
|
- $item['createTime'] = date("Y-m-d H:i:s",time());
|
|
|
+ if (count($msg) >= 1) {
|
|
|
+ $sheet->setCellValue('J' . ($index + 2), '导入失败,失败原因:' . implode(";", $msg));
|
|
|
+ } else {
|
|
|
+ if ($action == 'update') {
|
|
|
+ $item['updateTime'] = date("Y-m-d H:i:s", time());
|
|
|
+ Db::table("new_talent_info")->where('id', $talent_info['id'])->update($item);
|
|
|
+ $sheet->setCellValue('J' . ($index + 2), '更新成功');
|
|
|
+ } else {
|
|
|
+ $item['createTime'] = date("Y-m-d H:i:s", time());
|
|
|
Db::table("new_talent_info")->insert($item);
|
|
|
- $sheet->setCellValue('J'.($index+2), '导入成功');
|
|
|
+ $sheet->setCellValue('J' . ($index + 2), '导入成功');
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
$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())]);
|
|
|
+ $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',$id)->update(['task_result' => $e->getMessage(),'task_status' => 0,'updateTime' => date("Y-m-d H:i:s",time())]);
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ Db::table("new_talent_zhiren")->where('id', $id)->update(['task_result' => $e->getMessage(), 'task_status' => 0, 'updateTime' => date("Y-m-d H:i:s", time())]);
|
|
|
return false;
|
|
|
}
|
|
|
- }else{
|
|
|
+ } else {
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
}
|
|
|
-}
|
|
|
+
|
|
|
+}
|