diff --git a/app/inquiry/service/InquiryLogService.php b/app/inquiry/service/InquiryLogService.php index 10367db..31c161a 100644 --- a/app/inquiry/service/InquiryLogService.php +++ b/app/inquiry/service/InquiryLogService.php @@ -162,6 +162,8 @@ class InquiryLogService $data['r_time'] = time(); $data['t_time'] = time(); $data['status'] = 2; + } else { + $data['recipient'] = 0; } return $data; } diff --git a/app/queue/redis/InquiryToCrm.php b/app/queue/redis/InquiryToCrm.php index b3c3240..4d48d1c 100644 --- a/app/queue/redis/InquiryToCrm.php +++ b/app/queue/redis/InquiryToCrm.php @@ -68,21 +68,21 @@ class InquiryToCrm implements Consumer throw new BusinessException('同步失败~'); } - // 发送邮件消息 - if ($uinfo && $uinfo->email) { - $options = [ - 'id' => $info->id, - 'email' => $uinfo->email - ]; - // Log::info('发送邮件消息:' . json_encode($options)); - \Webman\RedisQueue\Redis::send('email-message', $options); - } + // // 发送邮件消息 + // if ($uinfo && $uinfo->email) { + // $options = [ + // 'id' => $info->id, + // 'email' => $uinfo->email + // ]; + // // Log::info('发送邮件消息:' . json_encode($options)); + // \Webman\RedisQueue\Redis::send('email-message', $options); + // } $wsdata = [ 'sender_id' => 0, 'sender_type' => 'system', - 'title' => '有新的客户线索,SN:' . $info->order_no . ',请及时处理', - 'content' => '有新的客户线索,SN:' . $info->order_no . ',请及时处理', + 'title' => '有新的客户线索,' . $info->order_no . ',请及时处理', + 'content' => '有新的客户线索,' . $info->order_no . ',请及时处理', 'scene' => 1, 'recipient' => [$info->recipient] ];