DS7/JobReqWebData/JobDs7ToWeb.cs

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 JobDs7ToWeb : IJob
    {
        private ILog log = LogManager.GetLogger(typeof(JobDs7ToWeb));
        //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 WebconnStr = context.JobDetail.JobDataMap.GetString("WebConnectString");

                ///记录在配置文件里的查询语句
                string sqlQuery = context.JobDetail.JobDataMap.GetString("QuerySql");

                log.Debug($"连接字符串：{connStr}");

                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 mblno = "";


                using (SqlConnection db = new SqlConnection(WebconnStr))
                {
                    db.Open();


                    #region 运踪
                    if (tQuery.Rows.Count > 0)
                    {

                        foreach (DataRow row in tQuery.Rows)
                        {

                            string cmdDelete = "delete from tb_order where BSNO='"+ row["AS_ID"].ToString() + "'  delete from tb_ctn where BSNO='" + row["AS_ID"].ToString() + "'";
                                SqlCommand cmddelete = new SqlCommand(cmdDelete, db);
                                cmddelete.ExecuteNonQuery();
                            using (SqlTransaction trans = db.BeginTransaction())
                            {
                                log.Debug("插入"+ row["MBLNO"].ToString()+"-"+ row["HBLNO"].ToString());
                                string sql = "insert into tb_order(BSNO,业务编号,提单号,分单号,客户名称,发货人,收货人,启运港,目的港,国家名称,船名,航次,箱量表示" +
                                    ",出口类型,运输条款,预计离港,实际离港,联系客户时间,建立时间,出号时间,操作时间,船公司,PO,品名,HS编码,件数文本,重量文本,尺码文本,保险联系人)";
                                sql = sql + " values (@BSNO,@CUSTNO,@MBLNO,@HBLNO,@CUSTOMERNAME,@SHIPPER,@CONSIGNEE,@PORTLOAD,@DESTINATION,@COUNTRY,@VESSEL,@VOYNO,@CNTRTOTAL,@BLTYPE" +
                                    ",@SERVICE,@ETD,@ATD,@LINKCUSTTIME,@CREATETIME,@MBLNOTIME,@BSDATE,@CARRIER,@PONO,@GOODSNAME,@HSCODE,@NOPKGS,@GROSSWEIGHT,@MEASUREMENT,@INSURANCEOP)";
                                SqlCommand cmd = new SqlCommand(sql, db, trans);
                                cmd.Parameters.AddWithValue("@BSNO", row["AS_ID"].ToString());
                                cmd.Parameters.AddWithValue("@CUSTNO", row["CUSTNO"].ToString());
                                cmd.Parameters.AddWithValue("@MBLNO", row["MBLNO"].ToString());
                                cmd.Parameters.AddWithValue("@HBLNO", row["HBLNO"].ToString());
                                cmd.Parameters.AddWithValue("@CUSTOMERNAME", row["CUSTOMERNAME"].ToString());
                                var Shipping = row["SHIPPER"].ToString();
                                Shipping = Shipping.Replace("\n", "\\");
                                Shipping = Shipping.Replace("\r", " ");
                                string[] ShippingList = Shipping.Split('\\');
                                if (ShippingList.Length != 0)
                                {
                                    cmd.Parameters.AddWithValue("@SHIPPER", ShippingList[0]);
                                }
                                else {
                                    cmd.Parameters.AddWithValue("@SHIPPER","");
                                }
                                Shipping = row["CONSIGNEE"].ToString();
                                Shipping = Shipping.Replace("\n", "\\");
                                Shipping = Shipping.Replace("\r", " ");
                                ShippingList = Shipping.Split('\\');
                                if (ShippingList.Length != 0)
                                {
                                    cmd.Parameters.AddWithValue("@CONSIGNEE", ShippingList[0]);
                                }
                                else
                                {
                                    cmd.Parameters.AddWithValue("@CONSIGNEE", "");
                                }

                                cmd.Parameters.AddWithValue("@PORTLOAD", row["PORTLOAD"].ToString());
                                cmd.Parameters.AddWithValue("@DESTINATION", row["DESTINATION"].ToString());
                                cmd.Parameters.AddWithValue("@COUNTRY", row["COUNTRY"].ToString());
                                cmd.Parameters.AddWithValue("@VESSEL", row["VESSEL"].ToString());
                                cmd.Parameters.AddWithValue("@VOYNO", row["VOYNO"].ToString());
                                cmd.Parameters.AddWithValue("@CNTRTOTAL", row["CNTRTOTAL"].ToString());
                                cmd.Parameters.AddWithValue("@BLTYPE", row["BLTYPE"].ToString());
                                cmd.Parameters.AddWithValue("@SERVICE", row["SERVICE"].ToString());
                                cmd.Parameters.AddWithValue("@ETD", row["ETD"].ToString());
                                cmd.Parameters.AddWithValue("@ATD", row["ATD"].ToString());
                                cmd.Parameters.AddWithValue("@LINKCUSTTIME", row["LINKCUSTTIME"].ToString());
                                cmd.Parameters.AddWithValue("@CREATETIME", row["CREATETIME"].ToString());
                                cmd.Parameters.AddWithValue("@MBLNOTIME", row["MBLNOTIME"].ToString());
                                cmd.Parameters.AddWithValue("@BSDATE", row["BSDATE"].ToString());
                                cmd.Parameters.AddWithValue("@CARRIER", row["CARRIER"].ToString());
                                cmd.Parameters.AddWithValue("@PONO", row["PONO"].ToString());
                                Shipping = row["DESCRIPTION"].ToString();
                                Shipping = Shipping.Replace("\n", "\\");
                                Shipping = Shipping.Replace("\r", " ");
                                ShippingList = Shipping.Split('\\');
                                if (ShippingList.Length != 0)
                                {
                                    cmd.Parameters.AddWithValue("@GOODSNAME", ShippingList[0]);
                                }
                                else
                                {
                                    cmd.Parameters.AddWithValue("@GOODSNAME", "");
                                }
                                cmd.Parameters.AddWithValue("@HSCODE", row["HSCODE"].ToString());
                                cmd.Parameters.AddWithValue("@NOPKGS", row["NOPKGS"].ToString());
                                cmd.Parameters.AddWithValue("@GROSSWEIGHT", row["GROSSWEIGHT"].ToString());
                                cmd.Parameters.AddWithValue("@MEASUREMENT", row["MEASUREMENT"].ToString());
                                cmd.Parameters.AddWithValue("@INSURANCEOP", row["INSURANCEOP"].ToString());
                                cmd.ExecuteNonQuery();
                                var sqlctn = "select * from op_ctn where BSNO='"+ row["AS_ID"].ToString() + "'";
                                SqlDataAdapter dataAdapterCtn = new SqlDataAdapter(sqlctn, conn);
                                DataTable tQueryCtn = new DataTable();
                                dataAdapterCtn.Fill(tQueryCtn);
                                if (tQueryCtn.Rows.Count > 0)
                                {

                                    foreach (DataRow rowctn in tQueryCtn.Rows)
                                    {
                                        var cmdInsertCtnSQL = "insert into tb_ctn (CTN_ID,BSNO,CTNCODE,[SIZE],CTN,CTNNUM,TEU,CTNALL,CNTRNO,SEALNO,PKGS,KGS,CBM,REMARK,KINDPKGS,TAREWEIGHT,GOODSNAME,CTNSTATUS,MASTERNO,WEIGHTYPE,WEIGHKGS,WEIGHATTN,WEIGHTEL,WEIGHSIGN,WEIGHDATE,TRUCKER,TRUCKFEE,FREESTORAGEDAY,STORAGEDAY,STORAGEPRICE,STORAGEFEE,FREECTNDAY,CTNDAY,CTNPRICE,CTNFEE,TRUCKNO,VGMCONNCOM,VGMADDR,VGMEMAIL,ISTEMP,TIXIANGSHIJIAN) values ("
                                             + "NEWID(),'" + row["AS_ID"].ToString() + "','" + rowctn["CTNCODE"].ToString() + "','" + rowctn["SIZE"].ToString()  + "','" + rowctn["CTN"].ToString()  + "'," + rowctn["CTNNUM"].ToString()+ "," + rowctn["TEU"].ToString()+ ",'" + rowctn["CTNALL"].ToString().Replace("'", "''") + "','" + rowctn["CNTRNO"].ToString() + "','" + rowctn["SEALNO"].ToString() + "','" + rowctn["PKGS"].ToString() + "'," + rowctn["KGS"].ToString()+ "," + rowctn["CBM"].ToString() + ",'" + rowctn["REMARK"].ToString() + "','" + rowctn["KINDPKGS"].ToString()+ "'," + rowctn["TAREWEIGHT"].ToString()+ ",'','"
                                             + rowctn["CTNSTATUS"].ToString() + "','" + rowctn["MASTERNO"].ToString()+ "','',0,'0','','','','',0"
                                         + ",0,0,0,0,0,0,0,0,'','','','','','')";
                                        SqlCommand cmdInsertCtn = new SqlCommand(cmdInsertCtnSQL, db, trans);
                                        cmdInsertCtn.ExecuteNonQuery();
                                    }
                                }
                                trans.Commit();
                            }
                            log.Debug("插入" + row["MBLNO"].ToString() + "-" + row["HBLNO"].ToString()+"完成！");


                                //if (!string.IsNullOrEmpty(item.SJLGSJ))
                                //{
                                //    string sql ="update op_seae set ATD='"+ item.SJLGSJ + "' where VESSEL='"+ item.YWCM + "' AND VOYNO='"+ item.CKHC+ "'";
                                //    SqlCommand cmd = new SqlCommand(sql, dbcon, trans);
                                //    cmd.ExecuteNonQuery();
                                //}
                            }
                        }
                        #endregion



                    db.Close();
                }


                foreach (DataRow row in tQuery.Rows)
                {

                    foreach (DataColumn col in tQuery.Columns)
                    {
                        mblno = row["MBLNO"].ToString();

                    }

                }


            }
            catch (Exception ex)
            {
                log.Error(ex.Message);
                log.Error(ex.StackTrace);
            }
        }

        static public string GETBSNO(string MBLNO, SqlConnection dbcon)
        {


            var strSql = new StringBuilder();
            strSql.Append("SELECT BSNO from V_OP_BS where MBLNO='" + MBLNO + "'");
            SqlDataAdapter adapter = new SqlDataAdapter(strSql.ToString(), dbcon);
            DataTable table = new DataTable();
            adapter.Fill(table);
            var BSNO = "";
            if (table.Rows.Count > 0)
            {
                foreach (DataRow row in table.Rows)
                {
                    BSNO = row["BSNO"].ToString();

                }

            }


            return BSNO;
        }
    }
}