reposync/milestone_sync/milestone_gitlink_to_gitee.py

144 lines
5.2 KiB
Python
Raw Permalink Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

import urllib
import requests
import mysql.connector
import json
def main():
conn = mysql.connector.connect(
host="localhost",
user="root",
password="185102xmy",
database="db1"
)
cursor = conn.cursor()
cursor.execute('DROP TABLE IF EXISTS gitlink_milestone_list')
# 创建一个表
cursor.execute('''CREATE TABLE IF NOT EXISTS gitlink_milestone_list
(id INT AUTO_INCREMENT PRIMARY KEY, milestone_index VARCHAR(100), name VARCHAR(100), description VARCHAR(100), due_on VARCHAR(100))''')
#获取gitlink中的所有milestone
url = "https://gitlink.org.cn/api/v1/xumingyang21/reposyncer2/milestones.json"
payload = {}
access_token = 'zo07-W-W6vnU1mvQhVhIdfyyVY3K1R1piil_jfvS1bg'
headers = {
'Authorization': f'Bearer {access_token}', # 使用 Bearer 标记
'User-Agent': 'Apifox/1.0.0 (https://apifox.com)',
'Content-Type': 'application/json'
}
response = requests.request("GET", url, headers=headers, data=payload)
print(response.text)
gitlink_milestone = response.json()['milestones']
for gitlink_single_milestone in gitlink_milestone:
cursor.execute(
'INSERT INTO gitlink_milestone_list (milestone_index, name, description, due_on) VALUES (%s, %s, %s, %s)',
(gitlink_single_milestone['id'], gitlink_single_milestone['name'], gitlink_single_milestone['description'],
gitlink_single_milestone['effective_date']))
#删除掉gitee的milestone
owner = 'xumingyang21'
repo = 'reposyncer2'
# Gitee获取issue的API URL
url = f"https://gitee.com/api/v5/repos/{owner}/{repo}/milestones"
# 构造请求头
token = 'f2be2313581c1fde50b16bf35bb655c5'
headers = {'Authorization': f'token {token}'}
# 发送POST请求 获取状态为open的issue
data = {
"access_token": token,
"owner": owner,
"repo": repo,
# "state":'all',
}
# 将字典转换为查询字符串
query_string = urllib.parse.urlencode(data)
# 完整的请求 URL包括查询字符串
full_url1 = f"{url}?{query_string}"
response = requests.get(full_url1, headers=headers, json=data)
# 打印响应
# print(response.text)
# 检查响应状态码
if response.status_code == 200:
# 注意:这里假设响应体中包含一个'number'字段作为issue的ID但实际上Gitee可能返回不同的结构
# 你需要根据实际的响应结构来调整以下代码
milestone_info = response.json()
print(milestone_info)
else:
print(f"创建issue失败12状态码{response.status_code},错误信息:{response.text}")
for single_milestone in milestone_info:
#删除gitee上面的milestone
token = 'f2be2313581c1fde50b16bf35bb655c5' # 假设这是您的有效token
# 你的仓库信息
owner = 'xumingyang21'
repo = 'reposyncer2'
number = '206035'
# Gitee删除issue的API URL
url = f'https://gitee.com/api/v5/repos/{owner}/{repo}/milestones/{single_milestone["number"]}'
# 构造请求头
headers = {'Authorization': f'token {token}'}
data = {
"access_token": token,
"owner": owner,
"repo": repo,
"number": number
}
# 将字典转换为查询字符串
query_string = urllib.parse.urlencode(data)
# 完整的请求 URL包括查询字符串
full_url1 = f"{url}?{query_string}"
response = requests.delete(full_url1, headers=headers, json=data)
# 打印响应
print(response.text)
# 检查响应状态码
if response.status_code == 204:
print('milestone已成功删除。')
else:
print(f"删除issue失败状态码{response.status_code},错误信息:{response.text}")
#创建新的giteemilestone
cursor.execute('SELECT name, description, due_on FROM gitlink_milestone_list')
milestone_result = cursor.fetchall()
for row in milestone_result:
url = f"https://gitee.com/api/v5/repos/{owner}/{repo}/milestones"
# 构造请求头
token = 'f2be2313581c1fde50b16bf35bb655c5'
headers = {'Authorization': f'token {token}'}
# 发送POST请求
data = {
"access_token": token,
"owner": owner,
"repo": repo,
"title": row[0],
"description": row[1],
"due_on": row[2]
}
response = requests.post(url, headers=headers, json=data)
# 打印响应
print(response.text)
# 检查响应状态码
if response.status_code == 201:
# 注意:这里假设响应体中包含一个'number'字段作为issue的ID但实际上Gitee可能返回不同的结构
# 你需要根据实际的响应结构来调整以下代码
issue_info = response.json()
else:
print(f"创建milestone失败状态码{response.status_code},错误信息:{response.text}")
# 提交事务
conn.commit()
# 关闭游标和连接
cursor.close()
conn.close()
if __name__ == '__main__':
main()