Entrust.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366
  1. <?php
  2. namespace app\admin\controller;
  3. use app\common\controller\Backend;
  4. use \think\Session;
  5. use \think\Db;
  6. /**
  7. * 委托管理管理
  8. *
  9. * @icon fa fa-circle-o
  10. */
  11. class Entrust extends Backend
  12. {
  13. /**
  14. * Entrust模型对象
  15. * @var \app\admin\model\Entrust
  16. */
  17. protected $model = null;
  18. protected $searchFields = 'no,name,bach,sell_bach,company';
  19. public function _initialize()
  20. {
  21. parent::_initialize();
  22. $this->model = new \app\admin\model\Entrust;
  23. $this->view->assign("statusList", $this->model->getStatusList());
  24. }
  25. /**
  26. * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法
  27. * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑
  28. * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改
  29. */
  30. /**
  31. * 添加
  32. *
  33. * @return string
  34. * @throws \think\Exception
  35. */
  36. public function add()
  37. {
  38. if (false === $this->request->isPost()) {
  39. return $this->view->fetch();
  40. }
  41. $params = $this->request->post('row/a');
  42. if (empty($params)) {
  43. $this->error(__('Parameter %s can not be empty', ''));
  44. }
  45. $params['name'] = preg_replace('/\s+/','',$params['name']);//去掉所有空格
  46. $params['user_id'] = Session::get('admin')['id'];
  47. $params['user_name'] = Session::get('admin')['username'];
  48. $params = $this->preExcludeFields($params);
  49. if ($params['is_two'] == 1){//双样
  50. for ($i=0;$i<2;$i++){
  51. $data[$i] = $params;
  52. $data[$i]['sample_no'] = $params['sample_no'].'-'.($i+1);
  53. }
  54. }else{//单样
  55. $data = $params;
  56. }
  57. $result = false;
  58. Db::startTrans();
  59. try {
  60. //是否采用模型验证
  61. if ($this->modelValidate) {
  62. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  63. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.add' : $name) : $this->modelValidate;
  64. $this->model->validateFailException()->validate($validate);
  65. }
  66. $result = $this->model->saveAll($data);
  67. Db::commit();
  68. } catch (ValidateException|PDOException|Exception $e) {
  69. Db::rollback();
  70. $this->error($e->getMessage());
  71. }
  72. if ($result === false) {
  73. $this->error(__('No rows were inserted'));
  74. }
  75. $this->success();
  76. }
  77. /**
  78. * 编辑
  79. *
  80. * @param $ids
  81. * @return string
  82. * @throws DbException
  83. * @throws \think\Exception
  84. */
  85. public function edit($ids = null)
  86. {
  87. $row = $this->model->get($ids);
  88. if (!$row) {
  89. $this->error(__('No Results were found'));
  90. }
  91. $adminIds = $this->getDataLimitAdminIds();
  92. if (is_array($adminIds) && !in_array($row[$this->dataLimitField], $adminIds)) {
  93. $this->error(__('You have no permission'));
  94. }
  95. if (false === $this->request->isPost()) {
  96. $company = ['美浓','翌星','亚新','涂料','其他'];
  97. $this->view->assign('row', $row);
  98. $this->view->assign('company', $company);
  99. return $this->view->fetch();
  100. }
  101. $params = $this->request->post('row/a');
  102. if (empty($params)) {
  103. $this->error(__('Parameter %s can not be empty', ''));
  104. }
  105. $params = $this->preExcludeFields($params);
  106. $result = false;
  107. Db::startTrans();
  108. try {
  109. //是否采用模型验证
  110. if ($this->modelValidate) {
  111. $name = str_replace("\\model\\", "\\validate\\", get_class($this->model));
  112. $validate = is_bool($this->modelValidate) ? ($this->modelSceneValidate ? $name . '.edit' : $name) : $this->modelValidate;
  113. $row->validateFailException()->validate($validate);
  114. }
  115. $result = $row->allowField(true)->save($params);
  116. Db::commit();
  117. } catch (ValidateException|PDOException|Exception $e) {
  118. Db::rollback();
  119. $this->error($e->getMessage());
  120. }
  121. if (false === $result) {
  122. $this->error(__('No rows were updated'));
  123. }
  124. $this->success();
  125. }
  126. //提交到检测
  127. public function submit(){
  128. if (false === $this->request->isPost()) {
  129. $id = input('id');
  130. $judgeData = Db::name('item_judge')->column('id,name');
  131. $this->view->assign('judgeData', $judgeData);
  132. $this->view->assign('id', $id);
  133. return $this->view->fetch();
  134. }
  135. $id = input('id');//委托单id
  136. $temp_id = input('temp');//判定标准id
  137. if (empty($id) || empty($temp_id)){
  138. $this->error('参数错误');
  139. }
  140. /***
  141. * 提交后,更新此数据的 判定标准、委托状态
  142. * 根据数据文件名称绑定检测数据
  143. * 生成检测结果
  144. */
  145. $entrust = Db::name('entrust')->where('id',$id)->find();
  146. /***
  147. * 无法确认是哪台机器(GC、GCMS)检测
  148. * 1、先去找gcms表 没有查到数据 再找gc表
  149. */
  150. $data_txt = $entrust['sample_no'].'MS.D'; //如果是GCMS机台,数据文件为委托编号+MS.D
  151. $gather_gcms = Db::name('gather_txt_gcms')->where('data_txt_name',$data_txt)->find();
  152. if (empty($gather_gcms)){
  153. $data_txt_gc = $entrust['sample_no'].'.D';
  154. $gather_gc = Db::name('gather_txt_gc')->where('data_txt_name',$data_txt_gc)->find();
  155. if (empty($gather_gc)){
  156. $this->error('未获取到检测数据');
  157. }
  158. $gather = $gather_gc;
  159. $gather_tab = 'gather_txt_check_gc';
  160. }else{
  161. $gather = $gather_gcms;
  162. $gather_tab = 'gather_txt_check_gcms';
  163. }
  164. $detail_data = Db::name($gather_tab)->where('pid',$gather['id'])->field('chemical_compound,potency')->select();
  165. $is_qualified = 1;//默认合格,当有一项不合格时,判定此次检测不合格
  166. $dis= 0;//溶剂残留总量
  167. $dis_impurity_data = [];//溶剂杂质总量
  168. $ben_total_data = [];//苯系物总量
  169. $ben = 0; //苯含量
  170. $all_dis_data = []; //所有杂质含量数组
  171. $ethanol = 0; //乙醇含量
  172. $dis_impurity_arr = ['甲醇','丙酮','正丁醇','苯','2-乙氧基乙醇','4-甲基-2-戊酮','甲苯','乙酸正丁酯','乙苯','间对二甲苯','邻-二甲苯','苯乙烯','2-乙氧基乙基乙酸酯','环己酮'];
  173. $ben_arr = ['甲苯','乙苯','间对二甲苯','邻-二甲苯'];
  174. foreach ($detail_data as $key=>$value){
  175. $all_dis_data[$key] = $value['potency'];
  176. if ($value['chemical_compound'] == '乙醇'){//乙醇含量
  177. $ethanol = $value['potency'];
  178. }
  179. if ($value['chemical_compound'] == '苯'){//苯含量
  180. $ben = $value['potency'];
  181. }
  182. if (in_array($value['chemical_compound'],$dis_impurity_arr)){//溶剂杂质总量
  183. $dis_impurity_data[$value['chemical_compound']] = $value['potency'];
  184. }
  185. if (in_array($value['chemical_compound'],$ben_arr)){//苯系物总量
  186. $ben_total_data[$value['chemical_compound']] = $value['potency'];
  187. }
  188. }
  189. $judge = Db::name('item_judge_detail')->where('pid',$temp_id)->select();
  190. $sum_all_dis_data = array_sum($all_dis_data);
  191. $dis = $sum_all_dis_data - $ethanol; //残留总量
  192. $dis_impurity = array_sum($dis_impurity_data); //杂质总量
  193. $ben_total = array_sum($ben_total_data); //苯系物重量
  194. foreach ($judge as $k=>$v){
  195. if ($v['params'] == '溶剂残留总量'){
  196. if ( $dis < $v['max']){
  197. $is_qualified = 1;
  198. }else{
  199. $is_qualified = 0;
  200. }
  201. }if ($v['params'] == '溶剂杂质总量' || $v['params'] == '总量'){
  202. if ( $dis_impurity < $v['max']){
  203. $is_qualified = 1;
  204. }else{
  205. $is_qualified = 0;
  206. }
  207. }if ($v['params'] == '溶剂杂质苯系物' || $v['params'] == '苯系物'){
  208. if ( $ben_total < $v['max']){
  209. $is_qualified = 1;
  210. }else{
  211. $is_qualified = 0;
  212. }
  213. }if ($v['params'] == '溶剂杂质苯' || $v['params'] == '苯'){
  214. if ($ben < $v['max']){
  215. $is_qualified = 1;
  216. }else{
  217. $is_qualified = 0;
  218. }
  219. }
  220. }
  221. $params = [];//检测结果数据
  222. $params['entrust_no'] = $entrust['no'];
  223. $params['entrust_id'] = $entrust['id'];
  224. $params['name'] = $entrust['name'];
  225. $params['bach'] = $entrust['bach'];
  226. $params['sample_no'] = $entrust['sample_no'];
  227. $params['standard_id'] = $temp_id;
  228. $params['standard_name'] = $judge[0]['name'];
  229. $params['dis'] = $dis;
  230. $params['dis_impurity'] = $dis_impurity;
  231. $params['ben_total'] = $ben_total;
  232. $params['ben'] = $ben;
  233. $params['unit'] = 'mg/m2';
  234. $params['judge'] = $is_qualified;
  235. $params['create'] = date('Y-m-d H:i:s');
  236. $params['maker'] = Session::get('admin')['username'];
  237. $params['params'] = Db::name('item_judge')->where('id',$temp_id)->value('list_name');
  238. $params['userid'] = Session::get('admin')['id'];;
  239. $params['status'] = 0;
  240. //更新数据
  241. $entrust_update = [];
  242. $entrust_update['standard_id'] =$temp_id;
  243. $entrust_update['standard_name'] =$judge[0]['name'];
  244. $entrust_update['status'] =2;
  245. $entrust_update['gather_id'] =$gather['id'];
  246. $entrust_update['gather_tab'] = $gather_tab;
  247. //日志记录
  248. $log = [];
  249. $log['userid'] = Session::get('admin')['id'];
  250. $log['username'] = Session::get('admin')['username'];
  251. $log['operate'] = '提交委托单id值为'.$id.'到检测';
  252. $log['e_id'] = $id;
  253. $log['create'] = date('Y-m-d H:i:s');
  254. $result = true;
  255. Db::startTrans();
  256. try {
  257. /***
  258. * 提交后,更新此数据的 判定标准、委托状态
  259. * 根据批次号绑定检测数据
  260. * 生成检测结果
  261. */
  262. $entrust_res = Db::name('entrust')->where('id',$id)->update($entrust_update);
  263. $res_check = Db::name('res')->insert($params);
  264. $log_res = Db::name('entrust_log')->insert($log);
  265. if (!$entrust_res || !$res_check){
  266. $result = false;
  267. }
  268. Db::commit();
  269. } catch (ValidateException|PDOException|Exception $e) {
  270. Db::rollback();
  271. $this->error($e->getMessage());
  272. }
  273. if ($result === false) {
  274. $this->error(__('No rows were inserted'));
  275. }
  276. $this->success();
  277. }
  278. //日志查看
  279. public function log(){
  280. //设置过滤方法
  281. $this->request->filter(['strip_tags', 'trim']);
  282. $params = $this->request->param("ids");
  283. if (false === $this->request->isAjax()) {
  284. $this->view->assign('id', $params);
  285. return $this->view->fetch();
  286. }
  287. //如果发送的来源是 Selectpage,则转发到 Selectpage
  288. if ($this->request->request('keyField')) {
  289. return $this->selectpage();
  290. }
  291. $id = $this->request->param("ids");
  292. $map = [];
  293. if (!empty($params)){
  294. $map['e_id'] = $id;
  295. }
  296. // print_r($map);die;
  297. [$where, $sort, $order, $offset, $limit] = $this->buildparams();
  298. $list = Db::name('entrust_log')
  299. ->where($map)
  300. ->order($sort, $order)
  301. ->paginate($limit);
  302. $result = ['total' => $list->total(), 'rows' => $list->items()];
  303. return json($result);
  304. }
  305. //检测数据查看
  306. public function data(){
  307. $params = input('id');
  308. if (empty($params)){
  309. $this->error('参数错误');
  310. }
  311. $gather_id = Db::name('entrust')->where('id',$params)->find();
  312. if (empty($gather_id['gather_id'])){
  313. $this->error('此委托单还未提交检测,暂无检测数据');
  314. }
  315. //此处根据实际获取到的采集表的数据 gather_tab 去对应表里查数据 重新写一个gc表格页面 js加代码
  316. if ($gather_id['gather_tab'] == 'gather_txt_check_gcms'){
  317. $gather = Db::name('gather_txt_gcms')->where('id',$gather_id['gather_id'])->find();
  318. $data = Db::name('gather_txt_check_gcms')->where('pid',$gather_id['gather_id'])->select();
  319. $this->view->assign('gather', $gather);
  320. $this->view->assign('data', $data);
  321. return $this->view->fetch();
  322. }else if ($gather_id['gather_tab'] == 'gather_txt_check_gc'){
  323. $gather = Db::name('gather_txt_gc')->where('id',$gather_id['gather_id'])->find();
  324. $data = Db::name('gather_txt_check_gc')->where('pid',$gather_id['gather_id'])->select();
  325. $this->view->assign('gather', $gather);
  326. $this->view->assign('data', $data);
  327. return $this->fetch('datagc');
  328. }
  329. }
  330. //委托单
  331. public function commissionSheet(){
  332. return $this->view->fetch();
  333. }
  334. //生成委托单号
  335. public function getNo(){
  336. $params = input('temp');
  337. $company = input('company');
  338. if (empty($params) || empty($company)){
  339. $this->error('参数错误');
  340. }
  341. $num = Db::name('entrust')->where('sample_no','like','%'.$params.'%')->whereTime('create','d')->count();
  342. if ($company == '亚欣'){//亚欣送样从100开始
  343. $num = $num+100;
  344. }else{
  345. $num = $num+1;
  346. }
  347. if ($num < 10){
  348. $num = '0'.$num;
  349. }
  350. //一位样品代号+8位日期+当前样品代号第几次送样+2位检测方式(01代表vocs)
  351. $sample_no = date('Ymd').$num.'01';
  352. return array('code'=>1,'data'=>$sample_no);
  353. }
  354. }