thierry/sql-snippets
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update azure-pipelines.yml for Azure Pipelines

Browse Source
This commit is contained in:
tschork
2023-07-27 12:14:03 +02:00
parent f5bb9b66b5
commit 852740b42d
1 changed files with 366 additions and 47 deletions
Download Patch File Download Diff File Expand all files Collapse all files

413
azure-pipelines.yml
View File

@@ -17,10 +17,11 @@ steps:
inputs:
TaskType: 'sqlInline'
InlineSql: |
/* step 1 - Check download from Pharmindex is finished */
use pharmindexTP
GO
/* step 1 - Check download from Pharmindex is finished */
declare @today datetime;
@@ -39,56 +40,374 @@ steps:
GO
begin try
declare @out_param_int_1 int
execute[dbo].[pdx_loading]
@in_job_type = 20
,@skip_mapping = 0
,@in_subsidiary = 100
,@in_table_name = null
,@in_debug = 0
,@out_param_int_1 = @out_param_int_1 output
end try
begin catch
declare
/* step 2 - INDEX - Transfert PharmIndexTP to Arizona items, Prescriber using Checksum */
begin try
declare @out_param_int_1 int
execute[dbo].[pdx_loading]
@in_job_type = 20
,@skip_mapping = 0
,@in_subsidiary = 100
,@in_table_name = null
,@in_debug = 0
,@out_param_int_1 = @out_param_int_1 output
end try
begin catch
declare
@mail_message nvarchar(2000),
@mail_subject nvarchar(255);
set @mail_message = ' <html><body><p>Résumé des erreurs dans le tableau ci-dessous : </p>' +'
<table border="1" width="400px" height="400px">
<tr>
<th>ErrorNumber</th>
<th>ErrorSeverity</th>
<th>ErrorState</th>
<th>ErrorProcedure</th>
<th>ErrorLine</th>
<th>ErrorMessage</th>
</tr>' + '<tr valign="center">
<td>' + isnull(convert(varchar, ERROR_NUMBER()), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_SEVERITY()), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_STATE()), '') + '</td>
<td>' + isnull(ERROR_PROCEDURE(), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_LINE()), '') + '</td>
<td>' + isnull(ERROR_MESSAGE(), '') + '</td>
</tr>'+ '
</table>
</body>
</html>';
set @mail_subject = 'INDEX - Transfert PharmIndex to PHGD_xx for items using checksum (Instance ' + @@SERVERNAME + ') - Job _D01941 - INDEX';
/* envoi du mail */
exec Arizona.dbo.aps_Send_Mail_with_template
@in_param_varchar_2 = 'HCI_PharmIndex;HCI_DataManagement',
@in_param_varchar_3 = @mail_message,
@in_param_subject = @mail_subject,
@in_job_type = 4;
end catch
set @mail_message = ' <html><body><p>Résumé des erreurs dans le tableau ci-dessous : </p>' +'
<table border="1" width="400px" height="400px">
<tr>
<th>ErrorNumber</th>
<th>ErrorSeverity</th>
<th>ErrorState</th>
<th>ErrorProcedure</th>
<th>ErrorLine</th>
<th>ErrorMessage</th>
</tr>' + '<tr valign="center">
<td>' + isnull(convert(varchar, ERROR_NUMBER()), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_SEVERITY()), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_STATE()), '') + '</td>
<td>' + isnull(ERROR_PROCEDURE(), '') + '</td>
<td>' + isnull(convert(varchar, ERROR_LINE()), '') + '</td>
<td>' + isnull(ERROR_MESSAGE(), '') + '</td>
</tr>'+ '
</table>
</body>
</html>';
set @mail_subject = 'INDEX - Transfert PharmIndex to PHGD_xx for items using checksum (Instance ' + @@SERVERNAME + ') - Job _D01941 - INDEX';
/* envoi du mail */
exec Arizona.dbo.aps_Send_Mail_with_template
@in_param_varchar_2 = 'HCI_PharmIndex;HCI_DataManagement',
@in_param_varchar_3 = @mail_message,
@in_param_subject = @mail_subject,
@in_job_type = 4;
end catch
go
/* step 3 - INDEX - Control if exist prescribers with same contract number than an OU */
use Arizona
declare @subject varchar(8000)
, @errmsg varchar(8000)
select @errmsg = 'Les pharmacies suivantes ont un concordat identique à celui d''un prescripteur actif'
select @errmsg = @errmsg + char(13) + char(10) + ou1.OU_code + char(9) + ou1.OU_short_name + char(9) + pr1.PHPR_contract_number
from PH_prescriber pr1 with (nolock)
join PH_prescriber pr2 with (nolock)
on pr2.PH_prescriber_GUID <> pr1.PH_prescriber_GUID
and pr2.PHPR_contract_number = pr1.PHPR_contract_number
and pr2.PHPR_status = pr1.PHPR_status
join Organizational_unit ou1 with (nolock)
on ou1.OU_address = pr1.PHPR_address
left outer join Organizational_unit ou2 with (nolock)
on ou2.OU_address = pr2.PHPR_address
where pr1.PHPR_status = 1
and ou2.Organizational_unit_ID is null
and exists(select 1
from OU_store_history oust with (nolock)
where oust.OUSH_organizational_unit = ou1.Organizational_unit_ID
and (oust.OUSH_end_date is null or oust.OUSH_end_date >= getdate()))
order by ou1.OU_code
if @@ROWCOUNT > 0
begin
select @subject = QUOTENAME(OBJECT_SCHEMA_NAME(@@PROCID))
+'.'+QUOTENAME(OBJECT_NAME(@@PROCID))
exec aps_Send_Mail_with_template
@in_param_varchar_2 = 'HCI_PharmIndex;HCI_DataManagement',
@in_param_varchar_3 = @errmsg,
@in_param_subject = @subject,
@in_job_type = 4;
end
go
/* step 4 - Update PEXF */
declare @cvPHGDPriceCodePEXF int,
@SubsidiaryId int,
@w_date date
select @SubsidiaryId = 1000,
@cvPHGDPriceCodePEXF = NULL,
@w_date = getdate()
exec arizona.dbo.sp_bmc_Bmc_Applic_Default
@in_job_type = 3,
@in_param_int_1 = NULL,
@in_param_int_2 = @SubsidiaryId,
@in_param_varchar_1 = 'cvPHGDPriceCodePSL1',
@out_default_value = @cvPHGDPriceCodePEXF output,
@out_param_int_1 = null
if @cvPHGDPriceCodePEXF is null
begin
select @SubsidiaryId = 100
exec arizona.dbo.sp_bmc_Bmc_Applic_Default
@in_job_type = 3,
@in_param_int_1 = NULL,
@in_param_int_2 = @SubsidiaryId,
@in_param_varchar_1 = 'cvPHGDPriceCodePSL1',
@out_default_value = @cvPHGDPriceCodePEXF output,
@out_param_int_1 = null
end
/*-------------
Fermeture des PEXF sans Adresse pour les articles avec insurance code not in (10, 11)
------------------*/
Update top(5000) FP set fp.fp_end_date = DATEADD(d,-1,@w_date)
from subsidiary SUB with (nolock)
join price_code PRC with (nolock)
on prc.prc_subsidiary = sub.subsidiary_id
and prc.price_code_id = @cvPHGDPriceCodePEXF
join Fixed_price FP with (nolock)
on FP.FP_price_code = prc.price_code_id
and FP.fp_subsidiary = sub.subsidiary_id
and FP.FP_address is null
and FP.FP_start_date < GETDATE()
and ISNULL(fp.fp_end_date, '2099-12-31') > GETDATE()
join Item_key ITK with (nolock)
on itk.ITK_item = fp.fp_item
and ITK.ITK_subsidiary = SUB.Subsidiary_ID
and ITK.ITK_type = 1
join PH_item phit with (nolock)
on phit.PHIT_item = ITK.ITK_item
and phit.PHIT_insurance_code not in ('10', '11')
where SUB.subsidiary_id = @SubsidiaryId
/*---------------------------------------
Clôture du PEXF sans adresse à la date -1 de la start_date du prix PEXF avec adresse
pour les articles LS.
Nous recréons un PEXF avec la bonne start_date et le bon prix afin que la facturation aux caisse maladie soit OK
--------------*/
Update top(5000) FP1 set fp1.fp_end_date = DATEADD(d,-1,fp.FP_start_date)
from subsidiary SUB with (nolock)
join price_code PRC with (nolock)
on prc.prc_subsidiary = sub.subsidiary_id
and prc.price_code_id = @cvPHGDPriceCodePEXF
join Fixed_price FP with (nolock)
on FP.FP_price_code = prc.price_code_id
and FP.fp_subsidiary = sub.subsidiary_id
and FP.FP_address is not null
and FP.FP_start_date < GETDATE()
and ISNULL(fp.fp_end_date, '2099-12-31') > GETDATE()
and FP.fixed_price_id = (select top 1 fp2.fixed_price_id from Fixed_price FP2 with (nolock)
where FP2.FP_item = FP.FP_item
and FP2.FP_price_code = fp.FP_price_code
and FP2.fp_subsidiary = FP.fp_subsidiary
and FP2.FP_address is not null
and FP2.FP_start_date < GETDATE()
and ISNULL(FP2.fp_end_date, '2099-12-31') > GETDATE()
order by FP2.FP_start_date desc
)
join Item_key ITK with (nolock)
on itk.ITK_item = fp.fp_item
and ITK.ITK_subsidiary = SUB.Subsidiary_ID
and ITK.ITK_type = 1
join PH_item phit with (nolock)
on phit.PHIT_item = ITK.ITK_item
and phit.PHIT_insurance_code in ('10', '11')
join Fixed_price FP1 with (nolock)
on FP1.FP_price_code = prc.price_code_id
and FP1.fp_subsidiary = sub.subsidiary_id
and FP1.FP_address is null
and FP1.FP_start_date < GETDATE()
and ISNULL(FP1.fp_end_date, '2099-12-31') > GETDATE()
and FP1.FP_item = FP.FP_item
where SUB.subsidiary_id = @SubsidiaryId
and isnull(FP.FP_tax_free_price_per_unit,0) <> isnull(FP1.FP_tax_free_price_per_unit,0)
/*----------
Creation PEXF sans adresse avec start_date et prix du PEXF avec Adresse pour LS (Le plus récent)
------------*/
declare
@New_fixed_price_ID int,
@nb_fixed_price int ,
@fp_subsidiary int,
@fp_tariff_type int,
@fp_item int,
@fp_currency int,
@fp_price_code int,
@fp_sales_tax_code int,
@FP_start_date datetime,
@FP_tax_free_price_per_unit dec(14,2)
SELECT @nb_fixed_price = 1
/*-- Declaration du curseur c_external_item --*/
declare c_FP cursor local forward_only read_only static for
select FP.fp_subsidiary,
FP.fp_tariff_type,
FP.fp_item,
FP.fp_currency,
FP.fp_price_code,
FP.fp_sales_tax_code,
FP.FP_start_date,
FP.FP_tax_free_price_per_unit
from subsidiary SUB with (nolock)
join price_code PRC with (nolock)
on prc.prc_subsidiary = sub.subsidiary_id
and prc.price_code_id = @cvPHGDPriceCodePEXF
join Fixed_price FP with (nolock)
on FP.FP_price_code = prc.price_code_id
and FP.fp_subsidiary = sub.subsidiary_id
and FP.FP_address is not null
and FP.FP_start_date < GETDATE()
and ISNULL(fp.fp_end_date, '2099-12-31') > GETDATE()
and FP.fixed_price_id = (select top 1 fp2.fixed_price_id from Fixed_price FP2 with (nolock)
where FP2.FP_item = FP.FP_item
and FP2.FP_price_code = fp.FP_price_code
and FP2.fp_subsidiary = FP.fp_subsidiary
and FP2.FP_address is not null
and FP2.FP_start_date < GETDATE()
and ISNULL(FP2.fp_end_date, '2099-12-31') > GETDATE()
order by FP2.FP_start_date desc
)
join Item_key ITK with (nolock)
on itk.ITK_item = fp.fp_item
and ITK.ITK_subsidiary = SUB.Subsidiary_ID
and ITK.ITK_type = 1
join PH_item phit with (nolock)
on phit.PHIT_item = ITK.ITK_item
and phit.PHIT_insurance_code in ('10', '11')
left outer join Fixed_price FP1 with (nolock)
on FP1.FP_price_code = prc.price_code_id
and FP1.fp_subsidiary = sub.subsidiary_id
and FP1.FP_address is null
and FP1.FP_start_date < GETDATE()
and ISNULL(FP1.fp_end_date, '2099-12-31') > GETDATE()
and FP1.FP_item = FP.FP_item
where SUB.subsidiary_id = @SubsidiaryId
and FP1.Fixed_price_ID is null
order by 1
open c_FP;
fetch next from c_FP
into @fp_subsidiary ,
@fp_tariff_type ,
@fp_item ,
@fp_currency ,
@fp_price_code ,
@fp_sales_tax_code ,
@FP_start_date ,
@FP_tax_free_price_per_unit
while (@@fetch_status <> -1 )
begin
if (@@fetch_status <> -2 )
begin
/*----- Recherche dernier ID pour Fixed_Price -----*/
select @New_fixed_price_ID = null
exec sp_bmc_GetNextID
@in_key = 'fixed_price',
@in_id_column = 'fixed_price_id',
@in_nbr_of_record = @nb_fixed_price,
@out_id = @New_fixed_price_id output
insert fixed_price
(fixed_price_id,
fp_subsidiary,
fp_tariff_type,
fp_item,
fp_currency,
fp_price_code,
fp_sales_tax_code,
fp_start_date,
fp_tax_free_price_per_unit ,
fp_unit_code,
FP_price_per_unit_unit_code,
fp_final_discount_possible,
FP_discount_level_1_possible,
FP_discount_level_2_possible,
FP_origin,
FP_remark
)
select
@New_fixed_price_id,
@fp_subsidiary ,
@fp_tariff_type ,
@fp_item ,
@fp_currency ,
@fp_price_code ,
@fp_sales_tax_code ,
@FP_start_date ,
@FP_tax_free_price_per_unit,
1,
1,
1,
1,
1,
1,
'Automatic Insert PEXF '
/*----- fin du curseur -----*/
end /* (@@fetch_status <> -2 ) */
fetch next from c_FP
into @fp_subsidiary ,
@fp_tariff_type ,
@fp_item ,
@fp_currency ,
@fp_price_code ,
@fp_sales_tax_code ,
@FP_start_date ,
@FP_tax_free_price_per_unit
end /* (@@fetch_status <> -1 ) */
close c_FP;
deallocate c_FP;
ServerName: 'localhost'
DatabaseName: 'master'
AuthScheme: 'windowsAuthentication'