Library.cs 59 KB

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