Program.cs

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.ServiceProcess;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using System.Diagnostics;
  9. namespace XMLMatrixConvert
  10. {
  11.     static class Program
  12.     {
  13.         static void Main()
  14.         {
  15.             if (Debugger.IsAttached)
  16.             {
  17.                 Service1 ser1 = new Service1();
  18.                 Console.ReadLine();
  19.             }
  20.             else
  21.             {
  22.                 ServiceBase[] ServicesToRun;
  23.                 ServicesToRun = new ServiceBase[]
  24.                 {
  25.                 new Service1()
  26.                 };
  27.                 ServiceBase.Run(ServicesToRun);
  28.             }        
  29.         }
  30.     }
  31. }

关键字：Dbugger.IsAttached
此处的作用的，调试状态下，作为调整。

Services1

  1. using System;
  2. using System.Data;
  3. using System.Diagnostics;
  4. using System.IO;
  5. using System.ServiceProcess;
  6. using System.Timers;
  8. namespace TestNamespace
  9. {
  10.     public partial class Service1 : ServiceBase
  11.     {
  12.         #region Variables
  13.         private string _SourceSQLConnORC = string.Empty;
  14.         private string _SourceSQLConnVRS = string.Empty;
  15.         private Timer _Timer = new Timer();
  16.         private int _TimerInterval = 0;
  17.         private string _MappingFolderPath = string.Empty;
  18.         #endregion
  19.         public Service1()
  20.         {
  21.             ServiceInitial();
  22.             InitializeComponent();
  23.         }
  24.         public void ServiceInitial()
  25.         {
  26.             GetConfig();
  27.             GeneralFunctions.WriteLog.WriteLogFun("ServiceInitial: Get config end");
  29.             _Timer.Interval = _TimerInterval * 1000 * 60;   //30s
  30.             if (Debugger.IsAttached)
  31.             {
  32.                 _Timer.Interval = 5000;
  33.             }
  34.             _Timer.Elapsed += new ElapsedEventHandler(TimedEvent); //此处委托给TimeEvent 
  35.             _Timer.Enabled = true;  
  36.             _Timer.AutoReset = false;   
  37.             _Timer.Start();
  38.             GeneralFunctions.WriteLog.WriteLogFun("ServiceInitial: Get config and Timer Started.");
  39.         }
  40.         private void GetConfig()
  41.         {
  42.             _SourceSQLConnORC = GeneralFunctions.ReadAndSetConfigFile.GetAppConfig("SourceSQLConnORC");
  43.             _SourceSQLConnVRS = GeneralFunctions.ReadAndSetConfigFile.GetAppConfig("SourceSQLConnVRS");
  45.             _MappingFolderPath = GeneralFunctions.ReadAndSetConfigFile.GetAppConfig("MappingFolderPath");
  47.             if (Debugger.IsAttached || string.IsNullOrWhiteSpace(_MappingFolderPath))
  48.             {
  49.                 _MappingFolderPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "eTest");
  50.                 DirectoryInfo dinfo = new DirectoryInfo(_MappingFolderPath);
  51.                 dinfo.Create();
  52.                 GeneralFunctions.WriteLog.WriteLogFun("Create eTest folder.");
  53.             }
  55.             try
  56.             {
  57.                 _TimerInterval = int.Parse(GeneralFunctions.ReadAndSetConfigFile.GetAppConfig("TimerInterval"));    
  58.             }
  59.             catch
  60.             {
  61.                 _TimerInterval = 30;
  62.             }
  63.         }
  64.         public void TimedEvent(object source, ElapsedEventArgs e)
  65.         {
  66.             _Timer.Enabled = false;
  67.             try
  68.             {
  69.                 //get orc data
  70.                 DataTable dt_orc = DataBaseFunctions.GetORCData.GetORCDataFunc(_SourceSQLConnORC);
  71.                 //get Json data
  72.                 //DataView dataView = dt_orc.DefaultView;DataTable dataTableDistinct = dataView.ToTable(true, "PanelId");
  73.                 eMapFunctions.loadlAndUpdateXml.CreateAndUpdateXml(dt_orc, _MappingFolderPath, _SourceSQLConnVRS);
  74.             }
  75.             catch (Exception ex)
  76.             {
  77.                 GeneralFunctions.WriteLog.WriteLogFun("Error:" + ex.Message);
  78.                 GeneralFunctions.WriteLog.WriteLogFun("StackTrace:" + ex.StackTrace);
  79.             }
  80.             finally
  81.             {
  82.                 GeneralFunctions.WriteLog.WriteLogFun("Process End.");
  83.                 //next timer
  84.                 //_Timer.Enabled = true;
  85.                 _Timer.Enabled = false;
  86.             }
  87.         }
  89.         protected override void OnStart(string[] args)
  90.         {
  91.         }
  93.         protected override void OnStop()
  94.         {
  95.         }
  96.     }
  97. }

App.config

  1. <?xml version="1.0" encoding="utf-8" ?>
  2. <configuration>
  3.   <appSettings>
  4.     <add key="SourceSQLConnORC" value="############"/>
  5.     <add key="SourceSQLConnVRS" value="############"/>
  6.     <!-- TimerInterval unit is min -->
  7.     <add key="TimerInterval" value="30"/>
  8.     <add key="SourceDataPath" value="D:\ATS\Application\C#\ETest\XMLMatrixConvert\XMLMatrixConvert\bin\Debug\SourceDataPath"/>
  9.     <add key="MappingFolderPath" value="D:\ATS\Application\C#\ETest\XMLMatrixConvert\XMLMatrixConvert\bin\Debug\TargetDataPath\eTest"/>
  10.   </appSettings>
  11.   <startup>
  12.     <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />
  13.   </startup>
  14. </configuration>

LogInfo

  1. using System;
  2. using System.IO;
  4. namespace XMLMatrixConvert.GeneralFunctions
  5. {
  6.     class WriteLog
  7.     {
  8.         //Record log
  9.         public static void WriteLogFun(String msg)
  10.         {
  11.             string logPath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory);
  12.             string tempfileFolder = Path.Combine(logPath, "Log");
  13.             if (!Directory.Exists(tempfileFolder))
  14.             {
  15.                 Directory.CreateDirectory(tempfileFolder);
  16.             }
  17.             string tempfile = Path.Combine(tempfileFolder, string.Format("Log_{0}.log", DateTime.Now.ToString("yyyyMMdd")));
  18.             if (!File.Exists(tempfile))
  19.             {
  20.                 File.Create(tempfile).Close();
  21.             }
  23.             StreamWriter writer = null;
  24.             try
  25.             {
  26.                 writer = File.AppendText(tempfile);
  27.                 writer.WriteLine("{0}: {1}", DateTime.Now.ToString("yyyy/MM/dd HH:mm:ss"), msg);
  28.                 writer.Flush();
  29.             }
  30.             catch
  31.             {
  33.             }
  34.             finally
  35.             {
  36.                 if (writer != null)
  37.                 {
  38.                     writer.Close();
  39.                 }
  40.             }
  41.         }
  42.     }
  43. }

ReadAndSetConfigFile

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Configuration;
  5. namespace XMLMatrixConvert.GeneralFunctions
  6. {
  7.     class ReadAndSetConfigFile
  8.     {
  9.         //Error Code        
  10.         const string Error_ConfigLoadFail = "Load Config file is Fail.";
  11.         const string Error_ConfigSetFail = "Set Config file is Fail";
  12.         const string Error_SQL_Fail = "Query SQL DB fail.";
  14.         /// <summary>
  15.         /// 查询AppConfig中Key = Key1的value
  16.         /// </summary>
  17.         /// <param name="Key1">Key ID</param>
  18.         /// <returns></returns>
  19.         public static string GetAppConfig(string Key1)
  20.         {
  21.             string str = string.Empty;
  22.             try
  23.             {
  24.                 ConfigurationManager.RefreshSection("appSettings");//重新加载新的配置文件  
  25.                 foreach (string key in ConfigurationManager.AppSettings)
  26.                 {
  27.                     if (key == Key1)
  28.                     {
  29.                         str = ConfigurationManager.AppSettings[Key1];
  30.                     }
  31.                 }
  32.                 return str;
  33.             }
  34.             catch
  35.             {
  36.                 return str;
  37.             }
  38.         }
  40.         /// <summary>
  41.         /// 查询AppConfig, contain Key1的Key, 并添加value到List , 返回List<string>
  42.         /// </summary>
  43.         /// <param name="Key1">Key ID</param>
  44.         /// <returns></returns>
  45.         public static List<string> GetAppConfig_Contain(string Key1)
  46.         {
  47.             List<string> TempList = new List<string>();
  48.             try
  49.             {
  50.                 ConfigurationManager.RefreshSection("appSettings");//重新加载新的配置文件  
  51.                 foreach (string key in ConfigurationManager.AppSettings)
  52.                 {
  53.                     if (key.ToUpper().Contains(Key1.ToUpper()))
  54.                     {
  55.                         if (ConfigurationManager.AppSettings[key] != string.Empty)
  56.                         {
  57.                             TempList.Add(ConfigurationManager.AppSettings[key]);
  58.                         }
  59.                     }
  60.                 }
  62.                 return TempList;
  63.             }
  64.             catch
  65.             {
  66.                 TempList = new List<string>();
  67.                 TempList.Add(Error_ConfigLoadFail);
  68.                 return TempList;
  69.             }
  70.             finally
  71.             {
  73.             }
  74.         }
  76.         /// <summary>
  77.         /// Search config items which name contain key1 and key2
  78.         /// </summary>
  79.         /// <param name="Key1"></param>
  80.         /// <param name="Key2"></param>
  81.         /// <returns></returns>
  82.         public static List<string> GetAppConfig_Contain(string Key1, string Key2)
  83.         {
  84.             List<string> TempList = new List<string>();
  85.             try
  86.             {
  87.                 ConfigurationManager.RefreshSection("appSettings");//重新加载新的配置文件  
  88.                 foreach (string key in ConfigurationManager.AppSettings)
  89.                 {
  90.                     if (key.ToUpper().Contains(Key1.ToUpper()) && key.ToUpper().Contains(Key2.ToUpper()))
  91.                     {
  92.                         if (ConfigurationManager.AppSettings[key] != string.Empty)
  93.                         {
  94.                             TempList.Add(ConfigurationManager.AppSettings[key]);
  95.                         }
  96.                     }
  97.                 }
  98.                 return TempList;
  99.             }
  100.             catch
  101.             {
  102.                 TempList = new List<string>();
  103.                 TempList.Add(Error_ConfigLoadFail);
  104.                 return TempList;
  105.             }
  106.             finally
  107.             {
  108.             }
  109.         }
  111.         /// <summary>
  112.         /// 修改AppConfig中Key1的value
  113.         /// </summary>
  114.         /// <param name="Key1">Key ID</param>
  115.         /// <param name="value1">Key Value</param>
  116.         public static void SetAppConfig(string Key1, string value1)
  117.         {
  118.             Configuration AppConfig = null;
  119.             try
  120.             {
  121.                 AppConfig = ConfigurationManager.OpenExeConfiguration(ConfigurationUserLevel.None);
  122.                 AppSettingsSection app = AppConfig.AppSettings;
  123.                 if (app.Settings[Key1] == null)
  124.                 {
  125.                     app.Settings.Add(Key1, value1);
  126.                 }
  127.                 else
  128.                 {
  129.                     app.Settings[Key1].Value = value1;
  130.                 }
  131.                 AppConfig.Save(ConfigurationSaveMode.Modified);
  132.                 ConfigurationManager.RefreshSection("appSettings");//重新加载新的配置文件  
  133.             }
  134.             catch (Exception Ex)
  135.             {
  136.                 throw new Exception(Error_ConfigSetFail + Ex.Message);
  137.             }
  138.             finally
  139.             {
  140.                 AppConfig = null;
  141.             }
  142.         }
  143.     }
  144. }

PaserParameter

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  7. namespace XMLMatrixConvert.GeneralFunctions
  8. {
  9.     class PaserParameter
  10.     {
  11.         public static string PaserString(string msg, string key, string spliter)
  12.         {
  13.             string result = string.Empty;
  14.             if (!msg.Contains(key))
  15.             {
  16.                 return result;
  17.             }
  18.             int indexKey = msg.IndexOf(key, 0);
  19.             int indexSpliter = msg.IndexOf(spliter, indexKey);
  20.             if (indexSpliter == -1)
  21.             {
  22.                 result = msg.Substring(indexKey).Replace(key, "");
  23.             }
  24.             else
  25.             {
  26.                 result = msg.Substring(indexKey, indexSpliter - indexKey).Replace(key, "");
  27.             }
  29.             return result;
  30.         }
  32.         public static string GetParentFolderFullPath(string filePath)
  33.         {
  34.             string folderPath = string.Empty;
  35.             int lastChar = filePath.LastIndexOf(@"\");
  36.             folderPath = filePath.Substring(0, lastChar);
  37.             return folderPath;
  38.         }
  39.     }
  40. }

Properies

图片.png