feat: 数据项列表全面带来源URL——国内众包需求主题接入数据参考弹窗(新opp_demand_items.dspy,逐条带需求详情/来源页)+category_references支持record_type+prompt强制数据项列表逐条挂来源链接

This commit is contained in:
yumoqing 2026-08-31 11:34:38 +08:00
parent ca8e9f2c71
commit 333aad0127
5 changed files with 150 additions and 11 deletions

View File

@ -122,10 +122,14 @@ opp_query_tenders / opp_tender_detail),**不要**自己去爬网站,
- 报告里的招标数量、预算、项目案例必须来自工具返回的真实数据,**禁止编造**;
查不到就如实写"数据未覆盖"。
- **所有分析必须带 references(可查证)**:给排名/统计/推荐结论时,调
opp_category_references 或 opp_query_tenders 取分项明细,回答末尾附 References 章节——
列出自带的「📋 数据参考」菜单(用户可逐条点开查公告原文),
并在正文中给出 3-5 条代表性分项的标题+公告链接(markdown 链接,外链会自动新窗口打开)。
- 每条引用的招标信息带来源链接(爬虫平台已提供 url / source_url)。
opp_category_references / opp_query_tenders / opp_demands / opp_overseas_references
取分项明细,回答末尾附 References 章节——
列出自带的「📋 数据参考」菜单(招标/国内众包需求/海外需求三类主题都可逐条点开查原文),
并在正文中给出 3-5 条代表性分项的标题+来源链接(markdown 链接,外链会自动新窗口打开)。
- **凡是回复中出现单个数据项的列表(招标/需求/样例),每一项都必须带来源 URL**:
用 markdown 链接把标题挂到该条的 url(公告原文/需求详情页)上,格式如
「[标题](url) | 来源:ccgp | 2026-08-30」;url 缺失时如实写「来源缺失」,禁止只贴标题。
- 每条引用的招标/需求信息带来源链接(爬虫平台已提供 url / source_url)。
- 报告没被人工确认,不许当作可发起审批;审批没过,不许当作可立项。
## 典型场景

View File

@ -37,13 +37,15 @@ async def hot_software(sor, days=30, top=10):
{"days": days, "top": top})
async def category_references(sor, category, days=30, limit=500):
async def category_references(sor, category, days=30, limit=500, record_type="tender"):
"""某软件主题的全部分项(references 可查证)。
每条带公告原文 url + 采集来源 source_url,供界面逐条查证。
每条带公告原文/详情页 url + 采集来源 source_url,供界面逐条查证。
record_type: tender=招标(默认) / demand=众包需求发布(猪八戒/一品威客)。
"""
return await crawler_get(sor, "/api/category_references",
{"category": category, "days": days, "limit": limit})
{"category": category, "days": days, "limit": limit,
"record_type": record_type})
async def crawler_stats(sor):

View File

@ -26,6 +26,7 @@ PATHS_LOGINED = [
"/%s/agent/index.ui" % MOD,
"/%s/api/opp_references_popup.dspy" % MOD,
"/%s/api/opp_references_items.dspy" % MOD,
"/%s/api/opp_demand_items.dspy" % MOD,
"/%s/api/opp_overseas_items.dspy" % MOD,
"/%s/api/opp_confirm_report.dspy" % MOD,
"/%s/api/opp_report_ppt.dspy" % MOD,

View File

@ -0,0 +1,89 @@
# opp_demand_items.dspy - 某软件主题的众包需求分项列表(国内猪八戒/一品威客,references 可查证)
# 入参:category=<主题名>。每条分项:标题+时间+预算+来源平台 + 「需求详情」「来源页」按钮(新窗口)
import json as _json
uid = await get_user()
if not uid:
return {"widgettype": "Message", "options": {"title": "未登录", "message": "请先登录"}}
category = ((params_kw or {}).get("category") or "").strip()
days = int((params_kw or {}).get("days") or 30)
if not category:
return {"widgettype": "Message", "options": {"title": "缺少参数", "message": "缺少 category"}}
dbname = get_module_dbname('pipeline-opportunity')
async with DBPools().sqlorContext(dbname) as sor:
from pipeline_opportunity.opp_data_capability import category_references
ok, res = await category_references(sor, category, days=days, limit=500, record_type="demand")
await sor.sqlExe("COMMIT", {})
SRC_NAME = {"zbj": "猪八戒", "epwk": "一品威客"}
rows = []
if not ok:
rows.append({"widgettype": "Text", "options": {
"text": "查询失败:" + str(res)[:200],
"color": "#dc2626", "padding": "12px", "halign": "left"}})
else:
items = res.get("items") or []
if not items:
rows.append({"widgettype": "Text", "options": {
"text": "该主题近 %d 天无众包需求分项" % days, "color": "#64748b", "padding": "12px", "halign": "left"}})
for it in items:
url = str(it.get("url") or "")
src = str(it.get("source_url") or "")
sub_btns = []
if url:
sub_btns.append({"widgettype": "Button", "options": {"label": "需求详情", "css": "small"},
"binds": [{"wid": "self", "event": "click", "actiontype": "script",
"target": "self",
"script": "window.open(" + _json.dumps(url) + ",'_blank','noopener');"}]})
if src and src != url:
sub_btns.append({"widgettype": "Button", "options": {"label": "来源页", "css": "small"},
"binds": [{"wid": "self", "event": "click", "actiontype": "script",
"target": "self",
"script": "window.open(" + _json.dumps(src) + ",'_blank','noopener');"}]})
budget = it.get("budget_wan") or 0
plat = SRC_NAME.get(str(it.get("source") or ""), str(it.get("source") or "众包平台"))
meta = "%s | %s | %s" % (
str(it.get("publish_time") or "")[:10],
plat,
(("预算 %.0f 万" % budget) if budget else "预算未公开"))
rows.append({
"widgettype": "VBox",
"options": {"width": "100%", "padding": "8px 12px", "gap": "4px",
"border": "1px solid #e2e8f0", "borderRadius": "8px",
"margin": "0 0 6px 0", "bgcolor": "#ffffff"},
"subwidgets": [
{"widgettype": "Text", "options": {
"text": str(it.get("title") or ""), "cfontsize": 0.95,
"color": "#0f172a", "halign": "left", "wrap": True}},
{"widgettype": "HBox", "options": {"width": "100%", "gap": "10px",
"alignItems": "center"},
"subwidgets": [
{"widgettype": "Text", "options": {"text": meta,
"cfontsize": 0.75, "color": "#94a3b8", "halign": "left"}},
{"widgettype": "Filler"}
] + sub_btns}
]
})
total = res.get("count", len(rows)) if ok else 0
return {
"widgettype": "PopupWindow",
"id": "opp_demand_items_pw",
"options": {"title": "众包需求分项:%s(%d 条)" % (category, total),
"width": "80%", "height": "82%", "auto_open": True, "resizable": True},
"subwidgets": [{
"widgettype": "VBox",
"options": {"css": "filler", "width": "100%", "height": "100%",
"padding": "12px 16px", "gap": "0px", "overflow": "auto"},
"subwidgets": [
{"widgettype": "Text", "options": {
"text": "每条「需求详情」为众包平台(猪八戒/一品威客)原始需求页,「来源页」为采集来源页,均在新窗口打开,可逐条查证。",
"cfontsize": 0.78, "color": "#64748b", "halign": "left", "margin": "0 0 8px 0"}}
] + rows
}]
}

View File

@ -1,5 +1,7 @@
# opp_references_popup.dspy - 数据参考(references):主题列表(agent_menu_open 弹窗内嵌内容)
# 点主题「查看分项」→ opp_references_items.dspy 列分项(每条带来源,点击新窗口查证)
# 点主题「查看分项」→ 对应分项列表(每条带来源,点击新窗口查证):
# 招标主题 → opp_references_items.dspy;国内众包需求主题 → opp_demand_items.dspy;
# 海外众包需求主题 → opp_overseas_items.dspy
import json as _json
@ -10,12 +12,15 @@ if not uid:
dbname = get_module_dbname('pipeline-opportunity')
items_url = entire_url("/pipeline-opportunity/api/opp_references_items.dspy")
demand_items_url = entire_url("/pipeline-opportunity/api/opp_demand_items.dspy")
overseas_items_url = entire_url("/pipeline-opportunity/api/opp_overseas_items.dspy")
async with DBPools().sqlorContext(dbname) as sor:
from pipeline_opportunity.opp_data_capability import hot_software, hot_overseas
from pipeline_opportunity.opp_data_capability import hot_software, hot_demands, hot_overseas
ok, res = await hot_software(sor, days=30, top=10)
await sor.sqlExe("COMMIT", {})
ok_dm, res_dm = await hot_demands(sor, days=30, top=10)
await sor.sqlExe("COMMIT", {})
ok_ov, res_ov = await hot_overseas(sor, days=30, top=10)
await sor.sqlExe("COMMIT", {})
@ -57,6 +62,44 @@ else:
]
})
# ── 国内众包需求板块(猪八戒/一品威客)──
dm_rows = []
if ok_dm:
dm_ranking = res_dm.get("ranking") or []
if dm_ranking:
dm_rows.append({"widgettype": "Text", "options": {
"text": "国内众包软件需求(猪八戒/一品威客,近30天)",
"cfontsize": 0.95, "color": "#0f172a", "halign": "left",
"margin": "14px 0 6px 0", "padding": "6px 0 0 0",
"border": "1px solid #f1f5f9", "borderRadius": "6px", "bgcolor": "#f8fafc"}})
for r in dm_ranking:
cat = str(r.get("category", ""))
cnt = r.get("tender_count", 0)
budget = r.get("total_budget_wan", 0)
script = ("var old=bricks.getWidgetById('opp_demand_items_pw',bricks.app);"
"if(old&&old.destroy){old.destroy();}"
"var rp=await fetch(" + _json.dumps(demand_items_url) + "+'?category='+encodeURIComponent(" + _json.dumps(cat) + "));"
"var d=await rp.json();"
"if(d){bricks.widgetBuild(d,bricks.app);}")
dm_rows.append({
"widgettype": "HBox",
"options": {"width": "100%", "gap": "10px", "alignItems": "center",
"padding": "8px 14px", "border": "1px solid #e2e8f0",
"borderRadius": "8px", "margin": "0 0 8px 0", "bgcolor": "#ffffff"},
"subwidgets": [
{"widgettype": "Text", "options": {"text": cat, "cfontsize": 1.0,
"color": "#0f172a", "halign": "left"}},
{"widgettype": "Filler"},
{"widgettype": "Text", "options": {"text": "%d 条" % cnt,
"cfontsize": 0.85, "color": "#64748b"}},
{"widgettype": "Text", "options": {"text": "预算 %s 万" % ("{:,.0f}".format(budget) if budget else "—"),
"cfontsize": 0.85, "color": "#64748b"}},
{"widgettype": "Button", "options": {"label": "查看分项", "css": "small"},
"binds": [{"wid": "self", "event": "click", "actiontype": "script",
"target": "self", "script": script}]}
]
})
# ── 海外众包需求板块(Freelancer.com / PeoplePerHour)──
ov_rows = []
if ok_ov:
@ -102,7 +145,7 @@ return {
"gap": "6px", "overflow": "auto"},
"subwidgets": [
{"widgettype": "Text", "options": {
"text": "点击「查看分项」列出该主题的全部招标分项;每条分项带公告原文链接,可逐条查证。",
"text": "点击「查看分项」列出该主题的全部数据项;每条数据项带来源链接(公告原文/需求详情/来源页),可逐条点开查证。",
"cfontsize": 0.8, "color": "#64748b", "halign": "left", "margin": "0 0 8px 0"}}
] + rows + ov_rows
] + rows + dm_rows + ov_rows
}