diff --git a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ_agi.sql b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ_agi.sql index 6e9f04d..d01abf3 100644 --- a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ_agi.sql +++ b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/smartccc工单信息集成/f_ccc_work_ticket_integ_agi.sql @@ -4,11 +4,11 @@ /*Brilliance stems from wisdoms. */ /*************Head Section**************************************************************************/ /*Script Use: Periodically load data to :f_ccc_work_ticket_integ(smartccc工单信息集成) */ -/*Create Date:2024-11-22 10:09:19 */ +/*Create Date:2024-12-12 11:47:33 */ /*SDM Developed By: dev */ /*SDM Developed Date: 2024-07-09 */ /*SDM Checked By: dev */ -/*SDM Checked Date: 2024-11-22 */ +/*SDM Checked Date: 2024-12-12 */ /*Script Developed By: dev */ /*Script Checked By: dev */ /*Source table 1: :PDMDB.t01_ccc_cust_info */ @@ -107,15 +107,13 @@ SELECT ,coalesce(p1."source",'') /*PEXTENSION*/ ,COALESCE(TRIM(CAST(p0.customer_name AS varchar(20))),'') /*LAST_NAME*/ ,coalesce(p0.id,'') /*SUFFIX*/ - ,'Company: '||coalesce((SELECT jsonb_extract_path_text(j, 'value') + ,coalesce((SELECT jsonb_extract_path_text(j, 'value') FROM jsonb_array_elements((p0.start_form::json -> 'fields')::jsonb) j - WHERE jsonb_extract_path_text(j, 'id') = '305038'),(SELECT jsonb_extract_path_text(j, 'value') - FROM jsonb_array_elements(p1.customize::jsonb) j - WHERE jsonb_extract_path_text(j, 'name') = '公司名称'),'')||',Enduser: '||coalesce((SELECT jsonb_extract_path_text(j, 'value') + WHERE jsonb_extract_path_text(j, 'id') = '305038'),'')||(case when coalesce((SELECT jsonb_extract_path_text(j, 'value') FROM jsonb_array_elements((p0.start_form::json -> 'fields')::jsonb) j - WHERE jsonb_extract_path_text(j, 'id') = '297756'),(SELECT jsonb_extract_path_text(j, 'value') - FROM jsonb_array_elements(p1.customize::jsonb) j - WHERE jsonb_extract_path_text(j, 'name') = '公司名称'),'') /*COMPANY_NAME*/ + WHERE jsonb_extract_path_text(j, 'id') = '297756'),'') = '' then '' else ',Enduser: '||coalesce((SELECT jsonb_extract_path_text(j, 'value') + FROM jsonb_array_elements((p0.start_form::json -> 'fields')::jsonb) j + WHERE jsonb_extract_path_text(j, 'id') = '297756'),'') end) /*COMPANY_NAME*/ ,coalesce((SELECT jsonb_extract_path_text(j, 'value') FROM jsonb_array_elements(p1.customize::jsonb) j WHERE jsonb_extract_path_text(j, 'name') = '职位'),'') /*JOB_TITLE*/ @@ -133,11 +131,15 @@ SELECT ,'YES' /*REQUEST_A_QUOTE*/ ,'YES' /*HAMCAM*/ ,4 /*PURCHASE_INTENT*/ - ,'L - mql '||coalesce((SELECT jsonb_extract_path_text(field, 'value') AS value_298245 + ,'L - mql '||case when p0.workflow_name ='CN离线工单_选型报价' then coalesce((SELECT jsonb_extract_path_text(field, 'value') AS value_298245 FROM ( SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field ) AS t -WHERE jsonb_extract_path_text(field, 'id')::int = 298246),'')||' 预算情况:'||coalesce((SELECT jsonb_extract_path_text(field, 'value') AS value_298245 +WHERE jsonb_extract_path_text(field, 'id')::int = 297757),'') else coalesce((SELECT jsonb_extract_path_text(field, 'value') AS value_298245 +FROM ( + SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field +) AS t +WHERE jsonb_extract_path_text(field, 'id')::int = 298246),'') end ||' 预算情况:'||coalesce((SELECT jsonb_extract_path_text(field, 'value') AS value_298245 FROM ( SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field ) AS t @@ -348,6 +350,10 @@ WHERE jsonb_extract_path_text(field, 'id')::int = 298249),' None ')||';' FROM ( SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field ) AS t +WHERE jsonb_extract_path_text(field, 'id')::int = 304927),(SELECT jsonb_extract_path_text(field, 'value') AS value_298300 +FROM ( + SELECT jsonb_array_elements(p0.start_form::jsonb->'fields') AS field +) AS t WHERE jsonb_extract_path_text(field, 'id')::int = 299137),'') /*LEAD_PRODUCTS_01_5*/ ,'YES' /*PERMISSION_PHONE*/ ,COALESCE(p0.create_time,TO_TIMESTAMP(:NULLDATE,'YYYYMMDD')) /*PERMISSION_PHONE_DATE*/ diff --git a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py index dd90b7b..2b29bce 100644 --- a/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py +++ b/dev/workflow/TK_Cust/smart_ccc_dynamic_email/天润dynamic邮件同步/wf_dag_smart_ccc_dynamic_email.py @@ -24,7 +24,7 @@ default_args = { } dag = DAG('wf_dag_smart_ccc_dynamic_email', default_args=default_args, -schedule_interval="5 10,14,16,12,18 * * 1-5", +schedule_interval="5 10,14,16,12,18 * * *", catchup=False, dagrun_timeout=timedelta(minutes=160), max_active_runs=3) @@ -37,7 +37,7 @@ task_failed = EmailOperator ( cc=[""], subject="smart_ccc_dynamic_email_failed", html_content='

您好，smart_ccc_dynamic_email作业失败，请及时处理"

') - + dysql_update_dynamic_email_data = SSHOperator( ssh_hook=sshHook, @@ -49,7 +49,7 @@ retries=3, dag=dag) - + uds_dynamic_data_export = SSHOperator( ssh_hook=sshHook, @@ -59,7 +59,7 @@ params={'my_param':"uds_dynamic_data_export"}, depends_on_past=False, retries=3, dag=dag) - + f_ccc_work_ticket_integ = SSHOperator( ssh_hook=sshHook, task_id='f_ccc_work_ticket_integ', @@ -67,7 +67,7 @@ command='/data/airflow/etl/COM/run_psql.sh {{ ds_nodash }} {{params.my_param}} > params={'my_param':"f_ccc_work_ticket_integ_agi"}, depends_on_past=False, retries=3, -dag=dag) -uds_dynamic_data_export >> dysql_update_dynamic_email_data -f_ccc_work_ticket_integ >> uds_dynamic_data_export -uds_dynamic_data_export >> task_failed +dag=dag) +uds_dynamic_data_export >> dysql_update_dynamic_email_data +f_ccc_work_ticket_integ >> uds_dynamic_data_export +uds_dynamic_data_export >> task_failed