|
|
@@ -2,21 +2,60 @@ import sys
|
|
|
import paho.mqtt.client as mqtt
|
|
|
import paho.mqtt.publish as publish
|
|
|
from git import Repo
|
|
|
+import urllib
|
|
|
+import requests
|
|
|
+import http.cookiejar
|
|
|
+import json
|
|
|
+
|
|
|
+#$MQTTADDR $MQTTPORT $MQTTTOPIC "https://xxxx" "air101" DD_APPKEY DD_APPSECRET DD_NOTIFY_LIST DD_API_TOKEN DD_API_SEND
|
|
|
+# 1 2 3 4 5 6 7 8 9 10
|
|
|
|
|
|
-client = mqtt.Client()
|
|
|
repo = Repo("../")
|
|
|
+
|
|
|
+#暂时停用
|
|
|
+############# MQTT ###############
|
|
|
+# client = mqtt.Client()
|
|
|
+# try:
|
|
|
+# #服务器请自行修改,需要传入参数
|
|
|
+# client.connect(sys.argv[1], int(sys.argv[2]), 60)
|
|
|
+# #topic请根据需要自行修改,需要传入参数
|
|
|
+# info = sys.argv[4]+"\r\n"+str(repo.head.commit.author)+"-"+str(repo.head.commit.message)
|
|
|
+# if len(sys.argv) >= 6:
|
|
|
+# repo = Repo("../../"+sys.argv[5])
|
|
|
+# info = info+"\r\n子仓库"+sys.argv[5]+"最后提交:\r\n"+str(repo.head.commit.author)+"-"+str(repo.head.commit.message)
|
|
|
+# pub = client.publish(sys.argv[3],info)
|
|
|
+# pub.wait_for_publish()
|
|
|
+# client.disconnect()
|
|
|
+# print("sent")
|
|
|
+# except Exception as e:
|
|
|
+# print(e)
|
|
|
+
|
|
|
+
|
|
|
+###############钉钉提醒######################
|
|
|
+
|
|
|
+dd_appkey = sys.argv[6]
|
|
|
+dd_appsecret = sys.argv[7]
|
|
|
+dd_list = sys.argv[8].split(",")
|
|
|
+dd_api_token = sys.argv[9]
|
|
|
+dd_api_send = sys.argv[10]
|
|
|
try:
|
|
|
- #服务器请自行修改,需要传入参数
|
|
|
- client.connect(sys.argv[1], int(sys.argv[2]), 60)
|
|
|
- #topic请根据需要自行修改,需要传入参数
|
|
|
- info = sys.argv[4]+"\r\n"+str(repo.head.commit.author)+"-"+str(repo.head.commit.message)
|
|
|
- if len(sys.argv) >= 6:
|
|
|
- repo = Repo("../../"+sys.argv[5])
|
|
|
- info = info+"\r\n子仓库"+sys.argv[5]+"最后提交:\r\n"+str(repo.head.commit.author)+"-"+str(repo.head.commit.message)
|
|
|
- pub = client.publish(sys.argv[3],info)
|
|
|
- pub.wait_for_publish()
|
|
|
- client.disconnect()
|
|
|
- print("sent")
|
|
|
+ headers = {'user-agent': '114514'}
|
|
|
+ token = requests.post(dd_api_token,json={"appKey":dd_appkey,"appSecret":dd_appsecret},headers=headers).json()["accessToken"]
|
|
|
+ #发消息
|
|
|
+ headers = {'user-agent': '114514', 'x-acs-dingtalk-access-token': token}
|
|
|
+ r = requests.post(dd_api_send,json={
|
|
|
+ "robotCode":dd_appkey,
|
|
|
+ "userIds":dd_list,
|
|
|
+ "msgKey" : "sampleLink",
|
|
|
+ "msgParam" : json.dumps({
|
|
|
+ "title": sys.argv[5]+"的编译炸了",
|
|
|
+ "text": "最后提交:"+str(repo.head.commit.author)+"\r\n"+str(repo.head.commit.message),
|
|
|
+ "messageUrl": sys.argv[4],
|
|
|
+ "picUrl": "https://www.luatos.com/img/footer-logo.png",
|
|
|
+ })
|
|
|
+ },headers=headers)
|
|
|
+
|
|
|
+ print(r.json())
|
|
|
+
|
|
|
except Exception as e:
|
|
|
print(e)
|
|
|
-
|