SaveMattressAuditingExcutor.cs 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Data.SqlClient;
  4. using System.Linq;
  5. using System.Text;
  6. using JLHHJSvr.BLL;
  7. using JLHHJSvr.Com;
  8. using JLHHJSvr.Com.Model;
  9. using JLHHJSvr.LJException;
  10. using JLHHJSvr.Tools;
  11. using LJLib.DAL.SQL;
  12. using LJLib.Net.SPI.Server;
  13. namespace JLHHJSvr.Excutor
  14. {
  15. internal sealed class SaveMattressAuditingExcutor : ExcutorBase<SaveMattressAuditingRequest, SaveMattressAuditingResponse>
  16. {
  17. protected override void ExcuteInternal(SaveMattressAuditingRequest request, object state, SaveMattressAuditingResponse rslt)
  18. {
  19. var tokendata = BllHelper.GetToken(request.token);
  20. if (tokendata == null)
  21. {
  22. rslt.ErrMsg = "会话已经中断,请重新登录";
  23. return;
  24. }
  25. using (var con = new SqlConnection(GlobalVar.ConnectionString))
  26. using (var cmd = con.CreateCommand())
  27. {
  28. con.Open();
  29. // 初始化属性
  30. //AutoInit.AutoInitS(cmd, request.mattress);
  31. using (cmd.Transaction = con.BeginTransaction())
  32. {
  33. try
  34. {
  35. // 只处理主规格
  36. Dictionary<int, u_mattress> mattressDic = new Dictionary<int, u_mattress>();
  37. foreach (int itemid in request.mattressids)
  38. {
  39. var mattressInfo = new u_mattress() { mattressid = itemid };
  40. if (DbSqlHelper.SelectOne(cmd, mattressInfo, "flag, xd_flag, yw_flag, mattresscode, parentid") != 1)
  41. {
  42. rslt.ErrMsg = "查找报价单据失败:" + itemid;
  43. return;
  44. }
  45. //if (mattressInfo.parentid > 0)
  46. //{
  47. // mattressInfo = new u_mattress() { mattressid = mattressInfo.parentid.Value };
  48. // if (DbSqlHelper.SelectOne(cmd, mattressInfo, "flag, xd_flag, parentid") != 1)
  49. // {
  50. // rslt.ErrMsg = "查找报价单据失败:" + itemid;
  51. // return;
  52. // }
  53. //}
  54. if (!mattressDic.ContainsKey(mattressInfo.mattressid))
  55. {
  56. mattressDic.Add(mattressInfo.mattressid, mattressInfo);
  57. }
  58. }
  59. if (request.xd_flag != null)
  60. {
  61. // 业务下单/取消
  62. var power94 = UserHelper.CheckFuncPower(cmd, tokendata.empid, 94);
  63. if (!power94 && request.xd_flag == 1)
  64. {
  65. throw new LJCommonException("你没有业务下单权限");
  66. }
  67. var power95 = UserHelper.CheckFuncPower(cmd, tokendata.empid, 95);
  68. if (!power95 && request.xd_flag == 0)
  69. {
  70. throw new LJCommonException("你没有取消业务下单权限");
  71. }
  72. var updateField = "xd_flag, xd_auditingrep, xd_auditingdate";
  73. foreach (var item in mattressDic)
  74. {
  75. var mattressInfo = item.Value;
  76. if (request.xd_flag == 1)
  77. {
  78. if (mattressInfo.flag == 1)
  79. {
  80. rslt.ErrMsg = "床垫已审核,不能业务下单!(" + mattressInfo.mattresscode + ")";
  81. return;
  82. }
  83. if (mattressInfo.xd_flag == 1)
  84. {
  85. rslt.ErrMsg = "床垫已完成业务下单(" + mattressInfo.mattresscode + ")";
  86. return;
  87. }
  88. mattressInfo.xd_flag = 1;
  89. mattressInfo.xd_auditingrep = tokendata.username;
  90. mattressInfo.xd_auditingdate = DateTime.Now;
  91. if (DbSqlHelper.Update(cmd, "u_mattress", null, mattressInfo, "mattressid", updateField) <= 0)
  92. {
  93. throw new LJCommonException("因网络或其它原因,【业务下单/取消】操作失败!");
  94. }
  95. //UpdateChildState(cmd, mattressInfo, "xd_flag", 1);
  96. }
  97. else
  98. {
  99. if (mattressInfo.js1_flag == 1)
  100. {
  101. rslt.ErrMsg = "已产品补充审核,不能取消下单!(" + mattressInfo.mattresscode + ")";
  102. return;
  103. }
  104. if (mattressInfo.xd_flag == 0)
  105. {
  106. rslt.ErrMsg = "未进行业务下单,不能取消下单!(" + mattressInfo.mattresscode + ")";
  107. return;
  108. }
  109. if (mattressInfo.yw_flag == 1)
  110. {
  111. rslt.ErrMsg = "床垫清单已业务补充审核,不能取消下单!(" + mattressInfo.mattresscode + ")";
  112. return;
  113. }
  114. mattressInfo.xd_flag = 0;
  115. mattressInfo.xd_auditingrep = "";
  116. mattressInfo.xd_auditingdate = null;
  117. if (DbSqlHelper.Update(cmd, "u_mattress", null, mattressInfo, "mattressid", updateField) <= 0)
  118. {
  119. throw new LJCommonException("因网络或其它原因,【业务下单/取消】操作失败!");
  120. }
  121. //UpdateChildState(cmd, mattressInfo, "xd_flag", 0);
  122. }
  123. }
  124. }
  125. else if (request.flag != null)
  126. {
  127. // 审核
  128. var power73 = UserHelper.CheckFuncPower(cmd, tokendata.empid, 73);
  129. if (!power73 && request.flag == 1)
  130. {
  131. throw new LJCommonException("你没有审核权限");
  132. }
  133. var power74 = UserHelper.CheckFuncPower(cmd, tokendata.empid, 74);
  134. if (!power74 && request.flag == 0)
  135. {
  136. throw new LJCommonException("你没有取消审核权限");
  137. }
  138. var updateField = "flag, auditingrep, auditingdate";
  139. foreach (var item in mattressDic)
  140. {
  141. var mattressInfo = item.Value;
  142. if (request.flag == 1)
  143. {
  144. if (mattressInfo.flag == 1)
  145. {
  146. rslt.ErrMsg = "床报价已完成审核(" + mattressInfo.mattresscode + ")";
  147. return;
  148. }
  149. mattressInfo.flag = 1;
  150. mattressInfo.auditingrep = tokendata.username;
  151. mattressInfo.auditingdate = DateTime.Now;
  152. if (DbSqlHelper.Update(cmd, "u_mattress", null, mattressInfo, "mattressid", updateField) <= 0)
  153. {
  154. throw new LJCommonException("因网络或其它原因,【审核消】操作失败!");
  155. }
  156. //UpdateChildState(cmd, mattressInfo, "flag", 1);
  157. }
  158. else
  159. {
  160. if (mattressInfo.flag == 0)
  161. {
  162. rslt.ErrMsg = "床报价已完成撤销审核!(" + mattressInfo.mattresscode + ")";
  163. return;
  164. }
  165. mattressInfo.flag = 0;
  166. mattressInfo.auditingrep = "";
  167. mattressInfo.auditingdate = null;
  168. if (DbSqlHelper.Update(cmd, "u_mattress", null, mattressInfo, "mattressid", updateField) <= 0)
  169. {
  170. throw new LJCommonException("因网络或其它原因,【撤销审核】操作失败!");
  171. }
  172. //UpdateChildState(cmd, mattressInfo, "flag", 0);
  173. }
  174. }
  175. }
  176. cmd.Transaction.Commit();
  177. }
  178. catch (Exception e)
  179. {
  180. cmd.Transaction.Rollback();
  181. rslt.ErrMsg = e.ToString();
  182. }
  183. }
  184. }
  185. }
  186. public void UpdateChildState(SqlCommand cmd, u_mattress mattress, string fieldStr, int value)
  187. {
  188. var updateStr = "";
  189. var rep = "";
  190. DateTime? date = null;
  191. if (fieldStr == "xd_flag")
  192. {
  193. if (mattress.auditingdate.HasValue)
  194. {
  195. updateStr = @"
  196. xd_auditingrep = @rep,
  197. xd_auditingdate = @date
  198. ";
  199. rep = mattress.xd_auditingrep;
  200. date = mattress.xd_auditingdate;
  201. }
  202. else
  203. {
  204. updateStr = @"
  205. xd_auditingrep = @rep,
  206. xd_auditingdate = null
  207. ";
  208. rep = mattress.xd_auditingrep;
  209. }
  210. } else
  211. {
  212. if (mattress.auditingdate.HasValue)
  213. {
  214. updateStr = @"
  215. auditingrep = @rep,
  216. auditingdate = @date
  217. ";
  218. rep = mattress.auditingrep;
  219. date = mattress.auditingdate;
  220. }
  221. else
  222. {
  223. updateStr = @"
  224. auditingrep = @rep,
  225. auditingdate = null
  226. ";
  227. rep = mattress.auditingrep;
  228. }
  229. }
  230. cmd.CommandText = @"UPDATE u_mattress
  231. SET " + fieldStr + @" = @value,
  232. " + updateStr + @"
  233. FROM u_mattress
  234. WHERE u_mattress.parentid = @mattressid";
  235. cmd.Parameters.Clear();
  236. cmd.Parameters.AddWithValue("@mattressid", mattress.mattressid);
  237. cmd.Parameters.AddWithValue("@value", value);
  238. cmd.Parameters.AddWithValue("@rep", rep);
  239. if (date.HasValue)
  240. {
  241. cmd.Parameters.AddWithValue("@date", date);
  242. }
  243. cmd.ExecuteNonQuery();
  244. }
  245. }
  246. }