Cron.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  1. <?php
  2. namespace Main\Lib;
  3. use Dever;
  4. class Cron
  5. {
  6. # 增加积分
  7. public function scores_api()
  8. {
  9. //$where['start'] = Dever::maketime('2019-04-24 23:12:40');
  10. $where['start'] = Dever::maketime('2019-04-25 00:34:55');
  11. $where['end'] = Dever::maketime('2019-04-25 14:47:16');
  12. $where['score_type'] = 1;
  13. $where['action_id'] = Dever::input('action_id');
  14. $data = Dever::db('score/action_log')->getDataByDate($where);
  15. $test = Dever::input('test');
  16. if ($test == 1) {
  17. print_r($data);die;
  18. }
  19. if ($data) {
  20. foreach ($data as $k => $v) {
  21. Dever::load('score/lib/core.oper?log_id='.$v['id']);
  22. }
  23. }
  24. return $data;
  25. # 购买小刊
  26. /*
  27. $where['product_id'] = Dever::input('journal_id', 28);
  28. $where['type'] = 1;
  29. $where['status'] = 2;
  30. $data = Dever::db('journal/order')->state($where);
  31. $score = 20;
  32. if ($data) {
  33. foreach ($data as $k => $v) {
  34. # 计算该订单能加的积分数
  35. if ($v['buy_id'] && $v['buy_id'] > 0) {
  36. $buy = Dever::db('journal/buy_num')->one($data['buy_id']);
  37. if ($buy && $buy['num'] > 0) {
  38. $update_score = $score*$buy['num'];
  39. }
  40. }
  41. }
  42. }
  43. # 兑换小刊
  44. $where['product_id'] = Dever::input('journal_id', 28);
  45. $where['type'] = 2;
  46. $where['status'] = 2;
  47. $data = Dever::db('journal/order')->state($where);
  48. */
  49. }
  50. # 收回多余的兑换码
  51. public function deleteCode_api()
  52. {
  53. $order_id = Dever::input('order_id');
  54. if ($order_id) {
  55. $where['order_id'] = $order_id;
  56. }
  57. $where['product_id'] = 28;
  58. //$where['refund_status'] = 1;
  59. $where['type'] = 3;
  60. $data = Dever::db('journal/order')->state($where);
  61. $test = Dever::input('test');
  62. if ($test == 1) {
  63. print_r($data);
  64. }
  65. if ($data) {
  66. foreach ($data as $k => $v) {
  67. $this->deleteCodes($v);
  68. }
  69. }
  70. }
  71. private function deleteCodes($data)
  72. {
  73. # 获取该订单所能拥有的兑换码数
  74. $code_num = 1;
  75. $uid = $data['uid'];
  76. if ($data['buy_id'] > 0) {
  77. $buy = Dever::db('journal/buy_num')->one($data['buy_id']);
  78. $code_num = $buy['code'];
  79. }
  80. # 这个订单下所有码
  81. $code_where['order_id'] = $data['order_id'];
  82. $code = Dever::db('code/info')->getData($code_where);
  83. # code_num = 1
  84. # code = 21
  85. $test = Dever::input('test');
  86. if ($test == 1) {
  87. echo $code_num;
  88. print_r($code);die;
  89. }
  90. if ($code) {
  91. $i = 1;
  92. foreach ($code as $k => $v) {
  93. if ($i > $code_num) {
  94. Dever::db('code/info')->update(array('where_id' => $v['id'], 'state' => 2));
  95. }
  96. $i++;
  97. }
  98. }
  99. }
  100. public function refund_api()
  101. {
  102. $order_id = Dever::input('order_id');
  103. if ($order_id) {
  104. $where['order_id'] = $order_id;
  105. }
  106. $where['product_id'] = 28;
  107. $where['status'] = 5;
  108. $where['refund_status'] = 1;
  109. $data = Dever::db('journal/order')->state($where);
  110. $test = Dever::input('test');
  111. if ($test == 1) {
  112. print_r($data);die;
  113. }
  114. if ($data) {
  115. foreach ($data as $k => $v) {
  116. $this->refundScore($v);
  117. }
  118. }
  119. }
  120. private function refundScore($data)
  121. {
  122. $score = 0;
  123. if ($data['cash'] == 6) {
  124. $score = 20;
  125. }
  126. if ($data['cash'] == 60) {
  127. $score = 20*10;
  128. }
  129. if ($data['cash'] == 588) {
  130. $score = 20*100;
  131. }
  132. if ($data['cash'] == 1728) {
  133. $score = 20*300;
  134. }
  135. if ($data['cash'] == 3348) {
  136. $score = 20*600;
  137. }
  138. if ($score > 0) {
  139. if ($data['type'] == 1) {
  140. $where['uid'] = $data['uid'];
  141. $user = Dever::db('score/user')->one($where);
  142. if ($user) {
  143. $user_score = $user['score'] - $score;
  144. if ($user_score < 0) {
  145. $user_score = 0;
  146. }
  147. Dever::db('score/user')->update(array('where_id' => $user['id'], 'score' => $user_score));
  148. }
  149. $where['type'] = 4;
  150. $where['data_id'] = 28;
  151. $user = Dever::db('act/score')->one($where);
  152. if ($user) {
  153. $user_score = $user['score'] - $score;
  154. if ($user_score < 0) {
  155. $user_score = 0;
  156. }
  157. Dever::db('act/score')->update(array('where_id' => $user['id'], 'score' => $user_score));
  158. }
  159. } elseif ($data['type'] == 3) {
  160. $code_where['order_id'] = $data['order_id'];
  161. //$code_where['type'] = 1;
  162. $code_where['create_uid'] = $data['uid'];
  163. $code = Dever::db('code/info')->state($code_where);
  164. if ($code) {
  165. print_r($code);
  166. foreach ($code as $k => $v) {
  167. if ($v['type'] == 1) {
  168. Dever::db('code/info')->update(array('where_id' => $v['id'], 'type' => 4));
  169. } elseif ($v['type'] == 3) {
  170. $this->refundScoreCode($v);
  171. }
  172. }
  173. }
  174. }
  175. Dever::db('journal/order')->update(array('where_id' => $data['id'], 'refund_status' => 2));
  176. }
  177. print_r($data);
  178. print_r($score);
  179. echo "\r\n";
  180. return $score;
  181. }
  182. private function refundScoreCode($data)
  183. {
  184. if (isset($data['score']) && $data['score'] > 0) {
  185. $score = $data['score'];
  186. } elseif (isset($data['product_num']) && $data['product_num'] > 0) {
  187. $score = $data['product_num'] * 20;
  188. }
  189. if ($score > 0) {
  190. $where['uid'] = $data['uid'];
  191. $user = Dever::db('score/user')->one($where);
  192. if ($user) {
  193. $user_score = $user['score'] - $score;
  194. if ($user_score < 0) {
  195. $user_score = 0;
  196. }
  197. Dever::db('score/user')->update(array('where_id' => $user['id'], 'score' => $user_score));
  198. }
  199. $where['type'] = 4;
  200. $where['data_id'] = 28;
  201. $user = Dever::db('act/score')->one($where);
  202. if ($user) {
  203. $user_score = $user['score'] - $score;
  204. if ($user_score < 0) {
  205. $user_score = 0;
  206. }
  207. Dever::db('act/score')->update(array('where_id' => $user['id'], 'score' => $user_score));
  208. }
  209. }
  210. }
  211. public function pays_api()
  212. {
  213. $where['product_id'] = 28;
  214. $where['type'] = 3;
  215. $where['status'] = 1;
  216. $where['cron_status'] = 1;
  217. $data = Dever::db('journal/order')->state($where);
  218. if ($data) {
  219. foreach ($data as $k => $v) {
  220. $this->getpays($v['order_id']);
  221. Dever::db('journal/order')->update(array('where_id' => $v['id'], 'cron_status' => 2));
  222. }
  223. }
  224. }
  225. private function getpays($order_id)
  226. {
  227. $url = 'http://mapi.jstyle.cn/pay/pay/?api.search&order_id='.$order_id.'&account_id=1';
  228. Dever::curl($url);
  229. }
  230. public function unpay_api()
  231. {}
  232. public function activeEnd_api()
  233. {}
  234. #用户未支付电子刊情况下,未支付订单超过2小时后,发送一次唤回支付提醒
  235. public function unpay()
  236. {
  237. $time = 7200;
  238. $where['cdate'] = time() + $time;
  239. $where['note'] = 1;
  240. $where['type'] = '1,3';
  241. $data = Dever::db('journal/order')->getDataByTime($where);
  242. if ($data) {
  243. foreach ($data as $k => $v) {
  244. $user = Dever::db('passport/user')->one($v['uid']);
  245. if (!$user) {
  246. continue;
  247. }
  248. Dever::db('journal/order')->update(array('where_id' => $v['id'], 'note' => 2));
  249. $journal = Dever::db('journal/info')->one($v['product_id']);
  250. if (Dever::project('message')) {
  251. Dever::load('message/lib/data')->push(-1, $v['uid'], '支付提醒', '您订阅的'.$journal['name'].'尚未支付!', 11, $v['cate_id'], 1, Dever::load('act/lib/note')->push(4, $journal['id'], $journal['name']));
  252. }
  253. # 发送短消息
  254. if (isset($user['mobile']) && $user['mobile'] && Dever::project('sms')) {
  255. $send = array();
  256. $send['name'] = $journal['name'];
  257. //Dever::load('sms/api.send', 'note_live', $user['mobile'], $send);
  258. }
  259. # 发模板消息
  260. $wechat = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'type' => 1, 'system_id' => $v['cate_id']));
  261. if ($wechat && Dever::project('wechat_applet')) {
  262. $send['key'] = 'unbuy_journal';
  263. $send['project_id'] = $v['cate_id'];
  264. $send['touser'] = $wechat['openid'];
  265. $send['page'] = Dever::config('base')->applet_index . '?scene=' . Dever::login($v['uid']) . ',' . '4,' . $v['product_id'];
  266. $send['data'] = array
  267. (
  268. 'keyword1' => array('value' => $journal['name']),
  269. 'keyword2' => array('value' => $v['cash']),
  270. 'keyword3' => array('value' => '您订阅的'.$journal['name'].'尚未支付!'),
  271. );
  272. $send['data'] = json_encode($send['data']);
  273. $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 2, $v['cate_id']);
  274. if ($send['form_id']) {
  275. Dever::load('wechat_applet/msg.send', $send);
  276. }
  277. }
  278. }
  279. }
  280. return 'ok';
  281. }
  282. #电子杂志活动结束前5个时,向己有电子刊阅读权限的用户发送活动结束提醒
  283. public function activeEnd()
  284. {
  285. $time = 5*3600;
  286. $where['ends'] = time();
  287. $where['end'] = $where['ends'] + $time;
  288. $data = Dever::db('journal/active')->getDataByTime($where);
  289. //echo Dever::sql();die;
  290. $test = Dever::input('test');
  291. if ($test == 1) {
  292. print_r($data);die;
  293. }
  294. if ($data) {
  295. foreach ($data as $ks => $vs) {
  296. $journal = Dever::db('journal/info')->one($vs['info_id']);
  297. $subscribe = Dever::db('act/subscribe')->state(array('note' => 1, 'type' => 4, 'data_id' => $vs['info_id']));
  298. if ($subscribe) {
  299. foreach ($subscribe as $k => $v) {
  300. $user = Dever::db('passport/user')->one($v['uid']);
  301. if ($user) {
  302. Dever::db('act/subscribe')->update(array('where_id' => $v['id'], 'note' => 2));
  303. if (Dever::project('message')) {
  304. Dever::load('message/lib/data')->push(-1, $v['uid'], '活动结束提醒', '您参与的'.$journal['name'].'积分排行榜活动还有5小时就要结束了,想要冲榜赢奖品的要抓紧机会呀〜', 11, $journal['cate_id'], 1, Dever::load('act/lib/note')->push(4, $journal['id'], $journal['name']));
  305. }
  306. # 发送短消息
  307. if (isset($user['mobile']) && $user['mobile'] && Dever::project('sms')) {
  308. $send = array();
  309. $send['name'] = $journal['name'];
  310. //Dever::load('sms/api.send', 'note_live', $user['mobile'], $send);
  311. }
  312. # 发模板消息
  313. $wechat = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'type' => 1, 'system_id' => $journal['cate_id']));
  314. if ($wechat && Dever::project('wechat_applet')) {
  315. $send['key'] = 'service_end_note';
  316. $send['project_id'] = $journal['cate_id'];
  317. $send['touser'] = $wechat['openid'];
  318. $send['page'] = Dever::config('base')->applet_index . '?scene=' . Dever::login($v['uid']) . ',' . '4,' . $journal['id'];
  319. $send['data'] = array
  320. (
  321. 'keyword1' => array('value' => $journal['name']),
  322. 'keyword2' => array('value' => date('Y-m-d H:i', $vs['end'])),
  323. 'keyword3' => array('value' => '您参与的'.$journal['name'].'积分排行榜活动还有5小时就要结束了,想要冲榜赢奖品的要抓紧机会呀~'),
  324. );
  325. $send['data'] = json_encode($send['data']);
  326. $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 1, $journal['cate_id']);
  327. if (!$send['form_id']) {
  328. $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 2, $journal['cate_id']);
  329. }
  330. if ($send['form_id']) {
  331. Dever::load('wechat_applet/msg.send', $send);
  332. }
  333. }
  334. }
  335. }
  336. }
  337. }
  338. }
  339. return 'ok';
  340. }
  341. }