MarketCustomerResourcesController.cs 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182
  1. using Aspose.Cells;
  2. using Microsoft.AspNetCore.Mvc.RazorPages;
  3. using OASystem.API.OAMethodLib;
  4. using OASystem.Domain.AesEncryption;
  5. using OASystem.Domain.Dtos.CRM;
  6. using OASystem.Domain.Entities.Customer;
  7. using OASystem.Domain.ViewModels.CRM;
  8. using OASystem.Infrastructure.Repositories.CRM;
  9. using System.Collections;
  10. using System.Data;
  11. using System.Diagnostics;
  12. using System.Linq;
  13. using OASystem.Domain.Attributes;
  14. using EyeSoft.Extensions;
  15. using OASystem.RedisRepository;
  16. using System.Linq.Expressions;
  17. namespace OASystem.API.Controllers
  18. {
  19. /// <summary>
  20. /// 市场客户资料
  21. /// </summary>
  22. [Route("api/[controller]/[action]")]
  23. public class MarketCustomerResourcesController : ControllerBase
  24. {
  25. private readonly NewClientDataRepository _clientDataRepository;
  26. private readonly SqlSugarClient _sqlSugar;
  27. private string keyName = "newClient_SearchKey";
  28. /// <summary>
  29. /// 初始化
  30. /// </summary>
  31. public MarketCustomerResourcesController(NewClientDataRepository clientDataRepository, SqlSugarClient sqlSugar)
  32. {
  33. this._clientDataRepository = clientDataRepository;
  34. _sqlSugar = sqlSugar;
  35. }
  36. /// <summary>
  37. /// 客户资料数据
  38. /// 基础数据
  39. /// </summary>
  40. /// <returns></returns>
  41. [HttpPost]
  42. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  43. public async Task<IActionResult> MarketCustomerInit(MarketCustomerInitDto dto)
  44. {
  45. JsonView jw = new JsonView();
  46. try
  47. {
  48. Result resultData = await _clientDataRepository._Init(dto);
  49. if (resultData.Code == 0)
  50. {
  51. jw = JsonView(true, "查询成功!", resultData.Data);
  52. }
  53. else
  54. {
  55. jw = JsonView(false, resultData.Msg);
  56. }
  57. }
  58. catch (Exception)
  59. {
  60. jw = JsonView(false, "程序错误!");
  61. }
  62. return Ok(jw);
  63. }
  64. /// <summary>
  65. /// 查询客户资料数据
  66. /// </summary>
  67. /// <returns></returns>
  68. [HttpPost]
  69. [ApiLog("Crm_NewClientData", OperationEnum.List)]
  70. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  71. public async Task<IActionResult> QueryNewClientData(NewClientDataQueryDto dto)
  72. {
  73. #region 参数验证
  74. if (dto.OperationUserId < 0)
  75. return Ok(JsonView(false, "请传入有效的OperationUserId参数!"));
  76. if (dto.PortType < 0)
  77. return Ok(JsonView(false, "请传入有效的PortType参数!"));
  78. #endregion
  79. JsonView jw = new JsonView();
  80. try
  81. {
  82. Result resultData = await _clientDataRepository.QueryNewClientData(dto);
  83. if (resultData.Code == 0)
  84. {
  85. #region 客户资料表操作记录
  86. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.NoOperation, dto.OperationUserId, 0, "");
  87. #endregion
  88. jw = JsonView(true, resultData.Msg, resultData.Data);
  89. }
  90. else
  91. {
  92. jw = JsonView(false, resultData.Msg);
  93. }
  94. }
  95. catch (Exception)
  96. {
  97. jw = JsonView(false, "程序错误!");
  98. }
  99. return Ok(jw);
  100. }
  101. /// <summary>
  102. /// 客户资料数据
  103. /// Details
  104. /// </summary>
  105. /// <returns></returns>
  106. [HttpPost]
  107. [ApiLog("Crm_NewClientData", OperationEnum.Details)]
  108. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  109. public async Task<IActionResult> PostNewClientDataDetails(NewClientDataDetailsDto dto)
  110. {
  111. #region 参数验证
  112. if (dto.Id < 0)
  113. return Ok(JsonView(false, "请传入有效的Id参数!"));
  114. if (dto.UserId < 0)
  115. return Ok(JsonView(false, "请传入有效的UserId参数!"));
  116. if (dto.PortType < 0)
  117. return Ok(JsonView(false, "请传入有效的PortType参数!"));
  118. #endregion
  119. JsonView jw = new JsonView();
  120. try
  121. {
  122. Result resultData = await _clientDataRepository._Details(dto.PortType, dto.Id);
  123. if (resultData.Code == 0)
  124. {
  125. #region 客户资料表操作记录
  126. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.Details, dto.UserId, dto.Id, "");
  127. #endregion
  128. jw = JsonView(true, "查询成功!", resultData.Data);
  129. }
  130. else
  131. {
  132. jw = JsonView(false, resultData.Msg);
  133. }
  134. }
  135. catch (Exception)
  136. {
  137. jw = JsonView(false, "程序错误!");
  138. }
  139. return Ok(jw);
  140. }
  141. /// <summary>
  142. /// 客户资料操作(Status:1.新增,2.修改)
  143. /// </summary>
  144. /// <param name="dto"></param>
  145. /// <returns></returns>
  146. [HttpPost]
  147. [ApiLog("Crm_NewClientData", OperationEnum.NoOperation)]
  148. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  149. public async Task<IActionResult> NewClientOp(NewClientOpDto dto)
  150. {
  151. #region 参数验证
  152. if (dto.CreateUserId < 0)
  153. {
  154. return Ok(JsonView(false, "请传入有效的CreateUserId参数!"));
  155. }
  156. if (dto.PortType < 0)
  157. {
  158. return Ok(JsonView(false, "请传入有效的PortType参数!"));
  159. }
  160. #endregion
  161. try
  162. {
  163. Domain.Result result = await _clientDataRepository.NewClientOp(dto);
  164. if (result.Code != 0)
  165. {
  166. return Ok(JsonView(false, result.Msg));
  167. }
  168. #region 客户资料操作记录
  169. //OperationEnum operationEnum = OperationEnum.NoOperation;
  170. //if (dto.Status == 1)
  171. //{
  172. // operationEnum = OperationEnum.Add;
  173. // dto.Id = Convert.ToInt32(result.Data);
  174. //}
  175. //else if (dto.Status == 2) operationEnum = OperationEnum.Edit;
  176. //await GeneralMethod.NewClientOperationRecord(dto.PortType, operationEnum, dto.CreateUserId, dto.Id, "");
  177. #endregion
  178. //this.keyName += "_" + dto.CreateUserId;
  179. //var exists = await RedisFactory.CreateRedisRepository().KeyExistsAsync(keyName);
  180. //if (exists) await RedisFactory.CreateRedisRepository().KeyDeleteAsync(keyName);
  181. return Ok(JsonView(true, result.Msg + "Id:" + dto.Id));
  182. }
  183. catch (Exception ex)
  184. {
  185. return Ok(JsonView(false, "程序错误!Msg:" + ex.Message));
  186. }
  187. }
  188. /// <summary>
  189. /// 新客户资料操作(删除)
  190. /// </summary>
  191. /// <param name="dto"></param>
  192. /// <returns></returns>
  193. [HttpPost]
  194. [ApiLog("Crm_NewClientData", OperationEnum.Del)]
  195. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  196. public async Task<IActionResult> NewClientDel(DelBaseDto dto)
  197. {
  198. #region 参数验证
  199. if (dto.Id < 0)
  200. {
  201. return Ok(JsonView(false, "请传入有效的Id参数!"));
  202. }
  203. if (dto.DeleteUserId < 0)
  204. {
  205. return Ok(JsonView(false, "请传入有效的DeleteUserId参数!"));
  206. }
  207. if (dto.PortType < 0)
  208. {
  209. return Ok(JsonView(false, "请传入有效的PortType参数!"));
  210. }
  211. #endregion
  212. var res = await _clientDataRepository.DelNewClientData(dto);
  213. if (res.Code != 0)
  214. {
  215. return Ok(JsonView(false, "删除失败"));
  216. }
  217. #region 客户资料表操作记录
  218. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.Del, dto.DeleteUserId, dto.Id, "");
  219. #endregion
  220. //this.keyName += "_" + dto.DeleteUserId;
  221. //var exists = await RedisFactory.CreateRedisRepository().KeyExistsAsync(keyName);
  222. //if (exists) await RedisFactory.CreateRedisRepository().KeyDeleteAsync(keyName);
  223. return Ok(JsonView(true, "删除成功!"));
  224. }
  225. /// <summary>
  226. /// 获取下拉列表数据和单条数据信息
  227. /// </summary>
  228. /// <param name="dto"></param>
  229. /// <returns></returns>
  230. [HttpPost]
  231. [ApiLog("Crm_NewClientData", OperationEnum.Details)]
  232. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  233. public async Task<IActionResult> QuerySelectAndSingleData(QuerySingleDto dto)
  234. {
  235. JsonView jw = new JsonView();
  236. var result = await _clientDataRepository.QuerySelectAndSingleData(dto);
  237. if (result.Code == 0)
  238. {
  239. #region 客户资料表操作记录
  240. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.Details, dto.UserId, dto.Id, "");
  241. #endregion
  242. jw = JsonView(true, result.Msg, result.Data);
  243. }
  244. else
  245. {
  246. jw = JsonView(false, result.Msg);
  247. }
  248. return Ok(jw);
  249. }
  250. /// <summary>
  251. /// 获取现有负责人
  252. /// </summary>
  253. /// <returns></returns>
  254. [HttpPost]
  255. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  256. public async Task<IActionResult> QueryUserSelect()
  257. {
  258. Result resTable = _clientDataRepository.QueryUserSelect();
  259. return Ok(JsonView(true, resTable.Msg, resTable.Data));
  260. }
  261. /// <summary>
  262. /// 获取出团数据
  263. /// </summary>
  264. /// <returns></returns>
  265. [HttpPost]
  266. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  267. public async Task<IActionResult> QueryNumberGroups()
  268. {
  269. var result = await _clientDataRepository.QueryNumberGroups();
  270. if (result.Code != 0)
  271. {
  272. return Ok(JsonView(false, result.Msg));
  273. }
  274. return Ok(JsonView(true, result.Msg, result.Data));
  275. }
  276. /// <summary>
  277. /// 新客户资料操作
  278. /// 批量分配
  279. /// </summary>
  280. /// <param name="dto"></param>
  281. /// <returns></returns>
  282. [HttpPost]
  283. [ApiLog("Crm_NewClientData", OperationEnum.BatchAssignment)]
  284. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  285. public async Task<IActionResult> PostBatchAssignment(BatchAssignmentDto dto)
  286. {
  287. #region 参数验证
  288. if (dto.UserId < 0)
  289. {
  290. return Ok(JsonView(false, "请传入有效的UserId参数!"));
  291. }
  292. if (dto.PortType < 0)
  293. {
  294. return Ok(JsonView(false, "请传入有效的PortType参数!"));
  295. }
  296. #endregion
  297. var res = await _clientDataRepository._BatchAssignment(dto);
  298. if (res.Code != 0)
  299. {
  300. return Ok(JsonView(false, res.Msg));
  301. }
  302. return Ok(JsonView(true, "操作成功!"));
  303. }
  304. private Dictionary<int, List<int>> MCRSetting()
  305. {
  306. Dictionary<int, List<int>> keyValuePairs = new Dictionary<int, List<int>>();
  307. keyValuePairs.Add(419, new List<int>() //四川
  308. {
  309. 376,377,378,381,382,387,388,389,390,753,754,1296,1303
  310. });
  311. keyValuePairs.Add(420, new List<int>() //云南
  312. {
  313. 407,408,409,410,449,451,452,453,567,754,1297,1304
  314. });
  315. keyValuePairs.Add(421, new List<int>() { 424, 425, 426, 427, 428, 429, 754,1298, 1305,1307,1306 }); // 贵州
  316. keyValuePairs.Add(422, new List<int>() { 415, 416, 754,1317,1316,1315, 455,1321, 1320, 1319, 1318 }); // 西藏
  317. keyValuePairs.Add(423, new List<int>() { 417, 418, 454, 456, 754, 1313, 1314 }); // 重庆
  318. keyValuePairs.Add(578, new List<int>() { 581, 582, 583, 754,1299,1300 }); // 青海
  319. keyValuePairs.Add(605, new List<int>() { 588, 589, 590, 591, 592, 593, 754,1301,1310,1309,1308 }); // 陕西
  320. keyValuePairs.Add(606, new List<int>() { 597, 598, 599, 600, 601, 602, 603, 604, 754,1324,1323,1322 }); // 宁夏
  321. keyValuePairs.Add(625, new List<int>() { 617, 618, 619, 620, 621, 622, 622, 623, 624, 754,1302,1312,1311 }); // 甘肃
  322. keyValuePairs.Add(634, new List<int>() { 630, 631, 632, 633, 754 }); // 新疆
  323. return keyValuePairs;
  324. }
  325. private Dictionary<int, List<int>> MCRSecondSetting()
  326. {
  327. Dictionary<int, List<int>> keyValuePairs = new Dictionary<int, List<int>>();
  328. // 四川
  329. keyValuePairs.Add(349, new List<int>() { 376, 378, 381, 387, 389, 1296 }); // 四川省级
  330. keyValuePairs.Add(350, new List<int>() { 377, 382, 388, 390, 1303 }); // 成都市级
  331. keyValuePairs.Add(348, new List<int>() { 387 }); // 四川地市州 - Explicitly assigning to ensure all source2 IDs are used
  332. keyValuePairs.Add(701, new List<int>() { 388 }); // 成都区市县
  333. // 云南
  334. keyValuePairs.Add(399, new List<int>() { 407, 408, 409, 410, 451 }); // 云南省级
  335. keyValuePairs.Add(400, new List<int>() { 449, 452, 453, 1297, 1304 }); // 昆明市级
  336. keyValuePairs.Add(450, new List<int>() { 410 }); // 云南地市州
  337. keyValuePairs.Add(566, new List<int>() { 567 }); // 昆明区市县
  338. // 贵州
  339. keyValuePairs.Add(401, new List<int>() { 424, 426, 427, 428, 1298 }); // 贵州省级
  340. keyValuePairs.Add(402, new List<int>() { 425, 429, 1306, 1307, 1305 }); // 贵阳市级
  341. keyValuePairs.Add(414, new List<int>() { 428 }); // 贵州地市州
  342. //keyValuePairs.Add(1305, new List<int>() { /* Add relevant IDs if available */ }); // 贵阳区市县 - Placeholder for now
  343. // 重庆
  344. keyValuePairs.Add(403, new List<int>() { 417, 418, 454, 456, 1314 }); // 重庆市级
  345. keyValuePairs.Add(404, new List<int>() { 1313 }); // 重庆区县 - No direct match in source1
  346. // 西藏
  347. keyValuePairs.Add(405, new List<int>() { 415, 1317, 1316, 1315 }); // 西藏自治区
  348. keyValuePairs.Add(406, new List<int>() { 455, 1321, 1320, 1319, 1318 }); // 拉萨市级
  349. keyValuePairs.Add(413, new List<int>() { 416 }); // 西藏地市州
  350. // 青海
  351. keyValuePairs.Add(579, new List<int>() { 581, 582, 583, 1300 }); // 青海省级
  352. keyValuePairs.Add(580, new List<int>() { 1299 }); // 青海市州县 (Includes 地市州)
  353. // 陕西
  354. keyValuePairs.Add(585, new List<int>() { 588, 589, 590, 591, 1301 }); // 陕西省级
  355. keyValuePairs.Add(586, new List<int>() { 589 }); // 陕西地市州
  356. keyValuePairs.Add(587, new List<int>() { 592, 593, 1309, 1310 , 1308 }); // 西安市级
  357. //keyValuePairs.Add(1308, new List<int>() { /* Add relevant IDs if available */ }); // 西安区市县 - Placeholder
  358. // 宁夏
  359. keyValuePairs.Add(594, new List<int>() { 597, 598, 599, 600, 601, 1322 }); // 宁夏自治区 (Includes 地市州 and 区级)
  360. keyValuePairs.Add(595, new List<int>() { 597 }); // 宁夏地市州
  361. keyValuePairs.Add(596, new List<int>() { 598, 599, 600, 603, 604, 602, 1323, 1324 }); // 银川市级 (Includes 区级)
  362. //keyValuePairs.Add(602, new List<int>()); // 银川区市县 - No direct match, but could be considered covered by "区级"
  363. // 甘肃
  364. keyValuePairs.Add(614, new List<int>() { 617, 618, 619, 620, 621, 1302 }); // 甘肃省级
  365. keyValuePairs.Add(615, new List<int>() { 618 }); // 甘肃地市州
  366. keyValuePairs.Add(616, new List<int>() { 622, 623, 624, 1312, 1311 }); // 兰州市级
  367. //keyValuePairs.Add(1311, new List<int>() { /* Add relevant IDs if available */ }); // 兰州区市县 - Placeholder
  368. // 新疆
  369. keyValuePairs.Add(627, new List<int>() { 630, 631, 632 , 1327,1326 ,1325 }); // 新疆自治区级
  370. keyValuePairs.Add(628, new List<int>() { 1326 }); // 新疆地市州 - No direct match
  371. keyValuePairs.Add(629, new List<int>() { 633,1331,1330,1329 ,1328 }); // 乌鲁木齐市级
  372. // 中央直属企业 (Special case)
  373. keyValuePairs.Add(351, new List<int>() { 754 }); // Using "未分级" for 中央直属企业
  374. return keyValuePairs;
  375. }
  376. private Dictionary<int, List<int>> MCRLvSetting()
  377. {
  378. var keyValuePairs = new Dictionary<int, List<int>>();
  379. // 四川 (419)
  380. keyValuePairs.Add(419, new List<int>() { 348, 349, 350, 701 }); // Includes all Sichuan-related IDs from source2
  381. // 云南 (420)
  382. keyValuePairs.Add(420, new List<int>() { 399, 400, 450, 566 }); // Includes all Yunnan-related IDs
  383. // 贵州 (421)
  384. keyValuePairs.Add(421, new List<int>() { 401, 402, 414 });
  385. // 西藏 (422)
  386. keyValuePairs.Add(422, new List<int>() { 405, 406, 413 });
  387. // 重庆 (423)
  388. keyValuePairs.Add(423, new List<int>() { 403, 404 });
  389. // 青海 (578)
  390. keyValuePairs.Add(578, new List<int>() { 579, 580, 626 }); // Includes 市州县 and 西宁市级
  391. // 陕西 (605)
  392. keyValuePairs.Add(605, new List<int>() { 585, 586, 587 });
  393. // 宁夏 (606)
  394. keyValuePairs.Add(606, new List<int>() { 594, 595, 596 });
  395. // 甘肃 (625)
  396. keyValuePairs.Add(625, new List<int>() { 614, 615, 616 });
  397. // 新疆 (634)
  398. keyValuePairs.Add(634, new List<int>() { 627, 628, 629 });
  399. // 未分级 (351) - You'll likely want to remove this as it's no longer a primary key.
  400. // keyValuePairs.Add(351, new List<int>()); //Remove this line.
  401. return keyValuePairs;
  402. }
  403. [HttpPost]
  404. public IActionResult QueryClientType(QueryClientTypeDto Dto)
  405. {
  406. var jw = JsonView(true,"获取成功!");
  407. var dic_lv = MCRLvSetting();
  408. var keyValuePairs = MCRSetting();
  409. ArrayList arr = new ArrayList();
  410. ArrayList lvArr = new ArrayList();
  411. var ids = new List<int>();
  412. var lvids = new List<int>();
  413. foreach (var item in Dto.SetDataIdArr)
  414. {
  415. if (keyValuePairs.Keys.Contains(item))
  416. {
  417. ids.AddRange(keyValuePairs[item]);
  418. }
  419. if (dic_lv.Keys.Contains(item))
  420. {
  421. lvids.AddRange(dic_lv[item]);
  422. }
  423. }
  424. arr.AddRange(_sqlSugar.Queryable<Sys_SetData>()
  425. .Where(u => ids.Contains(u.Id) && u.IsDel == 0)
  426. .Select(x => new { x.Id, x.Name , x.Remark })
  427. .ToList());
  428. if (arr.Count == 0)
  429. {
  430. arr.AddRange(_sqlSugar.Queryable<Sys_SetData>()
  431. .Where(u => u.STid == 37 && u.IsDel == 0)
  432. .Select(x => new { x.Id, x.Name, x.Remark }).ToList());
  433. }
  434. // 创建比较器实例
  435. IComparer remakeComparer = new RemakeComparer();
  436. // 使用ArrayList.Sort方法和自定义比较器对arr进行排序
  437. arr.Sort(remakeComparer);
  438. var rangelv = _sqlSugar.Queryable<Sys_SetData>()
  439. .Where(u => lvids.Contains(u.Id) && u.IsDel == 0)
  440. .Select(x => new { x.Id, x.Name })
  441. .ToList();
  442. lvArr.AddRange(rangelv);
  443. if (lvArr.Count == 0)
  444. {
  445. lvArr.AddRange(_sqlSugar.Queryable<Sys_SetData>()
  446. .Where(u => u.STid == 33 && u.IsDel == 0)
  447. .Select(x => new { x.Id, x.Name}).ToList());
  448. }
  449. jw.Data = new
  450. {
  451. TypeArr = arr,
  452. LvArr = lvArr,
  453. };
  454. return Ok(jw);
  455. }
  456. [HttpPost]
  457. public IActionResult QueryClientTypeSecond(QueryClientTypeDto Dto)
  458. {
  459. var jw = JsonView(true, "获取成功!");
  460. var keyValuePairs = MCRSecondSetting();
  461. ArrayList arr = new ArrayList();
  462. var ids = new List<int>();
  463. foreach (var item in Dto.SetDataIdArr)
  464. {
  465. if (keyValuePairs.Keys.Contains(item))
  466. {
  467. ids.AddRange(keyValuePairs[item]);
  468. }
  469. }
  470. arr.AddRange(_sqlSugar.Queryable<Sys_SetData>()
  471. .Where(u => ids.Contains(u.Id) && u.IsDel == 0)
  472. .Select(x => new { x.Id, x.Name, x.Remark })
  473. .ToList());
  474. if (arr.Count == 0)
  475. {
  476. arr.AddRange(_sqlSugar.Queryable<Sys_SetData>()
  477. .Where(u => u.STid == 37 && u.IsDel == 0)
  478. .Select(x => new { x.Id, x.Name, x.Remark }).ToList());
  479. }
  480. // 创建比较器实例
  481. IComparer remakeComparer = new RemakeComparer();
  482. // 使用ArrayList.Sort方法和自定义比较器对arr进行排序
  483. arr.Sort(remakeComparer);
  484. jw.Data = arr;
  485. return Ok(jw);
  486. }
  487. /// <summary>
  488. /// 客户资料数据 全信息导出 excel 下载
  489. /// </summary>
  490. /// <param name="dto"></param>
  491. /// <returns></returns>
  492. [HttpPost]
  493. [ApiLog("Crm_NewClientData", OperationEnum.Download)]
  494. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  495. public async Task<IActionResult> NewClientDataExcelDownload(NewClientDataExcelDownloadDto dto)
  496. {
  497. #region 参数验证
  498. if (dto.OperationUserId < 0) return Ok(JsonView(false, "请传入有效的OperationUserId参数!"));
  499. if (dto.PortType < 0) return Ok(JsonView(false, "请传入有效的PortType参数!"));
  500. if (dto.PageId < 0) return Ok(JsonView(false, "请传入有效的PageId参数!"));
  501. #endregion
  502. #region 页面操作权限验证
  503. var pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.OperationUserId, dto.PageId);
  504. if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您没有文件下载权!"));
  505. #endregion
  506. var dt = await _clientDataRepository.NewClientDataExcelDownload(dto);
  507. if (dt != null)
  508. {
  509. string tempPath = (AppSettingsHelper.Get("ExcelBasePath") + "Template/公司客户资料导出模板.xlsx");
  510. var designer = new WorkbookDesigner();
  511. designer.Workbook = new Workbook(tempPath);
  512. designer.SetDataSource("NCDDT", dt);
  513. designer.Process();
  514. //文件名
  515. string fileName = $"公司客户资料(全信息导出){DateTime.Now.ToString("yyyyMMddHHmmss")}.xls";
  516. designer.Workbook.Save(AppSettingsHelper.Get("ExcelBasePath") + "NewClientDataExcelDownload/" + fileName);
  517. string url = AppSettingsHelper.Get("ExcelBaseUrl") + "Office/Excel/NewClientDataExcelDownload/" + fileName;
  518. #region 客户资料表操作记录
  519. var respose = JsonView(true, "成功", url);
  520. //var paramData = new
  521. //{
  522. // APIName = @"MarketCustomerResources/NewClientDataExcelDownload",
  523. // RequestParam = dto,
  524. // ResposeParam = respose
  525. //};
  526. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.Download, dto.OperationUserId, 0, JsonConvert.SerializeObject(paramData));
  527. #endregion
  528. return Ok(respose);
  529. }
  530. return Ok(JsonView(false));
  531. }
  532. /// <summary>
  533. /// 客户资料数据 分权限导出 excel 下载
  534. /// </summary>
  535. /// <param name="dto"></param>
  536. /// <returns></returns>
  537. [HttpPost]
  538. [ApiLog("Crm_NewClientData", OperationEnum.Download)]
  539. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  540. public async Task<IActionResult> NewClientDataAuthorityExcelDownload(NewClientDataExcelDownloadDto dto)
  541. {
  542. #region 参数验证
  543. if (dto.OperationUserId < 0) return Ok(JsonView(false, "请传入有效的OperationUserId参数!"));
  544. if (dto.PortType < 0) return Ok(JsonView(false, "请传入有效的PortType参数!"));
  545. if (dto.PageId < 0) return Ok(JsonView(false, "请传入有效的PageId参数!"));
  546. #endregion
  547. #region 页面操作权限验证
  548. var pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.OperationUserId, dto.PageId);
  549. if (pageFunAuthView.FilesDownloadAuth == 0) return Ok(JsonView(false, "您没有文件下载权!"));
  550. #endregion
  551. var dt = await _clientDataRepository.NewClientDataExcelDownload(dto);
  552. if (dt != null)
  553. {
  554. string tempPath = (AppSettingsHelper.Get("ExcelBasePath") + "Template/公司客户资料分权限导出模板.xlsx");
  555. var designer = new WorkbookDesigner();
  556. designer.Workbook = new Workbook(tempPath);
  557. designer.SetDataSource("NCDDT", dt);
  558. designer.Process();
  559. //文件名
  560. string fileName = $"公司客户资料(分权限导出){DateTime.Now.ToString("yyyyMMddHHmmss")}.xls";
  561. designer.Workbook.Save(AppSettingsHelper.Get("ExcelBasePath") + "NewClientDataExcelDownload/" + fileName);
  562. string url = AppSettingsHelper.Get("ExcelBaseUrl") + "Office/Excel/NewClientDataExcelDownload/" + fileName;
  563. #region 客户资料表操作记录
  564. var respose = JsonView(true, "成功", url);
  565. //var paramData = new
  566. //{
  567. // APIName = @"MarketCustomerResources/NewClientDataExcelDownload",
  568. // RequestParam = dto,
  569. // ResposeParam = respose
  570. //};
  571. //await GeneralMethod.NewClientOperationRecord(dto.PortType, OperationEnum.Download, dto.OperationUserId, 0, JsonConvert.SerializeObject(paramData));
  572. #endregion
  573. return Ok(respose);
  574. }
  575. return Ok(JsonView(false));
  576. }
  577. /// <summary>
  578. /// 客户资料数据 历史记录 Init
  579. /// </summary>
  580. /// <param name="dto"></param>
  581. /// <returns></returns>
  582. [HttpPost]
  583. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  584. public async Task<IActionResult> NewClientDataRecordInit(NewClientDataRecordInitDto dto)
  585. {
  586. #region 参数验证
  587. if (dto.UserId < 0) return Ok(JsonView(false, MsgTips.UserId));
  588. if (!SharingStaticData.PortTypes.Contains(dto.PortType)) return Ok(JsonView(false, MsgTips.Port));
  589. if (dto.PageId < 0) return Ok(JsonView(false, MsgTips.PageId));
  590. #endregion
  591. #region 页面操作权限验证
  592. var pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  593. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  594. #endregion
  595. var enumfiltrates = new string[] { "NoOperation", "Audit", "Login" };
  596. var operations = EnumHelper.GetEnumDescriptions(typeof(OperationEnum), enumfiltrates);
  597. var operation1 = new List<dynamic>();
  598. foreach (var item in operations)
  599. {
  600. operation1.Add(new { value = item.Key, text = item.Value });
  601. }
  602. object userDatas = Array.Empty<object>();
  603. if (dto.UserId == 21)
  604. {
  605. var userIds = await _sqlSugar.Queryable<Crm_ClientDataAndUser>().Where(x => x.IsDel == 0).Select(x => x.usersId).Distinct().ToListAsync();
  606. if (userIds.Any())
  607. {
  608. userDatas = await _sqlSugar.Queryable<Sys_Users>().Where(x => x.IsDel == 0 && userIds.Contains(x.Id)).Select(x => new { value = x.Id, text = x.CnName }).ToListAsync();
  609. }
  610. }
  611. var data = new {
  612. operations = operation1,
  613. userDatas = userDatas
  614. };
  615. return Ok(JsonView(data));
  616. }
  617. /// <summary>
  618. /// 客户资料数据 历史记录
  619. /// </summary>
  620. /// <param name="dto"></param>
  621. /// <returns></returns>
  622. [HttpPost]
  623. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  624. public async Task<IActionResult> NewClientDataRecord(NewClientDataRecordDto dto)
  625. {
  626. #region 参数验证
  627. if (dto.UserId < 0) return Ok(JsonView(false, MsgTips.UserId));
  628. if (!SharingStaticData.PortTypes.Contains(dto.PortType)) return Ok(JsonView(false, MsgTips.Port));
  629. if (dto.PageId < 0) return Ok(JsonView(false, MsgTips.PageId));
  630. #endregion
  631. #region 页面操作权限验证
  632. var pageFunAuthView = await GeneralMethod.PostUserPageFuncDatas(dto.UserId, dto.PageId);
  633. if (pageFunAuthView.CheckAuth == 0) return Ok(JsonView(false, "您没有查看权限!"));
  634. #endregion
  635. return Ok(await _clientDataRepository.NewClientDataRecord(dto));
  636. }
  637. #region 修改数据
  638. //[HttpPost]
  639. //public IActionResult SynchronizationData()
  640. //{
  641. // var keyValuePairs = new Dictionary<int, List<string>>
  642. // {
  643. // { 5, new List<string> { "省级部门", "省级单位" } },
  644. // { 10, new List<string> { "市州" } },
  645. // { 15, new List<string> { "省属国企" } },
  646. // { 20, new List<string> { "省属学校", "省属高校" } },
  647. // { 25, new List<string> { "省级行业协会", "省级社团", "省级联合会" , "省属行业协会", "民营企业", "地方国企" } },
  648. // { 30, new List<string> { "市级部门", "市级单位" } },
  649. // { 35, new List<string> { "区市县" } },
  650. // { 40, new List<string> { "市级国企", "市属国企" } },
  651. // { 45, new List<string> { "市属学校", "市属高校" } },
  652. // { 50, new List<string> { "市级行业协会", "市级社团", "市级联合会" } }
  653. // };
  654. // var setting = MCRSetting();
  655. // var arr = new List<List<Sys_SetData>>();
  656. // foreach (var item in setting.Keys)
  657. // {
  658. // var setDataList_DB = _sqlSugar.Queryable<Sys_SetData>()
  659. // .Where(x => x.IsDel == 0 && setting[item].Contains(x.Id))
  660. // .ToList();
  661. // foreach (var setData in setDataList_DB)
  662. // {
  663. // foreach (var lv in keyValuePairs.Keys)
  664. // {
  665. // var islv = keyValuePairs[lv].Where(x => setData.Name.Contains(x)).Count() > 0;
  666. // if (islv)
  667. // {
  668. // setData.Remark = lv.ToString();
  669. // }
  670. // }
  671. // }
  672. // arr.Add(setDataList_DB);
  673. // }
  674. // _sqlSugar.Updateable(arr.SelectMany(x => x).ToList()).UpdateColumns(x => new
  675. // {
  676. // x.Remark
  677. // }).ExecuteCommand();
  678. // return Ok(arr);
  679. //}
  680. [HttpPost]
  681. public IActionResult QueryData()
  682. {
  683. var db = _sqlSugar.Queryable<Crm_NewClientData>()
  684. .Where(x => x.IsDel == 0)
  685. .Select(x => new Crm_NewClientData
  686. {
  687. Id = x.Id,
  688. Client = x.Client,
  689. Category = x.Category,
  690. Location = x.Location,
  691. }).ToList();
  692. var count = 0;
  693. var updateid = new List<int>();
  694. foreach (var item in db)
  695. {
  696. EncryptionProcessor.DecryptProperties(item);
  697. if (!string.IsNullOrWhiteSpace(item.Location) && item.Location.Contains("重庆") && item.Category == 0)
  698. {
  699. count++;
  700. //if (!string.IsNullOrWhiteSpace(item.Client) && (item.Client.Contains("大学") || item.Client.Contains("学院")))
  701. {
  702. updateid.Add(item.Id);
  703. }
  704. }
  705. }
  706. var updateCount = _sqlSugar.Updateable<Crm_NewClientData>().Where(x => updateid.Contains(x.Id))
  707. .SetColumns(x => new Crm_NewClientData { Category = 456 }).ExecuteCommand();
  708. return Ok( new
  709. {
  710. notCount = count,
  711. updateCount = updateCount
  712. });
  713. }
  714. [HttpPost]
  715. public IActionResult InsertData()
  716. {
  717. string sql = $@"SELECT * FROM [dbo].[Crm_NewClientData] WHERE ID IN (
  718. --所有四川省域的
  719. select Id from [dbo].[Crm_NewClientData] where ISDEL = 0 AND Lvlid IN (
  720. select S.Id from Sys_SetData S
  721. where STid = 33 and isdel = 0 and
  722. (Name like '%四%川%' or Name like '%成%都%')
  723. )
  724. ) AND IsDel = 0
  725. AND ID IN (
  726. SELECT NewClientDataId FROM [dbo].[Crm_ClientDataAndUser]
  727. WHERE NewClientDataId IN (
  728. --所有单独数据
  729. SELECT NewClientDataId FROM [dbo].[Crm_ClientDataAndUser]
  730. WHERE ISDEL = 0
  731. GROUP BY NewClientDataId
  732. HAVING COUNT(NewClientDataId) = 1
  733. ) AND IsDel = 0 AND UsersId = 21
  734. )";
  735. var clientList = _sqlSugar.SqlQueryable<Crm_NewClientData>(sql).Select(x => x.Id).ToList().Select(x => new Crm_ClientDataAndUser
  736. {
  737. NewClientDataId = x,
  738. usersId = 330,
  739. CreateTime = DateTime.Now,
  740. CreateUserId = 235,
  741. IsDel = 0,
  742. }).ToList();
  743. var insertCount = _sqlSugar.Insertable(clientList).ExecuteCommand();
  744. return Ok(insertCount);
  745. }
  746. [HttpPost]
  747. public IActionResult ExportData()
  748. {
  749. var soure = _sqlSugar.Queryable<Crm_NewClientData>()
  750. .InnerJoin<Crm_ClientDataAndUser>((a, b) => b.NewClientDataId == a.Id && b.IsDel == 0)
  751. .Where((a, b) => a.IsDel == 0 && b.usersId == 95)
  752. .Select((a, b) => a)
  753. .ToList();
  754. foreach (var item in soure)
  755. {
  756. EncryptionProcessor.DecryptProperties(item);
  757. }
  758. // 创建WorkbookDesigner对象
  759. WorkbookDesigner designer = new WorkbookDesigner();
  760. // 加载模板文件(包含智能标记)
  761. designer.Workbook = new Workbook("C:\\Users\\PC\\Desktop\\111.xlsx");
  762. // 设置数据源,这里假设你的List集合名为listData
  763. designer.SetDataSource("ListData", soure);
  764. // 处理智能标记以将数据填充到工作表中
  765. designer.Process();
  766. // 保存Excel文件
  767. designer.Workbook.Save("C:\\Users\\PC\\Desktop\\111000.xlsx");
  768. return Ok(1);
  769. }
  770. [HttpPost]
  771. public IActionResult DeleteData()
  772. {
  773. var soure = _sqlSugar.Queryable<Crm_NewClientData>()
  774. .InnerJoin<Crm_ClientDataAndUser>((a, b) => b.NewClientDataId == a.Id && b.IsDel == 0)
  775. .Where((a, b) => a.IsDel == 0 && b.usersId == 330)
  776. .Select((a, b) => b.Id)
  777. .ToList();
  778. var count = _sqlSugar.Updateable<Crm_ClientDataAndUser>()
  779. .Where(u => soure.Contains(u.Id) && u.IsDel == 0)
  780. .SetColumns(x => new Crm_ClientDataAndUser
  781. {
  782. DeleteTime = DateTime.Now.ToString(),
  783. DeleteUserId = 235,
  784. IsDel = 1
  785. }).ExecuteCommand();
  786. return Ok(count);
  787. }
  788. [HttpPost]
  789. public IActionResult ReassignCustomers()
  790. {
  791. var user_Client = _sqlSugar.Queryable<Crm_ClientDataAndUser>()
  792. .Where(x => x.usersId == 302 && x.IsDel == 0)
  793. .Select(x=>new
  794. {
  795. x.Id,
  796. x.NewClientDataId
  797. })
  798. .ToList();
  799. var ids = user_Client.Select(x=>x.NewClientDataId).ToList();
  800. string setDataSql = $"select * from Sys_SetData where STid = 33 and isdel = 0 and (Name like '%重庆%') ";
  801. var setDataids = _sqlSugar.SqlQueryable<Sys_SetData>(setDataSql).Select(x => x.Id).ToList();
  802. var clients = _sqlSugar.Queryable<Crm_NewClientData>().Where(x => ids.Contains(x.Id) && setDataids.Contains(x.Lvlid) && x.IsDel == 0).ToList();
  803. var clients_ids = clients.Select(x=>x.Id).ToList();
  804. int updateCount = 0;
  805. _sqlSugar.BeginTran();
  806. if (clients.Count == 223)
  807. {
  808. updateCount = _sqlSugar.Updateable<Crm_ClientDataAndUser>()
  809. .Where(x => x.usersId == 302 && clients_ids.Contains(x.NewClientDataId) && x.IsDel == 0)
  810. .SetColumns( x => new Crm_ClientDataAndUser
  811. {
  812. usersId = 21
  813. })
  814. .ExecuteCommand();
  815. }
  816. if (updateCount == clients.Count)
  817. {
  818. _sqlSugar.CommitTran();
  819. }
  820. else
  821. {
  822. _sqlSugar.RollbackTran();
  823. }
  824. return Ok( new
  825. {
  826. count = clients.Count,
  827. updateCount,
  828. });
  829. }
  830. [HttpPost]
  831. public IActionResult InsertDataJiang()
  832. {
  833. var list_DB = _sqlSugar.Queryable<Crm_NewClientData>().Where(x => x.IsDel == 0).ToList();
  834. foreach (var item in list_DB)
  835. {
  836. EncryptionProcessor.DecryptProperties(item);
  837. }
  838. list_DB = list_DB.Where(x => !string.IsNullOrWhiteSpace(x.Client) &&(x.Client.Contains("学院") || x.Client.Contains("大学"))).ToList();
  839. var arr = list_DB.Select(x => x.Id).ToList().Select(x => new Crm_ClientDataAndUser
  840. {
  841. NewClientDataId = x,
  842. usersId = 327,
  843. CreateTime = DateTime.Now,
  844. CreateUserId = 235,
  845. IsDel = 0,
  846. }).ToList();
  847. var insertCount = _sqlSugar.Insertable(arr).ExecuteCommand();
  848. return Ok(insertCount);
  849. }
  850. [HttpPost]
  851. public IActionResult InsertDataChen()
  852. {
  853. string sql = @"SELECT * FROM Crm_NewClientData cncd WHERE IsDel = 0
  854. AND Lvlid in (
  855. select Id from Sys_SetData where STid = 33 and isdel = 0
  856. and (Name like '%重庆%')
  857. )";
  858. var list = _sqlSugar.SqlQueryable<Crm_NewClientData>(sql).Select(x => x.Id).ToList();
  859. var toUserList = new List<Crm_ClientDataAndUser>();
  860. foreach (var item in list)
  861. {
  862. toUserList.Add(new Crm_ClientDataAndUser
  863. {
  864. CreateTime = DateTime.Now,
  865. CreateUserId = 235,
  866. NewClientDataId = item,
  867. usersId = 359,
  868. IsDel = 0,
  869. });
  870. }
  871. var updateCount = 0;
  872. if (toUserList.Count == 259)
  873. {
  874. updateCount = _sqlSugar.Insertable(toUserList).ExecuteCommand();
  875. }
  876. return Ok(new
  877. {
  878. updateCount
  879. });
  880. }
  881. #endregion
  882. /// <summary>
  883. /// 客户资料 操作记录记录查询
  884. /// </summary>
  885. /// <param name="userId"></param>
  886. /// <returns></returns>
  887. [HttpGet]
  888. [ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
  889. public async Task<IActionResult> NewClientDataOperatingRrecord(int userId)
  890. {
  891. var datas = await _sqlSugar.Queryable<Crm_TableOperationRecord, Crm_NewClientData, Sys_Users>((tor, ncd, u) =>
  892. new JoinQueryInfos(
  893. JoinType.Left, tor.DataId == ncd.Id,
  894. JoinType.Left, tor.CreateUserId == u.Id
  895. ))
  896. .Where((tor, ncd, u) => tor.TableName == "Crm_NewClientData" && tor.CreateUserId == userId && (int)tor.OperationItem > 1)
  897. .Select((tor, ncd, u) => new
  898. {
  899. tor.PortType,
  900. tor.OperationItem,
  901. tor.DataId,
  902. ncd.Client,
  903. u.CnName,
  904. tor.CreateTime
  905. }).ToListAsync();
  906. var view = new List<dynamic>();
  907. if (datas.Any())
  908. {
  909. datas = datas.OrderByDescending(x => x.CreateTime).ToList();
  910. foreach (var item in datas)
  911. {
  912. var text = item.OperationItem.GetDescription();
  913. view.Add(new
  914. {
  915. Client = AesEncryptionHelper.Decrypt(item.Client),
  916. item.PortType,
  917. item.OperationItem,
  918. text = text,
  919. item.DataId,
  920. item.CnName,
  921. item.CreateTime
  922. });
  923. }
  924. }
  925. return Ok(JsonView(view));
  926. }
  927. [HttpPost]
  928. public async Task<IActionResult> SearchClientByKeyword(SearchClientByKeywordDto dto)
  929. {
  930. var jw = JsonView(true);
  931. var expression = Expressionable.Create<Crm_NewClientData>()
  932. .And(x=>x.IsDel == 0);
  933. this.keyName += "_" + dto.UserId;
  934. //获取个人的客户
  935. if (dto.UserId != 21)
  936. {
  937. var userList = _clientDataRepository.GetNewExistClient(dto.UserId).Select(x=>x.Id);
  938. var newClientData = _sqlSugar.Queryable<Crm_ClientDataAndUser>()
  939. .Where(x => x.IsDel == 0 && userList.Contains(x.usersId))
  940. .Select(x=>x.NewClientDataId)
  941. .Distinct()
  942. .ToList();
  943. expression = expression.And(x=> newClientData.Contains(x.Id));
  944. }
  945. var exists = false;
  946. //var exists = await RedisFactory.CreateRedisRepository().KeyExistsAsync(keyName);
  947. //if (exists) exists = await RedisFactory.CreateRedisRepository().HashFieldExistAsync(keyName, dto.Keyword);
  948. if (!exists)
  949. {
  950. string field = "Id,Client";
  951. var newClitnData = _sqlSugar.Queryable<Crm_NewClientData>()
  952. .Where(expression.ToExpression())
  953. .Select(field)
  954. .ToList();
  955. foreach (var item in newClitnData)
  956. {
  957. EncryptionProcessor.DecryptProperties(item);
  958. }
  959. var keywordArray = dto.Keyword.ToCharArray();
  960. var matches = newClitnData
  961. .Where(fullString => !string.IsNullOrWhiteSpace(fullString.Client) &&
  962. keywordArray.All(keyword => fullString.Client.Contains(keyword)))
  963. .Select(x=> new
  964. {
  965. x.Client,
  966. x.Id
  967. })
  968. .DistinctBy(x=>x.Client)
  969. .ToList();
  970. if (matches.Any())
  971. {
  972. //await RedisFactory.CreateRedisRepository().HashSetAsync(keyName, dto.Keyword, matches);
  973. //await RedisFactory.CreateRedisRepository().KeyExpireInAsync(keyName, new TimeSpan(0,1,0));
  974. jw.Data = matches;
  975. }
  976. else
  977. {
  978. jw.Code = 201;
  979. jw.Msg = "empty list";
  980. jw.Data = new List<string>(1);
  981. }
  982. }
  983. else
  984. {
  985. jw.Data = await RedisFactory.CreateRedisRepository().HashGetAsync<List<string>>(keyName, dto.Keyword);
  986. }
  987. return Ok(jw);
  988. }
  989. }
  990. }