123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- package service
- import (
- "dy-admin/internal/pcmserver/bus/cabinet_pkg"
- "dy-admin/internal/pcmserver/bus/model"
- "dy-admin/internal/pcmserver/common"
- "dy-admin/internal/pcmserver/global"
- "dy-admin/internal/pcmserver/pkg/code"
- "dy-admin/pkg/rescode"
- "encoding/json"
- )
- type BusConfigService struct {
- }
- func (s *BusConfigService) GetBusConfig() (config *model.CabinetConfig, err error) {
- var busConfig model.BusConfig
- if err = global.DB.Model(&model.BusConfig{}).First(&busConfig).Error; err != nil {
- return config, rescode.RegisterErrorWithCause(err, code.ErrCodeMap[code.ErrDatabaseCode])
- }
- config = new(model.CabinetConfig)
- err = json.Unmarshal([]byte(busConfig.Config), config)
- if err != nil {
- return config, rescode.RegisterErrorWithCause(err, code.ErrCodeMap[code.ErrDecodingFailedCode])
- }
- return
- }
- func (s *BusConfigService) UpdateConfig(cabinetConfig *model.CabinetConfig) (err error) {
- config, err := json.Marshal(cabinetConfig)
- if err != nil {
- return rescode.RegisterErrorWithCause(err, code.ErrCodeMap[code.ErrEncodingFailedCode])
- }
- busConfig := &model.BusConfig{
- Model: common.Model{ID: cabinetConfig.ID},
- Config: string(config),
- }
- err = global.DB.Updates(busConfig).Error
- if err != nil {
- return rescode.RegisterErrorWithCause(err, code.ErrCodeMap[code.ErrDatabaseCode])
- }
- cabinet_pkg.SetCabinetMemConfig(cabinetConfig)
- return nil
- }
|