message
CI / changes (push) Successful in 38s
CI / ad (push) Successful in 46s
CI / admin (push) Successful in 47s
CI / bff (push) Successful in 3s
CI / chore (push) Successful in 49s
CI / equipment (push) Successful in 52s
CI / express (push) Successful in 48s
CI / factory (push) Successful in 48s
CI / message (push) Failing after 5s
CI / payment (push) Successful in 42s
CI / product (push) Successful in 48s
CI / record (push) Successful in 50s
CI / sale (push) Successful in 51s
CI / task (push) Successful in 47s
CI / user (push) Successful in 48s
CI / wecom (push) Successful in 46s
CI / changes (push) Successful in 38s
CI / ad (push) Successful in 46s
CI / admin (push) Successful in 47s
CI / bff (push) Successful in 3s
CI / chore (push) Successful in 49s
CI / equipment (push) Successful in 52s
CI / express (push) Successful in 48s
CI / factory (push) Successful in 48s
CI / message (push) Failing after 5s
CI / payment (push) Successful in 42s
CI / product (push) Successful in 48s
CI / record (push) Successful in 50s
CI / sale (push) Successful in 51s
CI / task (push) Successful in 47s
CI / user (push) Successful in 48s
CI / wecom (push) Successful in 46s
This commit is contained in:
@@ -0,0 +1,83 @@
|
||||
package logic
|
||||
|
||||
import (
|
||||
"context"
|
||||
"lone-services/pkg/modelbase"
|
||||
"lone-services/pkg/utils"
|
||||
"lone-services/services/equipment/internal/dao"
|
||||
"lone-services/services/equipment/internal/model"
|
||||
"lone-services/services/equipment/validator"
|
||||
"strconv"
|
||||
|
||||
"lone-services/rpc/equipment/pb"
|
||||
"lone-services/services/equipment/internal/svc"
|
||||
|
||||
"github.com/zeromicro/go-zero/core/logx"
|
||||
)
|
||||
|
||||
type ApiUnBindLogic struct {
|
||||
ctx context.Context
|
||||
svcCtx *svc.ServiceContext
|
||||
logx.Logger
|
||||
BaseLogic
|
||||
}
|
||||
|
||||
func NewApiUnBindLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ApiUnBindLogic {
|
||||
return &ApiUnBindLogic{
|
||||
ctx: ctx,
|
||||
svcCtx: svcCtx,
|
||||
Logger: logx.WithContext(ctx),
|
||||
}
|
||||
}
|
||||
|
||||
func (l *ApiUnBindLogic) ApiUnBind(in *equipment.ApiUnBindRequest) (*equipment.Response, error) {
|
||||
var v validator.BindUnbindValidator
|
||||
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)
|
||||
}
|
||||
|
||||
var info dao.BindInfo
|
||||
w := modelbase.Params{
|
||||
Eq: map[string]string{
|
||||
"host_code": in.HostCode,
|
||||
"user_id": strconv.FormatInt(adminInfo.ID, utils.NumberTen),
|
||||
"status": utils.StringStatusOk},
|
||||
}
|
||||
|
||||
modelObj := model.BindModel{}.Init()
|
||||
err := modelObj.GetOne(w, &info)
|
||||
if err != nil {
|
||||
l.Logger.Error(err)
|
||||
return l.fail(utils.Fail)
|
||||
}
|
||||
if info.Id < utils.NumberOne {
|
||||
return l.fail(utils.ErrorNotFund)
|
||||
}
|
||||
info.Status = utils.StatusFail
|
||||
host := dao.BindHistoryCreate{
|
||||
HostCode: v.HostCode,
|
||||
UserId: adminInfo.ID,
|
||||
Status: utils.StatusFail,
|
||||
}
|
||||
modelObj.Begin()
|
||||
_, err = modelObj.Edit(w, &info)
|
||||
if err != nil {
|
||||
l.Logger.Error(err)
|
||||
modelObj.Rollback()
|
||||
return l.fail(utils.Fail)
|
||||
}
|
||||
err = model.BindHistoryModel{}.Init().Create(&host)
|
||||
if err != nil {
|
||||
l.Logger.Error(err)
|
||||
modelObj.Rollback()
|
||||
return l.fail(utils.Fail)
|
||||
}
|
||||
modelObj.Commit()
|
||||
|
||||
return l.ok(utils.NumberOne)
|
||||
}
|
||||
Reference in New Issue
Block a user