足力健后端,使用.netcore版本,合并1个项目使用

TaskManagementController.cs 31KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Common;
  4. using System.Common.Helpers;
  5. using System.Data;
  6. using System.IRepositories;
  7. using System.Linq;
  8. using System.Model;
  9. using System.Security.Claims;
  10. using System.Threading.Tasks;
  11. using Microsoft.AspNetCore.Mvc;
  12. using SqlSugar;
  13. using TVShoppingCallCenter_ZLJ.Models.Inputs;
  14. namespace TVShoppingCallCenter_ZLJ.Controllers.TaskManagement
  15. {
  16. [Produces("application/json")]
  17. [Route("api/[controller]")]
  18. public class TaskManagementController : BaseController
  19. {
  20. private readonly ISMS_InternalMessagesReposytory _sys_internalMessagesrepository;
  21. private readonly ISys_UserAccountRepository _sys_useraccountRepository;
  22. private readonly ISys_TaskManagementRepository _sys_taskmanagement_Repository;
  23. private readonly ISys_DepartmentRepository _sys_departmentRepository;
  24. public TaskManagementController(ISys_TaskManagementRepository sys_taskmanagement_Repository, ISys_DepartmentRepository sys_departmentRepository,
  25. ISys_UserAccountRepository sys_useraccountRepository, ISMS_InternalMessagesReposytory sys_internalMessagesrepository)
  26. {
  27. _sys_taskmanagement_Repository = sys_taskmanagement_Repository;
  28. _sys_departmentRepository = sys_departmentRepository;
  29. _sys_useraccountRepository = sys_useraccountRepository;
  30. _sys_internalMessagesrepository = sys_internalMessagesrepository;
  31. }
  32. /// <summary>
  33. /// 添加任务
  34. /// </summary>
  35. /// <param name="input"></param>
  36. /// <returns></returns>
  37. [HttpPost("add")]
  38. public async Task<IActionResult> AddAsync(T_Sys_TaskManagement input)
  39. {
  40. if (string.IsNullOrEmpty(input.F_Name))
  41. return Error("请输入任务名称");
  42. if (string.IsNullOrEmpty(input.F_Content))
  43. return Error("请输入任务内容");
  44. if (input.F_StartTime == null)
  45. return Error("请选择任务开始时间");
  46. if (input.F_EndTime == null)
  47. return Error("请选择任务结束时间");
  48. if (input.F_Type < 0)
  49. return Error("请选择任务类型");
  50. if (string .IsNullOrEmpty (input .F_Deptid ))
  51. return Error("请选择任务部门");
  52. if (input.F_Money < 0)
  53. return Error("请输入目标金额");
  54. // string user = "8000";
  55. if (input.F_Remindertime == null)
  56. input.F_Remindertime = input.F_EndTime.Value.AddDays(-3);
  57. if (input.F_Currentamount > 0)
  58. input.F_Taskprogress = string.Format("{0:f2}", input.F_Currentamount / input.F_Money * 100);
  59. else
  60. input.F_Taskprogress = "0";
  61. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  62. input.F_CreateTime = DateTime.Now;
  63. input.F_CreateUser = user;
  64. input.F_IsDelete = 0;
  65. var res = await _sys_taskmanagement_Repository.Add(input);
  66. if (res > 0)
  67. {
  68. try
  69. {
  70. DateTime time = DateTime.Parse(input.F_Remindertime.ToString());
  71. if (input .F_Tasker >0)
  72. {
  73. string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
  74. bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, "任务提醒", input.F_Name + "任务提醒", user, time, 2, 1, 0, usercode, 1);
  75. }
  76. else
  77. {
  78. bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(res, "任务提醒", input.F_Name + "任务提醒", user, time, 2, 1, int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]), "", 0);
  79. }
  80. }
  81. catch
  82. {
  83. }
  84. return Success("添加成功");
  85. }
  86. else
  87. {
  88. return Error("添加失败");
  89. }
  90. }
  91. /// <summary>
  92. /// 修改任务
  93. /// </summary>
  94. [HttpPost("update")]
  95. public async Task<IActionResult> UpdateAsync(T_Sys_TaskManagement input)
  96. {
  97. if (input.F_ID <= 0)
  98. return Error("参数错误");
  99. if (string.IsNullOrEmpty(input.F_Name))
  100. return Error("请输入任务名称");
  101. if (string.IsNullOrEmpty(input.F_Content))
  102. return Error("请输入任务内容");
  103. if (input.F_StartTime == null)
  104. return Error("请选择任务开始时间");
  105. if (input.F_EndTime == null)
  106. return Error("请选择任务结束时间");
  107. if (input.F_Type < 0)
  108. return Error("请选择任务类型");
  109. if (string.IsNullOrEmpty(input.F_Deptid))
  110. return Error("请选择任务部门");
  111. if (input.F_Money < 0)
  112. return Error("请输入目标金额");
  113. var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == input.F_ID);
  114. if (model == null)
  115. return Error("操作失败");
  116. if (input.F_Remindertime == null)
  117. input.F_Remindertime = input.F_EndTime.Value.AddDays(-3);
  118. if (input.F_Currentamount > 0)
  119. input.F_Taskprogress = string.Format("{0:f2}", input.F_Currentamount / input.F_Money * 100);
  120. else
  121. input.F_Taskprogress = "0";
  122. // string user = "8000";
  123. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  124. input.F_IsDelete = 0;
  125. input.F_CreateUser = model.F_CreateUser;
  126. input.F_CreateTime = model.F_CreateTime ;
  127. input.F_UpdateTime = DateTime.Now;
  128. input.F_UpdateUser = user;
  129. // model.F_UpdateUser = "8000";
  130. var b = await _sys_taskmanagement_Repository.Update(input);
  131. if (b)
  132. {
  133. DateTime time = DateTime.Parse(input.F_Remindertime.ToString());
  134. var InternalMessages = _sys_internalMessagesrepository.GetListALL (x => x.F_ID == model.F_ID&&x.SMS_IsDelete ==0).Result.FirstOrDefault ();
  135. if (InternalMessages!=null )
  136. {
  137. try
  138. {
  139. if (input.F_Tasker > 0)
  140. {
  141. string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
  142. InternalMessages.SMS_Content = input.F_Name + "任务提醒";
  143. InternalMessages.SMS_Remindertime = input.F_Remindertime;
  144. InternalMessages.SMS_ReceiveUserCode = usercode;
  145. bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
  146. }
  147. else
  148. {
  149. InternalMessages.SMS_Content = input.F_Name + "任务提醒";
  150. InternalMessages.SMS_Remindertime = input.F_Remindertime;
  151. InternalMessages.SMS_Deptid = int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]);
  152. bool n = await _sys_internalMessagesrepository.Update(InternalMessages);
  153. }
  154. }
  155. catch
  156. {
  157. }
  158. }
  159. else
  160. {
  161. try
  162. {
  163. if (input.F_Tasker > 0)
  164. {
  165. string usercode = _sys_useraccountRepository.GetSingle(x => x.F_UserId == input.F_Tasker).Result.F_UserCode;
  166. bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, "任务提醒", input.F_Name + "任务提醒", user, time, 2, 1, 0, usercode, 1);
  167. }
  168. else
  169. {
  170. bool n = new InternalMessages.InternalMessagesController(_sys_internalMessagesrepository, _sys_useraccountRepository).AddInternalMessagesInfo(model.F_ID, "任务提醒", input.F_Name + "任务提醒", user, time, 2, 1, int.Parse(input.F_Deptid.Split(',')[input.F_Deptid.Split(',').Length - 1]), "", 0);
  171. }
  172. }
  173. catch
  174. {
  175. }
  176. }
  177. return Success("修改成功");
  178. }
  179. return Error("修改失败");
  180. }
  181. /// <summary>
  182. /// 删除任务
  183. /// </summary>
  184. /// <param name="ids"></param>
  185. /// <returns></returns>
  186. [HttpPost("delete")]
  187. public async Task<IActionResult> Remove(int[] ids)
  188. {
  189. var res = 0;
  190. if (ids != null && ids.Length > 0)
  191. {
  192. foreach (var item in ids)
  193. {
  194. var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == item);
  195. var message = await _sys_internalMessagesrepository.GetListALL(x => x.F_ID == item);
  196. if (message != null)
  197. {
  198. foreach (var it in message)
  199. {
  200. it.SMS_IsDelete = (int)EnumUserCountState.Delete;
  201. var n = _sys_internalMessagesrepository.Update(it);
  202. }
  203. }
  204. model.F_IsDelete = (int)EnumUserCountState.Delete;
  205. model.F_DeleteTime = DateTime.Now.ToLocalTime();
  206. model.F_DeleteUser = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  207. if (_sys_taskmanagement_Repository.Update(model).Result)
  208. res += 1;
  209. }
  210. if (res == ids.Length)
  211. return Success("删除成功");
  212. else if (res > 0 && res < ids.Length)
  213. return Error("部分删除失败,请查看后重新操作");
  214. else
  215. return Error("删除失败,请查看后重新操作");
  216. }
  217. else
  218. return Error("请选择要删除的记录");
  219. }
  220. /// <summary>
  221. /// 操作任务
  222. /// </summary>
  223. /// <param name="id">id</param>
  224. /// <returns></returns>
  225. [HttpGet("operation")]
  226. public async Task<IActionResult> GetOperationAsync(int id, int state)
  227. {
  228. if (id <= 0)
  229. return Error("参数错误");
  230. var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == id);
  231. if (model == null)
  232. {
  233. return Error("获取失败");
  234. }
  235. model.F_State = state;
  236. var obj = await _sys_taskmanagement_Repository.Update(model);
  237. if (obj)
  238. return Success("操作成功");
  239. else
  240. return Error("操作失败");
  241. }
  242. /// <summary>
  243. /// 获取任务列表
  244. /// </summary>
  245. /// <param name="keyword"></param>
  246. /// <param name="pageindex"></param>
  247. /// <param name="pagesize"></param>
  248. /// <returns></returns>
  249. [HttpGet("getlist")]
  250. public async Task<IActionResult> GetListMark(string keyword, string name,string parentname, string starttime, string endtime, string tasker,
  251. string deptid , int parentid=0,int type = -1, int pageindex = 1, int pagesize = 20)
  252. {
  253. List<IConditionalModel> conModels = new List<IConditionalModel>();
  254. #region 条件筛选
  255. conModels.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumUserCountState.Enabled).ToString() });
  256. if (!string.IsNullOrEmpty(name))
  257. {
  258. conModels.Add(new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = name });
  259. }
  260. if (!string.IsNullOrEmpty(tasker))
  261. {
  262. if (_sys_useraccountRepository .GetListALL(x => x.F_UserName == tasker&&x.F_DeleteFlag ==0).Result .FirstOrDefault ()!= null)
  263. {
  264. conModels.Add(new ConditionalModel() { FieldName = "F_Tasker", ConditionalType = ConditionalType.Equal , FieldValue = _sys_useraccountRepository.GetListALL (x => x.F_UserName == tasker && x.F_DeleteFlag == 0).Result.FirstOrDefault ().F_UserId .ToString () });
  265. }
  266. else
  267. {
  268. return Error("请输入正确的任务人");
  269. }
  270. }
  271. if (string .IsNullOrEmpty (tasker)&& string.IsNullOrEmpty(parentname))
  272. {
  273. conModels.Add(new ConditionalModel() { FieldName = "F_Parentid", ConditionalType = ConditionalType.Equal, FieldValue = parentid.ToString() });
  274. }
  275. // string user = "8000";
  276. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  277. var dept = _sys_useraccountRepository.GetSingle(x => x.F_UserCode == user).Result != null ? _sys_useraccountRepository.GetSingle(x => x.F_UserCode == user).Result.F_DeptId : 0;
  278. if (!string.IsNullOrEmpty(deptid))
  279. {
  280. conModels.Add(new ConditionalModel() { FieldName = "F_Deptid", ConditionalType = ConditionalType.Equal, FieldValue = deptid });
  281. }
  282. else
  283. {
  284. conModels.Add(new ConditionalModel() { FieldName = "F_CreateUser", ConditionalType = ConditionalType.Equal, FieldValue = user });
  285. new KeyValuePair<WhereType, ConditionalModel>(WhereType.Or, new ConditionalModel() { FieldName = "F_Deptid", ConditionalType = ConditionalType.Like, FieldValue = dept.ToString() });
  286. deptid = dept.ToString();
  287. }
  288. if (!string.IsNullOrEmpty(parentname))
  289. {
  290. List<IConditionalModel> conModel = new List<IConditionalModel>();
  291. conModel.Add(new ConditionalModel() { FieldName = "F_CreateUser", ConditionalType = ConditionalType.Equal, FieldValue = user });
  292. new KeyValuePair<WhereType, ConditionalModel>(WhereType.Or, new ConditionalModel() { FieldName = "F_Deptid", ConditionalType = ConditionalType.Like, FieldValue = deptid.ToString() });
  293. conModel.Add(new ConditionalModel() { FieldName = "F_IsDelete", ConditionalType = ConditionalType.Equal, FieldValue = ((int)EnumUserCountState.Enabled).ToString() });
  294. conModel.Add(new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = parentname });
  295. var model = _sys_taskmanagement_Repository.GetListALL(conModel, "F_CreateTime desc ").Result.FirstOrDefault();
  296. if (model != null )
  297. {
  298. conModels.Add(new ConditionalModel() { FieldName = "F_Parentid", ConditionalType = ConditionalType.Equal, FieldValue = model.F_ID .ToString () });
  299. }
  300. else
  301. {
  302. return Error("请输入正确的父级任务名称");
  303. }
  304. }
  305. if (type > -1)
  306. {
  307. conModels.Add(new ConditionalModel() { FieldName = "F_Type", ConditionalType = ConditionalType.Like, FieldValue = type.ToString() });
  308. }
  309. if (!string.IsNullOrEmpty(keyword))
  310. {
  311. conModels.Add(new ConditionalCollections()
  312. {
  313. ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
  314. {
  315. new KeyValuePair<WhereType, ConditionalModel>(WhereType.And, new ConditionalModel() { FieldName = "F_Name", ConditionalType = ConditionalType.Like, FieldValue = keyword }),
  316. new KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_Content", ConditionalType = ConditionalType.Like, FieldValue = keyword })
  317. }
  318. });
  319. }
  320. if (!string.IsNullOrEmpty(starttime))
  321. {
  322. conModels.Add(new ConditionalModel() { FieldName = "F_StartTime", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = starttime });
  323. }
  324. if (!string.IsNullOrEmpty(endtime))
  325. {
  326. conModels.Add(new ConditionalModel() { FieldName = "F_EndTime", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = endtime });
  327. }
  328. #endregion
  329. int recordCount = 0;
  330. var list = await _sys_taskmanagement_Repository.GetListByPage(conModels, new MyPageModel() { PageIndex = pageindex, PageSize = pagesize, PageCount = recordCount });
  331. var obj = new
  332. {
  333. state = "success",
  334. message = "成功",
  335. rows = ConvertAsync(list.Rows ),
  336. total = list.Totals,
  337. };
  338. return Content(obj.ToJson());
  339. }
  340. /// <summary>
  341. /// 获取任务详情
  342. /// </summary>
  343. /// <param name="id">id</param>
  344. /// <returns></returns>
  345. [HttpGet("getdetails")]
  346. public async Task<IActionResult> GetDetailsAsync(int id)
  347. {
  348. if (id <= 0)
  349. return Error("参数错误");
  350. var model = await _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == id);
  351. if (model == null)
  352. {
  353. return Error("获取失败");
  354. }
  355. return Success("获取成功!", Convert(model, 1));
  356. }
  357. /// <summary>
  358. /// 修改任务当前金额
  359. /// </summary>
  360. /// <param name="id"></param>
  361. /// <param name="money"></param>
  362. /// <returns></returns>
  363. public int UpdateTaskAmount(T_Bus_Order t_Bus_Order )
  364. {
  365. //0成功1任务暂停2任务终止3修改任务金额失败4任务不存在5父级任务不存在6父级任务修改失败7父级任务暂停8父级任务终止
  366. int n = 0;
  367. var model = _sys_taskmanagement_Repository.GetListALL (x => x.F_Tasker == t_Bus_Order.F_AddUser&& x.F_IsDelete ==0);
  368. if (model == null)
  369. return 4;
  370. foreach (var it in model.Result )
  371. {
  372. if (it.F_State == 0)
  373. {
  374. it.F_Currentamount +=(float ) t_Bus_Order.F_RealPrice;
  375. it.F_Taskprogress = string.Format("{0:f2}", it.F_Currentamount / it.F_Money * 100);
  376. var res = _sys_taskmanagement_Repository.Update(it);
  377. if (!res.Result)
  378. return 3;
  379. if (it.F_Parentid > 0)
  380. {
  381. n = TreeRecursion(it.F_Parentid, (float)t_Bus_Order.F_RealPrice);
  382. }
  383. }
  384. else
  385. n = (int)it .F_State;
  386. }
  387. return n;
  388. }
  389. /// <summary>
  390. /// 递归算法
  391. /// </summary>
  392. /// <param name="data"></param>
  393. /// <param name="parentId"></param>
  394. /// <returns></returns>
  395. private int TreeRecursion( int parentId = 0,float money=0)
  396. {
  397. int n = 0;
  398. var model = _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == parentId).Result;
  399. if (model == null)
  400. return 5;
  401. if (model.F_State == 0)
  402. {
  403. model.F_Currentamount += money;
  404. model.F_Taskprogress = string.Format("{0:f2}", model.F_Currentamount / model.F_Money * 100);
  405. var res = _sys_taskmanagement_Repository.Update(model);
  406. if (!res.Result)
  407. return 6;
  408. if (model.F_Parentid > 0)
  409. {
  410. n = TreeRecursion(model.F_Parentid, money);
  411. }
  412. }
  413. else
  414. n = (int)model.F_State+6;
  415. return n;
  416. }
  417. /// <summary>
  418. /// 上传文件并导入数据库
  419. /// </summary>
  420. /// <returns></returns>
  421. [HttpPost("importexcel")]
  422. public async Task<IActionResult> ImportExcel(int headrow = 0,int parentid=0)
  423. {
  424. Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
  425. if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
  426. return Error($"请正确上传Excel文件:file.ContentType={_upfile.ContentType}");
  427. NPOIHelper npoi = new NPOIHelper();
  428. var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
  429. int num = dtExcel.Rows.Count;
  430. var cols = dtExcel.Columns;
  431. int colnum = cols.Count;
  432. string errmsg = string.Empty;
  433. if (num > 0)
  434. {
  435. int index = 1;
  436. foreach (DataRow dr in dtExcel.Rows)
  437. {
  438. var model = new T_Sys_TaskManagement();
  439. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  440. model.F_Name = dr["任务名称"].ToString();
  441. model.F_Content = dr["任务内容"].ToString();
  442. if (string .IsNullOrEmpty (dr["任务开始时间"].ToString()))
  443. {
  444. errmsg = errmsg + "\r\n第" + index + "行导入失败!请输入任务开始时间";
  445. continue;
  446. }
  447. if (string.IsNullOrEmpty(dr["任务结束时间"].ToString()))
  448. {
  449. errmsg = errmsg + "\r\n第" + index + "行导入失败!请输入任务结束时间";
  450. continue;
  451. }
  452. if (string.IsNullOrEmpty(dr["目标金额"].ToString()))
  453. {
  454. errmsg = errmsg + "\r\n第" + index + "行导入失败!请输入目标金额";
  455. continue;
  456. }
  457. try
  458. {
  459. model.F_StartTime = DateTime.Parse(dr["任务开始时间"].ToString());
  460. }
  461. catch
  462. {
  463. errmsg = errmsg + "\r\n第" + index + "行导入失败!任务开始时间格式错误";
  464. continue;
  465. }
  466. try
  467. {
  468. model.F_EndTime = DateTime.Parse(dr["任务结束时间"].ToString());
  469. }
  470. catch
  471. {
  472. errmsg = errmsg + "\r\n第" + index + "行导入失败!任务结束时间格式错误";
  473. continue;
  474. }
  475. if (dr["任务类型"].ToString() == "月")
  476. model.F_Type = 2;
  477. else if (dr["任务类型"].ToString() == "周")
  478. model.F_Type = 1;
  479. else
  480. model.F_Type = 0;
  481. if (_sys_departmentRepository.GetSingle(x => x.F_DeptName == dr["任务部门"].ToString()).Result !=null )
  482. {
  483. model.F_Deptid = _sys_departmentRepository.GetSingle(x => x.F_DeptName == dr["任务部门"].ToString()).Result.F_DeptId.ToString ();
  484. }
  485. else
  486. {
  487. errmsg = errmsg + "\r\n第" + index + "行导入失败!请检查任务部门";
  488. continue;
  489. }
  490. if (_sys_useraccountRepository.GetSingle(x => x.F_UserName == dr["任务人"].ToString()).Result != null)
  491. {
  492. model.F_Tasker = _sys_useraccountRepository.GetSingle(x => x.F_UserName == dr["任务人"].ToString()).Result.F_UserId ;
  493. }
  494. else
  495. {
  496. errmsg = errmsg + "\r\n第" + index + "行导入失败!请检查任务人";
  497. continue;
  498. }
  499. try
  500. {
  501. model.F_Money = float .Parse(dr["目标金额"].ToString());
  502. }
  503. catch
  504. {
  505. errmsg = errmsg + "\r\n第" + index + "行导入失败!请输入正确的目标金额";
  506. continue;
  507. }
  508. if (string.IsNullOrEmpty(dr["当前金额"].ToString()))
  509. model.F_Currentamount = 0;
  510. try
  511. {
  512. model.F_Currentamount = float.Parse(dr["当前金额"].ToString());
  513. }
  514. catch
  515. {
  516. errmsg = errmsg + "\r\n第" + index + "行导入失败!请输入正确的当前金额";
  517. continue;
  518. }
  519. if (!string .IsNullOrEmpty (dr["任务提醒时间"].ToString()))
  520. {
  521. try
  522. {
  523. model.F_Remindertime = DateTime.Parse(dr["任务提醒时间"].ToString());
  524. }
  525. catch
  526. {
  527. errmsg = errmsg + "\r\n第" + index + "行导入失败!任务提醒时间格式错误";
  528. continue;
  529. }
  530. }
  531. else
  532. {
  533. model.F_Remindertime = model.F_EndTime.Value.AddDays(-3);
  534. }
  535. model.F_Taskprogress = string.Format("{0:f2}", model.F_Currentamount / model.F_Money * 100);
  536. if (dr["任务类型"].ToString() == "终止")
  537. model.F_State = 2;
  538. else if (dr["任务类型"].ToString() == "暂停")
  539. model.F_State = 1;
  540. else
  541. model.F_State = 0;
  542. model.F_CreateTime = DateTime.Now;
  543. model.F_CreateUser = user;
  544. model.F_IsDelete = 0;
  545. model.F_Parentid = parentid;
  546. int b = await _sys_taskmanagement_Repository.Add(model);
  547. if (b <= 0)
  548. {
  549. if (!string.IsNullOrEmpty(errmsg))
  550. {
  551. errmsg = errmsg + "\r\n第" + index + "行导入失败!";
  552. }
  553. else
  554. {
  555. errmsg = "第" + index + "行导入失败!";
  556. }
  557. }
  558. index++;
  559. }
  560. }
  561. else
  562. {
  563. return Error("文件中无数据");
  564. }
  565. if (!string.IsNullOrEmpty(errmsg))
  566. {
  567. return Error(errmsg);
  568. }
  569. return Success("导入成功");
  570. }
  571. #region 私有方法
  572. private TaskManagementInput Convert(T_Sys_TaskManagement it, int type = 0)
  573. {
  574. TaskManagementInput task = new TaskManagementInput();
  575. task.F_ID = it.F_ID;
  576. task.F_Name = it.F_Name;
  577. task.F_Content = it.F_Content;
  578. task.F_StartTime = it.F_StartTime;
  579. task.F_EndTime = it.F_EndTime;
  580. task.F_Type = it.F_Type;
  581. task.F_Deptid = it.F_Deptid;
  582. string deptmsg = "";
  583. if (!string.IsNullOrEmpty(it.F_Deptid))
  584. {
  585. try
  586. {
  587. string[] sprit = it.F_Deptid.Split(',');
  588. foreach (var iv in sprit)
  589. {
  590. if (deptmsg == "")
  591. deptmsg = _sys_departmentRepository.GetSingle(x => x.F_DeptId == int.Parse(iv)).Result != null ? _sys_departmentRepository.GetSingle(x => x.F_DeptId == int.Parse(iv)).Result.F_DeptName : "";
  592. else
  593. deptmsg = deptmsg + "," + _sys_departmentRepository.GetSingle(x => x.F_DeptId == int.Parse(iv)).Result != null ? _sys_departmentRepository.GetSingle(x => x.F_DeptId == int.Parse(iv)).Result.F_DeptName : "";
  594. }
  595. }
  596. catch
  597. {
  598. }
  599. }
  600. task.F_DeptName = deptmsg;// 部门名称
  601. task.F_Tasker = it.F_Tasker;
  602. task.F_TaskerName = _sys_useraccountRepository.GetSingle(x => x.F_UserId == it.F_Tasker).Result != null ? _sys_useraccountRepository.GetSingle(x => x.F_UserId == it.F_Tasker).Result .F_UserName : "";
  603. task.F_Money = it.F_Money;
  604. task.F_Currentamount = it.F_Currentamount;
  605. task.F_Taskprogress = it.F_Taskprogress;
  606. task.F_State = it.F_State;
  607. task.F_Remindertime = it.F_Remindertime;
  608. if (type ==0)
  609. {
  610. var taskcount = _sys_taskmanagement_Repository.GetListALL(x => x.F_Parentid == it.F_ID&&x.F_IsDelete ==0).Result != null ? _sys_taskmanagement_Repository.GetListALL(x => x.F_Parentid == it.F_ID && x.F_IsDelete == 0).Result: null ;
  611. if (taskcount!=null )
  612. {
  613. task.children = ConvertAsync(taskcount);
  614. }
  615. }
  616. task.F_Parentid = it.F_Parentid;
  617. task.F_ParentName = _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == it.F_Parentid).Result != null ? _sys_taskmanagement_Repository.GetSingle(x => x.F_ID == it.F_Parentid).Result.F_Name : "";// 部门名称
  618. return task;
  619. }
  620. /// model转input
  621. /// </summary>
  622. /// <param name="input"></param>
  623. /// <returns></returns>
  624. private List<TaskManagementInput> ConvertAsync(List<T_Sys_TaskManagement> model)
  625. {
  626. List<TaskManagementInput> input = new List<TaskManagementInput>();
  627. if (model != null)
  628. {
  629. foreach (var it in model)
  630. {
  631. TaskManagementInput marketing = new TaskManagementInput();
  632. marketing = Convert(it);
  633. input.Add(marketing);
  634. }
  635. }
  636. return input;
  637. }
  638. #endregion
  639. }
  640. }