feat: upload revenue file

apps/web-app/app/components/form/UploadKitchenRevenue.vue

@@ -0,0 +1,111 @@
+<template>
+  <UForm
+    :validate="createValidator(uploadFileSchema)"
+    :state="state"
+    class="flex flex-col gap-3"
+    @submit="onSubmit"
+  >
+    <UFormField
+      label="Тип отчета"
+      name="type"
+      required
+    >
+      <USelectMenu
+        v-model="selectedType"
+        :items="availableTypes"
+        :placeholder="$t('common.select')"
+        size="xl"
+        class="w-full"
+      />
+    </UFormField>
+
+    <UFormField
+      label="Файл"
+      name="file"
+      description="Не более 20 МБ"
+      required
+    >
+      <UFileUpload
+        v-model="state.file"
+        color="neutral"
+        highlight
+        label="Перетащите свой файл сюда"
+        description="XLSX"
+        class="min-h-28"
+      />
+
+      <template #hint>
+        <UButton
+          to="/docs/examples/iiko-daily-revenue.jpg"
+          target="_blank"
+          variant="subtle"
+          color="neutral"
+          size="sm"
+          icon="i-lucide-file-text"
+        >
+          Пример файла-отчета
+        </UButton>
+      </template>
+    </UFormField>
+
+    <UButton
+      type="submit"
+      variant="solid"
+      color="secondary"
+      size="xl"
+      block
+      class="mt-3"
+      :label="$t('common.upload')"
+    />
+  </UForm>
+</template>
+
+<script setup lang="ts">
+import type { FormSubmitEvent } from '@nuxt/ui'
+import type { UploadFile } from '~~/shared/services/file'
+import { uploadFileSchema } from '~~/shared/services/file'
+
+const emit = defineEmits(['success', 'submitted'])
+
+const { t } = useI18n()
+const actionToast = useActionToast()
+
+const postStore = usePostStore()
+
+const state = ref<Partial<UploadFile>>({
+  file: undefined,
+})
+
+const availableTypes = [
+  { label: 'Выручка магазинов из iiko за 1 день', value: 'iiko-daily' },
+]
+const selectedType = ref<typeof availableTypes[0]>()
+
+async function onSubmit(event: FormSubmitEvent<UploadFile>) {
+  const toastId = actionToast.start()
+  emit('submitted')
+
+  try {
+    const formData = new FormData()
+    formData.append('file', event.data.file)
+
+    const data = await $fetch(`/api/kitchen/revenue/${selectedType.value?.value}`, {
+      method: 'POST',
+      body: formData,
+    })
+
+    await postStore.update()
+
+    const errorMessage = data.result.errors.length > 0 ? `Ошибки: ${data.result.errors.join(', ')}` : ''
+
+    actionToast.success(
+      toastId,
+      t('toast.file-loaded'),
+      `Было добавлено ${data.result.rowsUpdated} ${pluralizationRu(data.result.rowsUpdated, ['запись', 'записи', 'записей'])}. ${errorMessage}`)
+    emit('success')
+  } catch (error) {
+    console.error(error)
+    actionToast.error(toastId)
+  }
+}
+</script>

apps/web-app/app/components/modal/UploadKitchenRevenue.vue

@@ -0,0 +1,14 @@
+<template>
+  <UModal title="Загрузка отчета">
+    <template #body>
+      <FormUploadKitchenRevenue
+        @submitted="overlay.closeAll"
+        @success="overlay.closeAll"
+      />
+    </template>
+  </UModal>
+</template>
+
+<script setup lang="ts">
+const overlay = useOverlay()
+</script>

apps/web-app/app/pages/kitchen/[id]/finance.vue

@@ -1,5 +1,10 @@
 <template>
   <Content>
-    <div>В разработке</div>
+    <div>{{ data }}</div>
   </Content>
 </template>
+
+<script setup lang="ts">
+const { params } = useRoute('kitchen-id')
+const { data } = useFetch(`/api/kitchen/id/${params.id}/revenue`)
+</script>

apps/web-app/app/pages/kitchen/index.vue

@@ -1,5 +1,15 @@
 <template>
-  <Header :title="t('app.menu.kitchens')" />
+  <Header :title="t('app.menu.kitchens')">
+    <UButton
+      size="lg"
+      variant="solid"
+      color="secondary"
+      class="w-full md:w-fit"
+      icon="i-lucide-upload"
+      label="Добавить выручку"
+      @click="modalUploadKitchenRevenue.open()"
+    />
+  </Header>
 
   <Content>
     <div class="flex flex-wrap items-center justify-between gap-1.5">
@@ -96,8 +106,8 @@
           {{ row.getValue('address') }}, {{ row.getValue('city') }}
         </div>
       </template>
-      <template #no-cell="">
-        <div>??? руб</div>
+      <template #revenueForThisWeek-cell="{ row }">
+        <div>{{ row.getValue('revenueForThisWeek') }} руб</div>
       </template>
       <template #action-cell="{ row }">
         <div class="flex items-end" data-action="true">
@@ -140,6 +150,7 @@
 <script setup lang="ts">
 import type { DropdownMenuItem, TableColumn } from '@nuxt/ui'
 import type { Kitchen } from '@roll-stack/database'
+import { ModalUploadKitchenRevenue } from '#components'
 import { getPaginationRowModel } from '@tanstack/table-core'
 import { upperFirst } from 'scule'
 
@@ -222,8 +233,20 @@ const columns: Ref<TableColumn<KitchenWithData>[]> = ref([{
   accessorKey: 'city',
   header: 'Населенный пункт',
 }, {
-  accessorKey: 'no',
-  header: 'Выручка',
+  accessorKey: 'revenueForThisWeek',
+  header: ({ column }) => {
+    const isSorted = column.getIsSorted()
+    const icon = isSorted === 'asc' ? 'i-lucide-arrow-up-narrow-wide' : 'i-lucide-arrow-down-wide-narrow'
+
+    return h(UButton, {
+      color: 'neutral',
+      variant: 'ghost',
+      label: 'Выручка за неделю',
+      icon: isSorted ? icon : 'i-lucide-arrow-up-down',
+      class: '-mx-2.5',
+      onClick: () => column.toggleSorting(column.getIsSorted() === 'asc'),
+    })
+  },
 }, {
   id: 'action',
   enableSorting: false,
@@ -249,6 +272,9 @@ function getDropdownActions(_: Kitchen): DropdownMenuItem[][] {
 
 const table = useTemplateRef('table')
 
+const overlay = useOverlay()
+const modalUploadKitchenRevenue = overlay.create(ModalUploadKitchenRevenue)
+
 useHead({
   title: t('app.menu.kitchens'),
 })

apps/web-app/i18n/locales/ru-RU.json

@@ -337,6 +337,7 @@
     "variant-updated": "Вариация продукта обновлена",
     "variant-deleted": "Вариация продукта удалена",
     "photo-loaded": "Фото загружено",
+    "file-loaded": "Файл загружен",
     "category-updated": "Категория обновлена",
     "category-deleted": "Категория удалена",
     "task-created": "Задача создана",

apps/web-app/package.json

@@ -25,6 +25,7 @@
     "date-fns": "catalog:",
     "ioredis": "catalog:",
     "libphonenumber-js": "catalog:",
+    "node-xlsx": "catalog:",
     "nuxt-tiptap-editor": "catalog:",
     "openai": "catalog:",
     "pinia": "catalog:",

apps/web-app/server/api/kitchen/id/[kitchenId]/revenue.get.ts

@@ -0,0 +1,13 @@
+import { repository } from '@roll-stack/database'
+
+export default defineEventHandler(async (event) => {
+  const kitchenId = getRouterParam(event, 'kitchenId')
+  if (!kitchenId) {
+    throw createError({
+      statusCode: 400,
+      message: 'Id is required',
+    })
+  }
+
+  return repository.kitchen.listRevenuesByKitchen(kitchenId)
+})

apps/web-app/server/api/kitchen/revenue/iiko-daily.post.ts

@@ -0,0 +1,139 @@
+import { repository } from '@roll-stack/database'
+import xlsx from 'node-xlsx'
+
+export default defineEventHandler(async (event) => {
+  try {
+    const logger = useLogger('kitchen-revenue-iiko-daily')
+
+    const files = await readMultipartFormData(event)
+    const file = files?.[0]
+    if (!files?.length || !file) {
+      throw createError({
+        statusCode: 400,
+        message: 'Missing file',
+      })
+    }
+
+    const maxFileSize = 20 * 1024 * 1024 // 20MB
+    if (file.data.length > maxFileSize) {
+      throw createError({
+        statusCode: 413,
+        message: 'File too large',
+      })
+    }
+
+    const allowedMimeTypes = [
+      'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet',
+      'application/vnd.ms-excel',
+    ]
+    if (file.type && !allowedMimeTypes.includes(file.type)) {
+      throw createError({
+        statusCode: 400,
+        message: 'Invalid file type',
+      })
+    }
+
+    const workSheetsFromFile = xlsx.parse(file.data.buffer)
+    if (!workSheetsFromFile[0]) {
+      throw createError({
+        statusCode: 404,
+        message: 'File not found',
+      })
+    }
+
+    const data = workSheetsFromFile[0].data
+    const dateRow = data[2] // 3rd row
+    if (!dateRow || typeof dateRow[0] !== 'string' || !dateRow[0].startsWith('Дата')) {
+      throw createError({
+        statusCode: 400,
+        message: 'Invalid date',
+      })
+    }
+
+    const dateMatch = dateRow[0].match(/Дата:\s*(\d{1,2})\.(\d{1,2})\.(\d{4})/)
+    if (!dateMatch) {
+      throw createError({
+        statusCode: 400,
+        message: 'Invalid date format. Expected "Дата: DD.MM.YYYY"',
+      })
+    }
+
+    const [, day, month, year] = dateMatch
+    const dateOnly = `${year}-${month?.padStart(2, '0')}-${day?.padStart(2, '0')}`
+    const date = new Date(`${dateOnly}T12:00:00.000Z`)
+
+    if (Number.isNaN(date.getTime())) {
+      throw createError({
+        statusCode: 400,
+        message: 'Invalid date values',
+      })
+    }
+
+    // Remove first 4 rows and last row
+    const dataRows = data.slice(4, data.length - 1)
+    if (!dataRows) {
+      throw createError({
+        statusCode: 400,
+        message: 'Invalid data',
+      })
+    }
+
+    const parsedKitchens: { name: string, total: number }[] = []
+
+    for (const row of dataRows) {
+      const name = row[2] // 3rd column
+      const total = row[4] // 5th column
+
+      if (typeof name !== 'string' || typeof total !== 'number') {
+        continue
+      }
+
+      parsedKitchens.push({
+        name,
+        total,
+      })
+    }
+
+    // Every kitchen: find in DB and add amount for this day
+    const kitchens = await repository.kitchen.list()
+    let rowsUpdated = 0
+    const errors: string[] = []
+
+    for (const kitchen of parsedKitchens) {
+      const found = kitchens.find((k) => k.iikoAlias === kitchen.name)
+      if (found) {
+        // Create or update
+        const revenue = await repository.kitchen.findRevenueByKitchenAndDate(found.id, date)
+        if (!revenue) {
+          await repository.kitchen.createRevenue({
+            kitchenId: found.id,
+            date: dateOnly,
+            total: kitchen.total,
+          })
+        } else {
+          await repository.kitchen.updateRevenue(revenue.id, {
+            total: kitchen.total,
+          })
+        }
+
+        rowsUpdated++
+        continue
+      }
+
+      logger.warn(`Kitchen "${kitchen.name}" from file not found`)
+      errors.push(`"${kitchen.name}" не найдена.`)
+    }
+
+    logger.log(rowsUpdated, date, parsedKitchens)
+
+    return {
+      ok: true,
+      result: {
+        rowsUpdated,
+        errors,
+      },
+    }
+  } catch (error) {
+    throw errorResolver(error)
+  }
+})

apps/web-app/shared/services/file.ts

@@ -0,0 +1,16 @@
+import { type } from 'arktype'
+
+const MAX_FILE_SIZE = 20000000
+const ACCEPTED_FILE_TYPES = [
+  'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet',
+  'application/vnd.ms-excel',
+]
+
+const FileSchema = type('File')
+  .narrow((file) => file.size <= MAX_FILE_SIZE && ACCEPTED_FILE_TYPES.includes(file.type))
+  .describe('error.file-size-or-type')
+
+export const uploadFileSchema = type({
+  file: FileSchema,
+})
+export type UploadFile = typeof uploadFileSchema.infer