Visit.cs 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286
  1. using Abp;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Data;
  5. using System.Linq;
  6. using System.Text;
  7. using System.Threading.Tasks;
  8. namespace DataTransmission.Joint
  9. {
  10. public class Visit
  11. {
  12. private readonly CommonTool tool = new CommonTool();
  13. public DataTable GetVisit(string flowId) {
  14. var conn = tool.GetConSqlServer();
  15. var appraiseSql = $@"SELECT * FROM dbo.Flow18_AppraiseList FA
  16. LEFT JOIN dbo.Flow15_PubList FP ON FA.FALT_FlowID =FP.FPLT_FlowID
  17. LEFT JOIN dbo.Flow18_AppraiseExpand FAE ON FAE.FAED_FALTID = FA.FALT_ListID
  18. LEFT JOIN SYS15_DICT SD ON SD.SDICT_Key='Appraise_DissType' AND SD.SDICT_PID!=0 AND FAE.FAED_DissTypeID = SD.SDICT_ID
  19. LEFT JOIN dbo.SYS09_BMDIR SBM ON FA.FALT_AppBMID = SBM.SBM_ID
  20. WHERE FALT_FlowID = {flowId} AND FA.FALT_AppFlag = 1 ";
  21. return tool.GetDataTable(appraiseSql, conn);
  22. }
  23. public string GetVisitSql(DataTable data,DataRow row,string VisitId, string orderId,DataTable org,DataTable user, Entity.Config config) {
  24. var num = 0;
  25. var pgVisitSql = string.Empty;
  26. var pgVisitDetail = string.Empty;
  27. Entity.OrderVisit visit = new Entity.OrderVisit();
  28. foreach (DataRow item in data.Rows)
  29. {
  30. DataRow ogrRow = org.AsEnumerable().First(x => x.Field<int?>("oldBmid").ToString() == item["FALT_AppBMID"].ToString());
  31. var VisitOrgCode = string.IsNullOrEmpty(ogrRow?["Id"].ToString()) ? item["FALT_AppBMID"].ToString() : ogrRow?["Id"].ToString();
  32. if (num == 0)
  33. {
  34. var EmployeeId = item["FALT_UserID"].ToString();
  35. try
  36. {
  37. DataRow userRow = user.AsEnumerable().First(x => x.Field<int?>("OldUserId").ToString() == item["FALT_UserID"].ToString());
  38. EmployeeId = string.IsNullOrEmpty(userRow?["Id"].ToString()) ? "NULL" : userRow?["Id"].ToString();
  39. }
  40. catch (Exception e)
  41. {
  42. tool.SaveLog(" VisitMessage :" + e.Message + ";" + row["FALT_UserID"].ToString() + " ;", 1);
  43. }
  44. var creator = user.AsEnumerable().FirstOrDefault(x => x.Field<int?>("oldUserId").ToString() == item["FALT_InsertUserID"].ToString());
  45. var creatorOrg = org.AsEnumerable().FirstOrDefault(x => x.Field<string?>("Id").ToString() == creator["OrgId"].ToString());
  46. visit.Id = VisitId;
  47. visit.No = row["FSH_Code"].ToString().Trim();
  48. visit.OrderId = orderId;
  49. visit.PublishTime = Convert.ToDateTime(item["FPLT_PubDate"]);
  50. visit.EmployeeId = EmployeeId;
  51. visit.VisitTime = Convert.ToDateTime(item["FALT_CallDate"]);
  52. visit.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
  53. visit.CreatorId = row["FALT_InsertUserID"].ToString();
  54. if (creator != null)
  55. {
  56. visit.CreatorId = creator["Id"].ToString();
  57. visit.CreatorName = creator["Name"].ToString();
  58. }
  59. if (creatorOrg != null)
  60. {
  61. visit.CreatorOrgId = creatorOrg["Id"].ToString();
  62. visit.CreatorOrgName = creatorOrg["Name"].ToString();
  63. visit.CreatorOrgLevel = int.Parse(creatorOrg["Level"].ToString());
  64. visit.AreaId = creatorOrg["AreaId"].ToString();
  65. //model.AssignerOrgIsCenter = bool.Parse(creatorOrg["IsCenter"].ToString());
  66. }
  67. //主表
  68. pgVisitSql = $@"INSERT INTO ""public"".""order_visit"" (""Id"", ""No"", ""OrderId"", ""VisitState"", ""VisitType"", ""PublishTime"", ""EmployeeId"", ""IsPutThrough"", ""VisitTime"", ""CreationTime"", ""CreatorOrgId"",
  69. ""CreatorId"", ""AreaId"", ""NowEvaluate"", ""AgainState"", ""CreatorOrgName"", ""CreatorName"",
  70. ""CreatorOrgLevel"", ""IsCanHandle"", ""CallId"", ""IsCanAiVisit"", ""FirstVisitTime"", ""LastVisitTime"",""AiVisitCount"") VALUES (
  71. '{visit.Id}', '{visit.No}', '{visit.OrderId}', 30, 10, '{visit.PublishTime.ToString()}', '{visit.EmployeeId}', 't', '{visit.VisitTime}', '{visit.CreationTime}', '{visit.CreatorOrgId}',
  72. '{visit.CreatorId}', '{visit.AreaId}', '{{""Key"":""{GetSatisfaction(item["FALT_AppTypeName"].ToString())}"",""Value"":""{item["FALT_AppTypeName"]}""}}',0, '{visit.CreatorOrgName}', '{visit.CreatorName}',
  73. {visit.CreatorOrgLevel}, 'f', NULL, 'f', '{visit.VisitTime}', '{visit.VisitTime}', 0);";
  74. //var seatsDetailId = SequentialGuidGenerator.Instance.Create().ToString("D");
  75. Entity.OrderVisitDetail seatDetail = new Entity.OrderVisitDetail();
  76. //var creatorDetail = user.AsEnumerable().FirstOrDefault(x => x.Field<int?>("oldUserId").ToString() == item["FALT_InsertUserID"].ToString());
  77. //var creatorDetailOrg = org.AsEnumerable().FirstOrDefault(x => x.Field<int?>("oldBmid").ToString() == creator["OrgId"].ToString());
  78. seatDetail.InitId();
  79. seatDetail.VisitId = visit.Id;
  80. seatDetail.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
  81. //明细表
  82. pgVisitDetail = $@"INSERT INTO ""public"".""order_visit_detail"" (""Id"", ""VisitId"", ""VoiceEvaluate"", ""SeatEvaluate"", ""OrgProcessingResults"", ""OrgNoSatisfiedReason"", ""OrgHandledAttitude"", ""VisitContent"",
  83. ""VisitOrgCode"",""VisitOrgName"", ""CreationTime"", ""CreatorOrgId"", ""CreatorId"", ""AreaId"", ""VisitTarget"", ""CreatorOrgName"", ""CreatorName"", ""CreatorOrgLevel"") VALUES
  84. ('{seatDetail.VisitId}', '{VisitId}', {GetSatisfaction(item["FALT_SeatsTypeName"].ToString())}, {GetSatisfaction(item["FALT_SeatsTypeName"].ToString())}, NULL, NULL,NULL,'{item["FALT_ZxRemark"]}',
  85. NULL,NULL, '{seatDetail.CreationTime.ToString()}', '{visit.CreatorOrgId}', '{visit.CreatorId}', '{visit.AreaId}', 10, '{visit.CreatorOrgName}', '{visit.CreatorName}', {visit.CreatorOrgLevel})";
  86. }
  87. //部门
  88. //var bmDetailId = SequentialGuidGenerator.Instance.Create().ToString("D");
  89. Entity.OrderVisitDetail bmDetail = new Entity.OrderVisitDetail();
  90. bmDetail.InitId();
  91. bmDetail.VisitId = visit.Id;
  92. bmDetail.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
  93. var OrgNoSatisfiedReason = "NULL";
  94. if ((item["FALT_AppTypeName"].ToString() == "非常不满意" || item["FALT_AppTypeName"].ToString() == "不满意") && !string.IsNullOrEmpty(item["SDICT_Name"].ToString()))
  95. {
  96. OrgNoSatisfiedReason = $@" '[{{""Key"":""{GetDissatisfiedReason(item["SDICT_Name"].ToString(),config)}"",""Value"":""{item["SDICT_Name"].ToString()}""}}]'";
  97. }
  98. pgVisitDetail += $@",('{bmDetail.Id}', '{VisitId}', NULL, NULL, '{{""Key"":""{GetSatisfaction(item["FALT_AppTypeName"].ToString())}"",""Value"":""{item["FALT_AppTypeName"]}""}}',{OrgNoSatisfiedReason},
  99. '{{""Key"":""{GetSatisfaction(item["FALT_AppTypeBName"].ToString())}"",""Value"":""{item["FALT_AppTypeBName"]}""}}', '{item["FALT_ZxRemark"]}', '{VisitOrgCode}', '{item["SBM_Name"]}',
  100. '{bmDetail.CreationTime.ToString()}', '{visit.CreatorOrgId}', '{visit.CreatorId}', '{visit.AreaId}', 20, '{visit.CreatorOrgName}', '{visit.CreatorName}', {visit.CreatorOrgLevel})";
  101. num++;
  102. }
  103. pgVisitDetail += ";";
  104. return pgVisitSql + pgVisitDetail;
  105. }
  106. private string GetSatisfaction(string name)
  107. {
  108. var satisfaction = string.Empty;
  109. switch (name)
  110. {
  111. case "非常不满意":
  112. satisfaction = "1";
  113. break;
  114. case "不满意":
  115. satisfaction = "2";
  116. break;
  117. case "一般":
  118. satisfaction = "3";
  119. break;
  120. case "满意":
  121. satisfaction = "4";
  122. break;
  123. case "非常满意":
  124. satisfaction = "5";
  125. break;
  126. case "未接通":
  127. satisfaction = "6";
  128. break;
  129. case "未做评价":
  130. satisfaction = "7";
  131. break;
  132. case "视为满意":
  133. satisfaction = "-1";
  134. break;
  135. case "默认满意":
  136. satisfaction = "0";
  137. break;
  138. default:
  139. satisfaction = "-2";
  140. break;
  141. }
  142. return satisfaction;
  143. }
  144. private string GetDissatisfiedReason(string name, Entity.Config config) {
  145. switch (config.Name)
  146. {
  147. case "宜宾市":
  148. return GetDissatisfiedReason_YB(name);
  149. case "自贡市":
  150. return GetDissatisfiedReason_ZG(name);
  151. case "泸州市":
  152. return GetDissatisfiedReason_LZ(name);
  153. default:
  154. return "";
  155. }
  156. }
  157. private string GetDissatisfiedReason_YB(string name)
  158. {
  159. var dissatisfiedReason = string.Empty;
  160. switch (name)
  161. {
  162. case "回复敷衍":
  163. dissatisfiedReason = "1";
  164. break;
  165. case "办件推诿":
  166. dissatisfiedReason = "2";
  167. break;
  168. case "未有效处理工单问题":
  169. dissatisfiedReason = "3";
  170. break;
  171. case "处理案件力度不够":
  172. dissatisfiedReason = "4";
  173. break;
  174. case "未与市民联系":
  175. dissatisfiedReason = "5";
  176. break;
  177. case "阶段性回复":
  178. dissatisfiedReason = "6";
  179. break;
  180. case "未回复":
  181. dissatisfiedReason = "7";
  182. break;
  183. case "对部门工作人员态度不满意":
  184. dissatisfiedReason = "8";
  185. break;
  186. default:
  187. dissatisfiedReason = "";
  188. break;
  189. }
  190. return dissatisfiedReason;
  191. }
  192. private string GetDissatisfiedReason_ZG(string name)
  193. {
  194. var dissatisfiedReason = string.Empty;
  195. switch (name)
  196. {
  197. case "回复敷衍":
  198. dissatisfiedReason = "1";
  199. break;
  200. case "办件推诿":
  201. dissatisfiedReason = "2";
  202. break;
  203. case "未有效处理工单问题":
  204. dissatisfiedReason = "3";
  205. break;
  206. case "处理案件力度不够,重视程度不高":
  207. dissatisfiedReason = "4";
  208. break;
  209. case "部门回复与市民诉求不一致":
  210. dissatisfiedReason = "5";
  211. break;
  212. case "个人诉求未满足":
  213. dissatisfiedReason = "6";
  214. break;
  215. case "未与市民联系":
  216. dissatisfiedReason = "7";
  217. break;
  218. case "对部门工作人员态度不满意":
  219. dissatisfiedReason = "8";
  220. break;
  221. case "办件时间长":
  222. dissatisfiedReason = "9";
  223. break;
  224. case "阶段性回复":
  225. dissatisfiedReason = "10";
  226. break;
  227. case "其他":
  228. dissatisfiedReason = "11";
  229. break;
  230. default:
  231. dissatisfiedReason = "";
  232. break;
  233. }
  234. return dissatisfiedReason;
  235. }
  236. private string GetDissatisfiedReason_LZ(string name)
  237. {
  238. var dissatisfiedReason = string.Empty;
  239. switch (name)
  240. {
  241. case "回复敷衍":
  242. dissatisfiedReason = "1";
  243. break;
  244. case "办件推诿":
  245. dissatisfiedReason = "2";
  246. break;
  247. case "未有效处理工单问题":
  248. dissatisfiedReason = "3";
  249. break;
  250. case "处理案件力度不够":
  251. dissatisfiedReason = "4";
  252. break;
  253. case "未与市民联系":
  254. dissatisfiedReason = "5";
  255. break;
  256. case "阶段性回复":
  257. dissatisfiedReason = "6";
  258. break;
  259. case "未回复":
  260. dissatisfiedReason = "7";
  261. break;
  262. case "对部门工作人员态度不满意":
  263. dissatisfiedReason = "8";
  264. break;
  265. default:
  266. dissatisfiedReason = "";
  267. break;
  268. }
  269. return dissatisfiedReason;
  270. }
  271. }
  272. }