Идемпотентность запросов

Можно ознакомится со статьей от Яндекс: https://habr.com/ru/company/yandex/blog/442762/

Обработка в агенте
Обработка на клиенте
Пример МП Courier

1. Добавлены property
   1. Himstat.IdempotencyText устанавливается на прямую (доступно на чтение и запись)
   2. Himstat.IdempotencyHash устанавливается при установке IdempotencyText (доступно только на чтение)
2. uErrorRes добавлен тип Exception TIdenpotencyException
   • На примере запроса PayPlanOrders:
3. THimstatDM.ReplyWithPayPlanOrders
   1. Himstat.IdempotencyText := Srvr.Request.Query.Text; Получаем IdempotencyText IdempotencyHash
4. Himstat.DoPayPlanOrders
   1. QueryIdempotency Записываем в таблицу Hash и время
      1. Нет таблицы IDEMPOTENCY_QUERY - выходим из проверки
      2. получаем старый ОТВЕТ (предыдущего АНАЛОГИЧНОГО запроса) ИЛИ получаем ОТВЕТ=«» - Идет запись
         1. ОТВЕТ=null - пытаемся записать HASH
            1. ERROR Присваиваем ОТВЕТ:=«» - Идет запись
      3. FINALY
         1. (1) ЕСЛИ ОТВЕТ=null - то у нас уникальный запрос записанный в таблицу
         2. (2) ЕСЛИ ОТВЕТ<>null - запрос не уникален - возбуждаем исключение TIdenpotencyException.Create(ОТВЕТ);
   2. (1) UpdateIdempotency сохраняем ОТВЕТ в таблицу
   3. (2) TIdenpotencyException
      1. Если исключение содержит НЕ ПУСТОЕ сообщение то это ОТВЕТ и мы его отправляем повторно
      2. Если исключение содержит ПУСТОЕ сообщение то снова возбуждаем TIdenpotencyException и отправляем как ошибку ОДНОВРЕМЕННОГО ЗАПРОСА (ErrorCode = 5)
5. Если ОШИБКА произошла в теле обработки до сохранения ОТВЕТа то HASH запроса удаляется

1. Организовать уникальность запроса
2. Обработку ErrorCode = 5

...
 
...
var
  PayIdempotency: string;/ /'Переменная сохраняет состояние текущей транзакции /запрос(dor_id, debet) + ответ(JSON)/'
...
 
...
      JSONAnswer := KassaFiscalRegistar.PrintFiscalCheck(JSONResultObj); / /'Печать чека'
      ...
    except
      on E: Exception do
      begin
        PayIdempotency := ''; / /'Если ошибка при печати - обнуляем текущую транзакцию' 
...
 
...
procedure TmoneyPayFramePanel.OnShow(curVisible: TuniFramePanel);
begin
  PayIdempotency := '';/ / 'При входе обнуление предыдущей транзакции'
...
 
...
      ClnDM.GetFiscalCheck(sJSON,
        procedure (AJObject: TJSONObject)
        var CurrentPayIdempotency: string; / /'Текущая транзакция'
        begin
          CurrentPayIdempotency := THashMD5.GetHashString(sJSON + '=' + AJObject.ToString);
          if PayIdempotency = CurrentPayIdempotency then / /'Текущую сравниваем с запомненой'
          begin
            / / 'Ничего не делаем если транзакция все еще ТА ЖЕ'
            WriteLog("TmoneyPayFramePanel.WorkOfPay PayIdempotency = CurrentPayIdempotency Abort");
          end
          else
          begin
            / /'Транзакция другая - выпонить оплату'
            PayIdempotency := CurrentPayIdempotency;
            AnswerFromWeb('GetFiscalCheck', '', 0, AJObject);
          end;
        end);
... 
 
...