forked from Lesin/reposync
179 lines
6.8 KiB
Python
179 lines
6.8 KiB
Python
import urllib
|
||
import requests
|
||
import mysql.connector
|
||
import json
|
||
|
||
def main():
|
||
########获取gitee里的issue并且放到数据库中#######################
|
||
# 连接到MySQL数据库
|
||
conn = mysql.connector.connect(
|
||
host="localhost",
|
||
user="root",
|
||
password="185102xmy",
|
||
database="db1"
|
||
)
|
||
cursor = conn.cursor()
|
||
|
||
cursor.execute('DROP TABLE IF EXISTS github_issue_list')
|
||
# 创建一个表
|
||
cursor.execute('''CREATE TABLE IF NOT EXISTS github_issue_list
|
||
(id INT AUTO_INCREMENT PRIMARY KEY, number VARCHAR(10), title VARCHAR(100), body VARCHAR(1000), state VARCHAR(15))''')
|
||
|
||
url = f"https://api.github.com/repos/fuxingtamu/yundingzhiyi/issues"
|
||
# 构造请求头
|
||
token = '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'
|
||
# 构造请求头
|
||
headers = {
|
||
'Authorization': f'token {token}',
|
||
'Accept': 'application/vnd.github+json'
|
||
}
|
||
|
||
# 发送POST请求
|
||
data = {
|
||
|
||
}
|
||
response = requests.get(url, headers=headers, json=data, verify=False)
|
||
issue_info = response.json()
|
||
for issue in issue_info:
|
||
print('title:', issue['title'])
|
||
print('body:', issue['body'])
|
||
print('number', issue['number'])
|
||
print('id', issue['id'])
|
||
cursor.execute(
|
||
'INSERT INTO github_issue_list (number, title, body, state) VALUES (%s, %s, %s, %s)',
|
||
(issue['number'], issue['title'], issue['body'], issue['state']))
|
||
|
||
########获取gitlink里的issue并且放到数据库中#######################
|
||
# 连接到MySQL数据库
|
||
cursor.execute('DROP TABLE IF EXISTS gitlink_issue_list')
|
||
# 创建一个表
|
||
cursor.execute('''CREATE TABLE IF NOT EXISTS gitlink_issue_list
|
||
(id INT AUTO_INCREMENT PRIMARY KEY, number VARCHAR(10), subject VARCHAR(100), description VARCHAR(1000), status_name VARCHAR(15), priority_name VARCHAR(15))''')
|
||
|
||
url = "https://gitlink.org.cn/api/v1/xumingyang21/reposyncer2/issues.json?category&participant_category&keyword&author_id&milestone_id&assigner_id&status_id&sort_by&sort_direction&issue_tag_ids&page&limit&debug=admin"
|
||
|
||
payload = {}
|
||
headers = {
|
||
'Authorization': 'zo07-W-W6vnU1mvQhVhIdfyyVY3K1R1piil_jfvS1bg',
|
||
'User-Agent': 'Apifox/1.0.0 (https://apifox.com)'
|
||
}
|
||
|
||
response = requests.request("GET", url, headers=headers, data=payload)
|
||
data = response.json()
|
||
# print(data)
|
||
print(data['issues'])
|
||
for issue in data['issues']:
|
||
url = f"https://gitlink.org.cn/api/v1/xumingyang21/reposyncer2/issues/{issue['id']}.json"
|
||
|
||
payload = {}
|
||
|
||
access_token = 'zo07-W-W6vnU1mvQhVhIdfyyVY3K1R1piil_jfvS1bg'
|
||
headers = {
|
||
'Authorization': f'Bearer {access_token}',
|
||
'User-Agent': 'Apifox/1.0.0 (https://apifox.com)'
|
||
}
|
||
|
||
response1 = requests.request("GET", url, headers=headers, data=payload)
|
||
data1 = response1.json()
|
||
# print(response.text)
|
||
# print(data)
|
||
print(issue['id'])
|
||
print(issue['subject'])
|
||
print(data1['description'])
|
||
print(issue['status_name'])
|
||
|
||
cursor.execute(
|
||
'INSERT INTO gitlink_issue_list (number, subject, description, status_name, priority_name) VALUES (%s, %s, %s, %s, %s)',
|
||
(issue['id'], issue['subject'], data1['description'], issue['status_name'], issue['priority_name']))
|
||
# # 执行查询
|
||
# cursor.execute('SELECT number FROM gitlink_issue_list')
|
||
# # 获取所有结果
|
||
# results = cursor.fetchall()
|
||
# # 提取列数据到列表中
|
||
# column_data = [row[0] for row in results]
|
||
|
||
##################将gitee仓库中的issue状态更新为关闭closed###########################
|
||
cursor.execute('SELECT number FROM github_issue_list')
|
||
gitee_results = cursor.fetchall()
|
||
for row in gitee_results:
|
||
issue_number = row[0]
|
||
|
||
url = f"https://api.github.com/repos/fuxingtamu/yundingzhiyi/issues/{issue_number}"
|
||
# 构造请求头
|
||
token = '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'
|
||
# 构造请求头
|
||
headers = {
|
||
'Authorization': f'token {token}',
|
||
'Accept': 'application/vnd.github+json'
|
||
}
|
||
# 发送POST请求
|
||
data = {
|
||
'owner': 'fuxingtamu',
|
||
'repo': 'yundingzhiyi',
|
||
'issue_number': issue_number,
|
||
'state': 'closed'
|
||
}
|
||
response = requests.patch(url, headers=headers, json=data, verify=False)
|
||
# 打印响应
|
||
print(response.text)
|
||
# 检查响应状态码
|
||
if response.status_code == 201:
|
||
# 注意：这里假设响应体中包含一个'number'字段作为issue的ID，但实际上GitHub可能返回不同的结构
|
||
# 你需要根据实际的响应结构来调整以下代码
|
||
issue_info = response.json()
|
||
print(f'Issue created with ID: {issue_info["number"]}')
|
||
else:
|
||
print(f"创建issue失败，状态码：{response.status_code}，错误信息：{response.text}")
|
||
|
||
##################将gitlink中的issue创建到github中###########################
|
||
|
||
cursor.execute('DROP TABLE IF EXISTS github_issue_list')
|
||
cursor.execute('''CREATE TABLE IF NOT EXISTS github_issue_list
|
||
(id INT AUTO_INCREMENT PRIMARY KEY, number VARCHAR(10), title VARCHAR(100), body VARCHAR(1000), state VARCHAR(15))''')
|
||
|
||
cursor.execute('SELECT subject, description, status_name, priority_name FROM gitlink_issue_list')
|
||
|
||
gitlink_result = cursor.fetchall()
|
||
|
||
for row in gitlink_result:
|
||
|
||
# GitHub创建issue的API URL
|
||
url = f"https://api.github.com/repos/fuxingtamu/yundingzhiyi/issues"
|
||
|
||
# 构造请求头
|
||
token = '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'
|
||
# 构造请求头
|
||
headers = {
|
||
'Authorization': f'token {token}',
|
||
'Accept': 'application/vnd.github+json'
|
||
}
|
||
|
||
# 发送POST请求
|
||
data = {
|
||
"title": row[0],
|
||
"body": row[1]
|
||
}
|
||
|
||
response = requests.post(url, headers=headers, json=data, verify=False)
|
||
# 打印响应
|
||
print(response.text)
|
||
# 检查响应状态码
|
||
if response.status_code == 201:
|
||
# 注意：这里假设响应体中包含一个'number'字段作为issue的ID，但实际上GitHub可能返回不同的结构
|
||
# 你需要根据实际的响应结构来调整以下代码
|
||
issue_info = response.json()
|
||
print(f'Issue created with ID: {issue_info["number"]}')
|
||
else:
|
||
print(f"创建issue失败，状态码：{response.status_code}，错误信息：{response.text}")
|
||
# 提交事务
|
||
|
||
###########################更改已经创建好的issue的状态和优先级###############################
|
||
|
||
conn.commit()
|
||
# 关闭游标和连接
|
||
cursor.close()
|
||
conn.close()
|
||
|
||
if __name__ == '__main__':
|
||
main()
|