win-service-machine-dll/ftpUploadDLL/ftpUploadDLL.cs

using System;
using System.Windows.Forms;
using Newtonsoft.Json.Linq;
using HttpServices;
using ProgressBar = ftpUploadDLL.Weblogic.ProgressBar;
using VersionListData = ftpUploadDLL.Weblogic.VersionListData;
using System.Threading;
using FtpConnection;
namespace ftpUploadDLL
{
    public class ftpUploadDLL
    {
		public string currentPath = "";

		public string serverPath = "";

		public string serverFTPName = "";

		public string serverFTPPassword = "pryk@";
		public string ftpIP = "";
		public string ftpDefaultFolder = "browser";
		public static JArray fileStringArray = new JArray();
		/// <summary>
		/// 弹选择文件的界面
		/// </summary>
		/// <param name="inParams"></param>
		/// <returns></returns>
		public string versionList(string inParams)
		{
			// System.Diagnostics.Debugger.Launch();
			string errorCode = "0";
			string errorMessage = "";
			JObject jObject = new JObject();
			try
			{
				VersionListData versionListDataing = new VersionListData(inParams);
				string outstring= versionListDataing.outstring;
				JObject outstringObj = JObject.Parse(outstring);
				errorCode = outstringObj["errorCode"].ToString();
				if (errorCode != "0")
				{
					return outstring;
				}
				if (versionListDataing.ShowDialog() == DialogResult.OK)
				{
					errorCode = "0";
					errorMessage = "结束";
					jObject.Add("errorCode", errorCode);
					jObject.Add("errorMessage", errorMessage);
					return jObject.ToString();
				}
				else
				{
					errorCode = "-1";
					errorMessage = "取消操作";
					jObject.Add("errorCode", errorCode);
					jObject.Add("errorMessage", errorMessage);
					return jObject.ToString();
				}
			}
			catch (Exception ex2)
			{
				errorCode = "-1";
				errorMessage = ex2.Message;
			}
			jObject.Add("errorCode", errorCode);
			jObject.Add("errorMessage", errorMessage);
			return jObject.ToString();
		}
		/// <summary>
		/// 获取文件路径
		/// </summary>
		public string getFilePath(string inParams)
		{
			string errorCode = "0";
			string errorMessage = "";
			JObject jObject = new JObject();
			String fileName = "", filePath = "";
			try
			{
				JObject inputEmpParamsObj = JObject.Parse(inParams);
				var paramsdata = inputEmpParamsObj["params"][0];
				string fileFlag = paramsdata["fileFlag"].ToString();                      //文档路径
				if (fileFlag == "true")
				{
					Thread t = new Thread((ThreadStart)(() =>
					{
						OpenFileDialog dialog = new OpenFileDialog();
						dialog.Filter = "DLL文件(*.dll)|*.dll|所有文件(*.*)|*.*";
						dialog.Title = "打开";
						dialog.FilterIndex = 1;
						dialog.RestoreDirectory = true;
						if (dialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)
						{
							fileName = dialog.SafeFileName;
							filePath = dialog.FileName.Replace("\\", "/"); 
						}
					}));
					// Run your code from a thread that joins the STA Thread
					t.SetApartmentState(ApartmentState.STA);
					t.Start();
					t.Join();

				}
				else {
					Thread t = new Thread((ThreadStart)(() =>
					{

						FolderBrowserDialog dialog = new FolderBrowserDialog();
						dialog.Description = "请选择文件路径";

						if (dialog.ShowDialog() == System.Windows.Forms.DialogResult.OK)
						{
							filePath = dialog.SelectedPath.Replace("\\", "/");

						}
					}));
					// Run your code from a thread that joins the STA Thread
					t.SetApartmentState(ApartmentState.STA);
					t.Start();
					t.Join();
				}
			}
			catch (Exception ex2)
			{
				 errorCode = "-1";
				 errorMessage = ex2.Message;
			}
			jObject.Add("errorCode", errorCode);
			jObject.Add("errorMessage", errorMessage);
			jObject.Add("filePath", filePath);
			jObject.Add("fileName", fileName);
			return jObject.ToString();
		}
			/// <summary>
			/// ftp上传
			/// </summary>
			/// 上传文件->上传成功返回
			/// <param name="inParams"></param>
			/// <returns></returns>
		public string doUpload(string inParams)
		{
			//System.Diagnostics.Debugger.Launch();
			string errorCode = "0";
			string errorMessage = "";
			JObject jObject = new JObject();
			try
			{
				JObject inputEmpParamsObj = JObject.Parse(inParams);
				var hisResultobj = inputEmpParamsObj["hisResult"];
				errorCode = hisResultobj["errorCode"].ToString();
				errorMessage = hisResultobj["errorMessage"].ToString();
				if (errorCode == "0")
				{
					var resultObj = hisResultobj["result"];
					string ftpIP = resultObj[0]["ftpIP"].ToString();        //ftp路径
					string serverPath = resultObj[0]["ftpToPath"].ToString();        //ftp路径
					string serverFTPName = resultObj[0]["serverFTPName"].ToString();        //ftp用户
					string serverFTPPassword = resultObj[0]["serverFTPPassword"].ToString();        //ftp密码
					///判断ftp是否可以连接
					///port
					errorMessage = "";
					//port
					string[] sArray = ftpIP.Split(new string[1] { ":" }, StringSplitOptions.None);
					string ftpip = sArray[0].ToString();
					string ftpport = sArray[1].ToString();
					FtpOperationClass ftpOpObj = new FtpOperationClass();
					string checkinfo = ftpOpObj.CheckLinkFtp(ftpip, serverFTPName, serverFTPPassword, ftpport);
					JObject checkinfoobj = JObject.Parse(checkinfo);
					errorCode = checkinfoobj["errorCode"].ToString();
					errorMessage = checkinfoobj["errorMessage"].ToString();
					if (errorCode != "0")
					{
						jObject.Add("errorCode", errorCode);
						jObject.Add("errorMessage", errorMessage);
						return jObject.ToString();
					}
				}
				
				ProgressBar progressBaring = new ProgressBar(inParams);
				if (progressBaring.ShowDialog() == DialogResult.OK)
				{
					return progressBaring.outstring;
				}
				else
				{
					//return progressBaring.outstring;
					jObject.Add("errorCode", "-1");
					jObject.Add("errorMessage", "上传中断或已取消");
					return jObject.ToString();
				}
			}
			catch (Exception ex2)
			{
				errorCode = "-1";
				errorMessage = ex2.Message;
			}
			jObject.Add("errorCode", errorCode);
			jObject.Add("errorMessage", errorMessage);
			return jObject.ToString();
		}
		public string GetFtpDataToHip(string inParams)
		{
			int checkFlag = 0;
			string code = "0";
			string message = "";
			//保存版本到hip 返回 获取Ftp用户，密码，地址（加密）
			JObject inputEmpParamsObj = JObject.Parse(inParams);
			var paramsdata = inputEmpParamsObj["params"][0];
			string hipIP = paramsdata["hipIP"].ToString();                     //hipIP
			string hipURL = paramsdata["hipURL"].ToString();                       //URL
			string hipAuthorization = paramsdata["hipAuthorization"].ToString(); //hipAuthorization

			JObject jObject = new JObject();
			RestClient restClient = new RestClient();
			string hisResult = restClient.HISHTTPServices(inParams, hipIP, hipURL, hipAuthorization); //调用HIS回调
			return hisResult;
		}
		
	}
}