公海member_id使用0

zhangqian

2023-11-01 530fed8ec225453572d57b15c200ab062c335457

 service/container_docker.go

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

import (
   "aps_crm/conf"
   "aps_crm/model"
   "aps_crm/pkg/logx"
   "aps_crm/utils"
   "context"
@@ -56,7 +55,7 @@
   Name  string `json:"Name"`
   Image string `json:"Image"`
   State struct {
      Status  string `json:"Status"`
      Status  string `json:"SalesReturnStatus"`
      Running bool   `json:"Running"`
   } `json:"State"`
}
@@ -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.UUID)
   //      if e != ContainerNotFound {
   //         continue
   //      }
   //      if err := slf.Init(u.UUID); err != nil {
   //         logx.Errorf("init ContainerNotFound err:", err)
   //      }
   //   }
   //}
}