增加用户工号 同步

Execute.cs

@@ -80,6 +80,14 @@ namespace DataTransmission
 			//tool.Execute(pgSql, pgConn);
 		}
 
+		public void ExecuteStaffSql()
+		{
+			var pgConn = tool.GetConPgSql();
+			var pgSql = user.GetStaffNoSql();
+			tool.SaveLog("StaffSQL :" + pgSql + "  ;", 1);
+			//tool.Execute(pgSql, pgConn);
+		}
+
 		public void ExecuteInsertKnowledge(string stTime,string endTime )
 		{
 			var know = knowledge.GetKnowledge(stTime , endTime);

Form1.cs

@@ -35,8 +35,10 @@ namespace DataTransmission
 			}
             if (cb_user.Checked)
             {
-	            execute.ExecuteUserSql();
-            }
+				execute.ExecuteUserSql();
+				//工号
+				//execute.ExecuteStaffSql();
+			}
             MessageBox.Show("同步完成！请先别关闭程序！");
 			btn_tb.Enabled = true;
 		}

Joint/User.cs

@@ -56,5 +56,16 @@ namespace DataTransmission.Joint
 					( '{id}', '{pgRole.Rows[0]["Id"]}' );";
 			return insertSql;
 		}
+
+		public string GetStaffNoSql() {
+			var updateSql = string.Empty;
+			var conn = tool.GetConSqlServer();
+			var sql = $@" SELECT * FROM dbo.SYS10_Tel ";
+			var data = tool.GetDataTable(sql, conn);
+			foreach (DataRow row in data.Rows) {
+				updateSql += $@"UPDATE ""user"" SET ""StaffNo"" ='{row["STel_UserNum"]}' ,""DefaultTelNo"" ='{row["STel_UserNum"]}' ,""DefaultTelGroup"" ='1'  WHERE ""OldUserId"" ='{row["STel_UserID"]}' ;";
+			}
+			return updateSql;
+		}
 	}
 }