Merge branch 'master' of http://git.12345lm.cn/Fengwo/data-transfer

Execute.cs

@@ -19,6 +19,7 @@ namespace DataTransmission
         private readonly Organize organize = new Organize();
         private readonly User user = new User();
         private readonly Notice notice = new Notice();
+        private readonly OrderPublic orderPublic  = new OrderPublic();
 
         public void ExecuteSql(DataTable orderTable)
         {
@@ -91,6 +92,26 @@ namespace DataTransmission
             //tool.Execute(pgSql, pgConn);
         }
 
+        /// <summary>
+        /// 同步工单已发布数据
+        /// </summary>
+        /// <param name="stTime"></param>
+        /// <param name="endTime"></param>
+        public void ExecuteInsertOrderPublic(string stTime, string endTime)
+        {
+            var know = orderPublic.GetOldNotice(stTime, endTime);
+            foreach (DataRow item in know.Rows)
+            {
+                var insert = orderPublic.GetNoticeSql(item);
+                if (!string.IsNullOrEmpty(insert))
+                {
+                    var pgConn = tool.GetConPgSql();
+                    // tool.SaveLog("KnowledgeSQL :" + insert + "  ;", 1);
+                    tool.Execute(insert, pgConn);
+                }
+            }
+        }
+
         /// <summary>
         /// 消息通知
         /// </summary>

Form1.Designer.cs

@@ -38,6 +38,7 @@
             cb_user = new CheckBox();
             cb_jg = new CheckBox();
             cb_tz = new CheckBox();
+            cb_opp = new CheckBox();
             SuspendLayout();
             // 
             // st_time
@@ -133,11 +134,22 @@
             cb_tz.Text = "同步通知";
             cb_tz.UseVisualStyleBackColor = true;
             // 
+            // cb_opp
+            // 
+            cb_opp.AutoSize = true;
+            cb_opp.Location = new Point(236, 239);
+            cb_opp.Name = "cb_opp";
+            cb_opp.Size = new Size(99, 21);
+            cb_opp.TabIndex = 10;
+            cb_opp.Text = "同步发布数据";
+            cb_opp.UseVisualStyleBackColor = true;
+            // 
             // Form1
             // 
             AutoScaleDimensions = new SizeF(7F, 17F);
             AutoScaleMode = AutoScaleMode.Font;
             ClientSize = new Size(403, 301);
+            Controls.Add(cb_opp);
             Controls.Add(cb_tz);
             Controls.Add(cb_jg);
             Controls.Add(cb_user);
@@ -166,5 +178,6 @@
 		private CheckBox cb_user;
 		private CheckBox cb_jg;
         private CheckBox cb_tz;
+        private CheckBox cb_opp;
     }
 }

Form1.cs

@@ -20,6 +20,11 @@ namespace DataTransmission
         private void btn_tb_Click(object sender, EventArgs e)
         {
             btn_tb.Enabled = false;
+            if (cb_opp.Enabled)
+            {//ͬ²½¹¤µ¥·¢²¼¹«¿ªÊý¾ÝExecuteInsertOrderPublic
+                execute.ExecuteInsertOrderPublic(st_time.Value.ToString("yyyy-MM-dd") + " 00:00:00", end_time.Value.ToString("yyyy-MM-dd") + " 23:59:59");
+            }
+
             if (cb_tz.Checked)
             {
                 execute.ExecuteInsertNotice(st_time.Value.ToString("yyyy-MM-dd") + " 00:00:00", end_time.Value.ToString("yyyy-MM-dd") + " 23:59:59");

Joint/OrderPublic.cs

@@ -0,0 +1,174 @@
+using Abp;
+using System;
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace DataTransmission.Joint
+{
+    public class OrderPublic
+    {
+        private readonly CommonTool tool = new CommonTool();
+
+        public DataTable GetOldNotice(string st_time, string end_time)
+        {
+            //  st_time = "2024-08-26 15:42:22";
+            var conn = tool.GetConSqlServer();
+            var sql = $@"  select CONVERT(VARCHAR(100),WFSH_FlowID) FlowID,WFSH_LKName LKName,FSH_LinkTel  LinkTel,FSH_PersonnelType PersonnelType ,RTRIM(WFSH_Code) Code,WFSH_Pwd pwd,
+	WFSH_Title Title,WFSH_FromID FromID,WFSH_FromName FromName,WFSH_PurTypeID PurTypeID,WFSH_PurTypeName PurTypeName,WFSH_ConTypeID ConTypeID,WFSH_ConTypeName ConTypeName,
+	WFSCT_Content Content,   WFSH_RSFlag ResultState ,WFSH_BMName BMName,WFSCT_Result Result ,
+	WFSH_AddDate AddDate,FSH_AcceptDate  AcceptDate,WFSH_PubDate PubDate ,FSH_DisposeDate DisposeDate
+	                                    from Web10_FlowSearch wfsh with(nolock)
+																		left join Web10_FlowSearchContent wfshc with(nolock) on wfshc.WFSCT_FlowID=WFSH_FlowID
+	                                    left join CityHotline_Ver3.dbo.View_Flow_Process fsh with(nolock) on WFSH_FlowID=FSH_FlowID
+	                                    where WFSH_PubFlag=2 and  WFSH_AddDate>='{st_time}' and WFSH_AddDate<='{end_time}'";
+            return tool.GetDataTable(sql, conn);
+        }
+
+        public string GetNoticeSql(DataRow item)
+        {
+            var noticeSql = $@"INSERT INTO ""old_public_data"" (""Id"", ""OrderId"", ""FromName"", ""Contact"", ""IdentityType"", ""OrderNo"", 
+            ""OrderPwd"", ""Title"", ""SourceChannel"", ""SourceChannelCode"", ""AcceptType"", ""AcceptTypeCode"", ""HotspotId"", ""HotspotName"", 
+            ""Content"", ""State"", ""ActualHandleOrgName"", ""ActualOpinion"", ""AcceptTime"", ""PubDate"", ""FiledTime"", 
+            ""CreationTime"",  ""CreatorOrgLevel"") VALUES";
+            var noticeId = SequentialGuidGenerator.Instance.Create().ToString("D");
+            int identityType = 1;
+            if (item["PersonnelType"].ToString() == "企业")
+            {
+                identityType = 2;
+            }
+
+            noticeSql += $@"('{noticeId}', '{item["FlowID"]}', '{item["LKName"]}', '{item["LinkTel"]}', {identityType}, '{item["Code"]}', 
+                '{item["pwd"]}', '{item["Title"]}',  '{GetSourceChannelCode(item["FromID"].ToString())}', '{item["FromName"]}', '{GetAcceptTypeCode(item["PurTypeName"].ToString())}', '{item["PurTypeName"]}', '{item["ConTypeID"]}', '{item["ConTypeName"]}',
+'{item["Content"]}','{item["ResultState"]}','{item["BMName"]}','{item["Result"]}','{item["AcceptDate"]}','{item["PubDate"]}','{item["DisposeDate"]}',
+ '2024-10-19 09:49:55.383397',1)";
+
+
+            return noticeSql;
+
+        }
+
+        private string GetSourceChannelCode(string name)
+        {
+            var acceptTypeCode = string.Empty;
+            switch (name)
+            {
+                case "1":
+                    acceptTypeCode = "RGDH";
+                    break;
+                case "5":
+                    acceptTypeCode = "YTW";
+                    break;
+                case "9":
+                    acceptTypeCode = "QT";
+                    break;
+                case "10":
+                    acceptTypeCode = "ZJ";
+                    break;
+                case "11":
+                    acceptTypeCode = "WX";
+                    break;
+                case "12":
+                    acceptTypeCode = "WB";
+                    break;
+                case "13":
+                    acceptTypeCode = "AP";
+                    break;
+                case "15":
+                    acceptTypeCode = "ZHYB";
+                    break;
+                case "16":
+                    acceptTypeCode = "ZZPT";
+                    break;
+                case "17":
+                    acceptTypeCode = "S12328";
+                    break;
+                case "21":
+                    acceptTypeCode = "SZYSM";
+                    break;
+                case "22":
+                    acceptTypeCode = "YBRMT";
+                    break;
+                case "24":
+                    acceptTypeCode = "S12345";
+                    break;
+                case "25":
+                    acceptTypeCode = "SZMHD";
+                    break;
+                case "26":
+                    acceptTypeCode = "YBS";
+                    break;
+                case "27":
+                    acceptTypeCode = "SZHZ";
+                    break;
+                case "28":
+                    acceptTypeCode = "YB110";
+                    break;
+                case "29":
+                    acceptTypeCode = "SMZXBNCS";
+                    break;
+                case "30":
+                    acceptTypeCode = "IYB";
+                    break;
+
+                default:
+                    acceptTypeCode = "QT";
+                    break;
+            }
+            return acceptTypeCode;
+        }
+
+        private string GetAcceptTypeCode(string name)
+        {
+            var acceptTypeCode = string.Empty;
+            switch (name)
+            {
+                case "其他":
+                    acceptTypeCode = "40";
+                    break;
+                case "表扬":
+                    acceptTypeCode = "25";
+                    break;
+                case "举报":
+                    acceptTypeCode = "30";
+                    break;
+                case "投诉":
+                    acceptTypeCode = "35";
+                    break;
+                case "咨询":
+                    acceptTypeCode = "10";
+                    break;
+                case "建议":
+                    acceptTypeCode = "15";
+                    break;
+                case "求助":
+                    acceptTypeCode = "20";
+                    break;
+                case "意见":
+                    acceptTypeCode = "1";
+                    break;
+                case "惠民帮助":
+                    acceptTypeCode = "2";
+                    break;
+                case "大气污染举报":
+                    acceptTypeCode = "3";
+                    break;
+                default:
+                    acceptTypeCode = "0";
+                    break;
+            }
+            return acceptTypeCode;
+        }
+
+        public DataTable GetPgUser(string userid)
+        {
+            var conn = tool.GetConPgSql();
+            var sql = $@"select ""Id"",""Name"" from ""user"" where ""OldUserId""='{userid}' ";
+            return tool.GetDataTable(sql, conn);
+        }
+
+
+    }
+}