biz_deleteBatch.cs 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.IO;
  7. using Newtonsoft.Json;
  8. using Saraff.Twain;
  9. using HXX.Scanner.Socket;
  10. using HXX.Scanner.Common;
  11. namespace HXX.Scanner.Biz.Socket
  12. {
  13. /// <summary>
  14. /// 业务处理 获取未上传图片列表
  15. /// </summary>
  16. public class biz_deleteBatch
  17. {
  18. /// <summary>
  19. /// 主业务
  20. /// </summary>
  21. /// <param name="connId"></param>
  22. /// <param name="data"></param>
  23. public static void Work(IntPtr connId, cmd_deleteBatch data)
  24. {
  25. var response = new response_deleteBatch()
  26. {
  27. subjectCode = data.subjectCode,
  28. batchNumber = data.batchNumber,
  29. msg = "ok"
  30. };
  31. try
  32. {
  33. var db_list = new biz_db().get_by_subjectCode_batchNumber(data.subjectCode, data.batchNumber);
  34. bool totalSuccess = false;
  35. //List<string> done_list = new List<string>();
  36. foreach (var entity in db_list)
  37. {
  38. var info = new DirectoryInfo(Path.GetDirectoryName(entity.fi_full_name));
  39. var source_path = info.Parent.FullName;
  40. var target_path = Path.Combine(info.Parent.Parent.FullName, @"delete\" + entity.fi_batchSeq);
  41. if (!Directory.Exists(target_path))
  42. {
  43. Directory.CreateDirectory(target_path);
  44. }
  45. if (Directory.Exists(source_path))
  46. {
  47. DirCopy.CopyDirectory(source_path, target_path, OverwriteStrategy.Overwrite);
  48. Directory.Delete(source_path, true);
  49. totalSuccess = true;
  50. break;
  51. }
  52. }
  53. if (totalSuccess)
  54. {
  55. new biz_db().deleteBatch(data.subjectCode, data.batchNumber);
  56. response.database_delete_number = db_list.Count;
  57. }
  58. }
  59. catch (Exception ee)
  60. {
  61. response.code = 500;
  62. response.msg = ee.Message;
  63. }
  64. SocketServerManager.Send_Single(connId, response.ToJson());
  65. }
  66. ///// <summary>
  67. ///// 主业务
  68. ///// </summary>
  69. ///// <param name="connId"></param>
  70. ///// <param name="data"></param>
  71. //public static void Work(IntPtr connId, cmd_deleteBatch data)
  72. //{
  73. // var response = new response_deleteBatch()
  74. // {
  75. // subjectCode = data.subjectCode,
  76. // batchNumber = data.batchNumber,
  77. // msg = "ok"
  78. // };
  79. // var db_list = new biz_db().get_by_subjectCode_batchNumber(data.subjectCode, data.batchNumber);
  80. // try
  81. // {
  82. // var totalSuccess = true;
  83. // foreach (var entity in db_list)
  84. // {
  85. // var fileName = Path.GetFileName(entity.fi_full_name);
  86. // var source_path = Path.GetDirectoryName(entity.fi_full_name);
  87. // var info = new DirectoryInfo(source_path);
  88. // var p = info.Parent.Parent;
  89. // source_path = p.FullName;
  90. // var target_path = Path.Combine(p.Parent.FullName, "delete");
  91. // //var target_path = Path.GetFullPath(source_path).TrimEnd(Path.DirectorySeparatorChar);
  92. // //var L1 = Path.GetFileName(target_path);
  93. // //var L2 = Path.GetFileName(Path.GetDirectoryName(target_path));
  94. // //path = path.Replace("ready", "delete");
  95. // //path = path.Replace("complete", "delete");
  96. // //fileName = Path.Combine(path, fileName);
  97. // //try
  98. // //{
  99. // // if (!Directory.Exists(path))
  100. // // {
  101. // // Directory.CreateDirectory(path);
  102. // // }
  103. // // if (File.Exists(fileName))
  104. // // {
  105. // // File.Delete(fileName);
  106. // // }
  107. // // if (File.Exists(entity.fi_full_name))
  108. // // {
  109. // // File.Move(entity.fi_full_name, fileName);
  110. // // response.picture_moved_number++;
  111. // // }
  112. // //}
  113. // //catch (Exception e1)
  114. // //{
  115. // // totalSuccess = false;
  116. // // LogManager.WriteLog(e1.Message);
  117. // // response_error error = new response_error(e1.Message);
  118. // // response.code = 500;
  119. // // response.msg = e1.Message;
  120. // // break;
  121. // //}
  122. // }
  123. // if (totalSuccess)
  124. // {
  125. // new biz_db().deleteBatch(data.subjectCode, data.batchNumber);
  126. // response.database_delete_number = db_list.Count;
  127. // }
  128. // }
  129. // catch (Exception ee)
  130. // {
  131. // response.code = 500;
  132. // response.msg = ee.Message;
  133. // }
  134. // //SocketServerManager.Send_Family(connId, response.ToJson());
  135. // SocketServerManager.Send_Single(connId, response.ToJson());
  136. //}
  137. }
  138. }