|
@@ -70,8 +70,9 @@ namespace Ropin.Inspection.Service
|
|
|
/// <param name="Subject"></param>
|
|
|
/// <param name="rabbitMQModel"></param>
|
|
|
/// <param name="UrlId">跳转小程序URLID</param>
|
|
|
+ /// <param name="status">状态</param>
|
|
|
/// <returns></returns>
|
|
|
- public async Task<bool> PushAlarmMsgAsync(TpushMsgModel pushModel,string Subject=null,RabbitMQModel rabbitMQModel=null, string UrlId = null)
|
|
|
+ public async Task<bool> PushAlarmMsgAsync(TpushMsgModel pushModel,string Subject=null,RabbitMQModel rabbitMQModel=null, string UrlId = null,string status=null)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
@@ -81,16 +82,6 @@ namespace Ropin.Inspection.Service
|
|
|
log.Info($"发送消息-接收数据【{JsonConvert.SerializeObject(pushModel)}】");
|
|
|
int msgStatus = DataDictionaryHelper.GetMsgStatus(pushModel.C_MsgTypeCode);
|
|
|
pushModel.msgStatus = msgStatus;
|
|
|
-
|
|
|
- string miniProgramAppId = "";//跳转小程序的Appid
|
|
|
- //获取小程序页面
|
|
|
- string miniProgramPagePath = DataDictionaryHelper.GetXCXPage(pushModel.C_MsgTypeCode);
|
|
|
- if (!string.IsNullOrEmpty(miniProgramPagePath))
|
|
|
- {
|
|
|
- miniProgramPagePath = miniProgramPagePath+ UrlId;
|
|
|
- miniProgramAppId = WXConstModel.XCXAppId;
|
|
|
- }
|
|
|
-
|
|
|
string createBy = "6e864cbc-5252-11ec-8681-fa163e02b3e4";
|
|
|
var devStore = await _tdevDevStoreRepository.GetByIdAsync(pushModel.C_DevStoreCode);
|
|
|
if(devStore == null) return await Task.FromResult(false);
|
|
@@ -270,7 +261,6 @@ namespace Ropin.Inspection.Service
|
|
|
I_GenerationType = pushModel.GenerationType,
|
|
|
I_MsgStatus = pushModel.msgStatus,
|
|
|
C_DevStoreCode = pushModel.C_DevStoreCode,
|
|
|
- C_WxJumpURL = miniProgramPagePath,
|
|
|
C_Remark = "",
|
|
|
C_CreateBy = createBy,
|
|
|
C_Creator = "Api",
|
|
@@ -297,275 +287,93 @@ namespace Ropin.Inspection.Service
|
|
|
FileList.Add(mesFile);
|
|
|
}
|
|
|
}
|
|
|
- if (sendUserWechatIDList.Any())
|
|
|
+
|
|
|
+ _messageRepository.Create(message);
|
|
|
+ bool messResult = await _messageRepository.SaveAsync();
|
|
|
+ if (messResult)
|
|
|
{
|
|
|
- try
|
|
|
+ if (FileList != null && FileList.Count > 0)
|
|
|
{
|
|
|
- #region 一次性订阅 -不用了【2025-2-11】
|
|
|
- //switch (pushModel.C_MsgTypeCode)
|
|
|
- //{
|
|
|
- // case "MSG_TYPE_001"://通知维修消息
|
|
|
- // //var MSG_TYPE_001 = new
|
|
|
- // //{
|
|
|
- // // character_string19 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // // name4 = new { value = pushModel.UserName ?? "" },
|
|
|
- // // thing7 = new { value = pushModel.Subject ?? "" },
|
|
|
- // // time15 = new { value = pushModel.DevName ?? "" },
|
|
|
- // // thing16 = new { value = pushModel.Msg ?? "" }
|
|
|
- // //};
|
|
|
- // //new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_001, "jGFacWkS9keOmvN71DN-7qX-wR30NdqOuQaPSNIMfnk");//
|
|
|
- // var MSG_TYPE_001 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_001);//
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_002"://通知运维消息
|
|
|
- // //var MSG_TYPE_002 = new
|
|
|
- // //{
|
|
|
- // // character_string19 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // // name4 = new { value = pushModel.UserName ?? "" },
|
|
|
- // // thing7 = new { value = pushModel.Subject ?? "" },
|
|
|
- // // time15 = new { value = pushModel.DevName ?? "" },
|
|
|
- // // thing16 = new { value = pushModel.Msg ?? "" }
|
|
|
- // //};
|
|
|
- // //new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_002, "jGFacWkS9keOmvN71DN-7qX-wR30NdqOuQaPSNIMfnk");//
|
|
|
- // var MSG_TYPE_002 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_002);//
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_003"://通知巡检消息
|
|
|
- // //var MSG_TYPE_003 = new
|
|
|
- // //{
|
|
|
- // // character_string19 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // // name4 = new { value = pushModel.UserName ?? "" },
|
|
|
- // // thing7 = new { value = pushModel.Subject ?? "" },
|
|
|
- // // time15 = new { value = pushModel.DevName ?? "" },
|
|
|
- // // thing16 = new { value = pushModel.Msg ?? "" }
|
|
|
- // //};
|
|
|
- // //new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_003, "jGFacWkS9keOmvN71DN-7qX-wR30NdqOuQaPSNIMfnk");//
|
|
|
- // var MSG_TYPE_003 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_003);//
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_004"://巡检异常消息
|
|
|
- // var MSG_TYPE_004 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_004);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_005"://异常消除消息
|
|
|
- // var MSG_TYPE_005 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_005);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_006"://维修确认消息
|
|
|
- // var MSG_TYPE_006 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_006);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_007"://维修取消消息
|
|
|
- // var MSG_TYPE_007 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_007);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_008"://维修完成消息
|
|
|
- // case "MSG_TYPE_014"://正在维修消息
|
|
|
- // case "MSG_TYPE_015"://维修返工消息
|
|
|
- // case "MSG_TYPE_016"://维修完成确认
|
|
|
- // var MSG_TYPE_008 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_008);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_009"://运维取消消息
|
|
|
- // var MSG_TYPE_009 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_009);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_010"://异常确认消息
|
|
|
- // var MSG_TYPE_010 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_010);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_011"://设备启停消息
|
|
|
- // var MSG_TYPE_011 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_011);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_012"://设备点报警
|
|
|
- // var MSG_TYPE_012 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_012);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_013"://设备点报警取消
|
|
|
- // var MSG_TYPE_013 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_013);
|
|
|
- // break;
|
|
|
- // case "MSG_TYPE_019"://上报报警
|
|
|
- // case "MSG_TYPE_020"://报警取消
|
|
|
- // case "MSG_TYPE_021"://报警确认
|
|
|
- // case "MSG_TYPE_022"://报警完成
|
|
|
- // var MSG_TYPE_020 = new
|
|
|
- // {
|
|
|
- // character_string1 = new { value = pushModel.DevNumber ?? "" },
|
|
|
- // thing2 = new { value = pushModel.DevName ?? "" },
|
|
|
- // thing16 = new { value = pushModel.Subject ?? "" },
|
|
|
- // time5 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // thing6 = new { value = pushModel.Msg ?? "" }
|
|
|
- // };
|
|
|
- // new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, MSG_TYPE_020);
|
|
|
- // break;
|
|
|
- // default:
|
|
|
- // break;
|
|
|
- //}
|
|
|
- #endregion
|
|
|
+ int fileSaveResult = await _tsysMessageFileRepository.CreateRangeAsync(FileList);
|
|
|
+ }
|
|
|
+ string miniProgramAppId = "";//跳转小程序的Appid
|
|
|
+ //获取小程序页面
|
|
|
+ string miniProgramPagePath = DataDictionaryHelper.GetXCXPage(pushModel.C_MsgTypeCode, message.C_ID, UrlId, pushModel.C_DevStoreCode, status);
|
|
|
+ if (!string.IsNullOrEmpty(miniProgramPagePath))
|
|
|
+ {
|
|
|
+ miniProgramAppId = WXConstModel.XCXAppId;
|
|
|
+ }
|
|
|
+ if (sendUserWechatIDList.Any())
|
|
|
+ {
|
|
|
+ try
|
|
|
+ {
|
|
|
|
|
|
- string typeName = tBDMCodeDetailList.Where(i => i.C_Code == pushModel.C_MsgTypeCode).Select(x => x.C_Name).FirstOrDefault();
|
|
|
- #region 长期订阅 【2025-2-11】
|
|
|
- //var content = new
|
|
|
- //{
|
|
|
- // character_string1 = new { value = devStore.C_NumberCode ?? "" },
|
|
|
- // time2 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
- // short_thing3 = new { value = typeName ?? "" }
|
|
|
- //};
|
|
|
- //new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, content, WXConstModel.WatchHealthAlarm_TemplateId);
|
|
|
- #endregion
|
|
|
+ string typeName = tBDMCodeDetailList.Where(i => i.C_Code == pushModel.C_MsgTypeCode).Select(x => x.C_Name).FirstOrDefault();
|
|
|
+ #region 长期订阅 【2025-2-11】
|
|
|
+ //var content = new
|
|
|
+ //{
|
|
|
+ // character_string1 = new { value = devStore.C_NumberCode ?? "" },
|
|
|
+ // time2 = new { value = DateTime.Now.ToString("yyyy-MM-dd hh:mm") },
|
|
|
+ // short_thing3 = new { value = typeName ?? "" }
|
|
|
+ //};
|
|
|
+ //new WeChatHelper(_httpClientFactory).PushMessageToUser(sendUserWechatIDList, content, WXConstModel.WatchHealthAlarm_TemplateId);
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 公众号模板【2025-3-5】
|
|
|
+ string msg = pushModel.Msg;
|
|
|
+ if (string.IsNullOrEmpty(msg))
|
|
|
+ {
|
|
|
+ msg = DataDictionaryHelper.GetValNameByCode(pushModel.C_MsgTypeCode);
|
|
|
+ }
|
|
|
+ if (msg.Length > 20)
|
|
|
+ {
|
|
|
+ msg = msg.Substring(0, 17) + "...";
|
|
|
+ }
|
|
|
+ string time = DateTime.Now.ToString("yyyy-MM-dd HH:mm");
|
|
|
+ if (!string.IsNullOrEmpty(pushModel.CreateOn))
|
|
|
+ {
|
|
|
+ time = Convert.ToDateTime(pushModel.CreateOn).ToString("yyyy-MM-dd HH:mm");
|
|
|
+ }
|
|
|
+ #region //_wP22WQxAlfYGfS8zlnHTl_-KgKS8j_FP5HDeqfsPtU
|
|
|
+ //设备编号{ { character_string2.DATA} }
|
|
|
+ //设备名称{ { thing1.DATA} }
|
|
|
+ //关闭状态{ { thing3.DATA} }
|
|
|
+ //关闭时间{ { time4.DATA} }
|
|
|
+ //var data = new
|
|
|
+ //{
|
|
|
+ // thing1 = new { value = devStore.C_Name }, //异常位置
|
|
|
+ // character_string2 = new { value = devStore.C_NumberCode },//异常点位
|
|
|
+ // thing3 = new { value = typeName }, //上报人
|
|
|
+ // time4 = new { value = pushModel.CreateOn}//上报时间
|
|
|
+ //};
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region 7eGjzIBAyysTOLfcn-oqkpOCEL_My5ItXHkd_DdniGw
|
|
|
+ //设备名称{ { thing2.DATA} }
|
|
|
+ //设备编号{ { character_string20.DATA} }
|
|
|
+ //报警时间{ { time4.DATA} }
|
|
|
+ //报警内容{ { thing5.DATA} }
|
|
|
+ var data = new
|
|
|
+ {
|
|
|
+ thing2 = new { value = devStore.C_Name }, //设备名称
|
|
|
+ character_string20 = new { value = devStore.C_NumberCode },//设备编号
|
|
|
+ thing5 = new { value = msg }, //报警内容
|
|
|
+ time4 = new { value = time }//报警时间
|
|
|
+ };
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ var row = new WeChatHelper(_httpClientFactory).PushGZHMessageToUser(sendUserWechatIDList, WXConstModel.GZHDevAlarmTemplateId, "", data, miniProgramAppId, miniProgramPagePath);
|
|
|
+ #endregion
|
|
|
|
|
|
- #region 公众号模板【2025-3-5】
|
|
|
- string msg = pushModel.Msg;
|
|
|
- if (msg.Length>20)
|
|
|
- {
|
|
|
- msg=msg.Substring(0,17)+"...";
|
|
|
}
|
|
|
- string time = DateTime.Now.ToString("yyyy-MM-dd HH:mm");
|
|
|
- if (!string.IsNullOrEmpty(pushModel.CreateOn))
|
|
|
+ catch (Exception ex)
|
|
|
{
|
|
|
- time=Convert.ToDateTime(pushModel.CreateOn).ToString("yyyy-MM-dd HH:mm");
|
|
|
+ log.Info($" 发送消息-WeChatHelper-发送异常【C_MsgTypeCode={pushModel.C_MsgTypeCode}】 异常信息:{ex.Message}");
|
|
|
+ throw;
|
|
|
}
|
|
|
- #region //_wP22WQxAlfYGfS8zlnHTl_-KgKS8j_FP5HDeqfsPtU
|
|
|
- //设备编号{ { character_string2.DATA} }
|
|
|
- //设备名称{ { thing1.DATA} }
|
|
|
- //关闭状态{ { thing3.DATA} }
|
|
|
- //关闭时间{ { time4.DATA} }
|
|
|
- //var data = new
|
|
|
- //{
|
|
|
- // thing1 = new { value = devStore.C_Name }, //异常位置
|
|
|
- // character_string2 = new { value = devStore.C_NumberCode },//异常点位
|
|
|
- // thing3 = new { value = typeName }, //上报人
|
|
|
- // time4 = new { value = pushModel.CreateOn}//上报时间
|
|
|
- //};
|
|
|
- #endregion
|
|
|
-
|
|
|
- #region 7eGjzIBAyysTOLfcn-oqkpOCEL_My5ItXHkd_DdniGw
|
|
|
- //设备名称{ { thing2.DATA} }
|
|
|
- //设备编号{ { character_string20.DATA} }
|
|
|
- //报警时间{ { time4.DATA} }
|
|
|
- //报警内容{ { thing5.DATA} }
|
|
|
- var data = new
|
|
|
- {
|
|
|
- thing2 = new { value = devStore.C_Name }, //异常位置
|
|
|
- character_string20 = new { value = devStore.C_NumberCode },//异常点位
|
|
|
- thing5 = new { value = msg }, //上报人
|
|
|
- time4 = new { value = time }//上报时间
|
|
|
- };
|
|
|
- #endregion
|
|
|
-
|
|
|
- var row = new WeChatHelper(_httpClientFactory).PushGZHMessageToUser(sendUserWechatIDList, WXConstModel.GZHDevAlarmTemplateId, "", data, miniProgramAppId, miniProgramPagePath);
|
|
|
- #endregion
|
|
|
-
|
|
|
}
|
|
|
- catch (Exception ex)
|
|
|
+ if (pushMsgResultList.Any())
|
|
|
{
|
|
|
- log.Info($" 发送消息-WeChatHelper-发送异常【C_MsgTypeCode={pushModel.C_MsgTypeCode}】 异常信息:{ex.Message}");
|
|
|
- throw;
|
|
|
- }
|
|
|
- }
|
|
|
- if (pushMsgResultList.Any())
|
|
|
- {
|
|
|
- _messageRepository.Create(message);
|
|
|
- bool messResult = await _messageRepository.SaveAsync();
|
|
|
- if (messResult)
|
|
|
- {
|
|
|
- if (FileList!=null&& FileList.Count>0)
|
|
|
- {
|
|
|
- int fileSaveResult = await _tsysMessageFileRepository.CreateRangeAsync(FileList);
|
|
|
- }
|
|
|
//await _tmtnPushMsgResultRepository.CreateRangeAsync(pushMsgResultList);
|
|
|
foreach (var content in pushMsgResultList)
|
|
|
{
|
|
@@ -593,10 +401,9 @@ namespace Ropin.Inspection.Service
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- else
|
|
|
- {
|
|
|
- log.Info($"发送消息-TSYS_Message 数据添加失败【{JsonConvert.SerializeObject(message)}】");
|
|
|
- }
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ log.Info($"发送消息-TSYS_Message 数据添加失败【{JsonConvert.SerializeObject(message)}】");
|
|
|
}
|
|
|
log.Info($"发送消息-END");
|
|
|
return await Task.FromResult(true);
|