API tools faq
paste
Advertisement
Guest User

Untitled

a guest
Jul 17th, 2019
90
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 13.46 KB | None | 0 0
raw download clone embed print report
  1. if (RedisObj.RequestType == "PRNTAXQN")
  2. {
  3. #region PTQ
  4. DataTable dtchild = ds.Tables[1].Select("ComputationQueueId = " + RedisObj.QueueId).CopyToDataTable();
  5. if (dtchild.Rows.Count > 0)
  6. RedisObj.TotalRequests = dtchild.Rows.Count;
  7. for (int m = 0; m < dtchild.Rows.Count; m++)
  8. {
  9. ProcessQueueRequest objRequest = new ProcessQueueRequest();
  10. objRequest.QueueId = Convert.ToInt32(dtchild.Rows[m]["ComputationQueueId"]);
  11. objRequest.Status = dtchild.Rows[m]["Status"].ToString();
  12. objRequest.RequestType = dtchild.Rows[m]["RequestType"].ToString();
  13. objRequest.ClientAssigneeId = Convert.ToInt32(dtchild.Rows[m]["ClientAssigneeId"]);
  14. objRequest.RCQuestionId = Convert.ToInt32(dtchild.Rows[m]["RCQuestionId"]);
  15. objRequest.ErrorDetails = Convert.ToString(dtchild.Rows[m]["ErrorDetails"]);
  16. objRequest.RequestId = Convert.ToInt32(dtchild.Rows[m]["RequestId"]);
  17. objRequest.AssigneeName = dtchild.Rows[m]["AssigneeName"].ToString();
  18. objRequest.RequestedBy = dtchild.Rows[m]["RequestedBy"].ToString();
  19. objRequest.RequestedById = Convert.ToInt32(dtchild.Rows[m]["RequestedById"]);
  20. objRequest.EmailId = dtchild.Rows[m]["EmailId"].ToString();
  21. RequestList.Add(objRequest);
  22. }
  23. #endregion
  24. }
  25. else if (RedisObj.RequestType == "EXTSCPITR")
  26. {
  27. #region SAT
  28. DataTable dtchild = ds.Tables[2].Select("ComputationQueueId = " + RedisObj.QueueId).CopyToDataTable();
  29. for (int m = 0; m < dtchild.Rows.Count; m++)
  30. {
  31. ProcessQueueRequest objRequest = new ProcessQueueRequest();
  32. objRequest.QueueId = Convert.ToInt32(dtchild.Rows[m]["ComputationQueueId"]);
  33. objRequest.Status = dtchild.Rows[m]["Status"].ToString();
  34. objRequest.RequestType = RedisObj.RequestType;
  35. objRequest.ZipName = Convert.ToString(dtchild.Rows[m]["ZipName"]);
  36. objRequest.RequestId = Convert.ToInt32(dtchild.Rows[m]["RequestId"]);
  37. objRequest.RequestedBy = dtchild.Rows[m]["RequestedBy"].ToString();
  38. objRequest.RequestedById = Convert.ToInt32(dtchild.Rows[m]["RequestedById"]);
  39. RedisObj.TotalRequests = 1;
  40. RequestList.Add(objRequest);
  41. }
  42. #endregion
  43. }
  44. else if (RedisObj.RequestType == "BUEORGSITR")
  45. {
  46. #region Excel
  47. DataTable dtchild = ds.Tables[2].Select("ComputationQueueId = " + RedisObj.QueueId).CopyToDataTable();
  48. for (int m = 0; m < dtchild.Rows.Count; m++)
  49. {
  50. ProcessQueueRequest objRequest = new ProcessQueueRequest();
  51. objRequest.QueueId = Convert.ToInt32(dtchild.Rows[m]["ComputationQueueId"]);
  52. objRequest.Status = dtchild.Rows[m]["Status"].ToString();
  53. objRequest.RequestType = RedisObj.RequestType;
  54. objRequest.ZipName = Convert.ToString(dtchild.Rows[m]["ZipName"]);
  55. objRequest.RequestId = Convert.ToInt32(dtchild.Rows[m]["RequestId"]);
  56. objRequest.RequestedBy = dtchild.Rows[m]["RequestedBy"].ToString();
  57. objRequest.RequestedById = Convert.ToInt32(dtchild.Rows[m]["RequestedById"]);
  58. RedisObj.TotalRequests = 1;
  59. RequestList.Add(objRequest);
  60. }
  61. #endregion
  62. }
  63. DataTable dtClient = ds.Tables[3].Select("ComputationQueueId = " + RedisObj.QueueId).CopyToDataTable();
  64. RedisObj.ClientName = dtClient.Rows[0]["ClientName"].ToString();
  65. RedisObj.Requestlist = RequestList;
  66. }
  67. }
  68. else
  69. RedisObj = null;
  70. if (RedisObj == null)
  71. {
  72. ProcessQueue objParent = new ProcessQueue();
  73. objParent.QueueId = Convert.ToInt32(dtParent.Rows[n]["ComputationQueueId"]);
  74. objParent.Status = dtParent.Rows[n]["Status"].ToString();
  75. objParent.RequestType = dtParent.Rows[n]["RequestType"].ToString();
  76. objParent.TotalRequests = Convert.ToInt32(dtParent.Rows[n]["TotalRequests"]);
  77. objParent.FailedRequests = Convert.ToInt32(dtParent.Rows[n]["FailedRequests"]);
  78. objParent.CompletedRequests = Convert.ToInt32(dtParent.Rows[n]["CompletedRequests"]);
  79. objParent.CancelledRequests = 0;
  80. objParent.InProgressRequests = Convert.ToInt32(dtParent.Rows[n]["TotalRequests"]);
  81. objParent.RequestedBy = Convert.ToString(dtParent.Rows[n]["RequestedBy"]);
  82. objParent.RequestedOn = Convert.ToDateTime(dtParent.Rows[n]["RequestedOn"]);
  83. objParent.ClientAssigneeId = dtParent.Rows[n]["ClientAssigneeId"].ToString();
  84. objParent.AssigneeName = dtParent.Rows[n]["AssigneeName"].ToString();
  85. objParent.RequestedById = dtParent.Rows[n]["RequestedById"].ToString();
  86. objParent.EmailId = dtParent.Rows[n]["EmailId"].ToString();
  87. objParent.IsCancellationRequested = false;
  88.  
  89. if (objParent.RequestType == "PRNTAXQN")
  90. {
  91. DataTable dtchild = ds.Tables[1].Select("ComputationQueueId = " + objParent.QueueId).CopyToDataTable();
  92. List<ProcessQueueRequest> RequestList = new List<ProcessQueueRequest>();
  93. if (dtchild.Rows.Count > 0)
  94. objParent.TotalRequests = dtchild.Rows.Count;
  95. for (int m = 0; m < dtchild.Rows.Count; m++)
  96. {
  97. ProcessQueueRequest objRequest = new ProcessQueueRequest();
  98. objRequest.QueueId = Convert.ToInt32(dtchild.Rows[m]["ComputationQueueId"]);
  99. objRequest.Status = dtchild.Rows[m]["Status"].ToString();
  100. objRequest.RequestType = dtchild.Rows[m]["RequestType"].ToString();
  101. objRequest.ClientAssigneeId = Convert.ToInt32(dtchild.Rows[m]["ClientAssigneeId"]);
  102. objRequest.RCQuestionId = Convert.ToInt32(dtchild.Rows[m]["RCQuestionId"]);
  103. objRequest.ErrorDetails = Convert.ToString(dtchild.Rows[m]["ErrorDetails"]);
  104. objRequest.RequestId = Convert.ToInt32(dtchild.Rows[m]["RequestId"]);
  105. objRequest.AssigneeName = dtchild.Rows[m]["AssigneeName"].ToString();
  106. objRequest.RequestedBy = dtchild.Rows[m]["RequestedBy"].ToString();
  107. objRequest.RequestedById = Convert.ToInt32(dtchild.Rows[m]["RequestedById"]);
  108. objRequest.EmailId = dtchild.Rows[m]["EmailId"].ToString();
  109. RequestList.Add(objRequest);
  110. }
  111. objParent.Requestlist = RequestList;
  112. }
  113. else if (objParent.RequestType == "BUEORGSITR")
  114. {
  115. List<ProcessQueueRequest> RequestList = new List<ProcessQueueRequest>();
  116. if (ds.Tables[2].Select("ComputationQueueId = " + objParent.QueueId).Count() > 0)
  117. {
  118. DataTable dtchild = ds.Tables[2].Select("ComputationQueueId = " + objParent.QueueId).CopyToDataTable();
  119. for (int m = 0; m < dtchild.Rows.Count; m++)
  120. {
  121. ProcessQueueRequest objRequest = new ProcessQueueRequest();
  122. objRequest.QueueId = Convert.ToInt32(dtchild.Rows[m]["ComputationQueueId"]);
  123. objRequest.Status = dtchild.Rows[m]["Status"].ToString();
  124. objRequest.RequestType = objParent.RequestType;
  125. objRequest.ZipName = Convert.ToString(dtchild.Rows[m]["ZipName"]);
  126. objRequest.RequestId = Convert.ToInt32(dtchild.Rows[m]["RequestId"]);
  127. objRequest.RequestedBy = dtchild.Rows[m]["RequestedBy"].ToString();
  128. objRequest.RequestedById = Convert.ToInt32(dtchild.Rows[m]["RequestedById"]);
  129. objParent.TotalRequests = 1;
  130. RequestList.Add(objRequest);
  131. }
  132. }
  133. objParent.Requestlist = RequestList;
  134. }
  135. if (ds.Tables.Count > 2)
  136. {
  137. DataTable dtClient1 = ds.Tables[3].Select("ComputationQueueId = " + objParent.QueueId).CopyToDataTable();
  138. objParent.ClientName = dtClient1.Rows[0]["ClientName"].ToString();
  139. }
  140.  
  141. ProcessQueueList.Add(objParent);
  142. }
  143. }
  144. }
  145. return ProcessQueueList;
  146. }
  147.  
  148. var FailedCount = rowParent.Requestlist.Where(p => p.Status == "Failed").ToList().Count;
  149. var CompletedCount = rowParent.Requestlist.Where(p => p.Status == "Completed").ToList().Count;
  150. var CancelledCount = rowParent.Requestlist.Where(p => p.Status == "Cancelled").ToList().Count;
  151. if (FailedCount > 0)
  152. rowParent.FailedRequests = FailedCount;
  153.  
  154. if (CompletedCount > 0)
  155. rowParent.CompletedRequests = CompletedCount;
  156.  
  157. if (CancelledCount > 0)
  158. rowParent.CancelledRequests = CancelledCount;
  159.  
  160. var TotalCount = rowParent.TotalRequests;
  161. rowParent.InProgressRequests = rowParent.Requestlist.Where(p => p.Status == "InProgress").ToList().Count;
  162.  
  163. list = JsonConvert.SerializeObject(BulkQueuelist);
  164. cache.StringSetAsync("ProcessQueue", list).Wait();
  165.  
  166. UpdateProcessQueue(rowParent);
  167.  
  168. #endregion
  169. }
  170. else if (rowParent != null && rowParent.RequestType == "EXTSCPITR")
  171. {
  172. #region SAT
  173. if (rowParent != null)
  174. {
  175. var rowChild = rowParent.Requestlist.Where(p => p.RequestId == RequestId).FirstOrDefault();
  176. if (rowChild != null)
  177. {
  178. rowChild.Status = Status;
  179. rowChild.ErrorDetails = ErrorDetails;
  180. }
  181. //rowParent.Status = Status;
  182. if (Status == "Completed")
  183. {
  184. rowParent.CompletedRequests = rowParent.CompletedRequests + 1;
  185. rowParent.InProgressRequests = rowParent.InProgressRequests - 1;
  186. }
  187. else
  188. {
  189. rowParent.FailedRequests = rowParent.FailedRequests + 1;
  190. rowParent.InProgressRequests = rowParent.InProgressRequests - 1;
  191. }
  192.  
  193. list = JsonConvert.SerializeObject(BulkQueuelist);
  194. cache.StringSetAsync("ProcessQueue", list).Wait();
  195.  
  196. UpdateProcessQueue(rowParent);
  197. }
  198. #endregion
  199. }
  200. else if (rowParent != null && (rowParent.RequestType == "ExcelOrganiser" || rowParent.RequestType == "BUEORGSITR"))
  201. {
  202. #region Excel Organiser
  203. if (rowParent != null)
  204. {
  205. var rowChild = rowParent.Requestlist.Where(p => p.RequestId == RequestId).FirstOrDefault();
  206. if (rowChild != null)
  207. {
  208. rowChild.Status = Status;
  209. rowChild.ErrorDetails = ErrorDetails;
  210. }
  211.  
  212. if (Status == "Completed")
  213. {
  214. rowParent.CompletedRequests = rowParent.CompletedRequests + 1;
  215. rowParent.InProgressRequests = rowParent.InProgressRequests - 1;
  216. }
  217. else
  218. {
  219. rowParent.FailedRequests = rowParent.FailedRequests + 1;
  220. rowParent.InProgressRequests = rowParent.InProgressRequests - 1;
  221. }
  222.  
  223. list = JsonConvert.SerializeObject(BulkQueuelist);
  224. cache.StringSetAsync("ProcessQueue", list).Wait();
  225.  
  226. UpdateProcessQueue(rowParent);
  227. }
  228. #endregion
  229. }
  230. return BulkQueuelist;
  231. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!