Merge branch 'main' of https://gittea.biveki.ru/Sfera/sfera

src/graphql/resolvers.ts

@@ -789,13 +789,25 @@ export const resolvers = {
         throw new GraphQLError("У пользователя нет организации");
       }
 
-      // Считаем заказы поставок со статусом PENDING где мы поставщики или получатели
+      // Считаем заказы поставок, требующие действий
       const pendingSupplyOrders = await prisma.supplyOrder.count({
         where: {
-          status: "PENDING",
           OR: [
-            { partnerId: currentUser.organization.id }, // Заказы где мы - поставщик (нужно подтвердить)
-            { fulfillmentCenterId: currentUser.organization.id }, // Заказы где мы - получатель ФФ (нужно подтвердить)
+            // Заказы со статусом PENDING где мы - поставщик (нужно подтвердить)
+            {
+              status: "PENDING",
+              partnerId: currentUser.organization.id,
+            },
+            // Заказы со статусом PENDING где мы - получатель ФФ (нужно подтвердить)
+            {
+              status: "PENDING",
+              fulfillmentCenterId: currentUser.organization.id,
+            },
+            // Заказы со статусом IN_TRANSIT где мы - получатель ФФ (нужно подтвердить получение)
+            {
+              status: "IN_TRANSIT",
+              fulfillmentCenterId: currentUser.organization.id,
+            },
           ],
         },
       });
@@ -902,6 +914,108 @@ export const resolvers = {
       });
     },
 
+    // Товары на складе фулфилмента (из доставленных заказов поставок)
+    warehouseProducts: async (_: unknown, __: unknown, context: Context) => {
+      if (!context.user) {
+        throw new GraphQLError("Требуется авторизация", {
+          extensions: { code: "UNAUTHENTICATED" },
+        });
+      }
+
+      const currentUser = await prisma.user.findUnique({
+        where: { id: context.user.id },
+        include: {
+          organization: true,
+        },
+      });
+
+      if (!currentUser?.organization) {
+        throw new GraphQLError("У пользователя нет организации");
+      }
+
+      // Проверяем, что это фулфилмент центр
+      if (currentUser.organization.type !== "FULFILLMENT") {
+        throw new GraphQLError(
+          "Товары склада доступны только для фулфилмент центров"
+        );
+      }
+
+      // Получаем все доставленные заказы поставок, где этот фулфилмент центр является получателем
+      const deliveredSupplyOrders = await prisma.supplyOrder.findMany({
+        where: {
+          fulfillmentCenterId: currentUser.organization.id,
+          status: "DELIVERED", // Только доставленные заказы
+        },
+        include: {
+          items: {
+            include: {
+              product: {
+                include: {
+                  category: true,
+                  organization: true, // Включаем информацию о поставщике
+                },
+              },
+            },
+          },
+          organization: true, // Селлер, который сделал заказ
+          partner: true, // Поставщик товаров
+        },
+      });
+
+      // Собираем все товары из доставленных заказов
+      const allProducts: any[] = [];
+
+      console.log("🔍 Резолвер warehouseProducts (доставленные заказы):", {
+        currentUserId: currentUser.id,
+        organizationId: currentUser.organization.id,
+        organizationType: currentUser.organization.type,
+        deliveredOrdersCount: deliveredSupplyOrders.length,
+        orders: deliveredSupplyOrders.map((order) => ({
+          id: order.id,
+          sellerName: order.organization.name || order.organization.fullName,
+          supplierName: order.partner.name || order.partner.fullName,
+          status: order.status,
+          itemsCount: order.items.length,
+          deliveryDate: order.deliveryDate,
+        })),
+      });
+
+      for (const order of deliveredSupplyOrders) {
+        console.log(
+          `📦 Заказ от селлера ${order.organization.name} у поставщика ${order.partner.name}:`,
+          order.items.map((item) => ({
+            productId: item.product.id,
+            productName: item.product.name,
+            article: item.product.article,
+            orderedQuantity: item.quantity,
+            price: item.price,
+          }))
+        );
+
+        for (const item of order.items) {
+          // Добавляем товар на склад с информацией о заказе
+          allProducts.push({
+            ...item.product,
+            // Дополнительная информация о заказе
+            orderedQuantity: item.quantity,
+            orderedPrice: item.price,
+            orderId: order.id,
+            orderDate: order.deliveryDate,
+            seller: order.organization, // Селлер, который заказал
+            supplier: order.partner, // Поставщик товара
+            // Для совместимости с существующим интерфейсом
+            organization: order.organization, // Указываем селлера как владельца
+          });
+        }
+      }
+
+      console.log(
+        "✅ Итого товаров на складе фулфилмента (из доставленных заказов):",
+        allProducts.length
+      );
+      return allProducts;
+    },
+
     // Все товары всех поставщиков для маркета
     allProducts: async (
       _: unknown,
@@ -3386,7 +3500,7 @@ export const resolvers = {
             price: product.price,
             quantity: item.quantity,
             unit: "шт",
-            category: productWithCategory?.category?.name || "Упаковка",
+            category: productWithCategory?.category?.name || "Расходники",
             status: "in-transit", // Статус "в пути" так как заказ только создан
             date: new Date(args.input.deliveryDate),
             supplier: partner.name || partner.fullName || "Не указан",
@@ -4866,7 +4980,7 @@ export const resolvers = {
                   price: item.price,
                   quantity: item.quantity,
                   unit: "шт",
-                  category: item.product.category?.name || "Упаковка",
+                  category: item.product.category?.name || "Расходники",
                   status: "available",
                   date: new Date(),
                   supplier: