发表新帖

task异步执行多次？

业务是客户端定时发送task异步至服务器的，服务端根据收到的数据进行业务处理。
处理过程中发现经常同时处理两次。不知道什么清空。我是15分钟发送一次至服务端，发送数据只有一次。但被执行两次，代码如下：
>     public function singleSend($params){
        $robotId = $params['robotId'];
        $timerId = $params['timerId'];
        $robotInfo = $this->getRobotDetail($robotId);
        if(!$this->checkRobot($robotInfo)){
            return true;
        }
        $this->sendRobotAllGroup($robotInfo ,$this->getGroupsByRobot($robotId));
    }

>     public function sendRobotAllGroup($robot,$group=[]){
        $this->setPrefix($robot);
        $wxId = $robot['wc_id'];
        
        wlog( [] ,"robot_send:".$robot['id']."group_count:".count($group));
        foreach ($group as $k=>$v){
            wlog( [] ,"group:{$v['id']} start");
            if(!$v['wechatgroup_code']){
                Wechatgroup::create()->where('id',$v['id'])->update(['status'=>6]);
                continue;
            }
            $v['group_space'] && $this->_group_space = $v['group_space'];
            $v['vedio_space'] && $this->_vedio_space = $v['vedio_space'];
            $v['img_space'] && $this->_img_space = $v['img_space'];
            $v['text_space'] && $this->_text_space = $v['text_space'];
            
            $send = new Send();
            //设置代理的推广位
            $robot['agent_uid'] && $send->setAgentPid($robot['agent_uid']);
            $send->setGroupId($v['id'],$robot);
            //获取内容
            $content = $send->index();
           
            wlog($content,"group:{$v['id']} ");
            
            //无数据
            if($content['status'] ==1){
                wlog( [] ,"group:{$v['id']} no data");
                continue;
            }
            
            wlog( [] ,"group_send:".$v['id'] /*."_content:".json_encode($content)*/ ); 
            
            $this->sendByWxId($wxId, $v['wechatgroup_code'] ,$content);
            
           // $space = ($k + 1)* $this->_group_space;
            
            //http接口发送
            //             \Swoole\Timer::after($space, function ()use($wxId,$v,$content) {
            //                 $this->httpSendData($wxId,$v,$content);
            //             });
            wlog( [] ,"group_done:".$v['id'] ); 
           
            $this->_group_space && \Swoole\Coroutine\System::sleep($this->_group_space);
      //      sleep($this->_group_space);
            unset($content);
            unset($send);
        }
        unset($group);
    }

上面是循环发送但过程，我打印 wlog($content,"group:{$v['id']} "); 被执行了两次。但group 里面只有一次这个id，搞不懂什么情况了。

发布于3年前 · 1 次浏览 · 来自提问

Caption

上面是循环发送但过程，我打印 wlog($content,"group:{$v['id']} "); 被执行了两次。但group 里面只有一次这个id，搞不懂什么情况了。