RoutineTemplateListService.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace app\services\message\notice;
  12. use app\jobs\TemplateJob;
  13. use app\services\message\NoticeService;
  14. use app\services\user\UserServices;
  15. use app\services\wechat\WechatUserServices;
  16. use think\facade\Log;
  17. /**
  18. * 小程序模板消息消息队列
  19. * Class RoutineTemplateJob
  20. * @package crmeb\jobs
  21. */
  22. class RoutineTemplateListService extends NoticeService
  23. {
  24. /**
  25. * 根据UID获取openid
  26. * @param int $uid
  27. * @return mixed
  28. */
  29. public function getOpenidByUid(int $uid)
  30. {
  31. $isDel = app()->make(UserServices::class)->value(['uid' => $uid], 'is_del');
  32. if ($isDel) {
  33. $openid = '';
  34. } else {
  35. $openid = app()->make(WechatUserServices::class)->uidToOpenid($uid, 'routine');
  36. }
  37. return $openid;
  38. }
  39. /**
  40. * 发送模板消息
  41. * @param int $uid
  42. * @param array $data
  43. * @param string|null $link
  44. * @param string|null $color
  45. * @return bool|void
  46. */
  47. public function sendTemplate(int $uid, array $data, string $link = null, string $color = null)
  48. {
  49. try {
  50. if ($this->noticeInfo['is_routine'] == 1) {
  51. $openid = $this->getOpenidByUid($uid);
  52. //放入队列执行
  53. TemplateJob::dispatch('doJob', ['subscribe', $openid, $this->noticeInfo['routine_tempid'], $data, $link, $color]);
  54. }
  55. } catch (\Exception $e) {
  56. Log::error($e->getMessage());
  57. return true;
  58. }
  59. }
  60. /**
  61. * 确认收货
  62. * @param $uid
  63. * @param $order
  64. * @param $title
  65. * @return bool|void
  66. */
  67. public function sendOrderTakeOver($uid, $order, $title)
  68. {
  69. return $this->sendTemplate((int)$uid, [
  70. 'thing1' => $order['order_id'],
  71. 'thing2' => $title,
  72. 'date5' => date('Y-m-d H:i:s', time()),
  73. ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
  74. }
  75. /**
  76. * 发货订阅消息
  77. * @param $uid
  78. * @param $order
  79. * @param $storeTitle
  80. * @param int $isGive
  81. * @return bool|void
  82. */
  83. public function sendOrderPostage($uid, $order, $storeTitle, int $isGive = 0)
  84. {
  85. if ($isGive) {//快递发货
  86. return $this->sendTemplate((int)$uid, [
  87. 'character_string2' => $order['delivery_id'],
  88. 'thing1' => $order['delivery_name'],
  89. 'time3' => date('Y-m-d H:i:s', time()),
  90. 'thing5' => $storeTitle,
  91. ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
  92. } else {//同城配送
  93. return $this->sendTemplate((int)$uid, [
  94. 'thing8' => $storeTitle,
  95. 'character_string1' => $order['order_id'],
  96. 'name4' => $order['delivery_name'],
  97. 'phone_number10' => $order['delivery_id']
  98. ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
  99. }
  100. }
  101. /**
  102. * 充值金额退款
  103. * @param $uid
  104. * @param $UserRecharge
  105. * @param $now_money
  106. * @return bool|void
  107. */
  108. public function sendRechargeSuccess($uid, $UserRecharge, $now_money)
  109. {
  110. return $this->sendTemplate((int)$uid, [
  111. 'character_string1' => $UserRecharge['order_id'],
  112. 'amount3' => $UserRecharge['price'],
  113. 'amount4' => $now_money,
  114. 'date5' => date('Y-m-d H:i:s', time()),
  115. ], '/pages/users/user_bill/index?type=2');
  116. }
  117. /**
  118. * 订单退款成功发送消息
  119. * @param $uid
  120. * @param $order
  121. * @param $storeTitle
  122. * @param $data
  123. * @return bool|void
  124. */
  125. public function sendOrderRefundSuccess($uid, $order, $storeTitle, $data)
  126. {
  127. return $this->sendTemplate((int)$uid, [
  128. 'thing1' => '已成功退款',
  129. 'thing2' => $storeTitle,
  130. 'amount3' => $order['pay_price'],
  131. 'character_string6' => $data['order_id']
  132. ], '/pages/goods/order_details/index?order_id=' . $data['order_id'] . '&isReturen=1');
  133. }
  134. /**
  135. * 订单退款失败
  136. * @param $uid
  137. * @param $order
  138. * @param $storeTitle
  139. * @return bool|void
  140. */
  141. public function sendOrderRefundFail($uid, $order, $storeTitle)
  142. {
  143. return $this->sendTemplate((int)$uid, [
  144. 'thing1' => '退款失败',
  145. 'thing2' => $storeTitle,
  146. 'amount3' => $order['pay_price'],
  147. 'character_string6' => $order['order_id']
  148. ], '/pages/goods/order_details/index?order_id=' . $order['order_id'] . '&isReturen=1');
  149. }
  150. /**
  151. * 用户申请退款给管理员发送消息
  152. * @param $uid
  153. * @param $order
  154. * @return bool|void
  155. */
  156. public function sendOrderRefundStatus($uid, $order)
  157. {
  158. $data['character_string4'] = $order['order_id'];
  159. $data['date5'] = date('Y-m-d H:i:s', time());
  160. $data['amount2'] = $order['pay_price'];
  161. $data['phrase7'] = '申请退款中';
  162. $data['thing8'] = '请及时处理';
  163. return $this->sendTemplate((int)$uid, $data);
  164. }
  165. /**
  166. * 砍价成功通知
  167. * @param $uid
  168. * @param array $bargain
  169. * @param array $bargainUser
  170. * @param int $bargainUserId
  171. * @return bool|void
  172. */
  173. public function sendBargainSuccess($uid, $bargain = [], $bargainUser = [], $bargainUserId = 0)
  174. {
  175. $data['thing1'] = $bargain['title'];
  176. $data['amount2'] = $bargain['min_price'];
  177. $data['thing3'] = '恭喜您,已经砍到最低价了';
  178. return $this->sendTemplate((int)$uid, $data, '/pages/activity/goods_bargain_details/index?id=' . $bargain['id'] . '&bargain=' . $bargainUserId);
  179. }
  180. /**
  181. * 订单支付成功发送模板消息
  182. * @param $uid
  183. * @param $pay_price
  184. * @param $orderId
  185. * @return bool|void
  186. */
  187. public function sendOrderSuccess($uid, $pay_price, $orderId)
  188. {
  189. if ($orderId == '') return true;
  190. $data['character_string1'] = $orderId;
  191. $data['amount2'] = $pay_price . '元';
  192. $data['date3'] = date('Y-m-d H:i:s', time());
  193. return $this->sendTemplate((int)$uid, $data, '/pages/goods/order_details/index?order_id=' . $orderId);
  194. }
  195. /**
  196. * 会员订单支付成功发送消息
  197. * @param $uid
  198. * @param $pay_price
  199. * @param $orderId
  200. * @return bool|void
  201. */
  202. public function sendMemberOrderSuccess($uid, $pay_price, $orderId)
  203. {
  204. if ($orderId == '') return true;
  205. $data['character_string1'] = $orderId;
  206. $data['amount2'] = $pay_price . '元';
  207. $data['date3'] = date('Y-m-d H:i:s', time());
  208. return $this->sendTemplate((int)$uid, $data, '/pages/annex/vip_paid/index');
  209. }
  210. /**
  211. * 提现失败
  212. * @param $uid
  213. * @param $msg
  214. * @param $extract_number
  215. * @param $nickname
  216. * @return bool|void
  217. */
  218. public function sendExtractFail($uid, $msg, $extract_number, $nickname)
  219. {
  220. return $this->sendTemplate((int)$uid, [
  221. 'thing1' => '提现失败:' . $msg,
  222. 'amount2' => $extract_number . '元',
  223. 'thing3' => $nickname,
  224. 'date4' => date('Y-m-d H:i:s', time())
  225. ], '/pages/users/user_spread_money/index?type=1');
  226. }
  227. /**
  228. * 提现成功
  229. * @param $uid
  230. * @param $extract_number
  231. * @param $nickname
  232. * @return bool|void
  233. */
  234. public function sendExtractSuccess($uid, $extract_number, $nickname)
  235. {
  236. return $this->sendTemplate((int)$uid, [
  237. 'thing1' => '提现成功',
  238. 'amount2' => $extract_number . '元',
  239. 'thing3' => $nickname,
  240. 'date4' => date('Y-m-d H:i:s', time())
  241. ], '/pages/users/user_spread_money/index?type=1');
  242. }
  243. /**
  244. * 拼团成功通知
  245. * @param $uid
  246. * @param $pinkTitle
  247. * @param $nickname
  248. * @param $pinkTime
  249. * @param $count
  250. * @param string $link
  251. * @return bool|void
  252. */
  253. public function sendPinkSuccess($uid, $pinkTitle, $nickname, $pinkTime, $count, string $link = '')
  254. {
  255. return $this->sendTemplate((int)$uid, [
  256. 'thing1' => $pinkTitle,
  257. 'thing12' => $nickname,
  258. 'date5' => date('Y-m-d H:i:s', $pinkTime),
  259. 'number2' => $count
  260. ], $link);
  261. }
  262. /**
  263. * 拼团状态通知
  264. * @param $uid
  265. * @param $pinkTitle
  266. * @param $count
  267. * @param $remarks
  268. * @param $link
  269. * @return bool|void
  270. */
  271. public function sendPinkFail($uid, $pinkTitle, $count, $remarks, $link)
  272. {
  273. return $this->sendTemplate((int)$uid, [
  274. 'thing2' => $pinkTitle,
  275. 'thing1' => $count,
  276. 'thing3' => $remarks
  277. ], $link);
  278. }
  279. /**
  280. * 赠送积分消息提醒
  281. * @param $uid
  282. * @param $order
  283. * @param $storeTitle
  284. * @param $gainIntegral
  285. * @param $integral
  286. * @return bool|void
  287. */
  288. public function sendUserIntegral($uid, $order, $storeTitle, $gainIntegral, $integral)
  289. {
  290. if (!$order || !$uid) return true;
  291. if (is_string($order['cart_id']))
  292. $order['cart_id'] = json_decode($order['cart_id'], true);
  293. return $this->sendTemplate((int)$uid, [
  294. 'character_string2' => $order['order_id'],
  295. 'thing3' => $storeTitle,
  296. 'amount4' => $order['pay_price'],
  297. 'number5' => $gainIntegral,
  298. 'number6' => $integral
  299. ], '/pages/users/user_integral/index');
  300. }
  301. /**
  302. * 获得推广佣金发送提醒
  303. * @param $uid
  304. * @param string $brokeragePrice
  305. * @param string $goods_name
  306. * @return bool|void
  307. */
  308. public function sendOrderBrokerageSuccess($uid, string $brokeragePrice, string $goods_name)
  309. {
  310. return $this->sendTemplate((int)$uid, [
  311. 'thing2' => $goods_name,
  312. 'amount4' => $brokeragePrice . '元',
  313. 'time1' => date('Y-m-d H:i:s', time())
  314. ], '/pages/users/user_spread_user/index');
  315. }
  316. /**
  317. * 绑定推广关系发送消息提醒
  318. * @param $uid
  319. * @param string $userName
  320. * @return bool|void
  321. */
  322. public function sendBindSpreadUidSuccess($uid, string $userName)
  323. {
  324. return $this->sendTemplate((int)$uid, [
  325. 'name3' => $userName . "加入您的团队",
  326. 'date4' => date('Y-m-d H:i:s', time())
  327. ], '/pages/users/user_spread_user/index');
  328. }
  329. }