dtgitea
/
dataops
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

add workflow 市场-Agents调度,dev

This commit is contained in:
root 2025-12-09 18:42:53 +08:00
parent 4b939dbf07
commit 44d7096b85
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
dev/workflow/TK_Cust/agents_market_newsletter/市场信息简报/a_market_Intelligence_newsletter_agi.sql
View File

@ -4,7 +4,7 @@
/*Brilliance stems from wisdoms. */ /*Brilliance stems from wisdoms. */
/*************Head Section**************************************************************************/ /*************Head Section**************************************************************************/
/*Script Use: Periodically load data to :a_market_Intelligence_newsletter(市场信息简报) */ /*Script Use: Periodically load data to :a_market_Intelligence_newsletter(市场信息简报) */
/*Create Date:2025-12-09 18:20:25 */ /*Create Date:2025-12-09 18:42:38 */
/*SDM Developed By: dev */ /*SDM Developed By: dev */
/*SDM Developed Date: 2025-11-12 */ /*SDM Developed Date: 2025-11-12 */
/*SDM Checked By: dev */ /*SDM Checked By: dev */
@ -66,6 +66,7 @@ INSERT INTO a_market_Intelligence_newsletter_agi_CUR_I (
,Etl_Tx_Dt /*作业运行时间*/ ,Etl_Tx_Dt /*作业运行时间*/
,Src_Sysname /*来源系统*/ ,Src_Sysname /*来源系统*/
,Src_Table /*来源表*/ ,Src_Table /*来源表*/
,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/
) )
SELECT SELECT
COALESCE(p0.id,0) /*id*/ COALESCE(p0.id,0) /*id*/
@ -92,6 +93,7 @@ SELECT
,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/ ,TO_DATE(:TXDATE,'YYYYMMDD') /*Etl_Tx_Dt*/
,Substr('agent_market_summary',1,3) /*Src_Sysname*/ ,Substr('agent_market_summary',1,3) /*Src_Sysname*/
,'agent_market_summary' /*Src_Table*/ ,'agent_market_summary' /*Src_Table*/
,COALESCE(TRIM(p0.business_type),'') /*business_type*/
FROM p70_ai_intelligence.agent_market_summary p0 FROM p70_ai_intelligence.agent_market_summary p0
where create_tm >=current_date - interval '7' day where create_tm >=current_date - interval '7' day
@ -117,6 +119,7 @@ where create_tm >=current_date - interval '7' day
,source_url /*来源链接（URL）*/ ,source_url /*来源链接（URL）*/
,news_date /*新闻日期*/ ,news_date /*新闻日期*/
,create_tm /*采集入库时间*/ ,create_tm /*采集入库时间*/
,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/
,id /*主键*/ ,id /*主键*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/ ,Etl_First_Dt /*最初入库时间*/
@ -143,6 +146,7 @@ where create_tm >=current_date - interval '7' day
,P1.source_url /*来源链接（URL）*/ ,P1.source_url /*来源链接（URL）*/
,P1.news_date /*新闻日期*/ ,P1.news_date /*新闻日期*/
,P1.create_tm /*采集入库时间*/ ,P1.create_tm /*采集入库时间*/
,P1.business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/
,P1.id /*主键*/ ,P1.id /*主键*/
,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_Batch_No /*作业批次号*/
,P1.Etl_First_Dt /*最初入库时间*/ ,P1.Etl_First_Dt /*最初入库时间*/
@ -169,6 +173,7 @@ ON P1.newsletter_title = P2.newsletter_title
AND P1.source_url = P2.source_url AND P1.source_url = P2.source_url
AND P1.news_date = P2.news_date AND P1.news_date = P2.news_date
AND P1.create_tm = P2.create_tm AND P1.create_tm = P2.create_tm
AND P1.business_type = P2.business_type
AND P1.id = P2.id AND P1.id = P2.id
WHERE P2.newsletter_title IS NULL WHERE P2.newsletter_title IS NULL
@ -186,6 +191,7 @@ WHERE P2.newsletter_title IS NULL
OR P2.source_url IS NULL OR P2.source_url IS NULL
OR P2.news_date IS NULL OR P2.news_date IS NULL
OR P2.create_tm IS NULL OR P2.create_tm IS NULL
OR P2.business_type IS NULL
OR P2.id IS NULL OR P2.id IS NULL
; ;
@ -206,6 +212,7 @@ WHERE P2.newsletter_title IS NULL
,source_url /*来源链接（URL）*/ ,source_url /*来源链接（URL）*/
,news_date /*新闻日期*/ ,news_date /*新闻日期*/
,create_tm /*采集入库时间*/ ,create_tm /*采集入库时间*/
,business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/
,id /*主键*/ ,id /*主键*/
,Etl_Batch_No /*作业批次号*/ ,Etl_Batch_No /*作业批次号*/
,Etl_First_Dt /*最初入库时间*/ ,Etl_First_Dt /*最初入库时间*/
@ -232,6 +239,7 @@ SELECT
,P1.source_url /*来源链接（URL）*/ ,P1.source_url /*来源链接（URL）*/
,P1.news_date /*新闻日期*/ ,P1.news_date /*新闻日期*/
,P1.create_tm /*采集入库时间*/ ,P1.create_tm /*采集入库时间*/
,P1.business_type /*商业活动类型（1-新项目，2-扩产，3-招聘，4-融资）*/
,P1.id /*主键*/ ,P1.id /*主键*/
,P1.Etl_Batch_No /*作业批次号*/ ,P1.Etl_Batch_No /*作业批次号*/
,P1.Etl_First_Dt /*最初入库时间*/ ,P1.Etl_First_Dt /*最初入库时间*/
@ -260,6 +268,7 @@ DO UPDATE SET
,source_url=excluded.source_url ,source_url=excluded.source_url
,news_date=excluded.news_date ,news_date=excluded.news_date
,create_tm=excluded.create_tm ,create_tm=excluded.create_tm
,business_type=excluded.business_type
,Etl_Batch_No=excluded.Etl_Batch_No ,Etl_Batch_No=excluded.Etl_Batch_No
,Etl_First_Dt=excluded.Etl_First_Dt ,Etl_First_Dt=excluded.Etl_First_Dt
,Etl_Job=excluded.Etl_Job ,Etl_Job=excluded.Etl_Job