API Survey Send Workflow

Цепочка выполнения:

1. Webhook (survey/data/send)

   Принимает POST-запрос с параметрами:

   • query.surveyId - токен опроса
   • query.userId - токен пользователя
   • query.surveyData - массив ответов на вопросы опроса

2. Параллельные проверки:

   1. check user token

      Проверяет валидность токена пользователя:

      SELECT "userId" FROM employees WHERE "token" = $1;

      Параметр: $1 = $json.query.userId

   2. check survey respondents

      Проверяет, что пользователь в списке респондентов и обновляет счетчик:

      UPDATE "surveys"
      SET "current_respondents_count" = "current_respondents_count" + 1,
          "respondents" = ARRAY_REMOVE("respondents", $2)
      WHERE "token" = $1
      AND $2 = ANY("respondents")
      RETURNING "surveyId";

      Параметры: $1 = $json.query.surveyId, $2 = $json.userId

      Особенности:

      • Увеличивает счетчик респондентов только если пользователь был в списке
      • Удаляет пользователя из списка респондентов
      • Возвращает surveyId при успешном обновлении

3. Merge2

   Объединяет результаты проверок и исходные данные запроса.

4. Edit Fields

   Подготавливает данные для дальнейшей обработки:

   query.surveyData = $json.query.surveyData
   query.surveyId = $json.query.surveyId
   query.userId = $json.query.userId

5. Параллельная обработка:

   1. Code

      Преобразует и очищает данные surveyData:

      Логика работы:

      1. Обрабатывает каждый элемент массива surveyData
      2. Для поля value сохраняет 0 как 0, null как null
      3. Для comment:
         • Заменяет null/undefined на null
         • Экранирует обратные слэши и кавычки
         • Ограничивает длину до 4000 символов
         • Удаляет лишние символы (\n, \r, \t)

      Пример преобразования:

      {
        "questionId": 123,
        "paramNameMetric": null,
        "paramNameSubmetric": null,
        "value": null,
        "comment": "Выдать рабочие компьютеры"
      }

   2. Postgres2

      Получает дополнительные данные о пользователе и опросе:

      SELECT 
          s."surveyId",
          s."companyId",
          e."userId",
          e."hireDate",
          e."gender",
          e."departmentId"
      FROM surveys s
      JOIN employees e ON e."token" = $2 
      WHERE s."token" = $1;

      Параметры: $1 = $json.query.surveyData[0].surveyId, $2 = $json.query.surveyData[0].userId

      Возвращает:

      • ID опроса, компании
      • Данные пользователя (ID, дата найма, пол, отдел)

6. Merge

   Объединяет очищенные данные опроса с информацией о пользователе.

7. Postgres

   Сохраняет данные в таблицу raw_survey_data:

   INSERT INTO public.raw_survey_data (
       questionId, value, departmentId, 
       userId, companyId, surveyId,
       paramNameSubmetric, paramNameMetric,
       comment, hireDate, gender
   ) VALUES (...);

   Особенности преобразования данных:

   • value: преобразует в число или null (если 'null', 'NaN' или не число)
   • comment: сохраняет как null если пустое или 'null'

8. Respond to Webhook

   Возвращает статус успешного выполнения:

   {"success": true}

Пример запроса:

{
  "surveyId": "5810b6d6-7545-49ff-b71d-ea39bee9835c",
  "userId": "3098c8c8-b17b-45c4-90ba-29da3eba4a29",
  "surveyData": [
    {
      "questionId": 3,
      "paramNameMetric": "recognition",
      "paramNameSubmetric": "recognition_quality",
      "value": 0,
      "comment": null
    },
    {
      "questionId": 123,
      "paramNameMetric": null,
      "paramNameSubmetric": null,
      "value": null,
      "comment": "Выдать рабочие компьютеры"
    }
  ]
}

Структура БД: