From f69379da9054a095716f7e433040907184e17152 Mon Sep 17 00:00:00 2001 From: hanxuntao Date: Wed, 8 May 2024 11:35:21 +0800 Subject: [PATCH] 1 --- JobReqWebData/JobGetMscBlDownloadRequest.cs | 112 +++++++++++++++++++ JobReqWebData/JobSendMscBlDownloadRequest.cs | 98 ++++++++++++++++ 2 files changed, 210 insertions(+) create mode 100644 JobReqWebData/JobGetMscBlDownloadRequest.cs create mode 100644 JobReqWebData/JobSendMscBlDownloadRequest.cs diff --git a/JobReqWebData/JobGetMscBlDownloadRequest.cs b/JobReqWebData/JobGetMscBlDownloadRequest.cs new file mode 100644 index 00000000..a83e2c19 --- /dev/null +++ b/JobReqWebData/JobGetMscBlDownloadRequest.cs @@ -0,0 +1,112 @@ +using log4net; +using Newtonsoft.Json; +using Newtonsoft.Json.Linq; +using Quartz; +using System; +using System.Collections.Generic; +using System.Data; +using System.Data.SqlClient; +using System.Linq; +using System.Text; +using System.IO; + +namespace JobReqWebData +{ + public class JobGetMscBlDownloadRequest : IJob + { + private ILog log = LogManager.GetLogger(typeof(JobGetMscBlDownloadRequest)); + private const string CfgFileName = "requestjson.cfg"; + private static string CfgFilePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, CfgFileName); + public void Execute(IJobExecutionContext context) + { + try + { + string connStr = context.JobDetail.JobDataMap.GetString("ConnectString"); + string sqlQuery = context.JobDetail.JobDataMap.GetString("QuerySql"); + string reqUrl = context.JobDetail.JobDataMap.GetString("ReqUrl"); + string customer = context.JobDetail.JobDataMap.GetString("Customer"); + string password = context.JobDetail.JobDataMap.GetString("Password"); + //string webcustomer = context.JobDetail.JobDataMap.GetString("WebCustomer"); + //string webpassword = context.JobDetail.JobDataMap.GetString("WebPassword"); + + int reqTimeout = Convert.ToInt32(context.JobDetail.JobDataMap.GetString("RequestTimeout")); + + log.Debug($"连接字符串：{connStr}"); + log.Debug($"查询SQL：{sqlQuery}"); + log.Debug($"请求URL：{reqUrl}"); + log.Debug($"用户：{customer}"); + log.Debug($"密码：{password}"); + log.Debug($"请求超时：{reqTimeout}"); + + SqlConnection conn = new SqlConnection(connStr); + SqlDataAdapter dataAdapter = new SqlDataAdapter(sqlQuery, conn); + DataTable tQuery = new DataTable(); + dataAdapter.Fill(tQuery); + + if (tQuery.Rows.Count == 0) + { + log.Debug("没有要发送的数据！"); + return; + } + + var json = DataTableToJsonHelper.ConvertToJson(tQuery); + log.Debug($"jsonStr：{json.ToString(Formatting.None)}"); + + JObject reqObj = new JObject(); + reqObj.Add("user_key", new JValue(customer)); + reqObj.Add("user_secret", new JValue(password)); + reqObj.Add("tasks_data", json); + + log.Debug($"reqObj：{reqObj.ToString(Formatting.None)}"); + + string rtn = WebRequestHelper.DoPost(reqUrl, reqObj.ToString(Formatting.None), reqTimeout * 1000); + log.Debug($"数据返回：{rtn}"); + var objRtn = JsonConvert.DeserializeAnonymousType(rtn, new { status = 0, message =""}); + if (objRtn.status == 1) { + var JsonMscSwBObj = JsonConvert.DeserializeObject(rtn); + foreach (var item in JsonMscSwBObj.data) + { + if (!string.IsNullOrEmpty(item.path)) { + + using (SqlConnection dbcon = new SqlConnection(connStr)) + { + dbcon.Open(); + string sql = " delete from t_op_seae_msc_file where 主提单号='"+item.bno+ "' insert into t_op_seae_msc_file(编号,主提单号,路径) select top 1 编号,主提单号,'"+item.path+"' from t_op_seae where 主提单号='"+item.bno+"'"; + SqlCommand cmd = new SqlCommand(sql, dbcon); + cmd.ExecuteNonQuery(); + dbcon.Close(); + } + + } + + + } + + + } + + log.Debug($"爬取服务返回：(Code:{objRtn.status})"); + } + catch (Exception ex) + { + log.Error(ex.Message); + log.Error(ex.StackTrace); + } + } + } + + public class JsonMscBlResponse + { + public List data { get; set; } + public string status { get; set; } + public string message { get; set; } + } + + public class JsonMscBlDataResponse + { + public string bno { get; set; } + public Int32 message { get; set; } + public string path { get; set; } + public string status { get; set; } + } +} diff --git a/JobReqWebData/JobSendMscBlDownloadRequest.cs b/JobReqWebData/JobSendMscBlDownloadRequest.cs new file mode 100644 index 00000000..2bbe989a --- /dev/null +++ b/JobReqWebData/JobSendMscBlDownloadRequest.cs @@ -0,0 +1,98 @@ +using log4net; +using Newtonsoft.Json; +using Newtonsoft.Json.Linq; +using Quartz; +using System; +using System.Collections.Generic; +using System.Data; +using System.Data.SqlClient; +using System.Linq; +using System.Text; +using System.IO; + +namespace JobReqWebData +{ + public class JobSendMscBlDownloadRequest : IJob + { + private ILog log = LogManager.GetLogger(typeof(JobSendMscBlDownloadRequest)); + private const string CfgFileName = "requestjson.cfg"; + private static string CfgFilePath = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, CfgFileName); + public void Execute(IJobExecutionContext context) + { + try + { + string connStr = context.JobDetail.JobDataMap.GetString("ConnectString"); + string sqlQuery = context.JobDetail.JobDataMap.GetString("QuerySql"); + string reqUrl = context.JobDetail.JobDataMap.GetString("ReqUrl"); + string customer = context.JobDetail.JobDataMap.GetString("Customer"); + string password = context.JobDetail.JobDataMap.GetString("Password"); + //string webcustomer = context.JobDetail.JobDataMap.GetString("WebCustomer"); + //string webpassword = context.JobDetail.JobDataMap.GetString("WebPassword"); + + int reqTimeout = Convert.ToInt32(context.JobDetail.JobDataMap.GetString("RequestTimeout")); + + log.Debug($"连接字符串：{connStr}"); + log.Debug($"查询SQL：{sqlQuery}"); + log.Debug($"请求URL：{reqUrl}"); + log.Debug($"用户：{customer}"); + log.Debug($"密码：{password}"); + log.Debug($"请求超时：{reqTimeout}"); + + SqlConnection conn = new SqlConnection(connStr); + SqlDataAdapter dataAdapter = new SqlDataAdapter(sqlQuery, conn); + DataTable tQuery = new DataTable(); + dataAdapter.Fill(tQuery); + + if (tQuery.Rows.Count == 0) + { + log.Debug("没有要发送的数据！"); + return; + } + + var json = DataTableToJsonHelper.ConvertToJson(tQuery); + log.Debug($"jsonStr：{json.ToString(Formatting.None)}"); + + JObject reqObj = new JObject(); + reqObj.Add("user_key", new JValue(customer)); + reqObj.Add("user_secret", new JValue(password)); + reqObj.Add("tasks_data", json); + + log.Debug($"reqObj：{reqObj.ToString(Formatting.None)}"); + + + string rtn = WebRequestHelper.DoPost(reqUrl, reqObj.ToString(Formatting.None), reqTimeout * 1000); + log.Debug($"数据返回：{rtn}"); + var objRtn = JsonConvert.DeserializeAnonymousType(rtn, new { status = 0}); + if (objRtn.status == 1) { + if (tQuery.Rows.Count > 0) + { + foreach (DataRow row in tQuery.Rows) + { + var MBLNO= row["bno"].ToString(); + if (!string.IsNullOrEmpty(MBLNO)) { + using (SqlConnection dbcon = new SqlConnection(connStr)) + { + dbcon.Open(); + string sql = " update t_op_seae_msc set UPLOAD='1' where EXISTS (select 1 from t_op_seae where t_op_seae.主提单号='" + MBLNO + "' and t_op_seae.编号=t_op_seae_msc.编号)"; + SqlCommand cmd = new SqlCommand(sql, dbcon); + cmd.ExecuteNonQuery(); + dbcon.Close(); + } + + } + } + + } + + } + + log.Debug($"爬取服务返回：(Code:{objRtn.status})"); + } + catch (Exception ex) + { + log.Error(ex.Message); + log.Error(ex.StackTrace); + } + } + } +}