<?php

namespace app\common\service\message;

use app\common\library\easywechat\AppWx;

/**
 * 微信小程序消息通知服务
 */
class WxMessageService
{
    /**
     * 订单支付成功后通知
     */
    public static function send($data, $wx_template, $touser, $app_id)
    {
        try{
            $wx_template = json_decode($wx_template, true);

            $var_data = $wx_template['var_data'];
            $send_data = [];
            foreach ($var_data as $key => $value){
                if(isset($data[$key])){
                    $send_data[$value['field_name']] = [
                        'value' => urldecode($data[$key])
                    ];
                }else{
                    $send_data[$value['field_name']] = [
                        'value' => urldecode($value['filed_value'])
                    ];
                }
            }


            foreach($send_data as $key => $value){
                if(mb_strlen($value['value']) > 20){
                    $send_data[$key]['value'] = mb_substr($value['value'],0, 20);
                }
            }

            $app = AppWx::getApp($app_id);
            $result = $app->subscribe_message->send([
                'template_id' => $wx_template['template_id'],
                'touser' => $touser,
                'page' => '/pages/index/index',
                'data' => $send_data,
            ]);

            log_write($result);
        }catch (\Exception $e){
            log_write('小程序订阅消息发送失败');
            log_write($e->getMessage());
        }
    }

}