package logic import ( "context" "lone-services/pkg/modelbase" "lone-services/pkg/utils" "lone-services/services/water/internal/dao" "lone-services/services/water/model" "lone-services/services/water/validator" "time" "lone-services/rpc/water/pb" "lone-services/services/water/internal/svc" "github.com/zeromicro/go-zero/core/logx" ) type AddLogLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger BaseLogic } func NewAddLogLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AddLogLogic { return &AddLogLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } func (l *AddLogLogic) AddLog(in *water.AddLogRequest) (*water.Response, error) { var v validator.LogAddValidator if fail := l.checkParams(in, &v); fail != nil { return fail, nil } adminInfo := utils.GetUserFromCtx(l.ctx) if adminInfo.ID < utils.NumberOne { return l.fail(utils.ErrorNoLoginInfo) } info := dao.LogCreate{ HostCode: in.HostCode, Water: in.Water, Salt: in.Salt, UserId: adminInfo.ID, } err := model.LogModel{}.Init().Create(&info) if err != nil { return l.fail(utils.Fail) } date := utils.Now().Format(time.DateOnly) w := modelbase.Params{Eq: map[string]string{"date": date}} var logDate dao.LogDate err = model.LogDateModel{}.Init().GetOne(w, &logDate) if err != nil { return l.fail(utils.Fail) } if logDate.Id < utils.NumberOne { logDate.Date = date logDate.Water = in.Water logDate.Salt = in.Salt logDate.UserId = adminInfo.ID logDate.HostCode = in.HostCode err = model.LogDateModel{}.Init().Create(&logDate) if err != nil { return l.fail(utils.Fail) } } else { logDate.Water += in.Water logDate.Salt += in.Salt _, err = model.LogDateModel{}.Init().Edit(w, &logDate) if err != nil { return l.fail(utils.Fail) } } month := utils.Now().Format("2006-01") w = modelbase.Params{Eq: map[string]string{"month": month}} var logMonth dao.LogMonth err = model.LogMonthModel{}.Init().GetOne(w, &logMonth) if err != nil { return l.fail(utils.Fail) } if logMonth.Id < utils.NumberOne { logMonth.Month = month logMonth.Water = in.Water logMonth.Salt = in.Salt logMonth.UserId = adminInfo.ID logMonth.HostCode = in.HostCode err = model.LogMonthModel{}.Init().Create(&logMonth) if err != nil { return l.fail(utils.Fail) } } else { logMonth.Water += in.Water logMonth.Salt += in.Salt _, err = model.LogMonthModel{}.Init().Edit(w, &logMonth) if err != nil { return l.fail(utils.Fail) } } return l.ok(utils.NumberOne) }