修复：日志关联不存在

.devops/未命名项目.yml

@@ -0,0 +1,57 @@
+version: 2
+name: 未命名项目
+description: ""
+global:
+  concurrent: 1
+trigger:
+  webhook: gitlink@1.0.0
+  event:
+    - ref: push
+      ruleset-operator: AND
+workflow:
+  - ref: start
+    name: 开始
+    task: start
+  - ref: end
+    name: 结束
+    task: end
+    needs:
+      - ssh_cmd_0
+  - ref: git_clone_0
+    name: git clone
+    task: git_clone@1.2.9
+    input:
+      remote_url: '"https://gitlink.org.cn/young/reposync.git"'
+      ref: '"refs/heads/master"'
+      commit_id: '""'
+      depth: 1
+    needs:
+      - start
+  - ref: docker_image_build_0
+    name: docker镜像构建
+    task: docker_image_build@1.6.0
+    input:
+      docker_username: ((dockerhub.zhanghao))
+      docker_password: ((dockerhub.mima))
+      image_name: '"viletyy/reposyncer"'
+      image_tag: '"latest"'
+      registry_address: '""'
+      docker_file: git_clone_0.git_path+"/Dockerfile"
+      docker_build_path: git_clone_0.git_path
+      workspace: git_clone_0.git_path
+      image_push: true
+      build_args: '""'
+    needs:
+      - git_clone_0
+  - ref: ssh_cmd_0
+    name: ssh执行命令
+    task: ssh_cmd@1.1.1
+    input:
+      ssh_private_key: ((sshkey.hehui))
+      ssh_ip: '"123.59.135.93"'
+      ssh_port: '"30122"'
+      ssh_user: '"root"'
+      ssh_cmd: '"ssh -p 30122 root@10.9.151.72 sh update_reposync.sh"'
+    needs:
+      - docker_image_build_0
+

.devops/测试.yml

@@ -0,0 +1,27 @@
+version: 2
+name: 测试
+description: ""
+global:
+  concurrent: 1
+workflow:
+  - ref: start
+    name: 开始
+    task: start
+  - ref: end
+    name: 结束
+    task: end
+    needs:
+      - ssh_cmd_0
+  - ref: ssh_cmd_0
+    name: ssh执行命令
+    on-failure: ignore
+    task: ssh_cmd@1.1.1
+    input:
+      ssh_private_key: ((sshkey.hehui))
+      ssh_ip: '"123.59.135.93"'
+      ssh_port: '"30122"'
+      ssh_user: '"root"'
+      ssh_cmd: '"ssh -p 30122 root@10.9.151.72 sh update_reposync.sh"'
+    needs:
+      - start
+

README.md

@@ -4,6 +4,8 @@
 
 ob-repository-synchronize is a small tool which can help engineer to master their open source production's code synchronization between GitHub, Gitee, CodeChina, internal repository and so on.
 
+add text...test...ok
+
 ## Principle
 
 ### Base on git rebase

src/dao/sync_config.py

@@ -302,13 +302,20 @@ class LogDAO(BaseDAO, metaclass=Singleton):
                 do_list: List[LogDO] = (await session.execute(query)).scalars().all()
                 datas = []
                 for do in do_list:
+                    stmt_query = select(SyncRepoMapping).where(SyncRepoMapping.repo_name == do.repo_name).limit(1)
+                    stmt = (await session.execute(stmt_query)).scalars().all()
+                    log_str = do.log 
+                    if len(stmt) > 0 and stmt[0].exter_token:
+                        log_str = log_str.replace(stmt[0].exter_token, "******")
+                    if len(stmt) > 0 and stmt[0].inter_token:
+                        log_str = log_str.replace(stmt[0].inter_token, "******")
                     data = LogDTO(
                         id=do.id,
                         branch_id=do.branch_id,
                         repo_name=do.repo_name,
                         commit_id=do.commit_id,
                         sync_direct=do.sync_direct.name,
-                        log=str(do.log),
+                        log=str(log_str),
                         created_at=str(do.created_at),
                         update_at=str(do.update_at)
                     )

src/service/cronjob.py

@@ -96,10 +96,7 @@ def inter_to_outer(repo, branch, log_name: str, user: str, force_flag):
         # 切换到inter_name分支，并将internal仓库的分支强制 checkout 到当前分支。
         shell(f"git checkout -B {inter_name} internal/{inter_name}", repo_dir, log_name, user)
         # 将本地仓库的inter_name分支推送到external仓库的outer_name分支上。
-        if force_flag:
+        shell(f"git push -f external {inter_name}:{outer_name}", repo_dir, log_name, user)
-            shell(f"git push --force external {inter_name}:{outer_name}", repo_dir, log_name, user)
-        else:
-            shell(f"git push external {inter_name}:{outer_name}", repo_dir, log_name, user)
         # commit id
         # result = shell(f"git log HEAD~1..HEAD --oneline", repo_dir, log_name, user)
         # commit_id = result.stdout.split(" ")[0]
@@ -121,10 +118,7 @@ def outer_to_inter(repo, branch, log_name: str, user: str, force_flag):
         # 切换到本地仓库的outer_name分支，并将origin仓库的outer_name分支强制 checkout 到当前分支。
         shell(f"git checkout -B {outer_name} external/{outer_name}", repo_dir, log_name, user)
         # 将本地仓库的outer_name分支推送到internal仓库的inter_name分支上。
-        if force_flag:
+        shell(f"git push -f internal {outer_name}:{inter_name}", repo_dir, log_name, user)
-            shell(f"git push --force internal {outer_name}:{inter_name}", repo_dir, log_name, user)
-        else:
-            shell(f"git push internal {outer_name}:{inter_name}", repo_dir, log_name, user)
         # commit id
         # result = shell(f"git log HEAD~1..HEAD --oneline", repo_dir, log_name, user)
         # commit_id = result.stdout.split(" ")[0]