From aa989cd85626a4bf3ec33359b42c91514c279a5b Mon Sep 17 00:00:00 2001 From: lj091715 <1091062319@qq.com> Date: Tue, 19 May 2026 09:43:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E6=96=87=E4=BB=B6=E8=87=B3?= =?UTF-8?q?=20gp?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- gp/SKILL.md | 78 +++++++++++++++++ gp/stock.cpython-312.pyc | Bin 0 -> 7317 bytes gp/stock.py | 181 +++++++++++++++++++++++++++++++++++++++ 3 files changed, 259 insertions(+) create mode 100644 gp/SKILL.md create mode 100644 gp/stock.cpython-312.pyc create mode 100644 gp/stock.py diff --git a/gp/SKILL.md b/gp/SKILL.md new file mode 100644 index 0000000..6954968 --- /dev/null +++ b/gp/SKILL.md @@ -0,0 +1,78 @@ +--- +name: stock +description: "当用户发送「股票 代码」或「gp 代码」时触发。调用腾讯股票行情接口获取实时数据，再调用本地微信机器人发消息接口把股票信息发给当前用户。" +argument-hint: "参数为股票代码，例如 600519 或 sz000001" +--- + +# Stock Skill + +## 描述 +这是一个用于查询股票实时行情并直接发送给当前用户的技能。 + +当用户发送 `股票 600519` 或 `gp sz000001` 时，调用腾讯股票行情接口获取实时数据，再调用本地微信机器人接口把格式化后的股票信息发出去。 + +这个仓库里额外提供了一个可执行脚本 `scripts/stock.py`，方便宿主机器人直接调用。 + +## 触发条件 +- 用户发送 `股票 <股票代码>` 或 `gp <股票代码>` +- 股票代码可以是纯数字（如 `600519`），也可以带市场前缀（如 `sh600519`、`sz000001`） + +## 接口信息 +- 获取股票行情：`https://qt.gtimg.cn/q={stock_code}` +- 请求方式：`GET` +- 发消息接口：`http://127.0.0.1:{ROBOT_WECHAT_CLIENT_PORT}/api/v1/robot/message/send/text` +- 请求方式：`POST` +- 本地脚本：`scripts/stock.py` + +### 腾讯股票行情返回示例 +``` +v_sh600519="1~贵州茅台~600519~1945.50~1942.00~1941.00~1946.80~1940.02~1945.71~4291131~8365444900~183~1945.60~826~1945.59~649~1945.58~699~1945.57~589~1945.56~1449~1945.71~1014~1945.72~722~1945.73~369~1945.74~471~1945.75~202~1945.76~2026-05-19~15:00:00~00~-1.18~-0.06~1945.50~1906.02~1945.50~1895216~4901415~1.22~836544.4900~18.55~403727.15~0.37~107.86~15.03~232.10~10.49~10.61~PB~0.23~0.53~-0.22~10.99~1945.50~1900.16~~ 1044479.27~1.22~1895216~4901415~0.06~10.47~10.49~10.61~0.01~-82.56~1945.50~1906.02~0.03~-0.06~1945.50~-0.39~1942.00~1036.50~1.88~181580~185384~1945.50~1900.16~0.00~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~0~" +``` + +### 字段说明 +| 索引 | 含义 | +|------|------| +| 1 | 股票名称 | +| 2 | 股票代码 | +| 3 | 当前价格 | +| 4 | 昨收价 | +| 5 | 今开价 | +| 6 | 成交量(手) | +| 7 | 成交额(万) | +| 8 | 最高价 | +| 9 | 最低价 | +| 10 | 涨跌额 | +| 11 | 涨跌幅(%) | + +## 环境变量 +- `ROBOT_WECHAT_CLIENT_PORT`：本地微信机器人服务端口。 +- `ROBOT_FROM_WX_ID`：当前消息来源用户的 wxid。 + +## 执行步骤 +1. 当用户发送 `股票 <代码>` 或 `gp <代码>` 时触发该技能。 +2. 在仓库根目录下执行本地脚本：`python3 scripts/stock.py <股票代码>`。 +3. 脚本内部自动处理股票代码格式（补全市场前缀 sh/sz）。 +4. 脚本发送 `GET` 请求到 `https://qt.gtimg.cn/q={stock_code}`。 +5. 脚本解析返回的行情数据，提取关键字段。 +6. 脚本从环境变量中读取 `ROBOT_WECHAT_CLIENT_PORT` 和 `ROBOT_FROM_WX_ID`。 +7. 脚本发送 `POST` 请求到 `http://127.0.0.1:{ROBOT_WECHAT_CLIENT_PORT}/api/v1/robot/message/send/text`，请求体为： + ```json + { + "to_wxid": "{ROBOT_FROM_WX_ID}", + "content": "【{股票名称}({股票代码})】 + 当前价：{当前价格} + 涨跌幅：{涨跌幅}% + 涨跌额：{涨跌额} + 最高：{最高价} + 最低：{最低价} + 今开：{今开价} + 昨收：{昨收价} + 成交量：{成交量} + 成交额：{成交额}" + } + ``` +8. 如果任一步骤失败，回复兜底文案：`股票查询失败，请稍后再试。` + +## 回复要求 +- 成功时，直接发送格式化股票信息，不要额外追加解释文字。 +- 失败时，使用固定兜底文案回复。 diff --git a/gp/stock.cpython-312.pyc b/gp/stock.cpython-312.pyc new file mode 100644 index 0000000000000000000000000000000000000000..ac55de67ebed5a14b072587457bf9abdd0c28611 GIT binary patch literal 7317 zcmbVRYjhJwmabN-rPll5Cw?JgLl6XH$A<767HsnhV-jqJjKiQK+-+O3EQ#(Genegb zd0-_F$&<_=2H2P+Oq_uU>^XB150K2sCVS5A**|jZS&N1roQ-AdKO4_Dd)Sltv$t9= z<2X#RWmLDSZq=&Y%YW!}Y6R)uKh?PYGZ&$+a3!7O$pSIAmO$tnVh}^PQ5Vrd z5V$OJ%UWa-C0j^|%3I_TrCKP7Dq0j0RkqL)RkhG8<$_rjCYG{m(rpacqGjYQI!4b> zFUwo>Kovj@jDb-CH8Mtq25MqVj0&ikF*9nQIczSY>0F5rr&l2vV)Njab2TOODy$!; zQ$(+<0(g~(lM(0?V)LQ2g24S1uC>WN^Yg`5drg~`CymTwbm{sjq8s&)KS$k!HD?A3 zvJ#@k;qiC{hv4*j_{P4%4ngqon{2jY!rFGh+10+b)nhxh^~HYw6VQG7)a3_PhNs@X zGJXA>#C!id{f8@G-##;a{o@D2XA_Y(60e?}zW%GPf~Q(j+mV(^K~5q>%)KXlqyTcw z=Sp1=N*{y^dM-?9UO$4dSlWWb5b5plrtj$?OZVVp0n~&9Wm<%bPM5NjAp=NIr0Xt8 z{nE80y_#AjXN374v*N!ylRSW~%91j<9pAHdDzkQqAp+kB)5Y+vQP zzI3*46SAuOm9VDi)4xl+Hava#O5&B_5r`BI|6*4^)U0|`u@s3<&k7TB-UGHB2gt0HJEM?iCR&%W3N>qQoO)9eIn)e`B+X= z^MZpD_-?1rA<8&bq`DkJYlo=bv#W9cfrh&6O${FqqP*41usqft%m36tUbpG+L7wIK z!_`$AtE&#zvwWxE^&Osq)tw)nym^!Fbh_P#rJT3%g15EP#<#+xLaMgb*DL0Fyj+*V z?d)UiQV%r6hib2xua|yMI<9;gIN`of-|K-GU7YF=QAg{? zmE~Ccw$Qd{&A4W1Jg*=sj~tI|j%my8>r7#L$R2GO*RA|P?HWVynK@W7dgKCPlmsOu z=59mb99EsjTtMlPEuzxdOUBU*s1`#q@}jJQEjA*nxHO~qK_jv%Ni(35kIo?}W({m1 zapP4>({5W+i)H$gYg1?6nH;%kId;r4^~RM%_}$4*{`BCj;RnBY*}`|&_&!TgPdN-5 zqKxmD!MClE!?zo%eVkS*9CcY`oF0mt0cSaoCDn|}!~7hdgX39ymxJqM1-p-9+nhaI zDR8W~qZ_h$DiW-Z&(n;!DJN1NHAT&l-H}ZLCt`G2T%`*y4K0o4j;qRkG#7tht^g){ zx@dg#Xg=2qfU`Ny$~1E@df0ogmYF`{e;SPxM0WD$e#u zmzWF|y6~r3keH0B^;5#qG&7JZMnvesyE&?1zazel-35yHo!ZfqRws{kg;| zBQw|p0{$w&A7H(HK_uIcb~g5@w=P@x!jWaaSZ!T4gB407{&8jvP_78F8H@-sSi5HM z-J8MMHM1ONC|C8^!lDp-x8?zw~en;Y!gpWS0WcwnEX zXv0`9hzdXFb~}%XN{&6|he<>wG)ObZIo8353Wmj2K%`iX^Kv2$V;iKBwmEqK$(nM1 zlT_gFw-6OP>)^m-QSF@94|a|Bxt(xQZq@_F4$K=^AIY|eBupmK9LxK_;bKLSb98gq z*1+@^#)2(OnWtlZufTFYg)Zyh$LrzXgJ@PxQMvc@#S{8vqxxk- zo5u8O2grN6obZv*kqKSJsIFqD?uI$0s~FeSj?i&)(YZB)Yu>a?m{*RPR}SZmnQa4g z4@sn7_l*|m4BdJ>I#&j!!JMSsg z1M6RUF>>HbWdU@XRUlJAbM~zC&}tR4NJ}XmmcrsjFEL7h6^BLNDslt`w4~uD<;9m1;i+!OyjE$Wz{8$ zQC~m-0?Ha_mmmb(HImUmO#%?$7@!U=CPO4gU6L{2;4%_?VAqbxfm&{cmj|`{OsxQF zg_+tCs1;>u#ZW6r)|k>uWV@zc#*{7QS_d+YGg#lHl3O@6bUSf7oH&z0j>$h=o;rCQ zLq+)d^z~a)zdk*6@f!Cu?2^N#){hZj_U$(Z(uI&81H)Ir2xkK-5-X)UFLAA31qb_b zw=RR|PG8d~HDZYnG{xhNnM1llbE+n6*I?ynG>d=ABEx zm0JJn+N)oWge{h-i@}+zQ9K4;rWEURnl<^!8<@2ovoHkDzWvslmdRVMC2j|C`&0AU ze`%SD4o|)H5pJ(ei^AKsObtXPZ@xEkI*eJ^dr2+pmp9TZX<1w?X5pim962o#YAY#H zZEi1s71_=L(z(1&546b{hu{FX^4XoOUXMt*ogS9w@i4%PBwFMqK`sRsUBGs$->eo^LEGij-j3#rm?b`vBKIB;>*H~p|+9Z!Cm*&x&bD#KI9%a60MFl z53M+VINCT|8KZ4+P0qloxW+tSjcgst9csT^I%J5^RdIE3w0@{$v}A3p*fxADMpq|W z3ePvjidVAsM7PFhYg}Cz&5gF5FNx}7^b^UNdvwX_SmBc~ zdd;GOl5&S@U`4Y9TAd=;Fk6JQ#_-0_#>l}jO>sV+>{~Ht&t~XSZ$%Pel zL0arG%)jui%nLF*F!N3&{vWc*ESNl2wk$xv8&-z>9sm~%ABsz4KPhB9wZ-160qn3V zFJ>;Y3*V;&iJ{XV)-M+_9>-#Sh70@03sQg#$Qc!*b`p#R!Vmb?L+Yo%7k#`e>|ifQ z;A!cu>C;{wc$f;t5Ky@An`}X9mG#Iv!Q0>{#wht~IuCeK9<>TV@CE+TG6>Xbo_9iv z_?3Z-x7e>-IQE2cQEkY{oEIIS83PXO^bkBnAgJZy+9KZFii~%cJr(RNEl94C1r1OY z%F=BDoi4d7=~9+1>ha}C(47bm&IC^;A$sbg0l@9Vz>UPGA7TtoznR6t1N(REZ?+$5 zsN220*P>x1 zZ4RH)cD&lgd5?MpTMB|~JnLa>0^1`%AV4X2?cF_2MpOcf39Luxqx?eKnhky0x@3J# zbFYu>Gdg_WMYT$?DVvK2#FIa}zp2?uatC3;S}TV@_{tgBLx9AWA+xzRvt(? ziriLQQ$Vaj@bjV^@R{NM0r%RDvmKae*xR(fv0m~YCFjtp66JW)qFOo)yU)uB+%IrX zC7hBS`-1YLUZz)?h}$bMe2!j8H1>vhe6b~G5NAnq|Ait|>N%3qDjuql zQg^a#;LuCnSq-98-{_Gc4^J?muN>7^#%V)bXNsGa#>#7A##-?5W>v_rd=60tMR3=w zUP0wO>Zb0xaX@lYH;n9#8_bc8bKXJkxMB4$`DepwnD`-u^c!Qk4X~bq;&aYH=MX)X zZynh6Pzmj`dZf(>Zw_sa93Rt^!8=@Ih}48Of2pa6Rt}Y)x5nfZ4^7GOfBS|;;2zKS zBy%UK8%C=eVw#=UpUk@h2Lb+M-nTrq|NpYCynY+{Jin;EhWxyW#^sH9Q2s)X%U{$` z^;?u*Y*6Czwx=3u$$zaOAa8|{nS_mW()_@e`g`UFObseRI2OZO<{6U|tY&0FVKHL? zrUd4|34jlRnGA`2J$USAj6@(4GVPZMna6w9+XI7=F%g06V;w)Z>wf%tvL+zAt{*Q2 zf&}w+C1BrAN`Xu}JmoW{Df^U%M?CrCXUmRumU(I{(vuNFl$P~XRqLuZswD{Ho&yn9wMg>4 z06-3|{Wyjr20zNFZq5l$Lu@9c;FR=86m>hd@7uRyd)+hk=7#5+B|lIC4S1B|;XJ%V z9o@-?sX7x1Wkiki&Sa9&&?MNVaQr*ZQ+b!e>EZfe+OzQEZ$TDB_cZ$OhR}w{_Q;Nb zEy4Ob8pAzW6IO@R6LjGyT^L((aGd^G++e(K$cbzZbq9CfGc6zL7&F-brOeBRTw~_y z;4>I?N~14~X{_IsaItipe&P|C5K)8Zn!z{;FW}lS{mS63drD)ZU|hKb8bK6ApWb_N z?}R*eRGu3-G%hc_Cs)pEX&#ps#Wh;VZxm@eMEjf`yB+?2MBe6fv(opo%98;K5<=Ia zf@1|g=i!2|UtsJ8B9*z5Q0mh#&Q`$^urzu-EO4b0l;bvuogRckhuJ~c5P01XiNq2_ z(&-Vbg`(PSZ}Y=MtliFG2;o?qwc-qi9XK8`Q6+GWR`#f)wNun4V;gH(9I)W92^00H zrc|_p^W#RWHPDB{D#>-@EFWh$R3<4-R#T);i%$ecXzX@T-PFqqY*#}Mgf~%>N!Tz*d4tpk;TF<}Ol6|I~Mp z@h-}_i}LR4jNz70OOSk7ec!k$sEZpn26c0aJi<6vrGl)mj8M$&AdE!G+=_Cda&9+K zNa$wQBe`~iN9ANz{U$?yyeO6huBbWR?w_e*N literal 0 HcmV?d00001 diff --git a/gp/stock.py b/gp/stock.py new file mode 100644 index 0000000..5d475e8 --- /dev/null +++ b/gp/stock.py @@ -0,0 +1,181 @@ +#!/usr/bin/env python3 +from __future__ import annotations +import io +import json +import os +import re +import sys +import traceback +import urllib.error +import urllib.request + +# 将 stdout 编码设置为 UTF-8，确保 emoji 等字符能正常输出 +if hasattr(sys.stdout, "reconfigure"): + sys.stdout.reconfigure(encoding="utf-8") +else: + sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding="utf-8") +sys.stderr = sys.stdout + +QUOTE_API_URL = "https://qt.gtimg.cn/q={}" +FALLBACK_TEXT = "股票查询失败，请稍后再试。" + + +def normalize_stock_code(code: str) -> str: + """自动补全股票代码市场前缀""" + code = code.strip().upper() + # 如果已经带前缀，直接返回 + if code.startswith("SH") or code.startswith("SZ"): + return code + # 如果已经是带 sh/sz 前缀 + if re.match(r"^(sh|sz)\d{6}$", code, re.IGNORECASE): + return code.upper() + # 纯数字处理 + if re.match(r"^\d{6}$", code): + # 沪市：6开头 + if code.startswith("6"): + return f"SH{code}" + # 深市：0或3开头 + elif code.startswith(("0", "3")): + return f"SZ{code}" + # 北交所：8开头 + elif code.startswith(("8", "4")): + return f"BJ{code}" + # 无法识别 + return code + + +def parse_market_prefix(code: str) -> str: + """将 SH/SZ 转换为 qq 接口使用的 sh/sz 前缀""" + code = code.upper() + if code.startswith("SH"): + return f"sh{code[2:]}" + elif code.startswith("SZ"): + return f"sz{code[2:]}" + elif code.startswith("BJ"): + return f"bj{code[2:]}" + return code + + +def fetch_stock_quote(stock_code: str) -> dict | None: + """获取股票行情数据并解析为字典""" + try: + url = QUOTE_API_URL.format(stock_code) + with urllib.request.urlopen(url, timeout=10) as response: + raw = response.read().decode("gbk") + except (urllib.error.URLError, TimeoutError, OSError): + return None + + # 解析返回数据，格式如：v_sh600519="..."; + match = re.search(r'="([^"]+)"', raw) + if not match: + return None + + fields = match.group(1).split("~") + if len(fields) < 45: + return None + + return { + "name": fields[1], # 股票名称 + "code": fields[2], # 股票代码 + "price": fields[3], # 当前价格 + "yest_close": fields[4], # 昨收价 + "open": fields[5], # 今开价 + "volume": fields[6], # 成交量(手) + "amount": fields[37], # 成交额(万) + "high": fields[33], # 最高价 + "low": fields[34], # 最低价 + "change": fields[31], # 涨跌额 + "change_pct": fields[32], # 涨跌幅(%) + } + + +def format_stock_message(data: dict) -> str: + """格式化股票信息为可读文本""" + up_icon = "📈" if float(data.get("change", 0)) >= 0 else "📉" + lines = [ + f"【{data['name']}({data['code']})】", + f"{'=' * 20}", + f"{up_icon} 当前价：{data['price']}", + f"📊 涨跌幅：{data['change_pct']}%", + f"📊 涨跌额：{data['change']}", + f"⬆️ 最高：{data['high']}", + f"⬇️ 最低：{data['low']}", + f"🔓 今开：{data['open']}", + f"🔒 昨收：{data['yest_close']}", + f"📈 成交量：{data['volume']}", + f"💰 成交额：{data['amount']}万", + ] + return "\n".join(lines) + + +def send_text(text: str) -> bool: + """发送文本消息到微信机器人""" + robot_port = os.environ.get("ROBOT_WECHAT_CLIENT_PORT", "").strip() + to_wxid = os.environ.get("ROBOT_FROM_WX_ID", "").strip() + if not robot_port or not to_wxid: + return False + + api_url = ( + f"http://127.0.0.1:{robot_port}/api/v1/robot/message/send/text" + ) + body = json.dumps( + { + "to_wxid": to_wxid, + "content": text, + } + ).encode("utf-8") + + request = urllib.request.Request( + api_url, + data=body, + headers={"Content-Type": "application/json"}, + method="POST", + ) + + try: + with urllib.request.urlopen(request, timeout=10) as response: + if 200 <= response.status < 300: + return True + payload = json.load(response) + except (urllib.error.URLError, TimeoutError, json.JSONDecodeError): + return False + + code = payload.get("code") + return code == 200 or code == 0 + + +def main() -> int: + args = sys.argv[1:] + if not args: + sys.stdout.write("请提供股票代码，例如：python3 stock.py 600519\n") + return 0 + + raw_code = args[0] + normalized = normalize_stock_code(raw_code) + quoted_code = parse_market_prefix(normalized) + + # 在QQ接口中，多个股票用逗号分隔 + data = fetch_stock_quote(quoted_code) + if not data: + sys.stdout.write(FALLBACK_TEXT) + sys.stdout.write("\n") + return 0 + + message = format_stock_message(data) + if send_text(message): + return 0 + + # 发送失败，输出到stdout让宿主机器人捕获 + sys.stdout.write(message) + sys.stdout.write("\n") + return 0 + + +if __name__ == "__main__": + try: + raise SystemExit(main()) + except SystemExit: + raise + except Exception: + traceback.print_exc(file=sys.stdout) + raise SystemExit(1)