dbo.MG_MS_BC_IN_SYNC_FROM_MODULE

SET QUOTED_IDENTIFIER, ANSI_NULLS ON
GO
create procedure dbo.MG_MS_BC_IN_SYNC_FROM_MODULE
@PARAMETER xml='' 
---XencX---with encryption
as

SET TRANSACTION ISOLATION LEVEL  READ UNCOMMITTED

declare @pemisah varchar(255)
declare @pemisah_replace varchar(255)
set @pemisah_replace='<br />'
--set @pemisah=CHAR(13) + CHAR(10) + '
'
set @pemisah = '
'

declare @resultX varchar(max)
declare @resultX2 varchar(max)

declare @XmlSts xml
declare @raw xml
declare @xStsnoheader varchar(2),
  @xStsno varchar(2),
  @xStsdes varchar(max)
   
set @xStsnoheader='07'
set @xStsno='00';
set @xStsdes='sukses'
 
BEGIN TRY
SET NOCOUNT ON
DECLARE @NOW datetime
set @NOW =GETDATE() 

DECLARE 
@data_by varchar(50)
,@id_header bigint

SELECT 
  @data_by=left(ltrim(rtrim(isnull(tempTable.item.value('data_by[1]', 'varchar(100)'),''))),50) 
, @ID_HEADER=isnull(tempTable.item.value('id_header[1]', 'bigint'),-1)  
FROM @PARAMETER.nodes('param/field')  tempTable(item)  
 
declare @c_id_header bigint
,@c_status_tpb_in_id int
,@c_status_tpb_in_name varchar(255)
,@c_NOMOR_AJU varchar(255)
,@c_TANGGAL_DAFTAR date
,@c_NOMOR_DAFTAR varchar(255)
,@c_ID_HEADER_ORI bigint
 declare @c_KODE_STATUS varchar(10)
if @c_id_header =-1
begin
 set @xStsno='02';
 set @xStsdes='Gagal, Header dokumen tidak di temukan(-1)' ;
 goto f 

end



declare @KODE_DOKUMEN_PABEAN varchar(255)
SELECT   top (1)  
 @c_id_header=ID_HEADER
,@c_status_tpb_in_id= status_tpb_in_id
,@c_status_tpb_in_name= status_tpb_in_name
,@c_NOMOR_AJU=NOMOR_AJU
,@c_TANGGAL_DAFTAR= TANGGAL_DAFTAR
,@c_NOMOR_DAFTAR= NOMOR_DAFTAR
,@c_ID_HEADER_ORI =ID_HEADER_ORI
,@c_KODE_STATUS= KODE_STATUS
,@KODE_DOKUMEN_PABEAN=        KODE_DOKUMEN_PABEAN
FROM            vw_ms_header_bc_in
WHERE        (ID_HEADER = @ID_HEADER)


if @c_id_header is null
begin
 set @xStsno='02';
 set @xStsdes='Gagal, Header dokumen tidak di temukan' ;
 goto f  
end 
  
if @c_status_tpb_in_id = -1  -- CANCEL
begin
 set @xStsno='02';
 set @xStsdes='Gagal, Dokumen dalam Status ' + @c_status_tpb_in_name ;
 goto f  
end

if  @c_status_tpb_in_id = 0  
begin
 set @xStsno='02';
 set @xStsdes='Gagal, Dokumen belum di kirim ke module ';
 goto f   
end   
  
declare @tmp_document table (
ID_DOC bigint primary key
,ID_ORI bigint
,ID_HEADER_ORI bigint)  


BEGIN TRANSACTION; 

declare @xml_header xml

declare @SQLString nvarchar(max),@ParmDefinition  nvarchar(max)

set @SQLString=
' MERGE dt_ms_tpb_in_header AS target USING ( SELECT ID ,KODE_STATUS ,NOMOR_AJU ,NOMOR_DAFTAR ,TANGGAL_DAFTAR ,NOMOR_IJIN_TPB_PENERIMA ,case when NDPBM is null then case when KODE_DOKUMEN_PABEAN=''41'' then 1 else NDPBM end else NDPBM end as NDPBM ,case when KODE_VALUTA is null then case when KODE_DOKUMEN_PABEAN=''41'' then ''IDR'' else KODE_VALUTA end else KODE_VALUTA end as KODE_VALUTA ,KODE_KANTOR_BONGKAR ,KODE_KANTOR ,KODE_PEL_BONGKAR ,KODE_PEL_MUAT ,BRUTO from OPENQUERY (TPBDB, ''SELECT * FROM tpbdb.tpb_header where ID=' +cast( @c_ID_HEADER_ORI as varchar(255))+ 
''' ) ) AS source(ID,KODE_STATUS,NOMOR_AJU,NOMOR_DAFTAR,TANGGAL_DAFTAR,NOMOR_IJIN_TPB_PENERIMA,NDPBM,KODE_VALUTA ,KODE_KANTOR_BONGKAR ,KODE_KANTOR ,KODE_PEL_BONGKAR ,KODE_PEL_MUAT ,BRUTO ) ON (target.ID_HEADER_ORI = source.ID) WHEN MATCHED THEN UPDATE SET target.KODE_STATUS = source.KODE_STATUS , target.NOMOR_AJU = source.NOMOR_AJU , target.NOMOR_DAFTAR = source.NOMOR_DAFTAR , target.TANGGAL_DAFTAR = source.TANGGAL_DAFTAR , target.NOMOR_IJIN_TPB_PENERIMA = source.NOMOR_IJIN_TPB_PENERIMA , target.NDPBM = source.NDPBM , target.KODE_VALUTA = source.KODE_VALUTA , target.KODE_KANTOR_BONGKAR = source.KODE_KANTOR_BONGKAR , target.KODE_KANTOR = source.KODE_KANTOR , target.KODE_PEL_BONGKAR = source.KODE_PEL_BONGKAR , target.KODE_PEL_MUAT = source.KODE_PEL_MUAT , target.BRUTO = source.BRUTO ; ' 
exec (@SQLString)

set @SQLString =
' delete from dt_ms_tpb_in_kontainer where ID_HEADER=' + cast(@id_header as varchar(255)) + 
' ;insert into dt_ms_tpb_in_kontainer (ID_ORI , KESESUAIAN_DOKUMEN , KETERANGAN , KODE_STUFFING , KODE_TIPE_KONTAINER , KODE_UKURAN_KONTAINER , FLAG_GATE_IN , FLAG_GATE_OUT , NO_POLISI , NOMOR_KONTAINER , NOMOR_SEGEL , SERI_KONTAINER , WAKTU_GATE_IN , WAKTU_GATE_OUT , ID_HEADER_ORI , ID_HEADER , create_date , create_by , modify_date , modify_by ) SELECT ID, KESESUAIAN_DOKUMEN, KETERANGAN, KODE_STUFFING, KODE_TIPE_KONTAINER, KODE_UKURAN_KONTAINER, FLAG_GATE_IN, FLAG_GATE_OUT, NO_POLISI, NOMOR_KONTAINER, NOMOR_SEGEL, SERI_KONTAINER, WAKTU_GATE_IN, WAKTU_GATE_OUT, ID_HEADER, ' + cast(@id_header as varchar(255)) + 
',@NOW,@data_by,@NOW,@data_by from OPENQUERY (TPBDB, ''SELECT * FROM tpbdb.tpb_kontainer where ID_HEADER=' + cast(@c_ID_HEADER_ORI as varchar(255)) + 
''' ) as xdata ; '  
SET @ParmDefinition = N'@NOW datetime, @data_by varchar(50)';
EXECUTE sp_executesql  @SQLString, @ParmDefinition
 ,@NOW = @NOW 
 ,@data_by = @data_by 


set @SQLString =
' delete from dt_ms_tpb_in_dokumen where (not((KODE_JENIS_DOKUMEN=380) or (KODE_JENIS_DOKUMEN=217))) AND ID_HEADER=' + cast(@id_header as varchar(255)) + 
' ;MERGE dt_ms_tpb_in_dokumen AS target USING ( SELECT ID as ID_ORI, FLAG_URL_DOKUMEN , KODE_JENIS_DOKUMEN , NOMOR_DOKUMEN , SERI_DOKUMEN , TANGGAL_DOKUMEN , TIPE_DOKUMEN , URL_DOKUMEN , ID_HEADER as ID_HEADER_ORI, ' + cast(@id_header as varchar(255)) + 
' as ID_HEADER ,@NOW,@data_by,@NOW,@data_by from OPENQUERY (TPBDB, ''SELECT * FROM tpbdb.tpb_dokumen where ID_HEADER=' + cast(@c_ID_HEADER_ORI as varchar(255)) + 
''' ) as xdata ) AS source( ID_ORI , FLAG_URL_DOKUMEN , KODE_JENIS_DOKUMEN , NOMOR_DOKUMEN , SERI_DOKUMEN , TANGGAL_DOKUMEN , TIPE_DOKUMEN , URL_DOKUMEN , ID_HEADER_ORI , ID_HEADER , create_date , create_by , modify_date , modify_by ) ON (1=2) WHEN NOT MATCHED THEN INSERT ( ID_ORI , FLAG_URL_DOKUMEN , KODE_JENIS_DOKUMEN , NOMOR_DOKUMEN , SERI_DOKUMEN , TANGGAL_DOKUMEN , TIPE_DOKUMEN , URL_DOKUMEN , ID_HEADER_ORI , ID_HEADER , create_date , create_by , modify_date , modify_by) VALUES ( source.ID_ORI , source.FLAG_URL_DOKUMEN , source.KODE_JENIS_DOKUMEN , source.NOMOR_DOKUMEN , source.SERI_DOKUMEN , source.TANGGAL_DOKUMEN , source.TIPE_DOKUMEN , source.URL_DOKUMEN , source.ID_HEADER_ORI , source.ID_HEADER , source.create_date , source.create_by , source.modify_date , source.modify_by) ; '  
SET @ParmDefinition = N'@NOW datetime, @data_by varchar(50)';
EXECUTE sp_executesql  @SQLString, @ParmDefinition
 ,@NOW = @NOW 
 ,@data_by = @data_by 

  

COMMIT TRANSACTION;
  
f:

set nocount off

END TRY  
BEGIN CATCH
 IF (@@TRANCOUNT > 0)  ROLLBACK TRAN; 
 set @xStsno='88'
 set @xStsdes= ERROR_MESSAGE() 
END CATCH

g:
set @XmlSts=(select @xStsnoheader + @xStsno as 'no', @xStsdes as 'des' for xml path('sts'))
 select  CAST( (select @XmlSts,isnull(@raw ,'')   for xml path ('result')
)  as XML)  as dt

GO