更新

app/admin/logic/operation/OpurchaseclassLogic.php

@@ -214,6 +214,7 @@ class OpurchaseclassLogic extends BaseLogic
             $goods_offer[] = [
                 'supplier_id' => $v['id'],
                 'goods_id' => $goods['goods'],
+                'order_id' => $goods['pid'],
                 'price' => 0,
                 'need_num' => $goods['nums']
             ];
@@ -222,7 +223,7 @@ class OpurchaseclassLogic extends BaseLogic
             $res = OpurchaseGoodsOffer::insertAll($goods_offer);
             if ($res) {
                 Opurchaseinfo::where('id',$goods['id'])->update(['is_push'=>1]);
-                return true;
+                return $goods_offer;
             }
         }
         } catch (\Exception $e) {

app/queue/redis/PushSupplierProductsSend.php

@@ -8,6 +8,7 @@ use Webman\RedisQueue\Consumer;
 use Webman\Push\Api;
 use support\exception\BusinessException;
 use support\Log;
+use think\facade\Db;
 
 class PushSupplierProductsSend implements Consumer
 {