wip:tj

userSign/main.go

@@ -13,16 +13,20 @@ import (
 )
 
 func main() {
+
 	ctx := gctx.New()
-	//runOnce(context.TODO())
-	//if e := userTag.BaseUserTag(); e != nil {
-	//	g.Log().Errorf(ctx, "BaseUserTag 异常 %v", e)
-	//}
-	//g.Dump("FINISH")
+	if g.Cfg().MustGet(ctx, "run", false).Bool() {
+		runOnce(context.TODO())
+		if e := userTag.BaseUserTag(); e != nil {
+			g.Log().Errorf(ctx, "BaseUserTag 异常 %v", e)
+		}
+		g.Dump("run once FINISH")
+	}
+
 	_, err := gcron.Add(gctx.New(), g.Cfg().MustGet(ctx, "runCron", "# 0 2 * * *").String(), func(ctx context.Context) {
 		runOnce(context.TODO())
 		if e := userTag.BaseUserTag(); e != nil {
-			g.Log().Errorf(ctx, "BaseUserTag 异常", e)
+			g.Log().Errorf(ctx, "BaseUserTag 异常 %v", e)
 		}
 	}, "userSign")
 	if err != nil {
@@ -58,7 +62,7 @@ func runOnce(ctx context.Context) {
 		nowTime = time.Now()
 	)
 	// 日志标签
-	logRes, logErr := manager.GetLogRes(ctx, nowTime)
+	logRes, logErr := manager.GetAnalysisLogRes(ctx, nowTime)
 	if logErr != nil {
 		g.Log().Errorf(ctx, "日志标签异常%v", logErr)
 	}
@@ -66,6 +70,15 @@ func runOnce(ctx context.Context) {
 		allRes = append(allRes, re)
 	}
 
+	// 后端接口日志分析
+	backLogsRes, backLogsErr := manager.GetBackLogsTagsData(ctx, nowTime)
+	if backLogsErr != nil {
+		g.Log().Errorf(ctx, "接口请求日志分析异常%v", backLogsErr)
+	}
+	for _, re := range backLogsRes {
+		allRes = append(allRes, re)
+	}
+
 	// 电销标签
 	telemarketingRes, telemarketingErr := manager.GetTelemarketingRes(ctx, nowTime)
 	if telemarketingErr != nil {
@@ -78,12 +91,22 @@ func runOnce(ctx context.Context) {
 	// 埋点数据分析
 	buryPointRes, buryPointErr := manager.GetBuryPointRes(ctx, nowTime)
 	if buryPointErr != nil {
-		g.Log().Errorf(ctx, "埋点数据分析%v", buryPointErr)
+		g.Log().Errorf(ctx, "埋点数据分析异常%v", buryPointErr)
 	}
 	for _, re := range buryPointRes {
 		allRes = append(allRes, re)
 	}
 
+	// 留资数据
+	saleLeadsRes, saleLeadsErr := manager.GetSaleLeadsData(ctx, nowTime)
+	if saleLeadsErr != nil {
+		g.Log().Errorf(ctx, "留资数据分析异常%v", saleLeadsErr)
+	}
+	for _, re := range saleLeadsRes {
+		allRes = append(allRes, re)
+	}
+
+	// 更新标签
 	for _, re := range allRes {
 		re.UpdateTag(ctx)
 	}

userSign/new.sql

@@ -42,4 +42,85 @@ INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, cre
 INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2105, 'telemarketing_hasCall_30_day', '近30天电销有效通话',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2105);
 INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2106, '7day_article_gte_7', '近7天访问标讯页面>=7次',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2106);
 INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2107, '7day_article_gte_10', '近7天访问标讯页面>=10次',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2107);
-INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2108, 'buryPoint_share_7_day_gte2', '近7天点击标讯分享按钮>=2',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2108);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2108, 'buryPoint_share_7_day_gte2', '近7天点击标讯分享按钮>=2',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2108);
+
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2109, 'add_monitor_ent_1_day', '近1天新增监控企业用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2109);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2110, 'add_monitor_buyer_1_day', '近1天新增监控业主用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2110);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2111, 'add_monitor_project_1_day', '近1天新增监控项目用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2111);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2112, 'add_change_subscribe_1_day', '近1天调整订阅词用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2112);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2113, 'active_1', '1天活跃用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2113);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2114, 'click_saleLeads_gte_1_7day', '近7天点击平台产品留资弹窗>=1次',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2114);
+INSERT INTO pub_tags.dwd_d_tag (id, code, name, bitobj, groupid, created_at, created_by, bit_num) VALUES(2115, 'save_saleLeads_7day', '近7天留资用户',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2115);
+
+
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2116, '近7天进入进入购买页大于等于7次', 'visit_buypage_7day_gte7',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2116);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2117, '近1天进入超级订阅购买页', 'visit_buypage_vip_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2117);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2118, '近7天进入超级订阅购买页', 'visit_buypage_vip_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2118);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2119, '近1天进入大会员购买页', 'visit_buypage_member_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2119);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2120, '近7天进入大会员购买页', 'visit_buypage_member_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2120);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2121, '近1天进入省份订阅包购买页', 'visit_buypage_areavip_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2121);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2122, '近7天进入省份订阅包购买页', 'visit_buypage_areavip_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2122);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2123, '近1天进入业主采购分析报告下载包购买页', 'visit_buypage_buyer_report_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2123);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2124, '近7天进入业主采购分析报告下载包购买页', 'visit_buypage_buyer_report_package_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2124);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2125, '近1天进入企业中标分析报告下载包购买页', 'visit_buypage_winner_report_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2125);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2126, '近7天进入企业中标分析报告下载包购买页', 'visit_buypage_winner_report_package_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2126);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2127, '近1天进入市场分析定制报告下载包购买页', 'visit_buypage_market_report_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2127);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2128, '近7天进入市场分析定制报告下载包购买页', 'visit_buypage_market_report_package_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2128);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2129, '近1天进入采购单位画像包购买页', ' visit_buypage_buyer_portrait_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2129);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2130, '近7天进入采购单位画像包购买页', ' visit_buypage_buyer_portrait_package_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2130);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2131, '近1天进入附件下载包购买页', 'visit_buypage_attach_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2131);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2132, '近7天进入附件下载包购买页', 'visit_buypage_attach_package_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2132);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2133, '近1天进入投标企业信用报告购买页', 'visit_buypage_ent_credit_report_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2133);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2134, '近7天进入投标企业信用报告购买页', 'visit_buypage_ent_credit_report_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2134);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2135, '近1天进入物业碎片化小程序购买页', ' visit_buypage_applet_wy_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2135);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2136, '近7天进入物业碎片化小程序购买页', ' visit_buypage_applet_wy_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2136);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2137, '近1天进入车辆租赁碎片化小程序购买页', 'visit_buypage_applet_clzl_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2137);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2138, '近7天进入车辆租赁碎片化小程序购买页', 'visit_buypage_applet_clzl_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2138);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2139, '近1天进入印务碎片化小程序购买页', 'visit_buypage_applet_ywsj_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2139);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2140, '近7天进入印务碎片化小程序购买页', 'visit_buypage_applet_ywsj_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2140);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2141, '近1天进入环境碎片化小程序购买页', 'visit_buypage_applet_hjcg_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2141);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2142, '近7天进入环境碎片化小程序购买页', 'visit_buypage_applet_hjcg_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2142);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2143, '近1天进入家具碎片化小程序购买页', ' visit_buypage_applet_jjztb_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2143);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2144, '近7天进入家具碎片化小程序购买页', ' visit_buypage_applet_jjztb_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2144);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2145, '近1天进入安防碎片化小程序购买页', ' visit_buypage_applet_af_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2145);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2146, '近7天进入安防碎片化小程序购买页', ' visit_buypage_applet_af_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2146);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2147, '近1天进入投招服工程设计咨询碎片化小程序购买页', 'visit_buypage_applet_gcsjzx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2147);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2148, '近7天进入投招服工程设计咨询碎片化小程序购买页', 'visit_buypage_applet_gcsjzx_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2148);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2149, '近1天进入法务碎片化小程序购买页', 'visit_buypage_applet_fw_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2149);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2150, '近7天进入法务碎片化小程序购买页', 'visit_buypage_applet_fw_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2150);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2151, '近1天进入保服碎片化小程序购买页', 'visit_buypage_applet_bx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2151);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2152, '近7天进入保服碎片化小程序购买页', 'visit_buypage_applet_bx_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2152);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2153, '近1天进入招服财审碎片化小程序购买页', 'visit_buypage_applet_cwsj_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2152);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2154, '近7天进入招服财审碎片化小程序购买页', 'visit_buypage_applet_cwsj_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2154);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2155, '近1天进入招服代理服务碎片化小程序购买页', 'visit_buypage_applet_zbdl_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2155);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2156, '近7天进入招服代理服务碎片化小程序购买页', 'visit_buypage_applet_zbdl_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2156);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2157, '近1天进入招服管理咨询碎片化小程序购买页', 'visit_buypage_applet_glzx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2157);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2158, '近7天进入招服管理咨询碎片化小程序购买页', 'visit_buypage_applet_glzx_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2158);
+
+
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2159, '近7天下单', 'has_order_7_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2159);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2160, '近1天下单超级订阅', 'has_order_vip_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2160);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2161, '近1天下单大会员', 'has_order_member_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2161);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2162, '近1天下单省份订阅包', 'has_order_areavip_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2162);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2163, '近1天下单业主采购分析报告下载包', 'has_order_buyer_report_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2163);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2164, '近1天下单企业中标分析报告下载包', 'has_order_winner_report_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2164);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2165, '近1天下单市场分析定制报告下载包', 'has_order_market_report_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2165);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2166, '近1天下单采购单位画像包', ' has_order_buyer_portrait_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2166);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2167, '近1天下单附件下载包', 'has_order_attach_package_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2167);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2168, '近1天下单投标企业信用报告', 'has_order_ent_credit_report_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2168);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2169, '近1天下单物业碎片化小程序', ' has_order_applet_wy_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2169);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2170, '近1天下单车辆租赁碎片化小程序', 'has_order_applet_clzl_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2170);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2171, '近1天下单印务碎片化小程序', 'has_order_applet_ywsj_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2171);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2172, '近1天下单环境碎片化小程序', 'has_order_applet_hjcg_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2172);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2173, '近1天下单家具碎片化小程序', ' has_order_applet_jjztb_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2173);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2174, '近1天下单安防碎片化小程序', ' has_order_applet_af_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2174);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2175, '近1天下单投招服工程设计咨询碎片化小程序', 'has_order_applet_gcsjzx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2175);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2176, '近1天下单法务碎片化小程序', 'has_order_applet_fw_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2176);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2177, '近1天下单保服碎片化小程序', 'has_order_applet_bx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2177);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2178, '近1天下单招服财审碎片化小程序', 'has_order_applet_cwsj_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2178);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2179, '近1天下单招服代理服务碎片化小程序', 'has_order_applet_zbdl_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2179);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2180, '近1天下单招服管理咨询碎片化小程序', 'has_order_applet_glzx_1_day',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2180);
+
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2181, '7天内访问详情页次数>=15', '7day_article_gte_15',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2181);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2182, '7天内访问详情页次数>=20', '7day_article_gte_20',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2182);
+INSERT INTO pub_tags.dwd_d_tag (id, name,code,bitobj, groupid, created_at, created_by, bit_num) VALUES(2183, '1天内访问详情页次数>=10', '1day_article_gte_10',bitmapBuild([toUInt64(0)]) , 2, '2025-03-25 00:00:00', 'wky', 2183);

userSign/userAnalysis/analysisLogsAnalysis.go

@@ -32,6 +32,10 @@ func (ua *UserAnalysis) GetAnalysisLogRes(ctx context.Context, runTime time.Time
 		returnData = append(returnData, res...)
 		//returnData = append(returnData, &AnalysisRes{Name: fmt.Sprintf("%d天内访问详情页次数%s", param.Day, param.Compare), Code: fmt.Sprintf("%dday_article_gt_%d", param.Day, param.Compare), Data: res})
 	}
+	//标讯详情页访问
+	if res, err := ua.ArticleVisit1Day(ctx, runTime.AddDate(0, 0, -1)); err == nil && len(res) > 0 {
+		returnData = append(returnData, res...)
+	}
 
 	// 已访问过
 	if res, err := ua.Visited(ctx, runTime.AddDate(0, 0, -7)); err == nil && len(res) > 0 {
@@ -124,6 +128,30 @@ func (ua *UserAnalysis) ArticleVisit(ctx context.Context, start time.Time) ([]*A
 	}, nil
 }
 
+func (ua *UserAnalysis) ArticleVisit1Day(ctx context.Context, start time.Time) ([]*AnalysisRes, error) {
+	var (
+		d0 = map[BaseUserId]bool{}
+	)
+
+	rPc, err := g.DB().Query(ctx, `SELECT sum(article) as articleCount,baseUserId FROM pub_tags.user_log_byHour WHERE create_time > ? GROUP BY  baseUserId HAVING articleCount >=10 `, start.Format(time.DateTime))
+	if err != nil {
+		return nil, err
+	}
+	for _, m := range rPc.List() {
+		var (
+			baseUserId = BaseUserId(gconv.Int64(m["baseUserId"]))
+			//count      = gconv.Int64(m["articleCount"])
+		)
+		if baseUserId <= 0 {
+			continue
+		}
+		d0[baseUserId] = true
+	}
+	return []*AnalysisRes{
+		{"1天内访问详情页次数>=10", "1day_article_gte_10", d0, false},
+	}, nil
+}
+
 // Visited 指定日期内访问过剑鱼
 func (ua *UserAnalysis) Visited(ctx context.Context, start time.Time) (map[BaseUserId]bool, error) {
 	rPc, err := g.DB().Query(ctx, `SELECT sum(article)+sum(search)+sum(portrait)+sum(other) as allCount,baseUserId FROM pub_tags.user_log_byHour WHERE create_time >? GROUP BY  baseUserId`, start.Format(time.DateTime))

userSign/userAnalysis/jobFrontLogs.go

@@ -95,9 +95,10 @@ type (
 		MiniCode string //小程序code
 	}
 	cVisit struct {
-		fullData map[string]*countObj
-		matchObj *match.TrieNode
-		now      time.Time
+		fullData    map[string]*countObj
+		mappingData map[string]*countObj
+		matchObj    *match.TrieNode
+		now         time.Time
 	}
 )
 
@@ -224,6 +225,16 @@ func getVisitStatic(t time.Time) *cVisit {
 			MiniCode: "glzx",
 		},
 	}
+	rData.mappingData = map[string]*countObj{}
+	for key, obj := range rData.fullData {
+		rData.matchObj.Insert(obj.LoadUrl...)
+		rData.mappingData[key] = obj
+		for _, s := range obj.LoadUrl {
+			if s != "pages/order/create/index" {
+				rData.mappingData[s] = obj
+			}
+		}
+	}
 	rData.now = t
 	return rData
 }
@@ -238,7 +249,7 @@ func (cv *cVisit) addCount(url, miniCode, dataStr string, uid BaseUserId) {
 			}
 		}
 
-		obj, ok := cv.fullData[matchUrl]
+		obj, ok := cv.mappingData[matchUrl]
 		if ok && obj != nil {
 			obj.Seven[uid]++
 			if insertOne {
@@ -249,7 +260,7 @@ func (cv *cVisit) addCount(url, miniCode, dataStr string, uid BaseUserId) {
 
 		//小程序
 		if matchUrl == "pages/order/create/index" {
-			if miniObj, miniOk := cv.fullData[fmt.Sprintf("visit_buypage_applet_%s", miniCode)]; miniOk && miniObj != nil {
+			if miniObj, miniOk := cv.mappingData[fmt.Sprintf("visit_buypage_applet_%s", miniCode)]; miniOk && miniObj != nil {
 				miniObj.Seven[uid]++
 				if insertOne {
 					miniObj.Seven[uid]++
@@ -266,8 +277,8 @@ func (cv *cVisit) getAnalysisRes() []*AnalysisRes {
 	)
 	for code, obj := range cv.fullData {
 		var (
-			dataOne   map[BaseUserId]bool
-			dataSeven map[BaseUserId]bool
+			dataOne   = map[BaseUserId]bool{}
+			dataSeven = map[BaseUserId]bool{}
 		)
 		for basUserId, _ := range obj.One {
 			dataOne[basUserId] = true
@@ -322,6 +333,7 @@ func (ua *UserAnalysis) visitBuyPageRes(ctx context.Context, t time.Time) (retur
 	if err != nil {
 		return nil, errors.Wrap(err, "查询超级订阅购买页访问数据异常")
 	}
+	var c int
 	for _, m := range res.List() {
 		var (
 			position_id       = gconv.String(m["position_id"])
@@ -332,10 +344,11 @@ func (ua *UserAnalysis) visitBuyPageRes(ctx context.Context, t time.Time) (retur
 		if position_id == "" {
 			continue
 		}
-
 		if baseUserId, ok := ua.UserMapping[position_id]; ok {
 			visitStatic.addCount(urlStr, mini_program_code, dataStr, baseUserId)
 		}
+		c++
 	}
+	g.Log().Infof(ctx, "<UserAnalysis.visitBuyPageRes> %d", c)
 	return visitStatic.getAnalysisRes(), nil
 }

userSign/userAnalysis/jobMgoUserRange.go

@@ -31,7 +31,7 @@ func (ua *UserAnalysis) GetMgoUserRes(ctx context.Context) ([]*AnalysisRes, erro
 			Code: fmt.Sprintf("newUser_%d", i),
 			Data: ua.NewUser[i],
 		})
-		g.Dump(fmt.Sprintf("近第%d天注册用户", i), ua.NewUser[i])
+		//g.Dump(fmt.Sprintf("近第%d天注册用户", i), ua.NewUser[i])
 	}
 	return rData, nil
 }