using System;
using System.Data;
using Devart.Data.Oracle;
using System.Threading.Tasks;

namespace ns_ГИС {
  public delegate void dlg_sp(dlg_RowToEntity RowToEntity);
  public delegate void dlg_RowToEntity(IDataRecord reader);

  public static class wsp {
    static int nRow;
    static OracleDataReader reader;

    //-- Обработка строк выборки select
    public static async void sp_Sel(dlg_RowToEntity RowToEntity) {
      while (await reader.ReadAsync()) {
        nRow++;
        if (nRow == гп.max_Выборка) break;   //-- Это максимум что можем отобразить, надо уточнять запрос
        RowToEntity(reader);
      }
    }
    //-- Обработка строки выборки insert
    public static async void sp_Ins(dlg_RowToEntity RowToEntity) {
      if (await reader.ReadAsync()) RowToEntity(reader);
    }
    //-- Обработка строки выборки update
    public static async void sp_Upd(dlg_RowToEntity RowToEntity) {
      int i = 0;
      if (await reader.ReadAsync()) {
        i = reader.FieldCount;
        i = (int)reader.GetInt32(i-1);
        RowToEntity(reader);
        if (i != 1) throw new Exception("Запись кем то изменена");
      }
    }
    //-- Обработка строки выборки delete
    public static async void sp_Del(dlg_RowToEntity RowToEntity) {
      if (await reader.ReadAsync()) {
        //-- Если читаем якобы удаленную строку, то удаления нет
        RowToEntity(reader);
        throw new Exception("Запись кем то изменена");
      }
    }

    //-- Выполнение хранимой процедуры
    public static async Task Entity_SP(string spname, dlg_sp sp, OracleParameter[] asp, dlg_RowToEntity RowToEntity) {
      nRow = 0;  //-- Число строк в выборке
      reader = null;

      using (OracleConnection connection = new OracleConnection(гп.str_Соединение)) {
        connection.Open();
        OracleCommand command = new OracleCommand("", connection);
        command.Parameters.Clear();
        command.Parameters.AddRange(asp);
        command.CommandText = spname;
        command.CommandType = CommandType.StoredProcedure;

        using (reader = (OracleDataReader)await command.ExecuteReaderAsync()) {
          //-- Формируем коллекцию из выборки
          sp(RowToEntity); //-- Обратный вызов
        }
      }
    }
  }
  . . .
    //-- Строку выбоки из таблиц базы данных отражаем на entity 
    //-- 0.pk_puska, 1.nv, 2.dt_puska, 3.nom_puska, 4.strana_puska, 5.mesto_puska 
    //-- 6.lng_s, 7.lat_s, 8.lng_p, 9.lat_p, 10.reg
    private void RowToEntity(IDataRecord record) {
      xrow = new row_Entity() {
        chb_Entity = false,
        pk_Entity = record.GetInt64(0),              //-- суррогатный ключ
        nv = record.GetInt64(1),                     //-- Для оптимистической блокировки

        dt_Пуск = record.GetDateTime(2),
        str_НомерПуска = record.GetString(3).Trim(),
        str_СтранаПуска = record.GetString(4).Trim(),
        str_МестоПуска = record.GetString(5).Trim(),
        fl_Lng_s = record.GetFloat(6),                 //-- Долгота объекта
        fl_Lat_s = record.GetFloat(7),                 //-- Широта объекта
        fl_Lng_p = record.GetFloat(8),                 //-- Долгота объекта
        fl_Lat_p = record.GetFloat(9),                 //-- Широта объекта
        reg = null
      };
      if (!record.IsDBNull(10)) {
        byte[] xbt = new byte[84];
        record.GetBytes(10, 0, xbt, 0, 84);
        xrow.reg = xbt;
      } 
      lst_Entity.Add(xrow);
    }
    . . .