123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350 |
- <?php
- // +----------------------------------------------------------------------
- // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
- // +----------------------------------------------------------------------
- // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
- // +----------------------------------------------------------------------
- // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
- // +----------------------------------------------------------------------
- // | Author: CRMEB Team <admin@crmeb.com>
- // +----------------------------------------------------------------------
- namespace app\services\message\notice;
- use app\jobs\TemplateJob;
- use app\services\message\NoticeService;
- use app\services\user\UserServices;
- use app\services\wechat\WechatUserServices;
- use think\facade\Log;
- /**
- * 小程序模板消息消息队列
- * Class RoutineTemplateJob
- * @package crmeb\jobs
- */
- class RoutineTemplateListService extends NoticeService
- {
- /**
- * 根据UID获取openid
- * @param int $uid
- * @return mixed
- */
- public function getOpenidByUid(int $uid)
- {
- $isDel = app()->make(UserServices::class)->value(['uid' => $uid], 'is_del');
- if ($isDel) {
- $openid = '';
- } else {
- $openid = app()->make(WechatUserServices::class)->uidToOpenid($uid, 'routine');
- }
- return $openid;
- }
- /**
- * 发送模板消息
- * @param int $uid
- * @param array $data
- * @param string|null $link
- * @param string|null $color
- * @return bool|void
- */
- public function sendTemplate(int $uid, array $data, string $link = null, string $color = null)
- {
- try {
- if ($this->noticeInfo['is_routine'] == 1) {
- $openid = $this->getOpenidByUid($uid);
- //放入队列执行
- TemplateJob::dispatch('doJob', ['subscribe', $openid, $this->noticeInfo['routine_tempid'], $data, $link, $color]);
- }
- } catch (\Exception $e) {
- Log::error($e->getMessage());
- return true;
- }
- }
- /**
- * 确认收货
- * @param $uid
- * @param $order
- * @param $title
- * @return bool|void
- */
- public function sendOrderTakeOver($uid, $order, $title)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => $order['order_id'],
- 'thing2' => $title,
- 'date5' => date('Y-m-d H:i:s', time()),
- ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
- }
- /**
- * 发货订阅消息
- * @param $uid
- * @param $order
- * @param $storeTitle
- * @param int $isGive
- * @return bool|void
- */
- public function sendOrderPostage($uid, $order, $storeTitle, int $isGive = 0)
- {
- if ($isGive) {//快递发货
- return $this->sendTemplate((int)$uid, [
- 'character_string2' => $order['delivery_id'],
- 'thing1' => $order['delivery_name'],
- 'time3' => date('Y-m-d H:i:s', time()),
- 'thing5' => $storeTitle,
- ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
- } else {//同城配送
- return $this->sendTemplate((int)$uid, [
- 'thing8' => $storeTitle,
- 'character_string1' => $order['order_id'],
- 'name4' => $order['delivery_name'],
- 'phone_number10' => $order['delivery_id']
- ], '/pages/goods/order_details/index?order_id=' . $order['order_id']);
- }
- }
- /**
- * 充值金额退款
- * @param $uid
- * @param $UserRecharge
- * @param $now_money
- * @return bool|void
- */
- public function sendRechargeSuccess($uid, $UserRecharge, $now_money)
- {
- return $this->sendTemplate((int)$uid, [
- 'character_string1' => $UserRecharge['order_id'],
- 'amount3' => $UserRecharge['price'],
- 'amount4' => $now_money,
- 'date5' => date('Y-m-d H:i:s', time()),
- ], '/pages/users/user_bill/index?type=2');
- }
- /**
- * 订单退款成功发送消息
- * @param $uid
- * @param $order
- * @param $storeTitle
- * @param $data
- * @return bool|void
- */
- public function sendOrderRefundSuccess($uid, $order, $storeTitle, $data)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => '已成功退款',
- 'thing2' => $storeTitle,
- 'amount3' => $order['pay_price'],
- 'character_string6' => $data['order_id']
- ], '/pages/goods/order_details/index?order_id=' . $data['order_id'] . '&isReturen=1');
- }
- /**
- * 订单退款失败
- * @param $uid
- * @param $order
- * @param $storeTitle
- * @return bool|void
- */
- public function sendOrderRefundFail($uid, $order, $storeTitle)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => '退款失败',
- 'thing2' => $storeTitle,
- 'amount3' => $order['pay_price'],
- 'character_string6' => $order['order_id']
- ], '/pages/goods/order_details/index?order_id=' . $order['order_id'] . '&isReturen=1');
- }
- /**
- * 用户申请退款给管理员发送消息
- * @param $uid
- * @param $order
- * @return bool|void
- */
- public function sendOrderRefundStatus($uid, $order)
- {
- $data['character_string4'] = $order['order_id'];
- $data['date5'] = date('Y-m-d H:i:s', time());
- $data['amount2'] = $order['pay_price'];
- $data['phrase7'] = '申请退款中';
- $data['thing8'] = '请及时处理';
- return $this->sendTemplate((int)$uid, $data);
- }
- /**
- * 砍价成功通知
- * @param $uid
- * @param array $bargain
- * @param array $bargainUser
- * @param int $bargainUserId
- * @return bool|void
- */
- public function sendBargainSuccess($uid, $bargain = [], $bargainUser = [], $bargainUserId = 0)
- {
- $data['thing1'] = $bargain['title'];
- $data['amount2'] = $bargain['min_price'];
- $data['thing3'] = '恭喜您,已经砍到最低价了';
- return $this->sendTemplate((int)$uid, $data, '/pages/activity/goods_bargain_details/index?id=' . $bargain['id'] . '&bargain=' . $bargainUserId);
- }
- /**
- * 订单支付成功发送模板消息
- * @param $uid
- * @param $pay_price
- * @param $orderId
- * @return bool|void
- */
- public function sendOrderSuccess($uid, $pay_price, $orderId)
- {
- if ($orderId == '') return true;
- $data['character_string1'] = $orderId;
- $data['amount2'] = $pay_price . '元';
- $data['date3'] = date('Y-m-d H:i:s', time());
- return $this->sendTemplate((int)$uid, $data, '/pages/goods/order_details/index?order_id=' . $orderId);
- }
- /**
- * 会员订单支付成功发送消息
- * @param $uid
- * @param $pay_price
- * @param $orderId
- * @return bool|void
- */
- public function sendMemberOrderSuccess($uid, $pay_price, $orderId)
- {
- if ($orderId == '') return true;
- $data['character_string1'] = $orderId;
- $data['amount2'] = $pay_price . '元';
- $data['date3'] = date('Y-m-d H:i:s', time());
- return $this->sendTemplate((int)$uid, $data, '/pages/annex/vip_paid/index');
- }
- /**
- * 提现失败
- * @param $uid
- * @param $msg
- * @param $extract_number
- * @param $nickname
- * @return bool|void
- */
- public function sendExtractFail($uid, $msg, $extract_number, $nickname)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => '提现失败:' . $msg,
- 'amount2' => $extract_number . '元',
- 'thing3' => $nickname,
- 'date4' => date('Y-m-d H:i:s', time())
- ], '/pages/users/user_spread_money/index?type=1');
- }
- /**
- * 提现成功
- * @param $uid
- * @param $extract_number
- * @param $nickname
- * @return bool|void
- */
- public function sendExtractSuccess($uid, $extract_number, $nickname)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => '提现成功',
- 'amount2' => $extract_number . '元',
- 'thing3' => $nickname,
- 'date4' => date('Y-m-d H:i:s', time())
- ], '/pages/users/user_spread_money/index?type=1');
- }
- /**
- * 拼团成功通知
- * @param $uid
- * @param $pinkTitle
- * @param $nickname
- * @param $pinkTime
- * @param $count
- * @param string $link
- * @return bool|void
- */
- public function sendPinkSuccess($uid, $pinkTitle, $nickname, $pinkTime, $count, string $link = '')
- {
- return $this->sendTemplate((int)$uid, [
- 'thing1' => $pinkTitle,
- 'thing12' => $nickname,
- 'date5' => date('Y-m-d H:i:s', $pinkTime),
- 'number2' => $count
- ], $link);
- }
- /**
- * 拼团状态通知
- * @param $uid
- * @param $pinkTitle
- * @param $count
- * @param $remarks
- * @param $link
- * @return bool|void
- */
- public function sendPinkFail($uid, $pinkTitle, $count, $remarks, $link)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing2' => $pinkTitle,
- 'thing1' => $count,
- 'thing3' => $remarks
- ], $link);
- }
- /**
- * 赠送积分消息提醒
- * @param $uid
- * @param $order
- * @param $storeTitle
- * @param $gainIntegral
- * @param $integral
- * @return bool|void
- */
- public function sendUserIntegral($uid, $order, $storeTitle, $gainIntegral, $integral)
- {
- if (!$order || !$uid) return true;
- if (is_string($order['cart_id']))
- $order['cart_id'] = json_decode($order['cart_id'], true);
- return $this->sendTemplate((int)$uid, [
- 'character_string2' => $order['order_id'],
- 'thing3' => $storeTitle,
- 'amount4' => $order['pay_price'],
- 'number5' => $gainIntegral,
- 'number6' => $integral
- ], '/pages/users/user_integral/index');
- }
- /**
- * 获得推广佣金发送提醒
- * @param $uid
- * @param string $brokeragePrice
- * @param string $goods_name
- * @return bool|void
- */
- public function sendOrderBrokerageSuccess($uid, string $brokeragePrice, string $goods_name)
- {
- return $this->sendTemplate((int)$uid, [
- 'thing2' => $goods_name,
- 'amount4' => $brokeragePrice . '元',
- 'time1' => date('Y-m-d H:i:s', time())
- ], '/pages/users/user_spread_user/index');
- }
- /**
- * 绑定推广关系发送消息提醒
- * @param $uid
- * @param string $userName
- * @return bool|void
- */
- public function sendBindSpreadUidSuccess($uid, string $userName)
- {
- return $this->sendTemplate((int)$uid, [
- 'name3' => $userName . "加入您的团队",
- 'date4' => date('Y-m-d H:i:s', time())
- ], '/pages/users/user_spread_user/index');
- }
- }
|