Cron.php 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. <?php
  2. namespace app\common\model;
  3. use think\facade\Db;
  4. /**
  5. * ============================================================================
  6. *
  7. * ============================================================================
  8. * 版权所有 2014-2028 浙江惠利玛产业互联网有限公司,并保留所有权利。
  9. * 网站地址: https://www.valimart.net/
  10. * ----------------------------------------------------------------------------
  11. *
  12. * ============================================================================
  13. * 数据层模型
  14. */
  15. class Cron extends BaseModel {
  16. /**
  17. * 取单条任务信息
  18. * @access public
  19. * @author csdeshang
  20. * @param array $condition 检索条件
  21. * @return type
  22. */
  23. public function getCronInfo($condition = array()) {
  24. return Db::name('cron')->where($condition)->find();
  25. }
  26. /**
  27. * 任务队列列表
  28. * @access public
  29. * @author csdeshang
  30. * @param array $condition 检索条件
  31. * @param number $limit 数目限制
  32. * @return array
  33. */
  34. public function getCronList($condition, $limit = 100) {
  35. return Db::name('cron')->where($condition)->limit($limit)->select()->toArray();
  36. }
  37. /**
  38. * 保存任务队列
  39. * @access public
  40. * @author csdeshang
  41. * @param unknown $data 参数内容
  42. * @return array
  43. */
  44. public function addCronAll($data) {
  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. return Db::name('cron')->insert($data);
  56. }
  57. /**
  58. * 删除任务队列
  59. * @access public
  60. * @author csdeshang
  61. * @param array $condition 条件
  62. * @return array
  63. */
  64. public function delCron($condition) {
  65. return Db::name('cron')->where($condition)->delete();
  66. }
  67. }
  68. ?>