Model.php 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. <?php
  2. /**
  3. *
  4. *User:Administrator
  5. *Date:2021/10/11
  6. */
  7. namespace app\api\controller\v1;
  8. //监测模型
  9. use app\api\business\ModelBus;
  10. use app\api\validate\ModelValidate;
  11. use think\exception\ValidateException;
  12. class Model
  13. {
  14. //获取模型表
  15. public function selectModelList()
  16. {
  17. $data = [
  18. 'type_id' => request()->param('type_id', '', 'int'),
  19. 'pageNum' => request()->param('pageNum,', 1, 'int'),
  20. 'pageSize' => request()->param('pageSize', 10, 'int'),
  21. ];
  22. try {
  23. validate(ModelValidate::class)->scene('selectQtModelList')->check($data);
  24. } catch (ValidateException $exception) {
  25. return showError($exception->getError());
  26. }
  27. $result = (new ModelBus())->selectModelList($data);
  28. return showSuccess($result);
  29. }
  30. public function bindModel()
  31. {
  32. $data=[
  33. 'endtime_cydsb' => request()->param('endtime_cydsb', '', 'trim'),
  34. 'is_divide'=>request()->param('is_divide', '0', 'int'),
  35. 'test_model_id' => request()->param('test_model_id', '', 'int'),
  36. 'task_id' => request()->param('id', '', 'int'),
  37. ];
  38. try {
  39. validate(ModelValidate::class)->scene('bindModel')->check($data);
  40. } catch (ValidateException $exception) {
  41. return showError($exception->getError());
  42. }
  43. $result = (new ModelBus())->updateInfoByTaskID($data);
  44. return showSuccess($result);
  45. }
  46. //获取模型信息
  47. public function getModelInfo()
  48. {
  49. $data['id'] = request()->param('id', '', 'int');
  50. try {
  51. validate(ModelValidate::class)->scene('getModelInfo')->check($data);
  52. } catch (ValidateException $exception) {
  53. return showError($exception->getError());
  54. }
  55. $result = (new ModelBus())->getModelInfo($data);
  56. return showSuccess($result);
  57. }
  58. //更新模型
  59. public function updateModelInfo()
  60. {
  61. //更新testModel;当提交时,修改updatetime
  62. $model_id = request()->param('id','','int');
  63. $model_info = [
  64. 'name' => request()->param('name', '', 'trim'),
  65. 'type_id' => request()->param('type_id', '', 'int'),
  66. ];
  67. $product=request()->param('product');
  68. $pesticides=request()->param('pesticides');
  69. //更新模型信息包括三步,1、更新test_model 2、删除&重新添加test_product 3、删除&重新添加test_pesticides
  70. $result = (new ModelBus())->updateModelInfo($model_id,$model_info,$product,$pesticides);//==true
  71. return showSuccess($result);
  72. }
  73. //新增模型
  74. public function createModelInfo()
  75. {
  76. //新增test_model表信息
  77. $model_type_id = request()->param('type_id');
  78. $model_name = request()->param('name');
  79. $product_data = request()->param('product');
  80. $pesticides_data = request()->param('pesticides');
  81. $result = (new ModelBus())->createModelInfo($model_name, $model_type_id,$product_data,$pesticides_data);
  82. return showSuccess($result);
  83. }
  84. //删除模型
  85. public function deleteModelInfo()
  86. {
  87. $del_arr = request()->param('delarr');
  88. $data=[];
  89. $data_count=0;
  90. foreach ($del_arr as $k => $v) {
  91. $data_count+=1;
  92. $k = ['id' => $v['id']];
  93. $data[]=$k;
  94. }
  95. $result = (new ModelBus())->deleteModelInfo($data,$data_count);
  96. return showSuccess($result);
  97. }
  98. }