diff --git a/app/queue/redis/InquiryToCrmNew.php b/app/queue/redis/InquiryToCrmNew.php index c3d0abf..4441610 100644 --- a/app/queue/redis/InquiryToCrmNew.php +++ b/app/queue/redis/InquiryToCrmNew.php @@ -39,7 +39,7 @@ class InquiryToCrmNew implements Consumer 发过 没分 更新 (要同步)7 发过 分过 更新 (要同步)8 */ -var_dump('询单同步开始:'.$data['id']); + // var_dump('询单同步开始:'.$data['id']); try { // 获取询盘信息 $info = InquiryLog::with(['channelInfo', 'countryInfo', 'enter'])->where('id', $data['id'])->first(); @@ -57,7 +57,7 @@ var_dump('询单同步开始:'.$data['id']); // 更改库信息 $this->syncCustomer($info); } catch (\Throwable $th) { - var_dump('询单同步失败:'.$th->getMessage().' | '.$th->getLine().' | '.$th->getFile()); + flg('询单同步失败:'.$th->getMessage().' | '.$th->getLine().' | '.$th->getFile(), false); throw $th; } } @@ -133,6 +133,11 @@ var_dump('询单同步开始:'.$data['id']); if (!$crmCustomerInfo->update($udata)) { throw new BusinessException('同步失败,更新客户线索失败'); } + + $info->sync_crm = 1; + if (!$info->save()) { + throw new BusinessException('标记询盘同步状态失败'); + } } else { $crmCustomer = new CrmCustomer(); $crmCustomer->sn = $info->order_no;