import requests
import pprint

# DevOps設定値
DO_ORGANIZATION = '******' # DevOpsのorganization名
DO_TOKEN = '******' # 先ほど生成したToken
DO_PROJECT = '******' # DevOpsのプロジェクト名

response = requests.get(
    f'https://dev.azure.com/{DO_ORGANIZATION}/_apis/projects',
    auth=('', f'{DO_TOKEN}')
)
DO_PROJECT_ID = list(filter(lambda x: x['name'] == DO_PROJECT, response.json()['value']))[0]['id']

pprint.pprint(response.json())
print(f'project id = {DO_PROJECT_ID}')

response = requests.get(
    f'https://dev.azure.com/{DO_ORGANIZATION}/{DO_PROJECT}/_apis/wit/fields?api-version=5.1-preview.2',
    auth=('', f'{DO_TOKEN}')
)
DO_REDMINE_ID_FIELD = list(filter(lambda x: x['name'] == 'Redmine ID', response.json()['value']))[0]['referenceName']

pprint.pprint(response.json())
print(f'Redmine ID field = {DO_REDMINE_ID_FIELD}')

response = requests.get(
    f'https://dev.azure.com/{DO_ORGANIZATION}/{DO_PROJECT}/_apis/git/repositories?api-version=5.1-preview.1',
    auth=('', f'{DO_TOKEN}')
)
DO_REPO_ID = response.json()['value'][0]['id']

pprint.pprint(response.json())
print(f'repository id = {DO_REPO_ID}')

# Redmineの各種設定値
RM_URL = 'http://192.168.1.xxx:10083' # RedmineのURL
RM_TOKEN = '******' # 先ほど生成したRedmine側のToken
RM_PROJECT_NAME = '******' # プロジェクト名

response = requests.get(
    f'{RM_URL}/projects.json',
    params={'key': f'{RM_TOKEN}'}
)

RM_PROJECT_ID = list(filter(lambda x: x['name'] == RM_PROJECT_NAME, response.json()['projects']))[0]['id']

pprint.pprint(response.json())
print(f'redmine project id = {RM_PROJECT_ID}')

response = requests.get(
    f'{RM_URL}/issue_statuses.json',
    params={'key': f'{RM_TOKEN}'})

pprint.pprint(response.json())

{'issue_statuses': [{'id': 1, 'name': '新規'},
                    {'id': 2, 'name': '進行中'},
                    {'id': 3, 'name': '解決'},
                    {'id': 4, 'name': 'フィードバック'},
                    {'id': 5, 'is_closed': True, 'name': '終了'},
                    {'id': 6, 'is_closed': True, 'name': '却下'}]}

STATUS_MAP = {'1': 'New', '2': 'Active', '3': 'Resolved', '4': 'Active', '5': 'Closed', '6': 'Closed'}

# 改行を1行ごとに<div>...</div>に変換する関数の定義
# Redmineは改行コードで取得するのに対して、DevOps側はHTML形式で入れる必要があるため。
def textToHtml(text):
    if text is None:
        return None
    else:
        return ''.join(map(lambda x: '<div>' + x + '</div>', text.split('\r\n')))

# 移行
import json
DO_USERNAME = '******' # DevOpsでWork Itemの担当者として割り当てるユーザ名

# Redmineのissueを取得
response = requests.get(
    f'{RM_URL}/issues.json?project_id={RM_PROJECT_ID}&status_id=*&sort=id&offset=0&limit=999',
    params={'key': f'{RM_TOKEN}'})

# 1件ごとにループ
for issue in response.json()["issues"]:
    print(f'ID:{issue["id"]}, タイトル:{issue["subject"]}')
    # Redmineから詳細(Gitとのリンク情報、注釈)を取得
    response = requests.get(
        f'{RM_URL}/issues/{issue["id"]}.json?include=journals,changesets',
        params={'key': f'{RM_TOKEN}'})
    # 取得した詳細情報
    issueDetail = response.json()['issue']

    # 登録するwork item本体の情報
    workItem = []
    # 作成日時
    workItem.append({"op": "add", "path": "/fields/System.CreatedDate", "value": issue["created_on"]})
    # 更新日時(登録時は更新日時=作成日時とする)
    workItem.append({"op": "add", "path": "/fields/System.ChangedDate", "value": issue["created_on"]})
    # RedmineのIDを入れておく
    workItem.append({"op": "add", "path": f"/fields/{DO_REDMINE_ID_FIELD}", "value": issue["id"]})
    # 担当者は今回は固定値
    workItem.append({"op": "add", "path": "/fields/System.AssignedTo", "value": DO_USERNAME})

    # タイトル
    if issue.get("subject") is not None:
        workItem.append({"op": "add", "path": "/fields/System.Title", "value": issue["subject"]})
    # 説明
    if issue.get("description") is not None:
        workItem.append({"op": "add", "path": "/fields/System.Description", "value": textToHtml(issue["description"])})

    # WorkItemの種類。トラッカーがバグの場合はBug。あとはUser Storyとした。
    itemType = "$Bug" if issue["tracker"]["name"] == "バグ" else "$User%20Story"

    # git commitとのリンク情報
    for change in issueDetail['changesets']:
        if change.get("revision"):
            commitUrl = f'vstfs:///Git/Commit/{DO_PROJECT_ID}%2F{DO_REPO_ID}%2F{change["revision"]}'
            value = {"rel": "ArtifactLink", "url": commitUrl, "attributes": {"name": "Fixed in Commit"}}
            workItem.append({"op": "add", "path": "/relations/-", "value": value})

    # 登録
    response = requests.post(
        f'https://dev.azure.com/{DO_ORGANIZATION}/{DO_PROJECT}/_apis/wit/workitems/{itemType}?bypassRules=true&api-version=5.1-preview.3',
        json.dumps(workItem),
        headers={"Content-Type": "application/json-patch+json"},
        auth=('', f'{DO_TOKEN}'))

    # 登録されたWorkItemのIDを取り出す
    workItemJson = response.json()
    workItemId = workItemJson['id']
    print(f'  DevOps work item id = {workItemId}')

    # Redmine側のjournalに従って状態変更処理を行う
    for journal in issueDetail['journals']:
        # 状態変更履歴はdetailsに入っている
        for detail in journal['details']:
            # 今回は状態の変更のみ処理する
            if detail.get('name') == 'status_id':
                url = f'https://dev.azure.com/{DO_ORGANIZATION}/{DO_PROJECT}/_apis/wit/workitems/{workItemId}?bypassRules=true&api-version=5.1-preview.3'
                patchItem = [{"op": "add", "path": "/fields/System.ChangedDate", "value": journal["created_on"]}]
                patchItem.append({"op": "add", "path": "/fields/System.State", "value": STATUS_MAP[detail["new_value"]]})
                # WorkItemの更新
                response = requests.patch(
                    url,
                    json.dumps(patchItem),
                    headers={"Content-Type": "application/json-patch+json"},
                    auth=('', f'{DO_TOKEN}'))

    # journalに入っている注記をコメントとして登録する
    for journal in issueDetail['journals']:
        if journal.get('notes'):
            url = f'https://dev.azure.com/{DO_ORGANIZATION}/{DO_PROJECT}/_apis/wit/workItems/{workItemId}/comments?api-version=5.1-preview.3'
            response = requests.post(
                url,
                json.dumps({"text": textToHtml(journal['notes'])}),
                headers={"Content-Type": "application/json"},
                auth=('', f'{DO_TOKEN}'))