5分钟连续出现某现象+微信模板消息提醒 PHP

Posted 2021-03-24 星辰一幕

需求场景：用电插座电流连续出现5次电流过高（大于 3A）后停止用电服务，前四次发送电流过高提醒，最后一次发送结束用电服务提醒

思路：

Redis  key 设为：插座编号+user户编号  value： 出现大于3A的次数 ；

心跳每分钟，心跳包数据含有 。判断电流：电流值 <3 清空对应key的次数  电流>=3  次数不为零小于5  次数加一 发送过高提醒，次数为5时发送结束服务提醒，清空对应key的次数；

先申请模板消息，获取模板ID（一搜一大把，此处不赘述了）

上代码：（Ci框架）

心跳包中拿到电流值 $i

if($i > 3){
       checkMeterCurrentUp($meter_id);
                
}else{
       //清空redis电流超限记录
       deleteAbnormalCurrentCache($meter_id);
}

function checkMeterCurrentUp($meter_id)

             //加载redis 
　　　　　　　　if($up_count < 5){//设备号 value加一  发送模板消息
                    $this->redisclient->save($user_id.$meter_id,$up_count+1,600);//给用户消息通知
　　　　　　　　　　　  //获取access_token

                  　lm(‘config_model‘);
                    $access_token = $this->config_model->r(pw(‘datakey‘,CONFIG_KEY_GZHH_ACCESS_TOKEN,‘platform_id‘,$order[‘platform_id‘]));
                    $access_token = element(‘datavalue‘,$access_token);

                    if($access_token) {
                            $url = sprintf("https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=%s", $access_token);

                            lm(‘users_model‘);
                            $user = $this->users_model->r(pw(‘id‘,$user_id));

                            lm(‘meters_model‘);
                            $meter = $this->meters_model->r(pw(‘id_open‘,$meter_id));
　　　　　　　　　　　　　　　　　//获取微信模板消息ID
                            lm(‘platform_config_model‘);
                            $platform_config = $this->platform_config_model->r(pw(‘platform_id‘,$order[‘platform_id‘]));
                            $template_id = $platform_config[‘wx_event_template_id‘];

                            $postdata = json_encode(array(
                                ‘touser‘ => element(‘openid‘,$user),
                                ‘template_id‘ => $template_id,
                                ‘url‘ => site_url(‘detail?id=‘.$meter_id),
                                ‘data‘ => array(
                                    "keyword1" => array (
                                        "value" => $meter_id,
                                        "color" => "#173177"
                                    ),
                                    "keyword2" => array ( //地址
                                        "value" => element(‘name‘,$meter),
                                        "color" => "#173177"
                                    ),
                                    "keyword3" => array (
                                        "value" => date(‘Y-m-d H:i:s‘),
                                        "color" => "#173177"
                                    ),
                                    "first" => array (
                                        "value" => ‘您的设备充电功率超限，连续五次超限后将停止充电服务‘,
                                        "color" => "#173177"
                                    ),
                                    "remark" => array (
                                        "value" => ‘请及时查看‘,
                                        "color" => "#173177"
                                    ),
                                )
                            ));
　　　　　　　　　　　　　　　　　//发送 发送模板消息请求
                            $resp = http_post($url,$postdata);
                     }
                    
                }else{
                    //结束订单
                    //发送模板消息
                    $this->redisclient->delete($user_id.$meter_id);
                    //给用户消息通知
                        lm(‘config_model‘);
                        $access_token = $this->config_model->r(pw(‘datakey‘,CONFIG_KEY_GZHH_ACCESS_TOKEN,‘platform_id‘,$order[‘platform_id‘]));
                        $access_token = element(‘datavalue‘,$access_token);

                        if($access_token) {
                            $url = sprintf("https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=%s", $access_token);

                            lm(‘users_model‘);
                            $user = $this->users_model->r(pw(‘id‘,$user_id));

                            lm(‘meters_model‘);
                            $meter = $this->meters_model->r(pw(‘id_open‘,$meter_id));
　　　　　　　　　　　　　　　　　
                            lm(‘platform_config_model‘);
                            $platform_config = $this->platform_config_model->r(pw(‘platform_id‘,$order[‘platform_id‘]));
                            $template_id = $platform_config[‘wx_event_template_id‘];
                            $postdata = json_encode(array(
                                ‘touser‘ => element(‘openid‘,$user),
                                ‘template_id‘ => $template_id,
                                ‘url‘ => site_url(‘detail?id=‘.$meter_id),
                                ‘data‘ => array(
                                    "keyword1" => array (
                                        "value" => $meter_id,
                                        "color" => "#173177"
                                    ),
                                    "keyword2" => array ( //地址
                                        "value" => element(‘name‘,$meter),
                                        "color" => "#173177"
                                    ),
                                    "keyword3" => array (
                                        "value" => date(‘Y-m-d H:i:s‘),
                                        "color" => "#173177"
                                    ),
                                    "first" => array (
                                        "value" => ‘您的设备充电功率连续五次超限，已停止充电服务‘,
                                        "color" => "#173177"
                                    ),
                                    "remark" => array (
                                        "value" => ‘请知悉‘,
                                        "color" => "#173177"
                                    ),
                                )
                            ));
                            $resp = http_post($url,$postdata);
                    }
                    //停止订单

　　　　　　　　　　　　//关闭设备
                }

function deleteAbnormalCurrentCache($meter_id){
        $user_id = 99;
      //加载Redis
　　　　if($this->redisclient->is_supported() === TRUE){
            $this->redisclient->delete($user_id.$meter_id);
            $this->redisclient->delete(‘down_‘.$user_id.$meter_id);
      }   
}