Writereport.php 74 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332
  1. <?php
  2. namespace app\inter\controller;
  3. //use Doctrine\Common\Cache\Cache;
  4. use app\common\library\Message;
  5. use think\Controller;
  6. use think\Db;
  7. use think\Session;
  8. use app\common\library\UUIDs;
  9. use think\Cache;
  10. use think\Log;
  11. use app\common\library\Verify;
  12. use app\common\library\send_message;
  13. use app\inter\service\WechatService;
  14. class Writereport extends Base
  15. {
  16. /**
  17. * 写报告页面
  18. *
  19. * @ApiTitle (写报告页面)
  20. * @ApiSummary (写报告页面)
  21. * @ApiSector (远程诊断)
  22. * @ApiMethod (POST)
  23. * @ApiRoute (/inter/writereport/index)
  24. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  25. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  26. * @ApiHeaders (name="timestamp", type=string, required=truee, description="请求头-时间戳s")
  27. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  28. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  29. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  30. * @ApiParams (name="param[id]", type="string", sample="", description="exams表id值<必填>")
  31. * @ApiParams (name="param[images]", type="string", sample="", description="影像图片<选填>")
  32. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  33. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  34. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  35. * @ApiReturnParams (name="is_remote", type="object", sample="{}", description="是否为远程诊断进入")
  36. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  37. * @ApiReturn (data="
  38. {
  39. 'status': ok,
  40. 'code': '0000',
  41. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  42. 'is_remote': 1,
  43. 'info' : ''
  44. }
  45. *")
  46. **/
  47. public function index(){
  48. try{
  49. log::record('-----请求值-----');
  50. log::record($_REQUEST);
  51. log::record('-----请求值-----');
  52. $sessionid = $_REQUEST['sessionid'];
  53. if(isset($_REQUEST['is_remote']) && !empty($_REQUEST['is_remote'])){
  54. $is_remote = $_REQUEST['is_remote'];
  55. }else{
  56. $is_remote = 0;
  57. }
  58. $doctor = Cache::get($sessionid);
  59. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name,report_subtitle')->find();
  60. $param = $_REQUEST['param'];
  61. $id = $param['id'];
  62. $info = DB::table('exams')->where('id',$id)->field(['id','ext','study_id','exam_class','exam_status','exam_datetime','exam_sub_class','body_part','accession_num','patient_id','film_type'])->find();
  63. $exam_class = DB::table('constant')->where('id',$info['exam_class'])->field('constant_value')->find();
  64. $info['exam_class'] = $exam_class['constant_value'];
  65. $exam_subclass = DB::table('exam_subclass')->where('id',$info['exam_sub_class'])->field('name')->find();
  66. $info['exam_sub_class'] = $exam_subclass['name'];
  67. $patient_info = DB::table('patient_infos')->where('id',$info['patient_id'])->field(['id','temp_patient_id','name','phone','sex','age'])->find();
  68. $info['pid'] = $patient_info['temp_patient_id'];
  69. $info['name'] = $patient_info['name'];
  70. $info['sex'] = $patient_info['sex'];
  71. $info['age'] = $patient_info['age'];
  72. $info['phone'] = $patient_info['phone'];
  73. $info['hospital_name'] = $institution['name'];
  74. $info['hospital_title'] = $institution['report_subtitle'];
  75. $info['images'] = isset($param['images']) ? $param['images'] : '';
  76. if(isset($param['rid']) && !empty($param['rid'])){
  77. $remote_id = $param['rid'];
  78. $report = DB::table('report')->where('exam_id',$id)->where('remote_application_id',$remote_id)->field('qr_code,id,remote_application_id,report_result,report_datetime,report_doctor_id,review_datetime,review_doctor_id,impression,description')->find();
  79. $sta = DB::table('remote_application')->where('id',$remote_id)->field('report_status')->find();
  80. $info['report_status'] = $sta['report_status'];
  81. $r_id = $report['remote_application_id'];
  82. }else{
  83. // 不存在 本地点击进入 获取本地报告
  84. $report = DB::table('report')->where('exam_id',$id)->where('type',1)->field('qr_code,id,remote_application_id,report_result,report_datetime,report_doctor_id,review_datetime,review_doctor_id,impression,description')->find();
  85. $info['report_status'] = '';
  86. $r_report = DB::table('report')->where('exam_id',$id)->where('type',2)->field('remote_application_id')->find();
  87. $r_id = $r_report['remote_application_id'];
  88. }
  89. if( $r_id == ''){
  90. $info['remote'] = 1;
  91. }else{
  92. $info['remote'] = 2;
  93. }
  94. $report_doctor = DB::table('doctors')->where('id',$report['report_doctor_id'])->field('realname')->find();
  95. $info['report_doctor'] = $report_doctor['realname'];
  96. $info['report_datetime'] = $report['report_datetime'];
  97. $review_doctor = DB::table('doctors')->where('id',$report['review_doctor_id'])->field('realname')->find();
  98. $info['review_doctor'] = $review_doctor['realname'];
  99. $info['review_datetime'] = $report['review_datetime'];
  100. $info['description'] = $report['description'];
  101. $info['impression'] = $report['impression'];
  102. $info['report_result'] = $report['report_result'];
  103. $info['report_id'] = $report['id'];
  104. $info['qr_code'] = $report['qr_code'];
  105. $cache_key = $doctor['id'].'_'.$report['id'];
  106. if(Cache::get($cache_key)){
  107. $cache = Cache::get($cache_key);
  108. $info['description'] = isset($cache['description']) ? $cache['description'] : '';
  109. $info['impression'] = isset($cache['impression']) ? $cache['impression'] : '';
  110. $info['report_result'] = isset($cache['r_result']) ?$cache['r_result'] : '';
  111. $info['name'] = isset($cache['name']) ? $cache['name'] : '';
  112. $info['sex'] = isset($cache['sex']) ? $cache['sex'] : '';
  113. $info['age'] = isset($cache['age']) ? $cache['age'] : '';
  114. $info['phone'] = isset($cache['phone']) ? $cache['phone'] : '';
  115. }
  116. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid,'is_remote'=>$is_remote]);
  117. }catch(\Exception $e){
  118. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  119. }
  120. }
  121. /**
  122. * 上远程申请附件
  123. *
  124. * @ApiTitle (上远程申请附件)
  125. * @ApiSummary (上远程申请附件)
  126. * @ApiSector (远程诊断)
  127. * @ApiMethod (POST)
  128. * @ApiRoute (/inter/writereport/upload)
  129. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  130. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  131. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  132. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  133. * @ApiParams (name="file", type="string", required=true, description="上传的文件<必填>")
  134. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  135. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  136. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  137. * @ApiReturn (data="
  138. {
  139. 'status': ok,
  140. 'code': '0000',
  141. 'info' : '/upload/20180101/12346asd.jpg'
  142. }
  143. *")
  144. **/
  145. public function upload($files){
  146. // 获取表单上传文件
  147. foreach($files as $file){
  148. // 移动到框架应用根目录/public/uploads/ 目录下
  149. $info = $file->move(ROOT_PATH . 'public' . DS . 'uploads');
  150. if($info){
  151. return $info->getSaveName();
  152. // 成功上传后 获取上传信息
  153. // 输出 jpg
  154. // echo $info-> getExtension();
  155. // 输出 42a79759f284b767dfcb2a0197904287.jpg
  156. // echo $info->getFilename();
  157. }else{
  158. // 上传失败获取错误信息
  159. // echo $file->getError();
  160. }
  161. }
  162. }
  163. /**
  164. * 报告保存
  165. *
  166. * @ApiTitle (报告保存)
  167. * @ApiSummary (报告保存)
  168. * @ApiSector (远程诊断)
  169. * @ApiMethod (POST)
  170. * @ApiRoute (/inter/writereport/write)
  171. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  172. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  173. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  174. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  175. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  176. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  177. * @ApiParams (name="param[id]", type="string", sample="", description="exams表id值<必填>")
  178. * @ApiParams (name="param[pid]", type="string", sample="", description="患者id值<必填>")
  179. * @ApiParams (name="param[name]", type="string", sample="", description="患者姓名<必填>")
  180. * @ApiParams (name="param[age]", type="string", sample="", description="患者年龄<必填>")
  181. * @ApiParams (name="param[sex]", type="string", sample="", description="患者性别<必填>")
  182. * @ApiParams (name="param[impression]", type="string", sample="", description="影响所见<必填>")
  183. * @ApiParams (name="param[description]", type="string", sample="", description="意见建议<必填>")
  184. * @ApiParams (name="param[film_type]", type="string", sample="", description="胶片<必填>")
  185. * @ApiParams (name="param[r_result]", type="string", sample="", description="检查结果<必填>")
  186. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  187. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  188. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  189. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  190. * @ApiReturn (data="
  191. {
  192. 'status': ok,
  193. 'code': '0000',
  194. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  195. 'msg' : '保存成功'
  196. }
  197. *")
  198. **/
  199. public function write(){
  200. try{
  201. $sessionid = $_REQUEST['sessionid'];
  202. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  203. // 是远程写报告 7
  204. $return = Verify::check_role($sessionid,7);
  205. }else{
  206. // 本地写报告权限 2
  207. $return = Verify::check_role($sessionid,2);
  208. }
  209. if($return != 1){
  210. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  211. }
  212. $param = $_REQUEST['param'];
  213. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  214. //远程
  215. $status = DB::table('remote_application')->where('id',$param['rid'])->field('report_status')->find();
  216. if($status['report_status'] == 12){
  217. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被撤回,无法进行保存填写']);
  218. }elseif($status['report_status'] > 7 && $status['report_status'] != 13){
  219. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被审核,无法再次被保存']);
  220. }
  221. }else{
  222. //本地
  223. $status = DB::table('exams')->where('id',$param['id'])->field('exam_status')->find();
  224. if($status['exam_status'] > 6 && $status['exam_status'] != 13){
  225. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被保存,无法再次被修改']);
  226. }
  227. }
  228. // Verify::wreportCheck($param);
  229. $doctor = Cache::get($sessionid);
  230. // $remote_app = DB::table('remote_application')->where('exam_id',$param['id'])->field('remote_doctor_id')->find();
  231. // if(!empty($remote_app['remote_doctor_id'])){
  232. // if($remote_app['remote_doctor_id'] != $doctor['id']){
  233. // return json_encode(['status'=>'fail','code'=>'1029','msg'=>'已被指定报告医生,您没有操作权限']);
  234. // }
  235. // }
  236. $this->uuids = new UUIDs();
  237. //初步报告生成
  238. $film_type = isset($param['film_type']) ? $param['film_type'] : '';
  239. // $exam_status = $this->get_exam_status($doctor['id'],7);
  240. $patient_info = array();
  241. $patient_info['id'] = isset($param['pid']) ? $param['pid'] : '';
  242. $patient_info['name'] = isset($param['name']) ? $param['name'] : '';
  243. $patient_info['age'] = isset($param['age']) ? $param['age'] : '';
  244. $patient_info['phone'] = isset($param['phone']) ? $param['phone'] : '';
  245. if(isset($param['sex']) && !empty($param['sex'])){
  246. switch($param['sex']){
  247. case '男';
  248. $sex = 'M';
  249. break;
  250. case '女';
  251. $sex = 'F';
  252. break;
  253. case 'm';
  254. $sex = 'M';
  255. break;
  256. case 'f';
  257. $sex = 'F';
  258. break;
  259. default :
  260. $sex = $param['sex'];
  261. }
  262. $patient_info['sex'] = $sex;
  263. }
  264. $patient = DB::table('patient_infos')->where('id',$param['pid'])->update($patient_info);
  265. $info = array();
  266. $info['exam_id'] = $param['id'];
  267. $info['impression'] = isset($param['impression']) ? $param['impression'] : '';
  268. $info['description'] = isset($param['description']) ? $param['description'] : '';
  269. if(isset($param['r_result']) && $param['r_result'] == 'true'){
  270. $info['report_result'] = 2;
  271. }else{
  272. $info['report_result'] = 1;
  273. }
  274. DB::table('exams')->where('id',$param['id'])->update(['film_type'=>$film_type,'phone'=>isset($param['phone']) ? $param['phone'] : '','exam_report'=>$info['report_result']]);
  275. // 报告的id
  276. $report_id = $param['report_id'];
  277. if(isset($_REQUEST['is_remote']) && !empty($_REQUEST['is_remote'])){
  278. // 远程保存
  279. DB::table('remote_application')->where('id',$param['rid'])->update(['report_status'=>'7']);
  280. $info['type'] = 2;
  281. }else{
  282. //本地保存
  283. DB::table('exams')->where('id',$param['id'])->update(['exam_status'=>'7']);
  284. $info['type'] = 1;
  285. }
  286. $info['report_datetime'] = date('Y-m-d H:i:s',time());
  287. $info['report_doctor_id'] = $doctor['id'];
  288. $info['remote_application_id'] = $param['rid'];
  289. if($report_id){
  290. $report_info = DB::table('report')->where('id',$report_id)->find();
  291. $report = DB::table('report')->where('id',$report_id)->update($info);
  292. $id = $report_info['id'];
  293. $cache_key = $doctor['id'].'_'.$report_id;
  294. $rid = $report_id;
  295. } else {
  296. $id = $this->uuids->uuid16();
  297. $info['id'] = $id;
  298. $info['createdAt'] = date('Y-m-d H:i:s',time());
  299. $report = DB::table('report')->insert($info);
  300. $cache_key = $doctor['id'].'_'.$id;
  301. $rid = $id;
  302. }
  303. if(Cache::get($cache_key)){
  304. Cache::rm($cache_key);
  305. }
  306. //写入log日志
  307. log::record('----日志写入----');
  308. $log = array();
  309. $log['id'] = UUIDs::uuid16();
  310. $log['impression'] = isset($param['impression']) ? $param['impression'] : '';
  311. $log['description'] = isset($param['description']) ? $param['description'] : '';
  312. $log['report_id'] = $rid;
  313. $log['createdAt'] = date('Y-m-d H:i:s',time());
  314. $log['doctor_id'] = $doctor['id'];
  315. $log['type'] = 1; //写报告
  316. log::record($log);
  317. $report_log = DB::table('report_record')->insert($log);
  318. log::record($report_log);
  319. log::record('----日志写入成功----');
  320. $application = DB::table('remote_application')->where('exam_id',$param['id'])->find();
  321. if($application['req_doctor_id'] == 'c44663d6d3c0b535'){
  322. $tel = '18910184804';
  323. $type = '保存报告';
  324. $content = $application['id'];
  325. // send_message::sendSms2Self($tel,$type,$content);
  326. }
  327. $url = 'http://wechat.pacsonline.cn/wx_patient/api/unifyGetWxQrcode?reportId='.$rid;
  328. $info = $this->curl_get($url);
  329. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'保存成功','sessionid'=>$sessionid]);
  330. }catch(\Exception $e){
  331. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  332. }
  333. }
  334. public function get_exam_status($doctorid,$status){
  335. $doctor_class = DB::table('doctor_class')->where('doctor_id',$doctorid)->field('doctor_class')->find();
  336. if(strpos($doctor_class['doctor_class'],'9')){
  337. return 9;
  338. }elseif(strpos($doctor_class['doctor_class'],'8')){
  339. return 8;
  340. }else{
  341. return $status;
  342. }
  343. }
  344. /**
  345. * 公有模板列表
  346. *
  347. * @ApiTitle (公有模板列表)
  348. * @ApiSummary (公有模板列表)
  349. * @ApiSector (远程诊断)
  350. * @ApiMethod (POST)
  351. * @ApiRoute (/inter/writereport/public_template)
  352. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  353. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  354. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  355. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  356. * @ApiParams (name="exam_class", type="string", required=true, description="检查类id")
  357. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  358. * @ApiReturn (data="
  359. {
  360. 'info' : ''
  361. }
  362. *")
  363. **/
  364. public function public_template(){
  365. $sessionid = $_REQUEST['sessionid'];
  366. $doctor = Cache::get($sessionid);
  367. $exam = $_REQUEST['exam_class'];
  368. //第一级 公共模板
  369. $info = $this->get_template(1,$doctor['id'],$exam);
  370. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid]);
  371. }
  372. /**
  373. * 私有模板列表
  374. *
  375. * @ApiTitle (私有模板列表)
  376. * @ApiSummary (私有模板列表)
  377. * @ApiSector (远程诊断)
  378. * @ApiMethod (POST)
  379. * @ApiRoute (/inter/writereport/private_template)
  380. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  381. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  382. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  383. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  384. * @ApiParams (name="exam_class", type="string", required=true, description="检查类id")
  385. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  386. * @ApiReturn (data="
  387. {
  388. 'info' : ''
  389. }
  390. *")
  391. **/
  392. public function private_template(){
  393. $sessionid = $_REQUEST['sessionid'];
  394. $doctor = Cache::get($sessionid);
  395. $exam = $_REQUEST['exam_class'];
  396. //私有模板
  397. $info = $this->get_template(2,$doctor['id'],$exam);
  398. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid]);
  399. }
  400. public function get_template($public,$id,$exam){
  401. // 查询exam_class表
  402. $examCla = DB::table('constant')->where('id',$exam)->field('constant_value as name')->find();
  403. if($public == 1){
  404. $t = DB::table('templates')->where('is_public',$public)->where('exam_class_id',$examCla['name'])->field(['id','title as label','impression','description','parent_id'])->select();
  405. }else{
  406. // 私有模板 添加创建人条件
  407. $t = DB::table('templates')->where('is_public',$public)->where('create_user',$id)->where('exam_class_id',$examCla['name'])->field(['id','title as label','impression','description','parent_id'])->select();
  408. }
  409. if(!$t){
  410. return '';
  411. }
  412. $data = array();
  413. foreach ($t as $k => $v) {
  414. if($v['parent_id'] == '0'){
  415. $data[] = $v;
  416. }
  417. }
  418. foreach ($data as $k => $v) {
  419. unset($data[$k]['impression']);
  420. unset($data[$k]['description']);
  421. unset($data[$k]['parent_id']);
  422. }
  423. foreach ($t as $k => $v) {
  424. foreach ($data as $key => $value) {
  425. if($v['parent_id'] == $value['id']){
  426. unset($t[$k]['parent_id']);
  427. $data[$key]['children'][] = $t[$k];
  428. }
  429. }
  430. }
  431. if($data){
  432. return $data;
  433. }
  434. }
  435. /**
  436. * 确认报告
  437. *
  438. * @ApiTitle (确认报告)
  439. * @ApiSummary (确认报告)
  440. * @ApiSector (远程诊断)
  441. * @ApiMethod (POST)
  442. * @ApiRoute (/inter/writereport/confirm)
  443. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  444. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  445. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  446. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  447. * @ApiParams (name="id", type="string", sample="", description="exams表id值<必填>")
  448. * @ApiParams (name="film_type", type="string", sample="", description="胶片类型<必填>")
  449. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  450. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  451. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  452. * @ApiReturn (data="
  453. {
  454. 'status': ok,
  455. 'code': '0000',
  456. 'msg': '已确认',
  457. }
  458. *")
  459. **/
  460. public function confirm(WechatService $wechatService){
  461. try{
  462. Log::record('confirm');
  463. $is_remote = $_REQUEST['is_remote'];
  464. if($is_remote == 1){
  465. return json_encode(['status'=>'fail','code'=>'1133','msg'=>'远程无法确诊报告']);
  466. }
  467. $sessionid = $_REQUEST['sessionid'];
  468. $doctor = Cache::get($sessionid);
  469. Log::record($doctor);
  470. $param = $_REQUEST['param'];
  471. Log::record($param);
  472. $id = $param['id'];
  473. $report_id = $param['report_id'];
  474. $report_info = DB::table('report')->where('id',$report_id)->find();
  475. Log::record($report_info);
  476. if($report_info['type'] == 1){
  477. //本地报告
  478. $status = DB::table('exams')->where('id',$id)->field('exam_status')->find();
  479. if($status['exam_status'] < 8 ){
  480. return json_encode(['status'=>'fail','code'=>'1033','msg'=>'只能确认通过审核的报告']);
  481. }elseif($status['exam_status'] == 9){
  482. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'已经确认过该报告,不可再次确认']);
  483. }
  484. }else{
  485. //远程
  486. $status = DB::table('remote_application')->where('id',$report_info['remote_application_id'])->field('remote_doctor_id,report_status')->find();
  487. if($status['report_status'] < 8 ){
  488. return json_encode(['status'=>'fail','code'=>'1033','msg'=>'只能确认通过审核的报告']);
  489. }elseif($status['report_status'] == 9){
  490. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'已经确认过该报告,不可再次确认']);
  491. }
  492. }
  493. $rinfo = array();
  494. if(isset($param['r_result']) && $param['r_result'] == 'true'){
  495. $rinfo['report_result'] = 2;
  496. }else{
  497. $rinfo['report_result'] = 1;
  498. }
  499. $rinfo['confirm_datetime'] = date('Y-m-d H:i:s',time());
  500. $rinfo['confirm_doctor_id'] = $doctor['id'];
  501. if($report_info['type'] == 1){
  502. //本地报告确认
  503. DB::table('exams')->where('id',$id)->update(['exam_status'=>'9']);
  504. }else{
  505. Message::read($doctor['id'],$report_info['remote_application_id'],4);
  506. //远程
  507. $this->confirmReport($report_info['remote_application_id'], $wechatService);
  508. // DB::table('remote_application')->where('id',$report_info['remote_application_id'])->update(['report_status'=>'9']);
  509. // 添加messages消息
  510. $t = '您的报告已确认';
  511. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  512. $c = '您的远程诊断报告,已被'.$institution['name'].$doctor['realname'].'医师确认';
  513. $d = $status['remote_doctor_id'];
  514. $type = '6';
  515. $url = '';
  516. Message::insert($t,$c,$d,$type,$url,1,$report_info['remote_application_id']);
  517. }
  518. DB::table('exams')->where('id',$id)->update(['film_type'=>$_REQUEST['param']['film_type']]);
  519. DB::table('report')->where('id',$report_id)->update($rinfo);
  520. $cache_key = $doctor['id'].'_'.$report_info['id'];
  521. if(Cache::get($cache_key)){
  522. Cache::rm($cache_key);
  523. }
  524. // 添加 确认log日志
  525. $info = array();
  526. $info['id'] = UUIDs::uuid16();
  527. $info['createdAt'] = date('Y-m-d H:i:s',time());
  528. $info['doctor_id'] = $doctor['id'];
  529. $info['type'] = 3;
  530. $info['report_id'] = $report_id;
  531. DB::table('report_record')->insert($info);
  532. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'已确认']);
  533. }catch(\Exception $e){
  534. Log::record('confirm error ');
  535. Log::record($e);
  536. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  537. }
  538. }
  539. private function confirmReport($application_id, $wechatService) {
  540. Db::startTrans();
  541. try{
  542. DB::table('remote_application')->where('id', $application_id)->update(['report_status'=>'9']);
  543. DB::table('remote_application')->where('id',$application_id)->update(['report_status'=>'9']);
  544. $remote_order = DB::table('remote_order')
  545. ->where('status', Application::ORDER_STATUS['PAYCOMPLTET'])
  546. ->where('application_id', $application_id)
  547. ->field('order_money, id, super_hospital_id')
  548. ->find();
  549. $hospital = DB::table('institution')->where('id', $remote_order['super_hospital_id'])->field('current_money')->find();
  550. if(!$remote_order) {
  551. DB::commit();
  552. // todo 微信消息推送
  553. return true;
  554. }
  555. $brfore_money = $hospital['current_money'];
  556. $order_money = $remote_order['order_money'];
  557. $after_money = $brfore_money + $order_money;
  558. DB::table('institution')->where('id', $remote_order['super_hospital_id'])->update(['current_money' => $after_money]);
  559. DB::table('remote_order')->where('id', $remote_order['id'])->update(['status' => Application::ORDER_STATUS['CONFIRM']]);
  560. $hospital_id = $remote_order['super_hospital_id'];
  561. $order_id = $remote_order['id'];
  562. $type = Application::WATER_TYPE['ADD'];
  563. $why = Application::WATER_WHY['REMOTEINCOME'];
  564. $water_id = DB::table('remote_water')->insertGetId([
  565. 'hospital_id' => $hospital_id,
  566. 'order_id' => $order_id,
  567. 'money' => $order_money,
  568. 'type' => $type,
  569. 'why' => $why,
  570. 'timestamp' => time(),
  571. ]);
  572. DB::table('remote_water_log')->insert([
  573. 'hospital_id' => $hospital_id,
  574. 'order_id' => $order_id,
  575. 'water_id' => $water_id,
  576. 'order_money' => $order_money,
  577. 'brfore_money' => $brfore_money,
  578. 'after_money' => $after_money,
  579. 'type' => $type,
  580. 'why' => $why,
  581. 'timestamp' => time(),
  582. ]);
  583. // 提交事务
  584. Db::commit();
  585. $wechatService->pushWechatComplete($order_id);
  586. // todo 消息推送
  587. return true;
  588. } catch (\Exception $e) {
  589. // 回滚事务
  590. Db::rollback();
  591. Log::record("-----错误-----");
  592. Log::record('xxxxxxxxx');
  593. var_dump($e->getMessage());
  594. }
  595. return json_encode(['status'=>'fail','code'=>'2110','确认报告失败']);
  596. }
  597. /**
  598. * 审核报告
  599. *
  600. * @ApiTitle (审核报告)
  601. * @ApiSummary (审核报告)
  602. * @ApiSector (远程诊断)
  603. * @ApiMethod (POST)
  604. * @ApiRoute (/inter/writereport/examine)
  605. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  606. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  607. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  608. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  609. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  610. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  611. * @ApiParams (name="id", type="string", sample="", description="exams表id值<必填>")
  612. * @ApiParams (name="param[impression]", type="string", sample="", description="检查所见<必填>")
  613. * @ApiParams (name="param[description]", type="string", sample="", description="意见建议<必填>")
  614. * @ApiParams (name="param[r_result]", type="string", sample="", description="检查结果<必填>")
  615. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  616. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  617. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  618. * @ApiReturn (data="
  619. {
  620. 'status': ok,
  621. 'code': '0000',
  622. 'msg': '已审核',
  623. }
  624. *")
  625. **/
  626. public function examine(){
  627. try{
  628. $id = $_REQUEST['id'];
  629. $param = $_REQUEST['param'];
  630. $report_id = $param['report_id'];
  631. $report = DB::table('report')->where('id',$report_id)->find();
  632. $sessionid = $_REQUEST['sessionid'];
  633. $doctor = Cache::get($sessionid);
  634. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  635. // 是远程审核报告 8
  636. $return = Verify::check_role($sessionid,8);
  637. $status = DB::table('remote_application')->where('id',$report['remote_application_id'])->field('req_doctor_id,report_status')->find();
  638. if($status['report_status'] < 7){
  639. return json_encode(['status'=>'fail','code'=>'1032','msg'=>'只能审核已提交的报告']);
  640. }elseif($status['report_status']>8){
  641. return json_encode(['status'=>'fail','code'=>'1035','msg'=>'报告已被下级医院所确认,无法进行审核']);
  642. }elseif($status['report_status'] == 8){
  643. if($report['review_doctor_id'] != $doctor['id']){
  644. return json_encode(['status'=>'fail','code'=>'1039','msg'=>'审核人不一致']);
  645. }
  646. }
  647. DB::table('remote_application')->where('id',$report['remote_application_id'])->update(['report_status'=>'8']);
  648. }else{
  649. // 本地审核权限 3
  650. $return = Verify::check_role($sessionid,3);
  651. $status = DB::table('exams')->where('id',$id)->field('exam_status')->find();
  652. if($status['exam_status'] < 7){
  653. return json_encode(['status'=>'fail','code'=>'1032','msg'=>'只能审核已提交的报告']);
  654. }elseif($status['exam_status']>7){
  655. return json_encode(['status'=>'fail','code'=>'1035','msg'=>'报告已通过审核步骤,请勿重复操作']);
  656. }
  657. DB::table('exams')->where('id',$id)->update(['exam_status'=>'8']);
  658. }
  659. $report_info = array();
  660. $report_info['impression'] = isset($param['impression']) ? $param['impression'] : '';
  661. $report_info['description'] = isset($param['description']) ? $param['description'] : '';
  662. if(isset($param['r_result']) && $param['r_result'] == 'true'){
  663. $report_info['report_result'] = 2;
  664. }else{
  665. $report_info['report_result'] = 1;
  666. }
  667. $report_info['review_datetime'] = date('Y-m-d H:i:s',time());
  668. $report_info['review_doctor_id'] = $doctor['id'];
  669. DB::table('report')->where('id',$report['id'])->update($report_info);
  670. $cache_key = $doctor['id'].'_'.$report['id'];
  671. if(Cache::get($cache_key)){
  672. Cache::rm($cache_key);
  673. }
  674. $info = array();
  675. $info['id'] = UUIDs::uuid16();
  676. $info['type'] = 2; //审核
  677. $info['createdAt'] = date('Y-m-d H:i:s',time());
  678. $info['doctor_id'] = $doctor['id'];
  679. $info['impression'] = isset($param['impression']) ? $param['impression'] : '';
  680. $info['description'] = isset($param['description']) ? $param['description'] : '';
  681. $info['report_id'] = $report['id'];
  682. DB::table('report_record')->insert($info);
  683. DB::table('exams')->where('id',$id)->update(['film_type'=>$param['film_type']]);
  684. // 已审核 发送短信
  685. $application = DB::table('remote_application')->where('exam_id',$id)->find();
  686. $dinfo = DB::table('doctors')->where('id',$application['req_doctor_id'])->find();
  687. $d_phone = $dinfo['phone'];
  688. log::record('发短信的手机号为'.$d_phone);
  689. $d_name = $doctor['realname'];
  690. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  691. if($dinfo['institution_id'] == '22100002' || $dinfo['send_sms'] == 1){ //魏庙下级
  692. $repsone = send_message::sendSms2CompleteReport($d_phone,$d_name);
  693. }
  694. $tel = '18910184804';
  695. $type = '完成并审核报告';
  696. $content =$application['id'];
  697. // send_message::sendSms2Self($tel,$type,$content);
  698. }
  699. // 添加messages消息
  700. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  701. Message::read($doctor['id'],$report['remote_application_id'],3);
  702. $t = '您的远程诊断申请已完成';
  703. $institution = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  704. $c = '您的远程诊断申请,已由被'.$institution['name'].$doctor['realname'].'医师完成报告';
  705. $d = $status['req_doctor_id'];
  706. $type = '5';
  707. $exam_class = DB::table('exams')->where('id',$id)->field('exam_class')->find();
  708. $url = Message::url($sessionid,$id,0,$exam_class['exam_class'],$report_id,$report['remote_application_id']);
  709. Message::insert($t,$c,$d,$type,$url,1,$report['remote_application_id']);
  710. }
  711. $url = 'http://wechat.pacsonline.cn/wx_patient/api/unifyGetWxQrcode?reportId='.$report_id;
  712. $info = $this->curl_get($url);
  713. return json_encode(['status'=>'ok','code'=>'0000','msg'=>'已审核']);
  714. }catch(\Exception $e){
  715. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  716. }
  717. }
  718. public function curl_get($url){
  719. //初始化
  720. $curl = curl_init();
  721. //设置抓取的url
  722. curl_setopt($curl, CURLOPT_URL, $url);
  723. //设置头文件的信息作为数据流输出
  724. curl_setopt($curl, CURLOPT_HEADER, 0);
  725. //设置获取的信息以文件流的形式返回,而不是直接输出。
  726. curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
  727. // 重定向
  728. curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1);
  729. //执行命令
  730. $data = curl_exec($curl);
  731. //关闭URL请求
  732. curl_close($curl);
  733. return $data;
  734. }
  735. /**
  736. * 获取报告权限
  737. *
  738. * @ApiTitle (获取报告权限)
  739. * @ApiSummary (获取报告权限)
  740. * @ApiSector (远程诊断)
  741. * @ApiMethod (POST)
  742. * @ApiRoute (/inter/writereport/getrole)
  743. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  744. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  745. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  746. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  747. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  748. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  749. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  750. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  751. * @ApiReturn (data="
  752. {
  753. 'status': ok,
  754. 'code': '0000',
  755. 'info': '',
  756. }
  757. *")
  758. **/
  759. public function getrole(){
  760. try{
  761. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  762. $is_remote = $_REQUEST['is_remote'];
  763. }
  764. $sessionid = $_REQUEST['sessionid'];
  765. $doctor = Cache::get($sessionid);
  766. $dclass = DB::table('doctor_class')->where('doctor_id',$doctor['id'])->field('doctor_class')->find();
  767. $doctor_class = explode(',',$dclass['doctor_class']);
  768. $info = array();
  769. foreach ($doctor_class as $k=>$v) {
  770. switch($v){
  771. case 2: //报告医生
  772. if(isset($is_remote)){
  773. //远程报告
  774. break;
  775. }
  776. $info['bg'] = 1;
  777. break;
  778. case 7: //远程报告医生
  779. if(!isset($is_remote)){
  780. //远程报告
  781. break;
  782. }
  783. $info['bg'] = 1;
  784. break;
  785. case 3: //3审核医生
  786. if(isset($is_remote)){
  787. //远程报告
  788. break;
  789. }
  790. $info['sh'] = 2;
  791. break;
  792. case 8: //远程审核医生
  793. if(!isset($is_remote)){
  794. //远程报告
  795. break;
  796. }
  797. $info['sh'] = 2;
  798. break;
  799. case 4: //确认医生
  800. $info['qr'] = 3;
  801. break;
  802. }
  803. }
  804. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info]);
  805. }catch(\Exception $e){
  806. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  807. }
  808. }
  809. /**
  810. * 获取报告日志
  811. *
  812. * @ApiTitle (获取报告日志)
  813. * @ApiSummary (获取报告日志)
  814. * @ApiSector (远程诊断)
  815. * @ApiMethod (POST)
  816. * @ApiRoute (/inter/writereport/get_report_log)
  817. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  818. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  819. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  820. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  821. * @ApiParams (name="id", type="string", required=true, description="exams表id值")
  822. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  823. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  824. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  825. * @ApiReturn (data="
  826. {
  827. 'status': ok,
  828. 'code': '0000',
  829. 'info': '',
  830. }
  831. *")
  832. **/
  833. public function get_report_log(){
  834. try{
  835. $sessionid = $_REQUEST['sessionid'];
  836. $doctor = Cache::get($sessionid);
  837. $id = $_REQUEST['id'];
  838. $exam_id = $_REQUEST['exam_id'];
  839. if(isset($_REQUEST['is_remote']) && !empty($_REQUEST['is_remote'])){
  840. // 远程
  841. $report = DB::table('report')->where('id',$id)->find();
  842. }else{
  843. // 本地
  844. $report = DB::table('report')->where('exam_id',$exam_id)->where('type',1)->find();
  845. }
  846. if(empty($report)){
  847. return json_encode(['status'=>'ok','code'=>'0000','info'=>'','msg'=>'无数据']);
  848. }
  849. $log = DB::table('report_record')->where('doctor_id',$doctor['id'])->where('report_id',$report['id'])->order('createdAt asc,type asc')->select();
  850. foreach ($log as $k => $v) {
  851. $doc = DB::table('doctors')->where('id',$v['doctor_id'])->field('realname')->find();
  852. $log[$k]['doctor_name'] = $doc['realname'];
  853. }
  854. return json_encode(['status'=>'ok','code'=>'0000','info'=>$log]);
  855. }catch(\Exception $e){
  856. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  857. }
  858. }
  859. /**
  860. * 打印报告
  861. *
  862. * @ApiTitle (打印报告)
  863. * @ApiSummary (打印报告)
  864. * @ApiSector (远程诊断)
  865. * @ApiMethod (POST)
  866. * @ApiRoute (/inter/writereport/print_report)
  867. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  868. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  869. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  870. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  871. * @ApiParams (name="id", type="string", required=true, description="exams表id值")
  872. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  873. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  874. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  875. * @ApiReturnParams (name="sessionid", type="object", sample="{}", description="缓存的数据key")
  876. * @ApiReturn (data="
  877. {
  878. 'status': ok,
  879. 'code': '0000',
  880. 'sessionid': 'a17z7a7a8f9g9rh9d89jio',
  881. 'info': '',
  882. }
  883. *")
  884. **/
  885. public function print_report(){
  886. try{
  887. $sessionid = $_REQUEST['sessionid'];
  888. $doctor = Cache::get($sessionid);
  889. $id = $_REQUEST['id'];
  890. $is_remote = $_REQUEST['is_remote'];
  891. $report_id = $_REQUEST['report_id'];
  892. $report = DB::table('report')->where('id',$report_id)->field('qr_code,remote_application_id,report_datetime,impression,description,report_doctor_id,review_doctor_id')->find();
  893. $info = array();
  894. // 检查日期 住院号 床号 本地申请科室 本地申请医生
  895. $exam_info = DB::table('exams')->where('id',$id)->field('id,ext,accession_num,exam_datetime,exam_class,hopitalized_no,bed_no,exam_project,patient_id,application_department,application_doctor')->find();
  896. $info['id'] = $exam_info['id'];
  897. $info['ext'] = $exam_info['ext'];
  898. $info['accession_num'] = $exam_info['accession_num'];
  899. if(!empty($exam_info['exam_datetime'])){
  900. $datetime = explode(' ',$exam_info['exam_datetime']);
  901. $info['exam_datetime'] = $datetime[0];
  902. }else{
  903. $info['exam_datetime'] = '';
  904. }
  905. $info['hopitalized_no'] = $exam_info['hopitalized_no'];
  906. $info['bed_no'] = $exam_info['bed_no'];
  907. // 检查项目
  908. $project = DB::table('exam_project')->where('id',$exam_info['exam_project'])->field('name')->find();
  909. $info['project'] = $project['name'];
  910. //检查类
  911. $exam_class = DB::table('constant')->where('id',$exam_info['exam_class'])->field('constant_value')->find();
  912. $info['exam_class'] = $exam_class['constant_value'];
  913. // 病历号 姓名 年龄 性别
  914. $patient_info = DB::table('patient_infos')->where('id',$exam_info['patient_id'])->field('temp_patient_id,name,sex,age')->find();
  915. $remote = DB::table('remote_application')->where('id',$report['remote_application_id'])->field('req_doctor_id')->find();
  916. $info['pnumber'] = $patient_info['temp_patient_id'];
  917. $info['name'] = $patient_info['name'];
  918. $info['sex'] = $patient_info['sex'];
  919. $info['age'] = $patient_info['age'];
  920. // 申请医生
  921. $application_name = DB::table('doctors')->where('id',$remote['req_doctor_id'])->field('realname,department_id,autograph,is_use_autograph')->find();
  922. if($is_remote == 1){
  923. $info['application_name'] = $application_name['realname'];
  924. // 申请科室
  925. $department = DB::table('department')->where('id',$application_name['department_id'])->field('department_name')->find();
  926. $info['department_name'] = $department['department_name'];
  927. }else{
  928. $info['application_name'] = $exam_info['application_doctor'];
  929. $info['application_department'] = $exam_info['application_department'];
  930. }
  931. $info['application_use_autograph'] = $application_name['is_use_autograph'];
  932. $info['application_autograph'] = $application_name['autograph'];
  933. // 报告时间 影像所见 意见建议
  934. if(!empty($report['report_datetime'])){
  935. $datetime1 = explode(' ',$report['report_datetime']);
  936. $info['report_datetime'] = $datetime1[0];
  937. }else{
  938. $info['report_datetime'] = '';
  939. }
  940. $info['report_datetime_xa'] = $report['report_datetime'];
  941. $info['impression'] = $report['impression'];
  942. $info['description'] = $report['description'];
  943. $info['qr_code'] = $report['qr_code'];
  944. // 报告医生
  945. $report_doctor = DB::table('doctors')->where('id',$report['report_doctor_id'])->field('realname,autograph,is_use_autograph,institution_id')->find();
  946. $info['report_doctor'] = $report_doctor['realname'];
  947. $info['report_use_autograph'] = $report_doctor['is_use_autograph'];
  948. $info['report_autograph'] = $report_doctor['autograph'];
  949. //审核医生
  950. $review_doctor = DB::table('doctors')->where('id',$report['review_doctor_id'])->field('realname,autograph,is_use_autograph')->find();
  951. $info['review_doctor'] = $review_doctor['realname'];
  952. $info['review_use_autograph'] = $review_doctor['is_use_autograph'];
  953. $info['review_autograph'] = $review_doctor['autograph'];
  954. // $hospital = DB::table('institution')->where('id',$doctor['institution_id'])->field('name')->find();
  955. $hospital = DB::table('institution')->where('id',$report_doctor['institution_id'])->field('name')->find();
  956. $info['hospital'] = $hospital['name'];
  957. return json_encode(['status'=>'ok','code'=>'0000','info'=>$info,'sessionid'=>$sessionid]);
  958. }catch(\Exception $e){
  959. return json_encode(['status'=>'fail','code'=>'2000','msg'=>$e->getMessage()]);
  960. }
  961. }
  962. /**
  963. * 变更胶片
  964. *
  965. * @ApiTitle (变更胶片)
  966. * @ApiSummary (变更胶片)
  967. * @ApiSector (远程诊断)
  968. * @ApiMethod (POST)
  969. * @ApiRoute (/inter/writereport/change_film)
  970. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  971. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  972. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  973. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  974. * @ApiParams (name="id", type="string", required=true, description="exams表id值")
  975. * @ApiParams (name="film_type", type="string", required=true, description="胶片")
  976. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  977. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  978. * @ApiReturnParams (name="info", type="string", required=true, sample="返回成功", description="返回信息")
  979. * @ApiReturn (data="z
  980. {
  981. 'status': ok,
  982. 'code': '0000',
  983. 'info': '',
  984. }
  985. *")
  986. **/
  987. public function change_film(){
  988. $id = $_REQUEST['id'];
  989. $film = $_REQUEST['film_type'];
  990. DB::table('exams')->where('id',$id)->update(['film_type'=>$film]);
  991. return json_encode(['status'=>'ok','info'=>$film,'code'=>'0000']);
  992. }
  993. /**
  994. * 保存草稿
  995. *
  996. * @ApiTitle (保存草稿)
  997. * @ApiSummary (保存草稿)
  998. * @ApiSector (远程诊断)
  999. * @ApiMethod (POST)
  1000. * @ApiRoute (/inter/writereport/draft)
  1001. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  1002. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  1003. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  1004. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  1005. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  1006. * @ApiParams (name="param[report_id]", type="string", sample="", description="报告表id值<必填>")
  1007. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  1008. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  1009. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  1010. * @ApiReturn (data="
  1011. {
  1012. 'status': ok,
  1013. 'code': '0000',
  1014. 'msg': '保存成功',
  1015. }
  1016. *")
  1017. **/
  1018. public function draft(){
  1019. $sessionid = $_REQUEST['sessionid'];
  1020. $doctor = Cache::get($sessionid);
  1021. $param = $_REQUEST['param'];
  1022. $report_id = $param['report_id'];
  1023. $rinfo = DB::table('report')->where('id',$report_id)->find();
  1024. if($rinfo['type'] == 2){
  1025. //远程报告
  1026. $status = DB::table('remote_application')->where('id',$rinfo['remote_application_id'])->find();
  1027. if($status['report_status'] ==6 || $status['report_status'] ==7){
  1028. $key = $doctor['id'].'_'.$report_id;
  1029. Cache::set($key,$param);
  1030. return json_encode(['status'=>'ok','msg'=>'保存成功','code'=>'0000']);
  1031. }else{
  1032. return json_encode(['status'=>'fail','msg'=>'只能为未保存或者未审核的报告填写草稿','code'=>'0110']);
  1033. }
  1034. }else {
  1035. //本地报告
  1036. $status = DB::table('exams')->where('id', $rinfo['exam_id'])->find();
  1037. if ($status['exam_status'] == 7 || $status['exam_status'] == 3) {
  1038. $key = $doctor['id'] . '_' . $report_id;
  1039. Cache::set($key, $param);
  1040. return json_encode(['status' => 'ok', 'msg' => '保存成功', 'code' => '0000']);
  1041. } else {
  1042. return json_encode(['status' => 'fail', 'msg' => '只能为未保存或者未审核的报告填写草稿', 'code' => '0110']);
  1043. }
  1044. }
  1045. }
  1046. /**
  1047. * XA类型数据获取
  1048. *
  1049. * @ApiTitle (XA类型数据获取)
  1050. * @ApiSummary (XA类型数据获取)
  1051. * @ApiSector (远程诊断)
  1052. * @ApiMethod (POST)
  1053. * @ApiRoute (/inter/writereport/get_rinfo)
  1054. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  1055. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  1056. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  1057. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  1058. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  1059. * @ApiParams (name="report_id", type="string", required=true, description="报告表id<必填>")
  1060. * @ApiParams (name="id", type="string", sample="", description="exams表id值<必填>")
  1061. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  1062. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  1063. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  1064. * @ApiReturn (data="
  1065. {
  1066. 'status': ok,
  1067. 'code': '0000',
  1068. 'msg': '已审核',
  1069. }
  1070. *")
  1071. **/
  1072. public function get_rinfo(){
  1073. $sessionid = $_REQUEST['sessionid'];
  1074. $doctor = Cache::get($sessionid);
  1075. $id = $_REQUEST['id'];
  1076. $report_id = $_REQUEST['report_id'];
  1077. $key = $doctor['id'].'_'.$report_id;
  1078. if(Cache::get($key)){
  1079. $patient = Cache::get($key);
  1080. }else{
  1081. $exam = DB::table('exams')->where('id',$id)->field('accession_num,exam_class,patient_id,ext,hopitalized_no,bed_no')->find();
  1082. $patient = DB::table('patient_infos')->where('id',$exam['patient_id'])->field(['id','temp_patient_id','name','phone','sex','age'])->find();
  1083. $report_info = DB::table('report')->where('id',$report_id)->field('description')->find();
  1084. $patient['ext'] = $exam['ext'];
  1085. $patient['exam_id'] = $id;
  1086. $patient['bed_no'] = $exam['bed_no'];
  1087. $patient['accession_num'] = $exam['accession_num'];
  1088. $patient['exam_class'] = $exam['exam_class'];
  1089. $patient['hopitalized_no'] = $exam['hopitalized_no'];
  1090. $patient['description'] = $report_info['description'];
  1091. $patient['report_id'] = $report_id;
  1092. }
  1093. return json_encode(['status'=>'ok','info'=>$patient,'code'=>'0000']);
  1094. }
  1095. /**
  1096. * XA类型保存
  1097. *
  1098. * @ApiTitle (XA类型保存)
  1099. * @ApiSummary (XA类型保存)
  1100. * @ApiSector (远程诊断)
  1101. * @ApiMethod (POST)
  1102. * @ApiRoute (/inter/writereport/write_info)
  1103. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  1104. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  1105. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  1106. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  1107. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  1108. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  1109. * @ApiParams (name="param[id]", type="string", sample="", description="exams表id值<必填>")
  1110. * @ApiParams (name="param[name]", type="string", sample="", description="姓名<必填>")
  1111. * @ApiParams (name="param[sex]", type="string", sample="", description="性别<必填>")
  1112. * @ApiParams (name="param[age]", type="string", sample="", description="年龄<必填>")
  1113. * @ApiParams (name="param[hospital_number]", type="string", sample="", description="住院号<必填>")
  1114. * @ApiParams (name="param[bed_number]", type="string", sample="", description="病床号<必填>")
  1115. * @ApiParams (name="param[ext]", type="string", sample="", description="其他<必填>")
  1116. * @ApiParams (name="param[description]", type="string", sample="", description="意见建议<必填>")
  1117. * @ApiParams (name="param[accession_num]", type="string", sample="", description="检查号<必填>")
  1118. * @ApiParams (name="param[pid]", type="string", sample="", description="患者id<必填>")
  1119. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  1120. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  1121. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  1122. * @ApiReturn (data="
  1123. {
  1124. 'status': ok,
  1125. 'code': '0000',
  1126. 'msg': '保存成功',
  1127. }
  1128. *")
  1129. **/
  1130. public function write_info(){
  1131. $sessionid = $_REQUEST['sessionid'];
  1132. /*if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  1133. // 是远程写报告 7
  1134. $return = Verify::check_role($sessionid,7);
  1135. }else{
  1136. // 本地写报告权限 2
  1137. $return = Verify::check_role($sessionid,2);
  1138. }
  1139. if($return != 1){
  1140. return json_encode(['status'=>'fail','code'=>'1029','msg'=>'没有操作权限']);
  1141. }
  1142. $param = $_REQUEST['param'];
  1143. if(isset($_REQUEST['is_remote']) && $_REQUEST['is_remote'] == 1){
  1144. //远程
  1145. $status = DB::table('remote_application')->where('id',$param['rid'])->field('report_status')->find();
  1146. if($status['report_status'] == 12){
  1147. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被撤回,无法进行保存填写']);
  1148. }elseif($status['report_status'] > 6){
  1149. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被保存,无法再次被修改']);
  1150. }
  1151. }else{
  1152. //本地
  1153. $status = DB::table('exams')->where('id',$param['id'])->field('exam_status')->find();
  1154. if($status['exam_status'] > 6){
  1155. return json_encode(['status'=>'fail','code'=>'1034','msg'=>'报告已被保存,无法再次被修改']);
  1156. }
  1157. }*/
  1158. $doctor = Cache::get($sessionid);
  1159. $is_remote = $_REQUEST['is_remote'];
  1160. $patient_info['name'] = isset($param['name']) ? $param['name'] : '';
  1161. $patient_info['sex'] = isset($param['sex']) ? $param['sex'] : '';
  1162. $patient_info['age'] = isset($param['age']) ? $param['age'] : '';
  1163. $exam_info['hopitalized_no'] = isset($param['hospital_number']) ? $param['hospital_number'] : '';
  1164. $exam_info['bed_no'] = isset($param['bed_number']) ? $param['bed_number'] : '';
  1165. $exam_info['ext'] = isset($param['ext']) ? $param['ext'] : '';
  1166. $exam_info['accession_num'] = isset($param['accession_num']) ? $param['accession_num'] : '';
  1167. $report['description'] = isset($param['description']) ? $param['description'] : '';
  1168. $report['report_datetime'] = date('Y-m-d H:i:s',time());
  1169. $report['report_doctor_id'] = $doctor['id'];
  1170. DB::table('patient_infos')->where('id',$param['pid'])->update($patient_info);
  1171. DB::table('exams')->where('id',$param['id'])->update($exam_info);
  1172. $rinfo = DB::table('report')->where('exam_id',$param['id'])->find();
  1173. if($rinfo){
  1174. DB::table('report')->where('exam_id',$param['id'])->update($report);
  1175. $rinfo = DB::table('report')->where('exam_id',$param['id'])->find();
  1176. $rid = $rinfo['id'];
  1177. }else{
  1178. $report['id'] = UUIDs::uuid16();
  1179. $report['exam_id'] = $param['id'];
  1180. $report['createdAt'] = date('Y-m-d H:i:s',time());
  1181. DB::table('report')->insert($report);
  1182. $rid = $report['id'];
  1183. }
  1184. $log = array();
  1185. $log['id'] = UUIDs::uuid16();
  1186. $log['impression'] = isset($param['ext']) ? $param['ext'] : '';
  1187. $log['description'] = isset($param['description']) ? $param['description'] : '';
  1188. $log['report_id'] = $rid;
  1189. $log['createdAt'] = date('Y-m-d H:i:s',time());
  1190. $log['doctor_id'] = $doctor['id'];
  1191. $log['type'] = 1; //写报告
  1192. log::record($log);
  1193. $report_log = DB::table('report_record')->insert($log);
  1194. $application = DB::table('remote_application')->where('exam_id',$param['id'])->find();
  1195. if($application['req_doctor_id'] == 'c44663d6d3c0b535'){
  1196. $tel = '18910184804';
  1197. $type = '保存报告';
  1198. $content = $application['id'];
  1199. // send_message::sendSms2Self($tel,$type,$content);
  1200. }
  1201. if($is_remote == 1){
  1202. DB::table('remote_application')->where('exam_id',$param['id'])->update(['report_status'=>7]);
  1203. }else{
  1204. DB::table('exams')->where('id',$param['id'])->update(['exam_status'=>7]);
  1205. }
  1206. $url = 'http://wechat.pacsonline.cn/wx_patient/api/unifyGetWxQrcode?reportId='.$rid;
  1207. $info = $this->curl_get($url);
  1208. return json_encode(['status'=>'ok','msg'=>'保存成功','code'=>'0000']);
  1209. }
  1210. /**
  1211. * 获取远程报告列表
  1212. *
  1213. * @ApiTitle (获取远程报告列表)
  1214. * @ApiSummary (获取远程报告列表)
  1215. * @ApiSector (远程诊断)
  1216. * @ApiMethod (POST)
  1217. * @ApiRoute (/inter/writereport/get_report_list)
  1218. * @ApiHeaders (name="sign", type="string", required=true, description="请求头-校验key")
  1219. * @ApiHeaders (name="nonce", type="string", required=true, description="请求头-随机数")
  1220. * @ApiHeaders (name="timestamp", type=string, required=true, description="请求头-时间戳s")
  1221. * @ApiParams (name="sessionid", type="string", required=true, description="参数json字符串")
  1222. * @ApiParams (name="param", type="string", required=true, description="参数json字符串")
  1223. * @ApiParams (name="is_remote", type="string", required=true, description="是否为远程列表进入")
  1224. * @ApiParams (name="param[id]", type="string", sample="", description="exams表id值<必填>")
  1225. * @ApiParams (name="param[pid]", type="string", sample="", description="病历号<必填>")
  1226. * @ApiReturnParams (name="status", type="integer", required=true, sample="0", description="返回码 fail 失败 ok成功"))
  1227. * @ApiReturnParams (name="code", type="integer", required=true, sample="0", description="返回状态码")
  1228. * @ApiReturnParams (name="msg", type="string", required=true, sample="返回成功", description="返回消息")
  1229. * @ApiReturn (data="
  1230. {
  1231. 'status': ok,
  1232. 'code': '0000',
  1233. 'info': '',
  1234. }
  1235. *")
  1236. **/
  1237. public function get_report_list(){
  1238. $sessionid = $_REQUEST['sessionid'];
  1239. $doctor = Cache::get($sessionid);
  1240. $param = $_REQUEST['param'];
  1241. $rinfo = DB::table('report')->where('exam_id',$param['id'])->where('type','<>',1)->select();
  1242. $einfo = DB::table('exams')->where('id',$param['id'])->field('exam_class,exam_sub_class,exam_datetime,patient_id')->find();
  1243. $pinfo = DB::table('patient_infos')->where('id',$einfo['patient_id'])->field('name,temp_patient_id,sex,age,phone')->find();
  1244. $info = array();
  1245. $arr = array();
  1246. foreach ($rinfo as $k => $v) {
  1247. $remote_info = DB::table('remote_application')->where('id',$v['remote_application_id'])->find();
  1248. Message::read($doctor['id'],$remote_info['id'],4);
  1249. if($remote_info['report_status'] == 8 || $remote_info['report_status'] == 9){
  1250. $arr = $v;
  1251. $remote_did = DB::table('doctors')->where('id',$v['report_doctor_id'])->field('realname')->find();
  1252. $arr['report_doctor'] = $remote_did['realname'];
  1253. $review_did = DB::table('doctors')->where('id',$v['review_doctor_id'])->field('realname')->find();
  1254. $arr['review_doctor'] = $review_did['realname'];
  1255. $arr['name'] = $pinfo['name'];
  1256. $arr['pid'] = $pinfo['temp_patient_id'];
  1257. $arr['sex'] = $pinfo['sex'];
  1258. $arr['age'] = $pinfo['age'];
  1259. $arr['phone'] = $pinfo['phone'];
  1260. $arr['exam_class'] = $einfo['exam_class'];
  1261. $arr['exam_sub_class'] = $einfo['exam_sub_class'];
  1262. $arr['exam_datetime'] = $einfo['exam_datetime'];
  1263. $arr['report_status'] = $remote_info['report_status'];
  1264. $arr['hospital_name'] = DB::table('institution')->where('id',$remote_info['remote_institution_id'])->value('name');
  1265. $info = $arr;
  1266. }elseif($remote_info['report_status'] == 4){
  1267. //申请中
  1268. return json_encode(['status'=>'fail','code'=>'0125','msg'=>'申请单正在申请中,暂无医生接收远程报告']);
  1269. }elseif($remote_info['report_status'] == 5){
  1270. // 驳回
  1271. return json_encode(['status'=>'fail','code'=>'0125','msg'=>'申请单已被驳回,没有医生完成远程报告']);
  1272. }elseif($remote_info['report_status'] == 12){
  1273. // 撤回
  1274. return json_encode(['status'=>'fail','code'=>'0125','msg'=>'申请单正在申请中,暂无医生完成远程报告']);
  1275. }elseif($remote_info['report_status'] == ''){
  1276. // 撤回
  1277. return json_encode(['status'=>'fail','code'=>'0126','msg'=>'没有申请单']);
  1278. }else{
  1279. // 其他
  1280. return json_encode(['status'=>'fail','code'=>'0125','msg'=>'申请单还没有被完成,请等待']);
  1281. }
  1282. }
  1283. return json_encode(['status'=>'ok','info'=>$info,'code'=>'0000']);
  1284. }
  1285. public function reject_examine()
  1286. {
  1287. $sessionid = $_REQUEST['sessionid'];
  1288. //传值报告id
  1289. $report_id = $_REQUEST['report_id'];
  1290. $reason = $_REQUEST['reason'];
  1291. $is_remote = $_REQUEST['is_remote'];
  1292. $report = DB::table('report')->where('id',$report_id)->field('remote_application_id,exam_id,report_doctor_id')->find();
  1293. $exam = DB::table('exams')->where('id',$report['exam_id'])->value('exam_class');
  1294. if($is_remote == 1){
  1295. //远程
  1296. DB::table('remote_application')->where('id',$report['remote_application_id'])->update(['report_status'=>13]);
  1297. }else{
  1298. // 本地
  1299. DB::table('exams')->where('id',$report['exam_id'])->update(['exam_status'=>13]);
  1300. }
  1301. $url = Message::url($sessionid,$report['exam_id'],0,$exam,$report_id,$report['remote_application_id']);
  1302. $t = '您的报告在审核步骤已被驳回';
  1303. $c = '您保存的报告在审核步骤已被驳回,驳回的原因是:'.$reason.',请您重新更改您的报告';
  1304. $d = $report['report_doctor_id'];
  1305. $type = '8';
  1306. Message::insert($t,$c,$d,$type,$url,1,$report['remote_application_id']);
  1307. return json_encode(['status'=>'ok','msg'=>'审核已驳回','code'=>'0000']);
  1308. }
  1309. }