Library.cs 51 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158
  1. using OASystem.Domain.Entities.Financial;
  2. using OASystem.Domain.Entities.Groups;
  3. using OASystem.Domain.ViewModels.CRM;
  4. using OASystem.Domain.ViewModels.Groups;
  5. using OASystem.Domain.ViewModels.QiYeWeChat;
  6. using OASystem.Infrastructure.Repositories.Groups;
  7. namespace OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice
  8. {
  9. public static class AppNoticeLibrary
  10. {
  11. private static readonly IQiYeWeChatApiService _qiYeWeChatApiService = AutofacIocManager.Instance.GetService<IQiYeWeChatApiService>();
  12. private static readonly DelegationInfoRepository _grpDeleRep = AutofacIocManager.Instance.GetService<DelegationInfoRepository>();
  13. #region 获取企微Id
  14. public static List<string> GetQiyeChatUserIdList(List<string> userId)
  15. {
  16. List<string> result = new List<string>();
  17. try
  18. {
  19. foreach (string item in userId)
  20. {
  21. int uid = int.Parse(item);
  22. Sys_Users users = _grpDeleRep.Query<Sys_Users>(s => s.Id == uid).First();
  23. if (!string.IsNullOrEmpty(users.QiyeChatUserId))
  24. {
  25. result.Add(users.QiyeChatUserId);
  26. }
  27. }
  28. }
  29. catch (Exception ex)
  30. {
  31. }
  32. return result;
  33. }
  34. #endregion
  35. #region 确认出团
  36. /// <summary>
  37. /// 向指定群聊发送- 确认出团 -通知
  38. /// </summary>
  39. /// <param name="diId"></param>
  40. /// <param name="qwEnum"></param>
  41. /// <returns></returns>
  42. public static async Task<bool> SendChatMsg_GroupStatus_Create(int diId, QiyeWeChatEnum qwEnum)
  43. {
  44. Grp_DelegationInfo entity = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  45. string dateRange = string.Format(@"{0}至{1}", entity.VisitStartDate.ToString("yyyy-MM-dd"), entity.VisitEndDate.ToString("yyyy-MM-dd"));
  46. string grpTypeStr = (_grpDeleRep.Query<Sys_SetData>(s => s.Id == entity.TeamDid).First()).Name;
  47. GroupStatus_CreateModel info = new GroupStatus_CreateModel()
  48. {
  49. ClientName = entity.ClientName,
  50. ClientUnit = entity.ClientUnit,
  51. TeamName = entity.TeamName,
  52. VisitDays = entity.VisitDays,
  53. VisitPNumber = entity.VisitPNumber,
  54. VisitDateRange = dateRange,
  55. TeamDid_Text = grpTypeStr
  56. };
  57. string chatId = qwEnum.GetEnumDescription();
  58. //发送信息
  59. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupStatus_Create(info));
  60. if (result.errcode != 0)
  61. {
  62. //抄送日志
  63. return false;
  64. }
  65. return true;
  66. }
  67. /// <summary>
  68. /// 向指定用户发送- 确认出团 -通知
  69. /// </summary>
  70. /// <param name="diId"></param>
  71. /// <param name="userId"></param>
  72. /// <returns></returns>
  73. public static async Task<bool> SendUserMsg_GroupStatus_Create(int diId, List<string> userId)
  74. {
  75. Grp_DelegationInfo entity = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  76. string dateRange = string.Format(@"{0}至{1}", entity.VisitStartDate.ToString("yyyy-MM-dd"), entity.VisitEndDate.ToString("yyyy-MM-dd"));
  77. string grpTypeStr = (_grpDeleRep.Query<Sys_SetData>(s => s.Id == entity.TeamDid).First()).Name;
  78. GroupStatus_CreateModel info = new GroupStatus_CreateModel()
  79. {
  80. ClientName = entity.ClientName,
  81. ClientUnit = entity.ClientUnit,
  82. TeamName = entity.TeamName,
  83. VisitDays = entity.VisitDays,
  84. VisitPNumber = entity.VisitPNumber,
  85. VisitDateRange = dateRange,
  86. TeamDid_Text = grpTypeStr
  87. };
  88. //发送信息
  89. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  90. if (qwUserIdList.Count > 0)
  91. {
  92. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupStatus_Create(info));
  93. if (result.errcode != 0)
  94. {
  95. //抄送日志
  96. return false;
  97. }
  98. }
  99. return true;
  100. }
  101. #endregion
  102. #region 团组费用审核
  103. /// <summary>
  104. /// 向指定群聊发送- 费用申请 -通知
  105. /// </summary>
  106. /// <param name="diId"></param>
  107. /// <param name="qwEnum"></param>
  108. /// <returns></returns>
  109. public static async Task<bool> SendChatMsg_GroupStatus_ApplyFee(int Grp_CreditCardPaymentId, int sign, QiyeWeChatEnum qwEnum)
  110. {
  111. string chatId = qwEnum.GetEnumDescription();
  112. Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
  113. Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();
  114. Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
  115. string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);
  116. List<Grp_CreditCardPayment> entityList = _grpDeleRep
  117. .Query<Grp_CreditCardPayment>(s => s.DIId == ccp.DIId && s.IsDel == 0 && s.CreateUserId > 0 && s.IsAuditGM == 0)
  118. .ToList();
  119. GroupStatus_ApplyFeeModel info = new GroupStatus_ApplyFeeModel()
  120. {
  121. QueueCount = entityList.Count,
  122. TeamName = group.TeamName,
  123. Price = priceStr
  124. };
  125. if (sign == 2)
  126. {
  127. info.TitleStr = "[更新]一项费用待审核";
  128. }
  129. //CTable
  130. #region CTable
  131. if (ccp.CTable == 76)//76,酒店预订
  132. {
  133. Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();
  134. info.CreateDt = _HotelReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");
  135. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
  136. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  137. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  138. info.PriceModule = "酒店预订";
  139. info.PriceName = _HotelReservations.HotelName;
  140. }
  141. else if (ccp.CTable == 79) //79://车/导游地接
  142. {
  143. Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();
  144. info.CreateDt = _CarTouristGuideGroundReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");
  145. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
  146. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  147. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  148. info.PriceModule = "车/导游地接";
  149. info.PriceName = _CarTouristGuideGroundReservations.PriceName;
  150. }
  151. else if (ccp.CTable == 80) //签证
  152. {
  153. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  154. Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();
  155. info.CreateDt = _VisaInfos.CreateTime.ToString("yyyy-MM-dd HH:mm");
  156. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
  157. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  158. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  159. info.PriceModule = "签证";
  160. info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
  161. }
  162. else if (ccp.CTable == 81)//邀请/公务活动
  163. {
  164. Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();
  165. info.CreateDt = _InvitationOfficialActivities.CreateTime.ToString("yyyy-MM-dd HH:mm");
  166. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _InvitationOfficialActivities.CreateUserId).First();
  167. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  168. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  169. info.PriceModule = "邀请/公务活动";
  170. info.PriceName = _InvitationOfficialActivities.InviterArea;
  171. }
  172. else if (ccp.CTable == 82)//团组客户保险
  173. {
  174. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  175. Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();
  176. info.CreateDt = _Customers.CreateTime.ToString("yyyy-MM-dd HH:mm");
  177. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
  178. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  179. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  180. info.PriceModule = "团组客户保险";
  181. info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
  182. }
  183. else if (ccp.CTable == 85) //机票预订
  184. {
  185. Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();
  186. info.CreateDt = _AirTicketReservations.CreateTime.ToString("yyyy-MM-dd HH:mm");
  187. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
  188. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  189. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  190. info.PriceModule = "机票预订";
  191. info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
  192. }
  193. else if (ccp.CTable == 98) //其他款项
  194. {
  195. Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();
  196. info.CreateDt = _DecreasePayments.CreateTime.ToString("yyyy-MM-dd HH:mm");
  197. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
  198. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  199. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  200. info.PriceModule = "其他款项";
  201. info.PriceName = _DecreasePayments.PriceName;
  202. }
  203. #endregion
  204. //发送信息
  205. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupStatus_ApplyFee(info));
  206. if (result.errcode != 0)
  207. {
  208. //抄送日志
  209. return false;
  210. }
  211. return true;
  212. }
  213. /// <summary>
  214. /// 向财务群发送费用审核结果通知(审核通过条件下发送)
  215. /// </summary>
  216. /// <param name="Grp_CreditCardPaymentId"></param>
  217. /// <param name="qwEnum"></param>
  218. /// <returns></returns>
  219. public static async Task<bool> SendChatMsg_GroupStatus_AuditFee(int Grp_CreditCardPaymentId, QiyeWeChatEnum qwEnum)
  220. {
  221. string chatId = qwEnum.GetEnumDescription();
  222. Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
  223. Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();
  224. Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
  225. string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);
  226. AuditResult_ApplyFee_GroupModel info = new AuditResult_ApplyFee_GroupModel()
  227. {
  228. TeamName = group.TeamName,
  229. Price = priceStr,
  230. GMAuditDate = "-"
  231. };
  232. DateTime gmAuditDt;
  233. bool bGMAuditDt = DateTime.TryParse(ccp.AuditGMDate, out gmAuditDt);
  234. info.GMAuditDate = gmAuditDt.ToString("yyyy-MM-dd HH:mm");
  235. //CTable
  236. #region CTable
  237. if (ccp.CTable == 76)//76,酒店预订
  238. {
  239. Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();
  240. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
  241. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  242. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  243. info.PriceModule = "酒店预订";
  244. info.PriceName = _HotelReservations.HotelName;
  245. }
  246. else if (ccp.CTable == 79) //79://车/导游地接
  247. {
  248. Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();
  249. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
  250. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  251. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  252. info.PriceModule = "车/导游地接";
  253. info.PriceName = _CarTouristGuideGroundReservations.PriceName;
  254. }
  255. else if (ccp.CTable == 80) //签证
  256. {
  257. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  258. Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();
  259. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
  260. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  261. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  262. info.PriceModule = "签证";
  263. info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
  264. }
  265. else if (ccp.CTable == 81)//邀请/公务活动
  266. {
  267. Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();
  268. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _InvitationOfficialActivities.CreateUserId).First();
  269. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  270. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  271. info.PriceModule = "邀请/公务活动";
  272. info.PriceName = _InvitationOfficialActivities.InviterArea;
  273. }
  274. else if (ccp.CTable == 82)//团组客户保险
  275. {
  276. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  277. Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();
  278. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
  279. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  280. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  281. info.PriceModule = "团组客户保险";
  282. info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
  283. }
  284. else if (ccp.CTable == 85) //机票预订
  285. {
  286. Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();
  287. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
  288. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  289. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  290. info.PriceModule = "机票预订";
  291. info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
  292. }
  293. else if (ccp.CTable == 98) //其他款项
  294. {
  295. Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();
  296. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
  297. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  298. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  299. info.PriceModule = "其他款项";
  300. info.PriceName = _DecreasePayments.PriceName;
  301. }
  302. #endregion
  303. //发送信息
  304. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.AuditResult_ApplyFee_Chat(info));
  305. if (result.errcode != 0)
  306. {
  307. //抄送日志
  308. return false;
  309. }
  310. return true;
  311. }
  312. /// <summary>
  313. /// 向指定用户发送-团组费用审核结果
  314. /// </summary>
  315. /// <param name="Grp_CreditCardPaymentId"></param>
  316. /// <param name="userId"></param>
  317. /// <returns></returns>
  318. public static async Task<bool> SendUserMsg_GroupStatus_AuditFee(int Grp_CreditCardPaymentId, List<string> userId, QiyeWeChatEnum qwEnum)
  319. {
  320. Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
  321. Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();
  322. Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
  323. string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);
  324. AuditResult_ApplyFee_GroupModel info = new AuditResult_ApplyFee_GroupModel()
  325. {
  326. TeamName = group.TeamName,
  327. Price = priceStr,
  328. GMAuditDate = "-"
  329. };
  330. DateTime gmAuditDt;
  331. bool bGMAuditDt = DateTime.TryParse(ccp.AuditGMDate, out gmAuditDt);
  332. info.GMAuditDate = gmAuditDt.ToString("yyyy-MM-dd HH:mm");
  333. if (ccp.IsAuditGM == 2)
  334. {
  335. info.Result = "总经理审核未通过";
  336. info.ResultColor = "warning";
  337. }
  338. //CTable
  339. #region CTable
  340. if (ccp.CTable == 76)//76,酒店预订
  341. {
  342. Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();
  343. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _HotelReservations.CreateUserId).First();
  344. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  345. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  346. info.PriceModule = "酒店预订";
  347. info.PriceName = _HotelReservations.HotelName;
  348. }
  349. else if (ccp.CTable == 79) //79://车/导游地接
  350. {
  351. Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();
  352. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _CarTouristGuideGroundReservations.CreateUserId).First();
  353. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  354. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  355. info.PriceModule = "车/导游地接";
  356. info.PriceName = _CarTouristGuideGroundReservations.PriceName;
  357. }
  358. else if (ccp.CTable == 80) //签证
  359. {
  360. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  361. Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();
  362. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _VisaInfos.CreateUserId).First();
  363. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  364. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  365. info.PriceModule = "签证";
  366. info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
  367. }
  368. else if (ccp.CTable == 81)//邀请/公务活动
  369. {
  370. Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();
  371. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _InvitationOfficialActivities.CreateUserId).First();
  372. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  373. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  374. info.PriceModule = "邀请/公务活动";
  375. info.PriceName = _InvitationOfficialActivities.InviterArea;
  376. }
  377. else if (ccp.CTable == 82)//团组客户保险
  378. {
  379. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  380. Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();
  381. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _Customers.CreateUserId).First();
  382. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  383. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  384. info.PriceModule = "团组客户保险";
  385. info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
  386. }
  387. else if (ccp.CTable == 85) //机票预订
  388. {
  389. Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();
  390. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _AirTicketReservations.CreateUserId).First();
  391. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  392. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  393. info.PriceModule = "机票预订";
  394. info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
  395. }
  396. else if (ccp.CTable == 98) //其他款项
  397. {
  398. Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();
  399. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == _DecreasePayments.CreateUserId).First();
  400. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  401. info.CreateUser = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  402. info.PriceModule = "其他款项";
  403. info.PriceName = _DecreasePayments.PriceName;
  404. }
  405. #endregion
  406. //发送信息
  407. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  408. if (qwUserIdList.Count > 0)
  409. {
  410. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.AuditResult_ApplyFee_User(info));
  411. if (ccp.IsAuditGM == 1)
  412. {
  413. await SendChatMsg_GroupStatus_AuditFee(Grp_CreditCardPaymentId, qwEnum);
  414. }
  415. if (result.errcode != 0)
  416. {
  417. //抄送日志
  418. return false;
  419. }
  420. }
  421. return true;
  422. }
  423. /// <summary>
  424. /// 向指定用户发送-团组费用支付结果
  425. /// </summary>
  426. /// <param name="Grp_CreditCardPaymentId"></param>
  427. /// <param name="userId"></param>
  428. /// <returns></returns>
  429. public static async Task<bool> SendUserMsg_GroupStatus_PayResult(int Grp_CreditCardPaymentId, List<string> userId)
  430. {
  431. //, QiyeWeChatEnum qiyeWeChat
  432. Grp_CreditCardPayment ccp = _grpDeleRep.Query<Grp_CreditCardPayment>(s => s.Id == Grp_CreditCardPaymentId).First();
  433. Grp_DelegationInfo group = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == ccp.DIId).First();
  434. Sys_SetData payMoneyCurrencySetData = _grpDeleRep.Query<Sys_SetData>(s => s.Id == ccp.PaymentCurrency).First();
  435. string priceStr = string.Format(@"{0} {1}", ccp.PayMoney, payMoneyCurrencySetData.Name);
  436. PayResult_Group_ToUserModel info = new PayResult_Group_ToUserModel()
  437. {
  438. PayDt = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  439. Price = priceStr,
  440. TeamName = group.TeamName
  441. };
  442. #region CTable
  443. if (ccp.CTable == 76)//76,酒店预订
  444. {
  445. Grp_HotelReservations _HotelReservations = _grpDeleRep.Query<Grp_HotelReservations>(s => s.Id == ccp.CId).First();
  446. info.PriceModule = "酒店预订";
  447. info.PriceName = _HotelReservations.HotelName;
  448. }
  449. else if (ccp.CTable == 79) //79://车/导游地接
  450. {
  451. Grp_CarTouristGuideGroundReservations _CarTouristGuideGroundReservations = _grpDeleRep.Query<Grp_CarTouristGuideGroundReservations>(s => s.Id == ccp.CId).First();
  452. info.PriceModule = "车/导游地接";
  453. info.PriceName = _CarTouristGuideGroundReservations.PriceName;
  454. }
  455. else if (ccp.CTable == 80) //签证
  456. {
  457. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  458. Grp_VisaInfo _VisaInfos = _grpDeleRep.Query<Grp_VisaInfo>(s => s.Id == ccp.CId).First();
  459. info.PriceModule = "签证";
  460. info.PriceName = getClientNameStr(clientNameList, _VisaInfos.VisaClient);
  461. }
  462. else if (ccp.CTable == 81)//邀请/公务活动
  463. {
  464. Grp_InvitationOfficialActivities _InvitationOfficialActivities = _grpDeleRep.Query<Grp_InvitationOfficialActivities>(s => s.Id == ccp.CId).First();
  465. info.PriceModule = "邀请/公务活动";
  466. info.PriceName = _InvitationOfficialActivities.InviterArea;
  467. }
  468. else if (ccp.CTable == 82)//团组客户保险
  469. {
  470. List<SimplClientInfo> clientNameList = getSimplClientList(group.Id);
  471. Grp_Customers _Customers = _grpDeleRep.Query<Grp_Customers>(s => s.Id == ccp.CId).First();
  472. info.PriceModule = "团组客户保险";
  473. info.PriceName = getClientNameStr(clientNameList, _Customers.ClientName);
  474. }
  475. else if (ccp.CTable == 85) //机票预订
  476. {
  477. Grp_AirTicketReservations _AirTicketReservations = _grpDeleRep.Query<Grp_AirTicketReservations>(s => s.Id == ccp.CId).First();
  478. info.PriceModule = "机票预订";
  479. info.PriceName = "(" + _AirTicketReservations.FlightsCode + ")";
  480. }
  481. else if (ccp.CTable == 98) //其他款项
  482. {
  483. Grp_DecreasePayments _DecreasePayments = _grpDeleRep.Query<Grp_DecreasePayments>(s => s.Id == ccp.CId).First();
  484. info.PriceModule = "其他款项";
  485. info.PriceName = _DecreasePayments.PriceName;
  486. }
  487. #endregion
  488. //发送信息
  489. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  490. if (qwUserIdList.Count > 0)
  491. {
  492. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.PayResult_Group_ToUser(info));
  493. if (result.errcode != 0)
  494. {
  495. //抄送日志
  496. return false;
  497. }
  498. }
  499. return true;
  500. }
  501. #endregion
  502. #region 团组出发、结束提醒(财务群)
  503. public static async Task<bool> SendChatMsg_GroupRemindersToCaiwu(List<Grp_DelegationInfo> list_7day, List<Grp_DelegationInfo> list_3day, List<Grp_DelegationInfo> list_minus1day, QiyeWeChatEnum qwEnum)
  504. {
  505. string chatId = qwEnum.GetEnumDescription();
  506. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupRemindersToCaiwuChat(list_7day, list_3day, list_minus1day));
  507. if (result.errcode != 0)
  508. {
  509. //抄送日志
  510. return false;
  511. }
  512. return true;
  513. }
  514. #endregion
  515. #region 团组结束提醒(国交群)
  516. public static async Task<bool> SendChatMsg_GroupRemindersToGuojiao(List<Grp_DelegationInfo> list_3day, QiyeWeChatEnum qwEnum)
  517. {
  518. string chatId = qwEnum.GetEnumDescription();
  519. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.GroupRemindersToGuojiao(list_3day));
  520. if (result.errcode != 0)
  521. {
  522. //抄送日志
  523. return false;
  524. }
  525. return true;
  526. }
  527. #endregion
  528. #region 团组出发提醒(HR)
  529. public static async Task<bool> SendUserMsg_DelegationVisit_ToHR(List<Grp_DelegationInfo> list_3day, List<string> userId)
  530. {
  531. //发送信息
  532. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  533. if (qwUserIdList.Count > 0)
  534. {
  535. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupRemindersToHR(list_3day));
  536. if (result.errcode != 0)
  537. {
  538. //抄送日志
  539. return false;
  540. }
  541. }
  542. return true;
  543. }
  544. #endregion
  545. #region 市场部新增客户资源统计
  546. /// <summary>
  547. /// 周统计
  548. /// </summary>
  549. /// <param name="sourceList"></param>
  550. /// <param name="userId"></param>
  551. /// <param name="begin"></param>
  552. /// <param name="end"></param>
  553. /// <returns></returns>
  554. public static async Task<bool> SendUserMsg_CRMStatistics_ToHR(List<CRMWeekStatisticsView> sourceList, List<string> userId, string begin, string end)
  555. {
  556. //发送信息
  557. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  558. if (qwUserIdList.Count > 0)
  559. {
  560. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.CRMStatistics_ToUser(sourceList, begin, end));
  561. if (result.errcode != 0)
  562. {
  563. //抄送日志
  564. return false;
  565. }
  566. }
  567. return true;
  568. }
  569. /// <summary>
  570. /// 月统计
  571. /// </summary>
  572. /// <param name="sourceList"></param>
  573. /// <param name="userId"></param>
  574. /// <param name="begin"></param>
  575. /// <param name="end"></param>
  576. /// <returns></returns>
  577. public static async Task<bool> SendUserMsg_CRMStatistics_Month_ToHR(List<CRMWeekStatisticsView> sourceList, List<string> userId, string begin, string end, int totalInsert, int totalDelete)
  578. {
  579. //发送信息
  580. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  581. if (qwUserIdList.Count > 0)
  582. {
  583. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.CRMStatistics_Month_ToUser(sourceList, begin, end, totalInsert, totalDelete));
  584. if (result.errcode != 0)
  585. {
  586. //抄送日志
  587. return false;
  588. }
  589. }
  590. return true;
  591. }
  592. #endregion
  593. #region 日付申请审核
  594. /// <summary>
  595. /// 日付申请提交时推送财务群
  596. /// </summary>
  597. /// <param name="dailyPayId"></param>
  598. /// <param name="qwEnum"></param>
  599. /// <returns></returns>
  600. public static async Task<bool> DailyPayReminders_Create_ToCaiwuChat(int dailyPayId, int sign, QiyeWeChatEnum qwEnum)
  601. {
  602. string chatId = qwEnum.GetEnumDescription();
  603. Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();
  604. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == fin_DailyFeePayment.CreateUserId).First();
  605. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  606. string users = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  607. string[] companyArr = new string[] { "未知", "成都泛美商务有限公司", "四川泛美交流有限公司", "成都纽茵教育科技有限公司", "成都鸿企中元科技有限公司", "测试公司1" };
  608. string companyStr = "未知";
  609. if (fin_DailyFeePayment.CompanyId < companyArr.Length)
  610. {
  611. companyStr = companyArr[fin_DailyFeePayment.CompanyId];
  612. }
  613. Sys_SetData sd_tansferType = _grpDeleRep.Query<Sys_SetData>(s => s.Id == fin_DailyFeePayment.TransferTypeId).First();
  614. Sys_SetData sd_priceType = _grpDeleRep.Query<Sys_SetData>(s => s.Id == fin_DailyFeePayment.PriceTypeId).First();
  615. string feeSignStr = string.Format(@"{0}-{1}", sd_tansferType.Name, sd_priceType.Name);
  616. string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");
  617. DailyPayReminders_Create_ToCaiwuChatModel info = new DailyPayReminders_Create_ToCaiwuChatModel()
  618. {
  619. CreateDt = fin_DailyFeePayment.CreateTime.ToString("yyyy-MM-dd HH:mm"),
  620. CreateUser = users,
  621. Price = priceStr,
  622. Company = companyStr,
  623. FeeSign = feeSignStr,
  624. PriceName = fin_DailyFeePayment.Instructions
  625. };
  626. if (sign == 2)
  627. {
  628. info.TitleStr = "[更新]一项费用待审核";
  629. }
  630. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.DailyPayReminders_Create_ToCaiwuChat(info));
  631. if (result.errcode != 0)
  632. {
  633. //抄送日志
  634. return false;
  635. }
  636. return true;
  637. }
  638. /// <summary>
  639. /// 日付申请审核结果推送给申请人
  640. /// </summary>
  641. /// <param name="dailyPayId"></param>
  642. /// <param name="userId"></param>
  643. /// <param name="qwEnum"></param>
  644. /// <returns></returns>
  645. public static async Task<bool> DailyPayReminder_Audit_ToUser(int dailyPayId, List<string> userId, QiyeWeChatEnum qwEnum)
  646. {
  647. Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();
  648. Sys_Users user = _grpDeleRep.Query<Sys_Users>(s => s.Id == fin_DailyFeePayment.CreateUserId).First();
  649. Sys_JobPost job = _grpDeleRep.Query<Sys_JobPost>(s => s.Id == user.JobPostId).First();
  650. string users = string.Format(@"{0}-{1}", job.JobName, user.CnName);
  651. string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");
  652. DailyPayReminder_Audit_ToUserModel info = new DailyPayReminder_Audit_ToUserModel()
  653. {
  654. Price = priceStr,
  655. PriceName = fin_DailyFeePayment.Instructions
  656. };
  657. if (fin_DailyFeePayment.FAudit == 1)
  658. {
  659. info.AuditDate = fin_DailyFeePayment.MAuditDate.ToString("yyyy-MM-dd HH:mm");
  660. if (fin_DailyFeePayment.MAudit == 1)
  661. {
  662. info.Result = "你有一笔日付申请已通过审核";
  663. info.ResultColor = "info";
  664. //发送至财务群
  665. DailyPayReminder_Audit_ToCaiwuChatModel chatInfo = new DailyPayReminder_Audit_ToCaiwuChatModel()
  666. {
  667. AuditDate = info.AuditDate,
  668. CreateUser = users,
  669. Price = priceStr,
  670. PriceName = fin_DailyFeePayment.Instructions
  671. };
  672. string chatId = qwEnum.GetEnumDescription();
  673. await _qiYeWeChatApiService.GroupStatus_SendChatMsg_Markdown(chatId, MarkdownLib.DailyPayReminder_Audit_ToCaiwuChat(chatInfo));
  674. }
  675. else if (fin_DailyFeePayment.MAudit == 2)
  676. {
  677. info.Result = "你有一笔日付申请未通过总经理审核";
  678. info.ResultColor = "warning";
  679. }
  680. }
  681. else if (fin_DailyFeePayment.FAudit == 2)
  682. {
  683. info.AuditDate = fin_DailyFeePayment.FAuditDate.ToString("yyyy-MM-dd HH:mm");
  684. info.Result = "你有一笔日付申请未通过财务审核";
  685. info.ResultColor = "warning";
  686. }
  687. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  688. if (qwUserIdList.Count > 0)
  689. {
  690. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.DailyPayReminder_Audit_ToUser(info));
  691. if (result.errcode != 0)
  692. {
  693. //抄送日志
  694. return false;
  695. }
  696. }
  697. return true;
  698. }
  699. /// <summary>
  700. /// 日付申请已付款推送给申请人
  701. /// </summary>
  702. /// <returns></returns>
  703. public static async Task<bool> DailyPayReminder_Pay_ToUser(int dailyPayId, List<string> userId)
  704. {
  705. Fin_DailyFeePayment fin_DailyFeePayment = _grpDeleRep.Query<Fin_DailyFeePayment>(s => s.Id == dailyPayId).First();
  706. string priceStr = fin_DailyFeePayment.SumPrice.ToString("#0.00");
  707. DailyPayReminder_Pay_ToUserModel info = new DailyPayReminder_Pay_ToUserModel()
  708. {
  709. PayDt = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  710. PriceName = fin_DailyFeePayment.Instructions,
  711. Price = priceStr
  712. };
  713. List<string> qwUserIdList = GetQiyeChatUserIdList(userId);
  714. if (qwUserIdList.Count > 0)
  715. {
  716. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.DailyPayReminder_Pay_ToUser(info));
  717. if (result.errcode != 0)
  718. {
  719. //抄送日志
  720. return false;
  721. }
  722. }
  723. return true;
  724. }
  725. #endregion
  726. #region 费用保存发送消息
  727. #region 三公费用更改通知
  728. /// <summary>
  729. /// 三公费用更改通知发送总经理(21)
  730. /// </summary>
  731. /// <param name="sign"></param>
  732. /// <returns></returns>
  733. public static async Task<bool> SendUserMsg_GroupShare_ToGM(int diId, List<string> receivedUserIds, int updateUserId, string url)
  734. {
  735. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  736. GroupShare_ToGMModel info = new GroupShare_ToGMModel()
  737. {
  738. RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  739. TeamName = groupInfo.TeamName,
  740. CreateUser = _grpDeleRep.Query<Sys_Users>(s => s.Id == updateUserId).First()?.CnName ?? "-",
  741. Url = url
  742. };
  743. if (receivedUserIds.Count > 0)
  744. {
  745. List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
  746. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToGM(info));
  747. if (result.errcode != 0)
  748. {
  749. //抄送日志
  750. return false;
  751. }
  752. }
  753. return true;
  754. }
  755. /// <summary>
  756. /// 三公费用确认通知发送财务部人员
  757. /// </summary>
  758. /// <param name="sign"></param>
  759. /// <returns></returns>
  760. public static async Task<bool> SendUserMsg_GroupShare_ToFinance(int diId)
  761. {
  762. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  763. GroupShare_ToUserModel info = new GroupShare_ToUserModel()
  764. {
  765. RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  766. TeamName = groupInfo.TeamName
  767. };
  768. List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 3).Select(x => x.Id.ToString()).ToList();
  769. var defaultUserIds = new List<string>() { "208", "233" };
  770. receivedUserIds.AddRange(defaultUserIds);
  771. if (receivedUserIds.Contains("150")) receivedUserIds.Remove("150");
  772. if (receivedUserIds.Count > 0)
  773. {
  774. List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
  775. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToFinance(info));
  776. if (result.errcode != 0)
  777. {
  778. //抄送日志
  779. return false;
  780. }
  781. }
  782. return true;
  783. }
  784. #endregion
  785. /// <summary>
  786. /// 机票行程代码录入变更通知发送国交经理、主管、王鸽
  787. /// </summary>
  788. /// <param name="diId"></param>
  789. /// <param name="operationId"></param>
  790. /// <returns></returns>
  791. public static async Task<bool> SendUserMsg_GroupShare_ToDP(int diId, int operationId)
  792. {
  793. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  794. var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";
  795. var defaultJobPostIds = new List<int>() { 22, 32 };
  796. List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 7 && defaultJobPostIds.Contains(s.JobPostId)).Select(x => x.Id.ToString()).ToList();
  797. var defaultUserIds = new List<string>() { "208", "233" };
  798. receivedUserIds.AddRange(defaultUserIds);
  799. if (receivedUserIds.Count > 0)
  800. {
  801. List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
  802. string resMsg = string.Format(@" `机票行程代码已调整更新通知`
  803. >团组:<font color='info'>{0}</font>
  804. >操作人员:<font color='comment'>{1}</font>
  805. >操作时间:<font color='comment'>{2}</font>
  806. [详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/) ", groupInfo.TeamName, operationName, DateTime.Now.ToString("yyyy-MM-dd HH:mm"));
  807. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
  808. if (result.errcode != 0)
  809. {
  810. //抄送日志
  811. return false;
  812. }
  813. }
  814. return true;
  815. }
  816. #region 公务出访数据变更发送通知
  817. /// <summary>
  818. /// 机票行程代码录入变更通知发送国交经理、主管、王鸽
  819. /// </summary>
  820. /// <param name="diId"></param>
  821. /// <param name="operationId"></param>
  822. /// <returns></returns>
  823. public static async Task<bool> SendUserMsg_GroupShare_ToOP(int diId, int operationId)
  824. {
  825. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  826. var operationName = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.Id == operationId).First()?.CnName ?? "Unknown";
  827. var defaultJobPostIds = new List<int>();
  828. List<string> receivedUserIds = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && s.DepId == 7 && s.JobPostId == 28).Select(x => x.Id.ToString()).ToList();
  829. var defaultUserIds = new List<string>() { "208", "233" };
  830. receivedUserIds.AddRange(defaultUserIds);
  831. if (receivedUserIds.Count > 0)
  832. {
  833. List<string> qwUserIdList = GetQiyeChatUserIdList(receivedUserIds);
  834. string resMsg = string.Format(@" `公务出访有数据更新通知`
  835. >团组:<font color='info'>{0}</font>
  836. >操作人员:<font color='comment'>{1}</font>
  837. >操作时间:<font color='comment'>{2}</font>
  838. [详细信息请前往OA系统查看](http://oa.pan-american-intl.com:4399/) ", groupInfo.TeamName, operationName, DateTime.Now.ToString("yyyy-MM-dd HH:mm"));
  839. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, resMsg);
  840. if (result.errcode != 0)
  841. {
  842. //抄送日志
  843. return false;
  844. }
  845. }
  846. return true;
  847. }
  848. #endregion
  849. #endregion
  850. #region 成本通知
  851. /// <summary>
  852. /// 成本通知发送给对应岗位用户
  853. /// </summary>
  854. /// <param name="diId"></param>
  855. /// <returns></returns>
  856. public static async Task<bool> SendUserMsg_GroupShare_ToJob(int diId)
  857. {
  858. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  859. List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 24 || s.JobPostId == 25 || s.JobPostId == 28)).ToList();
  860. //List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 40 || s.JobPostId == 41)).ToList();
  861. List<string> userIds = new List<string>();
  862. list_user.ForEach(s => userIds.Add(s.Id.ToString()));
  863. List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);
  864. GroupShare_ToUserModel info = new GroupShare_ToUserModel()
  865. {
  866. RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  867. TeamName = groupInfo.TeamName
  868. };
  869. if (qwUserIdList.Count > 0)
  870. {
  871. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.GroupShare_ToUser(info));
  872. if (result.errcode != 0)
  873. {
  874. //抄送日志
  875. return false;
  876. }
  877. }
  878. return true;
  879. }
  880. public static async Task<bool> SendUserMsg_blackAirInfo_ToVisaUser(int diId , string[] arr)
  881. {
  882. Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
  883. var visaUser = _grpDeleRep.Query<Sys_Users>(x => x.IsDel == 0 && x.JobPostId == 26)
  884. .Select(x => x.Id)
  885. .ToList();
  886. List<string> userIds = new List<string>() { "235" };
  887. List<string> qwUserIdList = GetQiyeChatUserIdList(userIds);
  888. BlackCodeInfo_ToVisaUser info = new BlackCodeInfo_ToVisaUser()
  889. {
  890. RefreshDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm"),
  891. TeamName = groupInfo.TeamName,
  892. info = arr
  893. };
  894. if (qwUserIdList.Count > 0)
  895. {
  896. ResponseBase result = await _qiYeWeChatApiService.GroupStatus_SendMessage_ToUser_Markdown(qwUserIdList, MarkdownLib.BlackCodeInfo_ToVisaUser(info));
  897. if (result.errcode != 0)
  898. {
  899. //抄送日志
  900. return false;
  901. }
  902. }
  903. return true;
  904. }
  905. #endregion
  906. #region Helper
  907. private static string getClientNameStr(List<SimplClientInfo> list, string origin)
  908. {
  909. string result = origin;
  910. if (Regex.Match(origin, @"\d+,?").Value.Length > 0)
  911. {
  912. string[] temparr = origin.Split(',');
  913. string fistrStr = temparr[0];
  914. int count = temparr.Count();
  915. int tempId;
  916. bool success = int.TryParse(fistrStr, out tempId);
  917. if (success)
  918. {
  919. SimplClientInfo tempInfo = list.FirstOrDefault(s => s.Id == tempId);
  920. if (tempInfo != null)
  921. {
  922. if (count > 1)
  923. {
  924. result = string.Format(@"{0}{1}等{2}人", tempInfo.LastName, tempInfo.FirstName, count);
  925. }
  926. else
  927. {
  928. result = string.Format(@"{0}{1}", tempInfo.LastName, tempInfo.FirstName);
  929. }
  930. }
  931. }
  932. }
  933. return result;
  934. }
  935. private static List<SimplClientInfo> getSimplClientList(int diId)
  936. {
  937. string sql = string.Format("select b.Id,b.Pinyin,b.lastName,b.firstName,b.phone from Grp_TourClientList a, Crm_DeleClient b where a.clientid = b.id and a.isdel = 0 and a.diid = {0}", diId);
  938. List<SimplClientInfo> arr = _grpDeleRep._sqlSugar.SqlQueryable<SimplClientInfo>(sql).ToList();
  939. return arr;
  940. }
  941. #endregion
  942. }
  943. }