|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.Linq;
|
|
|
using System.Web;
|
|
|
using System.Text;
|
|
|
using DSWeb.Areas.MvcShipping.Models.MsOpStatusNew;
|
|
|
using Microsoft.Practices.EnterpriseLibrary.Data;
|
|
|
using System.Data;
|
|
|
using DSWeb.MvcShipping.Models.MsOpSeae;
|
|
|
using qingdaoport;
|
|
|
using Ivony.Html;
|
|
|
using Ivony.Html.Parser;
|
|
|
using System.Text.RegularExpressions;
|
|
|
|
|
|
namespace DSWeb.Areas.MvcShipping.DAL
|
|
|
{
|
|
|
public class MsOpStatusNewDAL
|
|
|
{
|
|
|
|
|
|
/// <summary>
|
|
|
/// 创建/更新 状态树主表
|
|
|
/// 海运出口保存时只产生主状态、不产生集装箱状态
|
|
|
/// </summary>
|
|
|
/// <param name="bsno"></param>
|
|
|
/// <param name="oper">操作人</param>
|
|
|
/// <returns></returns>
|
|
|
public bool SaveStatusTree ( string bsno ,string oper) {
|
|
|
//根据提单号获取Opseae数据
|
|
|
OpSeaeModel OpSeaeModel = GetOpSeae(bsno);
|
|
|
if (OpSeaeModel.BSNO==null)
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
//如果主题单号下已有状态树则执行更新操作
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
if (CheckOpSeaeHasStatusTree(bsno))
|
|
|
{
|
|
|
//更新状态树
|
|
|
|
|
|
sb.Append("update Op_StatusMain set ");
|
|
|
sb.Append("ChuanGongSi = '" + OpSeaeModel.ChuanGongSi+ "',");
|
|
|
sb.Append("ChuanMingHangCi = '" + OpSeaeModel.ChuanMingHangCi + "',");
|
|
|
sb.Append("ShiFaGang = '" + OpSeaeModel.ShiFaGang + "',");
|
|
|
sb.Append("MuDiGang = '" + OpSeaeModel.MuDiGang + "',");
|
|
|
sb.Append("MBLNO = '" + OpSeaeModel.MBLNO + "',");
|
|
|
sb.Append("XiangXingXiangLiang = '" + OpSeaeModel.XiangXingXiangLiang.Replace("'","''") + "',");
|
|
|
sb.Append("ETD = '" + OpSeaeModel.ETD + "',");
|
|
|
sb.Append("ETA = '" + OpSeaeModel.ETA + "'");
|
|
|
sb.Append(" where BSNO = '" + bsno + "'");
|
|
|
|
|
|
//删除之前的明细
|
|
|
DeleteStatusDetails(bsno);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//新建状态树
|
|
|
sb.Append(@"Insert into Op_StatusMain
|
|
|
(GID,BSNO,ChuanGongSi,ChuanMingHangCi,ShiFaGang,MuDiGang,MBLNO,XiangXingXiangLiang,ETD,ETA) ");
|
|
|
sb.Append("values (");
|
|
|
sb.Append("'"+Guid.NewGuid()+"',");
|
|
|
sb.Append("'" + OpSeaeModel.BSNO + "',");
|
|
|
sb.Append("'" + OpSeaeModel.ChuanGongSi + "',");
|
|
|
sb.Append("'" + OpSeaeModel.ChuanMingHangCi + "',");
|
|
|
sb.Append("'" + OpSeaeModel.ShiFaGang + "',");
|
|
|
sb.Append("'" + OpSeaeModel.MuDiGang + "',");
|
|
|
|
|
|
sb.Append("'" + OpSeaeModel.MBLNO + "',");
|
|
|
sb.Append("'" + OpSeaeModel.XiangXingXiangLiang.Replace("'", "''") + "',");
|
|
|
sb.Append("'" + OpSeaeModel.ETD + "',");
|
|
|
sb.Append("'" + OpSeaeModel.ETA + "'");
|
|
|
sb.Append(")");
|
|
|
}
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
int flag = db.ExecuteNonQuery(CommandType.Text,sb.ToString());
|
|
|
|
|
|
//主提单号为空时，状态更新为【已接单】
|
|
|
if (OpSeaeModel.MBLNO==""||OpSeaeModel.MBLNO==null)
|
|
|
{
|
|
|
UpdateMainStatus(OpSeaeModel.BSNO, 0,oper,OpSeaeModel.CreateTime);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//主提单号不为空时，状态更新为【已出号】
|
|
|
UpdateMainStatus(OpSeaeModel.BSNO, 3, oper);
|
|
|
}
|
|
|
|
|
|
|
|
|
return flag > 0;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 更新状态节点-主表
|
|
|
/// </summary>
|
|
|
/// <param name="bsno">业务编号</param>
|
|
|
/// <param name="mblno">主提单号</param>
|
|
|
/// <param name="statusNode">0：已结单 1:已发入货通知 2：已订舱 3：已出号 4：已提单确认 5:费用已提交</param>
|
|
|
/// <param name="statusTime">状态完成时间</param>
|
|
|
/// <returns></returns>
|
|
|
public bool UpdateMainStatus (string bsno,int statusNode,string Oper,string statusTime="") {
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
string timeStr = statusTime==""?DateTime.Now.ToString("yyyy-MM-dd hh:mm:ss"):statusTime;
|
|
|
sb.Append("update Op_StatusMain ");
|
|
|
if (statusNode==0)
|
|
|
{
|
|
|
sb.Append(" set YiJieDanTime = '" + timeStr + "',");
|
|
|
sb.Append(" YiJieDanOp = '" + Oper + "'");
|
|
|
}
|
|
|
else if(statusNode==1)
|
|
|
{
|
|
|
sb.Append(" set YiFaRuHuoTongZhiTime = '" + timeStr + "',");
|
|
|
sb.Append(" YiFaRuHuoTongZhiOp = '" + Oper + "'");
|
|
|
}
|
|
|
else if (statusNode == 2)
|
|
|
{
|
|
|
sb.Append(" set YiDingCangTime = '" + timeStr + "',");
|
|
|
sb.Append(" YiDingCangOp = '" + Oper + "'");
|
|
|
}
|
|
|
else if (statusNode == 3)
|
|
|
{
|
|
|
sb.Append(" set YiChuHaoTime = '" + timeStr + "',");
|
|
|
sb.Append(" YiChuHaoOp = '" + Oper + "'");
|
|
|
}
|
|
|
else if (statusNode == 4)
|
|
|
{
|
|
|
sb.Append(" set YiTiDanQueRenTime = '" + timeStr + "',");
|
|
|
sb.Append(" YiTiDanQueRenOp = '" + Oper + "'");
|
|
|
}
|
|
|
else if (statusNode == 5)
|
|
|
{
|
|
|
sb.Append(" set FeiYongYiTiJiaoTime = '" + timeStr + "',");
|
|
|
sb.Append(" FeiYongYiTiJiaoOp = '" + Oper + "'");
|
|
|
}
|
|
|
sb.Append(" where BSNO in ('" + bsno + "')");
|
|
|
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
int flag = db.ExecuteNonQuery(CommandType.Text, sb.ToString());
|
|
|
return flag > 0;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 更新状态节点-青岛港码头
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public bool UpdateQdportStatus (OpSeaeQDPortDataModel model,string bsno) {
|
|
|
if (!checkOpSeaeQDPortDataModel(model))
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
//如果没有主表数据，创建主表数据
|
|
|
if (!CheckOpSeaeHasStatusTree(bsno))
|
|
|
{
|
|
|
SaveStatusTree(bsno, "System");
|
|
|
}
|
|
|
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
List<StatusDetails> listDetails = new List<StatusDetails>();
|
|
|
var mtxxList = model.mtxxList.Where(m => m.DQZTMC=="已装船").OrderBy(m => m.XH).ToList();
|
|
|
var ydbgList = model.ydbgList.OrderBy(m => m.XH).ToList();
|
|
|
var hgbgdfxList = model.bgdfxList.OrderBy(m => m.CONTA_ID).ToList();
|
|
|
var zzfxList = model.zzfxList.OrderBy(m => m.XH).ToList();
|
|
|
for (int i = 0; i < mtxxList.Count; i++)
|
|
|
{
|
|
|
StatusDetails sd = new StatusDetails();
|
|
|
sd.BSNO = bsno;
|
|
|
sd.MBLNO = mtxxList[i].TDH;
|
|
|
sd.XiangHao = mtxxList[i].XH;
|
|
|
sd.YunDiZhengChangMsg = ydbgList[i].HZMS;
|
|
|
sd.YunDiZhengChangTime =ydbgList.Count>0?ydbgList[i].HZSJ.ToString():"";
|
|
|
sd.YiRuZhaKouTime =mtxxList.Count>0?mtxxList[i].SJRGSJ.ToString():"";
|
|
|
sd.BaoGuanDanYiTongGuanFangXingTime =hgbgdfxList.Count>0?hgbgdfxList[i].R_DATE.ToString():"";
|
|
|
sd.CangDanYiZhuangZaiFangXingTime = zzfxList.Count>0?zzfxList[i].RDATE.ToString():"";
|
|
|
sd.YiZhuangChuanTime =mtxxList.Count>0?mtxxList[i].SJCGSJ.ToString():"";
|
|
|
listDetails.Add(sd);
|
|
|
}
|
|
|
|
|
|
|
|
|
foreach (var item in listDetails)
|
|
|
{
|
|
|
SaveStatusDetails(item, bsno);
|
|
|
}
|
|
|
string mblno = GetMBLNOWithBSNO(bsno);
|
|
|
string cgs = GetChuanGongSiWithMBLNO(mblno);
|
|
|
if (cgs=="达飞"|| cgs=="CMA" || cgs=="cma")
|
|
|
{
|
|
|
GetCMAData(mblno);
|
|
|
}
|
|
|
else if (cgs == "MAERSK") {
|
|
|
GetMaerskDetailsIntoDBWithMBLNO(mblno);
|
|
|
}
|
|
|
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
private bool SaveStatusDetails ( StatusDetails model,string bsno) {
|
|
|
|
|
|
StringBuilder sb = new StringBuilder();
|
|
|
if (CheckHasCtnWithBSNOAndCTNNO(bsno, model.XiangHao))
|
|
|
{
|
|
|
//如果同提单号下的该箱号已存在，对本条状态执行更新操作
|
|
|
sb.Append("update Op_StatusDetails set ");
|
|
|
sb.Append("CangDanJieShouShenBaoTime = '" + model.CangDanJieShouShenBaoTime + "', ");
|
|
|
sb.Append("YunDiZhengChangMsg = '" + model.YunDiZhengChangMsg + "', ");
|
|
|
sb.Append("YunDiZhengChangTime = '" + model.YunDiZhengChangTime + "', ");
|
|
|
sb.Append("YiRuZhaKouTime = '" + model.YiRuZhaKouTime + "', ");
|
|
|
sb.Append("BaoGuanDanYiTongGuanFangXingTime = '" + model.BaoGuanDanYiTongGuanFangXingTime + "', ");
|
|
|
sb.Append("CangDanYiZhuangZaiFangXingTime = '" + model.CangDanYiZhuangZaiFangXingTime + "', ");
|
|
|
sb.Append("YiZhuangChuanTime = '" + model.YiZhuangChuanTime + "' ");
|
|
|
sb.Append("where bsno in ('" + bsno + "') and XiangHao = '" + model.XiangHao + "'");
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
//如果同提单号下的该箱号不存在，执行插入操作
|
|
|
sb.Append("insert into Op_StatusDetails ");
|
|
|
sb.Append("values(");
|
|
|
sb.Append("'" + Guid.NewGuid() + "',");
|
|
|
sb.Append("'" + model.BSNO + "',");
|
|
|
sb.Append("'" + model.MBLNO + "',");
|
|
|
sb.Append("'" + model.XiangHao + "',");
|
|
|
sb.Append("'" + model.YiTiXiangTime + "',");
|
|
|
sb.Append("'" + model.YiFanChangTime + "',");
|
|
|
sb.Append("'" + model.CangDanJieShouShenBaoTime + "',");
|
|
|
sb.Append("'" + model.YunDiZhengChangMsg + "',");
|
|
|
sb.Append("'" + model.YunDiZhengChangTime + "',");
|
|
|
sb.Append("'" + model.YiRuZhaKouTime + "',");
|
|
|
sb.Append("'" + model.BaoGuanDanYiTongGuanFangXingTime + "',");
|
|
|
sb.Append("'" + model.CangDanYiZhuangZaiFangXingTime + "',");
|
|
|
sb.Append("'" + model.YiZhuangChuanTime + "'");
|
|
|
sb.Append(")");
|
|
|
}
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
int flag = db.ExecuteNonQuery(CommandType.Text, sb.ToString());
|
|
|
return flag > 0;
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取状态数据
|
|
|
/// </summary>
|
|
|
/// <param name="strCondition"></param>
|
|
|
/// <returns></returns>
|
|
|
public static List<MsOpStatusNew> GetStatusData ( string mblno="" )
|
|
|
{
|
|
|
|
|
|
var strSql = new StringBuilder();
|
|
|
|
|
|
strSql.Append(@"select
|
|
|
os.ChuanGongSi,
|
|
|
os.ChuanMingHangCi,
|
|
|
os.ShiFaGang,
|
|
|
os.MuDiGang,
|
|
|
os.BSNO,
|
|
|
os.MBLNO,
|
|
|
os.XiangXingXiangLiang,
|
|
|
os.ETD,
|
|
|
os.ETA,
|
|
|
os.YiJieDanTime,
|
|
|
os.YiJieDanOp,
|
|
|
os.YiFaRuHuoTongZhiTime,
|
|
|
os.YiFaRuHuoTongZhiOp,
|
|
|
os.YiDingCangTime,
|
|
|
os.YiDingCangOp,
|
|
|
os.YiChuHaoTime,
|
|
|
os.YiChuHaoOp,
|
|
|
os.YiTiDanQueRenTime,
|
|
|
os.YiTiDanQueRenOp,
|
|
|
os.FeiYongYiTiJiaoTime,
|
|
|
os.FeiYongYiTiJiaoOp,
|
|
|
osd.XiangHao ,
|
|
|
osd.YiTiXiangTime ,
|
|
|
osd.YiFanChangTime ,
|
|
|
osd.CangDanJieShouShenBaoTime ,
|
|
|
osd.YunDiZhengChangMsg ,
|
|
|
osd.YunDiZhengChangTime ,
|
|
|
osd.YiRuZhaKouTime ,
|
|
|
osd.BaoGuanDanYiTongGuanFangXingTime ,
|
|
|
osd.CangDanYiZhuangZaiFangXingTime ,
|
|
|
osd.YiZhuangChuanTime
|
|
|
from Op_StatusMain os
|
|
|
LEFT JOIN Op_StatusDetails osd on os.bsno = osd.BSNO ");
|
|
|
if (mblno != "")
|
|
|
{
|
|
|
strSql.Append(" where os.mblno= '" + mblno + "'");
|
|
|
}
|
|
|
return SetStatusData(strSql);
|
|
|
}
|
|
|
|
|
|
private static List<MsOpStatusNew> SetStatusData ( StringBuilder strSql )
|
|
|
{
|
|
|
var list = new List<MsOpStatusNew>();
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
using (IDataReader reader = db.ExecuteReader(CommandType.Text, strSql.ToString()))
|
|
|
{
|
|
|
while (reader.Read())
|
|
|
{
|
|
|
MsOpStatusNew s = new MsOpStatusNew();
|
|
|
//创建主状态模型
|
|
|
StatusMain sm = new StatusMain();
|
|
|
sm.ChuanGongSi = reader["ChuanGongSi"].ToString();
|
|
|
sm.ChuanMingHangCi = reader["ChuanMingHangCi"].ToString();
|
|
|
sm.ShiFaGang = reader["ShiFaGang"].ToString();
|
|
|
sm.MuDiGang = reader["MuDiGang"].ToString();
|
|
|
sm.BSNO = reader["BSNO"].ToString();
|
|
|
sm.MBLNO = reader["MBLNO"].ToString();
|
|
|
sm.XiangXingXiangLiang = reader["XiangXingXiangLiang"].ToString();
|
|
|
sm.ETD = reader["ETD"].ToString();
|
|
|
sm.ETA = reader["ETA"].ToString();
|
|
|
sm.YiJieDanTime = convertTimeStr(reader["YiJieDanTime"].ToString());
|
|
|
sm.YiJieDanOp = reader["YiJieDanOp"].ToString();
|
|
|
sm.YiFaRuHuoTongZhiTime = convertTimeStr(reader["YiFaRuHuoTongZhiTime"].ToString());
|
|
|
sm.YiFaRuHuoTongZhiOp = reader["YiFaRuHuoTongZhiOp"].ToString();
|
|
|
sm.YiDingCangTime = convertTimeStr(reader["YiDingCangTime"].ToString());
|
|
|
sm.YiDingCangOp = reader["YiDingCangOp"].ToString();
|
|
|
sm.YiChuHaoTime = convertTimeStr( reader["YiChuHaoTime"].ToString());
|
|
|
sm.YiChuHaoOp = reader["YiChuHaoOp"].ToString();
|
|
|
sm.YiTiDanQueRenTime = convertTimeStr( reader["YiTiDanQueRenTime"].ToString());
|
|
|
sm.YiTiDanQueRenOp = reader["YiTiDanQueRenOp"].ToString();
|
|
|
sm.FeiYongYiTiJiaoTime = convertTimeStr(reader["FeiYongYiTiJiaoTime"].ToString());
|
|
|
sm.FeiYongYiTiJiaoOp = reader["FeiYongYiTiJiaoOp"].ToString();
|
|
|
s.StatusMain = sm;
|
|
|
//创建明细状态模型
|
|
|
StatusDetails sd = new StatusDetails();
|
|
|
sd.XiangHao = reader["XiangHao"].ToString();
|
|
|
sd.YiTiXiangTime = convertTimeStr(reader["YiTiXiangTime"].ToString());
|
|
|
sd.YiFanChangTime = convertTimeStr( reader["YiFanChangTime"].ToString());
|
|
|
sd.CangDanJieShouShenBaoTime = convertTimeStr( reader["CangDanJieShouShenBaoTime"].ToString());
|
|
|
sd.YunDiZhengChangMsg = reader["YunDiZhengChangMsg"].ToString();
|
|
|
sd.YunDiZhengChangTime = convertTimeStr(reader["YunDiZhengChangTime"].ToString());
|
|
|
sd.YiRuZhaKouTime = convertTimeStr(reader["YiRuZhaKouTime"].ToString());
|
|
|
sd.BaoGuanDanYiTongGuanFangXingTime = convertTimeStr(reader["BaoGuanDanYiTongGuanFangXingTime"].ToString());
|
|
|
sd.CangDanYiZhuangZaiFangXingTime = convertTimeStr( reader["CangDanYiZhuangZaiFangXingTime"].ToString());
|
|
|
sd.YiZhuangChuanTime = convertTimeStr( reader["YiZhuangChuanTime"].ToString());
|
|
|
s.StatusDetails = sd;
|
|
|
list.Add(s);
|
|
|
}
|
|
|
reader.Close();
|
|
|
}
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取OpSeae信息
|
|
|
/// </summary>
|
|
|
/// <param name="mblno"></param>
|
|
|
/// <returns></returns>
|
|
|
private static OpSeaeModel GetOpSeae (string BSNO) {
|
|
|
string sql = @"select BSNO,MBLNO,CARRIER ChuanGongSi,MBLNO,VESSEL+'/'+VOYNO ChuanMingHangCi,
|
|
|
CNTRTOTAL XiangXingXiangLiang,PORTLOAD ShiFaGang,
|
|
|
PORTDISCHARGE MuDiGang,ETD,ETA,CreateTime,OP
|
|
|
from op_seae where BSNO = '" + BSNO + "'";
|
|
|
string sql2 = @" select CNTRNO XiangHao from op_ctn where bsno = '" + BSNO + "'";
|
|
|
OpSeaeModel model = new OpSeaeModel();
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
using (IDataReader reader = db.ExecuteReader(CommandType.Text, sql))
|
|
|
{
|
|
|
while (reader.Read())
|
|
|
{
|
|
|
model.BSNO = reader["BSNO"].ToString();
|
|
|
model.MBLNO = reader["MBLNO"].ToString();
|
|
|
model.ChuanGongSi = reader["ChuanGongSi"].ToString();
|
|
|
model.ChuanMingHangCi = reader["ChuanMingHangCi"].ToString();
|
|
|
model.XiangXingXiangLiang = reader["XiangXingXiangLiang"].ToString();
|
|
|
model.ShiFaGang = reader["ShiFaGang"].ToString();
|
|
|
model.MuDiGang = reader["MuDiGang"].ToString();
|
|
|
model.ETD = reader["ETD"].ToString();
|
|
|
model.ETA = reader["ETA"].ToString();
|
|
|
model.CreateTime = reader["CreateTime"].ToString();
|
|
|
model.Creator = reader["OP"].ToString();
|
|
|
}
|
|
|
reader.Close();
|
|
|
}
|
|
|
|
|
|
List<OpSeaeCtnModel> list = new List<OpSeaeCtnModel>();
|
|
|
using (IDataReader reader = db.ExecuteReader(CommandType.Text, sql2))
|
|
|
{
|
|
|
while (reader.Read())
|
|
|
{
|
|
|
}
|
|
|
reader.Close();
|
|
|
}
|
|
|
|
|
|
model.CtnList = list;
|
|
|
return model;
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 判断是否已有状态树
|
|
|
/// </summary>
|
|
|
/// <param name="mblno"></param>
|
|
|
/// <returns></returns>
|
|
|
private static bool CheckOpSeaeHasStatusTree ( string bsno ) {
|
|
|
string sql = "select count (*) from Op_StatusMain where bsno = '" + bsno + "'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
int flag = Convert.ToInt32(db.ExecuteScalar(CommandType.Text,sql));
|
|
|
if (flag>0)
|
|
|
{
|
|
|
return true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 判断是否已有明细状态
|
|
|
/// </summary>
|
|
|
/// <param name="mblno"></param>
|
|
|
/// <param name="xianghao"></param>
|
|
|
/// <returns></returns>
|
|
|
private static bool CheckHasCtnWithBSNOAndCTNNO (string bsno,string xianghao) {
|
|
|
string sql = "select count (*) from Op_StatusDetails where BSNO = '" + bsno + "' and XiangHao = '" + xianghao + "'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
int flag = Convert.ToInt32(db.ExecuteScalar(CommandType.Text, sql));
|
|
|
if (flag > 0)
|
|
|
{
|
|
|
return true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public static string GetBSNOWithMBLNO ( string mblno ) {
|
|
|
string sql = "select bsno from op_seae where mblno = '"+mblno+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
string bsno = Convert.ToString(db.ExecuteScalar(CommandType.Text, sql));
|
|
|
return bsno;
|
|
|
}
|
|
|
|
|
|
public static string GetMBLNOWithBSNO ( string bsno )
|
|
|
{
|
|
|
string sql = "select mblno from op_seae where bsno in ('" + bsno + "')";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
string mblno = Convert.ToString(db.ExecuteScalar(CommandType.Text, sql));
|
|
|
return mblno;
|
|
|
}
|
|
|
|
|
|
private static string convertTimeStr ( string time ) {
|
|
|
if (time=="")
|
|
|
{
|
|
|
return "[未取到相关时间]";
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return time;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private static bool checkOpSeaeQDPortDataModel ( OpSeaeQDPortDataModel model )
|
|
|
{
|
|
|
if (model==null||model.bgdfxList==null||model.mtxxList==null||model.wllhList==null||model.wlshList==null
|
|
|
||model.ydbgList==null||model.zxdList==null||model.zzfxList==null)
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return true;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
#region 船公司相关-CMA
|
|
|
public static bool GetCMAData (string mblno) {
|
|
|
if (mblno=="")
|
|
|
{
|
|
|
return false;
|
|
|
}
|
|
|
HttpHelper http = new HttpHelper();
|
|
|
string cmaUrl = "http://www.cma-cgm.com/ebusiness/tracking/search?SearchBy=BL&Reference="+mblno;
|
|
|
HttpItem item = new HttpItem()
|
|
|
{
|
|
|
URL = cmaUrl,//URL 必需项
|
|
|
Method = "get",//URL 可选项 默认为Get
|
|
|
|
|
|
};
|
|
|
HttpResult result1 = http.GetHtml(item);
|
|
|
string html = result1.Html;
|
|
|
IHtmlDocument document = new JumonyParser().Parse(html);
|
|
|
IEnumerable<IHtmlElement> result = document.Find("tbody[class=sep-horiz]");
|
|
|
//多箱
|
|
|
if (result.ToList().Count==0)
|
|
|
{
|
|
|
SaveCMAWithMultiData(document,mblno);
|
|
|
}
|
|
|
//单箱
|
|
|
else
|
|
|
{
|
|
|
SaveCMAWithSingleData(document,mblno);
|
|
|
}
|
|
|
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
private static void SaveCMAWithSingleData ( IHtmlDocument document,string mblno)
|
|
|
{
|
|
|
IEnumerable<IHtmlElement> result = document.Find("tbody[class=sep-horiz]");
|
|
|
List<string> ctnList = new List<string>();
|
|
|
List<string> msgList = new List<string>();
|
|
|
List<string> timeList = new List<string>();
|
|
|
IHtmlElement title = document.FindFirst("title");
|
|
|
string titlestr = title.InnerText();
|
|
|
string XiangHao = titlestr.Replace("Tracking details for Container", "").Trim();
|
|
|
|
|
|
foreach (var r in result)
|
|
|
{
|
|
|
//当前步骤获取
|
|
|
ctnList.Add(XiangHao);
|
|
|
//状态
|
|
|
IHtmlElement currtr = r.FindFirst("tr[class=date-current]");
|
|
|
IHtmlElement currstatus = currtr.FindFirst("td[data-move=status]");
|
|
|
string currstatusstr = currstatus.InnerText();
|
|
|
msgList.Add(currstatusstr);
|
|
|
//时间
|
|
|
IHtmlElement currstatustime = currtr.FindFirst("td[data-move=date]");
|
|
|
string currstatustimestr = currstatustime.InnerText();
|
|
|
try
|
|
|
{
|
|
|
string dt = DateTime.Parse(currstatustimestr).ToString("yyyy-MM-dd hh:mm");
|
|
|
timeList.Add(dt);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
timeList.Add("");
|
|
|
}
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
//插入数据库
|
|
|
if (ctnList.Count > 0)
|
|
|
{
|
|
|
//删除
|
|
|
string delSql = "delete from Op_StatusCarrier where MBLNO = '" + mblno + "' and Carrier = 'CMA'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
db.ExecuteNonQuery(CommandType.Text, delSql);
|
|
|
StringBuilder sbValues = new StringBuilder();
|
|
|
for (int i = 0; i < ctnList.Count; i++)
|
|
|
{
|
|
|
sbValues.Append("(");
|
|
|
sbValues.Append("'" + Guid.NewGuid() + "',");
|
|
|
sbValues.Append("'CMA',");
|
|
|
sbValues.Append("'" + mblno + "',");
|
|
|
sbValues.Append("'" + ctnList[i] + "',");
|
|
|
sbValues.Append("'" + msgList[i] + "',");
|
|
|
sbValues.Append("'" + timeList[i] + "'");
|
|
|
sbValues.Append("),");
|
|
|
}
|
|
|
//插入
|
|
|
string valuestr = sbValues.ToString().Substring(0, sbValues.ToString().Length - 1);
|
|
|
StringBuilder insSb = new StringBuilder();
|
|
|
insSb.Append("insert into Op_StatusCarrier (GID,Carrier,MBLNO,XiangHao,StatusMsg,StatusTime) ");
|
|
|
insSb.Append("values" + valuestr);
|
|
|
string sql = insSb.ToString();
|
|
|
db.ExecuteNonQuery(CommandType.Text, sql);
|
|
|
|
|
|
}
|
|
|
|
|
|
GetCMADataDetailsInToDBWithDocumentForSingleData(document,mblno,XiangHao);
|
|
|
}
|
|
|
private static void SaveCMAWithMultiData ( IHtmlDocument document, string mblno )
|
|
|
{
|
|
|
IEnumerable<IHtmlElement> result = document.Find("tbody");
|
|
|
List<string> ctnList = new List<string>();
|
|
|
List<string> msgList = new List<string>();
|
|
|
List<string> timeList = new List<string>();
|
|
|
foreach (var r in result)
|
|
|
{
|
|
|
IEnumerable<IHtmlElement> tds1 = r.Find("td[data-ctnr=id]");
|
|
|
foreach (var td in tds1)
|
|
|
{
|
|
|
ctnList.Add(td.InnerText());
|
|
|
}
|
|
|
IEnumerable<IHtmlElement> tds2 = r.Find("td[data-ctnr=date]");
|
|
|
foreach (var td in tds2)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string dt = DateTime.Parse(td.InnerText()).ToString("yyyy-MM-dd hh:mm");
|
|
|
timeList.Add(dt);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
timeList.Add("");
|
|
|
}
|
|
|
|
|
|
}
|
|
|
IEnumerable<IHtmlElement> tds3 = r.Find("td[data-ctnr=status]");
|
|
|
foreach (var td in tds3)
|
|
|
{
|
|
|
msgList.Add(td.InnerText());
|
|
|
}
|
|
|
}
|
|
|
|
|
|
//插入数据库
|
|
|
if (ctnList.Count > 0)
|
|
|
{
|
|
|
//删除
|
|
|
string delSql = "delete from Op_StatusCarrier where MBLNO = '" + mblno + "' and Carrier = 'CMA'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
db.ExecuteNonQuery(CommandType.Text, delSql);
|
|
|
StringBuilder sbValues = new StringBuilder();
|
|
|
for (int i = 0; i < ctnList.Count; i++)
|
|
|
{
|
|
|
sbValues.Append("(");
|
|
|
sbValues.Append("'" + Guid.NewGuid() + "',");
|
|
|
sbValues.Append("'CMA',");
|
|
|
sbValues.Append("'" + mblno + "',");
|
|
|
sbValues.Append("'" + ctnList[i] + "',");
|
|
|
sbValues.Append("'" + msgList[i] + "',");
|
|
|
sbValues.Append("'" + timeList[i] + "'");
|
|
|
sbValues.Append("),");
|
|
|
}
|
|
|
//插入
|
|
|
string valuestr = sbValues.ToString().Substring(0, sbValues.ToString().Length - 1);
|
|
|
StringBuilder insSb = new StringBuilder();
|
|
|
insSb.Append("insert into Op_StatusCarrier (GID,Carrier,MBLNO,XiangHao,StatusMsg,StatusTime) ");
|
|
|
insSb.Append("values" + valuestr);
|
|
|
string sql = insSb.ToString();
|
|
|
db.ExecuteNonQuery(CommandType.Text, sql);
|
|
|
//插入集装箱状态明细
|
|
|
foreach (var ctn in ctnList)
|
|
|
{
|
|
|
GetCMADataDetailsInToDBWithMBLNOAndXiangHaoForMultiData(mblno, ctn);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public static List<OpCMAStatus> GetCMADataFromDB(string mblno,string xianghao){
|
|
|
string sql = "select * from Op_StatusCarrier where Carrier = 'CMA' and MBLNO = '"+mblno+"' and XiangHao = '"+xianghao+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
List<OpCMAStatus> list = new List<OpCMAStatus>();
|
|
|
using (IDataReader reader = db.ExecuteReader(CommandType.Text, sql))
|
|
|
{
|
|
|
while (reader.Read())
|
|
|
{
|
|
|
OpCMAStatus s = new OpCMAStatus();
|
|
|
s.MBLNO = reader["MBLNO"].ToString();
|
|
|
s.XiangHao = reader["XiangHao"].ToString();
|
|
|
s.StatusMsg = reader["StatusMsg"].ToString();
|
|
|
s.StatusTime = reader["StatusTime"].ToString();
|
|
|
list.Add(s);
|
|
|
}
|
|
|
}
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
public static List<OpCMAStatus> GetStatusDetailsDataFromDB ( string mblno, string xianghao )
|
|
|
{
|
|
|
string sql = "select * from Op_StatusCarrierDetails where MBLNO = '" + mblno + "' and XiangHao = '" + xianghao + "' order by StatusTime";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
List<OpCMAStatus> list = new List<OpCMAStatus>();
|
|
|
using (IDataReader reader = db.ExecuteReader(CommandType.Text, sql))
|
|
|
{
|
|
|
while (reader.Read())
|
|
|
{
|
|
|
OpCMAStatus s = new OpCMAStatus();
|
|
|
s.MBLNO = reader["MBLNO"].ToString();
|
|
|
s.XiangHao = reader["XiangHao"].ToString();
|
|
|
s.StatusMsg = reader["StatusMsg"].ToString();
|
|
|
s.StatusTime = reader["StatusTime"].ToString();
|
|
|
s.ChuanMing = reader["Vessel"].ToString();
|
|
|
s.HangCi = reader["Voyage"].ToString();
|
|
|
list.Add(s);
|
|
|
}
|
|
|
}
|
|
|
return list;
|
|
|
}
|
|
|
|
|
|
|
|
|
private static bool GetCMADataDetailsInToDBWithMBLNOAndXiangHaoForMultiData ( string mblno, string xianghao ) {
|
|
|
string urlstr = "http://www.cma-cgm.com/eBusiness/tracking/detail/"+xianghao+"?SearchCriteria=BL&SearchByReference="+mblno;
|
|
|
HttpHelper http = new HttpHelper();
|
|
|
HttpItem item = new HttpItem()
|
|
|
{
|
|
|
// URL = textBox1.Text,//URL 必需项
|
|
|
URL = urlstr,
|
|
|
Method = "get",//URL 可选项 默认为Get
|
|
|
|
|
|
};
|
|
|
HttpResult result1 = http.GetHtml(item);
|
|
|
string html = result1.Html;
|
|
|
IHtmlDocument document = new JumonyParser().Parse(html);
|
|
|
IEnumerable<IHtmlElement> result = document.Find("tbody[class=sep-horiz]");
|
|
|
List<string> statusList = new List<string>();
|
|
|
List<string> timeList = new List<string>();
|
|
|
List<string> locList = new List<string>();
|
|
|
List<string> vesselList = new List<string>();
|
|
|
List<string> voyageList = new List<string>();
|
|
|
foreach (var r in result)
|
|
|
{
|
|
|
//状态
|
|
|
IEnumerable<IHtmlElement> statusTd = r.Find("td[data-move=status]");
|
|
|
foreach (var status in statusTd)
|
|
|
{
|
|
|
statusList.Add(status.InnerText());
|
|
|
}
|
|
|
//时间
|
|
|
IEnumerable<IHtmlElement> timeTd = r.Find("td[data-move=date]");
|
|
|
foreach (var time in timeTd)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string dt = DateTime.Parse(time.InnerText()).ToString("yyyy-MM-dd hh:mm");
|
|
|
timeList.Add(dt);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
timeList.Add("");
|
|
|
}
|
|
|
}
|
|
|
//位置
|
|
|
IEnumerable<IHtmlElement> locTd = r.Find("td[data-move=location]");
|
|
|
foreach (var loc in locTd)
|
|
|
{
|
|
|
locList.Add(loc.InnerText());
|
|
|
}
|
|
|
//船名
|
|
|
IEnumerable<IHtmlElement> vesselTd = r.Find("td[data-move=vessel]");
|
|
|
foreach (var vessel in vesselTd)
|
|
|
{
|
|
|
vesselList.Add(vessel.InnerText());
|
|
|
}
|
|
|
//航次
|
|
|
IEnumerable<IHtmlElement> voyageTd = r.Find("td[data-move=voyage]");
|
|
|
foreach (var voyage in voyageTd)
|
|
|
{
|
|
|
voyageList.Add(voyage.InnerText());
|
|
|
}
|
|
|
|
|
|
//数据库操作
|
|
|
if (statusList.Count>0)
|
|
|
{
|
|
|
//删除
|
|
|
string delSql = "delete from Op_StatusCarrierDetails where MBLNO = '" + mblno + "' and xianghao='"+xianghao+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
db.ExecuteNonQuery(CommandType.Text, delSql);
|
|
|
StringBuilder sbValues = new StringBuilder();
|
|
|
for (int i = 0; i < statusList.Count; i++)
|
|
|
{
|
|
|
sbValues.Append("(");
|
|
|
sbValues.Append("'" + Guid.NewGuid() + "',");
|
|
|
sbValues.Append("'"+mblno+"',");
|
|
|
sbValues.Append("'" + xianghao + "',");
|
|
|
sbValues.Append("'" + statusList[i] + "',");
|
|
|
sbValues.Append("'" + timeList[i] + "',");
|
|
|
sbValues.Append("'" + locList[i] + "',");
|
|
|
sbValues.Append("'" + vesselList[i] + "',");
|
|
|
sbValues.Append("'" + voyageList[i] + "'");
|
|
|
sbValues.Append("),");
|
|
|
}
|
|
|
//插入
|
|
|
string valuestr = sbValues.ToString().Substring(0, sbValues.ToString().Length - 1);
|
|
|
StringBuilder insSb = new StringBuilder();
|
|
|
insSb.Append("insert into Op_StatusCarrierDetails (GID,MBLNO,XIANGHAO,StatusMsg,StatusTime,LOC,Vessel,Voyage) ");
|
|
|
insSb.Append("values" + valuestr);
|
|
|
string sql = insSb.ToString();
|
|
|
db.ExecuteNonQuery(CommandType.Text, sql);
|
|
|
}
|
|
|
}
|
|
|
return true;
|
|
|
|
|
|
}
|
|
|
|
|
|
private static bool GetCMADataDetailsInToDBWithDocumentForSingleData ( IHtmlDocument document,string mblno,string xianghao )
|
|
|
{
|
|
|
IEnumerable<IHtmlElement> result = document.Find("tbody[class=sep-horiz]");
|
|
|
List<string> statusList = new List<string>();
|
|
|
List<string> timeList = new List<string>();
|
|
|
List<string> locList = new List<string>();
|
|
|
List<string> vesselList = new List<string>();
|
|
|
List<string> voyageList = new List<string>();
|
|
|
foreach (var r in result)
|
|
|
{
|
|
|
//状态
|
|
|
IEnumerable<IHtmlElement> statusTd = r.Find("td[data-move=status]");
|
|
|
foreach (var status in statusTd)
|
|
|
{
|
|
|
statusList.Add(status.InnerText());
|
|
|
}
|
|
|
//时间
|
|
|
IEnumerable<IHtmlElement> timeTd = r.Find("td[data-move=date]");
|
|
|
foreach (var time in timeTd)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string dt = DateTime.Parse(time.InnerText()).ToString("yyyy-MM-dd hh:mm");
|
|
|
timeList.Add(dt);
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
timeList.Add("");
|
|
|
}
|
|
|
}
|
|
|
//位置
|
|
|
IEnumerable<IHtmlElement> locTd = r.Find("td[data-move=location]");
|
|
|
foreach (var loc in locTd)
|
|
|
{
|
|
|
locList.Add(loc.InnerText());
|
|
|
}
|
|
|
//船名
|
|
|
IEnumerable<IHtmlElement> vesselTd = r.Find("td[data-move=vessel]");
|
|
|
foreach (var vessel in vesselTd)
|
|
|
{
|
|
|
vesselList.Add(vessel.InnerText());
|
|
|
}
|
|
|
//航次
|
|
|
IEnumerable<IHtmlElement> voyageTd = r.Find("td[data-move=voyage]");
|
|
|
foreach (var voyage in voyageTd)
|
|
|
{
|
|
|
voyageList.Add(voyage.InnerText());
|
|
|
}
|
|
|
|
|
|
//数据库操作
|
|
|
if (statusList.Count>0)
|
|
|
{
|
|
|
//删除
|
|
|
string delSql = "delete from Op_StatusCarrierDetails where MBLNO = '" + mblno + "' and xianghao = '"+xianghao+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
db.ExecuteNonQuery(CommandType.Text, delSql);
|
|
|
StringBuilder sbValues = new StringBuilder();
|
|
|
for (int i = 0; i < statusList.Count; i++)
|
|
|
{
|
|
|
sbValues.Append("(");
|
|
|
sbValues.Append("'" + Guid.NewGuid() + "',");
|
|
|
sbValues.Append("'"+mblno+"',");
|
|
|
sbValues.Append("'" + xianghao + "',");
|
|
|
sbValues.Append("'" + statusList[i] + "',");
|
|
|
sbValues.Append("'" + timeList[i] + "',");
|
|
|
sbValues.Append("'" + locList[i] + "',");
|
|
|
sbValues.Append("'" + vesselList[i] + "',");
|
|
|
sbValues.Append("'" + voyageList[i] + "'");
|
|
|
sbValues.Append("),");
|
|
|
}
|
|
|
//插入
|
|
|
string valuestr = sbValues.ToString().Substring(0, sbValues.ToString().Length - 1);
|
|
|
StringBuilder insSb = new StringBuilder();
|
|
|
insSb.Append("insert into Op_StatusCarrierDetails (GID,MBLNO,XIANGHAO,StatusMsg,StatusTime,LOC,Vessel,Voyage) ");
|
|
|
insSb.Append("values" + valuestr);
|
|
|
string sql = insSb.ToString();
|
|
|
db.ExecuteNonQuery(CommandType.Text, sql);
|
|
|
}
|
|
|
}
|
|
|
return true;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
#region 船公司相关-马士基
|
|
|
private static void GetMaerskDetailsIntoDBWithMBLNO ( string mblno ) {
|
|
|
string url = "https://my.maerskline.com/tracking/search?searchNumber="+mblno;
|
|
|
HttpItem item = new HttpItem()
|
|
|
{
|
|
|
URL = url,//URL 必需项
|
|
|
Method = "get"//URL 可选项 默认为Get
|
|
|
};
|
|
|
HttpHelper http = new HttpHelper();
|
|
|
HttpResult result1 = http.GetHtml(item);
|
|
|
string html = result1.Html;
|
|
|
IHtmlDocument document = new JumonyParser().Parse(html);
|
|
|
|
|
|
|
|
|
IEnumerable<IHtmlElement> result = document.Find("table[class=table table-striped cols20 schedule-table]");
|
|
|
foreach (var r in result)
|
|
|
{
|
|
|
string xianghao = r.FindFirst("span[class=tracking_container_id]").InnerText().Trim();
|
|
|
List<string> statusList = new List<string>();
|
|
|
List<string> timeList = new List<string>();
|
|
|
List<string> locList = new List<string>();
|
|
|
List<string> vesselList = new List<string>();
|
|
|
List<string> voyageList = new List<string>();
|
|
|
|
|
|
IEnumerable<IHtmlElement> details = r.NextElement().Find("table[class=row container-move past transport-plan-tbl cols20]");
|
|
|
|
|
|
foreach (var d in details)
|
|
|
{
|
|
|
string loc = d.PreviousElement().InnerText();
|
|
|
loc = loc == null ? "" : loc;
|
|
|
|
|
|
locList.Add(loc);
|
|
|
|
|
|
IEnumerable<IHtmlElement> tds = d.Find("td");
|
|
|
int index = 0;
|
|
|
foreach (var td in tds)
|
|
|
{
|
|
|
//时间
|
|
|
if (index==2)
|
|
|
{
|
|
|
string timestr = td.InnerText().Replace("\r\n"," ");
|
|
|
timestr = DateTime.Parse(timestr).ToString("yyyy-MM-dd HH:mm");
|
|
|
timeList.Add(timestr);
|
|
|
}
|
|
|
//状态、船名、航次
|
|
|
if (index==3)
|
|
|
{
|
|
|
string statusstr = td.InnerText().Replace("\r\n", " ");
|
|
|
string[] sArray = Regex.Split(statusstr, "Voyage No.:", RegexOptions.IgnoreCase);
|
|
|
if (sArray.Length >= 2)
|
|
|
{
|
|
|
string hangci = sArray[1].Trim();
|
|
|
string status = "Load on";
|
|
|
string chuanming = sArray[0].Replace("Load on", "").TrimStart().TrimEnd();
|
|
|
vesselList.Add(chuanming); ;
|
|
|
voyageList.Add(hangci);
|
|
|
statusList.Add(status);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
vesselList.Add(""); ;
|
|
|
voyageList.Add("");
|
|
|
statusList.Add(sArray[0]);
|
|
|
}
|
|
|
}
|
|
|
index++;
|
|
|
}
|
|
|
}
|
|
|
//插入数据库
|
|
|
if (statusList.Count>0)
|
|
|
{
|
|
|
string delsql = "delete from Op_StatusCarrierDetails where mblno ='"+mblno+"' and xianghao = '"+xianghao+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
db.ExecuteNonQuery(CommandType.Text, delsql);
|
|
|
StringBuilder sbValues = new StringBuilder();
|
|
|
for (int i = 0; i < statusList.Count; i++)
|
|
|
{
|
|
|
sbValues.Append("(");
|
|
|
sbValues.Append("'" + Guid.NewGuid() + "',");
|
|
|
sbValues.Append("'" + mblno + "',");
|
|
|
sbValues.Append("'" + xianghao + "',");
|
|
|
sbValues.Append("'" + statusList[i] + "',");
|
|
|
sbValues.Append("'" + timeList[i] + "',");
|
|
|
sbValues.Append("'" + locList[i] + "',");
|
|
|
sbValues.Append("'" + vesselList[i] + "',");
|
|
|
sbValues.Append("'" + voyageList[i] + "'");
|
|
|
sbValues.Append("),");
|
|
|
}
|
|
|
//插入
|
|
|
string valuestr = sbValues.ToString().Substring(0, sbValues.ToString().Length - 1);
|
|
|
StringBuilder insSb = new StringBuilder();
|
|
|
insSb.Append("insert into Op_StatusCarrierDetails (GID,MBLNO,XIANGHAO,StatusMsg,StatusTime,LOC,Vessel,Voyage) ");
|
|
|
insSb.Append("values" + valuestr);
|
|
|
string sql = insSb.ToString();
|
|
|
db.ExecuteNonQuery(CommandType.Text, sql);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
private static bool DeleteStatusDetails(string bsno)
|
|
|
{
|
|
|
string sql = "delete from Op_StatusDetails where bsno = '"+bsno+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
bool rst= db.ExecuteNonQuery(CommandType.Text,sql)>0;
|
|
|
return rst;
|
|
|
}
|
|
|
|
|
|
private static string GetChuanGongSiWithMBLNO ( string mblno ) {
|
|
|
string sql = "select top 1 CARRIER from op_seae where mblno = '"+mblno+"'";
|
|
|
Database db = DatabaseFactory.CreateDatabase();
|
|
|
var cgs = db.ExecuteScalar(CommandType.Text,sql);
|
|
|
if (cgs==null)
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return cgs.ToString();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
} |