CollectEquipment.php 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. <?php namespace App\Models;
  2. use Illuminate\Database\Eloquent\Factories\HasFactory;
  3. use Illuminate\Database\Eloquent\Model;
  4. use App\Facades\Servers\Encrypts\AccessToken;
  5. /**
  6. *采集设备表
  7. *
  8. */
  9. class CollectEquipment extends Model
  10. {
  11. use HasFactory;
  12. // 与模型关联的表名
  13. protected $table = 'collect_equipment';
  14. // 是否主动维护时间戳
  15. public $timestamps = false;
  16. protected $connection = 'mysql';
  17. // 定义时间戳字段名
  18. // const CREATED_AT = 'insert_time';
  19. // const UPDATED_AT = 'update_time';
  20. /**
  21. * 添加数据
  22. *
  23. */
  24. public function add($data)
  25. {
  26. // 时间
  27. $data['insert_time'] = time();
  28. $data['update_time'] = time();
  29. // 写入数据表
  30. $id = $this->query()->insertGetId($data);
  31. // 如果操作失败
  32. if( !$id ) return 0;
  33. // 更新缓存
  34. $this->getList(true);
  35. // 返回结果
  36. return $id;
  37. }
  38. /**
  39. * 添加数据
  40. *
  41. */
  42. public function edit($id,$data)
  43. {
  44. // 更新时间
  45. $data['update_time'] = time();
  46. // 写入数据表
  47. $result = $this->query()->where(['id'=>$id])->update($data);
  48. // 如果操作失败
  49. if( !$result ) return 0;
  50. // 更新缓存
  51. $this->getList(true);
  52. // 返回结果
  53. return $id;
  54. }
  55. /**
  56. * 获取列表
  57. * @param Bool $force 是否强制更新
  58. *
  59. */
  60. public function getList($force = false)
  61. {
  62. // 结果数据
  63. $list = $force ? [] : cache('collect:equipment:list');
  64. // 不存在数据
  65. if ( !$list ) {
  66. // 从数据库获取数据
  67. $data = $this->query()->get()->toArray();
  68. // 循环处理数据
  69. $list = [];
  70. // 进行更新
  71. foreach ($data as $value) {
  72. // 重组数据
  73. $list[$value['id']] = $value;
  74. }
  75. // 存起来
  76. cache(['collect:equipment:list'=>$list]);
  77. }
  78. // 返回结果
  79. return $list;
  80. }
  81. }