✎ Push уведомления [Клиника Wiki]

Вы загрузили старую ревизию документа. Сохранив её, вы создадите новую текущую версию с этим содержимым.

====== Push уведомления ======

[[https://ru.wikipedia.org/wiki/Технология_push|Технология push]] используется для рассылки персонализированных сообщений на мобильные телефоны. Для рассылки сообщений используется сервер FCM((Firebase Cloud Message server))

Подписка на функции осуществляется через функцию API((запрос ''/client/modify/push'')) Личного кабинета пациента.\\
Непосредственная рассылка объектов осуществляется [[index|сервисом смс-рассылки]]

В настоящий момент используется несколько типов передаваемых сообщений:
  * Генерируется Инфоклиникой\\ Генерация осуществляется на основе триггеров к соответствующим таблицам данных
    * [[#Запись]]
    * [[#Повторная явка]]
    * [[#Результат исследования]]
    * [[#Оценка приема]]
  * Генерируется на сайте
    * [[#Акции]]

Тип рассылки: Только Push.\\
Время рассылки: с 0ч до 23ч.

==== Запись ====
<spoiler|Push объект>
<code javascript>
{
    "to":"<to>",
    "time_to_leave":2119200,
    "notification":{
        "title":"Назначение перенесено",
        "body":"Назначение к доктору перенесено с 07.11.2017 на 08.11.2017.",
        "sound":"true",
        "tag":"schedule"
    },
    "data":{
        "datatype":"schedule",
        "action":"[new|move|delete]",
        "old":{
            "SchedId":641286841,
            "DCode":50000040,
            "DName":"Рябинина С.Н.",
            "WorkDate":"07.11.2017",
            "BHour":9,
            "BMin":30
        },
        "new":{
            "SchedId":641286841,
            "DCode":50000040,
            "DName":"Рябинина С.Н.",
            "WorkDate":"08.11.2017",
            "BHour":8,
            "BMin":30
        },
    }
}
</code>
В поле ''action'' передается производимое действие (''new'' - новое назначение; ''move'' - перенесено назначение; ''delete'' - удалено назначение)
</spoiler>

<spoiler|Триггер>
<code sql> 
create or alter trigger USER$SCHEDULE_PUSH for SCHEDULE
active after insert or update or delete position 99
AS
declare action varchar(6);
declare send int;
declare ttl int;
declare time_delay int; -- время, после которого рассылка не формируется;
declare notify type of column clphones.NOTIFICATIONID;
--
declare logid type of column sms_log.logid;
declare smsid type of column sms_logdet.smsid;

declare uid type of column doctor.dcode;
declare filial type of column filials.filid;

declare smstypeid type of column sms_log.smstypeid;
declare smsrefid type of column sms_log.smsrefid;
declare smsprofileid type of column sms_log.smsprofileid;
declare internalid type of column sms_log.internalid;
declare pcode type of column sms_log.pcode;
declare planftime type of column sms_log.planftime;
declare pushtext type of column sms_log.smstext;
begin
  time_delay = 600;

if (exists(select * from repl$getaccess where repl$access = 'USER')) then
  begin
    if (exists(select * from repl$getgrpid g join filials f on f.grpid=g.repl$grpid where f.ismain=1)) then
      exit;

-- формируем переменные
    send = 0;
    ttl = 0;
    if (updating)then
    begin
      if (new.workdate!=old.workdate) then
      begin
        send = 1;
      end
      else if (new.bhour*60+new.bmin != old.bhour*60+old.bmin) then
      begin
        send = 1;
      end
      ttl = datediff(second from current_timestamp to dateadd(new.bmin minute to dateadd(new.bhour hour to new.workdate)) );
      smsrefid = 70002;
      pcode = new.pcode;
      action = 'move';
    end
    else if (inserting) then
    begin
      send = 1;
      ttl = datediff(second from current_timestamp to dateadd(new.bmin minute to dateadd(new.bhour hour to new.workdate)) );
      smsrefid = 70001;
      pcode = new.pcode;
      action = 'new';
    end
    else if (deleting) then
    begin
      send = 1;
      ttl = datediff(second from current_timestamp to dateadd(old.bmin minute to dateadd(old.bhour hour to old.workdate)) );
      smsrefid = 70003;
      pcode = old.pcode;
      action = 'delete';
    end

if (ttl>2419200) then
      ttl = 2419200;

-- смотрим наличие пациента
    if (coalesce(pcode,0)=0) then
      exit;

-- смотрим наличие идентификатора
    notify = null;
    select NOTIFICATIONID from clphones cp where cp.pcode= :pcode and coalesce(cp.isdeleted,0)=0 and cp.phonetype=21
      into notify;
    notify = coalesce(notify,'-');

select current_uid from s_session_info into uid;
    -- формируем данные
    -- если есть идентификатор, можно рассылать, событие будет не ранее чем через time_delay сек
    if (notify != '-' and send=1 and ttl>time_delay)then
    begin
      pushtext = '{"to":"'||notify||'","time_to_leave":'||ttl||',"notification":{';

if (inserting) then
      begin
        pushtext = pushtext||'"title":"Новое назначение","body":"У Вас новое назначение к доктору на '||(select datestr from formatdate(new.workdate))||'."';
      end
      else if (updating) then
      begin
        pushtext = pushtext||'"title":"Назначение перенесено","body":"Назначение к доктору перенесено';
        if (old.workdate != new.workdate) then
          pushtext = pushtext||' с '||(select datestr from formatdate(old.workdate));
        pushtext = pushtext||' на '||(select datestr from formatdate(new.workdate))||'."';
      end
      else
      begin
        pushtext = pushtext||'"title":"Назначение отменено","body":"Назначение к доктору на '||(select datestr from formatdate(old.workdate))||' отменено."';
      end
      pushtext = pushtext||',"sound":"true","tag":"schedule"},';
      pushtext = pushtext||'"data":{"action":"'||action||'",';

-- формируем старый объект
      if (updating or deleting) then
      begin
        pushtext = pushtext||'"old":{"SchedId":"'||old.schedid||'","DCode":"'||old.dcode||'","DName":"'||(select dname from doctor where dcode= old.dcode)||'","WorkDate":"'||(select datestr from formatdate(old.workdate))||'","BHour":"'||old.bhour||'","BMin":"'||old.bmin||'"},';
        filial = old.filial;
        internalid = old.schedid;
      end

-- формируем новый объект
      if (inserting or updating) then
      begin
        pushtext = pushtext||'"new":{"SchedId":'||new.schedid||',"DCode":"'||new.dcode||'","DName":"'||(select dname from doctor where dcode= new.dcode)||'","WorkDate":"'||(select datestr from formatdate(new.workdate))||'","BHour":"'||new.bhour||'","BMin":"'||new.bmin||'"},';
        filial = new.filial;
        internalid = new.schedid;
      end
      planftime = dateadd(ttl second to current_timestamp);

pushtext = pushtext||'}}';

logid = gen_id(SMS_LOG_GEN, 1);
      smsid = gen_id(SMS_GEN, 1);
      smstypeid = 0;
      smsprofileid = 1;
      --
      insert into SMS_LOG(LOGID,SMSTYPEID,SMSREFID,SMSPROFILEID,FILIAL,
                 CREATEDATE,SMSTEXT,PCODE,UID,INTERNALID,PLANBTIME,PLANFTIME,STATE)
          values(:logid, :smstypeid, :smsrefid, :smsprofileid, :filial,
                 current_timestamp, :pushtext, :pcode, :uid, :internalid, current_timestamp, :planftime, 0);
      insert into SMS_LOGDET(SMSID,LOGID,PHONETYPE,EXTSMSID,PHPREFIX,PHONE,STATE,NOTIFICATIONID)
          values(:smsid, :logid, 21, null, null, null, 0, :notify);
    end
  end
  --
end
</code>
</spoiler>

=== Нюансы ===
Рассылка будет формироваться, в случае если назначение позже 10 минут от текущего времени

==== Повторная явка ====
<spoiler|Push объект>
<code javascript>
{
    "to":"<to>",
    "time_to_leave":2119200,
    "notification":{
        "title":"Приглашение",
        "body":"Приглашаем Вас на повторный прием к доктору",
        "sound":"true",
        "tag":"record"
    },
    "data":{
        "action":"record",
        "DCode":10101010,
        "DName":"Фартух Д.А.",
        "DepNum":120,
        "DepName":"Дерматолог",
        "filial":1,
        "FName":"Коломенский",
        "WorkDate":"21.11.2017",
        "SchList":"0,990099,990088",
        "wtime":45
    }
}
</code>
</spoiler>

<spoiler|Скрипт>
<code sql>
execute block
as
/*
 * Скрипт рассылки пуш-уведомлений для повторного визита пациентов
 *
 * Автор: Коробка А.А.
 */
-- константы
declare ttl int;
declare day_delay int;
declare datemsg date;
declare cnt int;
declare uid type of column doctor.dcode;
-- данные протокола
declare date_interv int;
declare p1 int;
declare txt type of column paramsinfo.valuetext;
declare tmp type of column paramsinfo.valuetext;
declare date_litera ttext16;
-- данные пациента
declare pcode type of column clients.pcode;
declare notify type of column clphones.notificationid;
-- данные приема
declare treatcode type of column treat.treatcode;
declare trdate type of column treat.treatdate;
declare fjid type of column filials.jid;
declare filial type of column filials.filid;
declare fname type of column filials.shortname;
declare depnum type of column departments.depnum;
declare depname type of column departments.depname;
declare dcode type of column doctor.dcode;
declare dname type of column doctor.dname;
declare dcode_send type of column doctor.dcode;
-- данные по услуге
declare spec int;
declare schid type of column wschema.schid;
declare worktime int;
declare structid type of column wschema.structid;
-- вставка сообщения
declare logid type of column sms_log.logid;
declare smsid type of column sms_logdet.smsid;
declare smstypeid type of column sms_log.smstypeid;
declare smsrefid type of column sms_log.smsrefid;
declare smsprofileid type of column sms_log.smsprofileid;
declare pushtext type of column sms_log.smstext;
declare planbtime type of column sms_log.planbtime;
declare planftime type of column sms_log.planftime;
begin
  day_delay = 1; -- приглашать за 1 день минимум
  ttl = day_delay*24*60*60; -- напоминание держится (расчет на отправку сразу)
  uid = null;
  -- филиал выполнения
  select first 1 f.filid, f.shortname, f.jid
    from repl$getgrpid g
    left join filials f on f.grpid=g.repl$grpid
    into filial, fname, fjid;
  -- поиск структуры
  select first 1 structid from pricestructure
   where bdate<= current_date+1+ :day_delay order by bdate desc
    into structid;
  for select p.pcode, p.treatdate, dcode, treatcode, lower(trim(valuetext)), cp.notificationid
        from paramsinfo p
        left join clphones cp on cp.pcode=p.pcode
       where p.codeparams in (990001860/* повторная явка */,990002043/*гастро*/,
                              990001689/*аллерг-1*/,990001823/*аллерг-2*/,
                              990001748/*невро*/,640000067/*берем*/,
                              990002216/*офтальм*/)
         and p.ver_no = 0
         and p.treatdate between current_date-370 and current_date
         and trim(valuetext)!=''
         and valuetext not like '%за результатами%'
         and coalesce(cp.isdeleted,0)=0
         and cp.phonetype=21
         and cp.notificationid>''
  into pcode, trdate, dcode, treatcode, txt, notify do
  begin
    datemsg = null;
    date_interv = 0;
    --
    while (position('  ', txt)>0) do
    begin
      txt = replace(txt, '  ', ' ');
    end

-- первым указано `через N период`
    if (position('через ', txt)=1) then
    begin
      -- отсекаем 1е слово
      tmp = trim(substring(txt from 6));
      -- иищем начало 2го слова
      p1 = position(' ', tmp);
      if (p1>0) then
      begin
        begin
          date_interv = trim(substring(tmp from 1 for p1));
          date_litera = trim(substring(tmp from p1 for 6));
        end
        when any do begin end
      end
      --
      if (date_interv>0) then
      begin
        datemsg = case when date_litera like 'год%' then dateadd(date_interv year  to trdate)
                       when date_litera like 'мес%' then dateadd(date_interv month to trdate)
                       when date_litera like 'нед%' then dateadd(date_interv week  to trdate)
                       when date_litera like 'дн%'  then dateadd(date_interv day   to trdate)
                       when date_litera like 'ден%' then dateadd(date_interv day   to trdate)
                       else null end;
      end
    end

-- первой указана дата
    else
    begin
      tmp = substring(txt from 1 for 10);
      begin
        begin
          datemsg = cast(tmp as date);
        end
        when any do begin end
      end

tmp = substring(txt from 1 for 8);
      if (datemsg is null) then
      begin
        begin
          datemsg = cast(tmp as date);
        end
        when any do begin end
      end
    end

if ( datemsg between current_date+ :day_delay and current_date+1+ :day_delay ) then
    begin
      -- беру специализацию
      select first 1 ws.speccode from treat t
        join orderdet od on od.orderno=t.orderno
        join wschema ws on ws.schid=od.schcode
       where t.treatcode= :treatcode
         and ws.consult=1
        into spec;
      -- смотрю наличие записей к доктору
      select count(*)
        from doctor d
        left join USER$WEB__DOCTOR_WSCHEMA(d.dcode, null, :spec) u on 1=1
        left join schedule s on s.workdate= :datemsg and s.dcode=d.dcode
       where d.filial= :filial
         and coalesce(d.locked,0)=0
         and u.avalue=1
         and s.pcode= :pcode
        into cnt;
      -- готовлю сообщение
      if (cnt=0) then
      begin
        pushtext = null;
        schid = null;
        dcode_send = null;
        select first  1 schid, dcode, worktime
          from (select ws.schid, d.dcode, coalesce(ws.worktime, dic.rekvint3) worktime,
                      (ds.endhour*60+ds.endmin) - (ds.beghour*60+ds.begmin) alltime,
                      (select sum(case when pcode>0 or nazndis=1 then (s.fhour*60+s.fmin)-(s.bhour*60+s.bmin) else 0 end )
                         from schedule s left join shedmarks m on m.mrkid=s.tmstatus where s.schedident=ds.schedident) denytime
                  from wschema ws
                  left join get_pricebyid(:datemsg, 1, :filial, :fjid, 0, ws.schid) s on 1=1
                  left join doctspec dsp on dsp.speccode= ws.speccode
                  join doctor d on d.dcode=dsp.dcode and d.filial= :filial
                  left join USER$WEB__DOCTOR_WSCHEMA(d.dcode, ws.schid) u on 1=1
                  join doctshedule ds on ds.dcode=d.dcode and ds.wdate= :datemsg
                  left join dicinfo dic on dic.refid=-10010011 and dic.dcode=d.dcode and dic.rekvint1=ws.schid
                 where ws.structid= :structid and ws.speccode= :spec and ws.consult=1
                   and s.sprice>0
                   and u.avalue=1
                 order by coalesce(repconsult,0) desc /* повторная выше */, case when d.dcode= :dcode then 1 else 0 end desc /* тот же доктор выше */)
         where alltime>denytime /* есть время для записи */
           and alltime-denytime > worktime
          into schid, dcode_send, worktime;
        -- возможность формирования
        if (schid is not null and dcode_send is not null) then
        begin
          -- данные
          select d.dname, dep.depnum, dep.depname
            from doctor d
            left join departments dep on dep.depnum=d.depnum
           where  d.dcode= :dcode_send
            into dname, depnum, depname;
          -- формирование текста
          pushtext = '{"to":"'||notify||'","time_to_leave":'||ttl||',"notification":{';
          pushtext = pushtext||'"title":"Приглашение","body":"Приглашаем Вас на повторный прием к доктору.",';
          pushtext = pushtext||'"sound":"true","tag":"record"},';
          pushtext = pushtext||'"data":{"action":"record",';
          pushtext = pushtext||'"DCode":'||dcode_send||',"DName":"'||dname||'",';
          pushtext = pushtext||'"DepNum":'||depnum||',"DepName":"'||depname||'",';
          pushtext = pushtext||'"filial":'||filial||',"FName":"'||fname||'",';
          pushtext = pushtext||'"WorkDate":"'||(select datestr from formatdate(:datemsg))||'",';
          pushtext = pushtext||'"SchList":"'||schid||'","wtime":"'||worktime||'",';
          pushtext = pushtext||'}}';
          -- заполняем данные
          logid = 1;--gen_id(SMS_LOG_GEN, 1);
          smsid = 1;--gen_id(SMS_GEN, 1);
          smstypeid = 0;
          smsprofileid = 1;
          smsrefid = 70005;
          planbtime = dateadd(9 hour to cast(current_date as timestamp));
          planftime = dateadd(18 hour to cast(datemsg as timestamp));
          -- вставляем запись
          insert into sms_log(logid,smstypeid,smsrefid,smsprofileid,filial,
                      createdate,smstext,pcode,uid,internalid,planbtime,planftime,state)
               values(:logid, :smstypeid, :smsrefid, :smsprofileid, :filial,
                      current_timestamp, :pushtext, :pcode, :uid, :treatcode, :planbtime, :planftime, 0);
          insert into sms_logdet(smsid,logid,phonetype,extsmsid,phprefix,phone,state,notificationid)
               values(:smsid, :logid, 21, null, null, null, 0, :notify);   
        end
      end
    end
  end
end
</code>     
</spoiler>

==== Результат исследования ====
<spoiler|Push объект>
<code javascript>
{
    "to":"<to>",
    "time_to_leave":"2119200",
    "notification":{
        "title":"Новое заключение",
        "body":"У Вас новое заключение доктора (результат исследования)",
        "sound":"true",
        "tag":"protocol"
    },
    "data":{
        "action":"protocol",
        "ProtocolID":99009900,
        "TreatCode":99009911,
        "DCode":99009922,
        "DName":"Фартух Д.А.",
        "ProtName":"Биохимия крови",
    }
}
</code>
</spoiler>

==== Оценка приема ====
<spoiler|Push объект>
<code javascript>
{
    "to":"<to>",
    "time_to_leave":"2119200",
    "notification":{
        "title":"Оценка посещения",
        "body":"Пожалуйста, оцените прием доктора",
        "sound":"true",
        "tag":"mark"
    },
    "data":{
        "action":"mark",
        "SchedId":99009900,
        "DCode":99009922,
        "DName":"Фартух Д.А.",
        "filial":1,
        "FName":"Коломенский",
    }
}
</code>
</spoiler>

<spoiler|Триггер>
<code sql>
create or alter trigger USER$ORDERS_PUSH for ORDERS
active after insert or update or delete position 99
as
--
declare logid type of column sms_log.logid;
declare smsid type of column sms_logdet.smsid;
declare smstypeid type of column sms_log.smstypeid;
declare smsrefid type of column sms_log.smsrefid;
declare smsprofileid type of column sms_log.smsprofileid;
declare planbtime type of column sms_log.planbtime;
declare planftime type of column sms_log.planftime;
declare pushtext type of column sms_log.smstext;
declare ttl int;
--
declare uid type of column doctor.dcode;
declare notify type of column clphones.notificationid;
declare summa type of column orderdet.schamount;
--
declare schedid type of column schedule.schedid;
declare filial type of column filials.filid;
declare fname type of column filials.shortname;
declare dcode type of column doctor.dcode;
declare dname type of column doctor.dname;
begin
  if (exists(select * from repl$getaccess where repl$access = 'USER')) then
  begin
    if (exists(select * from repl$getgrpid g join filials f on f.grpid=g.repl$grpid where f.ismain=1)) then
      exit;

select current_uid from s_session_info into uid;
    ttl = 7*24*60*60; -- 1 неделя  секундах
    -- вставка или обновление
    if (inserting or updating)then
    begin
      -- проверяем наличие идентификатора
      notify = null;
      select notificationid from clphones cp where cp.pcode= new.pcode and coalesce(cp.isdeleted,0)=0 and cp.phonetype=21
        into notify;
      notify = coalesce(notify,'-');
      -- проверяем сумму
      select sum(coalesce(schamount,0)) from orderdet where orderno= new.ordercod
        into summa;
      -- проверяем возможность рассылки (SCHEDULE)
      select max(coalesce(s.schedid,0)) from treat t join schedule s on s.treatcode=t.treatcode
       where t.orderno= new.ordercod and s.workdate=current_date
        into schedid;

-- объек добавляем/изменяем
      if (notify != '-' and summa > 0 and schedid>0) then
      begin
        -- формируем запись
        logid = null;
        select logid from sms_log where smsrefid=70008 and pcode= new.pcode and internalid= :schedid
          into logid;
        planbtime = dateadd(2 hour to current_timestamp);  -- не ранее чем через 2 часа после приема
        planftime = dateadd(ttl second to planbtime);      -- не позже ttl (неделя), т.к. не имеет смысла
        if (logid is null) then
        begin
          -- данные
          select d.dcode, d.dname, f.filid, f.shortname from schedule s
            left join doctor d on d.dcode=s.dcode
            left join filials f on f.filid=s.filial
           where s.schedid= :schedid
            into dcode, dname, filial, fname;
          -- формируем объект
          pushtext = '{"to":"'||notify||'","time_to_leave":'||ttl||',"notification":{';
          pushtext = pushtext||'"title":"Оценка посещения","body":"Пожалуйста, оцените прием доктора",';
          pushtext = pushtext||'"sound":"true","tag":"mark"},';
          pushtext = pushtext||'"data":{"action":"mark",';
          pushtext = pushtext||'"SchedId":'||schedid||',';
          pushtext = pushtext||'"DCode":'||dcode||',"DName":"'||dname||'",';
          pushtext = pushtext||'"filial":'||filial||',"FName":"'||fname||'",';
          pushtext = pushtext||'}}';

-- заполняем данные
          logid = gen_id(SMS_LOG_GEN, 1);
          smsid = gen_id(SMS_GEN, 1);
          smstypeid = 0;
          smsprofileid = 1;
          smsrefid = 70008;
          -- вставляем запись
          insert into sms_log(logid,smstypeid,smsrefid,smsprofileid,filial,
                     createdate,smstext,pcode,uid,internalid,planbtime,planftime,state)
              values(:logid, :smstypeid, :smsrefid, :smsprofileid, new.filial,
                     current_timestamp, :pushtext, new.pcode, :uid, :schedid, :planbtime, :planftime, 0);
          insert into sms_logdet(smsid,logid,phonetype,extsmsid,phprefix,phone,state,notificationid)
              values(:smsid, :logid, 21, null, null, null, 0, :notify);
        end
        else
        begin
          -- обновляем запись
          update sms_log set planbtime = :planbtime , planftime = :planftime
           where logid= :logid;
          update sms_logdet set state=0 where logid= :logid and state not in (1,2);
        end
      end

-- объект удаляем
      else
      begin
        logid = null;
        select logid from sms_log where smsrefid=70008 and pcode= new.pcode and internalid= :schedid
          into logid;
        -- деактивируем запись с ошибкой
        if (logid is not null and schedid>0) then
          update sms_logdet set state=-6 where state=0 and logid= :logid;
      end
    end

-- удаление
    else
    begin
      -- вычисляем данные
      select max(coalesce(s.schedid,0)) from treat t join schedule s on s.treatcode=t.treatcode
       where t.orderno= old.ordercod
        into schedid;
      logid = null;
      select logid from sms_log where smsrefid=70008 and pcode= old.pcode and internalid= :schedid
        into logid;
      -- деактивируем запись с ошибкой
      if (logid is not null and schedid>0) then
        update sms_logdet set state=-6 where state=0 and logid= :logid;
    end
  end
end
</code>
</spoiler>
 
==== Акции ====
<spoiler|Push объект>
(при передаче объекта используется картинка с самым маленьким размером - 2)
<code javascript>
{
    "to":"/topic/shares",
    "time_to_leave":"2119200",
    "notification":{
        "title":"Оценка посещения",
        "body":"Пожалуйста, оцените прием доктора",
        "sound":"true",
        "tag":"shares"
    },
    "data":{
        "action":"shares",
        "info":{
            "infoId": 0,
            "infoPreview": "string",
            "infoTitle": "string",
            "infoText": "string",
            "record": "string",
            "link": "string"
        }
    }
}
</code>
</spoiler>

Сводка изменений

Примечание: редактируя эту страницу, вы соглашаетесь на использование своего вклада на условиях следующей лицензии: CC Attribution-Share Alike 4.0 International

Наверх

расширенная.настройка/рассылка.уведомлений/push.1558017611.txt.gz · Последние изменения: 2019/05/16 17:40 (внешнее изменение)