CRON.class.php 7.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239
  1. <?php
  2. /*
  3. * CRON
  4. *
  5. * @author vesta, http://vestacp.com/
  6. * @author Dmitry Malishev <dima.malishev@gmail.com>
  7. * @author Dmitry Naumov-Socolov <naumov.socolov@gmail.com>
  8. * @copyright vesta 2010-2011
  9. */
  10. class CRON extends AjaxHandler
  11. {
  12. /**
  13. * Get CRON entries
  14. *
  15. * @param Request $request
  16. * @return string - Ajax Reply
  17. */
  18. public function getListExecute($request)
  19. {
  20. $user = $this->getLoggedUser();
  21. $reply = array();
  22. $result = Vesta::execute(Vesta::V_LIST_CRON_JOBS, array($user['uid'], Config::get('response_type')));
  23. foreach ($result['data'] as $id => $record) {
  24. $reply[$id] = array(
  25. 'CMD' => $record['CMD'],
  26. 'MIN' => $record['MIN'],
  27. 'HOUR' => $record['HOUR'],
  28. 'DAY' => $record['DAY'],
  29. 'MONTH' => $record['MONTH'],
  30. 'WDAY' => $record['WDAY'],
  31. 'SUSPENDED' => $record['SUSPEND'],
  32. 'DATE' => date(Config::get('ui_date_format', strtotime($record['DATE']))),
  33. 'JOB' => $id
  34. );
  35. }
  36. if (!$result['status']) {
  37. $this->errors[] = array($result['error_code'] => $result['error_message']);
  38. }
  39. return $this->reply($result['status'], $reply);
  40. }
  41. /**
  42. * Add CRON entry
  43. *
  44. * @param Request $request
  45. * @return string - Ajax Reply
  46. */
  47. public function addExecute(Request $request)
  48. {
  49. $user = $this->getLoggedUser();
  50. $spell = $request->getParameter('spell');
  51. $params = array(
  52. 'USER' => $user['uid'],
  53. 'MIN' => $spell['MIN'],
  54. 'HOUR' => $spell['HOUR'],
  55. 'DAY' => $spell['DAY'],
  56. 'MONTH' => $spell['MONTH'],
  57. 'WDAY' => $spell['WDAY'],
  58. 'CMD' => $spell['CMD']
  59. );
  60. $result = Vesta::execute(Vesta::V_ADD_CRON_JOB, $params);
  61. if ($spell['REPORTS']) {
  62. $result = array();
  63. $result = Vesta::execute(Vesta::V_ADD_SYS_USER_REPORTS, array('USER' => $user['uid']));
  64. if (!$result['status']) {
  65. $this->status = FALSE;
  66. $this->errors['REPORTS'] = array($result['error_code'] => $result['error_message']);
  67. }
  68. }
  69. if (!$result['status']) {
  70. $this->errors[] = array($result['error_code'] => $result['error_message']);
  71. }
  72. return $this->reply($result['status'], $result['data']);
  73. }
  74. /**
  75. * Delete CRON entry
  76. *
  77. * @param Request $request
  78. * @return string - Ajax Reply
  79. */
  80. public function deleteExecute(Request $request)
  81. {
  82. $user = $this->getLoggedUser();
  83. $spell = $request->getParameter('spell');
  84. $params = array(
  85. 'USER' => $user['uid'],
  86. 'JOB' => $spell['JOB']
  87. );
  88. $result = Vesta::execute(Vesta::V_DEL_CRON_JOB, $params);
  89. if (!$result['status']) {
  90. $this->errors[] = array($result['error_code'] => $result['error_message']);
  91. }
  92. return $this->reply($result['status'], $result['data']);
  93. }
  94. /**
  95. * Change CRON entry
  96. *
  97. * @param Request $request
  98. * @return string - Ajax Reply
  99. */
  100. public function changeExecute(Request $request)
  101. {
  102. $user = $this->getLoggedUser();
  103. $_old = $request->getParameter('old');
  104. $_new = $request->getParameter('new');
  105. $result = array();
  106. $params = array(
  107. 'USER' => $user['uid'],
  108. 'JOB' => $_old['JOB'],
  109. 'MIN' => $_new['MIN'],
  110. 'HOUR' => $_new['HOUR'],
  111. 'DAY' => $_new['DAY'],
  112. 'MONTH' => $_new['MONTH'],
  113. 'WDAY' => $_new['WDAY'],
  114. 'CMD' => $_new['CMD']
  115. );
  116. $result = Vesta::execute(Vesta::V_CHANGE_CRON_JOB, $params);
  117. if (!$result['status']) {
  118. $this->errors[] = array($result['error_code'] => $result['error_message']);
  119. }
  120. return $this->reply($result['status'], $result['data']);
  121. }
  122. /**
  123. * Suspend CRON entry
  124. *
  125. * @param Request $request
  126. * @return string - Ajax Reply
  127. */
  128. public function suspendExecute(Request $request)
  129. {
  130. $user = $this->getLoggedUser();
  131. $spell = $request->getParameter('spell');
  132. $params = array(
  133. 'USER' => $user['uid'],
  134. 'JOB' => $spell['JOB']
  135. );
  136. $result = Vesta::execute(Vesta::V_SUSPEND_CRON_JOB, $params);
  137. if (!$result['status']) {
  138. $this->errors[] = array($result['error_code'] => $result['error_message']);
  139. }
  140. return $this->reply($result['status'], $result['data']);
  141. }
  142. /**
  143. * Unsuspend CRON entry
  144. *
  145. * @param Request $request
  146. * @return string - Ajax Reply
  147. */
  148. public function unsuspendExecute($request)
  149. {
  150. $user = $this->getLoggedUser();
  151. $spell = $request->getParameter('spell');
  152. $params = array(
  153. 'USER' => $user['uid'],
  154. 'JOB' => $spell['JOB']
  155. );
  156. $result = Vesta::execute(Vesta::V_UNSUSPEND_CRON_JOB, $params);
  157. if (!$result['status']) {
  158. $this->errors[] = array($result['error_code'] => $result['error_message']);
  159. }
  160. return $this->reply($result['status'], $result['data']);
  161. }
  162. /**
  163. * Batch suspend CRON entries
  164. *
  165. * @param Request $request
  166. * @return string - Ajax Reply
  167. */
  168. /*public function suspendAllExecute($request)
  169. {
  170. $r = new Request();
  171. $_s = $r->getSpell();
  172. $_user = 'vesta';
  173. $_JOB = $_s['JOB'];
  174. $params = array(
  175. 'USER' => $_user
  176. );
  177. $result = Vesta::execute(Vesta::V_SUSPEND_CRON_JOBS, $params);
  178. if (!$result['status']) {
  179. $this->errors[] = array($result['error_code'] => $result['error_message']);
  180. }
  181. return $this->reply($result['status'], $result['data']);
  182. }*/
  183. /**
  184. * Batch unsuspend CRON entries
  185. *
  186. * @param Request $request
  187. * @return string - Ajax Reply
  188. */
  189. /*public function unsuspendAllExecute($request)
  190. {
  191. $r = new Request();
  192. $_s = $r->getSpell();
  193. $_user = 'vesta';
  194. $params = array(
  195. 'USER' => $_user
  196. );
  197. $result = Vesta::execute(Vesta::V_UNSUSPEND_CRON_JOBS, $params);
  198. if (!$result['status']) {
  199. $this->errors[] = array($result['error_code'] => $result['error_message']);
  200. }
  201. return $this->reply($result['status'], $result['data']);
  202. }*/
  203. }