QiYeWeChatApiService.cs 63 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469
  1. using Microsoft.AspNetCore.Identity;
  2. using OASystem.Domain.Dtos.QiYeWeChat;
  3. using OASystem.Domain.ViewModels.JuHeExchangeRate;
  4. using OASystem.Domain.ViewModels.QiYeWeChat;
  5. using Org.BouncyCastle.Ocsp;
  6. using SqlSugar;
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Diagnostics;
  10. using System.Text.Json;
  11. using Ubiety.Dns.Core;
  12. using Ubiety.Dns.Core.Common;
  13. namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
  14. {
  15. /// <summary>
  16. /// 聚合Api 服务
  17. /// </summary>
  18. public class QiYeWeChatApiService : IQiYeWeChatApiService
  19. {
  20. private readonly HttpClient _httpClient;
  21. private readonly string CorpId = "wwe978bef5495a0728"; //企业Id
  22. private readonly string PersonnelAssistant_AgentId = "3010011"; //人事助手Id
  23. private readonly string PersonnelAssistant_Corpsecret = "ig--IJd6TxWDMJ1wT4e-RDRcRX12v5GjB359DNATwJ4"; //人事助手凭证密钥
  24. private readonly string PunchCard_AgentId = "3010185"; //打卡Id
  25. private readonly string PunchCard_Corpsecret = "Xhrl37GOqlAjsu0VzUSJECaJdjzkDXQLbvrzRsZQb8M"; //打卡凭证密钥
  26. private readonly string Email_AgentId = "1000004"; //E-Mail Id
  27. private readonly string Email_Corpsecret = "NA1zbJM15GmgjPYwDOqz59dIo1Wnug-MbU107MeUemc"; //E-Mail 凭证密钥
  28. private readonly string AddressBook_Corpsecret = "Y1tnjh7j-BvbqAytAoXZPUbmDR6dqLTL6mXtc6PZ7fo"; //通讯录同步 凭证密钥
  29. private readonly string Approve_AgentId = "3010040"; //审批 Id
  30. private readonly string Approve_Corpsecret = "k_Jo69Jw9Hqg_in-Rypbs30PNbxOYa1t4e-dxYuT-kw"; //审批 凭证密钥
  31. private readonly string GroupStatus_AgentId = "1000008"; //团组状态通知 Id
  32. private readonly string GroupStatus_Corpsecret = "7J_ST3jTPzbZpFwl7ttToTVufjEx6O2wuApvKHxt2Ak"; //团组状态通知Secret
  33. private readonly DateTime _1970 = new DateTime(1970, 1, 1, 0, 0, 0, 0);
  34. private readonly JobPostRepository _jobPostRep;
  35. /// <summary>
  36. /// 初始化
  37. /// </summary>
  38. /// <param name="clientFactory"></param>
  39. /// <param name="jobPostRep"></param>
  40. public QiYeWeChatApiService(IHttpClientFactory clientFactory, JobPostRepository jobPostRep)
  41. {
  42. _httpClient = clientFactory.CreateClient("PublicQiYeWeChatApi"); ;
  43. _jobPostRep = jobPostRep;
  44. }
  45. /// <summary>
  46. /// 获取access_token
  47. /// </summary>
  48. /// <param name="applicationType">
  49. /// 1:人事助手
  50. /// 2:打卡
  51. /// 3:邮件
  52. /// 4:通讯录同步
  53. /// 5:审批
  54. /// 6:团组状态通知
  55. /// </param>
  56. /// <returns></returns>
  57. private async Task<Access_TokenView> GetTokenAsync(int applicationType)
  58. {
  59. Access_TokenView tokenResult = new Access_TokenView();
  60. Access_Token_Request access_Token = new Access_Token_Request();
  61. string cacheName = string.Empty;
  62. if (applicationType == 1)
  63. {
  64. access_Token.corpsecret = PersonnelAssistant_Corpsecret; //人事助手
  65. cacheName = "PersonnelAssistant_Access_Token";
  66. }
  67. else if (applicationType == 2)
  68. {
  69. access_Token.corpsecret = PunchCard_Corpsecret; //打卡
  70. cacheName = "PunchCard_Access_Token";
  71. }
  72. else if (applicationType == 3)
  73. {
  74. access_Token.corpsecret = Email_Corpsecret; //E-Mail
  75. cacheName = "Enail_Access_Token";
  76. }
  77. else if (applicationType == 4) //通讯录同步
  78. {
  79. access_Token.corpsecret = AddressBook_Corpsecret;
  80. cacheName = "AddressBook_Access_Token";
  81. }
  82. else if (applicationType == 5) //审批
  83. {
  84. access_Token.corpsecret = Approve_Corpsecret;
  85. cacheName = "Approve_Access_Token";
  86. }
  87. else if (applicationType == 6) //团组状态通知
  88. {
  89. access_Token.corpsecret = GroupStatus_Corpsecret;
  90. cacheName = "GroupStatus_Access_Token";
  91. }
  92. else
  93. {
  94. tokenResult.errmsg = "未识别应用类型Id!";
  95. return tokenResult;
  96. }
  97. string access_token = await RedisRepository.RedisFactory
  98. .CreateRedisRepository()
  99. .StringGetAsync<string>(cacheName);//string 取
  100. if (string.IsNullOrEmpty(access_token))
  101. {
  102. string access_token_url = string.Format(@"/cgi-bin/gettoken?corpid={0}&corpsecret={1}", access_Token.corpid, access_Token.corpsecret);
  103. var access_tokenReq = await _httpClient.GetAsync(access_token_url);
  104. if (access_tokenReq.IsSuccessStatusCode)
  105. {
  106. var stringResponse = await access_tokenReq.Content.ReadAsStringAsync();
  107. tokenResult = System.Text.Json.JsonSerializer.Deserialize<Access_TokenView>(stringResponse,
  108. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  109. if (tokenResult.errcode == 0)
  110. {
  111. TimeSpan ts = DateTime.Now.AddMinutes(118) - DateTime.Now; //设置redis 过期时间 118分钟
  112. await RedisRepository
  113. .RedisFactory
  114. .CreateRedisRepository()
  115. .StringSetAsync<string>(cacheName, tokenResult.access_token, ts);//string 存
  116. }
  117. }
  118. else
  119. {
  120. tokenResult.errmsg = "企业微信Token未获取到!";
  121. }
  122. }
  123. else
  124. {
  125. tokenResult.errcode = 0;
  126. tokenResult.access_token = access_token;
  127. }
  128. return tokenResult;
  129. }
  130. #region 添加员工
  131. /// <summary>
  132. /// 获取成员ID列表
  133. /// </summary>
  134. /// <returns></returns>
  135. public async Task<UserIdListView> GetUserIdListAsync()
  136. {
  137. UserIdListView userIdListView = new UserIdListView();
  138. Access_TokenView access_Token = await GetTokenAsync(4);
  139. if (access_Token.errcode != 0)
  140. {
  141. userIdListView.errcode = access_Token.errcode;
  142. userIdListView.errmsg = access_Token.errmsg;
  143. return userIdListView;
  144. }
  145. string url = string.Format("/cgi-bin/user/list_id?access_token={0}&debug=1", access_Token.access_token);
  146. var jsonData = new
  147. {
  148. access_token = access_Token.access_token, //调用接口凭证
  149. };
  150. var json = System.Text.Json.JsonSerializer.Serialize(jsonData);
  151. var content = new StringContent(json, Encoding.UTF8, "application/json");
  152. var create_Req = await _httpClient.PostAsync(url, content);
  153. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  154. userIdListView = System.Text.Json.JsonSerializer.Deserialize<UserIdListView>(stringResponse,
  155. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  156. return userIdListView;
  157. }
  158. /// <summary>
  159. /// 获取部门列表
  160. /// </summary>
  161. /// <param name="access_token"></param>
  162. /// <returns></returns>
  163. private async Task<DepartmentListView> GetDepartmentAsync(string access_token)
  164. {
  165. DepartmentListView result = new DepartmentListView();
  166. string dep_url = string.Format("/cgi-bin/department/list?access_token={0}&debug=1", access_token);
  167. var depReq = await _httpClient.GetAsync(dep_url);
  168. if (depReq.IsSuccessStatusCode)
  169. {
  170. var stringResponse = await depReq.Content.ReadAsStringAsync();
  171. result = System.Text.Json.JsonSerializer.Deserialize<DepartmentListView>(stringResponse,
  172. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  173. }
  174. else
  175. {
  176. result.errcode = -1;
  177. result.errmsg = "企业微信部门列表未获取到!";
  178. }
  179. return result;
  180. }
  181. /// <summary>
  182. /// 创建员工
  183. /// </summary>
  184. /// <param name="create_Request"></param>
  185. /// <returns></returns>
  186. public async Task<ResponseBase> CreateAsync(Create_Request create_Request)
  187. {
  188. ResponseBase responseBase = new ResponseBase();
  189. #region 职位
  190. string depName = string.Empty,
  191. jobName = string.Empty;
  192. List<Sys_JobPostI> jobs = await _jobPostRep.QueryJobPost(string.Empty);
  193. Sys_JobPostI jobPost = jobs.Where(it => it.IsDel == 0 && it.Id == Convert.ToInt32(create_Request.position)).FirstOrDefault();
  194. if (jobPost != null)
  195. {
  196. depName = jobPost.DepName;
  197. jobName = jobPost.JobName;
  198. }
  199. create_Request.position = jobName;
  200. if (string.IsNullOrEmpty(create_Request.biz_mail))
  201. {
  202. create_Request.biz_mail = string.Format("{0}@pan-american-intl.com", create_Request.userid);
  203. }
  204. #endregion
  205. Access_TokenView access_Token = new Access_TokenView();
  206. access_Token = await GetTokenAsync(4);
  207. if (access_Token.errcode == 0)
  208. {
  209. create_Request.access_token = access_Token.access_token;
  210. #region 处理部门
  211. Access_TokenView dep_Access_Token = await GetTokenAsync(1);
  212. if (dep_Access_Token.errcode != 0)
  213. {
  214. responseBase.errcode = dep_Access_Token.errcode;
  215. responseBase.errmsg = dep_Access_Token.errmsg;
  216. }
  217. DepartmentListView depData = await GetDepartmentAsync(dep_Access_Token.access_token);
  218. if (depData.errcode == 0)
  219. {
  220. var depData1 = depData.department.Where(x => x.name == depName).FirstOrDefault();
  221. if (depData1 != null)
  222. {
  223. create_Request.department = new List<long> { depData1.id };
  224. }
  225. else
  226. {
  227. responseBase.errcode = -1;
  228. responseBase.errmsg = "未在企业微信上找到OA内设置的部门";
  229. return responseBase;
  230. }
  231. }
  232. else
  233. {
  234. responseBase.errcode = depData.errcode;
  235. responseBase.errmsg = depData.errmsg;
  236. return responseBase;
  237. }
  238. #endregion
  239. create_Request.access_token = access_Token.access_token;
  240. string create_url = string.Format("/cgi-bin/user/create?access_token={0}", create_Request.access_token);
  241. var json = System.Text.Json.JsonSerializer.Serialize(create_Request);
  242. var content = new StringContent(json, Encoding.UTF8, "application/json");
  243. var create_Req = await _httpClient.PostAsync(create_url, content);
  244. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  245. responseBase = System.Text.Json.JsonSerializer.Deserialize<ResponseBase>(stringResponse,
  246. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  247. }
  248. else
  249. {
  250. responseBase.errcode = access_Token.errcode;
  251. responseBase.errmsg = access_Token.errmsg;
  252. }
  253. return responseBase;
  254. }
  255. #endregion
  256. #region 打卡
  257. /// <summary>
  258. /// 获取企业所有打卡规则
  259. /// </summary>
  260. /// <returns></returns>
  261. public async Task<CorpCheckInRuleView> GetCheckIn_CorpCheckInOptionAsync()
  262. {
  263. CorpCheckInRuleView corpCheckInRuleView = new CorpCheckInRuleView();
  264. //获取打卡数据 token
  265. Access_TokenView access_Token = await GetTokenAsync(2);
  266. if (access_Token.errcode != 0)
  267. {
  268. corpCheckInRuleView.errcode = access_Token.errcode;
  269. corpCheckInRuleView.errmsg = string.Format("【企业微信】【获取月打卡数据】【Token】【Msg】{0}", access_Token.errmsg);
  270. return corpCheckInRuleView;
  271. }
  272. string url = string.Format("/cgi-bin/checkin/getcorpcheckinoption?access_token={0}", access_Token.access_token);
  273. var content = new StringContent(string.Empty, Encoding.UTF8, "application/json");
  274. var create_Req = await _httpClient.PostAsync(url, content);
  275. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  276. corpCheckInRuleView = System.Text.Json.JsonSerializer.Deserialize<CorpCheckInRuleView>(stringResponse,
  277. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  278. return corpCheckInRuleView;
  279. }
  280. /// <summary>
  281. /// 获取月打卡记录数据
  282. /// </summary>
  283. /// <param name="startDt"></param>
  284. /// <param name="endDt"></param>
  285. /// <returns></returns>
  286. public async Task<CheckInView> GetCheckin_MonthDataAsync1(DateTime startDt, DateTime endDt)
  287. {
  288. CheckInView checkInView = new CheckInView();
  289. //获取员工Id
  290. UserIdListView userIdListView = await GetUserIdListAsync();
  291. if (userIdListView.errcode != 0)
  292. {
  293. checkInView.errcode = userIdListView.errcode;
  294. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】{0}", userIdListView.errmsg);
  295. return checkInView;
  296. }
  297. if (userIdListView.dept_user == null || userIdListView.dept_user.Count <= 0)
  298. {
  299. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】未查出员工Id");
  300. return checkInView;
  301. }
  302. //获取打卡数据 token
  303. Access_TokenView access_Token = await GetTokenAsync(2);
  304. if (access_Token.errcode != 0)
  305. {
  306. checkInView.errcode = access_Token.errcode;
  307. checkInView.errmsg = string.Format("【企业微信】【获取月打卡数据】【Token】【Msg】{0}", access_Token.errmsg);
  308. return checkInView;
  309. }
  310. string url = string.Format("/cgi-bin/checkin/getcheckin_monthdata?access_token={0}", access_Token.access_token);
  311. Checkin_MonthData_Request checkInReq = new Checkin_MonthData_Request();
  312. checkInReq.access_token = access_Token.access_token;
  313. checkInReq.starttime = (uint)(startDt - _1970).TotalSeconds;
  314. checkInReq.endtime = (uint)(endDt - _1970).TotalSeconds;
  315. checkInReq.useridlist = userIdListView.dept_user.Select(it => it.userid).ToList();
  316. var json = System.Text.Json.JsonSerializer.Serialize(checkInReq);
  317. var content = new StringContent(json, Encoding.UTF8, "application/json");
  318. var create_Req = await _httpClient.PostAsync(url, content);
  319. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  320. checkInView = System.Text.Json.JsonSerializer.Deserialize<CheckInView>(stringResponse,
  321. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  322. return checkInView;
  323. }
  324. /// <summary>
  325. /// 获取月打卡记录数据
  326. /// </summary>
  327. /// <param name="startDt"></param>
  328. /// <param name="endDt"></param>
  329. /// <returns></returns>
  330. public async Task<CheckInView> GetCheckin_MonthDataAsync(DateTime startDt, DateTime endDt)
  331. {
  332. CheckInView checkInView = new CheckInView();
  333. //获取员工Id
  334. UserIdListView userIdListView = await GetUserIdListAsync();
  335. if (userIdListView.errcode != 0)
  336. {
  337. checkInView.errcode = userIdListView.errcode;
  338. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】{0}", userIdListView.errmsg);
  339. return checkInView;
  340. }
  341. if (userIdListView.dept_user == null || userIdListView.dept_user.Count <= 0)
  342. {
  343. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】未查出员工Id");
  344. return checkInView;
  345. }
  346. //获取打卡数据 token
  347. Access_TokenView access_Token = await GetTokenAsync(2);
  348. if (access_Token.errcode != 0)
  349. {
  350. checkInView.errcode = access_Token.errcode;
  351. checkInView.errmsg = string.Format("【企业微信】【获取月打卡数据】【Token】【Msg】{0}", access_Token.errmsg);
  352. return checkInView;
  353. }
  354. #region 处理超31天的月报表数据
  355. string url = string.Format("/cgi-bin/checkin/getcheckin_monthdata?access_token={0}", access_Token.access_token);
  356. Checkin_MonthData_Request checkInReq = new Checkin_MonthData_Request();
  357. checkInReq.access_token = access_Token.access_token;
  358. checkInReq.useridlist = userIdListView.dept_user.Select(it => it.userid).ToList();
  359. uint starttimeOne, endtimeOne, starttimeTwo, endtimeTwo;
  360. int days = (int)(endDt - startDt).TotalDays;
  361. if (days > 32)
  362. {
  363. starttimeOne = (uint)((startDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  364. endtimeOne = (uint)((startDt.AddDays(31).ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  365. starttimeTwo = (uint)((startDt.AddDays(32).ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  366. endtimeTwo = (uint)((endDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  367. checkInReq.starttime = starttimeOne;
  368. checkInReq.endtime = endtimeOne;
  369. CheckInView checkInViewOne = new CheckInView();
  370. var jsonOne = System.Text.Json.JsonSerializer.Serialize(checkInReq);
  371. var contentOne = new StringContent(jsonOne, Encoding.UTF8, "application/json");
  372. var create_ReqOne = await _httpClient.PostAsync(url, contentOne);
  373. var stringResponseOne = await create_ReqOne.Content.ReadAsStringAsync();
  374. checkInViewOne = System.Text.Json.JsonSerializer.Deserialize<CheckInView>(stringResponseOne,
  375. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  376. if (checkInViewOne.errcode != 0)
  377. {
  378. return checkInViewOne;
  379. }
  380. checkInReq.starttime = starttimeTwo;
  381. checkInReq.endtime = endtimeTwo;
  382. CheckInView checkInViewTwo = new CheckInView();
  383. var jsonTwo = System.Text.Json.JsonSerializer.Serialize(checkInReq);
  384. var contentTwo = new StringContent(jsonTwo, Encoding.UTF8, "application/json");
  385. var create_ReqTwo = await _httpClient.PostAsync(url, contentTwo);
  386. var stringResponseTwo = await create_ReqTwo.Content.ReadAsStringAsync();
  387. checkInViewTwo = System.Text.Json.JsonSerializer.Deserialize<CheckInView>(stringResponseTwo,
  388. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  389. if (checkInViewTwo.errcode != 0)
  390. {
  391. return checkInViewTwo;
  392. }
  393. #region 整合月报表数据
  394. foreach (var item_one in checkInViewOne.datas)
  395. {
  396. foreach (var item_two in checkInViewTwo.datas)
  397. {
  398. if (item_one.base_info.acctid.Equals(item_two.base_info.acctid))
  399. {
  400. #region summary_info 汇总信息整合
  401. item_one.summary_info.work_days += item_two.summary_info.work_days; //应打卡天数
  402. item_one.summary_info.regular_days += item_two.summary_info.regular_days; //正常天数
  403. item_one.summary_info.except_days += item_two.summary_info.except_days; //异常天数
  404. item_one.summary_info.regular_work_sec += item_two.summary_info.regular_work_sec; //实际工作时长,为统计周期每日实际工作时长之和
  405. item_one.summary_info.standard_work_sec += item_two.summary_info.standard_work_sec; //标准工作时长,为统计周期每日标准工作时长之和
  406. #endregion
  407. #region exception_infos 异常状态统计信息 整合
  408. item_one.exception_infos.AddRange(item_two.exception_infos);
  409. #endregion
  410. #region sp_items 假勤统计信息整合
  411. item_one.sp_items.AddRange(item_two.sp_items);
  412. #endregion
  413. #region overwork_info 加班情况 整合
  414. item_one.overwork_info.workday_over_sec += item_two.overwork_info.workday_over_sec; //工作日加班时长
  415. item_one.overwork_info.holidays_over_sec += item_two.overwork_info.holidays_over_sec; //节假日加班时长
  416. item_one.overwork_info.restdays_over_sec += item_two.overwork_info.restdays_over_sec; //休息日加班时长
  417. #endregion
  418. break;
  419. }
  420. }
  421. }
  422. #endregion
  423. checkInView = checkInViewOne;
  424. }
  425. else
  426. {
  427. checkInReq.starttime = (uint)((startDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  428. checkInReq.endtime = (uint)((endDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000);
  429. var json = System.Text.Json.JsonSerializer.Serialize(checkInReq);
  430. var content = new StringContent(json, Encoding.UTF8, "application/json");
  431. var create_Req = await _httpClient.PostAsync(url, content);
  432. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  433. checkInView = System.Text.Json.JsonSerializer.Deserialize<CheckInView>(stringResponse,
  434. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  435. }
  436. #endregion
  437. return checkInView;
  438. }
  439. /// <summary>
  440. /// 获取月打卡数据(redis缓存)
  441. /// </summary>
  442. /// <param name="startDt"></param>
  443. /// <param name="endDt"></param>
  444. /// <returns></returns>
  445. public async Task<CheckInView> GetCheckin_MonthDataRedisAsync(DateTime startDt, DateTime endDt)
  446. {
  447. CheckInView checkInView = new CheckInView();
  448. string checkInDatastring = await RedisRepository.RedisFactory
  449. .CreateRedisRepository()
  450. .StringGetAsync<string>("Checkin_MonthData");//List<T> 取
  451. if (!string.IsNullOrEmpty(checkInDatastring))
  452. {
  453. checkInView = JsonConvert.DeserializeObject<CheckInView>(checkInDatastring);
  454. return checkInView;
  455. }
  456. //获取员工Id
  457. UserIdListView userIdListView = await GetUserIdListAsync();
  458. if (userIdListView.errcode != 0)
  459. {
  460. checkInView.errcode = userIdListView.errcode;
  461. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】{0}", userIdListView.errmsg);
  462. return checkInView;
  463. }
  464. if (userIdListView.dept_user == null || userIdListView.dept_user.Count <= 0)
  465. {
  466. checkInView.errmsg = string.Format("【企业微信】【获取员工IdList】【Msg】未查出员工Id");
  467. return checkInView;
  468. }
  469. //获取月打卡数据 token
  470. Access_TokenView access_Token = await GetTokenAsync(2);
  471. if (access_Token.errcode != 0)
  472. {
  473. checkInView.errcode = access_Token.errcode;
  474. checkInView.errmsg = string.Format("【企业微信】【获取月打卡数据】【Token】【Msg】{0}", access_Token.errmsg);
  475. return checkInView;
  476. }
  477. string url = string.Format("/cgi-bin/checkin/getcheckin_monthdata?access_token={0}", access_Token.access_token);
  478. Checkin_MonthData_Request checkInReq = new Checkin_MonthData_Request();
  479. checkInReq.access_token = access_Token.access_token;
  480. checkInReq.starttime = (uint)(startDt - _1970).TotalSeconds;
  481. checkInReq.endtime = (uint)(endDt - _1970).TotalSeconds;
  482. checkInReq.useridlist = userIdListView.dept_user.Select(it => it.userid).ToList();
  483. var json = System.Text.Json.JsonSerializer.Serialize(checkInReq);
  484. var content = new StringContent(json, Encoding.UTF8, "application/json");
  485. var create_Req = await _httpClient.PostAsync(url, content);
  486. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  487. checkInView = System.Text.Json.JsonSerializer.Deserialize<CheckInView>(stringResponse,
  488. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  489. if (checkInView.errcode == 0)
  490. {
  491. TimeSpan ts = DateTime.Now.AddMinutes(60) - DateTime.Now; //设置redis 过期时间 60分钟
  492. await RedisRepository
  493. .RedisFactory
  494. .CreateRedisRepository()
  495. .StringSetAsync<string>("Checkin_MonthData", JsonConvert.SerializeObject(checkInView), ts);//List<T> 存
  496. }
  497. return checkInView;
  498. }
  499. /// <summary>
  500. /// 获取打卡记录数据
  501. /// </summary>
  502. /// <param name="useridlist">需要获取打卡记录的用户列表</param>
  503. /// <param name="opencheckindatatype">打卡类型。1:上下班打卡;2:外出打卡;3:全部打卡</param>
  504. /// <param name="startDt">获取打卡记录的开始时间。Unix时间戳</param>
  505. /// <param name="endDt">获取打卡记录的结束时间。Unix时间戳</param>
  506. /// <returns></returns>
  507. public async Task<CheckInDataView> GetCheckinDataAsync(List<string> useridlist, int opencheckindatatype, DateTime startDt, DateTime endDt)
  508. {
  509. CheckInDataView checkInDataView = new CheckInDataView();
  510. //参数处理
  511. if (useridlist.Count <= 0)
  512. {
  513. checkInDataView.errmsg = "请填写企业微信用户id,可为多个!";
  514. return checkInDataView;
  515. }
  516. if (useridlist.Count > 100)
  517. {
  518. checkInDataView.errmsg = "用户列表不超过100个。若用户超过100个,请分批获取!";
  519. return checkInDataView;
  520. }
  521. //获取打卡数据 token
  522. Access_TokenView access_Token = await GetTokenAsync(2);
  523. if (access_Token.errcode != 0)
  524. {
  525. checkInDataView.errcode = access_Token.errcode;
  526. checkInDataView.errmsg = string.Format("【企业微信】【获取打卡数据】【Token】【Msg】{0}", access_Token.errmsg);
  527. return checkInDataView;
  528. }
  529. string url = string.Format("/cgi-bin/checkin/getcheckindata?access_token={0}", access_Token.access_token);
  530. DateTime centerDt = startDt.AddDays(30);
  531. long startTs = (long)(startDt - _1970).TotalSeconds;
  532. long centerTs = (long)(centerDt - _1970).TotalSeconds;
  533. long endTs = (long)(endDt - _1970).TotalSeconds;
  534. CheckInData_Request checkInData_Req = new CheckInData_Request()
  535. {
  536. access_token = access_Token.access_token,
  537. opencheckindatatype = opencheckindatatype,
  538. useridlist = useridlist,
  539. starttime = startTs,
  540. endtime = centerTs
  541. };
  542. var json = System.Text.Json.JsonSerializer.Serialize(checkInData_Req);
  543. var content = new StringContent(json, Encoding.UTF8, "application/json");
  544. var create_Req = await _httpClient.PostAsync(url, content);
  545. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  546. checkInDataView = System.Text.Json.JsonSerializer.Deserialize<CheckInDataView>(stringResponse,
  547. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  548. if (centerDt < endDt)
  549. {
  550. checkInData_Req.starttime = centerTs;
  551. checkInData_Req.endtime = endTs;
  552. var json1 = System.Text.Json.JsonSerializer.Serialize(checkInData_Req);
  553. var content1 = new StringContent(json1, Encoding.UTF8, "application/json");
  554. var create_Req1 = await _httpClient.PostAsync(url, content1);
  555. var stringResponse1 = await create_Req1.Content.ReadAsStringAsync();
  556. CheckInDataView checkInDataView1 = System.Text.Json.JsonSerializer.Deserialize<CheckInDataView>(stringResponse1,
  557. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  558. if (checkInDataView1.errcode != 0)
  559. {
  560. return checkInDataView1;
  561. }
  562. checkInDataView.checkindata.AddRange(checkInDataView1.checkindata);
  563. return checkInDataView;
  564. }
  565. return checkInDataView;
  566. }
  567. /// <summary>
  568. /// 获取打卡日报数据
  569. /// </summary>
  570. /// <param name="useridlist"></param>
  571. /// <param name="startDt"></param>
  572. /// <param name="endDt"></param>
  573. /// <returns></returns>
  574. public async Task<CheckInDayDataView> GetCheckInDayDataAsync1(List<string> useridlist, DateTime startDt, DateTime endDt)
  575. {
  576. CheckInDayDataView checkInDayDataView = new CheckInDayDataView();
  577. //参数处理
  578. if (useridlist.Count <= 0)
  579. {
  580. checkInDayDataView.errmsg = "请填写企业微信用户id,可为多个!";
  581. return checkInDayDataView;
  582. }
  583. //获取打卡数据 token
  584. Access_TokenView access_Token = await GetTokenAsync(2);
  585. if (access_Token.errcode != 0)
  586. {
  587. checkInDayDataView.errcode = access_Token.errcode;
  588. checkInDayDataView.errmsg = string.Format("【企业微信】【获取打卡日报数据】【Token】【Msg】{0}", access_Token.errmsg);
  589. return checkInDayDataView;
  590. }
  591. string url = string.Format("/cgi-bin/checkin/getcheckin_daydata?access_token={0}&debug=1", access_Token.access_token);
  592. long startTs = (startDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  593. long endTs = (endDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  594. var checkInData_Req = new
  595. {
  596. access_token = access_Token.access_token,
  597. useridlist = useridlist,
  598. starttime = startTs,
  599. endtime = endTs
  600. };
  601. var json = System.Text.Json.JsonSerializer.Serialize(checkInData_Req);
  602. var content = new StringContent(json, Encoding.UTF8, "application/json");
  603. var create_Req = await _httpClient.PostAsync(url, content);
  604. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  605. checkInDayDataView = System.Text.Json.JsonSerializer.Deserialize<CheckInDayDataView>(stringResponse,
  606. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  607. return checkInDayDataView;
  608. }
  609. /// <summary>
  610. /// 获取打卡日报数据
  611. /// </summary>
  612. /// <param name="useridlist"></param>
  613. /// <param name="startDt"></param>
  614. /// <param name="endDt"></param>
  615. /// <returns></returns>
  616. public async Task<CheckInDayDataView> GetCheckInDayDataAsync(List<string> useridlist, DateTime startDt, DateTime endDt)
  617. {
  618. CheckInDayDataView checkInDayDataView = new CheckInDayDataView();
  619. //参数处理
  620. if (useridlist.Count <= 0)
  621. {
  622. checkInDayDataView.errmsg = "请填写企业微信用户id,可为多个!";
  623. return checkInDayDataView;
  624. }
  625. //获取打卡数据 token
  626. Access_TokenView access_Token = await GetTokenAsync(2);
  627. if (access_Token.errcode != 0)
  628. {
  629. checkInDayDataView.errcode = access_Token.errcode;
  630. checkInDayDataView.errmsg = string.Format("【企业微信】【获取打卡日报数据】【Token】【Msg】{0}", access_Token.errmsg);
  631. return checkInDayDataView;
  632. }
  633. string url = string.Format("/cgi-bin/checkin/getcheckin_daydata?access_token={0}&debug=1", access_Token.access_token);
  634. int days = (int)(endDt - startDt).TotalDays;
  635. if (days > 31)
  636. {
  637. long startTs_One = (startDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  638. long endTs_One = (startDt.AddDays(31).ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  639. long startTs_Two = (startDt.AddDays(31).ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  640. long endTs_Two = (endDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  641. var checkInData_ReqOne = new
  642. {
  643. access_token = access_Token.access_token,
  644. useridlist = useridlist,
  645. starttime = startTs_One,
  646. endtime = endTs_One
  647. };
  648. var jsonOne = System.Text.Json.JsonSerializer.Serialize(checkInData_ReqOne);
  649. var contentOne = new StringContent(jsonOne, Encoding.UTF8, "application/json");
  650. var create_ReqOne = await _httpClient.PostAsync(url, contentOne);
  651. var stringResponseOne = await create_ReqOne.Content.ReadAsStringAsync();
  652. CheckInDayDataView checkInDayDataViewOne = System.Text.Json.JsonSerializer.Deserialize<CheckInDayDataView>(stringResponseOne,
  653. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  654. if (checkInDayDataViewOne.errcode != 0)
  655. {
  656. return checkInDayDataViewOne;
  657. }
  658. var checkInData_ReqTwo = new
  659. {
  660. access_token = access_Token.access_token,
  661. useridlist = useridlist,
  662. starttime = startTs_Two,
  663. endtime = endTs_Two
  664. };
  665. var jsonTwo = System.Text.Json.JsonSerializer.Serialize(checkInData_ReqTwo);
  666. var contentTwo = new StringContent(jsonTwo, Encoding.UTF8, "application/json");
  667. var create_ReqTwo = await _httpClient.PostAsync(url, contentTwo);
  668. var stringResponseTwo = await create_ReqTwo.Content.ReadAsStringAsync();
  669. CheckInDayDataView checkInDayDataViewTwo = System.Text.Json.JsonSerializer.Deserialize<CheckInDayDataView>(stringResponseTwo,
  670. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  671. if (checkInDayDataViewTwo.errcode != 0)
  672. {
  673. return checkInDayDataViewTwo;
  674. }
  675. checkInDayDataViewOne.datas.AddRange(checkInDayDataViewTwo.datas);
  676. return checkInDayDataViewOne;
  677. }
  678. else
  679. {
  680. long startTs = (startDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  681. long endTs = (endDt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  682. var checkInData_Req = new
  683. {
  684. access_token = access_Token.access_token,
  685. useridlist = useridlist,
  686. starttime = startTs,
  687. endtime = endTs
  688. };
  689. var json = System.Text.Json.JsonSerializer.Serialize(checkInData_Req);
  690. var content = new StringContent(json, Encoding.UTF8, "application/json");
  691. var create_Req = await _httpClient.PostAsync(url, content);
  692. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  693. checkInDayDataView = System.Text.Json.JsonSerializer.Deserialize<CheckInDayDataView>(stringResponse,
  694. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  695. }
  696. return checkInDayDataView;
  697. }
  698. #endregion
  699. #region 审批
  700. /// <summary>
  701. /// 获取审批数据(旧)
  702. /// </summary>
  703. /// <param name="startDt"></param>
  704. /// <param name="endDt"></param>
  705. /// <returns></returns>
  706. public async Task<ApprovalDataView> GetApprovalDataAsync(DateTime startDt, DateTime endDt)
  707. {
  708. ApprovalDataView approvalDataView = new ApprovalDataView();
  709. //获取审批数据 token
  710. Access_TokenView access_Token = await GetTokenAsync(5);
  711. if (access_Token.errcode != 0)
  712. {
  713. approvalDataView.errcode = access_Token.errcode;
  714. approvalDataView.errmsg = string.Format("【企业微信】【获取审批数据】【Token】【Msg】{0}", access_Token.errmsg);
  715. return approvalDataView;
  716. }
  717. string url = string.Format("/cgi-bin/corp/getapprovaldata?access_token={0}", access_Token.access_token);
  718. ApprovalData_Request approvalDataReq = new ApprovalData_Request();
  719. approvalDataReq.access_token = access_Token.access_token;
  720. approvalDataReq.starttime = (uint)(startDt - _1970).TotalSeconds;
  721. approvalDataReq.endtime = (uint)(endDt - _1970).TotalSeconds;
  722. var json = System.Text.Json.JsonSerializer.Serialize(approvalDataReq);
  723. var content = new StringContent(json, Encoding.UTF8, "application/json");
  724. var create_Req = await _httpClient.PostAsync(url, content);
  725. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  726. approvalDataView = System.Text.Json.JsonSerializer.Deserialize<ApprovalDataView>(stringResponse,
  727. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  728. List<Sp_Info> sp_datas = new List<Sp_Info>();
  729. sp_datas.AddRange(approvalDataView.data);
  730. int index = 0;
  731. //多次访问审批接口
  732. if (approvalDataView.total >= 100)
  733. {
  734. approvalDataView.total -= 100;
  735. int forTotal = approvalDataView.total % 100 == 0 ? approvalDataView.total / 100 : approvalDataView.total / 100 + 1;
  736. long? next_spnum = approvalDataView.next_spnum;
  737. approvalDataReq.next_spnum = next_spnum;
  738. for (int i = 0; i < forTotal; i++)
  739. {
  740. index++;
  741. var for_json = System.Text.Json.JsonSerializer.Serialize(approvalDataReq);
  742. var for_content = new StringContent(for_json, Encoding.UTF8, "application/json");
  743. var for_create_Req = await _httpClient.PostAsync(url, for_content);
  744. var for_stringResponse = await for_create_Req.Content.ReadAsStringAsync();
  745. ApprovalDataView for_approvalDataView = System.Text.Json.JsonSerializer.Deserialize<ApprovalDataView>(for_stringResponse,
  746. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  747. approvalDataReq.next_spnum = for_approvalDataView.next_spnum; //重新定义游标
  748. sp_datas.AddRange(for_approvalDataView.data); //追加数据
  749. }
  750. approvalDataView.total += 100;
  751. }
  752. approvalDataView.data = sp_datas;
  753. return approvalDataView;
  754. }
  755. /// <summary>
  756. /// 获取审批数据(旧)(redis缓存)
  757. /// </summary>
  758. /// <param name="startDt"></param>
  759. /// <param name="endDt"></param>
  760. /// <returns></returns>
  761. public async Task<List<Sp_Info>> GetApprovalDatasAsync(DateTime startDt, DateTime endDt)
  762. {
  763. List<Sp_Info> sp_Infos = new List<Sp_Info>();
  764. //获取所有打卡补卡,审批 数据 前后范围增加10天
  765. DateTime sp_startDt = startDt.AddDays(-10);
  766. DateTime sp_centerDt = sp_startDt.AddDays(30);
  767. DateTime sp_endDt = endDt.AddDays(10);
  768. ApprovalDataView approvalData_1 = await GetApprovalDataAsync(sp_startDt, sp_centerDt); //时间段内所有 审批数据
  769. ApprovalDataView approvalData_2 = await GetApprovalDataAsync(sp_centerDt, sp_endDt); //时间段内所有 审批数据
  770. if (approvalData_1.errcode != 0)
  771. {
  772. Log.Error("企业微信 获取 " + sp_startDt + " - " + sp_centerDt + " 内审批 Msg:" + approvalData_1.errmsg);
  773. return sp_Infos;
  774. }
  775. sp_Infos.AddRange(approvalData_1.data);
  776. if (approvalData_2.errcode != 0)
  777. {
  778. Log.Error("企业微信 获取 " + sp_centerDt + " - " + sp_endDt + " 内审批 Msg:" + approvalData_2.errmsg);
  779. return sp_Infos;
  780. }
  781. sp_Infos.AddRange(approvalData_2.data);
  782. sp_Infos = sp_Infos.Where(it => it.sp_status == 2).ToList(); //存储已审核的数据
  783. return sp_Infos;
  784. }
  785. /// <summary>
  786. /// 获取审批数据(旧)(redis缓存)
  787. /// </summary>
  788. /// <param name="startDt"></param>
  789. /// <param name="endDt"></param>
  790. /// <returns></returns>
  791. public async Task<List<Sp_Info>> GetApprovalDatasRedisAsync(DateTime startDt, DateTime endDt)
  792. {
  793. List<Sp_Info> sp_Infos = new List<Sp_Info>();
  794. //获取所有打卡补卡,审批 数据 前后范围增加10天
  795. DateTime sp_startDt = startDt.AddDays(-10);
  796. DateTime sp_centerDt = sp_startDt.AddDays(30);
  797. DateTime sp_endDt = endDt.AddDays(10);
  798. string redisName = "ApprovalData" + sp_startDt.ToString("yyyyMMdd") + "-" + sp_endDt.ToString("yyyyMMdd");
  799. string sp_InfosString = string.Empty;
  800. //sp_InfosString = await RedisRepository.RedisFactory
  801. // .CreateRedisRepository()
  802. // .StringGetAsync<string>(redisName);//string 取
  803. if (string.IsNullOrEmpty(sp_InfosString))
  804. {
  805. ApprovalDataView approvalData_1 = await GetApprovalDataAsync(sp_startDt, sp_centerDt); //时间段内所有 审批数据
  806. ApprovalDataView approvalData_2 = await GetApprovalDataAsync(sp_centerDt, sp_endDt); //时间段内所有 审批数据
  807. if (approvalData_1.errcode != 0)
  808. {
  809. Log.Error("企业微信 获取 " + sp_startDt + " - " + sp_centerDt + " 内审批 Msg:" + approvalData_1.errmsg);
  810. return sp_Infos;
  811. }
  812. sp_Infos.AddRange(approvalData_1.data);
  813. if (approvalData_2.errcode != 0)
  814. {
  815. Log.Error("企业微信 获取 " + sp_centerDt + " - " + sp_endDt + " 内审批 Msg:" + approvalData_2.errmsg);
  816. return sp_Infos;
  817. }
  818. sp_Infos.AddRange(approvalData_2.data);
  819. sp_Infos = sp_Infos.Where(it => it.sp_status == 2).ToList(); //存储已审核的数据
  820. TimeSpan ts = DateTime.Now.AddMinutes(60) - DateTime.Now; //设置redis 过期时间 60分钟
  821. await RedisRepository
  822. .RedisFactory
  823. .CreateRedisRepository()
  824. .StringSetAsync<string>(redisName, JsonConvert.SerializeObject(sp_Infos), ts);//string 存
  825. }
  826. else
  827. {
  828. sp_Infos = JsonConvert.DeserializeObject<List<Sp_Info>>(sp_InfosString);
  829. }
  830. return sp_Infos;
  831. }
  832. /// <summary>
  833. /// 批量获取审批单号
  834. /// </summary>
  835. /// <param name="startDt"></param>
  836. /// <param name="endDt"></param>
  837. /// <param name="creator">
  838. /// 申请人
  839. /// </param>
  840. /// <param name="sp_status">
  841. /// sp_status-审批单状态(1-审批中;2-已通过;3-已驳回;4-已撤销;6-通过后撤销;7-已删除;10-已支付)
  842. /// </param>
  843. /// <param name="record_type">
  844. /// record_type == 0 ALL 有值 请填写对应值
  845. /// record_type - 审批单类型属性,1-请假;2-打卡补卡;3-出差;4-外出;5-加班; 6- 调班;7-会议室预定;8-退款审批;9-红包报销审批
  846. /// </param>
  847. /// <returns></returns>
  848. private async Task<ApprovalInfoView> GetApprovalInfoAsync(DateTime startDt, DateTime endDt, string creator, int sp_status, int record_type)
  849. {
  850. Stopwatch sw = new Stopwatch();
  851. sw.Start();
  852. ApprovalInfoView approvalInfoView = new ApprovalInfoView();
  853. //获取所有打卡补卡,审批 数据 向前增加30天 向后范围增加15天
  854. DateTime sp_startDt = startDt.AddDays(-30);
  855. DateTime sp_endDt = endDt.AddDays(15);
  856. //获取审批数据 token
  857. Access_TokenView access_Token = await GetTokenAsync(5);
  858. if (access_Token.errcode != 0)
  859. {
  860. approvalInfoView.errcode = access_Token.errcode;
  861. approvalInfoView.errmsg = string.Format("【企业微信】【批量获取审批单号】【Token】【Msg】{0}", access_Token.errmsg);
  862. return approvalInfoView;
  863. }
  864. string url = string.Format("/cgi-bin/oa/getapprovalinfo?access_token={0}", access_Token.access_token);
  865. List<Dic> filters = new List<Dic> {
  866. new Dic() { key = "creator", value = creator }, //筛选条件 申请人
  867. new Dic() { key = "sp_status", value = sp_status.ToString() }, //筛选条件 审核状态 2 已同意
  868. };
  869. if (record_type != 0)
  870. {
  871. filters.Add(new Dic() { key = "record_type", value = record_type.ToString() }); //筛选条件 审批单类型 请假 1
  872. }
  873. int days = (sp_endDt - sp_startDt).Days;
  874. decimal runCount = days % 30;
  875. int runCount1 = 0;
  876. if (runCount == 0) runCount1 = (int)(days % 30.00M);
  877. else runCount1 = (int)Math.Ceiling(days / 30.00M);
  878. List<string> sp_no_lists = new List<string>();
  879. for (int i = 0; i < runCount1; i++)
  880. {
  881. DateTime for_sp_startDt = sp_startDt;
  882. DateTime for_sp_endDt = sp_startDt.AddDays(30);
  883. sp_startDt = sp_startDt.AddDays(30);
  884. if (for_sp_endDt >= sp_endDt)
  885. {
  886. for_sp_endDt = sp_endDt;
  887. }
  888. ApprovalInfo_Request approvalInfoReq = new ApprovalInfo_Request()
  889. {
  890. access_token = access_Token.access_token,
  891. starttime = (uint)ConvertToTimeSpan(for_sp_startDt),
  892. endtime = (uint)ConvertToTimeSpan(for_sp_endDt),
  893. filters = filters.ToList(),
  894. };
  895. var json = System.Text.Json.JsonSerializer.Serialize(approvalInfoReq);
  896. var content = new StringContent(json, Encoding.UTF8, "application/json");
  897. var create_Req = await _httpClient.PostAsync(url, content);
  898. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  899. ApprovalInfoView approvalInfoView1 = System.Text.Json.JsonSerializer.Deserialize<ApprovalInfoView>(stringResponse,
  900. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  901. #region 分页调用 new_next_cursor != null
  902. string new_cursor = approvalInfoView1.new_next_cursor;
  903. while (!string.IsNullOrEmpty(new_cursor))
  904. {
  905. approvalInfoReq.new_cursor = new_cursor;
  906. var json1 = System.Text.Json.JsonSerializer.Serialize(approvalInfoReq);
  907. var content1 = new StringContent(json, Encoding.UTF8, "application/json");
  908. var create_Req1 = await _httpClient.PostAsync(url, content1);
  909. var stringResponse1 = await create_Req1.Content.ReadAsStringAsync();
  910. ApprovalInfoView approvalInfoView11 = System.Text.Json.JsonSerializer.Deserialize<ApprovalInfoView>(stringResponse1,
  911. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  912. if (approvalInfoView11.errcode != 0)
  913. {
  914. return approvalInfoView1;
  915. }
  916. new_cursor = approvalInfoView11.new_next_cursor;
  917. if (approvalInfoView11.sp_no_list.Count > 0 || approvalInfoView11.sp_no_list != null)
  918. {
  919. sp_no_lists.AddRange(approvalInfoView1.sp_no_list);
  920. }
  921. }
  922. #endregion
  923. if (approvalInfoView1.errcode != 0)
  924. {
  925. return approvalInfoView1;
  926. }
  927. if (approvalInfoView1.sp_no_list.Count > 0 || approvalInfoView1.sp_no_list != null)
  928. {
  929. sp_no_lists.AddRange(approvalInfoView1.sp_no_list);
  930. }
  931. }
  932. approvalInfoView.errcode = 0;
  933. if (sp_no_lists.Count > 0)
  934. {
  935. sp_no_lists = sp_no_lists.Distinct().ToList();
  936. }
  937. approvalInfoView.sp_no_list = sp_no_lists;
  938. sw.Stop();
  939. approvalInfoView.errmsg = approvalInfoView.errmsg + " 耗时:" + sw.Elapsed.TotalMilliseconds + "ms";
  940. return approvalInfoView;
  941. }
  942. /// <summary>
  943. /// 获取审批申请详情
  944. /// </summary>
  945. /// <param name="sp_no"></param>
  946. /// <returns></returns>
  947. public async Task<ApprovalDetailView> GetApprovalDetailAsync(string sp_no)
  948. {
  949. ApprovalDetailView ApprovalDetailView = new ApprovalDetailView();
  950. if (string.IsNullOrEmpty(sp_no))
  951. {
  952. return ApprovalDetailView;
  953. }
  954. //获取审批数据 token
  955. Access_TokenView access_Token = await GetTokenAsync(5);
  956. if (access_Token.errcode != 0)
  957. {
  958. ApprovalDetailView.errcode = access_Token.errcode;
  959. ApprovalDetailView.errmsg = string.Format("【企业微信】【审批申请详情】【Token】【Msg】{0}", access_Token.errmsg);
  960. return ApprovalDetailView;
  961. }
  962. string url = string.Format("/cgi-bin/oa/getapprovaldetail?access_token={0}", access_Token.access_token);
  963. ApprovalDetail_Request approvalDetail_Req = new ApprovalDetail_Request()
  964. {
  965. access_token = access_Token.access_token,
  966. sp_no = sp_no,
  967. };
  968. var json = System.Text.Json.JsonSerializer.Serialize(approvalDetail_Req);
  969. var content = new StringContent(json, Encoding.UTF8, "application/json");
  970. var create_Req = await _httpClient.PostAsync(url, content);
  971. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  972. ApprovalDetailView = System.Text.Json.JsonSerializer.Deserialize<ApprovalDetailView>(stringResponse,
  973. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  974. return ApprovalDetailView;
  975. }
  976. /// <summary>
  977. /// 批量获取审批详情
  978. /// </summary>
  979. /// <param name="startDt"></param>
  980. /// <param name="endDt"></param>
  981. /// <param name="creator">
  982. /// 申请人
  983. /// </param>
  984. /// <param name="sp_status">
  985. /// sp_status-审批单状态(1-审批中;2-已通过;3-已驳回;4-已撤销;6-通过后撤销;7-已删除;10-已支付)
  986. /// </param>
  987. /// <param name="record_type">
  988. /// record_type - 审批单类型属性,1-请假;2-打卡补卡;3-出差;4-外出;5-加班; 6- 调班;7-会议室预定;8-退款审批;9-红包报销审批
  989. /// </param>
  990. /// <returns></returns>
  991. public async Task<List<Sp_Detail>> GetApprovalDetailsAsync(DateTime startDt, DateTime endDt, string creator, int sp_status, int record_type)
  992. {
  993. Stopwatch sw = new Stopwatch();
  994. sw.Start();
  995. List<Sp_Detail> details = new List<Sp_Detail>();
  996. if (string.IsNullOrEmpty(creator))
  997. {
  998. return details;
  999. }
  1000. ApprovalInfoView approvalInfoView = new ApprovalInfoView();
  1001. approvalInfoView = await GetApprovalInfoAsync(startDt, endDt, creator, sp_status, record_type);
  1002. if (approvalInfoView.errcode != 0)
  1003. {
  1004. return details;
  1005. }
  1006. //循环查询详情
  1007. foreach (var item in approvalInfoView.sp_no_list)
  1008. {
  1009. ApprovalDetailView approvalDetailView = new ApprovalDetailView();
  1010. approvalDetailView = await GetApprovalDetailAsync(item);
  1011. if (approvalDetailView.errcode != 0)
  1012. {
  1013. Log.Error("【GetApprovalDetailsAsync】 record_type:" + record_type + " ErrorMsg:" + approvalDetailView.errmsg);
  1014. break;
  1015. }
  1016. details.Add(approvalDetailView.info);
  1017. }
  1018. sw.Stop();
  1019. double hs = sw.Elapsed.TotalMilliseconds;
  1020. return details;
  1021. }
  1022. /// <summary>
  1023. /// 获取审批模板详情
  1024. /// </summary>
  1025. /// <param name="template_id">模板Id</param>
  1026. /// <returns></returns>
  1027. public async Task<TemplateDetailView> GetTemplateDetailAsync(string template_id)
  1028. {
  1029. TemplateDetailView templateDetailView = new TemplateDetailView();
  1030. if (string.IsNullOrEmpty(template_id))
  1031. {
  1032. templateDetailView.errmsg = "template_id为空!";
  1033. return templateDetailView;
  1034. }
  1035. //获取审批数据 token
  1036. Access_TokenView access_Token = await GetTokenAsync(5);
  1037. if (access_Token.errcode != 0)
  1038. {
  1039. templateDetailView.errcode = access_Token.errcode;
  1040. templateDetailView.errmsg = string.Format("【企业微信】【审批申请详情】【Token】【Msg】{0}", access_Token.errmsg);
  1041. return templateDetailView;
  1042. }
  1043. string url = string.Format("/cgi-bin/oa/gettemplatedetail?access_token={0}", access_Token.access_token);
  1044. var approvalDetail_Req = new
  1045. {
  1046. access_token = access_Token.access_token,
  1047. template_id = template_id,
  1048. };
  1049. var json = System.Text.Json.JsonSerializer.Serialize(approvalDetail_Req);
  1050. var content = new StringContent(json, Encoding.UTF8, "application/json");
  1051. var create_Req = await _httpClient.PostAsync(url, content);
  1052. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  1053. templateDetailView = System.Text.Json.JsonSerializer.Deserialize<TemplateDetailView>(stringResponse,
  1054. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  1055. return templateDetailView;
  1056. }
  1057. #endregion
  1058. #region hook机器人
  1059. /// <summary>
  1060. /// 发送团组信息给财务群
  1061. /// </summary>
  1062. /// <param name="msg"></param>
  1063. /// <returns></returns>
  1064. /// <exception cref="NotImplementedException"></exception>
  1065. public async Task<ResponseBase> RobotSendMsg_GroupInfo(string msg)
  1066. {
  1067. string key = "b4fe152f-a97a-48b1-830f-ab447f6d2f5f";
  1068. string url = string.Format("/cgi-bin/webhook/send?key={0}", key);
  1069. RobotSendMsg_GroupInfo_Content contentStr = new RobotSendMsg_GroupInfo_Content() { content = msg };
  1070. RobotSendMsg_GroupInfo_Param reqJson = new RobotSendMsg_GroupInfo_Param()
  1071. {
  1072. msgtype = "markdown",
  1073. markdown = contentStr
  1074. };
  1075. var json = System.Text.Json.JsonSerializer.Serialize(reqJson);
  1076. var content = new StringContent(json, Encoding.UTF8, "application/json");
  1077. var create_Req = await _httpClient.PostAsync(url, content);
  1078. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  1079. ResponseBase sendMsgView = System.Text.Json.JsonSerializer.Deserialize<ResponseBase>(stringResponse,
  1080. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  1081. return sendMsgView;
  1082. }
  1083. #endregion
  1084. #region 团组状态通知
  1085. /// <summary>
  1086. /// 获取部门成员
  1087. /// </summary>
  1088. /// <param name="departmentId"></param>
  1089. /// <returns></returns>
  1090. public async Task<GroupStatus_UserSimplelistView> GroupStatus_GetUserList(int departmentId = 8402038)
  1091. {
  1092. GroupStatus_UserSimplelistView result = new GroupStatus_UserSimplelistView();
  1093. Access_TokenView access_Token = await GetTokenAsync(6);
  1094. if (access_Token.errcode != 0)
  1095. {
  1096. result.errcode = access_Token.errcode;
  1097. result.errmsg = string.Format("【企业微信】【团组状态通知】【Token】【Msg】{0}", access_Token.errmsg);
  1098. return result;
  1099. }
  1100. string url = string.Format("/cgi-bin/user/simplelist?access_token={0}&department_id={1}", access_Token.access_token, departmentId);
  1101. var simplelist_Req = await _httpClient.GetAsync(url);
  1102. if (simplelist_Req.IsSuccessStatusCode)
  1103. {
  1104. var stringResponse = await simplelist_Req.Content.ReadAsStringAsync();
  1105. result = System.Text.Json.JsonSerializer.Deserialize<GroupStatus_UserSimplelistView>(stringResponse,
  1106. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  1107. }
  1108. else
  1109. {
  1110. result.errcode = -1;
  1111. result.errmsg = "企业微信部门列表未获取到!";
  1112. }
  1113. return result;
  1114. }
  1115. /// <summary>
  1116. /// 创建群聊
  1117. /// </summary>
  1118. /// <param name="chatName"></param>
  1119. /// <param name="owner"></param>
  1120. /// <param name="userList"></param>
  1121. /// <param name="chatId"></param>
  1122. /// <returns></returns>
  1123. public async Task<GroupStatus_CreateChatView> GroupStatus_CreateChat(string chatName, string owner, List<string> userList, string chatId)
  1124. {
  1125. GroupStatus_CreateChatView result = new GroupStatus_CreateChatView();
  1126. Access_TokenView access_Token = await GetTokenAsync(6);
  1127. if (access_Token.errcode != 0)
  1128. {
  1129. result.errcode = access_Token.errcode;
  1130. result.errmsg = string.Format("【企业微信】【团组状态通知】【Token】【Msg】{0}", access_Token.errmsg);
  1131. return result;
  1132. }
  1133. GroupStatus_CreateChat reqJson = new GroupStatus_CreateChat()
  1134. {
  1135. chatid = chatId,
  1136. name = chatName,
  1137. owner = owner,
  1138. userlist = userList
  1139. };
  1140. string url = string.Format("/cgi-bin/appchat/create?access_token={0}&debug=1", access_Token.access_token);
  1141. var json = System.Text.Json.JsonSerializer.Serialize(reqJson);
  1142. var content = new StringContent(json, Encoding.UTF8, "application/json");
  1143. var create_Req = await _httpClient.PostAsync(url, content);
  1144. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  1145. result = System.Text.Json.JsonSerializer.Deserialize<GroupStatus_CreateChatView>(stringResponse,
  1146. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  1147. return result;
  1148. }
  1149. /// <summary>
  1150. /// 向群聊发送信息
  1151. /// </summary>
  1152. /// <param name="chatId"></param>
  1153. /// <param name="msgContent"></param>
  1154. /// <param name="msgType"></param>
  1155. /// <returns></returns>
  1156. /// <exception cref="NotImplementedException"></exception>
  1157. public async Task<ResponseBase> GroupStatus_SendChatMsg_Markdown(string chatId, string msgContent, string msgType = "markdown")
  1158. {
  1159. ResponseBase result = new ResponseBase();
  1160. Access_TokenView access_Token = await GetTokenAsync(6);
  1161. if (access_Token.errcode != 0)
  1162. {
  1163. result.errcode = access_Token.errcode;
  1164. result.errmsg = string.Format("【企业微信】【团组状态通知】【Token】【Msg】{0}", access_Token.errmsg);
  1165. return result;
  1166. }
  1167. RobotSendMsg_GroupInfo_Content markdown = new RobotSendMsg_GroupInfo_Content() { content = msgContent };
  1168. GroupStatus_AppChatSend_Markdown reqJson = new GroupStatus_AppChatSend_Markdown()
  1169. {
  1170. chatid = chatId,
  1171. msgtype = msgType,
  1172. markdown = markdown
  1173. };
  1174. string url = string.Format("/cgi-bin/appchat/send?access_token={0}", access_Token.access_token);
  1175. var json = System.Text.Json.JsonSerializer.Serialize(reqJson);
  1176. var content = new StringContent(json, Encoding.UTF8, "application/json");
  1177. var create_Req = await _httpClient.PostAsync(url, content);
  1178. var stringResponse = await create_Req.Content.ReadAsStringAsync();
  1179. result = System.Text.Json.JsonSerializer.Deserialize<ResponseBase>(stringResponse,
  1180. new JsonSerializerOptions() { PropertyNamingPolicy = JsonNamingPolicy.CamelCase });
  1181. return result;
  1182. }
  1183. public Task<GroupStatus_SendMessageView> GroupStatus_SendMessage_ToUser(string toUser, string msgContent, string msgType = "markdown")
  1184. {
  1185. throw new NotImplementedException();
  1186. }
  1187. #endregion
  1188. public long ConvertToTimeSpan(DateTime dt)
  1189. {
  1190. return (dt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
  1191. }
  1192. }
  1193. }