在VS2012中新建WindowsService定时任务

  1  /// <summary>
  2         /// 同步数据方法
  3         /// </summary>
  4         /// <param name="number">几点开启的服务</param>
  5         public void CallSqlToOracle(string number)
  6         {
  7             int DataCount = 0;
  8             SqlConnection sqlConn = new SqlConnection(strSqlConnection);
  9             sqlConn.Open();
 10 
 11             string strSql = "SELECT  grid,i_count,nowtime FROM IPS_View_SourceDetail";
 12 
 13             SqlCommand sqlCommand = sqlConn.CreateCommand();
 14             sqlCommand.CommandText = strSql;
 15             sqlCommand.CommandType = CommandType.Text;
 16 
 17             SqlDataAdapter sqlAdapter = new SqlDataAdapter();
 18             sqlAdapter.SelectCommand = sqlCommand;
 19 
 20             DataSet ds = new DataSet();//创建数据集；
 21             sqlAdapter.Fill(ds);//填充数据集
 22 
 23             string strMessageBody = string.Empty;   //消息内容
 24             string employeeID = string.Empty;        //员工工号
 25             string reportCount = string.Empty;       //报告数量
 26             string strNowTime = string.Empty;       //时间
 27 
 28             #region    搬运数据
 29             //判断数据集是否为空
 30             if (ds.Tables[0].Rows.Count > 0 && ds != null)
 31             {
 32                 OracleConnection oracleConn = new OracleConnection(strOracleConnection);
 33                 oracleConn.Open();
 34                 foreach (DataRow dsRow in ds.Tables[0].Rows)
 35                 {
 36                     int result = 0;
 37 
 38 
 39                     DateTime nowTime = Convert.ToDateTime(dsRow["nowtime"]);
 40 
 41                     string strOracle = "INSERT INTO IPS_SEND_QUEUE(QUEUE_SEQID,SERVICE_ID,USER_ID,SUBSCRIBE_TYPE,MESSAGE_BODY,RECEIVE_TIME,NEED_SENDTIME,SEND_FLAG,SEND_NUM)"
 42                     + "VALUES(SEQ_Ips_Send_Queue_Id.Nextval,:SERVICE_ID,:USER_ID,:SUBSCRIBE_TYPE,:MESSAGE_BODY,:RECEIVE_TIME,:NEED_SENDTIME,:SEND_FLAG,:SEND_NUM)";
 43 
 44 
 45                     OracleParameter[] prams = new OracleParameter[] {
 46                         new OracleParameter("SERVICE_ID",OracleType.Number), 
 47                         new OracleParameter("USER_ID",OracleType.NVarChar), 
 48                         new OracleParameter("SUBSCRIBE_TYPE", OracleType.Number), 
 49                         new OracleParameter("MESSAGE_BODY", OracleType.Clob), 
 50                         new OracleParameter("RECEIVE_TIME", OracleType.DateTime), 
 51                         new OracleParameter("NEED_SENDTIME",OracleType.DateTime),
 52                         new OracleParameter("SEND_FLAG",OracleType.Number),
 53                         new OracleParameter("SEND_NUM",OracleType.Number),
 54                     };
 55 
 56                     reportCount = dsRow["i_count"].ToString();
 57                     employeeID = dsRow["grid"].ToString();
 58                     strNowTime = nowTime.ToString("yyyy-MM-dd hh:mm:ss");
 59                     strMessageBody = string.Format("尊敬的:{0},您好,截至{1}您有{2}份报告4小时后将超时，请及时登录系统审批，谢谢！", employeeID, strNowTime, reportCount);
 60 
 61 
 62                     prams[0].Value = 100;
 63                     prams[1].Value = employeeID;
 64                     prams[2].Value = 1;
 65                     prams[3].Value = strMessageBody;
 66                     prams[4].Value = nowTime;
 67                     prams[5].Value = nowTime;
 68                     prams[6].Value = 0;
 69                     prams[7].Value = 0;
 70 
 71 
 72 
 73                     OracleCommand oracleCommand = oracleConn.CreateCommand();
 74                     oracleCommand.CommandText = strOracle;
 75                     oracleCommand.CommandType = CommandType.Text;
 76 
 77                     if (prams.Length > 0)
 78                     {
 79                         oracleCommand.Parameters.AddRange(prams);
 80                     }
 81 
 82                     try
 83                     {
 84                         result = oracleCommand.ExecuteNonQuery();
 85                         if (result > 0)
 86                         {
 87                             DataCount++;
 88                         }
 89                     }
 90                     catch (Exception ex)
 91                     {
 92                         WriteTxtFile(DateTime.Now.ToLongTimeString() + " : " + number + "的服务插入失败！" + ex.Message, logFilePath);
 93                     }
 94                 }
 95 
 96                 oracleConn.Close();
 97 
 98             }
 99             else
100             {
101                 WriteTxtFile(DateTime.Now.ToLongTimeString() + " : " + number + "的服务插入失败！没有数据可进行同步", logFilePath);
102             }
103             #endregion
104             sqlConn.Close();
105             WriteTxtFile(DateTime.Now.ToLongTimeString() + " : " + number + "的服务一共同步了" + DataCount + "条数据！", logFilePath);
106         }