feat: batch add dependency

api/api/api_interface.go

@@ -114,6 +114,8 @@ type ServiceInterface interface {
 	CreateService(w http.ResponseWriter, r *http.Request)
 	UpdateService(w http.ResponseWriter, r *http.Request)
 	Dependency(w http.ResponseWriter, r *http.Request)
+	Dependencys(w http.ResponseWriter, r *http.Request)
+
 	Env(w http.ResponseWriter, r *http.Request)
 	Ports(w http.ResponseWriter, r *http.Request)
 	PutPorts(w http.ResponseWriter, r *http.Request)

api/api_routers/version2/v2Routers.go

@@ -306,6 +306,8 @@ func (v2 *V2) serviceRouter() chi.Router {
 
 	//应用依赖关系增加与删除(source)
 	r.Post("/dependency", middleware.WrapEL(controller.GetManager().Dependency, dbmodel.TargetTypeService, "add-service-dependency", dbmodel.SYNEVENTTYPE))
+	r.Post("/dependencys", middleware.WrapEL(controller.GetManager().Dependencys, dbmodel.TargetTypeService, "add-service-dependency", dbmodel.SYNEVENTTYPE))
+
 	r.Delete("/dependency", middleware.WrapEL(controller.GetManager().Dependency, dbmodel.TargetTypeService, "delete-service-dependency", dbmodel.SYNEVENTTYPE))
 	//环境变量增删改(source)
 	r.Post("/env", middleware.WrapEL(controller.GetManager().Env, dbmodel.TargetTypeService, "add-service-env", dbmodel.SYNEVENTTYPE))

api/controller/resources.go

@@ -1048,6 +1048,14 @@ func (t *TenantStruct) Dependency(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
+// Dependencys Dependencys batch add dependency
+func (t *TenantStruct) Dependencys(w http.ResponseWriter, r *http.Request) {
+	switch r.Method {
+	case "POST":
+		t.AddDependencys(w, r)
+	}
+}
+
 // AddDependency AddDependency
 // swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/dependency v2 addDependency
 //
@@ -1093,6 +1101,55 @@ func (t *TenantStruct) AddDependency(w http.ResponseWriter, r *http.Request) {
 	httputil.ReturnSuccess(r, w, nil)
 }
 
+// AddDependencys AddDependencys
+// swagger:operation POST /v2/tenants/{tenant_name}/services/{service_alias}/dependencys v2 addDependencys
+//
+// 批量增加应用依赖关系
+//
+// add dependency
+//
+// ---
+// consumes:
+// - application/json
+// - application/x-protobuf
+//
+// produces:
+// - application/json
+// - application/xml
+//
+// responses:
+//
+//	default:
+//	  schema:
+//	    "$ref": "#/responses/commandResponse"
+//	  description: 统一返回格式
+
+func (t *TenantStruct) AddDependencys(w http.ResponseWriter, r *http.Request) {
+	rules := validator.MapData{
+		"dep_service_ids":  []string{"required"},
+		"dep_service_type": []string{"required"},
+		"dep_order":        []string{},
+	}
+	data, ok := httputil.ValidatorRequestMapAndErrorResponse(r, w, rules, nil)
+	if !ok {
+		return
+	}
+	depServiceIds := data["dep_service_id"].(string)
+	for _, depServiceId := range strings.Split(",", depServiceIds) {
+		ds := &api_model.DependService{
+			TenantID:       r.Context().Value(ctxutil.ContextKey("tenant_id")).(string),
+			ServiceID:      r.Context().Value(ctxutil.ContextKey("service_id")).(string),
+			DepServiceID:   depServiceId,
+			DepServiceType: data["dep_service_type"].(string),
+		}
+		if err := handler.GetServiceManager().ServiceDepend("add", ds); err != nil {
+			httputil.ReturnError(r, w, 500, fmt.Sprintf("add dependency error, %v", err))
+			return
+		}
+	}
+	httputil.ReturnSuccess(r, w, nil)
+}
+
 // DeleteDependency DeleteDependency
 // swagger:operation DELETE /v2/tenants/{tenant_name}/services/{service_alias}/dependency v2 deleteDependency
 //