报错信息

biz/common/classes/GhsNotifyClass.php

@@ -15,10 +15,24 @@ class GhsNotifyClass extends BaseClass
         try {
             $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
             $msg = serialize(['type' => 'ghs_new_order_notify', 'orderId' => $orderId]);
-            $producer->publish($msg, 'notifyExchange', 'notifyRoute',['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
+            $producer->publish($msg, 'notifyExchange', 'notifyRoute', ['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
         } catch (\Exception $e) {
             $msg = $e->getMessage();
-            $remind = "供货商新订单通知，生产消息报错 {$orderId} {$msg}";
+            $remind = "批发，新订单通知，生产消息端报错 {$orderId} {$msg}";
+            noticeUtil::push($remind, '15280215347');
+        }
+    }
+
+    //跑腿异常通知
+    public static function ptErrorNotify($orderId, $event)
+    {
+        try {
+            $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
+            $msg = serialize(['type' => 'ghs_pt_error', 'orderId' => $orderId, 'event' => $event]);
+            $producer->publish($msg, 'notifyExchange', 'notifyRoute', ['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
+        } catch (\Exception $e) {
+            $msg = $e->getMessage();
+            $remind = "批发，跑腿异常通知，生产消息端报错 {$orderId} {$msg}";
             noticeUtil::push($remind, '15280215347');
         }
     }

biz/common/classes/HdNotifyClass.php

@@ -14,10 +14,10 @@ class HdNotifyClass extends BaseClass
         try {
             $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
             $msg = serialize(['type' => 'hd_new_order_notify', 'orderId' => $orderId]);
-            $producer->publish($msg, 'notifyExchange', 'notifyRoute',['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
+            $producer->publish($msg, 'notifyExchange', 'notifyRoute', ['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
         } catch (\Exception $e) {
             $msg = $e->getMessage();
-            $remind = "花店新订单通知，生产消息报错 {$orderId} {$msg}";
+            $remind = "零售，新订单通知，生产消息端报错 {$orderId} {$msg}";
             noticeUtil::push($remind, '15280215347');
         }
     }
@@ -27,10 +27,23 @@ class HdNotifyClass extends BaseClass
         try {
             $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
             $msg = serialize(['type' => 'hd_new_cg_notify', 'cgId' => $cgId]);
-            $producer->publish($msg, 'notifyExchange', 'notifyRoute',['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
+            $producer->publish($msg, 'notifyExchange', 'notifyRoute', ['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
         } catch (\Exception $e) {
             $msg = $e->getMessage();
-            $remind = "花店新采购单通知，生产消息报错 {$cgId} {$msg}";
+            $remind = "零售，新采购单通知，生产消息端报错 {$cgId} {$msg}";
+            noticeUtil::push($remind, '15280215347');
+        }
+    }
+
+    public static function ptErrorNotify($orderId, $event)
+    {
+        try {
+            $producer = Yii::$app->rabbitmq->getProducer('notifyProducer');
+            $msg = serialize(['type' => 'hd_pt_error', 'orderId' => $orderId, 'event' => $event]);
+            $producer->publish($msg, 'notifyExchange', 'notifyRoute', ['delivery_mode' => 2, 'content_type' => 'application/octet-stream']);
+        } catch (\Exception $e) {
+            $msg = $e->getMessage();
+            $remind = "零售，跑腿异常通知，生产消息端报错 {$orderId} {$msg}";
             noticeUtil::push($remind, '15280215347');
         }
     }

common/components/rabbitmq/notifyConsumer.php

@@ -54,6 +54,14 @@ class notifyConsumer implements ConsumerInterface
                     //花店的新采购单通知
                     $result = $this->hdNewCgNotify($data);
                     break;
+                case 'ghs_pt_error':
+                    //供货商跑腿异常通知
+                    $result = $this->ghsPtErrorAction($data);
+                    break;
+                    break;
+                case 'hd_pt_error':
+                    //花店跑腿异常通知
+                    break;
                 default:
                     noticeUtil::push("通知的消费者提示：Unknown notify type: {$type}", '15280215347');
                     $result = false;
@@ -70,6 +78,24 @@ class notifyConsumer implements ConsumerInterface
         }
     }
 
+    private function ghsPtErrorAction($data)
+    {
+        $orderId = $data['orderId'] ?? 0;
+        $event = $data['event'] ?? '';
+        $order = OrderClass::getById($orderId, true);
+        if (!empty($order)) {
+            $sendNum = $order->sendNum ?? '';
+            $result = $event . '，取货号：' . $sendNum;
+            $customName = $order->customName ?? '';
+            $shopId = $order->shopId ?? '';
+            $shop = ShopClass::getById($shopId, true);
+            if (!empty($shop)) {
+                WxMessageClass::expressErrorInform($shop, $customName, $orderId, $result);
+            }
+        }
+        return true;
+    }
+
     private function ghsNewOrderNotify($data)
     {
         $orderId = $data['orderId'] ?? 0;