25.7 fb clinpath panic notification

onprc_ehr/resources/queries/onprc_ehr/ChemistryPanicNotification.sql

@@ -0,0 +1,17 @@
+select a.Id,
+       a.date,
+       a.servicerequested,
+       b.testid,
+       b.qualresult,
+       a.vet,
+       a.created,
+       a.objectid,
+      (select j.rowid from ehr.tasks j where j.taskid = a.taskid) as taskid
+
+
+from study.ClinpathRuns a, study.chemistryResults b
+Where  a.objectid = b.runid
+  And a.type = 'biochemistry'
+  And b.qualresult like '%panic%'
+  And a.qcstate = 18
+  And b.qcstate = 18

onprc_ehr/resources/queries/onprc_ehr/ChemistryPanicNotification.xml

@@ -0,0 +1,14 @@
+<query xmlns="http://labkey.org/data/xml/query">
+    <metadata>
+        <tables xmlns="http://labkey.org/data/xml">
+            <table tableName="Chemistry Panic Test Values" tableDbType="NOT_IN_DB">
+                <columns>
+                    <column columnName="userId">
+                        <columnTitle>user ID</columnTitle>
+                        <isKeyField>true</isKeyField>
+                   </column>
+                </columns>
+            </table>
+        </tables>
+    </metadata>
+</query>

onprc_ehr/resources/scripts/onprc_ehr/onprc_triggers.js

@@ -1378,6 +1378,15 @@ exports.init = function(EHR){
         });
     });
 
+    // Added: 10-6-2025
+    EHR.Server.TriggerManager.registerHandlerForQuery(EHR.Server.TriggerManager.Events.AFTER_UPSERT, 'study', 'chemistryResults', function (helper, scriptErrors, row, oldRow) {
+
+        if (row.Id && row.qualresult && row.qualresult.indexOf('panic') !== -1)  {
+               console.log("panic values:  " + row.qualresult);
+            triggerHelper.sendClinpathPanicEmail(row.Id, row.runid);
+        }
+    });
+
     //Added: 10-4-2022  R.Blasa
     EHR.Server.TriggerManager.registerHandler(EHR.Server.TriggerManager.Events.COMPLETE, function(event, errors, helper){
         // Send notifications when requests approved

onprc_ehr/src/org/labkey/onprc_ehr/query/ONPRC_EHRTriggerHelper.java

@@ -54,6 +54,9 @@
 import org.labkey.api.query.QueryService;
 import org.labkey.api.query.QueryUpdateServiceException;
 import org.labkey.api.query.UserSchema;
+import org.labkey.api.security.Group;
+import org.labkey.api.security.MemberType;
+import org.labkey.api.security.SecurityManager;
 import org.labkey.api.security.User;
 import org.labkey.api.security.UserManager;
 import org.labkey.api.security.UserPrincipal;
@@ -63,6 +66,7 @@
 import org.labkey.api.util.MailHelper;
 import org.labkey.api.util.PageFlowUtil;
 import org.labkey.api.util.Pair;
+import org.labkey.api.util.logging.LogHelper;
 import org.labkey.onprc_ehr.ONPRC_EHRManager;
 import org.labkey.onprc_ehr.ONPRC_EHRModule;
 import org.labkey.onprc_ehr.ONPRC_EHRSchema;
@@ -99,7 +103,7 @@
  */
 public class ONPRC_EHRTriggerHelper
 {
-    private static final Logger _log = LogManager.getLogger(ONPRC_EHRTriggerHelper.class);
+    private static final Logger _log = LogHelper.getLogger(ONPRC_EHRTriggerHelper.class, "Fill in description");
     private static final String NONRESTRICTED = "Nonrestricted";
     private static final String EXPERIMENTAL_EUTHANASIA = "EUTHANASIA, EXPERIMENTAL";
     private static final String NON_EXPERIMENTAL_EUTHANASIA = "EUTHANASIA, NONEXPERIMENTAL";
@@ -2600,7 +2604,6 @@ public void updateArrivalrecords(String id, Date date) throws Exception
         keys.add(FieldKey.fromString("lsid"));
         final Map<FieldKey, ColumnInfo> colMap = QueryService.get().getColumns(ti, keys);
 
-
         final List<Map<String, Object>> toUpdate = new ArrayList<>();
         final List<Map<String, Object>> oldKeys = new ArrayList<>();
         TableSelector ts = new TableSelector(ti, colMap.values(), new SimpleFilter(FieldKey.fromString("Id"), id, CompareType.IN), null);
@@ -2633,8 +2636,148 @@ public void exec(ResultSet object) throws SQLException
         }
     }
 
+    public void sendClinpathPanicEmail(String id, String runid)
+    {
+        String subject = "Chemistry Results with Panic values";
+
+
+        final TableInfo ti = getTableInfo("onprc_ehr", "ChemistryPanicNotification");
+        SimpleFilter filter = new SimpleFilter(FieldKey.fromString("Id"), id, CompareType.EQUAL);
+        filter.addCondition(FieldKey.fromString("objectid"), runid, CompareType.EQUAL);
+
+
+        List<FieldKey> names= new ArrayList<>();
+        FieldKey clinpathFieldKey = FieldKey.fromString("objectid");
+        names.add(clinpathFieldKey);
+        names.add(FieldKey.fromString("qualResult"));
+        names.add(FieldKey.fromString("servicerequested"));
+        names.add(FieldKey.fromString("testid"));
+        names.add(FieldKey.fromString("date"));
+        names.add(FieldKey.fromString("Id"));
+        names.add(FieldKey.fromString("vet"));
+        names.add(FieldKey.fromString("taskid"));
+
+
+        final Map<FieldKey, ColumnInfo> colKeys = QueryService.get().getColumns(ti, names);
+        final ColumnInfo clinpathColumn = colKeys.get(clinpathFieldKey);
+        TableSelector ts = new TableSelector(ti, colKeys.values(), filter, null);
+
+        final StringBuilder html = new StringBuilder();
+
+
+        if (ts.getRowCount() == 0)
+        {
+            html.append("There are no Chemistry Panlc Values to display");
+
+            return;
+        }
+        else
+        {
+
+            html.append("<table border=1 style='border-collapse: collapse;'>");
+            html.append("<tr style='font-weight: bold;'><td>Animal ID</td><td>Date</td><td>Service Requested</td><td> Panel Test Name</td><td> Qual Results</td><td>Task ID </td><td> Vet/PI Name</td></tr>\n");
+            ts.forEach(new Selector.ForEachBlock<ResultSet>()
+               {
+
+                   @Override
+                   public void exec(ResultSet rs) throws SQLException
+                   {
+
+                       TableInfo ti2 = getTableInfo("onprc_ehr", "Labwork_Requestor_Vets");
+                       SimpleFilter filter2 = new SimpleFilter(FieldKey.fromString("userid"), rs.getString("vet"));
+                       filter2.addCondition(FieldKey.fromString("DisableDate"), true, CompareType.ISBLANK);
+
+
+                       TableSelector ts2 = new TableSelector(ti2, PageFlowUtil.set("LastName"), filter2, null);
+                       List<String> ret2 = ts2.getArrayList(String.class);
+                       if (!ret2.isEmpty())
+                       {
+                           for (String Vetname : ret2)
+                           {
+                               html.append("<tr><td>" + PageFlowUtil.filter(rs.getString("Id")) +
+                                       "</td><td>" + PageFlowUtil.filter(rs.getString("date")) +
+                                       "</td><td>" + PageFlowUtil.filter(rs.getString("servicerequested")) +
+                                       " </td><td>" + PageFlowUtil.filter(rs.getString("testid")) +
+                                       " </td><td>" + PageFlowUtil.filter(rs.getString("qualResult")) +
+                                       " </td><td>" + PageFlowUtil.filter(rs.getString("taskid")) +
+                                       "</td><td>" + PageFlowUtil.filter(Vetname) + "</td></tr>\n");
+                               break;
+
+                           }
+                       }
+
+                   }
+
+               }
+
+            );
+
+        }
 
 
+        final TableInfo tt = getTableInfo("study", "clinpathRuns");
+        SimpleFilter filtert = new SimpleFilter(FieldKey.fromString("objectid"), runid, CompareType.EQUAL);
+        filter.addCondition(FieldKey.fromString("id"), id, CompareType.EQUAL);
+
+        TableSelector tst = new TableSelector(ti, PageFlowUtil.set("vet"), filter, null);
+        tst.forEach(new Selector.ForEachBlock<>()
+        {
+            @Override
+            public void exec(ResultSet rs) throws SQLException
+            {
+                Integer vetId = rs.getInt("vet");
+                Set<UserPrincipal> recipients = getRecipients(vetId);
+                if (recipients.isEmpty())
+                {
+                    _log.warn("No recipients, unable to send EHR trigger script email");
+                    return;
+                }
+                else
+                {
+                    html.append("</table>\n");
+
+                    sendMessage(subject, html.toString(), recipients);
+
+                }
+
+            }
+
+
+        });
+
+
+    }
+
+
+    private Set<UserPrincipal> getRecipients(Integer... userIds)
+    {
+        Set<UserPrincipal> recipients = new HashSet<>();
+        for (Integer userId : userIds)
+        {
+            if (userId > 0)
+            {
+                UserPrincipal up = SecurityManager.getPrincipal(userId);
+                if (up != null)
+                {
+                    if (up instanceof  User)
+                    {
+                        recipients.add(up);
+                    }
+                    else
+                    {
+                        for (UserPrincipal u : SecurityManager.getAllGroupMembers((Group)up, MemberType.ACTIVE_USERS))
+                        {
+                            if (u.isActive())
+                                recipients.add(u);
+                        }
+                    }
+                }
+            }
+        }
+
+        return recipients;
+    }
+
     //Added 9-30-2025
     public String retrieveGeographic_Origin(String Id)