<?php

/**
 * @author Any
 * @description KISS
 * @date 2020-12-2
 * @version 1.0.0
 *
 * _____LOG_____
 *
 */

namespace app\modules\api\models;

use app\components\SiteHelper;
use app\components\sms\AliSmsMsgSender;
use app\models\Box;
use app\models\DevList;
use app\models\MsgCentre;
use app\models\OrderDetail;
use app\models\OrderSale;
use app\models\sms\SmsMsgHelper;
use app\models\sms\SmsSetting;
use app\models\sms\SmsTpl;
use app\models\Store;
use app\models\StoreUser;
use app\models\User;
use app\models\UserCoupon;
use app\modules\api\components\ApiHelper;
use function AlibabaCloud\Client\value;
use yii\data\Pagination;


class MsgCentreForm extends ApiModel
{

    /**
     * 创建消息
     * @param $store_id int 门店id
     * @param $type int 1=租赁消息2=归还消息3=售后消息4=报警消息
     * @param $data array ball_mark球车型号,ball_cart球车名称,start_date开始时间,end_date结束日期,price金额,object_id订单id
     * @return array|void
     */
    public static function add($store_id,$type,$data)
    {
        $store_user_ids = StoreUser::find()->where([
            'is_delete' => 0,
            'status' => 0,
            'store_id' => $store_id,
            'user_type' => [1,2]
        ])->select('user_id')->column();
        $store_user_ids = empty($store_user_ids) ? [] : $store_user_ids;

        // $boss_ids = User::find()->where(['is_delete' => 0,'type' => User::TYPE_ADMIN_STAFF])->select('id')->column();
        $boss_ids = empty($boss_ids) ? [] : $boss_ids;
        $user_ids = array_merge($store_user_ids,$boss_ids);
        // $user_ids = [3];
        if(empty($user_ids)){
            return ['code' => 0,'msg' => '无需处理消息'];
        }
        if($type == '1'){
            $title = '球车租赁消息通知';
            $content = json_encode($data,JSON_UNESCAPED_UNICODE);
        }elseif ($type == '2'){
            $title = '球车还车消息通知';
            $content = json_encode($data,JSON_UNESCAPED_UNICODE);
        }elseif ($type == '3') {
            $title = '有新的待处理售后';
            $content = '有一笔新的待处理售后订单需要处理 进入查看并处理退款订单';
        }
        $array = [];
        foreach ($user_ids as $item){
            array_push($array,[$type,$title,$content,$item,0,time(),$data['object_id']]);
        }
        $chunk = array_chunk($array,300);
        $key = ['type','title','content','user_id','is_admin_send','created_at','object_id'];
        foreach ($chunk as $index => $value){
            \Yii::$app->db->createCommand()->batchInsert(MsgCentre::tableName(),$key, $value)->execute();
        }

        //判断是否在发送短信时间段
        $redis_name = "api:cxaibc:send:send_time";
        $send_time = \Yii::$app->redis->get($redis_name);
        if(empty($send_time)){
            return ['code' => 0,'msg' =>"成功发送"];
        }
        $send_time = explode(' - ',$send_time);
        $send_time_arr0 = explode(':',$send_time[0]);
        $send_time_arr1 = explode(':',$send_time[1]);
        $begin=mktime($send_time_arr0[0],$send_time_arr0[1],$send_time_arr0[2],date('m'),date('d'),date('Y'));
        $end = mktime($send_time_arr1[0],$send_time_arr1[1],$send_time_arr1[2],date('m'),date('d'),date('Y'));
        if(time() < $begin || time() > $end){
            \Yii::info(json_encode($data,JSON_UNESCAPED_UNICODE).'__不在发送短信区间','ball_sms');
            return ['code' => 0,'msg' =>"不在发送短信区间"];
        }

        $sms_sender = SmsSetting::findOne(['cx_mch_id' => 0]);
        if($type == '2' && $sms_sender->is_prod == '1' && $sms_sender->type == 0 && !empty($sms_sender->access_key_id) && !empty($sms_sender->access_secret) && !empty($sms_sender->sign_name)){
            \Yii::info($data['ball_cart'].'__进入发送短信','ball_sms');
            $length = 50;
            $users = User::find()->where(['is_delete' => 0,'status' => 0,'id' => $user_ids])->select('real_name as name,mobile_phone')->asArray()->all();
            $users_check = array_chunk($users,$length);
            $tpl_type_key = SmsTpl::getTplKey(6);
            $sms = SmsTpl::findOne(['key' => $tpl_type_key,'is_delete' => 0,'type' => 0]);
            if($sms != null && !empty($users_check)){
                \Yii::info(json_encode($users_check,JSON_UNESCAPED_UNICODE).'__存在数据','ball_sms');
                $tpl_type = $sms->tpl_code;
                foreach ($users_check as $index => &$item){

                    foreach ($item as $index2 => &$item2){
                        $redis_name = "api:cxaibc:gh:send_sms:{$item2['mobile_phone']}";
                        $get = \Yii::$app->redis->get($redis_name);
                        if($get == 'nosend'){
                            // 跳过短信发送
                            unset($item[$index2]);
                        }else{
                            $item2['numbers'] = $data['ball_cart'];
                        }
                    }
                    if(empty($item)){
                        continue;
                    }
                    $item = array_values($item);
                    $count = count($item);
                    $mobile_phones = array_column($item,'mobile_phone');
                    $sign_names = array_pad([],$count,$sms_sender->sign_name);

                    $sms_senders = new AliSmsMsgSender();
                    $sms_senders->access_key_id = $sms_sender->access_key_id;
                    $sms_senders->access_secret = $sms_sender->access_secret;
                    $sms_senders->tpl_code = $tpl_type;
                    $sms_senders->signname = $sign_names;
                    $res = $sms_senders->batchSender($mobile_phones, $sign_names,$item, 86);
                    if($res['code'] != 0){
                        \Yii::info(json_encode($mobile_phones,JSON_UNESCAPED_UNICODE).'__'.json_encode($sign_names,JSON_UNESCAPED_UNICODE).'__'.json_encode($item,JSON_UNESCAPED_UNICODE),'ball_sms');
                        \Yii::info($data['ball_cart'].'__'.$res['msg'],'ball_sms');
                    }
                }
            }
        }
        return ['code' => 0,'msg' =>"成功发送"];
    }

    //小程序下单模板通知
    public static function sendWxAppletLeaseMsg($user,$store,$order,$params)
    {
        $time5 = date('Y-m-d H:i:s',$order->created_at);
        $template_id = \Yii::$app->params['wxappletmsg']['ball_lease'];
        $openid = $user->bindWxmp->openid;
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'thing1' => ['value' => $store->name],
                'character_string2'   => ['value' => $order->order_no],
                'thing3'   => ['value' => $params['ball_number']],
                'amount4'   => ['value' => $params['price']],
                'time5'   => ['value' => $time5],
            ],
            'miniprogram_state' => 'trial',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info($order->id.'__'.$params['ball_number'].'__'.$r['errcode'].'__'.$r['errmsg'].'__小程序下单模板通知','wx_applet_msg');
        }
    }

    //小程序管理员确认还车模板通知
    public static function sendWxAppletReturnMsg($order)
    {
        if($order == null){
            return;
        }
        $order_detail = OrderDetail::findOne(['order_id' => $order->id]);
        $thing1 = $order_detail != null ? $order_detail->goods_id : '球车';
        $user = ApiHelper::findOneUser($order->user_id);
        if($user->bindWxmp){
            $template_id = \Yii::$app->params['wxappletmsg']['ball_return'];
            $openid = $user->bindWxmp->openid;
            $time4 = date('Y-m-d H:i:s',time());
            $thing3 = ceil($order->updated_at - $order->created_at);
            $thing3 = self::Sec2Time($thing3);
            $args = [
                'template_id'       => $template_id,
                'touser'            => $openid,
                'data'              => [
                    'thing1' => ['value' => $thing1],
                    'amount2'   => ['value' => $order->total_pay_price],
                    'thing3'   => ['value' => $thing3],
                    'time4'   => ['value' => $time4],
                ],
                'miniprogram_state' => 'trial',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
                'lang'              => 'zh_CN',
            ];
            $plugin = new \app\models\common\PluginService();
            $wxmpService = $plugin->getWxmpService(0);
            $accessToken = $wxmpService->getAccessToken();
            $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
            if($r['errcode'] != 0){
                \Yii::info($order->id.'__'.$order_detail->goods_id.'__'.$r['errcode'].'__'.$r['errmsg'].'__小程序管理员确认还车模板通知','ball_sms');
            }
        }
    }

    public static function Sec2Time($time)
    {
        if (is_numeric($time)) {
            $value = array(
                "years" => 0, "days" => 0, "hours" => 0,
                "minutes" => 0, "seconds" => 0,
            );
            $t = '';
            if ($time >= 31556926) {
                $value["years"] = floor($time / 31556926);
                $time = ($time % 31556926);
                $t .= $value["years"] . "年";
            }
            if ($time >= 86400) {
                $value["days"] = floor($time / 86400);
                $time = ($time % 86400);
                $t .= $value["days"] . "天";
            }
            if ($time >= 3600) {
                $value["hours"] = floor($time / 3600);
                $time = ($time % 3600);
                $t .= $value["hours"] . "小时";
            }
            if ($time >= 60) {
                $value["minutes"] = floor($time / 60);
                $time = ($time % 60);
                $t .= $value["minutes"] . "分";
            }
            $value["seconds"] = floor($time);
            //return (array) $value;
            $t .= $value["seconds"] . "秒";
            return $t;
        } else {
            return (bool) false;
        }
    }

    //小程序管理员确认售后用户结果通知
    public static function sendWxAppletStoreSalesMsg($order,$orderSale,$name,$merchant_remark)
    {
        if($order == null || $orderSale == null){
            return;
        }
        $time2 = date('Y/m/d H:i:s',$orderSale->created_at);

        $user = ApiHelper::findOneUser($order->user_id);
        if($user->bindWxmp){
            $template_id = \Yii::$app->params['wxappletmsg']['order_sale_notarize'];
            $openid = $user->bindWxmp->openid;
            $args = [
                'template_id'       => $template_id,
                'touser'            => $openid,
                'data'              => [
                    'thing1' => ['value' => '退款'],
                    'character_string6'   => ['value' => $order->order_no],
                    'time2'   => ['value' => $time2],
                    'phrase4'   => ['value' => $name],
                    'thing5'   => ['value' => $merchant_remark],
                ],
                'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
                'lang'              => 'zh_CN',
            ];
            \Yii::info($order->id.'__'.json_encode($args,JSON_UNESCAPED_UNICODE).'__小程序管理员确认售后body数据','ball_sms');
            $plugin = new \app\models\common\PluginService();
            $wxmpService = $plugin->getWxmpService(0);
            $accessToken = $wxmpService->getAccessToken();
            $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
            if($r['errcode'] != 0){
                \Yii::info($order->id.'__'.$r['errcode'].'__'.$r['errmsg'].'__小程序管理员确认售后用户结果通知','ball_sms');
            }
        }

    }

    //小程序待支付模板通知
    public static function sendWxAppletTopPay($user,$store,$order)
    {
        $thing5 = floor((time() - $order->created_at) / 60);
        $time = date('Y-m-d H:i:s',$order->created_at);
        $template_id = \Yii::$app->params['wxappletmsg']['to_pay'];
        $openid = $user->bindWxmp->openid;
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'character_string3' => ['value' => $order->order_no],
                'amount2'   => ['value' => $order->total_goods_price],
                'thing1'   => ['value' => $store->name],
                'time7'   => ['value' => $time],
                'thing5'   => ['value' => '订单将于提交后'.$thing5.'分钟内过期，请快去支付。'],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('待支付通知__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        return $r;
    }

    //小程序包厢预约开始提醒
    public static function sendWxAppletBoxBookStartRemind($order)
    {
        $box = Box::findOne(['id' => $order->coach_id]);
        $orderDetail = OrderDetail::findOne(['order_id' => $order->id]);
        $store = Store::findOne(['id' => $order->store_id]);
        $time = strtotime($orderDetail->start_time);
        $thing5 = floor((time() - $time) / 60);

        if($thing5 <= 0){
            $thing5 = '您的订单已生效';
        }else{
            $thing5 = '您的订单将于'.$thing5.'分钟后生效。';
        }
        $user = User::findOne(['id' => $order->user_id]);
        $template_id = \Yii::$app->params['wxappletmsg']['box_book_start_remind'];
        $openid = $user->bindWxmp->openid;
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'thing1' => ['value' => $box->name],
                'time2'   => ['value' => $orderDetail->start_time],
                'character_string10'   => ['value' => $order->order_no],
                'thing21'   => ['value' => $store->name],
                'thing9'   => ['value' => $thing5],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('预约开始提醒通知__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        return $r;
    }


    //小程序货柜关门提醒-货柜-微信
    public static function sendWxAppletGoodsContainerCloseRemind($order)
    {
        $redis = \Yii::$app->redis;
        $redis_name = "cxgyc:api:sendWxAppletGoodsContainerCloseRemind_{$order->user_id}:{$order->id}";
        $setnx = $redis->setnx($redis_name,1);
        if(empty($setnx)){
            return false;
        }
        \Yii::info('货柜关门提醒__ORDER_ID'.$order->id, 'wx_applet_msg');
        $time3 = date('Y-m-d H:i:s',$order->created_at);
        $time4 = date('Y-m-d H:i:s',time());
        $user = User::findOne(['id' => $order->user_id]);
        $thing5 = '稍后为您推送订单';
        $template_id = \Yii::$app->params['wxappletmsg']['goods_container_close_remind'];
        $openid = $user->bindWxmp->openid;
        \Yii::info('货柜关门提醒__OPEN_ID:'.$openid, 'wx_applet_msg');
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'character_string1' => ['value' => $order->order_no],
                'time3'   => ['value' => $time3],
                'time4'   => ['value' => $time4],
                'thing5'   => ['value' => $thing5],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        \Yii::info('货柜关门提醒__ORDER_ID:'.json_encode($args,JSON_UNESCAPED_UNICODE), 'wx_applet_msg');
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('货柜关门提醒__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        $redis->expire($redis_name,600);
        \Yii::info('货柜关门提醒__ORDER_ID:'.json_encode($r), 'wx_applet_msg');
        return $r;
    }

    //货柜生成订单提醒
    public static function sendWxAppletGoodsOrderPayRemind($order,$res)
    {
        \Yii::info('货柜生成订单提醒__ORDER_ID'.$order->id, 'wx_applet_msg');
        $time4 = date('Y-m-d H:i:s',$order->created_at);
        $amount7 = sprintf("%.2f",$res['data']['total_price']);
        $user = User::findOne(['id' => $order->user_id]);
        $thing5 = '商品订单已生成,点击进入';
        $template_id = \Yii::$app->params['wxappletmsg']['goods_order_pay_remind'];
        $openid = $user->bindWxmp->openid;
        \Yii::info('货柜生成订单提醒__OPEN_ID:'.$openid, 'wx_applet_msg');
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'page'              => 'subpages/order/orderDetailTwo?id='.$order->id.'&v=1',
            'data'              => [
                'character_string6' => ['value' => $order->order_no],
                'time4'   => ['value' => $time4],
                'amount7'   => ['value' => $amount7],
                'thing5'   => ['value' => $thing5],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        \Yii::info('货柜生成订单提醒__ORDER_ID:'.json_encode($args,JSON_UNESCAPED_UNICODE), 'wx_applet_msg');
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('货柜生成订单提醒__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        \Yii::info('货柜生成订单提醒__ORDER_ID:'.json_encode($r), 'wx_applet_msg');
        return $r;
    }

    //小程序包厢预约即将结束提醒
    public static function sendWxAppletBoxBookEndRemind($order)
    {
        $box = Box::findOne(['id' => $order->coach_id]);
        $orderDetail = OrderDetail::findOne(['order_id' => $order->id]);
        $store = Store::findOne(['id' => $order->store_id]);
        // $time = strtotime($orderDetail->start_time);
        $thing5 = ceil(($orderDetail->end_at - time()) / 60);
        $user = User::findOne(['id' => $order->user_id]);
        $template_id = \Yii::$app->params['wxappletmsg']['box_book_end_remind'];
        $openid = $user->bindWxmp->openid;
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'thing2' => ['value' => $store->name],
                'time3'   => ['value' => $orderDetail->end_time],
                'number4'   => ['value' =>$thing5],
                'thing6'   => ['value' => $box->name],
                'thing5'   => ['value' => '您的预约马上结束，请注意时间，或续单~'],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        \Yii::info('包厢预约即将结束提醒__ORDER_ID'.json_encode($args,JSON_UNESCAPED_UNICODE), 'wx_applet_msg');
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('包厢预约即将结束提醒__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        return $r;
    }

    //小程序货柜生成订单提醒-货柜-微信
    public static function sendWxAppletGoodsOrderAddRemind($order)
    {
        $redis = \Yii::$app->redis;
        $redis_name = "cxgyc:api:sendWxAppletGoodsOrderAddRemind_{$order->user_id}:{$order->id}";
        $setnx = $redis->setnx($redis_name,1);
        if(empty($setnx)){
            return false;
        }
        \Yii::info('货柜生成订单提醒__ORDER_ID'.$order->id, 'wx_applet_msg');
        $time3 = date('Y-m-d H:i:s',$order->created_at);
        $user = User::findOne(['id' => $order->user_id]);
        $thing5 = '订单生成中,稍后为您推送';
        $template_id = \Yii::$app->params['wxappletmsg']['goods_order_add_remind'];
        $openid = $user->bindWxmp->openid;
        \Yii::info('货柜关门提醒__OPEN_ID:'.$openid, 'wx_applet_msg');
        $args = [
            'template_id'       => $template_id,
            'touser'            => $openid,
            'data'              => [
                'time4' => ['value' => $time3],
                'phrase3'   => ['value' => '生成中'],
                'thing5'   => ['value' => $thing5],
            ],
            'miniprogram_state' => 'formal',//跳转小程序类型：developer为开发版；trial为体验版；formal为正式版；默认为正式版
            'lang'              => 'zh_CN',
        ];
        \Yii::info('货柜生成订单提醒__ORDER_ID:'.json_encode($args,JSON_UNESCAPED_UNICODE), 'wx_applet_msg');
        $plugin = new \app\models\common\PluginService();
        $wxmpService = $plugin->getWxmpService(0);
        $accessToken = $wxmpService->getAccessToken();
        $r = $wxmpService->tplMsg->sendWxAppletMsg($args,$accessToken);
        if($r['errcode'] != 0){
            \Yii::info('货柜生成订单提醒__ORDER_ID'.$order->id.$r['errcode'].'__'.$r['errmsg'], 'wx_applet_msg');
        }
        $redis->expire($redis_name,600);
        \Yii::info('货柜生成订单提醒__ORDER_ID:'.json_encode($r), 'wx_applet_msg');
        return $r;
    }


}