123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445 |
- <?php
- namespace app\jobs\notice\template;
- use app\services\message\TemplateMessageServices;
- use crmeb\basic\BaseJobs;
- use crmeb\services\wechat\OfficialAccount;
- use crmeb\traits\QueueTrait;
- use crmeb\services\template\Template;
- use think\facade\Log;
- use think\facade\Route;
- class WechatTemplateJob extends BaseJobs
- {
- use QueueTrait;
-
- public function doJob(array $template)
- {
- if ($template) {
- try {
-
-
- $list = OfficialAccount::getPrivateTemplates();
- foreach ($list['template_list'] as $v) {
-
- OfficialAccount::deleleTemplate($v['template_id']);
- }
-
- $templateMessageServices = app()->make(TemplateMessageServices::class);
- foreach ($template as $temp) {
- $keywordList = [];
- $content = is_array($temp['content']) ? $temp['content'] : explode("\n", $temp['content']);
- foreach ($content as $c) {
- $name = explode('{{', $c)[0] ?? '';
- if ($name) {
- $keywordList[] = $name;
- }
- }
- if(!$keywordList) continue;
-
- $res = OfficialAccount::addTemplateId($temp['tempkey'], $keywordList);
- if (!$res['errcode'] && $res['template_id']) {
- $templateMessageServices->update($temp['id'], ['tempid' => $res['template_id']]);
- }
- }
- } catch (\Throwable $e) {
- Log::error('同步订阅消息失败,原因:' . $e->getMessage());
- }
- }
- return true;
- }
-
- public function sendOrderPaySuccess($openid, $order)
- {
- return $this->sendTemplate('ORDER_PAY_SUCCESS', $openid, [
- 'first' => '亲,您购买的商品已支付成功',
- 'keyword1' => $order['order_id'],
- 'keyword2' => $order['pay_price'],
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'])->suffix('')->domain(false)->build());
- }
-
- public function sendMemberOrderPaySuccess($openid, $order)
- {
- return $this->sendTemplate('ORDER_PAY_SUCCESS', $openid, [
- 'first' => '亲,购买会员成功,恭喜您成为本平台尊贵会员!',
- 'keyword1' => $order['order_id'],
- 'keyword2' => $order['pay_price'],
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/annex/vip_paid/index')->suffix('')->domain(false)->build());
- }
-
- public function sendServiceNoticeNew($openid, $data, $url)
- {
- return $this->sendTemplate('SERVICE_NOTICE_NEW', $openid, [
- 'first' => $data['first'],
- 'keyword1' => $data['keyword1'],
- 'keyword2' => $data['keyword2'],
- 'keyword3' => $data['keyword3'],
- 'remark' => $data['remark']
- ], $url);
- }
-
- public function sendOrderDeliver($openid, string $goodsName, $order, array $data)
- {
- return $this->sendTemplate('ORDER_DELIVER_SUCCESS', $openid, [
- 'keyword1' => $goodsName,
- 'keyword2' => $order['pay_type'] == 'offline' ? '线下支付' : date('Y/m/d H:i', $order['pay_time']),
- 'keyword3' => $order['user_address'],
- 'keyword4' => $data['delivery_name'],
- 'keyword5' => $data['delivery_id'],
- 'first' => '亲,您的订单已发货,请注意查收',
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'])->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPostage($openid, $order, array $data)
- {
- return $this->sendTemplate('ORDER_POSTAGE_SUCCESS', $openid, [
- 'keyword1' => $order['order_id'],
- 'keyword2' => $data['delivery_name'],
- 'keyword3' => $data['delivery_id'],
- 'first' => '亲,您的订单已发货,请注意查收',
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'])->suffix(false)->domain(false)->build());
- }
-
- public function sendServiceNotice($openid, $data, ?string $link = null)
- {
- return $this->sendTemplate('ADMIN_NOTICE', $openid, $data, $link);
- }
-
- public function sendRefundServiceNotice($openid, $data, ?string $link = null)
- {
- return $this->sendTemplate('ADMIN_NOTICE', $openid, $data, $link);
- }
-
- public function sendOrderTakeSuccess($openid, $order, $title)
- {
- return $this->sendTemplate('ORDER_TAKE_SUCCESS', $openid, [
- 'first' => '亲,您的订单已收货',
- 'keyword1' => $order['order_id'],
- 'keyword2' => '已收货',
- 'keyword3' => date('Y-m-d H:i:s', time()),
- 'keyword4' => $title,
- 'remark' => '感谢您的光临!'
- ]);
- }
-
- public function sendOrderApplyRefund($openid, $order)
- {
- return $this->sendTemplate('ORDER_REFUND_STATUS', $openid, [
- 'amount2' => bcadd((string)$order['pay_price'],'0',2),
- 'time4' => date('Y-m-d H:i:s', $order['add_time']),
- 'character_string5' => $order['order_id']
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'])->suffix('')->domain(false)->build());
- }
-
- public function sendOrderRefundSuccess($openid, array $data, $order)
- {
- return $this->sendTemplate('ORDER_REFUND_STATUS', $openid, [
- 'first' => '亲,您购买的商品已退款,本次退款' . $data['refund_price'] . '金额',
- 'keyword1' => $order['order_id'],
- 'keyword2' => $order['pay_price'],
- 'keyword3' => date('Y-m-d H:i:s', $order['add_time']),
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'] . '&isReturen=1')->suffix('')->domain(false)->build());
- }
-
- public function sendOrderRefundNoStatus($openid, $order)
- {
- return $this->sendTemplate('ORDER_REFUND_STATUS', $openid, [
- 'first' => '亲,您的退款申请未申请通过',
- 'keyword1' => $order['order_id'],
- 'keyword2' => $order['pay_price'],
- 'keyword3' => date('Y-m-d H:i:s', $order['add_time']),
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/order_details/index?order_id=' . $order['order_id'])->suffix('')->domain(false)->build());
- }
-
- public function sendRechargeRefundStatus($openid, array $data, $userRecharge)
- {
- return $this->sendTemplate('ORDER_REFUND_STATUS', $openid, [
- 'first' => '亲,您充值的金额已退款,本次退款' .
- $data['refund_price'] . '金额',
- 'keyword1' => $userRecharge['order_id'],
- 'keyword2' => $userRecharge['price'],
- 'keyword3' => date('Y-m-d H:i:s', $userRecharge['add_time']),
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/user_bill/index')->domain(false)->suffix(false)->build());
- }
-
- public function sendUserBalanceChangeFial($openid, $extract_number, $fail_msg)
- {
- return $this->sendTemplate('USER_BALANCE_CHANGE', $openid, [
- 'first' => '提现失败,退回佣金' . $extract_number . '元',
- 'keyword1' => '佣金提现',
- 'keyword2' => date('Y-m-d H:i:s', time()),
- 'keyword3' => $extract_number,
- 'remark' => '错误原因:' . $fail_msg
- ], sys_config('site_url') . Route::buildUrl('/pages/users/user_spread_money/index?type=1')->suffix(false)->domain(false)->build());
- }
-
- public function sendUserBalanceChangeSuccess($openid, $extractNumber)
- {
- return $this->sendTemplate('USER_BALANCE_CHANGE', $openid, [
- 'first' => '成功提现佣金' . $extractNumber . '元',
- 'keyword1' => '佣金提现',
- 'keyword2' => date('Y-m-d H:i:s', time()),
- 'keyword3' => $extractNumber,
- 'remark' => '点击查看我的佣金明细'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/user_spread_money/index?type=1')->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPinkSuccess($openid, $order_id, $pinkId, $title)
- {
- return $this->sendTemplate('ORDER_USER_GROUPS_SUCCESS', $openid, [
- 'first' => '亲,您的拼团已经完成了',
- 'keyword1' => $order_id,
- 'keyword2' => $title,
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_combination_status/index?id=' . $pinkId)->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPinkUseSuccess($openid, string $order_id, string $title, int $pink_id)
- {
- return $this->sendTemplate('ORDER_USER_GROUPS_SUCCESS', $openid, [
- 'first' => '亲,您已成功参与拼团',
- 'keyword1' => $order_id,
- 'keyword2' => $title,
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_combination_status/index?id=' . $pink_id)->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPinkClone($openid, $pink, $title)
- {
- return $this->sendTemplate('ORDER_USER_GROUPS_LOSE', $openid, [
- 'first' => '亲,您的拼团取消',
- 'keyword1' => $title,
- 'keyword2' => $pink->price,
- 'keyword3' => $pink->price,
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_combination_status/index?id=' . $pink->id)->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPinkFial($openid, $pink, $title)
- {
- return $this->sendTemplate('ORDER_USER_GROUPS_LOSE', $openid, [
- 'first' => '亲,您的拼团失败',
- 'keyword1' => $title,
- 'keyword2' => $pink->price,
- 'keyword3' => $pink->price,
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_combination_status/index?id=' . $pink->id)->suffix(false)->domain(false)->build());
- }
-
- public function sendOrderPinkOpenSuccess($openid, $pink, $title)
- {
- return $this->sendTemplate('OPEN_PINK_SUCCESS', $openid, [
- 'first' => '您好,您已成功开团!赶紧与小伙伴们分享吧!!!',
- 'keyword1' => $title,
- 'keyword2' => $pink['total_price'],
- 'keyword3' => $pink['people'],
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_combination_status/index?id=' . $pink['id'])->suffix(false)->domain(false)->build());
- }
-
- public function sendBargainSuccess($openid, $bargain, $bargainUser = [], $bargainUserId = 0)
- {
- return $this->sendTemplate('BARGAIN_SUCCESS', $openid, [
- 'first' => '好腻害!你的朋友们已经帮你砍到底价了!',
- 'keyword1' => $bargain['title'],
- 'keyword2' => $bargain['min_price'],
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/activity/goods_bargain_details/index?id=' . $bargain['id'] . '&bargain=' . $bargainUserId)->suffix(false)->domain(false)->build());
- }
-
- public function sendTemplate(string $tempCode, $openid, array $data, string $link = null, string $color = null)
- {
- try {
- if (!$openid) return true;
- $template = new Template('wechat');
- $template->to($openid)->color($color);
- if ($link) $template->url($link);
- return $template->send($tempCode, $data);
- } catch (\Exception $e) {
- Log::error('发送模版消息失败,原因:' . $e->getMessage());
- return true;
- }
- }
-
- public function sendOrderBrokerageSuccess(string $openid, string $brokeragePrice, string $goodsName, string $goodsPrice, $orderTime)
- {
- return $this->sendTemplate('ORDER_BROKERAGE', $openid, [
- 'first' => '亲,您有一笔佣金入账!',
- 'keyword1' => $goodsName,
- 'keyword2' => $goodsPrice . "元",
- 'keyword3' => $brokeragePrice . "元",
- 'keyword4' => date('Y-m-d H:i:s', $orderTime),
- 'remark' => '点击查看订单详情'
- ], sys_config('site_url') . Route::buildUrl('/pages/users/user_spread_user/index')->suffix('')->domain(false)->build());
- }
- }
|