254 lines
5.8 KiB
Transact-SQL
254 lines
5.8 KiB
Transact-SQL
create index i_UDC on AS400_BatchConsumoMP(UDC)
|
|
go
|
|
|
|
|
|
create index i_UDC on RilPro.RapQual(UDC)
|
|
go
|
|
|
|
|
|
set xact_abort on
|
|
go
|
|
|
|
begin transaction
|
|
go
|
|
|
|
set ANSI_NULLS on
|
|
go
|
|
|
|
/***************************************
|
|
* STORED stp_consumaMP
|
|
*
|
|
* Salva il movimento di consumo dell'UDC di MP indicato
|
|
*
|
|
* Steamware, S.E.L.
|
|
* mod: 2010.10.12
|
|
*
|
|
****************************************/
|
|
alter PROCEDURE BatchQueue.stp_consumaMP
|
|
(
|
|
@XRPQLN INT, --è il num rap qualità
|
|
@XNRETI NVARCHAR(10), -- è il numUdc prog
|
|
@XDTPRO INT, -- data 8 cifre aaaammgg
|
|
@XTRPRO NVARCHAR(5), -- turno
|
|
@XDESMT NVARCHAR(3), -- destinatario int/terzista
|
|
@XCDTER NVARCHAR(6) -- cod terzista
|
|
)
|
|
AS
|
|
-- BOZZA DA VERIFICARE E COMPLETARE A CURA MAZZUCCONI!!!
|
|
|
|
DECLARE @SQL AS NVARCHAR(1000)
|
|
|
|
-- Faccio chiamata su AS400
|
|
|
|
SET @SQL = N' OPENQUERY( P65220DC, ''UPDATE MAZZT_DTV3.XOGIX00F'
|
|
SET @SQL = @SQL + 'SET XDTPRO = ' + @XDTPRO + ', XTRPRO = ' + @XTRPRO
|
|
SET @SQL = @SQL + ', XDESMT = ''' + @XDESMT +''', XMATSC=''S'' , XCDTER = ''' + @XCDTER + ''' '
|
|
SET @SQL = @SQL + 'WHERE XRPQLN =' + @XRPQLN + ' AND XNRETI = ' + @XNRETI + ''' )'
|
|
|
|
EXEC dbo.sp_executesql @SQL
|
|
|
|
RETURN
|
|
go
|
|
|
|
commit
|
|
go
|
|
|
|
|
|
set xact_abort on
|
|
go
|
|
|
|
begin transaction
|
|
go
|
|
|
|
set ANSI_NULLS on
|
|
go
|
|
|
|
/***************************************
|
|
* STORED stp_processaCodaConsumoMP
|
|
*
|
|
* Processa la coda dei consumo di UDC di MP e chiaam procedura x salvataggio dato su AS400
|
|
*
|
|
* Steamware, S.E.L.
|
|
* mod: 2010.10.12
|
|
*
|
|
****************************************/
|
|
create PROCEDURE BatchQueue.stp_processaCodaConsumoMP
|
|
AS
|
|
-- BOZZA DA VERIFICARE E COMPLETARE A CURA MAZZUCCONI!!!
|
|
|
|
-- faccio una query con un cursore x processare tutte le righe da inviare ad AS400..
|
|
DECLARE @UDC NVARCHAR(50)
|
|
DECLARE @XRPQLN INT
|
|
DECLARE @XNRETI NVARCHAR(10)
|
|
DECLARE @XDTPRO INT
|
|
DECLARE @XTRPRO NVARCHAR(5)
|
|
DECLARE @XDESMT NVARCHAR(3)
|
|
DECLARE @XCDTER NVARCHAR(6)
|
|
|
|
DECLARE @SqlCode NVARCHAR(1000)
|
|
|
|
DECLARE UdcMpList CURSOR FOR
|
|
SELECT UDC FROM AS400_BatchConsumoMP WHERE DataInvioAs IS NULL
|
|
OPEN UdcMpList
|
|
FETCH NEXT FROM UdcMpList
|
|
INTO @UDC
|
|
WHILE @@FETCH_STATUS = 0
|
|
BEGIN
|
|
-- controllo ci sia la riga
|
|
IF (SELECT COUNT(UDC) FROM AS400_BatchConsumoMP WHERE UDC=@UDC) > 0
|
|
BEGIN
|
|
-- carico valori che mi servono
|
|
SELECT @XRPQLN=rq.nRapQual, @XNRETI=rq.ProgUDC, @XDTPRO=bcu.DataPrelFus, @XTRPRO=bcu.TurnoPrelFus,
|
|
@XDESMT=bcu.DestLega, @XCDTER=bcu.DestTerz
|
|
FROM AS400_BatchConsumoMP as bcu INNER JOIN RilPro.RapQual as rq ON bcu.UDC = rq.UDC
|
|
WHERE bcu.UDC=@UDC
|
|
-- compongo testo x exec
|
|
SET @SqlCode = N'EXEC BatchQueue.stp_consumaMP ' + CAST(@XRPQLN AS NVARCHAR(50)) + ' ' + @XNRETI + ' ' + CAST(@XDTPRO AS NVARCHAR(8)) + ' ' + LTRIM(RTRIM(@XTRPRO)) + ' ' + LTRIM(RTRIM(@XDESMT)) + ' ' + LTRIM(RTRIM(@XCDTER))
|
|
-- lo mostro
|
|
print '%' + LTRIM(RTRIM(@SqlCode)) + '%'
|
|
|
|
-- chiamo la stored ed eseguo invio
|
|
--EXEC dbo.sp_executesql @SqlCode -- decommentare se va bene...
|
|
FETCH NEXT FROM UdcMpList INTO @UDC
|
|
END
|
|
END
|
|
CLOSE UdcMpList
|
|
DEALLOCATE UdcMpList
|
|
|
|
|
|
RETURN
|
|
go
|
|
|
|
commit
|
|
go
|
|
|
|
|
|
set xact_abort on
|
|
go
|
|
|
|
begin transaction
|
|
go
|
|
|
|
set ANSI_NULLS on
|
|
go
|
|
|
|
/***************************************
|
|
* STORED stp_processaCodaConsumoMP
|
|
*
|
|
* Processa la coda dei consumo di UDC di MP e chiaam procedura x salvataggio dato su AS400
|
|
*
|
|
* Steamware, S.E.L.
|
|
* mod: 2010.10.12
|
|
*
|
|
****************************************/
|
|
create PROCEDURE BatchQueue.stp_processaCodaConsumoMP
|
|
AS
|
|
-- BOZZA DA VERIFICARE E COMPLETARE A CURA MAZZUCCONI!!!
|
|
|
|
-- faccio una query con un cursore x processare tutte le righe da inviare ad AS400..
|
|
DECLARE @UDC NVARCHAR(50)
|
|
DECLARE @XRPQLN INT
|
|
DECLARE @XNRETI NVARCHAR(10)
|
|
DECLARE @XDTPRO INT
|
|
DECLARE @XTRPRO NVARCHAR(5)
|
|
DECLARE @XDESMT NVARCHAR(3)
|
|
DECLARE @XCDTER NVARCHAR(6)
|
|
|
|
DECLARE @SqlCode NVARCHAR(1000)
|
|
|
|
DECLARE UdcMpList CURSOR FOR
|
|
SELECT UDC FROM AS400_BatchConsumoMP WHERE DataInvioAs IS NULL
|
|
OPEN UdcMpList
|
|
FETCH NEXT FROM UdcMpList
|
|
INTO @UDC
|
|
WHILE @@FETCH_STATUS = 0
|
|
BEGIN
|
|
-- controllo ci sia la riga
|
|
IF (SELECT COUNT(UDC) FROM AS400_BatchConsumoMP WHERE UDC=@UDC) > 0
|
|
BEGIN
|
|
-- carico valori che mi servono
|
|
SELECT @XRPQLN=rq.nRapQual, @XNRETI=rq.ProgUDC, @XDTPRO=bcu.DataPrelFus, @XTRPRO=bcu.TurnoPrelFus,
|
|
@XDESMT=bcu.DestLega, @XCDTER=bcu.DestTerz
|
|
FROM AS400_BatchConsumoMP as bcu INNER JOIN RilPro.RapQual as rq ON bcu.UDC = rq.UDC
|
|
WHERE bcu.UDC=@UDC
|
|
-- compongo testo x exec
|
|
SET @SqlCode = N'EXEC BatchQueue.stp_consumaMP ' + CAST(@XRPQLN AS NVARCHAR(50)) + ' ' + @XNRETI + ' ' + CAST(@XDTPRO AS NVARCHAR(8)) + ' ' + LTRIM(RTRIM(@XTRPRO)) + ' ' + LTRIM(RTRIM(@XDESMT)) + ' ' + LTRIM(RTRIM(@XCDTER))
|
|
-- lo mostro
|
|
print '%' + LTRIM(RTRIM(@SqlCode)) + '%'
|
|
|
|
-- chiamo la stored ed eseguo invio
|
|
--EXEC dbo.sp_executesql @SqlCode -- decommentare se va bene...
|
|
FETCH NEXT FROM UdcMpList INTO @UDC
|
|
END
|
|
END
|
|
CLOSE UdcMpList
|
|
DEALLOCATE UdcMpList
|
|
|
|
|
|
RETURN
|
|
go
|
|
|
|
commit
|
|
go
|
|
|
|
|
|
set xact_abort on
|
|
go
|
|
|
|
begin transaction
|
|
go
|
|
|
|
set ANSI_NULLS on
|
|
go
|
|
|
|
/***************************************
|
|
* STORED stp_accodaConsumoUdcMP
|
|
*
|
|
* Accoda alla tab Batch il consumo di un UDC
|
|
*
|
|
* Steamware, S.E.L.
|
|
* mod: 2010.10.10
|
|
*
|
|
****************************************/
|
|
alter PROCEDURE stp_accodaConsumoUdcMP
|
|
(
|
|
@UDC NVARCHAR(50),
|
|
@DataPrelFus DATETIME,
|
|
@TurnoPrelFus CHAR(5),
|
|
@DestLega CHAR(3),
|
|
@DestTerz CHAR(6)
|
|
)
|
|
AS
|
|
|
|
BEGIN TRAN
|
|
|
|
-- registro movimento da riconciliare
|
|
INSERT INTO AS400_BatchConsumoMP(ProgUDC, UDC, DataPrelFus, TurnoPrelFus, DestLega, DestTerz)
|
|
SELECT ProgUdc, UDC, dbo.dateToAsFormat(@DataPrelFus), @TurnoPrelFus, @DestLega, @DestTerz FROM RilPro.RapQual WHERE UDC = @UDC
|
|
|
|
-- aggiorno con data e turno di prelievo su tab RilPro (locale)
|
|
UPDATE RilPro.RapQual
|
|
SET DataPrelFus = dbo.dateToAsFormat(@DataPrelFus), TurnoPrelFus = @TurnoPrelFus
|
|
WHERE UDC = @UDC
|
|
|
|
COMMIT TRAN
|
|
|
|
RETURN
|
|
go
|
|
|
|
commit
|
|
go
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
-- registro versione...
|
|
INSERT INTO [dbo].[LogUpdateDb] ([Versione],[Data]) VALUES(280, GETDATE())
|
|
GO
|