1

main.py

@@ -4,6 +4,8 @@ import dingding
 import monitors.jin10_cal as jin10
 
 from monitors import macd_boll,vol_up
+# from plombery import task, get_logger, Trigger, register_pipeline
+
 
 #vegas
 # schedule.every().hour.at(":00").do(vegas.run_crypto, interval = '1h')
@@ -18,6 +20,10 @@ from monitors import macd_boll,vol_up
 #     schedule.every().day.at(t).do(vegas_cross.run_crypto, interval = '4h')
 
 
+# register_pipeline(tasks=[vol_up.run_crypto('15')], triggers=[Trigger()])
+
+
+
 #vol
 schedule.every(5).minutes.do(vol_up.run_crypto, interval = '5m')
 
@@ -41,9 +47,9 @@ for t in times:
     schedule.every().day.at(t).do(macd_boll.run_crypto, interval = '4h')
 
 #jin10
-schedule.every().day.at("00:00").do(jin10.run)
+schedule.every().day.at("09:00").do(jin10.run)
 
-version = 'V1.3'
+version = 'V1.4'
 text = f'☕️ Signals running... {version} !'
 print(text)
 dingding.send_message(text)

monitors/jin10_cal.py

@@ -1,7 +1,7 @@
 import requests
 import datetime
 import time
-import discord_sender
+import discord_sender,dingding
 
 
 def run():
@@ -27,6 +27,9 @@ def run():
             content += _build_content(item)
         
         print(content)
+
+        dingding.send_message(content)
+
         url = 'https://discord.com/api/webhooks/1287027684370681939/fzinKKoNK6KXoLNdj1wttSDtIGio-VHijaYzZInoajHHu-PZyZXVpWDxM6_XrxCtPrPY'
         discord_sender.send_message(url, '【最近重要数据公布时间】',content)