WasteRecord.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911
  1. <?php
  2. namespace app\common\model;
  3. use function PHPSTORM_META\map;
  4. use think\Db;
  5. use think\Exception;
  6. class WasteRecord extends Base {
  7. public $table = 'waste_record';
  8. protected $validateName = 'WasteRecord';
  9. public $status = [
  10. '已收取',
  11. '已交接',
  12. '已转运',
  13. '医废异常',
  14. '未转运',
  15. ];
  16. /**
  17. * 医废记录详情
  18. *
  19. * @author wst
  20. * @date 2021/9/8 17:32
  21. * @return array
  22. */
  23. public function info($id,$orgId){
  24. $info = $this->getOne($id,$orgId);
  25. if($info){
  26. $info['real_name'] = Db::name('user')
  27. ->where('id',$info['user_id'])
  28. ->value('real_name');
  29. $info['waste_device'] = Db::name('address')
  30. ->where('id',$info['waste_device_id'])
  31. ->value('title');
  32. $info['cate'] = Db::name('waste_type')
  33. ->where('id',$info['cateid'])
  34. ->value('title');
  35. $info['weight'] =round($info['weight']/1000,2);
  36. $info['status'] =$this->status[$info['status']];
  37. $rlist = Db::name('waste_record_user')
  38. ->alias('waste_record_user')
  39. ->join('user user','user.id = waste_record_user.user_id')
  40. ->where('waste_record_user.waste_record_id',$info['id'])
  41. ->field('waste_record_user.*,user.real_name')
  42. ->order('status', 'asc')
  43. ->select();
  44. $info['rlist'] = $rlist?$rlist:array();
  45. $info = json_decode(json_encode($info),true);
  46. }
  47. return $info;
  48. }
  49. //转运
  50. public function finish($id,$user_id){
  51. $this->startTrans();
  52. try{
  53. $ret = $this
  54. ->where('id', $id)
  55. ->update(['status'=>2]);
  56. if(!$ret){
  57. throw new Exception('更新状态失败');
  58. }
  59. $ret2 = Db::name('waste_record_user')->insert(array(
  60. 'waste_record_id' => $id,
  61. 'user_id' => $user_id,
  62. 'status' => 2,
  63. 'create_time' => getTime()
  64. ));
  65. if(!$ret2){
  66. throw new exception('保存操作记录失败');
  67. }
  68. $this->commit();
  69. return true;
  70. }catch (exception $e){
  71. $this->rollback();
  72. $this->error=$e->getMessage();
  73. return false;
  74. }
  75. }
  76. public function getOne($id,$orgId=0){
  77. $info = $this
  78. ->where('id',$id)
  79. ->where('org_id',$orgId)
  80. ->whereOr('serial_number',$id)
  81. ->find()
  82. ->toArray();
  83. return $info;
  84. }
  85. /*----------------api----------------*/
  86. public function recordInfo($serialNum,$orgId){
  87. $map[] = ['serial_number','=',$serialNum];
  88. $map[] = ['org_id','=',$orgId];
  89. $map[] = ['del','=',0];
  90. $info = $this->field('id,serial_number,org_id,waste_device_id,user_id,cateid,weight,status,create_time,reason,is_print,weight2')
  91. ->where($map)->find();
  92. $info = $info?$info->toArray():[];
  93. if(!$info){
  94. $this->error = '记录不存在';
  95. return false;
  96. }
  97. $org = Db::name('org')
  98. ->where('id',$info['org_id'])
  99. ->field('name')->find();
  100. $info['org_name'] = $org?$org['name']:'';
  101. $user = Db::name('user')
  102. ->where('id',$info['user_id'])
  103. ->field('real_name')->find();
  104. $info['real_name'] = $user?$user['real_name']:'';
  105. $wasteDevice = Db::name('address')
  106. ->where('id',$info['waste_device_id'])
  107. ->field('title')
  108. ->find();
  109. $info['title'] = $wasteDevice?$wasteDevice['title']:'';
  110. $info['cate_id'] = $info['cateid'];
  111. $info['cate_name'] =Db::name('waste_type')
  112. ->where('id',$info['cateid'])->value('title');
  113. unset($info['cateid']);
  114. $lists = Db::name('waste_record_user')
  115. ->alias('wru')
  116. ->where('wru.waste_record_id',$info['id'])
  117. ->join('user u','u.id = wru.user_id')
  118. ->field('u.real_name,wru.status,wru.create_time')
  119. ->order('wru.id asc')
  120. ->select();
  121. $data = [
  122. 'type' => 1, // 1=医废记录详情 2=医废包详情
  123. 'info' => $info,
  124. 'status_list' => $lists?$lists:[]
  125. ];
  126. return $data;
  127. }
  128. public function queryIsPrint($id){
  129. $ret=$this
  130. ->where('id',$id)
  131. ->field('is_print')
  132. ->find()->toArray();
  133. return $ret;
  134. }
  135. public function wasteRecordList($orgId,$status,$createTime,$page,$size){
  136. $offset= ($page - 1) * $size;
  137. $starttime=$createTime.' 00:00:00';
  138. $endtime=$createTime.' 23:59:59';
  139. $where[] = ['create_time','between',[$starttime,$endtime]];
  140. $list=$this
  141. ->field('waste_device_id,cateid,create_time,is_print,serial_number,id,weight')
  142. ->where([
  143. 'org_id'=>$orgId,
  144. 'status'=>$status,
  145. 'del'=>0,
  146. ])
  147. ->where($where)
  148. ->order('id desc')
  149. ->limit($offset,$size)
  150. ->select()->toArray();
  151. $ret['list']=$list;
  152. foreach ($list as $k=>$v){
  153. $title=Db::name('address')
  154. ->where([
  155. 'id'=>$v['waste_device_id'],
  156. 'del'=>0,
  157. 'enable'=>1,
  158. ])->value('title');
  159. $ret['list'][$k]['title']= $title;
  160. $cate = Db::name('waste_type')
  161. ->where('id',$v['cateid'])
  162. ->value('title');
  163. $ret['list'][$k]['cate_title']= $cate;
  164. }
  165. return $ret;
  166. }
  167. public function unTransportList($orgId,$createTime){
  168. $where = [];
  169. if($createTime){
  170. $starttime=$createTime.' 00:00:00';
  171. $endtime=$createTime.' 23:59:59';
  172. $where[] = ['create_time','between',[$starttime,$endtime]];
  173. }
  174. $list=$this
  175. ->field('waste_device_id,cateid,create_time,is_print,serial_number,id,weight')
  176. ->where('org_id',$orgId)
  177. ->where('del',0)
  178. ->where($where)
  179. ->where('status','in',[0,1])
  180. ->order('id','desc')
  181. ->select()
  182. ->toArray();
  183. $ret['list']=$list;
  184. foreach ($list as $k=>$v){
  185. $title=Db::name('address')
  186. ->where([
  187. 'id'=>$v['waste_device_id'],
  188. 'del'=>0,
  189. 'enable'=>1,
  190. ])->value('title');
  191. $ret['list'][$k]['title']= $title;
  192. $cate =Db::name('waste_type')
  193. ->where('id',$v['cateid'])
  194. ->value('title');;
  195. $ret['list'][$k]['cate_title']= $cate;
  196. }
  197. return $ret;
  198. }
  199. public function saveRecord($data){
  200. $curtime = getTime();
  201. $data['serial_number'] = get_unique_id();
  202. $data['create_time'] = $curtime;
  203. $data['create_yyyy'] = date('Y');
  204. $data['create_yyyymm'] = date('Ym');
  205. $data['create_yyyymmdd'] = date('Ymd');
  206. $this->startTrans();
  207. try{
  208. $waste_record_id = $this->insertGetId($data);
  209. if (!$waste_record_id) {
  210. throw new Exception('保存记录失败');
  211. }
  212. $sdata = [
  213. 'status' => 0,
  214. 'create_time' => $curtime,
  215. 'user_id' => $data['user_id'],
  216. 'waste_record_id' => $waste_record_id,
  217. ];
  218. $res = Db::name('waste_record_user')->insert( $sdata);
  219. if (!$res) {
  220. throw new Exception('保存操作记录失败');
  221. }
  222. $this->commit();
  223. return $waste_record_id;
  224. }catch (Exception $e){
  225. $this->error = $e->getMessage();
  226. $this->rollback();
  227. return false;
  228. }
  229. }
  230. public function saveStatus($data){
  231. $info = $this->
  232. where('serial_number',$data['serialNumber'])
  233. ->find();
  234. if(!$info){
  235. $this->error = '记录不存在';
  236. return false;
  237. }
  238. $curTime = date('Y-m-d H:i:s');
  239. $this->startTrans();
  240. try{
  241. $rdata = [
  242. 'weight2' => isset($data['weight2'])?$data['weight2']:0,
  243. 'status' => $data['status'],
  244. 'reason' => isset($data['reason'])?$data['reason']:'',
  245. 'package_id' => 0 // 有任何变化,都删除与包的关系
  246. ];
  247. $ret = $this
  248. ->where('id',$info['id'])
  249. ->update( $rdata);
  250. if (!$ret) {
  251. \exception('操作失败1');
  252. }
  253. $sdata = [
  254. 'status' => $data['status'],
  255. 'create_time' => $curTime,
  256. 'user_id' => $data['userId'],
  257. 'waste_record_id' => $info['id'],
  258. ];
  259. $res = Db::name('waste_record_user')
  260. ->insert($sdata);
  261. if (!$res) {
  262. \exception('操作失败');
  263. }
  264. // 如果在保内,检查包内是否还有可以记录,没有则删除包记录
  265. if($info['package_id'] > 0){
  266. $count = $this
  267. ->where('package_id',$info['package_id'])
  268. ->where('id','<>',$info['id'])
  269. ->count();
  270. if($count == 0){
  271. $res = Db::name('waste_package')->
  272. where('id',$info['package_id'])
  273. ->update(['del' => 1]);
  274. if (!$res) {
  275. \exception('操作失败');
  276. }
  277. }
  278. }
  279. $this->commit();
  280. }catch (Exception $e){
  281. $this->error = '操作失败'.$e->getMessage();
  282. $this->rollback();
  283. return false;
  284. }
  285. return true;
  286. }
  287. public function lists($orgId,$depId,$date,$page,$size,$userId){
  288. $offset= ($page - 1) * $size;
  289. $map[]= ['wr.org_id','=',$orgId];
  290. $map[]= ['wr.sign','=',0];
  291. $map[]= ['wr.del','=',0];
  292. $map1[]= ['wr.user_id','=',$userId];
  293. if($depId){
  294. $map1[]= ['wd.dep_id','=',$depId];
  295. }
  296. if($date){
  297. $date = date('Ymd',strtotime($date));
  298. $map[]= ['wr.create_yyyymmdd','=',$date];
  299. }
  300. $list = $this
  301. ->alias('wr')
  302. ->join('address wd','wd.id = wr.waste_device_id')
  303. ->where(function ($query) use ($map1) {
  304. $query->whereOr($map1);
  305. })->where($map)->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
  306. ->order('wr.id','desc')
  307. ->limit($offset,$size)->select();
  308. $list = $list?$list->toArray():[];
  309. foreach ($list as $k=>$v){
  310. $title=Db::name('address')
  311. ->where('id',$v['waste_device_id'])
  312. ->value('title');
  313. $list[$k]['waste_device_name'] = $title;
  314. $cate = Db::name('waste_type')->
  315. where('id',$v['cateid'])->value('title');
  316. $list[$k]['cate_title']= $cate?$cate:'';
  317. }
  318. $ret['list']=$list?$list:[];
  319. return $ret;
  320. }
  321. public function savePackage($post){
  322. $curTime =getTime();
  323. $data = [
  324. 'org_id' => $post['org_id'],
  325. 'user_id' => $post['user_id'],
  326. 'ids' => $post['ids'],
  327. 'create_time' => $curTime,
  328. ];
  329. // 检查是否符合要求
  330. $count = Db::name('waste_record')
  331. ->where('del',0)
  332. ->where('status',0)
  333. ->where('package_id',0)
  334. ->where('user_id',$data['user_id'])
  335. ->where('id','in',$data['ids'])
  336. ->count();
  337. if($count != count($data['ids'])){
  338. $this->error = '有不符合要求的医废记录';
  339. return false;
  340. }
  341. $this->startTrans();
  342. try{
  343. $pData = [
  344. 'org_id' => $post['org_id'],
  345. 'user_id' => $post['user_id'],
  346. 'record' => implode(',',$post['ids']),
  347. 'create_time' => $curTime,
  348. 'sn' => get_unique_id2()
  349. ];
  350. $id= Db::name('waste_package')
  351. ->insertGetId($pData);
  352. if (!$id) {
  353. exception('操作失败');
  354. }
  355. $sData = [
  356. 'package_id' => $id,
  357. ];
  358. $res = $this->where('id','in',$data['ids'])
  359. ->update( $sData);
  360. if (!$res) {
  361. exception('操作失败');
  362. }
  363. $this->commit();
  364. }catch (Exception $e){
  365. $this->error = $e->getMessage();
  366. $this->rollback();
  367. return false;
  368. }
  369. return $id;
  370. }
  371. public function packInfo($serialNum,$orgId){
  372. $map[] = ['sn','=',$serialNum];
  373. $map[] = ['org_id','=',$orgId];
  374. $map[] = ['del','=',0];
  375. $info = Db::name('waste_package')
  376. ->where($map)
  377. ->field('id,sn,org_id,user_id,status,create_time,jj_time,zy_time,jj_user_id,zy_user_id')
  378. ->find();
  379. if(!$info){
  380. $this->error = '记录不存在';
  381. return false;
  382. }
  383. $org = Db::name('org')
  384. ->where('id',$info['org_id'])
  385. ->field('name')->find();
  386. $info['org_name'] = $org?$org['name']:'';
  387. $user = Db::name('user')
  388. ->where('id',$info['user_id'])
  389. ->field('real_name')->find();
  390. $info['real_name'] = $user?$user['real_name']:'';
  391. $info['jj_time'] = $info['jj_time']?$info['jj_time']:'';
  392. $info['zy_time'] = $info['zy_time']?$info['zy_time']:'';
  393. if($info['jj_user_id'] > 0){
  394. $user = Db::name('user')
  395. ->where('id',$info['jj_user_id'])
  396. ->field('real_name')->find();
  397. $info['jj_real_name'] = $user?$user['real_name']:'';
  398. }
  399. if($info['zy_user_id'] > 0){
  400. $user = Db::name('user')
  401. ->where('id',$info['zy_user_id'])
  402. ->field('real_name')->find();
  403. $info['zy_real_name'] = $user?$user['real_name']:'';
  404. }
  405. $weight =$this
  406. ->where('package_id',$info['id'])
  407. ->sum('weight');
  408. $info['weight'] = $weight?round($weight/1000,2):0;
  409. $count = $this->where('package_id',$info['id'])
  410. ->count();
  411. $info['count'] = $count?$count:0;
  412. $record = Db::name('waste_record')
  413. ->alias('wr')
  414. ->where('wr.del',0)
  415. ->where('wr.package_id',$info['id'])
  416. ->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
  417. ->order('wr.id desc')
  418. ->select();
  419. foreach ($record as $k=>$v){
  420. $title=Db::name('address')
  421. ->field('title')
  422. ->where('id',$v['waste_device_id'])
  423. ->find();
  424. $record[$k]['title'] = $title?$title['title']:'';
  425. $record[$k]['cate_name'] =Db::name('waste_type')
  426. ->where('id',$v['cateid'])->value('title');
  427. // $record[$k]['weight'] = $v['weight']?round($v['weight']/1000,2):0;
  428. $record[$k]['weight'] = $v['weight']?$v['weight']:0;
  429. }
  430. $data = [
  431. 'type' => 2,
  432. 'pinfo' => $info,
  433. 'record' => $record?$record:[]
  434. ];
  435. return $data;
  436. }
  437. public function packagesLists($orgId,$page,$size,$userId){
  438. $offset= ($page - 1) * $size;
  439. $map[] = ['org_id','=',$orgId];
  440. $map[] = ['user_id','=',$userId];
  441. $map[] = ['del','=',0];
  442. $list = Db::name('waste_package')
  443. ->field('id,sn,org_id,user_id,status,create_time')
  444. ->order('id desc')
  445. ->where($map)
  446. ->limit($offset,$size)
  447. ->select();
  448. foreach ($list as $k=>$v){
  449. $user = Db::name('user')
  450. ->where('id',$v['user_id'])
  451. ->field('real_name')
  452. ->find();
  453. $list[$k]['real_name'] = $user?$user['real_name']:'';
  454. $weight = $this->where('package_id',$v['id'])
  455. ->sum('weight');
  456. $list[$k]['weight'] = $weight?$weight:0;
  457. $count = $this->where('package_id',$v['id'])
  458. ->count();
  459. $list[$k]['count'] = $count?$count:0;
  460. }
  461. return $list?$list:[];
  462. }
  463. public function delpackage($orgId,$userId,$id,$recordId){
  464. $info = $this
  465. ->where('del',0)
  466. ->where('org_id',$orgId)
  467. ->where('package_id',$id)
  468. ->where('id',$recordId)
  469. ->find();
  470. if(!$info){
  471. $this->error = '记录不存在';
  472. return false;
  473. }
  474. $this->startTrans();
  475. try{
  476. $res = $this->where('id',$recordId)
  477. ->update(['package_id' => 0]);
  478. if (!$res) {
  479. exception('操作失败');
  480. }
  481. // 如果在保内,检查包内是否还有可以记录,没有则删除包记录
  482. if($info['package_id'] > 0){
  483. $count = $this
  484. ->where('package_id',$id)
  485. ->where('id','<>',$recordId)
  486. ->count();
  487. if($count == 0){
  488. $res = Db::name('waste_package')
  489. ->where('id',$id)
  490. ->update(['del' => 1]);
  491. if (!$res) {
  492. exception('操作失败');
  493. }
  494. }
  495. }
  496. $this->commit();
  497. return true;
  498. }catch (Exception $e){
  499. $this->error = '操作失败'.$e->getmessage();
  500. $this->rollback();
  501. return false;
  502. }
  503. }
  504. // 交接
  505. public function jjpackage($orgId,$userId,$id){
  506. $info = Db::name('waste_package')
  507. ->where('del',0)
  508. ->where('org_id',$orgId)
  509. ->where('id',$id)
  510. ->find();
  511. if(!$info){
  512. $this->error = '记录不存在';
  513. return false;
  514. }
  515. if($info['status'] != 0){
  516. $this->error = '无权限操作';
  517. return false;
  518. }
  519. $lists = $this
  520. ->where('package_id',$id)
  521. ->where('del',0)
  522. ->select();
  523. $lists = $lists?$lists->toArray():[];
  524. if(count($lists) == 0){
  525. $this->error = '无可操作的医废记录';
  526. return false;
  527. }
  528. $ids = [];
  529. foreach ($lists as $k=>$v){
  530. $ids[] = $v['id'];
  531. }
  532. $this->startTrans();
  533. try{
  534. $rData = [
  535. 'jj_time' => getTime(),
  536. 'status' => 1,
  537. 'jj_user_id' => $userId,
  538. 'jj_record' => implode(',',$ids)
  539. ];
  540. $ret = Db::name('waste_package')
  541. ->where('id',$id)
  542. ->update($rData);
  543. if (!$ret) {
  544. exception('操作失败1');
  545. }
  546. foreach ($lists as $k=>$v){
  547. $rrData = [
  548. 'weight2' => 0,
  549. 'status' => 1,
  550. 'reason' => '',
  551. ];
  552. $ret = $this
  553. ->where('id',$v['id'])
  554. ->update($rrData);
  555. if (!$ret) {
  556. exception('操作失败');
  557. }
  558. $sData = [
  559. 'status' => 1,
  560. 'create_time' => getTime(),
  561. 'user_id' => $userId,
  562. 'waste_record_id' => $v['id'],
  563. ];
  564. $res = Db::name('waste_record_user')
  565. ->insert($sData);
  566. if (!$res) {
  567. exception('操作失败');
  568. }
  569. }
  570. $this->commit();
  571. return true;
  572. }catch (Exception $e){
  573. $this->error = '操作失败'.$e->getmessage();
  574. $this->rollback();
  575. return false;
  576. }
  577. }
  578. // 转运
  579. public function zypackage($orgId,$userId,$id){
  580. $info = Db::name('waste_package')
  581. ->where('del',0)
  582. ->where('org_id',$orgId)
  583. ->where('id',$id)
  584. ->find();
  585. if(!$info){
  586. $this->error = '记录不存在';
  587. return false;
  588. }
  589. if($info['status'] != 1){
  590. $this->error = '无权限操作';
  591. return false;
  592. }
  593. $lists = $this
  594. ->where('package_id',$id)
  595. ->where('del',0)
  596. ->select();
  597. $lists = $lists?$lists->toArray():[];
  598. if(count($lists) == 0){
  599. $this->error = '无可操作的医废记录';
  600. return false;
  601. }
  602. $ids = [];
  603. foreach ($lists as $k=>$v){
  604. $ids[] = $v['id'];
  605. }
  606. $this->startTrans();
  607. try{
  608. $rData = [
  609. 'zy_time' => date('Y-m-d H:i:s'),
  610. 'status' => 2,
  611. 'zy_user_id' => $userId,
  612. 'zy_record' => implode(',',$ids)
  613. ];
  614. $ret = Db::name('waste_package')
  615. ->where('id',$id)
  616. ->update($rData);
  617. if (!$ret) {
  618. throw new exception('操作失败');
  619. }
  620. foreach ($lists as $k=>$v){
  621. $rrdata = [
  622. 'weight2' => 0,
  623. 'status' => 2,
  624. 'reason' => '',
  625. ];
  626. $ret = $this
  627. ->where('id',$v['id'])
  628. ->update($rrdata);
  629. if (!$ret) {
  630. exception('操作失败');
  631. }
  632. $sdata = [
  633. 'status' => 2,
  634. 'create_time' => getTime(),
  635. 'user_id' => $userId,
  636. 'waste_record_id' => $v['id'],
  637. ];
  638. $res = Db::name('waste_record_user')
  639. ->insert($sdata);
  640. if (!$res) {
  641. exception('操作失败');
  642. }
  643. }
  644. $this->commit();
  645. return true;
  646. }catch (Exception $e){
  647. $this->error = '操作失败'.$e->getmessage();
  648. $this->rollback();
  649. return false;
  650. }
  651. }
  652. public function yflist($orgId,$userId){
  653. $map[] = ['wr.org_id','=',$orgId];
  654. $map[] = ['wr.user_id','=',$userId];
  655. $map[] = ['wr.package_id','=',0];
  656. $map[] = ['wr.del','=',0];
  657. $map[] = ['wr.status','=',0];
  658. $list=$this->alias('wr')
  659. ->where($map)
  660. ->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
  661. ->order('wr.id desc')
  662. ->select();
  663. $list = $list?$list->toArray():[];
  664. foreach ($list as $k=>$v){
  665. $title=Db::name('address')
  666. ->field('title')
  667. ->where('id',$v['waste_device_id'])
  668. ->find();
  669. $list[$k]['title'] = $title?$title['title']:'';
  670. $list[$k]['cate_name'] =Db::name('waste_type')
  671. ->where('id',$v['cateid'])->value('title');
  672. }
  673. return $list?$list:[];
  674. }
  675. public function printList($orgId,$userId){
  676. $title = input('title','');
  677. if($title!=''){
  678. $type = 7;
  679. $map1[]=['','exp',Db::raw("FIND_IN_SET($type,types)")];
  680. $address = Db::name('address')
  681. ->where('del',0)
  682. ->where('enable',1)
  683. ->where('org_id',$orgId)
  684. ->where('title','like','%'.$title.'%')
  685. ->where($map1)
  686. ->column('id');
  687. if($address){
  688. $map[] = ['wr.waste_device_id','in',$address];
  689. }else{
  690. $map[] = ['wr.waste_device_id','=',-1];
  691. }
  692. }
  693. $map[] = ['wr.org_id','=',$orgId];
  694. $map[] = ['wr.user_id','=',$userId];
  695. $map[] = ['wr.del','=',0];
  696. $map[] = ['wr.status','=',0];
  697. $map[] = ['wr.create_yyyymmdd','=',date('Ymd')];
  698. $list=$this->alias('wr')
  699. ->where($map)
  700. ->field('wr.waste_device_id,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
  701. ->order('wr.id desc')
  702. ->limit(1000)
  703. ->select();
  704. $list = $list?$list->toArray():[];
  705. foreach ($list as $k=>$v){
  706. $title=Db::name('address')
  707. ->field('title')
  708. ->where('id',$v['waste_device_id'])
  709. ->find();
  710. $list[$k]['title'] = $title?$title['title']:'';
  711. $list[$k]['cate_name'] =Db::name('waste_type')
  712. ->where('id',$v['cateid'])->value('title');
  713. }
  714. return $list?$list:[];
  715. }
  716. public function recordLists($orgId,$wasteDeviceId,$start,$end,$page,$size,$userId){
  717. $offset= ($page - 1) * $size;
  718. $map[] = ['wr.org_id','=',$orgId];
  719. $map[] = ['wr.del','=',0];
  720. if($wasteDeviceId>0){
  721. $map[] = ['wr.waste_device_id','=',$wasteDeviceId];
  722. }
  723. if($start){
  724. $date = date('Ymd',strtotime($start));
  725. $map[] = ['wr.create_yyyymmdd','>=',$date];
  726. }
  727. if($end){
  728. $date = date('Ymd',strtotime($end));
  729. $map[] = ['wr.create_yyyymmdd','<=',$date];
  730. }
  731. $list=db('waste_record')
  732. ->alias('wr')
  733. ->field('wr.waste_device_id,wr.status,wr.cateid,wr.create_time,wr.is_print,wr.serial_number,wr.id,wr.weight,wr.sign')
  734. ->order('wr.id','desc')
  735. ->where($map)
  736. ->limit($offset,$size)
  737. ->select();
  738. foreach ($list as $k=>$v){
  739. $title=db('address')
  740. ->field('title')
  741. ->where('id',$v['waste_device_id'])
  742. ->find();
  743. $list[$k]['title'] = $title?$title['title']:'';
  744. $list[$k]['cate_title'] = $this->getTableField('waste_type',['id'=>$v['cateid']],'title');
  745. }
  746. $ret=$list?$list:[];
  747. return $ret;
  748. }
  749. public function getByDepDayList($wasteDeviceId,$orgId){
  750. $typeList = model('WasteType')->getList();
  751. $str ='';
  752. foreach ($typeList as $k=>$v){
  753. $sum = Db::name('waste_record')
  754. ->where('create_yyyymmdd',date('Ymd'))
  755. ->where('org_id',$orgId)
  756. ->where('waste_device_id',$wasteDeviceId)
  757. ->where('cateid',$v['id'])
  758. ->where('del',0)
  759. ->sum('weight');
  760. if($sum >0){
  761. $count = ($sum/1000).'kg';
  762. $str.=$v['title'].':'.$count.';';
  763. }
  764. }
  765. if($str!=''){
  766. $s = explode(';',$str);
  767. unset($s[count($s)-1]);
  768. $str = implode(';',$s);
  769. }
  770. return $str;
  771. }
  772. public function print($ids,$orgId,$userId){
  773. $waste_device_id = [];
  774. $id = explode(',',$ids);
  775. $total = 0;
  776. $cate = [];
  777. foreach ($id as $k=>$v){
  778. $info = Db::name('waste_record')
  779. ->where('id',$v)
  780. ->find();
  781. if(empty($info)){
  782. $this->error='记录id'.$v.'不存在';
  783. return false;
  784. }
  785. if($info['user_id']!=$userId){
  786. $this->error='记录id'.$v.'收取人不是自己';
  787. return false;
  788. }
  789. $cateInfo = Db::name('waste_type')
  790. ->where('id',$info['cateid'])
  791. ->find();
  792. $cate[] = [
  793. 'id'=>$info['cateid'],
  794. 'title'=>$cateInfo['title'],
  795. 'num'=>$info['weight'],
  796. 'count'=>1,
  797. ];
  798. $total+=$info['weight'];
  799. $waste_device_id[] = $info['waste_device_id'];
  800. }
  801. $aa = [];
  802. foreach ($cate as $k=>$v){
  803. if(isset($aa[$v['id']])){
  804. $aa[$v['id']]['num'] = $aa[$v['id']]['num']+$v['num'];
  805. $aa[$v['id']]['count'] = $aa[$v['id']]['count']+1;
  806. }else{
  807. $aa[$v['id']] = $v;
  808. }
  809. }
  810. $ab = [];
  811. foreach ($aa as $k=>$v){
  812. $kg = sprintf("%.2f",$v['num']/1000);
  813. $ab[]=$v['title'].':'.$v['count'].' '.$kg.'kg';
  814. }
  815. if(count(array_unique($waste_device_id)) >1){
  816. $this->error='只能打印同一个科室下的记录';
  817. return false;
  818. }
  819. $address = Db::name('address')
  820. ->where('id',$waste_device_id[0])
  821. ->find();
  822. if(empty($address['user'])){
  823. $this->error='当前科室未绑定负责人';
  824. return false;
  825. }
  826. $amount = $total>0?sprintf("%.2f",$total/1000):"0";
  827. $total_desc = $amount.'kg,'.count($id).'袋';
  828. $a = [
  829. 'org_id'=>$orgId,
  830. 'waste_record_id'=>$ids,
  831. 'address'=>$address['title'],
  832. 'address_user'=>$address['user'],
  833. 'create_time'=>getTime(),
  834. 'total'=>$total_desc,
  835. 'user_id'=>$userId,
  836. 'desc'=>implode(',',$ab),
  837. ];
  838. $r = Db::name('waste_print_log')
  839. ->insertGetId($a);
  840. $a['org_name'] = Db::name('org')
  841. ->where('id',$a['org_id'])
  842. ->value('name');
  843. $a['user_name'] = Db::name('user')
  844. ->where('id',$userId)
  845. ->value('real_name');
  846. unset($a['user_id']);
  847. return $a;
  848. }
  849. }