通知

app-ghs/controllers/OrderController.php

@@ -1069,7 +1069,7 @@ class OrderController extends BaseController
                 if (!empty($shop)) {
                     //花店采购供货商端收到微信通知
                     //WxMessageClass::ghsHasNewOrderInform($shop, $order);
-                    $noticeText = json_encode(['shopId' => $shopId, 'orderId' => $saleId]);
+                    $noticeText = json_encode(['orderId' => $saleId]);
                     $noticeKey = "hdCgNoticeGhs";
                     Yii::$app->redis->executeCommand('LPUSH', [$noticeKey, $noticeText]);
                 }

console/controllers/KindController.php

@@ -14,11 +14,6 @@ use Yii;
 class KindController extends Controller
 {
 
-    public function actionCs()
-    {
-        echo 123;
-    }
-
     //品类更新 ssh 20230320
     public function actionUpdate()
     {

console/controllers/MqController.php

@@ -2,23 +2,15 @@
 
 namespace console\controllers;
 
-use bizHd\goods\classes\GoodsCategoryClass;
-use bizHd\goods\classes\GoodsClass;
-use bizHd\goods\classes\KindClass;
-use bizHd\order\classes\OrderGoodsClass;
 use bizHd\shop\classes\ShopClass;
-use bizHd\work\classes\WorkClass;
+use biz\wx\classes\WxMessageClass;
 use yii\console\Controller;
+use bizGhs\order\classes\OrderClass;
 use Yii;
 
 class MqController extends Controller
 {
 
-    public function actionCs()
-    {
-        echo 123;
-    }
-
     //花店采购通知供货商 ssh 20230805
     public function actionHdCgNoticeGhs()
     {
@@ -26,6 +18,15 @@ class MqController extends Controller
         $json = Yii::$app->redis->executeCommand('RPOP', [$noticeKey]);
         if (!empty($json)) {
             $arr = json_decode($json, true);
+            $orderId = $arr['orderId'] ?? 0;
+            if (!empty($orderId)) {
+                $order = OrderClass::getById($orderId, true);
+                $shopId = $order->shopId ?? 0;
+                $shop = ShopClass::getById($shopId, true);
+                if (!empty($shop)) {
+                    WxMessageClass::ghsHasNewOrderInform($shop, $order);
+                }
+            }
             print_r($arr);
         }
     }