QiYeWeChatApiService.cs 57 KB

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