def init(context):
# 官方原版选股条件:完全保留
wencai_string_KDJ = '非ST,非北交所,换手率大于2%,kdj金叉或macd金叉,最近一个交易日涨幅大于1.5%,最近一个交易日涨幅小于5%,CCI金叉,连续3日主力流入>0'
# 调用问财选股接口:完全保留
get_iwencai(wencai_string_KDJ)
# 已替换为你提供的企业微信webhook链接
g.wechat_work_webhook = "//qyapi.weixin.qq.com/cgi-bin/webhook/send?key=adbdad00-702e-4812-89c6-ac25fd4db6f4"
def handle_bar(context, bar_dict):# 每个交易频率(日/分钟)调用一次
# 官方原版日志打印:完全保留
log.info("满足条件的股票个数:")
log.info(len(context.iwencai_securities))
log.info("满足条件的股票个数占大盘比例:")
log.info(len(context.iwencai_securities)/5000)
# 打印选股结果:完全保留
log.info(context.iwencai_securities)
notify_push_string = ""
# 组装推送文本:完全保留
for stock in context.iwencai_securities:
notify_push_string = "" + stock + ","+ notify_push_string
# 企业微信推送(链接已替换为你的)
notify_push(
content=notify_push_string,
channel='webhook',
subject='SuperMind消息提醒',
url=g.wechat_work_webhook,
payload={"msgtype": "text", "text": {"content": "$content"}},
uids=None,
email_list=None,
topic_ids=None,
group_id=None
)