颐和api

InputDataController.cs 32KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Security.Claims;
  5. using System.Threading.Tasks;
  6. using MadRunFabric.Common;
  7. using MadRunFabric.Model.PLCAutomationApi;
  8. using Microsoft.AspNetCore.Authorization;
  9. using Microsoft.AspNetCore.Mvc;
  10. using Microsoft.Extensions.Logging;
  11. using MongoDB.Driver;
  12. using PLCAutomationApi.IRepositories;
  13. namespace PLCAutomationApi.Controllers
  14. {
  15. /// <summary>
  16. /// 水电气数据录入
  17. /// </summary>
  18. [ApiVersion("6.0")]
  19. [Produces("application/json")]
  20. [Route("api/[controller]")]
  21. public class InputDataController : BaseController
  22. {
  23. private readonly ILogger<InputDataController> _logger;
  24. private readonly IPLC_InputDataRepository _plc_inputdataRepository;
  25. private readonly IPLC_MonthDataRepository _plc_monthdataRepository;
  26. public InputDataController(ILogger<InputDataController> logger, IPLC_InputDataRepository plc_inputdataRepository, IPLC_MonthDataRepository plc_monthdataRepository)
  27. {
  28. _logger = logger;
  29. _plc_inputdataRepository = plc_inputdataRepository;
  30. _plc_monthdataRepository = plc_monthdataRepository;
  31. }
  32. [HttpGet("index")]
  33. public IActionResult Index()
  34. {
  35. return View();
  36. }
  37. //[Authorize]
  38. [HttpPost("add")]
  39. public async Task<IActionResult> AddData(string[] dataname,string[] datavalue,string inputtime,string projectname)
  40. {
  41. try
  42. {
  43. string ytime = DateTime.Now.AddDays (-1).ToString("yyyy-MM-dd");
  44. PLC_InputData comodel = new PLC_InputData();
  45. if (!string.IsNullOrWhiteSpace(inputtime))
  46. {
  47. DateTime dt2 = new DateTime();
  48. if (DateTime.TryParse(inputtime.Trim(), out dt2))
  49. ytime = dt2.AddDays(-1).ToString("yyyy-MM-dd");
  50. }
  51. else
  52. {
  53. inputtime = DateTime.Now.ToString("yyyy-MM-dd");
  54. }
  55. int t = dataname.Length;
  56. int res = 0;
  57. for (int i = 0; i < dataname.Length; i++)
  58. {
  59. #region 判断是否有当天记录,若有则删除
  60. //Dictionary<string, string> dic = new Dictionary<string, string>();
  61. //dic.Add("deleteflag", "1");
  62. var list = new List<FilterDefinition<PLC_InputData>>();
  63. var filterBuilder = Builders<PLC_InputData>.Filter;
  64. list.Add(filterBuilder.Eq("dataname", dataname[i]));
  65. list.Add(filterBuilder.Eq("inputtime", inputtime));
  66. list.Add(filterBuilder.Eq("projectname", projectname));
  67. var filter = Builders<PLC_InputData>.Filter.And(list);
  68. var count = await _plc_inputdataRepository.CountAsync(filter);
  69. if (count > 0)
  70. {
  71. var dModel = await _plc_inputdataRepository.GetSingle(s => s.dataname .Equals(dataname[i])&s.inputtime == inputtime&s.projectname ==projectname & s.deleteflag == 0, null);
  72. if (dModel != null)
  73. {
  74. dModel.deleteflag = 1;
  75. var tt = await _plc_inputdataRepository.Update(dModel);
  76. }
  77. }
  78. #endregion
  79. #region 更新昨天的止数
  80. var fModel = await _plc_inputdataRepository.GetSingle(s => s.dataname.Equals(dataname[i]) & s.inputtime == ytime&s.projectname ==projectname & s.deleteflag == 0, null);
  81. if (fModel != null)
  82. {
  83. fModel.endvalue = datavalue[i];
  84. var n = await _plc_inputdataRepository.Update(fModel);
  85. }
  86. #endregion
  87. #region 保存月数据
  88. string year = DateTime.Now.Year.ToString();
  89. int mon = Convert.ToDateTime(inputtime.Trim()).Month;// DateTime.Parse(inputtime.Trim());
  90. var aModel = await _plc_monthdataRepository.GetSingle(s => s.datayear==year & s.datamonth == mon&s.dataname == dataname[i]&s.projectname ==projectname , null);
  91. if (aModel != null)
  92. {
  93. //判断更新止数
  94. if (aModel.endday <= Convert.ToDateTime(inputtime.Trim()).Day)
  95. {
  96. aModel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  97. aModel.endvalue = datavalue[i];
  98. aModel.endtime = inputtime.Trim();
  99. var n = await _plc_monthdataRepository.Update(aModel);
  100. #region 判断如果为每月最后一天则将当前数做为下月起数
  101. DateTime dtn = Convert.ToDateTime(inputtime.Trim());
  102. DateTime startMonth = dtn.AddDays(1 - dtn.Day); //本月月初
  103. DateTime endMonth = startMonth.AddMonths(1).AddDays(-1);
  104. if (endMonth.Day == dtn.Day)//最后一天
  105. {
  106. string byear = startMonth.AddMonths(1).Year.ToString();
  107. int bmon = startMonth.AddMonths(1).Month;
  108. var bModel = await _plc_monthdataRepository.GetSingle(s => s.datayear == byear & s.datamonth == bmon & s.dataname == dataname[i] & s.projectname == projectname, null);
  109. if (bModel != null)
  110. {
  111. //判断更新止数
  112. if (bModel.endday <= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  113. {
  114. bModel.endday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  115. bModel.endvalue = datavalue[i];
  116. bModel.endtime = startMonth.AddMonths(1).ToString ("yyyy-MM-dd");
  117. var bn = await _plc_monthdataRepository.Update(bModel);
  118. }
  119. else if (bModel.startday >= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  120. {
  121. bModel.startday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  122. bModel.startvalue = datavalue[i];
  123. bModel.starttime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  124. var bn = await _plc_monthdataRepository.Update(bModel);
  125. }
  126. }
  127. else
  128. {
  129. #region
  130. var amodel = new PLC_MonthData();
  131. amodel.dataname = dataname[i];
  132. amodel.startvalue = datavalue[i];
  133. amodel.endvalue = datavalue[i];
  134. amodel.datamonth = startMonth.AddMonths(1).Month;
  135. amodel.datayear = startMonth.AddMonths(1).Year.ToString();
  136. amodel.startday = startMonth.AddMonths(1).Day;
  137. amodel.endday = startMonth.AddMonths(1).Day;
  138. amodel.starttime = inputtime.Trim();
  139. amodel.endtime = inputtime.Trim();
  140. if (dataname[i].Contains("水"))
  141. { amodel.datakind = 0; }
  142. else if (dataname[i].Contains("天然气") || dataname[i].Contains("燃气"))
  143. { amodel.datakind = 2; }
  144. else if (dataname[i].Contains("氧"))
  145. { amodel.datakind = 3; }
  146. else
  147. { amodel.datakind = 1; }
  148. amodel.projectname = projectname;
  149. await _plc_monthdataRepository.Add(amodel);
  150. #endregion
  151. }
  152. }
  153. #endregion
  154. }
  155. else if (aModel.startday >= Convert.ToDateTime(inputtime.Trim()).Day)
  156. {
  157. aModel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  158. aModel.startvalue = datavalue[i];
  159. aModel.starttime = inputtime.Trim();
  160. var n = await _plc_monthdataRepository.Update(aModel);
  161. #region 判断如果为每月最后一天则将当前数做为下月起数
  162. DateTime dtn = Convert.ToDateTime(inputtime.Trim());
  163. DateTime startMonth = dtn.AddDays(1 - dtn.Day); //本月月初
  164. DateTime endMonth = startMonth.AddMonths(1).AddDays(-1);
  165. if (endMonth.Day == dtn.Day)//最后一天
  166. {
  167. string byear = startMonth.AddMonths(1).Year.ToString();
  168. int bmon = startMonth.AddMonths(1).Month;
  169. var bModel = await _plc_monthdataRepository.GetSingle(s => s.datayear == byear & s.datamonth == bmon & s.dataname == dataname[i] & s.projectname == projectname, null);
  170. if (bModel != null)
  171. {
  172. //判断更新止数
  173. if (bModel.endday <= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  174. {
  175. bModel.endday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  176. bModel.endvalue = datavalue[i];
  177. bModel.endtime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  178. var bn = await _plc_monthdataRepository.Update(bModel);
  179. }
  180. else if (bModel.startday >= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  181. {
  182. bModel.startday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  183. bModel.startvalue = datavalue[i];
  184. bModel.starttime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  185. var bn = await _plc_monthdataRepository.Update(bModel);
  186. }
  187. }
  188. else
  189. {
  190. #region
  191. var amodel = new PLC_MonthData();
  192. amodel.dataname = dataname[i];
  193. amodel.startvalue = datavalue[i];
  194. amodel.endvalue = datavalue[i];
  195. amodel.datamonth = startMonth.AddMonths(1).Month;
  196. amodel.datayear = startMonth.AddMonths(1).Year.ToString();
  197. amodel.startday = startMonth.AddMonths(1).Day;
  198. amodel.endday = startMonth.AddMonths(1).Day;
  199. amodel.starttime = inputtime.Trim();
  200. amodel.endtime = inputtime.Trim();
  201. if (dataname[i].Contains("水"))
  202. { amodel.datakind = 0; }
  203. else if (dataname[i].Contains("天然气") || dataname[i].Contains("燃气"))
  204. { amodel.datakind = 2; }
  205. else if (dataname[i].Contains("氧"))
  206. { amodel.datakind = 3; }
  207. else
  208. { amodel.datakind = 1; }
  209. amodel.projectname = projectname;
  210. await _plc_monthdataRepository.Add(amodel);
  211. #endregion
  212. }
  213. }
  214. #endregion
  215. }
  216. }
  217. else
  218. {
  219. var amodel = new PLC_MonthData();
  220. amodel.dataname = dataname[i];
  221. amodel.startvalue = datavalue[i];
  222. amodel.endvalue = datavalue[i];
  223. amodel.datamonth = mon;
  224. amodel.datayear = year;
  225. amodel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  226. amodel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  227. amodel.starttime = inputtime.Trim();
  228. amodel.endtime = inputtime.Trim();
  229. if (dataname[i].Contains("水"))
  230. { amodel.datakind = 0; }
  231. else if (dataname[i].Contains("天然气") || dataname[i].Contains("燃气"))
  232. { amodel.datakind = 2; }
  233. else if (dataname[i].Contains("氧"))
  234. { amodel.datakind = 3; }
  235. else
  236. { amodel.datakind = 1; }
  237. amodel.projectname = projectname;
  238. await _plc_monthdataRepository.Add(amodel);
  239. }
  240. #endregion
  241. var cmodel = new PLC_InputData();
  242. cmodel.dataname = dataname[i];
  243. cmodel.startvalue = datavalue[i];
  244. cmodel.inputtime = inputtime;
  245. cmodel.createusercode = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value; //"8000";
  246. cmodel.deleteflag = 0;
  247. cmodel.createtime = DateTime.Now.ToLocalTime();
  248. if (dataname[i].Contains("水"))
  249. { cmodel.datakind = 0; }
  250. else if (dataname[i].Contains("天然气") || dataname[i].Contains("燃气"))
  251. { cmodel.datakind = 2; }
  252. else if (dataname[i].Contains("氧"))
  253. { cmodel.datakind = 3; }
  254. else
  255. { cmodel.datakind = 1; }
  256. cmodel.projectname = projectname;
  257. if (await _plc_inputdataRepository.Add(cmodel))
  258. res++;
  259. }
  260. if (res == t)
  261. {
  262. return Success("添加数据成功");
  263. }
  264. else
  265. {
  266. return Error("添加数据失败");
  267. }
  268. }
  269. catch (Exception ex)
  270. {
  271. _logger.LogError(ex, "添加水电气数据异常");
  272. return Error("添加水电气数据失败");
  273. }
  274. }
  275. //[Authorize]
  276. [HttpPost("update")]
  277. public async Task<IActionResult> UpdateData(string id, string datavalue)//(string dataname, string datavalue,string inputdate)
  278. {
  279. try
  280. {
  281. PLC_InputData comodel = new PLC_InputData();
  282. var list = new List<FilterDefinition<PLC_InputData>>();
  283. var filterBuilder = Builders<PLC_InputData>.Filter;
  284. //list.Add(filterBuilder.Eq("dataname", dataname));
  285. //list.Add(filterBuilder.Eq("inputtime", DateTime.Now.ToString("yyyy-MM-dd")));
  286. list.Add(filterBuilder.Eq("id", id));
  287. var filter = Builders<PLC_InputData>.Filter.And(list);
  288. var count = await _plc_inputdataRepository.CountAsync(filter);
  289. if (count > 0)
  290. {
  291. var dModel = await _plc_inputdataRepository.GetSingle(s => s.id .Equals(id) & s.deleteflag == 0, null);
  292. dModel.startvalue = datavalue;
  293. string inputtime = dModel.inputtime;
  294. string dataname = dModel.dataname;
  295. var tt = await _plc_inputdataRepository.Update(dModel);
  296. if (tt)
  297. {
  298. #region 保存月数据
  299. string year = DateTime.Now.Year.ToString();
  300. int mon = Convert.ToDateTime(inputtime.Trim()).Month;// DateTime.Parse(inputtime.Trim());
  301. var aModel = await _plc_monthdataRepository.GetSingle(s => s.datayear == year & s.datamonth == mon & s.dataname == dataname&s.projectname ==dModel .projectname , null);
  302. if (aModel != null)
  303. {
  304. //判断更新止数
  305. if (aModel.endday <= Convert.ToDateTime(inputtime.Trim()).Day)
  306. {
  307. aModel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  308. aModel.endvalue = datavalue;
  309. aModel.endtime = inputtime.Trim();
  310. var n = await _plc_monthdataRepository.Update(aModel);
  311. #region 判断如果为每月最后一天则将当前数做为下月起数
  312. DateTime dtn = Convert.ToDateTime(inputtime.Trim());
  313. DateTime startMonth = dtn.AddDays(1 - dtn.Day); //本月月初
  314. DateTime endMonth = startMonth.AddMonths(1).AddDays(-1);
  315. if (endMonth.Day == dtn.Day)//最后一天
  316. {
  317. string byear = startMonth.AddMonths(1).Year.ToString();
  318. int bmon = startMonth.AddMonths(1).Month;
  319. var bModel = await _plc_monthdataRepository.GetSingle(s => s.datayear == byear & s.datamonth == bmon & s.dataname == dataname & s.projectname == dModel.projectname, null);
  320. if (bModel != null)
  321. {
  322. //判断更新止数
  323. if (bModel.endday <= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  324. {
  325. bModel.endday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  326. bModel.endvalue = datavalue;
  327. bModel.endtime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  328. var bn = await _plc_monthdataRepository.Update(bModel);
  329. }
  330. else if (bModel.startday >= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  331. {
  332. bModel.startday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  333. bModel.startvalue = datavalue;
  334. bModel.starttime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  335. var bn = await _plc_monthdataRepository.Update(bModel);
  336. }
  337. }
  338. else
  339. {
  340. #region
  341. var amodel = new PLC_MonthData();
  342. amodel.dataname = dataname;
  343. amodel.startvalue = datavalue;
  344. amodel.datamonth = mon;
  345. amodel.datayear = year;
  346. amodel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  347. amodel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  348. amodel.starttime = inputtime.Trim();
  349. amodel.endtime = inputtime.Trim();
  350. amodel.projectname = dModel.projectname;
  351. await _plc_monthdataRepository.Add(amodel);
  352. #endregion
  353. }
  354. }
  355. #endregion
  356. }
  357. else if (aModel.startday>= Convert.ToDateTime(inputtime.Trim()).Day)
  358. {
  359. aModel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  360. aModel.startvalue = datavalue;
  361. aModel.starttime = inputtime.Trim();
  362. var n = await _plc_monthdataRepository.Update(aModel);
  363. #region 判断如果为每月最后一天则将当前数做为下月起数
  364. DateTime dtn = Convert.ToDateTime(inputtime.Trim());
  365. DateTime startMonth = dtn.AddDays(1 - dtn.Day); //本月月初
  366. DateTime endMonth = startMonth.AddMonths(1).AddDays(-1);
  367. if (endMonth.Day == dtn.Day)//最后一天
  368. {
  369. string byear = startMonth.AddMonths(1).Year.ToString();
  370. int bmon = startMonth.AddMonths(1).Month;
  371. var bModel = await _plc_monthdataRepository.GetSingle(s => s.datayear == byear & s.datamonth == bmon & s.dataname == dataname & s.projectname == dModel.projectname, null);
  372. if (bModel != null)
  373. {
  374. //判断更新止数
  375. if (bModel.endday <= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  376. {
  377. bModel.endday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  378. bModel.endvalue = datavalue;
  379. bModel.endtime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  380. var bn = await _plc_monthdataRepository.Update(bModel);
  381. }
  382. else if (bModel.startday >= Convert.ToDateTime(startMonth.AddMonths(1)).Day)
  383. {
  384. bModel.startday = Convert.ToDateTime(startMonth.AddMonths(1)).Day;
  385. bModel.startvalue = datavalue;
  386. bModel.starttime = startMonth.AddMonths(1).ToString("yyyy-MM-dd");
  387. var bn = await _plc_monthdataRepository.Update(bModel);
  388. }
  389. }
  390. else
  391. {
  392. #region
  393. var amodel = new PLC_MonthData();
  394. amodel.dataname = dataname;
  395. amodel.startvalue = datavalue;
  396. amodel.datamonth = mon;
  397. amodel.datayear = year;
  398. amodel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  399. amodel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  400. amodel.starttime = inputtime.Trim();
  401. amodel.endtime = inputtime.Trim();
  402. amodel.projectname = dModel.projectname;
  403. await _plc_monthdataRepository.Add(amodel);
  404. #endregion
  405. }
  406. }
  407. #endregion
  408. }
  409. }
  410. else
  411. {
  412. var amodel = new PLC_MonthData();
  413. amodel.dataname = dataname;
  414. amodel.startvalue = datavalue;
  415. amodel.datamonth = mon;
  416. amodel.datayear = year;
  417. amodel.startday = Convert.ToDateTime(inputtime.Trim()).Day;
  418. amodel.endday = Convert.ToDateTime(inputtime.Trim()).Day;
  419. amodel.starttime = inputtime.Trim();
  420. amodel.endtime = inputtime.Trim();
  421. amodel.projectname = dModel.projectname;
  422. await _plc_monthdataRepository.Add(amodel);
  423. }
  424. #endregion
  425. return Success("修改数据成功");
  426. }
  427. }
  428. return Error("修改数据失败");
  429. }
  430. catch (Exception ex)
  431. {
  432. _logger.LogError(ex, "修改水电气数据异常");
  433. return Error("修改水电气数据失败");
  434. }
  435. }
  436. [HttpPost("delete")]
  437. public async Task<IActionResult> Remove(string[] ids)
  438. {
  439. //使用逻辑删除
  440. //物理删除的数据无法恢复
  441. var res = 0;
  442. if (ids != null && ids.Length > 0)
  443. {
  444. foreach (var item in ids)
  445. {
  446. var ml = await _plc_inputdataRepository.GetSingle(item);
  447. ml.deleteflag = 1;
  448. if (await _plc_inputdataRepository.Update(ml))
  449. res += 1;
  450. }
  451. if (res == ids.Length)
  452. return Success("删除成功");
  453. else if (res > 0 && res < ids.Length)
  454. return Error("部分删除失败,请查看后重新操作");
  455. else
  456. return Error("删除失败,请查看后重新操作");
  457. }
  458. else
  459. return Error("请选择要删除的记录");
  460. }
  461. //[Authorize]
  462. [HttpPost("deleteby")]
  463. public async Task<IActionResult> DeleteData(string dataname, string inputdate)
  464. {
  465. try
  466. {
  467. PLC_InputData comodel = new PLC_InputData();
  468. var list = new List<FilterDefinition<PLC_InputData>>();
  469. var filterBuilder = Builders<PLC_InputData>.Filter;
  470. list.Add(filterBuilder.Eq("dataname", dataname));
  471. list.Add(filterBuilder.Eq("inputtime", DateTime.Now.ToString("yyyy-MM-dd")));
  472. var filter = Builders<PLC_InputData>.Filter.And(list);
  473. var count = await _plc_inputdataRepository.CountAsync(filter);
  474. if (count > 0)
  475. {
  476. var dModel = await _plc_inputdataRepository.GetSingle(s => s.dataname.Equals(dataname) & s.inputtime == inputdate & s.deleteflag == 0, null);
  477. dModel.deleteflag = 1;
  478. var tt = await _plc_inputdataRepository.Update(dModel);
  479. if (tt)
  480. return Success("删除成功");
  481. }
  482. return Error("删除失败");
  483. }
  484. catch (Exception ex)
  485. {
  486. _logger.LogError(ex, "删除水电气数据异常");
  487. return Error("删除水电气数据失败");
  488. }
  489. }
  490. //[Authorize]
  491. [HttpGet("getlistbypage")]
  492. public async Task<IActionResult> GetListsByPageAsync(string dataname, string stime, string etime,string projectname, int pageindex = 1, int pagesize = 10)
  493. {
  494. try
  495. {
  496. //排序字段
  497. var sort = Builders<PLC_InputData>.Sort.Descending("inputtime");
  498. //根据条件查询集合
  499. var flist = new List<FilterDefinition<PLC_InputData>>();
  500. flist.Add(Builders<PLC_InputData>.Filter.Eq("deleteflag", 0));
  501. if (!string.IsNullOrWhiteSpace(dataname))
  502. flist.Add(Builders<PLC_InputData>.Filter.Where(s => s.dataname.Equals(dataname)));
  503. if (!string.IsNullOrWhiteSpace(projectname))
  504. flist.Add(Builders<PLC_InputData>.Filter.Where(s => s.projectname.Equals(projectname)));
  505. if (!string.IsNullOrWhiteSpace(stime))
  506. {
  507. DateTime dt2 = new DateTime();
  508. if (DateTime.TryParse(stime.Trim(), out dt2))
  509. flist.Add(Builders<PLC_InputData>.Filter.Gt("createtime", stime + " 00:00:00"));
  510. }
  511. if (!string.IsNullOrWhiteSpace(etime))
  512. {
  513. DateTime dt2 = new DateTime();
  514. if (DateTime.TryParse(etime.Trim(), out dt2))
  515. flist.Add(Builders<PLC_InputData>.Filter.Lt("createtime", etime + " 23:59:59"));
  516. }
  517. var filter = Builders<PLC_InputData>.Filter.And(flist);
  518. var list = await _plc_inputdataRepository.GetByPage(filter, pageindex, pagesize, sort);
  519. var count = await _plc_inputdataRepository.CountAsync(filter);
  520. var obj = new
  521. {
  522. state = "success",
  523. message = "根据条件获取分页数据成功",
  524. rows = list,
  525. total = count,
  526. };
  527. return Content(obj.ToJson());
  528. //return Success("根据条件获取值班电话分页数据成功", list);0
  529. }
  530. catch (Exception ex)
  531. {
  532. _logger.LogError(ex, "根据条件获取分页数据异常");
  533. return Error("根据条件获取分页数据异常");
  534. }
  535. }
  536. //[Authorize]
  537. [HttpGet("getsingle")]
  538. public async Task<IActionResult> GetSingleAsync(string id)
  539. {
  540. if (id != null && id.Trim() != "")
  541. {
  542. try
  543. {
  544. var dModel = await _plc_inputdataRepository.GetSingle(id.Trim());
  545. if (dModel != null)
  546. {
  547. return Success("获取参数成功", dModel);
  548. }
  549. else
  550. {
  551. return Error("获取参数失败");
  552. }
  553. }
  554. catch (Exception ex)
  555. {
  556. _logger.LogError(ex, "获取参数实体异常");
  557. return Error("获取参数失败");
  558. }
  559. }
  560. else
  561. {
  562. return Error("获取参数失败");
  563. }
  564. }
  565. }
  566. }