提交 23535cf4 编写于 作者: m0_50812349's avatar m0_50812349

优化server/api/v1/exa_customer.go的代码及备注错误

上级 eaedb37f
...@@ -11,13 +11,13 @@ import ( ...@@ -11,13 +11,13 @@ import (
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
) )
// @Tags SysApi // @Tags ExaCustomer
// @Summary 创建客户 // @Summary 创建客户
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body model.ExaCustomer true "创建客户" // @Param data body model.ExaCustomer true "客户用户名, 客户手机号码"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"创建成功"}"
// @Router /customer/customer [post] // @Router /customer/customer [post]
func CreateExaCustomer(c *gin.Context) { func CreateExaCustomer(c *gin.Context) {
var cu model.ExaCustomer var cu model.ExaCustomer
...@@ -26,66 +26,53 @@ func CreateExaCustomer(c *gin.Context) { ...@@ -26,66 +26,53 @@ func CreateExaCustomer(c *gin.Context) {
"CustomerName": {utils.NotEmpty()}, "CustomerName": {utils.NotEmpty()},
"CustomerPhoneData": {utils.NotEmpty()}, "CustomerPhoneData": {utils.NotEmpty()},
} }
CustomerVerifyErr := utils.Verify(cu, CustomerVerify) if CustomerVerifyErr := utils.Verify(cu, CustomerVerify); CustomerVerifyErr != nil {
if CustomerVerifyErr != nil {
response.FailWithMessage(CustomerVerifyErr.Error(), c) response.FailWithMessage(CustomerVerifyErr.Error(), c)
return return
} }
claims, _ := c.Get("claims") cu.SysUserID = getUserID(c)
waitUse := claims.(*request.CustomClaims) cu.SysUserAuthorityID = getUserAuthorityId(c)
cu.SysUserID = waitUse.ID if err := service.CreateExaCustomer(cu); err != nil {
cu.SysUserAuthorityID = waitUse.AuthorityId
err := service.CreateExaCustomer(cu)
if err != nil {
response.FailWithMessage(fmt.Sprintf("删除失败:%v", err), c) response.FailWithMessage(fmt.Sprintf("删除失败:%v", err), c)
} else { } else {
response.OkWithMessage("创建成功", c) response.OkWithMessage("创建成功", c)
} }
} }
// @Tags SysApi // @Tags ExaCustomer
// @Summary 删除客户 // @Summary 删除客户
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body model.ExaCustomer true "删除客户" // @Param data body model.ExaCustomer true "客户ID"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"删除成功"}"
// @Router /customer/customer [delete] // @Router /customer/customer [delete]
func DeleteExaCustomer(c *gin.Context) { func DeleteExaCustomer(c *gin.Context) {
var cu model.ExaCustomer var cu model.ExaCustomer
_ = c.ShouldBindJSON(&cu) _ = c.ShouldBindJSON(&cu)
CustomerVerify := utils.Rules{ if CustomerVerifyErr := utils.Verify(cu.GVA_MODEL, utils.Rules{"ID": {utils.NotEmpty()}}); CustomerVerifyErr != nil {
"ID": {utils.NotEmpty()},
}
CustomerVerifyErr := utils.Verify(cu.GVA_MODEL, CustomerVerify)
if CustomerVerifyErr != nil {
response.FailWithMessage(CustomerVerifyErr.Error(), c) response.FailWithMessage(CustomerVerifyErr.Error(), c)
return return
} }
err := service.DeleteExaCustomer(cu) if err := service.DeleteExaCustomer(cu); err != nil {
if err != nil {
response.FailWithMessage(fmt.Sprintf("删除失败:%v", err), c) response.FailWithMessage(fmt.Sprintf("删除失败:%v", err), c)
} else { } else {
response.OkWithMessage("删除成功", c) response.OkWithMessage("删除成功", c)
} }
} }
// @Tags SysApi // @Tags ExaCustomer
// @Summary 更新客户信息 // @Summary 更新客户信息
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body model.ExaCustomer true "创建客户" // @Param data body model.ExaCustomer true "客户ID, 客户信息"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"更新成功"}"
// @Router /customer/customer [put] // @Router /customer/customer [put]
func UpdateExaCustomer(c *gin.Context) { func UpdateExaCustomer(c *gin.Context) {
var cu model.ExaCustomer var cu model.ExaCustomer
_ = c.ShouldBindJSON(&cu) _ = c.ShouldBindJSON(&cu)
IdCustomerVerify := utils.Rules{ if IdCustomerVerifyErr := utils.Verify(cu.GVA_MODEL, utils.Rules{"ID": {utils.NotEmpty()}}); IdCustomerVerifyErr != nil {
"ID": {utils.NotEmpty()},
}
IdCustomerVerifyErr := utils.Verify(cu.GVA_MODEL, IdCustomerVerify)
if IdCustomerVerifyErr != nil {
response.FailWithMessage(IdCustomerVerifyErr.Error(), c) response.FailWithMessage(IdCustomerVerifyErr.Error(), c)
return return
} }
...@@ -93,35 +80,29 @@ func UpdateExaCustomer(c *gin.Context) { ...@@ -93,35 +80,29 @@ func UpdateExaCustomer(c *gin.Context) {
"CustomerName": {utils.NotEmpty()}, "CustomerName": {utils.NotEmpty()},
"CustomerPhoneData": {utils.NotEmpty()}, "CustomerPhoneData": {utils.NotEmpty()},
} }
CustomerVerifyErr := utils.Verify(cu, CustomerVerify) if CustomerVerifyErr := utils.Verify(cu, CustomerVerify); CustomerVerifyErr != nil {
if CustomerVerifyErr != nil {
response.FailWithMessage(CustomerVerifyErr.Error(), c) response.FailWithMessage(CustomerVerifyErr.Error(), c)
return return
} }
err := service.UpdateExaCustomer(&cu) if err := service.UpdateExaCustomer(&cu); err != nil {
if err != nil {
response.FailWithMessage(fmt.Sprintf("更新失败:%v", err), c) response.FailWithMessage(fmt.Sprintf("更新失败:%v", err), c)
} else { } else {
response.OkWithMessage("更新成功", c) response.OkWithMessage("更新成功", c)
} }
} }
// @Tags SysApi // @Tags ExaCustomer
// @Summary 获取单一客户信息 // @Summary 获取单一客户信息
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body model.ExaCustomer true "获取单一客户信息" // @Param data body model.ExaCustomer true "客户ID"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"操作成功"}"
// @Router /customer/customer [get] // @Router /customer/customer [get]
func GetExaCustomer(c *gin.Context) { func GetExaCustomer(c *gin.Context) {
var cu model.ExaCustomer var cu model.ExaCustomer
_ = c.ShouldBindQuery(&cu) _ = c.ShouldBindQuery(&cu)
IdCustomerVerify := utils.Rules{ if IdCustomerVerifyErr := utils.Verify(cu.GVA_MODEL, utils.Rules{"ID": {utils.NotEmpty()}}); IdCustomerVerifyErr != nil {
"ID": {utils.NotEmpty()},
}
IdCustomerVerifyErr := utils.Verify(cu.GVA_MODEL, IdCustomerVerify)
if IdCustomerVerifyErr != nil {
response.FailWithMessage(IdCustomerVerifyErr.Error(), c) response.FailWithMessage(IdCustomerVerifyErr.Error(), c)
return return
} }
...@@ -133,25 +114,22 @@ func GetExaCustomer(c *gin.Context) { ...@@ -133,25 +114,22 @@ func GetExaCustomer(c *gin.Context) {
} }
} }
// @Tags SysApi // @Tags ExaCustomer
// @Summary 获取权限客户列表 // @Summary 获取权限客户列表
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body request.PageInfo true "获取权限客户列表" // @Param data body request.PageInfo true "页码, 每页大小"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"操作成功"}"
// @Router /customer/customerList [get] // @Router /customer/customerList [get]
func GetExaCustomerList(c *gin.Context) { func GetExaCustomerList(c *gin.Context) {
claims, _ := c.Get("claims")
waitUse := claims.(*request.CustomClaims)
var pageInfo request.PageInfo var pageInfo request.PageInfo
_ = c.ShouldBindQuery(&pageInfo) _ = c.ShouldBindQuery(&pageInfo)
PageVerifyErr := utils.Verify(pageInfo, utils.CustomizeMap["PageVerify"]) if PageVerifyErr := utils.Verify(pageInfo, utils.CustomizeMap["PageVerify"]); PageVerifyErr != nil {
if PageVerifyErr != nil {
response.FailWithMessage(PageVerifyErr.Error(), c) response.FailWithMessage(PageVerifyErr.Error(), c)
return return
} }
err, customerList, total := service.GetCustomerInfoList(waitUse.AuthorityId, pageInfo) err, customerList, total := service.GetCustomerInfoList(getUserAuthorityId(c), pageInfo)
if err != nil { if err != nil {
response.FailWithMessage(fmt.Sprintf("获取失败:%v", err), c) response.FailWithMessage(fmt.Sprintf("获取失败:%v", err), c)
} else { } else {
......
package v1 package v1
import ( import (
"errors"
"fmt" "fmt"
"gin-vue-admin/global" "gin-vue-admin/global"
"gin-vue-admin/global/response" "gin-vue-admin/global/response"
...@@ -169,7 +168,7 @@ func ChangePassword(c *gin.Context) { ...@@ -169,7 +168,7 @@ func ChangePassword(c *gin.Context) {
// @Security ApiKeyAuth // @Security ApiKeyAuth
// @accept application/json // @accept application/json
// @Produce application/json // @Produce application/json
// @Param data body request.PageInfo true "页码, 页大小" // @Param data body request.PageInfo true "页码, 页大小"
// @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}" // @Success 200 {string} string "{"success":true,"data":{},"msg":"获取成功"}"
// @Router /user/getUserList [post] // @Router /user/getUserList [post]
func GetUserList(c *gin.Context) { func GetUserList(c *gin.Context) {
...@@ -274,34 +273,34 @@ func SetUserInfo(c *gin.Context) { ...@@ -274,34 +273,34 @@ func SetUserInfo(c *gin.Context) {
} }
// 从Gin的Context中获取从jwt解析出来的用户ID // 从Gin的Context中获取从jwt解析出来的用户ID
func getUserID(c *gin.Context) (uint, error) { func getUserID(c *gin.Context) uint {
if claims, exists := c.Get("claims"); !exists { if claims, exists := c.Get("claims"); !exists {
global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户ID失败, 请检查路由是否使用jwt中间件") global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户ID失败, 请检查路由是否使用jwt中间件")
return 0, errors.New("解析失败") return 0
} else { } else {
waitUse := claims.(*request.CustomClaims) waitUse := claims.(*request.CustomClaims)
return waitUse.ID, nil return waitUse.ID
} }
} }
// 从Gin的Context中获取从jwt解析出来的用户UUID // 从Gin的Context中获取从jwt解析出来的用户UUID
func getUserUuid(c *gin.Context) (string, error) { func getUserUuid(c *gin.Context) string {
if claims, exists := c.Get("claims"); !exists { if claims, exists := c.Get("claims"); !exists {
global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户UUID失败, 请检查路由是否使用jwt中间件") global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户UUID失败, 请检查路由是否使用jwt中间件")
return "", errors.New("解析失败") return ""
} else { } else {
waitUse := claims.(*request.CustomClaims) waitUse := claims.(*request.CustomClaims)
return waitUse.UUID.String(), nil return waitUse.UUID.String()
} }
} }
// 从Gin的Context中获取从jwt解析出来的用户角色id // 从Gin的Context中获取从jwt解析出来的用户角色id
func getUserAuthorityId(c *gin.Context) (string, error) { func getUserAuthorityId(c *gin.Context) string {
if claims, exists := c.Get("claims"); !exists { if claims, exists := c.Get("claims"); !exists {
global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户UUID失败, 请检查路由是否使用jwt中间件") global.GVA_LOG.Error("从Gin的Context中获取从jwt解析出来的用户UUID失败, 请检查路由是否使用jwt中间件")
return "", errors.New("解析失败") return ""
} else { } else {
waitUse := claims.(*request.CustomClaims) waitUse := claims.(*request.CustomClaims)
return waitUse.AuthorityId, nil return waitUse.AuthorityId
} }
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册