From 5d504b5ec7895d41232730ad3a4f6fcca18c612e Mon Sep 17 00:00:00 2001 From: TsMask <340112800@qq.com> Date: Thu, 4 Jul 2024 20:38:14 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E7=BD=91=E5=85=83=E5=8F=82=E6=95=B0?= =?UTF-8?q?=E9=85=8D=E7=BD=AE=E5=BA=94=E7=94=A8=E7=94=B3=E8=AF=B7=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/pt_ne_config_apply.go | 145 +++++++++++ .../controller/pt_ne_config_data.go | 18 +- .../controller/pt_ne_config_data_log.go | 2 +- .../model/pt_ne_config_apply.go | 18 ++ .../practical_training/practical_training.go | 38 ++- .../repository/pt_ne_config_apply.go | 24 ++ .../repository/pt_ne_config_apply.impl.go | 241 ++++++++++++++++++ .../service/pt_ne_config_apply.go | 26 ++ .../service/pt_ne_config_apply.impl.go | 67 +++++ 9 files changed, 559 insertions(+), 20 deletions(-) create mode 100644 src/modules/practical_training/controller/pt_ne_config_apply.go create mode 100644 src/modules/practical_training/model/pt_ne_config_apply.go create mode 100644 src/modules/practical_training/repository/pt_ne_config_apply.go create mode 100644 src/modules/practical_training/repository/pt_ne_config_apply.impl.go create mode 100644 src/modules/practical_training/service/pt_ne_config_apply.go create mode 100644 src/modules/practical_training/service/pt_ne_config_apply.impl.go diff --git a/src/modules/practical_training/controller/pt_ne_config_apply.go b/src/modules/practical_training/controller/pt_ne_config_apply.go new file mode 100644 index 00000000..6a53b900 --- /dev/null +++ b/src/modules/practical_training/controller/pt_ne_config_apply.go @@ -0,0 +1,145 @@ +package controller + +import ( + "be.ems/src/framework/i18n" + "be.ems/src/framework/utils/ctx" + "be.ems/src/framework/vo/result" + "be.ems/src/modules/practical_training/model" + "be.ems/src/modules/practical_training/service" + "github.com/gin-gonic/gin" + "github.com/gin-gonic/gin/binding" +) + +// NewPtNeConfigApply 实例化控制层 +var NewPtNeConfigApply = &PtNeConfigApplyController{ + ptNeConfigApplyService: service.NewPtNeConfigApplyService, + ptNeConfigDataService: service.NewPtNeConfigDataService, +} + +// 网元参数配置应用申请 +// +// PATH /neConfigApply +type PtNeConfigApplyController struct { + // 实训教学_网元参数配置应用申请服务 + ptNeConfigApplyService service.IPtNeConfigApplyService + // 实训教学_网元参数配置服务 + ptNeConfigDataService service.IPtNeConfigDataService +} + +// 网元参数配置应用申请信息 +// +// GET / +func (s *PtNeConfigApplyController) Info(c *gin.Context) { + language := ctx.AcceptLanguage(c) + id, idOk := c.GetQuery("id") + if !idOk { + c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400"))) + return + } + + data := s.ptNeConfigApplyService.SelectById(id) + + c.JSON(200, result.OkData(data)) +} + +// 网元参数配置应用申请提交(仅学生操作) +// +// POST / +func (s *PtNeConfigApplyController) Add(c *gin.Context) { + language := ctx.AcceptLanguage(c) + var body struct { + NeType string `json:"neType" binding:"required"` // 网元类型 + Status string `json:"status" binding:"required,oneof=0 1"` // 状态 0申请 1撤回 + } + if err := c.ShouldBindBodyWith(&body, binding.JSON); err != nil { + c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400"))) + return + } + + currentUserName := ctx.LoginUserToUserName(c) + applyInfos := s.ptNeConfigApplyService.SelectList(model.PtNeConfigApply{ + CreateBy: currentUserName, + Status: "0", + NeType: body.NeType, + }) + + // 申请 + if body.Status == "0" { + // 申请中 + if len(applyInfos) > 0 { + c.JSON(200, result.OkMsg("Application In Progress")) + return + } + s.ptNeConfigApplyService.Insert(model.PtNeConfigApply{ + CreateBy: currentUserName, + Status: "0", + NeType: body.NeType, + }) + c.JSON(200, result.OkMsg("Application Submission Complete!")) + return + } + + // 撤回 + if body.Status == "1" { + // 没申请 + if len(applyInfos) == 0 { + c.JSON(200, result.OkMsg("No Revocable Applications")) + return + } + for _, v := range applyInfos { + v.UpdateBy = currentUserName + v.Status = "1" + s.ptNeConfigApplyService.Update(v) + } + c.JSON(200, result.OkMsg("Application Revocable Complete!")) + return + } +} + +// 网元参数配置应用申请状态变更(仅管理员/教师操作) +// +// PUT / +func (s *PtNeConfigApplyController) Edit(c *gin.Context) { + language := ctx.AcceptLanguage(c) + var body struct { + ApplyId string `json:"applyId" binding:"required"` // 申请ID + NeType string `json:"neType" binding:"required"` // 网元类型 + Status string `json:"status" binding:"required,oneof=2 3"` // 状态 2应用 3退回 + BackInfo string `json:"backInfo"` // 退回信息 + } + if err := c.ShouldBindBodyWith(&body, binding.JSON); err != nil { + c.JSON(400, result.CodeMsg(400, i18n.TKey(language, "app.common.err400"))) + return + } + + currentUserName := ctx.LoginUserToUserName(c) + applyInfos := s.ptNeConfigApplyService.SelectById(body.ApplyId) + if applyInfos.ID != body.ApplyId || applyInfos.Status != "0" { + c.JSON(200, result.ErrMsg("Application Information Is Incorrect!")) + return + } + + // 退回 + if body.Status == "3" { + applyInfos.UpdateBy = currentUserName + applyInfos.Status = "3" + applyInfos.BackInfo = body.BackInfo + s.ptNeConfigApplyService.Update(applyInfos) + c.JSON(200, result.OkMsg("Application Return Complete!")) + return + } + + // 应用 + if body.Status == "2" { + if err := s.ptNeConfigDataService.ApplyToNe(applyInfos.CreateBy, applyInfos.NeType); err != nil { + c.JSON(200, result.ErrMsg("Application Failed! "+err.Error())) + return + } + applyInfos.UpdateBy = currentUserName + applyInfos.Status = "1" + applyInfos.BackInfo = "" + s.ptNeConfigApplyService.Update(applyInfos) + c.JSON(200, result.OkMsg("Application Appliance Complete!")) + return + } +} diff --git a/src/modules/practical_training/controller/pt_ne_config_data.go b/src/modules/practical_training/controller/pt_ne_config_data.go index f51d78cd..30a07084 100644 --- a/src/modules/practical_training/controller/pt_ne_config_data.go +++ b/src/modules/practical_training/controller/pt_ne_config_data.go @@ -14,8 +14,8 @@ import ( "github.com/gin-gonic/gin/binding" ) -// NewPtNeConfigData 网元参数配置服务 实例化控制层 -var NewPtNeConfigData = &PtNeConfigData{ +// NewPtNeConfigData 实例化控制层 +var NewPtNeConfigData = &PtNeConfigDataController{ ptNeConfigDataService: service.NewPtNeConfigDataService, ptNeConfigDataLogService: service.NewPtNeConfigDataLogService, neInfoService: neService.NewNeInfoImpl, @@ -24,7 +24,7 @@ var NewPtNeConfigData = &PtNeConfigData{ // 网元参数配置服务 // // PATH /neConfigData -type PtNeConfigData struct { +type PtNeConfigDataController struct { // 实训教学_网元参数配置服务 ptNeConfigDataService service.IPtNeConfigDataService // 实训教学_网元参数配置数据变更日志服务 @@ -36,7 +36,7 @@ type PtNeConfigData struct { // 保存为示例配置 (仅管理员/教师操作) // // POST /saveAsDefault -func (s *PtNeConfigData) SaveAsDefault(c *gin.Context) { +func (s *PtNeConfigDataController) SaveAsDefault(c *gin.Context) { language := ctx.AcceptLanguage(c) var body struct { NeType string `json:"neType" binding:"required"` // 网元类型 @@ -72,7 +72,7 @@ func (s *PtNeConfigData) SaveAsDefault(c *gin.Context) { // 重置为示例配置 (仅学生/教师操作) // // POST /resetAsDefault -func (s *PtNeConfigData) ResetAsDefault(c *gin.Context) { +func (s *PtNeConfigDataController) ResetAsDefault(c *gin.Context) { language := ctx.AcceptLanguage(c) var body struct { NeType string `json:"neType" binding:"required"` // 网元类型 @@ -101,7 +101,7 @@ func (s *PtNeConfigData) ResetAsDefault(c *gin.Context) { // 网元参数配置信息 // // GET / -func (s *PtNeConfigData) Info(c *gin.Context) { +func (s *PtNeConfigDataController) Info(c *gin.Context) { language := ctx.AcceptLanguage(c) var querys struct { NeType string `form:"neType" binding:"required"` @@ -133,7 +133,7 @@ func (s *PtNeConfigData) Info(c *gin.Context) { // 网元参数配置修改 // // PUT / -func (s *PtNeConfigData) Edit(c *gin.Context) { +func (s *PtNeConfigDataController) Edit(c *gin.Context) { language := ctx.AcceptLanguage(c) var body model.PtNeConfigData if err := c.ShouldBindBodyWith(&body, binding.JSON); err != nil { @@ -228,7 +228,7 @@ func (s *PtNeConfigData) Edit(c *gin.Context) { // 网元参数配置新增（array） // // POST / -func (s *PtNeConfigData) Add(c *gin.Context) { +func (s *PtNeConfigDataController) Add(c *gin.Context) { language := ctx.AcceptLanguage(c) var body model.PtNeConfigData if err := c.ShouldBindBodyWith(&body, binding.JSON); err != nil { @@ -316,7 +316,7 @@ func (s *PtNeConfigData) Add(c *gin.Context) { // 网元参数配置删除（array） // // DELETE / -func (s *PtNeConfigData) Remove(c *gin.Context) { +func (s *PtNeConfigDataController) Remove(c *gin.Context) { language := ctx.AcceptLanguage(c) var query struct { Index int64 `form:"index" binding:"required"` //定位变更数据项 diff --git a/src/modules/practical_training/controller/pt_ne_config_data_log.go b/src/modules/practical_training/controller/pt_ne_config_data_log.go index 85ecedd8..253023d6 100644 --- a/src/modules/practical_training/controller/pt_ne_config_data_log.go +++ b/src/modules/practical_training/controller/pt_ne_config_data_log.go @@ -11,7 +11,7 @@ import ( "github.com/gin-gonic/gin" ) -// NewPtNeConfigDataLog 实例化控制层 PtNeConfigDataLog +// NewPtNeConfigDataLog 实例化控制层 var NewPtNeConfigDataLog = &PtNeConfigDataLog{ ptNeConfigDataLogService: service.NewPtNeConfigDataLogService, } diff --git a/src/modules/practical_training/model/pt_ne_config_apply.go b/src/modules/practical_training/model/pt_ne_config_apply.go new file mode 100644 index 00000000..4c9ee885 --- /dev/null +++ b/src/modules/practical_training/model/pt_ne_config_apply.go @@ -0,0 +1,18 @@ +package model + +// PtNeConfigApply 实训教学_网元参数配置应用下发申请 +type PtNeConfigApply struct { + ID string `json:"id" gorm:"column:id;primaryKey;autoIncrement"` // ID + CreateBy string `json:"createBy" gorm:"create_by"` // 创建者 + CreateTime int64 `json:"createTime" gorm:"create_time"` // 创建时间 + UpdateBy string `json:"updateBy" gorm:"update_by"` // 更新者 + UpdateTime int64 `json:"updateTime" gorm:"update_time"` // 更新时间 + NeType string `json:"neType" gorm:"ne_type"` // 网元类型 + Status string `json:"status" gorm:"status"` // 应用状态 0申请 1撤回 2应用 3退回 + BackInfo string `json:"backInfo" gorm:"back_info"` // 退回信息 +} + +// TableName 表名称 +func (*PtNeConfigApply) TableName() string { + return "pt_ne_config_apply" +} diff --git a/src/modules/practical_training/practical_training.go b/src/modules/practical_training/practical_training.go index 30ca6779..2d7c4f28 100644 --- a/src/modules/practical_training/practical_training.go +++ b/src/modules/practical_training/practical_training.go @@ -16,33 +16,33 @@ func Setup(router *gin.Engine) { ptGroup := router.Group("/pt") // 网元参数配置 - paramConfigGroup := ptGroup.Group("/neConfigData") + neConfigDataGroup := ptGroup.Group("/neConfigData") { - paramConfigGroup.POST("/saveAsDefault", + neConfigDataGroup.POST("/saveAsDefault", middleware.PreAuthorize(map[string][]string{"hasRoles": {"admin", "teacher"}}), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigData", collectlogs.BUSINESS_TYPE_OTHER)), controller.NewPtNeConfigData.SaveAsDefault, ) - paramConfigGroup.POST("/resetAsDefault", + neConfigDataGroup.POST("/resetAsDefault", middleware.PreAuthorize(map[string][]string{"hasRoles": {"student", "teacher"}}), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigData", collectlogs.BUSINESS_TYPE_OTHER)), controller.NewPtNeConfigData.ResetAsDefault, ) - paramConfigGroup.GET("", + neConfigDataGroup.GET("", middleware.PreAuthorize(nil), controller.NewPtNeConfigData.Info, ) - paramConfigGroup.POST("", + neConfigDataGroup.POST("", middleware.PreAuthorize(nil), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigData", collectlogs.BUSINESS_TYPE_INSERT)), controller.NewPtNeConfigData.Add, ) - paramConfigGroup.PUT("", + neConfigDataGroup.PUT("", middleware.PreAuthorize(nil), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigData", collectlogs.BUSINESS_TYPE_UPDATE)), controller.NewPtNeConfigData.Edit, ) - paramConfigGroup.DELETE("/", + neConfigDataGroup.DELETE("/", middleware.PreAuthorize(nil), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigData", collectlogs.BUSINESS_TYPE_DELETE)), controller.NewPtNeConfigData.Remove, @@ -50,17 +50,35 @@ func Setup(router *gin.Engine) { } // 网元参数配置数据变更日志 - paramConfigLogGroup := ptGroup.Group("/neConfigDataLog") + neConfigDataLogGroup := ptGroup.Group("/neConfigDataLog") { - paramConfigLogGroup.GET("", + neConfigDataLogGroup.GET("", middleware.PreAuthorize(nil), controller.NewPtNeConfigDataLog.Info, ) - paramConfigLogGroup.DELETE("", + neConfigDataLogGroup.DELETE("", middleware.PreAuthorize(map[string][]string{"hasRoles": {"admin"}}), collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigDataLog", collectlogs.BUSINESS_TYPE_DELETE)), controller.NewPtNeConfigDataLog.Remove, ) } + // 网元参数配置应用申请 + neConfigApplyGroup := ptGroup.Group("/neConfigApply") + { + neConfigApplyGroup.GET("", + middleware.PreAuthorize(nil), + controller.NewPtNeConfigApply.Info, + ) + neConfigApplyGroup.POST("", + middleware.PreAuthorize(map[string][]string{"hasRoles": {"student"}}), + collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigApply", collectlogs.BUSINESS_TYPE_INSERT)), + controller.NewPtNeConfigApply.Add, + ) + neConfigApplyGroup.PUT("", + middleware.PreAuthorize(map[string][]string{"hasRoles": {"teacher", "admin"}}), + collectlogs.OperateLog(collectlogs.OptionNew("log.operate.title.neConfigApply", collectlogs.BUSINESS_TYPE_UPDATE)), + controller.NewPtNeConfigApply.Edit, + ) + } } diff --git a/src/modules/practical_training/repository/pt_ne_config_apply.go b/src/modules/practical_training/repository/pt_ne_config_apply.go new file mode 100644 index 00000000..97376876 --- /dev/null +++ b/src/modules/practical_training/repository/pt_ne_config_apply.go @@ -0,0 +1,24 @@ +package repository + +import "be.ems/src/modules/practical_training/model" + +// IPtNeConfigApplyRepository 数据层接口 +type IPtNeConfigApplyRepository interface { + // SelectPage 根据条件分页查询字典类型 + SelectPage(query map[string]any) map[string]any + + // SelectList 根据实体查询 + SelectList(param model.PtNeConfigApply) []model.PtNeConfigApply + + // SelectByIds 通过ID查询 + SelectByIds(paramIds []string) []model.PtNeConfigApply + + // Insert 新增信息 + Insert(param model.PtNeConfigApply) string + + // Update 修改信息 + Update(param model.PtNeConfigApply) int64 + + // DeleteByIds 批量删除信息 + DeleteByIds(paramIds []string) int64 +} diff --git a/src/modules/practical_training/repository/pt_ne_config_apply.impl.go b/src/modules/practical_training/repository/pt_ne_config_apply.impl.go new file mode 100644 index 00000000..fccac2fc --- /dev/null +++ b/src/modules/practical_training/repository/pt_ne_config_apply.impl.go @@ -0,0 +1,241 @@ +package repository + +import ( + "strings" + "time" + + "be.ems/src/framework/datasource" + "be.ems/src/framework/logger" + "be.ems/src/framework/utils/parse" + "be.ems/src/framework/utils/repo" + "be.ems/src/modules/practical_training/model" +) + +// NewPtNeConfigApplyRepository 实例化数据层 +var NewPtNeConfigApplyRepository = &PtNeConfigApplyRepository{ + selectSql: `select + id, create_by, create_time, update_by, update_time, back_info, + status, ne_type + from pt_ne_config_apply`, + + resultMap: map[string]string{ + "id": "ID", + "create_by": "CreateBy", + "create_time": "CreateTime", + "update_by": "UpdateBy", + "update_time": "UpdateTime", + "ne_type": "NeType", + "status": "Status", + "back_info": "BackInfo", + }, +} + +// PtNeConfigApplyRepository 数据层处理 +type PtNeConfigApplyRepository struct { + // 查询视图对象SQL + selectSql string + // 结果字段与实体映射 + resultMap map[string]string +} + +// convertResultRows 将结果记录转实体结果组 +func (r *PtNeConfigApplyRepository) convertResultRows(rows []map[string]any) []model.PtNeConfigApply { + arr := make([]model.PtNeConfigApply, 0) + for _, row := range rows { + item := model.PtNeConfigApply{} + for key, value := range row { + if keyMapper, ok := r.resultMap[key]; ok { + repo.SetFieldValue(&item, keyMapper, value) + } + } + arr = append(arr, item) + } + return arr +} + +// SelectPage 根据条件分页查询字典类型 +func (r *PtNeConfigApplyRepository) SelectPage(query map[string]any) map[string]any { + // 查询条件拼接 + var conditions []string + var params []any + if v, ok := query["status"]; ok && v != "" { + conditions = append(conditions, "status = ?") + params = append(params, v) + } + if v, ok := query["neType"]; ok && v != "" { + conditions = append(conditions, "ne_type = ?") + params = append(params, v) + } + + // 构建查询条件语句 + whereSql := "" + if len(conditions) > 0 { + whereSql += " where " + strings.Join(conditions, " and ") + } + + result := map[string]any{ + "total": int64(0), + "rows": []model.PtNeConfigApply{}, + } + + // 查询数量 长度为0直接返回 + totalSql := "select count(1) as 'total' from pt_ne_config_apply" + totalRows, err := datasource.RawDB("", totalSql+whereSql, params) + if err != nil { + logger.Errorf("total err => %v", err) + return result + } + if total := parse.Number(totalRows[0]["total"]); total > 0 { + result["total"] = total + } else { + return result + } + + // 分页 + pageNum, pageSize := repo.PageNumSize(query["pageNum"], query["pageSize"]) + pageSql := " limit ?,? " + params = append(params, pageNum*pageSize) + params = append(params, pageSize) + + // 查询数据 + querySql := r.selectSql + whereSql + pageSql + results, err := datasource.RawDB("", querySql, params) + if err != nil { + logger.Errorf("query err => %v", err) + return result + } + + // 转换实体 + result["rows"] = r.convertResultRows(results) + return result +} + +// SelectList 根据实体查询 +func (r *PtNeConfigApplyRepository) SelectList(param model.PtNeConfigApply) []model.PtNeConfigApply { + // 查询条件拼接 + var conditions []string + var params []any + if param.CreateBy != "" { + conditions = append(conditions, "create_by = ?") + params = append(params, param.CreateBy) + } + if param.Status != "" { + conditions = append(conditions, "status = ?") + params = append(params, param.Status) + } + if param.NeType != "" { + conditions = append(conditions, "ne_type = ?") + params = append(params, param.NeType) + } + + // 构建查询条件语句 + whereSql := "" + if len(conditions) > 0 { + whereSql += " where " + strings.Join(conditions, " and ") + } + + // 查询数据 + querySql := r.selectSql + whereSql + " order by id asc " + results, err := datasource.RawDB("", querySql, params) + if err != nil { + logger.Errorf("query err => %v", err) + } + + // 转换实体 + return r.convertResultRows(results) +} + +// SelectByIds 通过ID查询 +func (r *PtNeConfigApplyRepository) SelectByIds(paramIds []string) []model.PtNeConfigApply { + placeholder := repo.KeyPlaceholderByQuery(len(paramIds)) + querySql := r.selectSql + " where id in (" + placeholder + ")" + parameters := repo.ConvertIdsSlice(paramIds) + results, err := datasource.RawDB("", querySql, parameters) + if err != nil { + logger.Errorf("query err => %v", err) + return []model.PtNeConfigApply{} + } + // 转换实体 + return r.convertResultRows(results) +} + +// Insert 新增信息 +func (r *PtNeConfigApplyRepository) Insert(param model.PtNeConfigApply) string { + // 参数拼接 + params := make(map[string]any) + if param.CreateBy != "" { + params["create_by"] = param.CreateBy + params["create_time"] = time.Now().UnixMilli() + } + params["back_info"] = param.BackInfo + if param.Status != "" { + params["status"] = param.Status + } + if param.NeType != "" { + params["ne_type"] = param.NeType + } + + // 构建执行语句 + keys, placeholder, values := repo.KeyPlaceholderValueByInsert(params) + sql := "insert into pt_ne_config_apply (" + strings.Join(keys, ",") + ")values(" + placeholder + ")" + + tx := datasource.DefaultDB().Begin() // 开启事务 + // 执行插入 + if err := tx.Exec(sql, values...).Error; err != nil { + logger.Errorf("insert row : %v", err.Error()) + tx.Rollback() + return "" + } + // 获取生成的自增 ID + var insertedID string + if err := tx.Raw("select last_insert_id()").Row().Scan(&insertedID); err != nil { + logger.Errorf("insert last id : %v", err.Error()) + tx.Rollback() + return "" + } + tx.Commit() // 提交事务 + return insertedID +} + +// Update 修改信息 +func (r *PtNeConfigApplyRepository) Update(param model.PtNeConfigApply) int64 { + // 参数拼接 + params := make(map[string]any) + if param.UpdateBy != "" { + params["update_by"] = param.UpdateBy + params["update_time"] = time.Now().UnixMilli() + } + params["back_info"] = param.BackInfo + if param.Status != "" { + params["status"] = param.Status + } + if param.NeType != "" { + params["ne_type"] = param.NeType + } + + // 构建执行语句 + keys, values := repo.KeyValueByUpdate(params) + sql := "update pt_ne_config_apply set " + strings.Join(keys, ",") + " where id = ?" + + // 执行更新 + values = append(values, param.ID) + rows, err := datasource.ExecDB("", sql, values) + if err != nil { + logger.Errorf("update row : %v", err.Error()) + return 0 + } + return rows +} + +// DeleteByIds 批量删除信息 +func (r *PtNeConfigApplyRepository) DeleteByIds(paramIds []string) int64 { + placeholder := repo.KeyPlaceholderByQuery(len(paramIds)) + sql := "delete from pt_ne_config_apply where id in (" + placeholder + ")" + parameters := repo.ConvertIdsSlice(paramIds) + results, err := datasource.ExecDB("", sql, parameters) + if err != nil { + logger.Errorf("delete err => %v", err) + return 0 + } + return results +} diff --git a/src/modules/practical_training/service/pt_ne_config_apply.go b/src/modules/practical_training/service/pt_ne_config_apply.go new file mode 100644 index 00000000..38756278 --- /dev/null +++ b/src/modules/practical_training/service/pt_ne_config_apply.go @@ -0,0 +1,26 @@ +package service + +import ( + "be.ems/src/modules/practical_training/model" +) + +// IPtNeConfigApplyService 服务层接口 +type IPtNeConfigApplyService interface { + // SelectPage 根据条件分页查询字典类型 + SelectPage(query map[string]any) map[string]any + + // SelectList 根据实体查询 + SelectList(param model.PtNeConfigApply) []model.PtNeConfigApply + + // SelectByIds 通过ID查询 + SelectById(paramId string) model.PtNeConfigApply + + // Insert 新增信息 + Insert(param model.PtNeConfigApply) string + + // Update 修改信息 + Update(param model.PtNeConfigApply) int64 + + // DeleteByIds 批量删除信息 + DeleteByIds(paramIds []string) (int64, error) +} diff --git a/src/modules/practical_training/service/pt_ne_config_apply.impl.go b/src/modules/practical_training/service/pt_ne_config_apply.impl.go new file mode 100644 index 00000000..25e19634 --- /dev/null +++ b/src/modules/practical_training/service/pt_ne_config_apply.impl.go @@ -0,0 +1,67 @@ +package service + +import ( + "fmt" + + "be.ems/src/modules/practical_training/model" + "be.ems/src/modules/practical_training/repository" +) + +// NewPtNeConfigApplyService 实例化服务层 +var NewPtNeConfigApplyService = &PtNeConfigApplyService{ + ptNeConfigApplyRepository: repository.NewPtNeConfigApplyRepository, +} + +// PtNeConfigApplyService 服务层处理 +type PtNeConfigApplyService struct { + // 实训教学_网元参数配置表 + ptNeConfigApplyRepository repository.IPtNeConfigApplyRepository +} + +// SelectNeHostPage 分页查询列表数据 +func (r *PtNeConfigApplyService) SelectPage(query map[string]any) map[string]any { + return r.ptNeConfigApplyRepository.SelectPage(query) +} + +// SelectConfigList 查询列表 +func (r *PtNeConfigApplyService) SelectList(param model.PtNeConfigApply) []model.PtNeConfigApply { + return r.ptNeConfigApplyRepository.SelectList(param) +} + +// SelectByIds 通过ID查询 +func (r *PtNeConfigApplyService) SelectById(paramId string) model.PtNeConfigApply { + if paramId == "" { + return model.PtNeConfigApply{} + } + neHosts := r.ptNeConfigApplyRepository.SelectByIds([]string{paramId}) + if len(neHosts) > 0 { + return neHosts[0] + } + return model.PtNeConfigApply{} +} + +// Insert 新增信息 +func (r *PtNeConfigApplyService) Insert(param model.PtNeConfigApply) string { + return r.ptNeConfigApplyRepository.Insert(param) +} + +// Update 修改信息 +func (r *PtNeConfigApplyService) Update(param model.PtNeConfigApply) int64 { + return r.ptNeConfigApplyRepository.Update(param) +} + +// DeleteByIds 批量删除信息 +func (r *PtNeConfigApplyService) DeleteByIds(paramIds []string) (int64, error) { + // 检查是否存在 + ids := r.ptNeConfigApplyRepository.SelectByIds(paramIds) + if len(ids) <= 0 { + return 0, fmt.Errorf("ptNeConfigApply.noData") + } + + if len(ids) == len(paramIds) { + rows := r.ptNeConfigApplyRepository.DeleteByIds(paramIds) + return rows, nil + } + // 删除信息失败！ + return 0, fmt.Errorf("delete fail") +}