Browse Source

同步数据

田爽 3 months ago
parent
commit
1035b904f2
6 changed files with 28 additions and 25 deletions
  1. 4 4
      App.config
  2. 3 3
      Joint/Delay.cs
  3. 13 10
      Joint/Order.cs
  4. 1 1
      Joint/Public.cs
  5. 5 5
      Joint/Visit.cs
  6. 2 2
      Joint/Workflow.cs

+ 4 - 4
App.config

@@ -1,14 +1,14 @@
 <?xml version="1.0" encoding="utf-8" ?>
 <configuration>
   <appSettings>
-    <!--<add key ="SQLServerDB" value="server=10.10.110.195;database=CityHotline_Web;uid=CityHotlineUser_V3;pwd=F123456aA;"/>
-    <add key ="PGSQLDB" value="Server=110.188.24.182;Port=5432;UserId=dev;Password=fengwo11!!;Database=hotline_dev;"/>-->
+    <add key ="SQLServerDB" value="server=10.10.110.195;database=CityHotline_Ver3;uid=CityHotlineUser_V3;pwd=F123456aA;"/>
+    <add key ="PGSQLDB" value="Server=110.188.24.182;Port=5432;UserId=dev;Password=fengwo11!!;Database=hotline;"/>
     <!--宜宾-->
     <!--<add key ="SQLServerDB" value="server=172.15.28.10,4666;database=CityHotline_Ver3;uid=CityHotlineUser;pwd=yb12345#@!;"/>
     <add key ="PGSQLDB" value="Server=100.122.1.9;Port=5432;UserId=fwkjyibin;Password=Fwkj2023##!!**;Database=hotline;"/>-->
     <!--自贡-->
-    <add key ="SQLServerDB" value="server=61.157.186.3,4368;database=ZG_CityHotline_Ver3;uid=ZGCityHotlineUser;pwd=fway09!@ZG_15;"/>
-    <add key ="PGSQLDB" value="Server=110.188.24.182;Port=5432;UserId=dev;Password=fengwo11!!;Database=hotline_zg;"/>
+    <!--<add key ="SQLServerDB" value="server=61.157.186.3,4368;database=ZG_CityHotline_Ver3;uid=ZGCityHotlineUser;pwd=fway09!@ZG_15;"/>
+    <add key ="PGSQLDB" value="Server=110.188.24.182;Port=5432;UserId=dev;Password=fengwo11!!;Database=hotline_zg;"/>-->
     <!--泸州-->
     <!--<add key ="SQLServerDB" value="server=172.20.200.11,4433;database=CityHotline_Ver3;uid=HotlineUser_Ver3;pwd=lzs12345aA!@#;"/>
     <add key ="PGSQLDB" value="Server=110.188.24.182;Port=5432;UserId=dev;Password=fengwo11!!;Database=hotline_lz;"/>-->

+ 3 - 3
Joint/Delay.cs

@@ -32,7 +32,7 @@ namespace DataTransmission.Joint
 				model.InitId();
 				model.No = row["FSH_Code"].ToString().Trim();
 				model.OrderId = orderId;
-				model.ApplyDelayTime = DateTime.Parse(delay["FPE_FPDate"].ToString());
+				model.ApplyDelayTime = Convert.ToDateTime(delay["FPE_FPDate"]);
 				model.ApplyOrgCode = delay["FPE_BMID"].ToString().ToString();
 				model.CreatorOrgId = model.ApplyOrgCode;
 				if (applyOrg != null) {
@@ -54,9 +54,9 @@ namespace DataTransmission.Joint
 				}
 				model.DelayNum = int.Parse(delay["FPE_SLimits"].ToString());
 				model.DelayReason = delay["FPE_Reson"].ToString();
-				model.AfterDelay = DateTime.Parse(delay["FPE_STTime"].ToString());
+				model.AfterDelay = Convert.ToDateTime(delay["FPE_FPDate"]);
 				model.DelayState = (Enum.EDelayState)int.Parse(delay["FPE_AuditFlag"].ToString());
-				model.CreationTime = DateTime.Parse(delay["FPE_FPDate"].ToString());
+				model.CreationTime = Convert.ToDateTime(delay["FPE_FPDate"]);
 
 				if (delayNum == 0)
 				{

+ 13 - 10
Joint/Order.cs

@@ -15,7 +15,10 @@ namespace DataTransmission.Joint
 		public DataTable GetOrder( string st_time, string end_time) {
 			var conn = tool.GetConSqlServer();
 			//获取工单数据
-			var orderSql = $@"SELECT ROW_NUMBER() OVER (ORDER BY FSH_FlowID) AS Serial, CHPRCI.RCI_FlowID,*,REPLACE(CAST(FCT.FCT_Content  AS NVARCHAR(MAX)),CHAR(13)+CHAR(10), '') 受理内容,REPLACE(CAST(ISNULL(FTC2.FTC_RRemark,FTRB.FTRB_RRemark) AS NVARCHAR(MAX)),CHAR(13)+CHAR(10), '')  承办意见 
+			var orderSql = $@"SELECT ROW_NUMBER() OVER (ORDER BY FSH_FlowID) AS Serial, CHPRCI.RCI_FlowID,*,REPLACE(CAST(FCT.FCT_Content  AS NVARCHAR(MAX)),CHAR(13)+CHAR(10), '') 受理内容,
+			CASE WHEN ISNULL(FSH_DisposeDate, GETDATE())  > FSH_TTime THEN '超期' WHEN ISNULL(FSH_DisposeDate, GETDATE()) > FSH_EightyTTime THEN '即将超期' ELSE '正常' END AS FSH_OverTimeState,
+			REPLACE(REPLACE(FSH_Title, '</font>', ''), '<font color=mediumorchid>', '') AS FSH_Title_ys,
+			REPLACE(CAST(ISNULL(FTC2.FTC_RRemark,FTRB.FTRB_RRemark) AS NVARCHAR(MAX)),CHAR(13)+CHAR(10), '')  承办意见 
 				FROM  dbo.Flow03_Search   FSH
 				LEFT JOIN  Flow02_From FRM ON FSH.FSH_FromID = FRM.FFM_FromID
 				LEFT JOIN  dbo.Flow05_LinkMan  FLM ON FSH.FSH_FlowID = FLM.FLM_FlowID
@@ -28,8 +31,8 @@ namespace DataTransmission.Joint
 				LEFT JOIN Flow_Transfer02_Content FTC2 WITH(NOLOCK) ON FTC2.FTC_RunID = FTS.FTS_RunID
 				LEFT JOIN Flow_Transfer01_RunBackups FTRB WITH(NOLOCK) ON  FTS.FTS_RunID =FTRB.FTRB_RunID
 				LEFT JOIN  CityHotline_Province.dbo.receive_case_info CHPRCI ON CHPRCI.RCI_FlowID = FSH.FSH_FlowID
-				WHERE FSH_AddDate >= '{st_time}' AND FSH_AddDate <= '{end_time}' AND  ISNULL(FAL.FALT_ListID,0) > 0 AND FAL.FALT_AppFlag ='1' ";
-			//AND FSH.FSH_Code = '202309190017'
+				WHERE FSH_AddDate >= '{st_time}' AND FSH_AddDate <= '{end_time}' AND  ISNULL(FAL.FALT_ListID,0) > 0 AND FAL.FALT_AppFlag ='1' AND FSH.FSH_Code = '202409240002' ";
+			//AND FSH.FSH_Code = '202409240002'
 			return tool.GetDataTable(orderSql, conn);
 		}
 
@@ -72,14 +75,14 @@ namespace DataTransmission.Joint
 			order.PushTypeCode = row["FSH_PushType"].ToString();
 			order.Content = row["受理内容"].ToString();
 			order.Status =  Enum.EOrderStatus.Visited;
-			order.StartTime = DateTime.Parse(row["FSH_AddDate"].ToString());
-			order.ExpiredTime = DateTime.Parse(row["FSH_TTime"].ToString());
-			order.FiledTime = DateTime.Parse(row["FSH_DisposeDate"].ToString());
+			order.StartTime = Convert.ToDateTime(row["FSH_AddDate"]) ;
+			order.ExpiredTime = Convert.ToDateTime(row["FSH_TTime"])   ;
+			order.FiledTime = Convert.ToDateTime(row["FSH_DisposeDate"])  ;
 			order.ExpiredStatus =  (Enum.EExpiredStatus)ExpiredStatus;
 			order.AreaCode = row["SA_AreaCode"].ToString();
 			order.Street = row["FLM_LKAddress"].ToString();
 			order.IsDeleted = false;
-			order.CreationTime = DateTime.Parse(row["FSH_AddDate"].ToString());
+			order.CreationTime = Convert.ToDateTime(row["FSH_AddDate"])   ;
 			order.SmsSended = false;
 			order.ProcessType = row["FSH_AcceptBMID"].ToString() == Form1.CenterId ? Enum.EProcessType.Zhiban : Enum.EProcessType.Jiaoban;
 			order.IsPublicity = row["FSH_IsPublic"].ToString() == "1"; //0:不公开 ;1:公开 12345在线传递过来的状态
@@ -112,7 +115,7 @@ namespace DataTransmission.Joint
 			order.TimeLimitCount = int.Parse(row["FTRB_TLimits"].ToString());
 			order.TimeLimit = order.TimeLimitCount + "个工作日";
 			order.AcceptTypeCode = GetAcceptTypeCode(row["FSH_PurTypeName"].ToString());
-			order.NearlyExpiredTime = DateTime.Parse(row["FSH_EightyTTime"].ToString());
+			order.NearlyExpiredTime = Convert.ToDateTime(row["FSH_EightyTTime"]) ;
 			order.Password = row["FED_ReultPWD"].ToString();
 			order.ProvinceNo = row["FSH_ProCode"].ToString();
 			order.IsUrgent = row["FSH_Urgent"].ToString() == "1";
@@ -135,7 +138,7 @@ namespace DataTransmission.Joint
 						""AcceptTypeCode"", ""Additions"", ""CreatorOrgName"", 
 						""CreatorName"",""FlowedOrgIds"", ""FlowedUserIds"", ""CreatorOrgLevel"", ""ProvinceNo"", ""ExternalId"", ""Password"",
 						""SignerId"", ""SignerName"", 
-						""City"", ""Source"",""IsResolved"",""IsFormalistWorkOrder"",""IsSensitiveWorkOrders"",""IsUrgent"",""IsProvinceZmhd""
+						""City"", ""Source"",""IsResolved"",""IsFormalistWorkOrder"",""IsSensitiveWorkOrders"",""IsUrgent"",""IsProvinceZmhd"",
 						""EventCategoryExternal"",""NearlyExpiredTime"", ""CsActualHandleOrgIds"", ""CsActualHandleUserIds"", ""HandlerUsers"", ""HandlerOrgs"",
 						""Is24HoursComplete"",""IsThreePartyConference"",""IsEvasive"",""IsInactively"",""IsStepUrgent"",""OldOrderId""
 						) VALUES (
@@ -152,7 +155,7 @@ namespace DataTransmission.Joint
 						 '{order.AcceptTypeCode}', '[]', '{order.AcceptorOrgName}',
 						'{order.AcceptorName}', '[""001""]', '[]', 1, '{order.ProvinceNo}', NULL, '{order.Password}',
 						'{order.AcceptorId}', '{order.AcceptorName}',
-						'{Form1.Name}','0','t','f','f','{order.IsUrgent.ToString()}','f'
+						'{Form1.Name}','0','t','f','f','{order.IsUrgent.ToString()}','f',
 						'19', '{order.NearlyExpiredTime.ToString()}', '[]', '[]', '[]', '[]',
 						'f','f','f','f','f','{order.OldOrderId}');";
 			return pgOrderSql;

+ 1 - 1
Joint/Public.cs

@@ -39,7 +39,7 @@ namespace DataTransmission.Joint
 				model.ArrangeOpinion = item["FPIA_Result"].ToString();
 				//model.ProPublishState = item["FPLT_PubFlag"].ToString() == "2" 
 				model.FeedBackPhone = item["FSH_LinkTel"].ToString();
-				model.CreationTime = DateTime.Parse(item["FPLT_PubDate"].ToString());
+				model.CreationTime = Convert.ToDateTime(item["FPLT_PubDate"]);
 				model.OrderId = orderId;
 				if (creatorOrg != null) {
 					model.CreatorOrgId = creatorOrg["Id"].ToString();

+ 5 - 5
Joint/Visit.cs

@@ -51,10 +51,10 @@ namespace DataTransmission.Joint
 					visit.Id = VisitId;
 					visit.No = row["FSH_Code"].ToString().Trim();
 					visit.OrderId = orderId;
-					visit.PublishTime = DateTime.Parse(item["FPLT_PubDate"].ToString());
+					visit.PublishTime = Convert.ToDateTime(item["FPLT_PubDate"]);
 					visit.EmployeeId = EmployeeId;
-					visit.VisitTime = DateTime.Parse(item["FALT_CallDate"].ToString());
-					visit.CreationTime = DateTime.Parse(item["FALT_InsertDate"].ToString());
+					visit.VisitTime = Convert.ToDateTime(item["FALT_CallDate"]);
+					visit.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
 					visit.CreatorId = row["FALT_InsertUserID"].ToString();
 					if (creator != null)
 					{
@@ -85,7 +85,7 @@ namespace DataTransmission.Joint
 
 					seatDetail.InitId();
 					seatDetail.VisitId = visit.Id;
-					seatDetail.CreationTime = DateTime.Parse(item["FALT_InsertDate"].ToString());
+					seatDetail.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
 
 
 					//明细表
@@ -99,7 +99,7 @@ namespace DataTransmission.Joint
 				Entity.OrderVisitDetail bmDetail = new Entity.OrderVisitDetail();
 				bmDetail.InitId();
 				bmDetail.VisitId = visit.Id;
-				bmDetail.CreationTime = DateTime.Parse(item["FALT_InsertDate"].ToString());
+				bmDetail.CreationTime = Convert.ToDateTime(item["FALT_InsertDate"]);
 
 				var OrgNoSatisfiedReason = "NULL";
 				if ((item["FALT_AppTypeName"].ToString() == "非常不满意" || item["FALT_AppTypeName"].ToString() == "不满意") && !string.IsNullOrEmpty(item["SDICT_Name"].ToString()))

+ 2 - 2
Joint/Workflow.cs

@@ -136,7 +136,7 @@ namespace DataTransmission.Joint
 				step.AcceptorOrgAreaCode = acceptorOrg["AreaCode"].ToString();
 				step.AcceptorOrgAreaName = acceptorOrg["AreaName"].ToString();
 			}
-			step.AcceptTime = DateTime.Parse(item["FTRB_APDate"].ToString());
+			step.AcceptTime = string.IsNullOrEmpty(item["FTRB_APDate"].ToString()) ? null : DateTime.Parse(item["FTRB_APDate"].ToString());
 			step.HandlerId = item["FTRB_UserID"].ToString();
 			if (handler != null)
 			{
@@ -188,7 +188,7 @@ namespace DataTransmission.Joint
 			VALUES ('{step.Id}', '[]', '{step.PrevStepId}', '{step.PrevStepCode}', 'f', 2, 'f', NULL, 0,
 			'f', NULL, 'f', NULL, '{workflow.Id}', 1, '[]', NULL,
 			'{step.AcceptorId}', '{step.AcceptorName}', '{step.AcceptorOrgId}', '{step.AcceptorOrgName}', '{step.AcceptorOrgAreaCode}', '{step.AcceptorOrgAreaName}', '{step.AcceptTime.ToString()}', '{step.HandlerId}', '{step.HandlerName}', '{step.HandlerOrgId}',
-			'{step.HandlerOrgIsCenter.ToString()}', '{step.HandlerOrgName}', {step.HandlerOrgAreaCode}, '{step.HandlerOrgAreaName}', '{step.HandleTime.ToString()}', '{step.Name}', '', {(int)step.StepType},
+			'{step.HandlerOrgIsCenter.ToString()}', '{step.HandlerOrgName}', '{step.HandlerOrgAreaCode}', '{step.HandlerOrgAreaName}', '{step.HandleTime.ToString()}', '{step.Name}', '', {(int)step.StepType},
 			{(int)step.BusinessType}, 3, 'f', 0, 'f', '[]', 'f', 'f', '{step.Opinion}', '{step.StepExpiredTime.ToString()}',
 			'f', '{step.CreationTime.ToString()}', '{step.CreatorId}', '{step.CreatorName}', '{step.CreatorOrgId}', '{step.CreatorOrgName}', {step.CreatorOrgLevel}, '{step.AreaId}', NULL, NULL, 
 			'f', '{workflow.ModuleId}', '{workflow.ModuleName}', '{workflow.ModuleCode}', 0, '[]', '{step.ExternalId}',  '', '{step.CreatorId}', '{step.CreatorName}', '{step.CreatorOrgId}', '{step.CreatorOrgName}', '{step.AssignerOrgIsCenter.ToString()}', 0, 0);";