Msg.php 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283
  1. <?php
  2. /*
  3. |--------------------------------------------------------------------------
  4. | 模板消息
  5. |--------------------------------------------------------------------------
  6. */
  7. namespace Applet\Src;
  8. use Dever;
  9. use Main\Lib\Wechat;
  10. use Main\Lib\Core;
  11. class Msg
  12. {
  13. # 发送模板消息
  14. public function test()
  15. {
  16. $page = 'pages/index/index';
  17. $data = array
  18. (
  19. 'keyword1' => array
  20. (
  21. 'value' => '测试活动',
  22. ),
  23. 'keyword2' => array
  24. (
  25. 'value' => date('Y-m-d H:i:s'),
  26. ),
  27. 'keyword3' => array
  28. (
  29. 'value' => '欢迎参加',
  30. ),
  31. );
  32. $data = json_encode($data);
  33. //Dever::setInput('touser', 'oIZ895bO9a_TT_ouYCQLPFMod57c');
  34. //Dever::setInput('touser', 'oIZ895bO9a_TT_ouYCQLPFMod57c');
  35. Dever::setInput('page', $page);
  36. Dever::setInput('data', $data);
  37. //Dever::setInput('form_id', '1526295575657');
  38. Dever::setInput('key', 'act');
  39. Dever::setInput('project_id', '2');
  40. $type = Dever::input('type', 1);
  41. if ($type == 1) {
  42. return $this->send();
  43. } else {
  44. return $this->sendMul();
  45. }
  46. }
  47. # 发送单条模板消息
  48. public function send()
  49. {
  50. $key = Dever::input('key');
  51. $project_id = Dever::input('project_id');
  52. $touser = Dever::input('touser');
  53. $page = Dever::input('page');
  54. $data = Dever::input('data');
  55. $form_id = Dever::input('form_id');
  56. $emphasis_keyword = Dever::input('emphasis_keyword');
  57. $this->sendOne($key, $project_id, $touser, $page, $data, $form_id, $emphasis_keyword);
  58. return 'ok';
  59. }
  60. # 发送单条模板消息
  61. public function sendOne($key, $project_id, $touser, $page, $data, $form_id, $emphasis_keyword = '', $state = false)
  62. {
  63. if ($project_id > 0 && $key && $touser && $page && $data) {
  64. $info = Dever::db('applet/msg')->one(array('option_key' => $key, 'option_project_id' => $project_id));
  65. if ($info) {
  66. $update = array();
  67. $update['project_id'] = $info['project_id'];
  68. $update['msg_id'] = $info['id'];
  69. $update['touser'] = $touser;
  70. $update['page'] = $page;
  71. $update['data'] = $data;
  72. $update['form_id'] = $form_id;
  73. $update['emphasis_keyword'] = $emphasis_keyword;
  74. if (!$update['form_id']) {
  75. $update['form_id'] = $this->getFormId($info['project_id'], $update['touser']);
  76. }
  77. $where = array();
  78. $where['option_msg_id'] = $info['id'];
  79. $where['option_touser'] = $update['touser'];
  80. //$where['option_data'] = $update['data'];
  81. //$where['option_form_id'] = $update['form_id'];
  82. $where['option_page'] = $update['page'];
  83. $id = Dever::upinto('applet/msg_log', $where, $update);
  84. Core::run($info['project_id'], 'send_msg', 'msg.sendAction', 'msg.sendLog', 'applet', $id, $state);
  85. }
  86. }
  87. }
  88. public function submit()
  89. {
  90. # 立刻发送
  91. $id = Dever::input('id');
  92. if ($id > 0) {
  93. $info = Dever::db('applet/msg_send')->one($id);
  94. if ($info) {
  95. Dever::setInput('key', $info['key']);
  96. Dever::setInput('project_id', $info['project_id']);
  97. Dever::setInput('page', $info['page']);
  98. $data = json_decode(base64_decode($info['content']), true);
  99. if ($data) {
  100. $send = array();
  101. foreach ($data as $k => $v) {
  102. $send[$v['key']] = $v['value'];
  103. }
  104. $send = json_encode($send, JSON_UNESCAPED_UNICODE);
  105. Dever::setInput('data', $send);
  106. }
  107. $this->sendMul();
  108. }
  109. }
  110. Dever::alert('提交成功,请到模板消息日志中查看发送记录');
  111. return;
  112. }
  113. # 发送多条模板消息 入队
  114. public function sendMul()
  115. {
  116. $key = Dever::input('key');
  117. $project_id = Dever::input('project_id');
  118. $page = Dever::input('page');
  119. $data = Dever::input('data');
  120. $emphasis_keyword = Dever::input('emphasis_keyword');
  121. if ($project_id > 0 && $key && $page && $data) {
  122. # 获取所有拥有formid的openid,并去重
  123. $list = Dever::db('applet/msg_form')->getAllGroupByOpenid(array('option_project_id' => $project_id));
  124. if ($list) {
  125. Dever::import('queue');
  126. foreach ($list as $k => $v) {
  127. if (is_numeric($v['form_id']) && $v['openid'] == 'oIZ895adCNPtwyPX47Uv8ne8_xcM') {
  128. $param = array();
  129. $param['key'] = $key;
  130. $param['project_id'] = $project_id;
  131. $param['touser'] = $v['openid'];
  132. $param['page'] = $page;
  133. $param['data'] = $data;
  134. $param['form_id'] = $v['form_id'];
  135. $param['emphasis_keyword'] = $emphasis_keyword;
  136. Dever::db('applet/msg_form')->delete($v['id']);
  137. Dever::push($param);
  138. }
  139. }
  140. }
  141. }
  142. return 'ok';
  143. }
  144. # 发送多条模板消息 出队 每小时执行一次
  145. public function cron()
  146. {
  147. Dever::import('queue');
  148. $state = true;
  149. //如果是异步发送,每发送10次,休息3秒
  150. $time = 3;
  151. $num = 0;
  152. $sync = true;//同步发送
  153. while ($state == true) {
  154. $data = Dever::pop();
  155. if ($data) {
  156. $num++;
  157. $state = true;
  158. $this->sendOne($data['key'], $data['project_id'], $data['touser'], $data['page'], $data['data'], $data['form_id'], $data['emphasis_keyword'], $state);
  159. if ($sync == false && $num == 10) {
  160. $num = 0;
  161. sleep($time);
  162. }
  163. } else {
  164. $state = false;
  165. }
  166. }
  167. return 'ok';
  168. }
  169. public function getFormId($project_id, $openid)
  170. {
  171. # 获取一个form_id,取最新的100条,然后随机取
  172. $info = Dever::db('applet/msg_form')->getAll(array('option_openid' => $openid, 'option_project_id' => $project_id));
  173. if ($info) {
  174. $key = array_rand($info, 1);
  175. $info = $info[$key];
  176. Dever::db('applet/msg_form')->delete($info['id']);
  177. return $info['form_id'];
  178. } else {
  179. Dever::alert('错误的form_id');
  180. }
  181. }
  182. # 记录form_id 之后加上清理过期的form_id 七天过期
  183. public function write_form_id()
  184. {
  185. $id = Dever::input('project_id');
  186. if ($id > 0) {
  187. $update = array();
  188. $update['project_id'] = $id;
  189. $update['form_id'] = Dever::input('form_id');
  190. $update['openid'] = Dever::input('openid');
  191. $where = array();
  192. $where['option_openid'] = $update['openid'];
  193. $where['option_project_id'] = $update['project_id'];
  194. $where['option_form_id'] = $update['form_id'];
  195. $id = Dever::upinto('applet/msg_form', $where, $update);
  196. }
  197. return 'ok';
  198. }
  199. public function sendAction($id)
  200. {
  201. $info = Dever::db('applet/msg_log')->one($id);
  202. if ($info) {
  203. $msg = Dever::db('applet/msg')->one($info['msg_id']);
  204. $info['template_id'] = $msg['template_id'];
  205. if ($info['data']) {
  206. $info['data'] = json_decode($info['data'], true);
  207. }
  208. return $info;
  209. } else {
  210. die;
  211. }
  212. }
  213. public function sendLog($project_id, $data, $id = false)
  214. {
  215. $info = Dever::db('applet/msg_log')->one($id);
  216. if ($info) {
  217. $update['where_id'] = $info['id'];
  218. $update['result'] = json_encode($data);
  219. if ($data['errmsg'] == 'ok') {
  220. $update['status'] = 2;
  221. } else {
  222. $update['status'] = 3;
  223. }
  224. $update['num'] = $info['num'] + 1;
  225. Dever::db('applet/msg_log')->update($update);
  226. }
  227. }
  228. # 同步微信消息模板到本地
  229. public function sync()
  230. {
  231. $project = Dever::db('main/project')->state(array('option_type' => 3));
  232. if ($project) {
  233. foreach ($project as $k => $v) {
  234. Core::run($v['id'], 'get_msg', '', 'msg.load', 'applet');
  235. }
  236. }
  237. return 'ok';
  238. }
  239. public function load($project_id, $data, $param = false)
  240. {
  241. if (isset($data['list']) && $data['list']) {
  242. foreach ($data['list'] as $k => $v) {
  243. $update = array();
  244. $update['project_id'] = $project_id;
  245. $update['template_id'] = $v['template_id'];
  246. $update['content'] = $v['content'];
  247. $update['name'] = $v['title'];
  248. $update['example'] = $v['example'];
  249. $id = Dever::upinto('applet/msg', array('option_project_id' => $project_id, 'option_template_id' => $v['template_id']), $update);
  250. }
  251. }
  252. return array();
  253. }
  254. }