|
|
<?php
namespace App\Service\v3\Implementations;
use App\Model\v3\Order;use App\Model\v3\OrderGoods;use App\Model\v3\OrderMain;use App\Model\v3\Store;use App\Model\v3\User;use App\Service\v3\Interfaces\MiniprogramServiceInterface;use EasyWeChat\Factory;use Hyperf\Guzzle\CoroutineHandler;
class MiniprogramService implements MiniprogramServiceInterface{
/** * @inheritDoc */ public function sendTemMsgForOnlineOrder($globalOrderId) {
// 查询订单信息
$order = OrderMain::query()->where(['global_order_id' => $globalOrderId])->first()->toArray();
$payTypes = ['1' => '微信支付', '2' => '余额支付', '3' => '积分支付', '4' => '货到付款']; $address_store = $order['address'] . '；' .$order['name']. '；'. substr_replace($order['tel'],'****',3,4); $address = $order['address'] . '；' .$order['name']. '；'. $order['tel'];
// 查询子订单，用于发消息给商户
$order_children = Order::query() ->with('orderMain') ->where(['order_main_id' => $globalOrderId]) ->get();
$goods_temp_all = []; foreach ($order_children as $key => &$item) {
// 订单商品
$order_goods = OrderGoods::query() ->where(['order_id' => $item->id]) ->get() ->toArray();
$goods_temp = []; foreach ($order_goods as $k => &$goods) { array_push($goods_temp, $goods['name']."*".$goods['number']."/".($goods['goods_unit'])); array_push($goods_temp_all, $goods['name']."*".$goods['number']."/".($goods['goods_unit'])); }
// 商户/门店的openid
$store = Store::query()->select(['id', 'name', 'user_id']) ->where(['id' => $item->store_id]) ->first()->toArray(); $store['openid'] = User::query() ->where(['id' => $store['user_id']]) ->value('openid');
// 模板数据
$data_store = [ 'first' => ['您有新的外卖订单！订单编号：'.$item->order_num, '#ff0000'], 'keyword' => [ ["您的外卖订单详情：\r\n".implode(";\r\n",$goods_temp), '#ff0000'], $item->money, $payTypes[$order['pay_type']], $item->created_at_text??'', $address_store, ], 'remark' => [$item->note, '#4e6ef2'] ];
$ret_store = $this->sendTempMsg($store['openid'], '-M7DG_ACwJxqdAvyvJuAnPpx4xaLf3VkkN0fckno71c',$data_store); }
// 模板数据发送消息给用户
$data_user = [ 'first' => '您好，下单成功！订单编号：'.$order['global_order_id'], 'keyword' => [ implode(";\r\n", $goods_temp_all), $order['money'], $payTypes[$order['pay_type']], $order['created_at_text'], $address, ], 'remark' => '感谢您的光临，欢迎下次再来！' ];
// 获取用户openid，发送给用户
$user_openid = User::query()->where(['id' => $order['user_id']])->value('openid'); $ret_user = $this->sendTempMsg($user_openid,'-M7DG_ACwJxqdAvyvJuAnPpx4xaLf3VkkN0fckno71c', $data_user);
}
/** * @inheritDoc */ public function sendTemMsgForOfflineOrder($globalOrderId) {
// 查询子订单，用于发消息给商户
$order_children = Order::query() ->where(['order_main_id' => $globalOrderId]) ->get() ->toArray();
foreach ($order_children as $key => &$item) { // 商户/门店的openid
$store = Store::query() ->where(['id' => $item['store_id']]) ->first()->toArray(); $store['openid'] = User::query() ->where(['id' => $store['user_id']]) ->value('openid');
// 模板数据
$data_store = [ 'first' => '您有新订单收入！订单编号：'.$item['order_num'], 'keyword' => [ $store['name']?:'', $item['created_at_text']??'', '暂无', $item['money'] ], 'remark' => '感谢您的使用！' ];
// $ret_store = $this->sendTempMsg($store['openid'], 'lxVbC6PVpKbiO44bYqLmacl-BaME70D47Q0jn2Link0',$data_store);
$ret_store = $this->sendTempMsg( $store['openid'], 'b9SR_3j6GhJvVjuIoYlil4-m09plcjNnI5lls1wHfpo', $data_store, true, '/pages/orderDetail/orderDetail?global_order_id='.$globalOrderId, '1461', $item['money'] ); }
}
/** * @inheritDoc */ public function sendTemMsgForAward($money, $note, $openid, $time) { // 模板数据发送消息给用户
$data_user = [ 'first' => '恭喜！您有一笔新的奖励收入！', 'keyword' => [ $money, $note, $time ], 'remark' => '感谢您的使用！' ];
// 获取用户openid，发送给用户
$ret_user = $this->sendTempMsg($openid,'ypZ7xdHUjWrRG8P-MD42dhpp6kUlh4Unoh7eTSrLZEg', $data_user); }
/** * @inheritDoc */ public function sendTempMsg($openid, $template_id, $data, $isApplet = false, $redirect_url = '', $appletFormId = '', $appletEmKeyword = '', $applet_config = ['appid' => '', 'pagepath' => '']) { if (empty($openid) || empty($template_id) || empty($data)) { return ; }
// 先拼个基础的
$template = [ 'touser' => $openid, 'mp_template_msg' => [ 'appid' => config('wechat.official.app_id'), 'template_id' => $template_id, 'url' => $redirect_url, ] ];
if ($isApplet) { $template['weapp_template_msg'] = [ 'template_id' => $template_id, 'page' => $redirect_url, 'form_id' => $appletFormId, 'emphasis_keyword' => $appletEmKeyword, ]; }
// 看看有没有小程序跳转的要求
$template['mp_template_msg']['miniprogram'] = $applet_config;
// 重点来了，拼接关键数据data
if (!is_array($data)) { # 数组都不是，请回去
return false; }
if ( !$isApplet ) { if (is_array($data['first'])) { $template['mp_template_msg']['data']['first']['value'] = $data['first'][0] ?? ''; $template['mp_template_msg']['data']['first']['color'] = $data['first'][1] ?? ''; } else { $template['mp_template_msg']['data']['first']['value'] = $data['first']; }
if (isset($data['keyword'])&&is_array($data['keyword'])) { foreach ($data['keyword'] as $key => &$keyword) { $index = $key+1;
if (is_array($keyword)) { $template['mp_template_msg']['data']['keyword'.$index]['value'] = $keyword[0] ?? ''; $template['mp_template_msg']['data']['keyword'.$index]['color'] = $keyword[1] ?? ''; } else { $template['mp_template_msg']['data']['keyword'.$index]['value'] = $keyword; }
} }
if (is_array($data['remark'])) { $template['mp_template_msg']['data']['remark']['value'] = $data['remark'][0] ?? ''; $template['mp_template_msg']['data']['remark']['color'] = $data['remark'][1] ?? ''; } else { $template['mp_template_msg']['data']['remark']['value'] = $data['remark']; } } else { if (isset($data['keyword'])&&is_array($data['keyword'])) { foreach ($data['keyword'] as $key => &$keyword) { $index = $key+1;
if (is_array($keyword)) { $template['weapp_template_msg']['data']['keyword'.$index]['value'] = $keyword[0] ?? ''; } else { $template['weapp_template_msg']['data']['keyword'.$index]['value'] = $keyword; }
} } }
$app = Factory::miniProgram(config('wechat.applet')); $app['guzzle_handler'] = CoroutineHandler::class; $app->uniform_message->send($template); }
}
|
