add

wangpengfei

2023-07-18 5fac03fb857cf9a160e1736a25de2c5f95f5e44f

 service/container_docker.go

@@ -2,7 +2,6 @@

import (
   "aps_crm/conf"
   "aps_crm/model"
   "aps_crm/pkg/logx"
   "aps_crm/utils"
   "context"
@@ -232,18 +231,18 @@
}

func (slf *DockerImpl) initContainerNotFound() {
   users, _ := model.NewUserSearch(nil).FindNotTotal()
   for _, u := range users {
      if u.ParentId == "" { //是主账号
         //判断容器是否存在时是否需要加锁？用户注册主账号时是异步请求，创建docker容器没有冲突，因为容器的id不同。
         //拉起容器和用户主动启动容器也没有时间冲突
         _, e := slf.Exist(u.ID)
         if e != ContainerNotFound {
            continue
         }
         if err := slf.Init(u.ID); err != nil {
            logx.Errorf("init ContainerNotFound err:", err)
         }
      }
   }
   //users, _ := model.NewUserSearch(nil).FindNotTotal()
   //for _, u := range users {
   //   if u.ParentId == "" { //是主账号
   //      //判断容器是否存在时是否需要加锁？用户注册主账号时是异步请求，创建docker容器没有冲突，因为容器的id不同。
   //      //拉起容器和用户主动启动容器也没有时间冲突
   //      _, e := slf.Exist(u.ID)
   //      if e != ContainerNotFound {
   //         continue
   //      }
   //      if err := slf.Init(u.ID); err != nil {
   //         logx.Errorf("init ContainerNotFound err:", err)
   //      }
   //   }
   //}
}