feat:即时配送

src/Cmq/Topic.php

@@ -261,9 +261,9 @@ class Topic
 		do {
 		do {
 			try {
 			try {
 				$res = $this->publish_message($cryptMessage, $vTagList, $routingKey);
 				$res = $this->publish_message($cryptMessage, $vTagList, $routingKey);
-				if($res['code'] == 0) break;
-			} catch(\Throwable $e) {
-				App::error("[消息队列异常]:".var_export($e, true));
+				if ($res['code'] == 0) break;
+			} catch (\Throwable $e) {
+				App::error("[消息队列异常]:" . $e->getFile() . $e->getMessage(), $e->getLine());
 			}
 			}
 			$tryTimes++;
 			$tryTimes++;
 		} while ($tryTimes < 3);
 		} while ($tryTimes < 3);
@@ -277,7 +277,7 @@ class Topic
 		return $res;
 		return $res;
 	}
 	}
 
 
-	protected function TopicLog($message, $cryptMessage, $tagName, $response, $status=0)
+	protected function TopicLog($message, $cryptMessage, $tagName, $response, $status = 0)
 	{
 	{
 		$data = [
 		$data = [
 			'tagName' => $tagName,
 			'tagName' => $tagName,
@@ -291,8 +291,8 @@ class Topic
 		try {
 		try {
 			$db = CfgCenter::dbConnect();
 			$db = CfgCenter::dbConnect();
 			$db->insert('topic_log', $data);
 			$db->insert('topic_log', $data);
-		}catch (\Exception $e){
-			App::error("消息主题日志记录失败：".$e->getMessage().'---'.json_encode($data));
+		} catch (\Exception $e) {
+			App::error("消息主题日志记录失败：" . $e->getMessage() . '---' . json_encode($data));
 		}
 		}
 	}
 	}
 }
 }