Zzjobs.php 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. <?php
  2. defined('BASEPATH') or exit('No direct script access allowed');
  3. /**
  4. * 此类是为了解决erp没有队列的问题,为了解决这个问题,先写一下这个类,避免后期写那么多定时任务类 这里只能解决每间隔多少时间执行一会的
  5. */
  6. class Zzjobs extends Start_Controller
  7. {
  8. private $serect_str = "erpjob";
  9. private $user_agent = 'Xcly251618/Job (Erp)';
  10. private $api = "ly202508160727";
  11. private $ip = ['127.0.0.1','47.105.156.18'];
  12. public function __construct()
  13. {
  14. parent::__construct();
  15. $this->load->_model("Model_zzjobs","zzjobs");
  16. $this->load->_model("Model_logic_tools",'logic_tools');
  17. }
  18. public function _remap($arg, $arg_array)
  19. {
  20. $ip = $_SERVER['REMOTE_ADDR'];
  21. if(!in_array($ip,$this->ip)){
  22. exit("Unauthorized access");
  23. }
  24. $user_agent = empty($_SERVER['HTTP_USER_AGENT'])?"":$_SERVER['HTTP_USER_AGENT'];
  25. $token = empty($_SERVER['HTTP_X_AUTH_TOKEN'])?"":$_SERVER['HTTP_X_AUTH_TOKEN'];
  26. $time = $this->input->get('time',true);
  27. $api = $this->input->get('api',true);
  28. $this->checkAuth($user_agent,$token,$time,$api);
  29. if ($arg == 'jobs') //调出单
  30. {
  31. $this->_jobs();
  32. } else {
  33. $this->_index();
  34. }
  35. }
  36. /**
  37. * 校验是否有权限可以执行
  38. * $user_agent 自定义的请求客户端名称
  39. * $token 自定义的清华客户端的token
  40. * $time 请求的时间
  41. *
  42. */
  43. private function checkAuth($user_agent,$token,$time,$api){
  44. if($api != $this->api){
  45. exit("Access denied due to insufficient permissions");
  46. }
  47. $check_str = date("Ymd")."¥_".$this->serect_str."_¥".$time;
  48. if(empty($user_agent)){
  49. exit('No direct script access allowed');
  50. }
  51. if($user_agent != $this->user_agent){
  52. exit('Illegal request');
  53. }
  54. if(empty($token)){
  55. exit('No access permission');
  56. }
  57. $sercet_str = md5($check_str);
  58. if($sercet_str != $token){
  59. exit("Request permission is illegal");
  60. }
  61. }
  62. private function _index() {}
  63. //一般每一分钟都执行的 每分钟就执行10条
  64. //每五分钟 就执行100条
  65. //其他的就不限制了
  66. private function _jobs() {
  67. $m = (int)date("i");//当前分钟
  68. // 1分钟的队列
  69. $list_1 = $this->zzjobs->find_all('do_interval = 1 and status = 0');
  70. // 5分钟的队列
  71. $list_5 = [];
  72. if($m%5 == 0){
  73. $list_5 = $this->zzjobs->find_all('do_interval = 5 and status = 0');
  74. }
  75. // 10分钟的队列
  76. $list_10 = [];
  77. if($m%10 == 0){
  78. $list_10 = $this->zzjobs->find_all('do_interval = 10 and status = 0');
  79. }
  80. // 30分钟的队列
  81. $list_30 = [];
  82. if($m%30 == 0){
  83. $list_30 = $this->zzjobs->find_all('do_interval = 10 and status = 0');
  84. }
  85. $list = array_merge($list_1,$list_5,$list_10,$list_30);
  86. $do_list_ids = array_column($list,'id');
  87. if(empty($do_list_ids)){
  88. exit("No jobs to do");
  89. }
  90. $this->db->query("update crowd_zzjobs set status = 1 where id in (".implode(",",$do_list_ids).")");
  91. foreach($list as $k=>$v){
  92. $this->tasksAssign($v);
  93. }
  94. }
  95. private function tasksAssign($info){
  96. switch($info['quque']){
  97. case '1m':
  98. $this->zzjobs->save([
  99. 'result'=>$this->logic_tools->ret_json(1,"1m队列已经执行"),
  100. 'last_time'=>time()
  101. ],$info['id']);
  102. break;
  103. case '5m':
  104. $this->zzjobs->save([
  105. 'result'=>$this->logic_tools->ret_json(1,"没有对应发方法执行任务"),
  106. 'last_time'=>time()
  107. ],$info['id']);
  108. break;
  109. case '10m':
  110. $this->zzjobs->save([
  111. 'result'=>$this->logic_tools->ret_json(1,"没有对应发方法执行任务"),
  112. 'last_time'=>time()
  113. ],$info['id']);
  114. break;
  115. case '30':
  116. $this->zzjobs->save([
  117. 'result'=>$this->logic_tools->ret_json(1,"没有对应发方法执行任务"),
  118. 'last_time'=>time()
  119. ],$info['id']);
  120. break;
  121. default:
  122. $this->zzjobs->save([
  123. 'result'=>$this->logic_tools->ret_json(-1,"没有对应发方法执行任务"),
  124. 'last_time'=>time()
  125. ],$info['id']);
  126. break;
  127. }
  128. }
  129. }