using log4net; using Newtonsoft.Json; using Quartz; using System; using System.Collections.Generic; using System.Data; using System.Data.SqlClient; using System.IO; using System.Linq; using System.Reflection; using System.Text; namespace JobReqWebData { public class JobGetMskFtp : IJob { private ILog log = LogManager.GetLogger(typeof(JobGetMskFtp)); public void Execute(IJobExecutionContext context) { log.Debug($"开始运行ftp"); try { string connStr = context.JobDetail.JobDataMap.GetString("ConnectString"); var FTPADDRESS = context.JobDetail.JobDataMap.GetString("FTPADDRESS"); var FTPPATH = context.JobDetail.JobDataMap.GetString("FTPPATH"); var FTPUSERNAME = context.JobDetail.JobDataMap.GetString("FTPUSERNAME"); var FTPPWD = context.JobDetail.JobDataMap.GetString("FTPPWD"); var FTPPORT = context.JobDetail.JobDataMap.GetString("FTPPORT"); //// 配置会话选项 //SessionOptions sessionOptions = new SessionOptions //{ // Protocol = Protocol.Ftp, // HostName = FTPADDRESS, // UserName = FTPUSERNAME, // Password= FTPPWD //}; //try //{ // log.Debug($"FTP连接:{FTPADDRESS},{FTPPATH},{FTPUSERNAME},{FTPPWD}"); // var m_session = new Session(); // m_session.Open(sessionOptions); // log.Debug($"FTP已连接:{FTPADDRESS},{FTPPATH},{FTPUSERNAME},{FTPPWD}"); // //this.propUpdateDownloadStatus("已连接"); // var ftpfilelist = m_session.ListDirectory(FTPPATH); // var filepath = AppDomain.CurrentDomain.BaseDirectory + @"\FTPDOWNLOADFILE\" + DateTime.Now.ToString("yyyy-MM-dd") + @"\"; // if (Directory.Exists(filepath) == false) // { // Directory.CreateDirectory(filepath); // log.Debug($"服务器本地建立文件夹：{filepath}"); // } // for (var i = 0; i <= ftpfilelist.Files.Count - 1; i++) // { // if (!ftpfilelist.Files[i].IsDirectory && Path.GetFileName(ftpfilelist.Files[i].FullName) != "..") // { // var finf = new fileprop(); // finf.fdate = ftpfilelist.Files[i].LastWriteTime.ToString("yyyy-MM-dd HH:mm:ss"); // finf.fname = Path.GetFileName(ftpfilelist.Files[i].FullName); // finf.fullname = ftpfilelist.Files[i].FullName; // finf.fsize = ftpfilelist.Files[i].Length.ToString(); // finf.ftype = "文件"; // m_filelist.Add(finf); // } // else // { // if (ftpfilelist.Files[i].Name != "..") // { // var ftpfilelist2 = m_session.ListDirectory(ftpfilelist.Files[i].FullName); // for (var j = 0; j <= ftpfilelist2.Files.Count - 1; j++) // { // if (!ftpfilelist2.Files[j].IsDirectory && ftpfilelist2.Files[j].Name != "..") // { // var finf = new fileprop(); // finf.fdate = ftpfilelist2.Files[j].LastWriteTime.ToString("yyyy-MM-dd HH:mm:ss"); // finf.fname = ftpfilelist2.Files[j].Name; // finf.fullname = ftpfilelist2.Files[j].FullName; // finf.fsize = ftpfilelist2.Files[j].Length.ToString(); // finf.ftype = "文件"; // m_filelist.Add(finf); // } // } // } // } // } //} //catch (Exception e) //{ //} FTPDA FTPDA = new FTPDA(); try { FTPDA.ErrorMsg = ""; FTPDA.Uri = new Uri("ftp://" + FTPADDRESS + "/"); FTPDA.DirectoryPath = FTPPATH.Replace("/", "//"); FTPDA.UserName = FTPUSERNAME; FTPDA.Password = FTPPWD; log.Debug($"FTP连接:{FTPADDRESS},{FTPPATH},{FTPUSERNAME},{FTPPWD}"); var filearray = FTPDA.ListFiles(); var errmsg = FTPDA.ErrorMsg; log.Debug($"FTP错误日志"+errmsg); if (filearray == null || filearray.Count() == 0) { log.Debug($"没有可读取的文件，进程结束"); return; } log.Debug($"发现文件数：{filearray.Count()}"); var filepath = AppDomain.CurrentDomain.BaseDirectory + @"\FTPDOWNLOADFILE\" + DateTime.Now.ToString("yyyy-MM-dd") + @"\"; if (Directory.Exists(filepath) == false) { Directory.CreateDirectory(filepath); log.Debug($"服务器本地建立文件夹：{filepath}"); } foreach (FileStruct file in filearray) { if (!file.IsDirectory) { string LocalFullPath = Path.Combine(filepath, file.Name); if (File.Exists(LocalFullPath)) { log.Debug($"当前路径下已经存在同名文件：{LocalFullPath}"); FTPDA.DeleteFile(file.Name); } else if (FTPDA.DownloadFile(file.Name, filepath)) { log.Debug($"下载文件：{LocalFullPath}"); var tmpfile = file.Name; if (tmpfile.IndexOf(".") > 0) { var tmpfilelist = tmpfile.Split('.'); if (tmpfilelist.Length >= 3 && tmpfilelist[2] == "CONTRL") { var filename = filepath + file.Name; var headList = ""; var custno = ""; try { FileStream fs = new FileStream(filename, FileMode.Open); StreamReader sr = new StreamReader(fs, System.Text.Encoding.GetEncoding("gb2312")); string line; while ((line = sr.ReadLine()) != null && line != "") { headList = headList + line; } headList = headList.Replace("?'", "し"); string[] StrList = headList.Split('\''); for (var i = 0; i <= StrList.Length - 1; i++) { line = StrList[i]; if (line.Length > 3) { var head = line.Substring(0, 3); if (head == "UCM") { custno = GetPosStringplus(line, 2); if (!string.IsNullOrEmpty(custno)) { using (SqlConnection dbcon = new SqlConnection(connStr)) { dbcon.Open(); var COUNT = GETBSCOUNT(custno,dbcon); if (COUNT == 0) { string sql = " insert op_status (ST_ID,BSNO,STATUS,ISCOMP,COMPTIME,COMPOP,INPUTTIME,STTYPE) Select NEWID(),BSNO,'订舱已接收',1,GETDATE(),'ADMIN',GETDATE(),'1' FROM OP_SEAE WHERE CUSTNO='" + custno + "'"; SqlCommand cmd = new SqlCommand(sql, dbcon); cmd.ExecuteNonQuery(); } else { string sql = " insert op_status (ST_ID,BSNO,STATUS,ISCOMP,COMPTIME,COMPOP,INPUTTIME,STTYPE) Select NEWID(),BSNO,'截单已接收',1,GETDATE(),'ADMIN',GETDATE(),'1' FROM OP_SEAE WHERE CUSTNO='" + custno + "'"; SqlCommand cmd = new SqlCommand(sql, dbcon); cmd.ExecuteNonQuery(); } dbcon.Close(); } } } } } } catch { } } } FTPDA.DeleteFile(file.Name); } } } log.Debug($"连接字符串：{connStr}"); } catch (Exception ex) { log.Error(ex.Message); } } catch (Exception ex) { log.Error(ex.Message); log.Error(ex.StackTrace); } } public static string GetPosStringplus(string str, int pos, bool isnum = false) { var result = ""; if (isnum) result = "0"; var j = 0; if (str.IndexOf("+") == -1) return result; str = str.Replace("??", "?").Replace("?'", "'").Replace("?+", "し"); for (int i = 1; i < pos; i++) { if (str.IndexOf("+") == -1) return result; if (str.IndexOf("+") != -1) { j = str.IndexOf("+"); str = str.Substring(j + 1, str.Length - j - 1); } } j = str.IndexOf("+"); if (j != -1) { str = str.Substring(0, j); } else { if (str.Length != 0) str = str.Substring(0, str.Length); } result = str.Replace("し", "+"); if (isnum) { if (result == "") result = "0"; } return result; } static public int GETBSCOUNT(string custno, SqlConnection dbcon) { var strSql = new StringBuilder(); strSql.Append("SELECT COUNT(1) ct from op_status where [STATUS]='已发确认' and BSNO IN (SELECT BSNO FROM OP_SEAE WHERE CUSTNO='" + custno + "')"); SqlDataAdapter adapter = new SqlDataAdapter(strSql.ToString(), dbcon); DataTable table = new DataTable(); adapter.Fill(table); var bscount =0; if (table.Rows.Count > 0) { foreach (DataRow row in table.Rows) { bscount =Convert.ToInt32(row["ct"].ToString()); } } return bscount; } } }