Cron.php 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182
  1. <?php
  2. namespace app\common\model;
  3. use think\facade\Db;
  4. /**
  5. *
  6. *
  7. * ----------------------------------------------------------------------------
  8. *
  9. * 数据层模型
  10. */
  11. class Cron extends BaseModel
  12. {
  13. /**
  14. * 取单条任务信息
  15. * @access public
  16. * @author csdeshang
  17. * @param array $condition 检索条件
  18. * @return type
  19. */
  20. public function getCronInfo($condition = array())
  21. {
  22. return Db::name('cron')->where($condition)->find();
  23. }
  24. /**
  25. * 任务队列列表
  26. * @access public
  27. * @author csdeshang
  28. * @param array $condition 检索条件
  29. * @param number $limit 数目限制
  30. * @return array
  31. */
  32. public function getCronList($condition, $limit = 100)
  33. {
  34. return Db::name('cron')->where($condition)->limit($limit)->select()->toArray();
  35. }
  36. /**
  37. * 保存任务队列
  38. * @access public
  39. * @author csdeshang
  40. * @param unknown $data 参数内容
  41. * @return array
  42. */
  43. public function addCronAll($data)
  44. {
  45. return Db::name('cron')->insertAll($data);
  46. }
  47. /**
  48. * 保存任务队列
  49. * @access public
  50. * @author csdeshang
  51. * @param array $data 参数内容
  52. * @return boolean
  53. */
  54. public function addCron($data)
  55. {
  56. return Db::name('cron')->insert($data);
  57. }
  58. /**
  59. * 删除任务队列
  60. * @access public
  61. * @author csdeshang
  62. * @param array $condition 条件
  63. * @return array
  64. */
  65. public function delCron($condition)
  66. {
  67. return Db::name('cron')->where($condition)->delete();
  68. }
  69. }