mirror of
https://gitee.com/openLuat/LuatOS
synced 2025-08-17 22:18:03 +08:00
62 lines
2.1 KiB
Python
62 lines
2.1 KiB
Python
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
|
||
|
||
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:
|
||
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)
|