|
|
<?php
|
|
|
|
|
|
namespace App\Http\Controllers\API\His;
|
|
|
|
|
|
use App\Http\Controllers\Controller;
|
|
|
use Illuminate\Http\Request;
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
use JWT;
|
|
|
|
|
|
class UserController extends Controller
|
|
|
{
|
|
|
public function GetUserList(){
|
|
|
$data = [];
|
|
|
|
|
|
$His = new HisController();
|
|
|
$res = $His::Get("查询人员列表", $data);
|
|
|
$up_count=0;
|
|
|
if ($res['code'] == 200) {
|
|
|
$res_data = $res['data'];
|
|
|
foreach ($res_data as $data_k => $data_v) {
|
|
|
if( $data_v['emplCode']=='admin') continue;
|
|
|
$user = DB::table('users')->where(['cas_code' => $data_v['emplCode']])->first();
|
|
|
$dept = DB::table('s_department')->where(['department_number' => $data_v['deptCode']])->first();
|
|
|
$group=null;
|
|
|
if($data_v['posiCode']=='300A'){
|
|
|
$group=6;
|
|
|
}else{
|
|
|
if(in_array($data_v['emplType'], ['N', 'T'])){ //护士
|
|
|
$group=3;
|
|
|
}
|
|
|
if($data_v['emplType']=='D'){ //医生
|
|
|
$group=7;
|
|
|
}
|
|
|
}
|
|
|
if (!$user) {
|
|
|
//插入用户表
|
|
|
$u= DB::table('users')->insert([
|
|
|
'cas_code' => $data_v['emplCode'],
|
|
|
'cn_name' => $data_v['emplName'],
|
|
|
'username' => $data_v['emplCode'],
|
|
|
'pwd' =>'$2y$10$HlgBHem3knR9JGcPWWxfhuj/oQzGouQaWQ8BIDbSxliJ39G6pOj/K',//默认密码：111111
|
|
|
'department_id' => isset($dept->id)?$dept->id:null,
|
|
|
'status' => 1,
|
|
|
'group' => $group,
|
|
|
]);
|
|
|
}else{
|
|
|
$u= DB::table('users')->where('id', $user->id)->update([
|
|
|
'cn_name' => $data_v['emplName'],
|
|
|
'department_id' => isset($dept->id)?$dept->id:null,
|
|
|
'group' => $user->group_locked==1?$user->group:$group,//如果分组被手动调整过，那就维持手动的分组不变
|
|
|
]);
|
|
|
}
|
|
|
if($u){
|
|
|
$up_count++;
|
|
|
}
|
|
|
}
|
|
|
return \Yz::JsonReturn(true,"调用His接口完成，更新".$up_count."条数据",['up_count'=>$up_count]);
|
|
|
}
|
|
|
return \Yz::JsonError("调用His接口失败");
|
|
|
}
|
|
|
|
|
|
//从HIS同步人员 + 返回统计
|
|
|
public function SyncUser()
|
|
|
{
|
|
|
// 1. 同步前快照
|
|
|
$beforeSnapshot = $this->getUserSnapshot();
|
|
|
|
|
|
// 2. 调用 HIS 接口
|
|
|
$His = new HisController();
|
|
|
$res = $His::Get('查询人员列表', []);
|
|
|
|
|
|
if ($res['code'] != 200) {
|
|
|
return \Yz::JsonError('调用His接口失败');
|
|
|
}
|
|
|
|
|
|
$hisData = $res['data'];
|
|
|
$receivedCodes = [];
|
|
|
|
|
|
foreach ($hisData as $item) {
|
|
|
$emplCode = $item['emplCode'];
|
|
|
if ($emplCode == 'admin') continue;
|
|
|
$receivedCodes[] = $emplCode;
|
|
|
|
|
|
$user = DB::table('users')->where('cas_code', $emplCode)->first();
|
|
|
$dept = DB::table('s_department')->where('department_number', $item['deptCode'])->first();
|
|
|
|
|
|
$group = null;
|
|
|
if ($item['posiCode'] == '300A') {
|
|
|
$group = 6;
|
|
|
} else {
|
|
|
if (in_array($item['emplType'], ['N', 'T'])) {
|
|
|
$group = 3;
|
|
|
}
|
|
|
if ($item['emplType'] == 'D') {
|
|
|
$group = 7;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if (!$user) {
|
|
|
DB::table('users')->insert([
|
|
|
'cas_code' => $emplCode,
|
|
|
'cn_name' => $item['emplName'],
|
|
|
'username' => $emplCode,
|
|
|
'pwd' => '$2y$10$HlgBHem3knR9JGcPWWxfhuj/oQzGouQaWQ8BIDbSxliJ39G6pOj/K',
|
|
|
'department_id' => isset($dept->id) ? $dept->id : null,
|
|
|
'status' => 1,
|
|
|
'group' => $group,
|
|
|
]);
|
|
|
} else {
|
|
|
$updateData = [
|
|
|
'cn_name' => $item['emplName'],
|
|
|
'department_id' => isset($dept->id) ? $dept->id : null,
|
|
|
'group' => $user->group_locked == 1 ? $user->group : $group,
|
|
|
];
|
|
|
// 如果之前是禁用状态，同步时恢复启用
|
|
|
if ($user->status == 0) {
|
|
|
$updateData['status'] = 1;
|
|
|
}
|
|
|
DB::table('users')->where('id', $user->id)->update($updateData);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
// 3. 处理移除：HIS未返回的人员标记 status=0
|
|
|
DB::table('users')
|
|
|
->where('status', 1)
|
|
|
->where('cas_code', '!=', 'admin')
|
|
|
->whereNotIn('cas_code', $receivedCodes)
|
|
|
->update(['status' => 0]);
|
|
|
|
|
|
// 4. 同步后快照
|
|
|
$afterSnapshot = $this->getUserSnapshot();
|
|
|
|
|
|
// 5. 对比统计
|
|
|
$beforeCodes = array_keys($beforeSnapshot);
|
|
|
$afterCodes = array_keys($afterSnapshot);
|
|
|
$beforeSet = array_flip($beforeCodes);
|
|
|
$afterSet = array_flip($afterCodes);
|
|
|
|
|
|
$addedCodes = array_diff_key($afterSet, $beforeSet);
|
|
|
$removedCodes = array_diff_key($beforeSet, $afterSet);
|
|
|
$commonCodes = array_intersect_key($beforeSet, $afterSet);
|
|
|
|
|
|
$updatedCount = 0;
|
|
|
foreach ($commonCodes as $code => $v) {
|
|
|
$before = $beforeSnapshot[$code];
|
|
|
$after = $afterSnapshot[$code];
|
|
|
if ($before['name'] !== $after['name'] || $before['dept_id'] !== $after['dept_id']) {
|
|
|
$updatedCount++;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
return \Yz::Return(true, '同步完成', [
|
|
|
'added' => count($addedCodes),
|
|
|
'removed' => count($removedCodes),
|
|
|
'updated' => $updatedCount,
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
//获取所有 status=1 的人员快照
|
|
|
private function getUserSnapshot()
|
|
|
{
|
|
|
$items = DB::table('users')
|
|
|
->where('status', 1)
|
|
|
->select('cas_code', 'cn_name', 'department_id')
|
|
|
->get();
|
|
|
|
|
|
$snapshot = [];
|
|
|
foreach ($items as $item) {
|
|
|
$snapshot[$item->cas_code] = [
|
|
|
'name' => $item->cn_name,
|
|
|
'dept_id' => $item->department_id,
|
|
|
];
|
|
|
}
|
|
|
return $snapshot;
|
|
|
}
|
|
|
|
|
|
//用于his 医生直接跳转过来，查看开单记录
|
|
|
public function AutoLogin(){
|
|
|
$usercode = request('usercode');
|
|
|
$deptcode = request('deptcode');
|
|
|
|
|
|
$missingParams = [];
|
|
|
if (empty($usercode)) $missingParams[] = '医生编码';
|
|
|
if (empty($deptcode)) $missingParams[] = '科室编码';
|
|
|
|
|
|
if (!empty($missingParams)) {
|
|
|
return \Yz::JsonReturn(false, '缺少参数：' . implode('、', $missingParams), [
|
|
|
'missing_params' => $missingParams
|
|
|
]);
|
|
|
}
|
|
|
$dept=DB::table('s_department')->where(['department_number' => $deptcode])->first();
|
|
|
if(!$dept) return \Yz::JsonError("科室不存在");
|
|
|
|
|
|
$user=DB::table('users')->where('username', $usercode)->first();
|
|
|
if(!$user) return \Yz::JsonError("无效用户");
|
|
|
$u_user=DB::table('users')->where(['username' => $usercode])->update([
|
|
|
'department_id'=>$dept->id,
|
|
|
'updated_at'=>date('Y-m-d H:i:s')
|
|
|
]);
|
|
|
$jwt= new JWT();
|
|
|
$accessTimeout = $jwt -> GetGetSecretTimeOut();
|
|
|
$refreshTimeout = $jwt -> GetRefreshTokenTimeOut();
|
|
|
$access_token = $jwt->BuildJWT('yz','access',$user->id,$user->group,$accessTimeout);
|
|
|
$refresh_token = $jwt->BuildJWT('yz','refresh',$user->id,'',$refreshTimeout);
|
|
|
DB::table('users')->where(['id'=>$user->id,'status'=>1])->update(['token'=>md5($refresh_token)]);
|
|
|
|
|
|
// 记录 HIS 登录日志
|
|
|
try {
|
|
|
$allParams = request()->all();
|
|
|
\App\Services\LogService::DoctorLoginLog(
|
|
|
request()->ip(),
|
|
|
http_build_query($allParams),
|
|
|
json_encode($allParams, JSON_UNESCAPED_UNICODE),
|
|
|
'HIS登录'
|
|
|
);
|
|
|
} catch (\Exception $e) {
|
|
|
// 日志写入失败不影响主流程
|
|
|
}
|
|
|
|
|
|
return \Yz::JsonReturn(true,'登录成功',['access_token'=>$access_token,'refresh_token'=>$refresh_token]);
|
|
|
}
|
|
|
}
|