|
|
using JobYunDang.Model;
|
|
|
using log4net;
|
|
|
using Newtonsoft.Json;
|
|
|
using Quartz;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Data;
|
|
|
using System.Data.SqlClient;
|
|
|
using System.Linq;
|
|
|
using System.Text;
|
|
|
using YDN;
|
|
|
|
|
|
namespace JobYunDang
|
|
|
{
|
|
|
public class JobDownloadData : IJob
|
|
|
{
|
|
|
private ILog log = LogManager.GetLogger(typeof(JobDownloadData));
|
|
|
|
|
|
public void Execute(IJobExecutionContext context)
|
|
|
{
|
|
|
|
|
|
string connStr = context.JobDetail.JobDataMap.GetString("ConnectString");
|
|
|
string reqUrl = context.JobDetail.JobDataMap.GetString("ReqUrl");
|
|
|
string companyCode = context.JobDetail.JobDataMap.GetString("CompanyCode");
|
|
|
string companySecret = context.JobDetail.JobDataMap.GetString("CompanySecret");
|
|
|
string querySql = context.JobDetail.JobDataMap.GetString("QuerySql");
|
|
|
|
|
|
|
|
|
using (SqlConnection dbcon = new SqlConnection(connStr))
|
|
|
{
|
|
|
SqlDataAdapter adapter = new SqlDataAdapter(querySql, dbcon);
|
|
|
DataTable table = new DataTable();
|
|
|
adapter.Fill(table);
|
|
|
if (table.Columns.Contains("mblno") && table.Columns.Contains("carrierid"))
|
|
|
{
|
|
|
if (table.Rows.Count > 0)
|
|
|
{
|
|
|
List<dynamic> listOjb = new List<dynamic>();
|
|
|
foreach (DataRow row in table.Rows)
|
|
|
{
|
|
|
|
|
|
if (row["mblno"].ToString()!=""&& row["carrierid"].ToString() !=""&& row["portloadid"].ToString() != "") {
|
|
|
var obj = new
|
|
|
{
|
|
|
referenceno = row["mblno"].ToString(),
|
|
|
carriercd = row["carrierid"].ToString(),
|
|
|
pol = row["portloadid"].ToString()
|
|
|
|
|
|
};
|
|
|
listOjb.Add(obj);
|
|
|
log.Debug($"下载数据请求，主提单号：{row["mblno"].ToString()}");
|
|
|
}
|
|
|
}
|
|
|
|
|
|
var map = new Dictionary<string, string>();
|
|
|
map.Add("data", JsonConvert.SerializeObject(listOjb));
|
|
|
|
|
|
var urlMap = new Dictionary<string, string>();
|
|
|
urlMap.Add("companyid", companyCode);
|
|
|
|
|
|
var html = RequestApi.HttpPost(reqUrl, companySecret, urlMap, map).Replace("'", "''");
|
|
|
|
|
|
if (html.IndexOf("exceptioncode") >= 0)
|
|
|
{
|
|
|
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
|
|
|
var list = JsonConvert.DeserializeObject<List<JsonDownloadReturn>>(html);
|
|
|
|
|
|
dbcon.Open();
|
|
|
StringBuilder sbSql = new StringBuilder();
|
|
|
foreach (var track in list)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (dbcon.State==0)
|
|
|
dbcon.Open();
|
|
|
if (track.success)
|
|
|
{
|
|
|
using (var trans = dbcon.BeginTransaction())
|
|
|
{
|
|
|
sbSql.Clear();
|
|
|
|
|
|
#region ydw_linertracking
|
|
|
sbSql.AppendLine($"delete ydw_linertracking where keyid='{track.objlinertracking.keyid}';");
|
|
|
string sql_linertracking = $@"INSERT INTO [ydw_linertracking]
|
|
|
(keyid,
|
|
|
blprefix,
|
|
|
referenceno,
|
|
|
blno,
|
|
|
bkgno,
|
|
|
trfsno,
|
|
|
ctnrno,
|
|
|
isctnr,
|
|
|
bkgvolumn,
|
|
|
carriercd,
|
|
|
carrier,
|
|
|
currentnodeplace,
|
|
|
currentnodetime,
|
|
|
currentnode,
|
|
|
updatetime,
|
|
|
createtime,
|
|
|
endtime,
|
|
|
pol,
|
|
|
dtp,
|
|
|
terminalcd,
|
|
|
terminal,
|
|
|
dptloadid,
|
|
|
vslname,
|
|
|
voy,
|
|
|
declarationno,
|
|
|
agentcd,
|
|
|
currentvslname,
|
|
|
currentvoy,
|
|
|
longtitude,
|
|
|
latitude)
|
|
|
VALUES
|
|
|
(
|
|
|
'{track.objlinertracking.keyid}',--keyid
|
|
|
'{track.objlinertracking.blprefix}',--blprefix
|
|
|
'{track.objlinertracking.referenceno}',--referenceno
|
|
|
'{track.objlinertracking.blno}',--blno
|
|
|
'{track.objlinertracking.bkgno}',--bkgno
|
|
|
'{track.objlinertracking.trfsno}',--trfsno
|
|
|
'{track.objlinertracking.ctnrno}',--ctnrno
|
|
|
'{track.objlinertracking.isctnr}',--isctnr
|
|
|
'{track.objlinertracking.bkgvolumn}',--bkgvolumn
|
|
|
'{track.objlinertracking.carriercd}',--carriercd
|
|
|
'{track.objlinertracking.carrier}',--carrier
|
|
|
'{track.objlinertracking.currentnodeplace}',--currentnodeplace
|
|
|
{(track.objlinertracking.currentnodetime.HasValue ? "'" + track.objlinertracking.currentnodetime.Value.ToString() + "'" : "null")},--currentnodetime
|
|
|
'{track.objlinertracking.currentnode}',--currentnode
|
|
|
{(track.objlinertracking.updatetime.HasValue ? "'" + track.objlinertracking.updatetime.Value.ToString() + "'" : "null")},--updatetime
|
|
|
{(track.objlinertracking.createtime.HasValue ? "'" + track.objlinertracking.createtime.Value.ToString() + "'" : "null")},--createtime
|
|
|
{(track.objlinertracking.endtime.HasValue ? "'" + track.objlinertracking.endtime.Value.ToString() + "'" : "null")},--endtime
|
|
|
'{track.objlinertracking.pol}',--pol
|
|
|
'{track.objlinertracking.dtp}',--dtp
|
|
|
'{track.objlinertracking.terminalcd}',--terminalcd
|
|
|
'{track.objlinertracking.terminal}',--terminal
|
|
|
'{track.objlinertracking.dptloadid}',--dptloadid
|
|
|
'{track.objlinertracking.vslname}',--vslname
|
|
|
'{track.objlinertracking.voy}',--voy
|
|
|
'{track.objlinertracking.declarationno}',--declarationno
|
|
|
'{track.objlinertracking.agentcd}',--agentcd
|
|
|
'{track.objlinertracking.currentvslname}',--currentvslname
|
|
|
'{track.objlinertracking.currentvoy}',--currentvoy
|
|
|
{(track.objlinertracking.longtitude.HasValue ? track.objlinertracking.longtitude.Value.ToString() : "null")},--longtitude
|
|
|
{(track.objlinertracking.latitude.HasValue ? track.objlinertracking.latitude.Value.ToString() : "null")}--latitude
|
|
|
);";
|
|
|
|
|
|
sbSql.AppendLine(sql_linertracking);
|
|
|
#endregion
|
|
|
|
|
|
#region ydw_linertrackingstatus
|
|
|
sbSql.AppendLine($"delete ydw_linertrackingstatus where fkeyid='{track.objlinertracking.keyid}';");
|
|
|
if (track.objlinertracking.lstlinertrackingstatus != null && track.objlinertracking.lstlinertrackingstatus.Count > 0)
|
|
|
{
|
|
|
foreach (var objsta in track.objlinertracking.lstlinertrackingstatus)
|
|
|
{
|
|
|
string sql_linertrackingstatus = $@"INSERT INTO [ydw_linertrackingstatus]
|
|
|
(
|
|
|
keyid,
|
|
|
fkeyid,
|
|
|
blno,
|
|
|
statuscd,
|
|
|
statedescription,
|
|
|
statustime,
|
|
|
statusplace,
|
|
|
vslname,
|
|
|
voy,
|
|
|
isest,
|
|
|
cancelid,
|
|
|
updatetime,
|
|
|
createtime
|
|
|
)
|
|
|
VALUES
|
|
|
(
|
|
|
'{objsta.keyid}',--keyid
|
|
|
'{objsta.fkeyid}',--fkeyid
|
|
|
'{objsta.blno}',--blno
|
|
|
'{objsta.statuscd}',--statuscd
|
|
|
'{objsta.statedescription}',--statedescription
|
|
|
{(objsta.statustime.HasValue ? "'" + objsta.statustime.Value.ToString() + "'" : "null")},--statustime
|
|
|
'{objsta.statusplace}',--statusplace
|
|
|
'{objsta.vslname}',--vslname
|
|
|
'{objsta.voy}',--voy
|
|
|
'{objsta.isest}',--isest
|
|
|
'{objsta.cancelid}',--cancelid
|
|
|
{(objsta.updatetime.HasValue ? "'" + objsta.updatetime.Value.ToString() + "'" : "null")},--updatetime
|
|
|
{(objsta.createtime.HasValue ? "'" + objsta.createtime.Value.ToString() + "'" : "null")}--createtime
|
|
|
);";
|
|
|
|
|
|
sbSql.AppendLine(sql_linertrackingstatus);
|
|
|
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region ydw_billinfo
|
|
|
|
|
|
if (track.objlinertracking.objbillinfo != null)
|
|
|
{
|
|
|
log.Debug($"下载数据，主提单号：{track.objlinertracking.objbillinfo.blprefix + track.objlinertracking.objbillinfo.blno+"-"+ track.objlinertracking.objbillinfo.bkgno}");
|
|
|
#region ydw_billinfo主表
|
|
|
sbSql.AppendLine($"update op_seae set YDWUpdate=GETDATE() where mblno='{track.objlinertracking.objbillinfo.blprefix + track.objlinertracking.objbillinfo.blno}' or mblno='{track.objlinertracking.objbillinfo.bkgno}';");
|
|
|
sbSql.AppendLine($"delete ydw_billinfo where keyid='{track.objlinertracking.objbillinfo.keyid}';");
|
|
|
string sql_billinfo = $@"INSERT INTO [ydw_billinfo]
|
|
|
(
|
|
|
keyid,
|
|
|
blprefix,
|
|
|
bkgno,
|
|
|
blno,
|
|
|
carriercd,
|
|
|
carrier,
|
|
|
plrcd,
|
|
|
plr,
|
|
|
polcd,
|
|
|
pol,
|
|
|
dtpcd,
|
|
|
dtp,
|
|
|
pldcd,
|
|
|
pld,
|
|
|
bkgvolumn,
|
|
|
vslname,
|
|
|
voy,
|
|
|
updatetime,
|
|
|
createtime,
|
|
|
blid,
|
|
|
currentnode,
|
|
|
currentnodetime,
|
|
|
currentnodeplace
|
|
|
)
|
|
|
VALUES
|
|
|
(
|
|
|
'{track.objlinertracking.objbillinfo.keyid}',--keyid
|
|
|
'{track.objlinertracking.objbillinfo.blprefix}',--blprefix
|
|
|
'{track.objlinertracking.objbillinfo.bkgno}',--bkgno
|
|
|
'{track.objlinertracking.objbillinfo.blno}',--blno
|
|
|
'{track.objlinertracking.objbillinfo.carriercd}',--carriercd
|
|
|
'{track.objlinertracking.objbillinfo.carrier}',--carrier
|
|
|
'{track.objlinertracking.objbillinfo.plrcd}',--plrcd
|
|
|
'{track.objlinertracking.objbillinfo.plr}',--plr
|
|
|
'{track.objlinertracking.objbillinfo.polcd}',--polcd
|
|
|
'{track.objlinertracking.objbillinfo.pol}',--pol
|
|
|
'{track.objlinertracking.objbillinfo.dtpcd}',--dtpcd
|
|
|
'{track.objlinertracking.objbillinfo.dtp}',--dtp
|
|
|
'{track.objlinertracking.objbillinfo.pldcd}',--pldcd
|
|
|
'{track.objlinertracking.objbillinfo.pld}',--pld
|
|
|
'{track.objlinertracking.objbillinfo.bkgvolumn}',--bkgvolumn
|
|
|
'{track.objlinertracking.objbillinfo.vslname}',--vslname
|
|
|
'{track.objlinertracking.objbillinfo.voy}',--voy
|
|
|
{(track.objlinertracking.objbillinfo.updatetime.HasValue ? "'" + track.objlinertracking.objbillinfo.updatetime.Value.ToString() + "'" : "null")},--updatetime
|
|
|
{(track.objlinertracking.objbillinfo.createtime.HasValue ? "'" + track.objlinertracking.objbillinfo.createtime.Value.ToString() + "'" : "null")},--createtime
|
|
|
'{track.objlinertracking.objbillinfo.blid}',--blid
|
|
|
'{track.objlinertracking.objbillinfo.currentnode}',--currentnode
|
|
|
{(track.objlinertracking.objbillinfo.currentnodetime.HasValue ? "'" + track.objlinertracking.objbillinfo.currentnodetime.Value.ToString() + "'" : "null")},--currentnodetime
|
|
|
'{track.objlinertracking.objbillinfo.currentnodeplace}'--currentnodeplace
|
|
|
);";
|
|
|
|
|
|
sbSql.AppendLine(sql_billinfo);
|
|
|
#endregion
|
|
|
|
|
|
#region ydw_carriage
|
|
|
if (track.objlinertracking.objbillinfo.lstcarriages != null)
|
|
|
{
|
|
|
sbSql.AppendLine($"delete ydw_carriage where bkeyid='{track.objlinertracking.objbillinfo.keyid}';");
|
|
|
foreach (var objcarr in track.objlinertracking.objbillinfo.lstcarriages)
|
|
|
{
|
|
|
string sql_carriage = $@"INSERT INTO [ydw_carriage]
|
|
|
(
|
|
|
keyid,
|
|
|
bkeyid,
|
|
|
sno,
|
|
|
vslname,
|
|
|
voy,
|
|
|
blno,
|
|
|
pol,
|
|
|
pod,
|
|
|
etd,
|
|
|
eta,
|
|
|
atd,
|
|
|
ata
|
|
|
)
|
|
|
VALUES
|
|
|
(
|
|
|
'{objcarr.keyid}',--keyid
|
|
|
'{objcarr.bkeyid}',--bkeyid
|
|
|
{(objcarr.sno.HasValue ? objcarr.sno.Value.ToString() : "null")},--sno
|
|
|
'{objcarr.vslname}',--vslname
|
|
|
'{objcarr.voy}',--voy
|
|
|
'{objcarr.blno}',--blno
|
|
|
'{objcarr.pol}',--pol
|
|
|
'{objcarr.pod}',--pod
|
|
|
{(objcarr.etd.HasValue ? "'" + objcarr.etd.Value.ToString() + "'" : "null")},--etd
|
|
|
{(objcarr.eta.HasValue ? "'" + objcarr.eta.Value.ToString() + "'" : "null")},--eta
|
|
|
{(objcarr.atd.HasValue ? "'" + objcarr.atd.Value.ToString() + "'" : "null")},--atd
|
|
|
{(objcarr.ata.HasValue ? "'" + objcarr.ata.Value.ToString() + "'" : "null")}--ata
|
|
|
);";
|
|
|
sbSql.AppendLine(sql_carriage);
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region ydw_ctnrinfo
|
|
|
if (track.objlinertracking.objbillinfo.lstctnrinfos != null)
|
|
|
{
|
|
|
sbSql.AppendLine($"delete ydw_ctnrinfo where bkeyid='{track.objlinertracking.objbillinfo.keyid}';");
|
|
|
foreach (var objctnr in track.objlinertracking.objbillinfo.lstctnrinfos)
|
|
|
{
|
|
|
string sql_ctnrinfo = $@"INSERT INTO [ydw_ctnrinfo]
|
|
|
(
|
|
|
keyid,
|
|
|
bkeyid,
|
|
|
vkeyid,
|
|
|
conno,
|
|
|
sealno,
|
|
|
csize,
|
|
|
ctype,
|
|
|
ctnrtype,
|
|
|
pkgs,
|
|
|
gwgt,
|
|
|
vgm,
|
|
|
currentstatus,
|
|
|
currenttime,
|
|
|
currentstation,
|
|
|
updatetime
|
|
|
)
|
|
|
VALUES
|
|
|
(
|
|
|
'{objctnr.keyid}',--keyid
|
|
|
'{objctnr.bkeyid}',--bkeyid
|
|
|
'{objctnr.vkeyid}',--vkeyid
|
|
|
'{objctnr.conno}',--conno
|
|
|
'{objctnr.sealno}',--sealno
|
|
|
'{objctnr.csize}',--csize
|
|
|
'{objctnr.ctype}',--ctype
|
|
|
'{objctnr.ctnrtype}',--ctnrtype
|
|
|
'{objctnr.pkgs}',--pkgs
|
|
|
'{objctnr.gwgt}',--gwgt
|
|
|
'{objctnr.vgm}',--vgm
|
|
|
'{objctnr.currentstatus}',--currentstatus
|
|
|
{(objctnr.currenttime.HasValue ? "'" + objctnr.currenttime.Value.ToString() + "'" : "null")},--currenttime
|
|
|
'{objctnr.currentstation}',--currentstation
|
|
|
{(objctnr.updatetime.HasValue ? "'" + objctnr.updatetime.Value.ToString() + "'" : "null")}--updatetime
|
|
|
);";
|
|
|
sbSql.AppendLine(sql_ctnrinfo);
|
|
|
|
|
|
#region ydw_ctnrstatus
|
|
|
if (objctnr.lstctnrstatus != null)
|
|
|
{
|
|
|
sbSql.AppendLine($"delete ydw_ctnrstatus where ckeyid='{objctnr.vkeyid}';");
|
|
|
foreach (var objctnrstatus in objctnr.lstctnrstatus)
|
|
|
{
|
|
|
string sql_ctnrstatus = $@"INSERT INTO [ydw_ctnrstatus]
|
|
|
(
|
|
|
keyid,
|
|
|
ckeyid,
|
|
|
status,
|
|
|
statedescription,
|
|
|
vslvoy,
|
|
|
vslname,
|
|
|
voy,
|
|
|
eventtime,
|
|
|
station,
|
|
|
transportation,
|
|
|
iscode,
|
|
|
isest,
|
|
|
updatetime
|
|
|
)
|
|
|
VALUES
|
|
|
(
|
|
|
'{objctnrstatus.keyid}',--keyid
|
|
|
'{objctnrstatus.ckeyid}',--ckeyid
|
|
|
'{objctnrstatus.status}',--status
|
|
|
'{objctnrstatus.statedescription}',--statedescription
|
|
|
'{objctnrstatus.vslvoy}',--vslvoy
|
|
|
'{objctnrstatus.vslname}',--vslname
|
|
|
'{objctnrstatus.voy}',--voy
|
|
|
{(objctnrstatus.eventtime.HasValue ? "'" + objctnrstatus.eventtime.Value.ToString() + "'" : "null")},--eventtime
|
|
|
'{objctnrstatus.station}',--station
|
|
|
'{objctnrstatus.transportation}',--transportation
|
|
|
'{objctnrstatus.iscode}',--iscode
|
|
|
'{objctnrstatus.isest}',--isest
|
|
|
{(objctnrstatus.updatetime.HasValue ? "'" + objctnrstatus.updatetime.Value.ToString() + "'" : "null")}--updatetime
|
|
|
);";
|
|
|
sbSql.AppendLine(sql_ctnrstatus);
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region ydw_terminaloptime
|
|
|
// sbSql.AppendLine($"delete ydw_terminaloptime where keyid='{track.objlinertracking.keyid}';");
|
|
|
|
|
|
// if (track.objlinertracking.objterminalop != null)
|
|
|
// {
|
|
|
// //测试发现track.objlinertracking.objterminalop.keyid返回null
|
|
|
// if (track.objlinertracking.objterminalop.keyid == null)
|
|
|
// {
|
|
|
// track.objlinertracking.objterminalop.keyid = Guid.NewGuid().ToString();
|
|
|
// }
|
|
|
|
|
|
// string sql_terminaloptime = $@"INSERT INTO [ydw_terminaloptime]
|
|
|
// (
|
|
|
//keyid,
|
|
|
//fkeyid,
|
|
|
//vslcd,
|
|
|
//vslname,
|
|
|
//vslnamecn,
|
|
|
//voyin,
|
|
|
//voyout,
|
|
|
//servicecd,
|
|
|
//servicename,
|
|
|
//carriercd,
|
|
|
//carrier,
|
|
|
//terminalcd,
|
|
|
//terminal,
|
|
|
//eta,
|
|
|
//ata,
|
|
|
//atd,
|
|
|
//etd,
|
|
|
//cyopentime,
|
|
|
//fumigationtime,
|
|
|
//cyclosetime,
|
|
|
//customcutofftime,
|
|
|
//cycutofftime,
|
|
|
//carriagecutofftime,
|
|
|
//cutofftime,
|
|
|
//remarks,
|
|
|
//createtime,
|
|
|
//updatetime,
|
|
|
//berthno
|
|
|
// )
|
|
|
// VALUES
|
|
|
// (
|
|
|
//'{track.objlinertracking.objterminalop.keyid}',--keyid
|
|
|
//'{track.objlinertracking.objterminalop.fkeyid}',--fkeyid
|
|
|
//'{track.objlinertracking.objterminalop.vslcd}',--vslcd
|
|
|
//'{track.objlinertracking.objterminalop.vslname}',--vslname
|
|
|
//'{track.objlinertracking.objterminalop.vslnamecn}',--vslnamecn
|
|
|
//'{track.objlinertracking.objterminalop.voyin}',--voyin
|
|
|
//'{track.objlinertracking.objterminalop.voyout}',--voyout
|
|
|
//'{track.objlinertracking.objterminalop.servicecd}',--servicecd
|
|
|
//'{track.objlinertracking.objterminalop.servicename}',--servicename
|
|
|
//'{track.objlinertracking.objterminalop.carriercd}',--carriercd
|
|
|
//'{track.objlinertracking.objterminalop.carrier}',--carrier
|
|
|
//'{track.objlinertracking.objterminalop.terminalcd}',--terminalcd
|
|
|
//'{track.objlinertracking.objterminalop.terminal}',--terminal
|
|
|
//{(track.objlinertracking.objterminalop.eta.HasValue ? "'" + track.objlinertracking.objterminalop.eta.Value.ToString() + "'" : "null")},--eta
|
|
|
//{(track.objlinertracking.objterminalop.ata.HasValue ? "'" + track.objlinertracking.objterminalop.ata.Value.ToString() + "'" : "null")},--ata
|
|
|
//{(track.objlinertracking.objterminalop.atd.HasValue ? "'" + track.objlinertracking.objterminalop.atd.Value.ToString() + "'" : "null")},--atd
|
|
|
//{(track.objlinertracking.objterminalop.etd.HasValue ? "'" + track.objlinertracking.objterminalop.etd.Value.ToString() + "'" : "null")},--etd
|
|
|
//{(track.objlinertracking.objterminalop.cyopentime.HasValue ? "'" + track.objlinertracking.objterminalop.cyopentime.Value.ToString() + "'" : "null")},--cyopentime
|
|
|
//{(track.objlinertracking.objterminalop.fumigationtime.HasValue ? "'" + track.objlinertracking.objterminalop.fumigationtime.Value.ToString() + "'" : "null")},--fumigationtime
|
|
|
//{(track.objlinertracking.objterminalop.cyclosetime.HasValue ? "'" + track.objlinertracking.objterminalop.cyclosetime.Value.ToString() + "'" : "null")},--cyclosetime
|
|
|
//{(track.objlinertracking.objterminalop.customcutofftime.HasValue ? "'" + track.objlinertracking.objterminalop.customcutofftime.Value.ToString() + "'" : "null")},--customcutofftime
|
|
|
//{(track.objlinertracking.objterminalop.cycutofftime.HasValue ? "'" + track.objlinertracking.objterminalop.cycutofftime.Value.ToString() + "'" : "null")},--cycutofftime
|
|
|
//{(track.objlinertracking.objterminalop.carriagecutofftime.HasValue ? "'" + track.objlinertracking.objterminalop.carriagecutofftime.Value.ToString() + "'" : "null")},--carriagecutofftime
|
|
|
//{(track.objlinertracking.objterminalop.cutofftime.HasValue ? "'" + track.objlinertracking.objterminalop.cutofftime.Value.ToString() + "'" : "null")},--cutofftime
|
|
|
//'{track.objlinertracking.objterminalop.remarks}',--remarks
|
|
|
//{(track.objlinertracking.objterminalop.createtime.HasValue ? "'" + track.objlinertracking.objterminalop.createtime.Value.ToString() + "'" : "null")},--createtime
|
|
|
//{(track.objlinertracking.objterminalop.updatetime.HasValue ? "'" + track.objlinertracking.objterminalop.updatetime.Value.ToString() + "'" : "null")},--updatetime
|
|
|
//'{track.objlinertracking.objterminalop.berthno}'--berthno
|
|
|
// );";
|
|
|
|
|
|
// sbSql.AppendLine(sql_terminaloptime);
|
|
|
// }
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
SqlCommand cmdIns = new SqlCommand(sbSql.ToString(), dbcon, trans);
|
|
|
cmdIns.ExecuteNonQuery();
|
|
|
|
|
|
trans.Commit();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
log.Error(ex.Message+ sbSql.ToString());
|
|
|
log.Error(ex.StackTrace);
|
|
|
dbcon.Close();
|
|
|
}
|
|
|
finally
|
|
|
{
|
|
|
dbcon.Close(); // 关闭数据库连接
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
dbcon.Close();
|
|
|
}
|
|
|
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
log.Debug($"未查询到数据，SQL语句：{querySql}");
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
log.Error($"未包含所需的列(mblno,carrierid)，SQL语句：{querySql}");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|