增加异常工艺参数预警通知

zrg

2026-02-27 7ca0d964d2df19bf56e8a8a96f34f26a139b078d

 DingDingMsg/MesMessage/MesMessageList.cs

@@ -145,14 +145,14 @@
                    return;
                }

                #region 异常工艺参数预警（每 5 分钟执行一次，但定时器为1分钟，所以内部判断时间差）
                #region 异常工艺参数预警（每 1 分钟执行一次，但定时器为1分钟，所以内部判断时间差）
                DBHelper.CustomWriteLog("开始进入执行循环 :", DateTime.Now.ToString("yyyy-MM-dd"));
             
                #endregion

                #region 异常工艺参数预警处理（每分钟执行）
                // 查询出要更新的异常参数（最近5分钟内的未发送数据）
                string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 4, GETDATE()) AND HSendFlag = 0";
                // 查询出要更新的异常参数（最近1分钟内的未发送数据）
                string Sql = "select HItemID from Sb_EquipMentCollectionTechParam_ERR where HCreateTime>=DATEADD(minute, - 1, GETDATE()) AND HSendFlag = 0";
                DBHelper.CustomWriteLog("查询出异常的参数:" + Sql, DateTime.Now.ToString("yyyy-MM-dd"));
                DataSet dsErr = oCN.RunProcReturn(Sql, "Sb_EquipMentCollectionTechParam_ERR");
                if (dsErr != null && dsErr.Tables[0].Rows.Count > 0)
@@ -242,7 +242,55 @@
                    }
                    else if (rule == "APP")
                    {
                        
                        // 查询出要发信息的异常参数
                        string newSql = @"SELECT 工序名称, STUFF((
                                            SELECT DISTINCT '; ' + 设备编码 + ' - ' + 工艺参数名称 + ' - 数采值: ' + CAST(数采值 AS VARCHAR(10)) 
                                                   + ' - 上限值: ' + CAST(上限值 AS VARCHAR(10)) + ' - 下限值: ' + CAST(下限值 AS VARCHAR(10))  
                                            FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS InnerTable  
                                            WHERE InnerTable.工序名称 = OuterTable.工序名称  
                                              AND 发现异常时间 >= DATEADD(minute, -1, GETDATE())
                                            FOR XML PATH('')), 1, 2, '') AS 内容  
                                          FROM h_v_Sb_EquipMentCollectionTechParam_ERRList AS OuterTable  
                                          GROUP BY 工序名称";

                        DataSet dsContent = oCN.RunProcReturn(newSql, "h_v_Sb_EquipMentCollectionTechParam_ERRList");

                        for (int j = 0; j < dsContent.Tables[0].Rows.Count; j++)
                        {
                            DBHelper.CustomWriteLog("异常内容数量   " + dsContent.Tables[0].Rows.Count, DateTime.Now.ToString("yyyy-MM-dd"));
                            string HContext = dsContent.Tables[0].Rows[j]["内容"].ToString();
                            string HDeptName = dsContent.Tables[0].Rows[j]["工序名称"].ToString();
                            if (!string.IsNullOrEmpty(HContext) && HContext.ToLower() != "null")
                            {
                                // 查询出要发送的人
                                string newSql1 = $@"select a.HDingDingUserID 钉钉id, a.Czymc 接收人 
                                                from Gy_Czygl a 
                                                left join System_UserGroupInfo b on a.Czybm = b.UserId
                                                left join System_UserGroup c on b.GroupId = c.GroupID  
                                                where c.GroupName = '{HDeptName}工艺异常预警接收人'";                             
                                DataSet dsUsers = oCN.RunProcReturn(newSql1, "Gy_Czygl");
                                if (dsUsers.Tables[0].Rows.Count > 0)
                                {

                                    for (int i = 0; i < dsUsers.Tables[0].Rows.Count; i++)
                                    {
                                        string HName = dsUsers.Tables[0].Rows[i]["钉钉id"].ToString();

                                        var ds = oCN.RunProcReturn($"exec h_p_OA_WorkLinkBill_TechParam_ERR_Create '{HContext}','{HName}'", "h_p_OA_WorkLinkBill_TechParam_ERR_Create");
                                        if (ds != null && ds.Tables[0].Rows.Count > 0)
                                        {
                                            // 第一步：先获取字符串并判断是否为"0"，是则直接跳过
                                            int newHInterID = int.Parse(ds.Tables[0].Rows[0]["HInterID"].ToString());
                                            if (newHInterID != 0)
                                            {
                                                DBHelper.CustomWriteLog($"执行消息推送...{newHInterID}", DateTime.Now.ToString("yyyy-MM-dd"));
                                                GeTuiService.PubishSingle(newHInterID); // 同步方法，若耗时较长可考虑异步优化
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
                #endregion