using System ;
using System.Data ;
using System.Collections.Generic ;
using System.Text ;
using DSWeb.MvcShipping.Models.CodeCtnEdi ;
using DSWeb.MvcShipping.Models.MsCodeAfrEdi ;
using Microsoft.Practices.EnterpriseLibrary.Data ;
using DSWeb.Areas.CommMng.Models ;
using HcUtility.Comm ;
namespace DSWeb.MvcShipping.DAL.MsCodeCtnEdi
{
public class MsCodeCtnEdiDAL
{
#region 查询
static public List < CodeCtnEdi > GetDataList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_ctn_edi.EDINAME) as EDINAMEREF,'' as PORTID" ) ;
strSql . Append ( " from code_ctn_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else {
strSql . Append ( " order by EDINAME,CTN" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetCustList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,CUST as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_cust_edi.EDINAME) as EDINAMEREF,'' as PORTID" ) ;
strSql . Append ( " from code_cust_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,CUST" ) ;
}
return SetData ( strSql ) ;
}
public static List < CodeCtnEdi > GetCustListByName ( string CUSTOMERNAME , string EDINAME ) {
var condition = $"code_cust_edi.CUST='{CUSTOMERNAME}' and EDINAME='{EDINAME}'" ;
var result = GetCustList ( condition ) ;
return result ;
}
public static string GetCustEdiNameByName ( string CUSTOMERNAME , string EDINAME )
{
var condition = $"code_cust_edi.CUST='{CUSTOMERNAME}' and EDINAME='{EDINAME}'" ;
var result = GetCustList ( condition ) ;
if ( result ! = null & & result . Count > 0 )
{
return result [ 0 ] . CTN ;
}
else {
return CUSTOMERNAME ;
}
}
static public List < CodeCtnEdi > GetPkgsList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,PKGS as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_pkgs_edi.EDINAME) as EDINAMEREF,'' as PORTID" ) ;
strSql . Append ( " from code_pkgs_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,PKGS" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetVesselList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,VESSEL as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_vessel_edi.EDINAME) as EDINAMEREF,'' as PORTID" ) ;
strSql . Append ( " from code_vessel_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,VESSEL" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetSERVICEList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,SERVICE as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_service_edi.EDINAME) as EDINAMEREF,'' as PORTID" ) ;
strSql . Append ( " from code_service_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,SERVICE" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetPORTDISCHARGEList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,PORTDISCHARGE as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_disport_edi.EDINAME) as EDINAMEREF,PORTID" ) ;
strSql . Append ( " from code_disport_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,PORTDISCHARGE" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetISSUETYPEList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,BLTYPE as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_issutype_edi.EDINAME) as EDINAMEREF,'' PORTID" ) ;
strSql . Append ( " from code_issutype_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by EDINAME,BLTYPE" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetFeeNameList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "ID as GID,FEENAME as CTN,FEEENAME EDICODE, EDINAME,'' REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_fee_edi.EDINAME) EDINAMEREF,'' PORTID" ) ;
strSql . Append ( " from code_fee_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by ID" ) ;
}
return SetData ( strSql ) ;
}
static public List < CodeCtnEdi > GetReeferfList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT " ) ;
strSql . Append ( "GID,REEFERF as CTN,EDICODE,EDINAME,REMARK" ) ;
strSql . Append ( ",(select EnumValueName from tSysEnumValue where LangId=0 and EnumTypeID=97012 and EnumValueID=code_reeferf_edi.EDINAME) as EDINAMEREF,'' PORTID" ) ;
strSql . Append ( " from code_reeferf_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by REEFERF" ) ;
}
return SetData ( strSql ) ;
}
static public CodeCtnEdi GetData ( string condition )
{
CodeCtnEdi data = null ;
var list = GetDataList ( condition ) ;
if ( list . Count > 0 )
data = list [ 0 ] ;
if ( data = = null )
{
data = new CodeCtnEdi ( ) ;
}
return data ;
}
private static List < CodeCtnEdi > SetData ( StringBuilder strSql )
{
var headList = new List < CodeCtnEdi > ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( IDataReader reader = db . ExecuteReader ( CommandType . Text , strSql . ToString ( ) ) )
{
while ( reader . Read ( ) )
{
CodeCtnEdi data = new CodeCtnEdi ( ) ;
#region Set DB data to Object
data . GID = Convert . ToString ( reader [ "GID" ] ) ;
data . CTN = Convert . ToString ( reader [ "CTN" ] ) ;
data . EDICODE = Convert . ToString ( reader [ "EDICODE" ] ) ;
data . EDINAME = Convert . ToString ( reader [ "EDINAME" ] ) ;
data . EDINAMEREF = Convert . ToString ( reader [ "EDINAMEREF" ] ) ;
data . REMARK = Convert . ToString ( reader [ "REMARK" ] ) ;
data . PORTID = Convert . ToString ( reader [ "PORTID" ] ) ;
# endregion
headList . Add ( data ) ;
}
reader . Close ( ) ;
}
return headList ;
}
public static Dictionary < string , string > GetFeeNameDicByName ( string EDINAME )
{
var result = new Dictionary < string , string > ( ) ;
var condition = $" EDINAME='{EDINAME}'" ;
var namelist = GetFeeNameList ( condition ) ;
if ( namelist ! = null & & namelist . Count > 0 ) {
foreach ( var item in namelist ) {
result . Add ( item . CTN , item . EDICODE ) ;
}
}
return result ;
}
static public List < MsCodeAfrEdi > GetAFRList ( string strCondition , string sort = null )
{
var strSql = new StringBuilder ( ) ;
strSql . Append ( "SELECT *" ) ;
strSql . Append ( ",(select SHORTNAME from info_client where GID=code_afr_edi.LINKGID) as CustName" ) ;
strSql . Append ( " from code_afr_edi where 1=1 " ) ;
if ( ! string . IsNullOrEmpty ( strCondition ) )
{
strSql . Append ( " and " + strCondition ) ;
}
var sortstring = DatasetSort . Getsortstring ( sort ) ;
if ( ! string . IsNullOrEmpty ( sortstring ) )
{
strSql . Append ( " order by " + sortstring ) ;
}
else
{
strSql . Append ( " order by MODIFIEDTIME" ) ; //CustName
}
return SetDataAFR ( strSql ) ;
}
private static List < MsCodeAfrEdi > SetDataAFR ( StringBuilder strSql )
{
var headList = new List < MsCodeAfrEdi > ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( IDataReader reader = db . ExecuteReader ( CommandType . Text , strSql . ToString ( ) ) )
{
while ( reader . Read ( ) )
{
MsCodeAfrEdi data = new MsCodeAfrEdi ( ) ;
#region Set DB data to Object
data . GID = ( reader [ "GID" ] = = null ? "" : Convert . ToString ( reader [ "GID" ] ) ) ; //编号
data . LINKGID = ( reader [ "LINKGID" ] = = null ? "" : Convert . ToString ( reader [ "LINKGID" ] ) ) ; //关联客户GID
data . SHIPPERNAME = ( reader [ "SHIPPERNAME" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERNAME" ] ) ) ; //发货人名称
data . SHIPPERADDR1 = ( reader [ "SHIPPERADDR1" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERADDR1" ] ) ) ; //发货人地址1
data . SHIPPERADDR2 = ( reader [ "SHIPPERADDR2" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERADDR2" ] ) ) ; //发货人地址2
data . SHIPPERADDR3 = ( reader [ "SHIPPERADDR3" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERADDR3" ] ) ) ; //发货人地址3
data . SHIPPERCITY = ( reader [ "SHIPPERCITY" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERCITY" ] ) ) ; //SHIPPERCITY
data . SHIPPERPROVINCE = ( reader [ "SHIPPERPROVINCE" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERPROVINCE" ] ) ) ; //发货人省
data . SHIPPERPOSTCODE = ( reader [ "SHIPPERPOSTCODE" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERPOSTCODE" ] ) ) ; //发货人邮编
data . SHIPPERCOUNTRY = ( reader [ "SHIPPERCOUNTRY" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERCOUNTRY" ] ) ) ; //发货人国家
data . SHIPPERATTN = ( reader [ "SHIPPERATTN" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERATTN" ] ) ) ; //发货人联系人
data . SHIPPERTEL = ( reader [ "SHIPPERTEL" ] = = null ? "" : Convert . ToString ( reader [ "SHIPPERTEL" ] ) ) ; //发货人联系方式
data . CONSIGNEENAME = ( reader [ "CONSIGNEENAME" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEENAME" ] ) ) ; //收货人名称
data . CONSIGNEEADDR1 = ( reader [ "CONSIGNEEADDR1" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEADDR1" ] ) ) ; //收货人地址1
data . CONSIGNEEADDR2 = ( reader [ "CONSIGNEEADDR2" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEADDR2" ] ) ) ; //收货人地址2
data . CONSIGNEEADDR3 = ( reader [ "CONSIGNEEADDR3" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEADDR3" ] ) ) ; //收货人地址3
data . CONSIGNEECITY = ( reader [ "CONSIGNEECITY" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEECITY" ] ) ) ; //收货人城市
data . CONSIGNEEPROVINCE = ( reader [ "CONSIGNEEPROVINCE" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEPROVINCE" ] ) ) ; //收货人省
data . CONSIGNEEPOSTCODE = ( reader [ "CONSIGNEEPOSTCODE" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEPOSTCODE" ] ) ) ; //收货人邮编
data . CONSIGNEECOUNTRY = ( reader [ "CONSIGNEECOUNTRY" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEECOUNTRY" ] ) ) ; //收货人国家
data . CONSIGNEEATTN = ( reader [ "CONSIGNEEATTN" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEEATTN" ] ) ) ; //收货人联系人
data . CONSIGNEETEL = ( reader [ "CONSIGNEETEL" ] = = null ? "" : Convert . ToString ( reader [ "CONSIGNEETEL" ] ) ) ; //收货人联系方式
data . NOTIFYPARTYNAME = ( reader [ "NOTIFYPARTYNAME" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYNAME" ] ) ) ; //通知人名称
data . NOTIFYPARTYADDR1 = ( reader [ "NOTIFYPARTYADDR1" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYADDR1" ] ) ) ; //通知人地址1
data . NOTIFYPARTYADDR2 = ( reader [ "NOTIFYPARTYADDR2" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYADDR2" ] ) ) ; //通知人地址2
data . NOTIFYPARTYADDR3 = ( reader [ "NOTIFYPARTYADDR3" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYADDR3" ] ) ) ; //通知人地址3
data . NOTIFYPARTYCITY = ( reader [ "NOTIFYPARTYCITY" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYCITY" ] ) ) ; //通知人城市
data . NOTIFYPARTYPROVINCE = ( reader [ "NOTIFYPARTYPROVINCE" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYPROVINCE" ] ) ) ; //通知人省
data . NOTIFYPARTYPOSTCODE = ( reader [ "NOTIFYPARTYPOSTCODE" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYPOSTCODE" ] ) ) ; //通知人邮编
data . NOTIFYPARTYCOUNTRY = ( reader [ "NOTIFYPARTYCOUNTRY" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYCOUNTRY" ] ) ) ; //通知人国家
data . NOTIFYPARTYATTN = ( reader [ "NOTIFYPARTYATTN" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYATTN" ] ) ) ; //通知人联系人
data . NOTIFYPARTYTEL = ( reader [ "NOTIFYPARTYTEL" ] = = null ? "" : Convert . ToString ( reader [ "NOTIFYPARTYTEL" ] ) ) ; //通知人联系方式
data . CORPID = ( reader [ "CORPID" ] = = null ? "" : Convert . ToString ( reader [ "CORPID" ] ) ) ; //所属公司
data . MODIFIEDUSER = ( reader [ "MODIFIEDUSER" ] = = null ? "" : Convert . ToString ( reader [ "MODIFIEDUSER" ] ) ) ; //更改操作人GID
data . MODIFIEDTIME = ( reader [ "MODIFIEDTIME" ] = = null ? DateTime . Now : Convert . ToDateTime ( reader [ "MODIFIEDTIME" ] ) ) ; //更改操作时间
data . CustName = ( reader [ "CustName" ] = = null ? "" : Convert . ToString ( reader [ "CustName" ] ) ) ;
# endregion
headList . Add ( data ) ;
}
reader . Close ( ) ;
}
return headList ;
}
# endregion
#region 删除
public static DBResult DeleteCust ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_cust_edi where GID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult DeletePkgs ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_pkgs_edi where GID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult DeleteSERVICE ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate = db . GetSqlStringCommand ( @"delete from code_service_edi where GID=@GID" ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "出现错误,请重试!" ;
return result ;
}
}
result . Success = true ;
result . Message = "删除成功" + result . Message ;
return result ;
}
public static DBResult DeletePORTDISCHARGE ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate = db . GetSqlStringCommand ( @"delete from code_disport_edi where GID=@GID" ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "出现错误,请重试!" ;
return result ;
}
}
result . Success = true ;
result . Message = "删除成功" + result . Message ;
return result ;
}
public static DBResult DeleteVessel ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_vessel_edi where GID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult DeleteISSUETYPE ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_issutype_edi where GID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult DeleteFeeName ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_fee_edi where ID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult DeleteReeferf ( CodeCtnEdi headdata )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdUpdate =
db . GetSqlStringCommand (
@"delete from code_reeferf_edi where GID=@GID " ) ;
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , headdata . GID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
# endregion
#region 保存
public static DBResult SaveDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_ctn_edi (GID,CTN,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_ctn_edi set CTN=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveCustDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_cust_edi (GID,CUST,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_cust_edi set CUST=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SavePkgsDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_pkgs_edi (GID,PKGS,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_pkgs_edi set PKGS=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveVesselDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_vessel_edi (GID,VESSEL,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_vessel_edi set VESSEL=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveISSUETYPEDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_issutype_edi (GID,BLTYPE,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_issutype_edi set BLTYPE=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveSERVICEDetail ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert = db . GetSqlStringCommand ( @"insert into code_service_edi (GID,SERVICE,EDICODE,EDINAME,REMARK,CREATEUSER,CREATETIME) values (@GID,@SERVICE,@EDICODE,@EDINAME,@REMARK,@CREATEUSER,getdate())" ) ;
var cmdUpdate = db . GetSqlStringCommand ( @"update code_service_edi set SERVICE=@SERVICE,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK,CREATEUSER=@CREATEUSER,CREATETIME=getdate() where GID=@GID" ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@SERVICE" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . AddInParameter ( cmdInsert , "@CREATEUSER" , DbType . String , enumValue . CREATEUSER ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@SERVICE" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . AddInParameter ( cmdInsert , "@CREATEUSER" , DbType . String , enumValue . CREATEUSER ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试!" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SavePORTDISCHARGEDetail ( List < CodeCtnEdi > bodyList , string companyid , string sUSERID )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert = db . GetSqlStringCommand ( @"insert into code_disport_edi (GID,PORTDISCHARGE,EDICODE,EDINAME,REMARK,CREATEUSER,CREATETIME,PORTID) values (@GID,@PORTDISCHARGE,@EDICODE,@EDINAME,@REMARK,@CREATEUSER,getdate(),@PORTID)" ) ;
var cmdUpdate = db . GetSqlStringCommand ( @"update code_disport_edi set PORTDISCHARGE=@PORTDISCHARGE,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK,CREATEUSER=@CREATEUSER,CREATETIME=getdate(),PORTID=@PORTID where GID=@GID" ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@PORTDISCHARGE" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . AddInParameter ( cmdInsert , "@CREATEUSER" , DbType . String , sUSERID ) ;
db . AddInParameter ( cmdInsert , "@PORTID" , DbType . String , enumValue . PORTID ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@PORTDISCHARGE" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . AddInParameter ( cmdUpdate , "@CREATEUSER" , DbType . String , sUSERID ) ;
db . AddInParameter ( cmdUpdate , "@PORTID" , DbType . String , enumValue . PORTID ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试!" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveFeeName ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_fee_edi (FEENAME,FEEENAME,EDINAME)
values ( @CTN , @EDICODE , @EDINAME ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_fee_edi set FEENAME=@CTN,FEEENAME=@EDICODE,EDINAME=@EDINAME where ID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception e )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = $"保存出现错误[{e.Message}],请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
public static DBResult SaveReeferf ( List < CodeCtnEdi > bodyList , string companyid )
{
var result = new DBResult ( ) ;
Database db = DatabaseFactory . CreateDatabase ( ) ;
using ( var conn = db . CreateConnection ( ) )
{
conn . Open ( ) ;
var tran = conn . BeginTransaction ( ) ;
try
{
var cmdInsert =
db . GetSqlStringCommand (
@ "insert into code_reeferf_edi (GID,REEFERF,EDICODE,EDINAME,REMARK)
values ( @GID , @CTN , @EDICODE , @EDINAME , @REMARK ) ");
var cmdUpdate =
db . GetSqlStringCommand (
@"update code_reeferf_edi set REEFERF=@CTN,EDICODE=@EDICODE,EDINAME=@EDINAME,REMARK=@REMARK where GID=@GID " ) ;
if ( bodyList ! = null )
{
foreach ( var enumValue in bodyList )
{
if ( enumValue . GID = = "*" | | enumValue . GID = = "" )
{
cmdInsert . Parameters . Clear ( ) ;
db . AddInParameter ( cmdInsert , "@GID" , DbType . String , Guid . NewGuid ( ) . ToString ( ) ) ;
db . AddInParameter ( cmdInsert , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdInsert , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdInsert , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdInsert , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdInsert , tran ) ;
}
else
{
cmdUpdate . Parameters . Clear ( ) ;
db . AddInParameter ( cmdUpdate , "@GID" , DbType . String , enumValue . GID ) ;
db . AddInParameter ( cmdUpdate , "@CTN" , DbType . String , enumValue . CTN ) ;
db . AddInParameter ( cmdUpdate , "@EDICODE" , DbType . String , enumValue . EDICODE ) ;
db . AddInParameter ( cmdUpdate , "@EDINAME" , DbType . String , enumValue . EDINAME ) ;
db . AddInParameter ( cmdUpdate , "@REMARK" , DbType . String , enumValue . REMARK ) ;
db . ExecuteNonQuery ( cmdUpdate , tran ) ;
}
}
}
tran . Commit ( ) ;
}
catch ( Exception )
{
tran . Rollback ( ) ;
result . Success = false ;
result . Message = "保存出现错误,请重试或联系系统管理员" ;
return result ;
}
}
result . Success = true ;
result . Message = "保存成功" + result . Message ;
return result ;
}
# endregion
}
}