fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'develop' of gitee.com:fusenpack/fusenapi into develop

Browse Source
This commit is contained in:
momo
2023-11-27 14:46:56 +08:00
parent 4889590b35 fdb8082095
commit 9cb514ca75
14 changed files with 235 additions and 92 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
server/ldap-admin/internal/logic/createldaporganizationlogic.go
View File

@@ -68,7 +68,27 @@ func (l *CreateLdapOrganizationLogic) CreateLdapOrganization(req *types.CreateLd
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "创建组织失败,"+err.Error())
}
return resp.SetStatus(basic.CodeOK)
user, err := l.svcCtx.Ldap.GetLdapUserInfo(req.OwnerDN)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "获取负责人信息失败,"+err.Error())
}
if user.Status != 1 {
return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "负责人状态不正常")
}
//用户加入的部门
user.OrganizationDNList = append(user.OrganizationDNList, organizationDN)
//用户管理的部门
user.ManageOrganizationDNList = append(user.ManageOrganizationDNList, organizationDN)
//更新用户信息
err = l.svcCtx.Ldap.Update(user.UserDN, map[string][]string{
"departmentNumber": user.OrganizationDNList,
"telexNumber": user.ManageOrganizationDNList,
})
if err != nil {
return resp.SetStatusWithMessage(basic.CodeOK, "添加组织成功，但是设置负责人信息失败，"+err.Error())
}
return resp.SetStatusWithMessage(basic.CodeOK, "添加组织成功")
}
// 处理逻辑后 w,r 如:重定向, resp 必须重新处理

12
server/ldap-admin/internal/logic/createldapuserlogic.go
View File

@@ -88,7 +88,10 @@ func (l *CreateLdapUserLogic) CreateLdapUser(req *types.CreateLdapUserReq, r *ht
"mail": {req.Email}, //邮箱
"postalCode": {fmt.Sprintf("%d", req.Status)}, //状态
"roomNumber": {fmt.Sprintf("%d", req.GroupId)}, //权限分组id
"departmentNumber": req.OrganizationDNList, //所属组织部门
"departmentNumber": {""}, //所属组织部门
"telexNumber": {""}, //管理的部门
"st": {fmt.Sprintf("%d", req.Gender)}, //性别
"title": {req.Birthday}, //生日
"postalAddress": {req.Avatar}, //头像
"mobile": {req.Mobile}, //手机号
"userPassword": {req.Password}, //密码
@@ -97,13 +100,6 @@ func (l *CreateLdapUserLogic) CreateLdapUser(req *types.CreateLdapUserReq, r *ht
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "添加用户失败,"+err.Error())
}
//将用户加入这些部门
for _, v := range req.OrganizationDNList {
if err = l.svcCtx.Ldap.AddUserToOrganization(v, userDN); err != nil {
logx.Error("加入部门失败:", err)
continue
}
}
return resp.SetStatusWithMessage(basic.CodeOK, "添加用户成功")
}

2
server/ldap-admin/internal/logic/getldaporganizationmemberslogic.go
View File

@@ -116,6 +116,8 @@ func (l *GetLdapOrganizationMembersLogic) GetLdapOrganizationMembers(req *types.
Mobile: user.Mobile,
Avatar: user.Avatar,
EmployeeType: user.EmployeeType,
Gender: user.Gender,
Birthday: user.Birthday,
Status: user.Status,
})
}

4
server/ldap-admin/internal/logic/getldapuserinfologic.go
View File

@@ -54,8 +54,10 @@ func (l *GetLdapUserInfoLogic) GetLdapUserInfo(req *types.GetLdapUserInfoReq, r
Email: user.Email,
Mobile: user.Mobile,
Avatar: user.Avatar,
Status: user.Status,
EmployeeTpye: user.EmployeeType,
Gender: user.Gender,
Birthday: user.Birthday,
Status: user.Status,
})
}

31
server/ldap-admin/internal/logic/removeldaporganizationmemberlogic.go
View File

@@ -49,11 +49,42 @@ func (l *RemoveLdapOrganizationMemberLogic) RemoveLdapOrganizationMember(req *ty
if !email.IsEmailValid(cnEmail) {
return resp.SetStatusWithMessage(basic.CodeRequestParamsErr, "错误的用户cn")
}
//获取组织成员列表
err := l.svcCtx.Ldap.RemoveUserFromOrganization(req.OrganizationDN, req.UserDN)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "移除成员失败，"+err.Error())
}
//获取用户信息
userInfo, err := l.svcCtx.Ldap.GetLdapUserInfo(req.UserDN)
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "获取用户信息失败，"+err.Error())
}
//把属于的组织去掉
newOrganizationDNList := make([]string, 0, len(userInfo.OrganizationDNList))
for _, v := range userInfo.OrganizationDNList {
if v == req.OrganizationDN {
continue
}
newOrganizationDNList = append(newOrganizationDNList, v)
}
//如果是负责人也要把管理组织标识去掉
newManageOrganizationDNList := make([]string, 0, len(userInfo.OrganizationDNList))
for _, v := range userInfo.ManageOrganizationDNList {
if v == req.OrganizationDN {
continue
}
newManageOrganizationDNList = append(newManageOrganizationDNList, v)
}
err = l.svcCtx.Ldap.Update(req.UserDN, map[string][]string{
"departmentNumber": newOrganizationDNList, //所属组织部门
"telexNumber": newManageOrganizationDNList, //管理的部门
})
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeServiceErr, "移除成员成功，但更新用户信息失败")
}
return resp.SetStatusWithMessage(basic.CodeOK, "移除成员成功")
}

2
server/ldap-admin/internal/logic/updateldapuserlogic.go
View File

@@ -68,6 +68,8 @@ func (l *UpdateLdapUserLogic) UpdateLdapUser(req *types.UpdateLdapUserReq, r *ht
"postalAddress": {req.Avatar},
"postalCode": {fmt.Sprintf("%d", req.Status)},
"employeeType": {fmt.Sprintf("%d", req.EmployeeType)},
"st": {fmt.Sprintf("%d", req.Gender)}, //性别
"title": {req.Birthday}, //生日
}
err := l.svcCtx.Ldap.Update(req.UserDN, attr)
if err != nil {

49
server/ldap-admin/internal/types/types.go
View File

@@ -144,15 +144,16 @@ type UpdateLdapOrganizationReq struct {
}
type CreateLdapUserReq struct {
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Password string `json:"password"` //密码
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeType int64 `json:"employee_type,options=1|2|3"` //1正式 2实习 3外包
GroupId int64 `json:"group_id,optional"` //授权分组id
OrganizationDNList []string `json:"organization_dn_list"` //属于哪些部门
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Password string `json:"password"` //密码
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeType int64 `json:"employee_type,options=1|2|3"` //1正式 2实习 3外包
GroupId int64 `json:"group_id,optional"` //授权分组id
Gender int64 `json:"gender,options=1|2|3"` //性别 1男 2女 3未知
Birthday string `json:"birthday"` //生日
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
}
type UpdateLdapUserReq struct {
@@ -163,6 +164,8 @@ type UpdateLdapUserReq struct {
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
EmployeeType int64 `json:"employee_type,options=1|2|3"` //1正式 2实习 3外包
GroupId int64 `json:"group_id,optional"` //权限分组id
Gender int64 `json:"gender,options=1|2|3"` //性别 1男 2女 3未知
Birthday string `json:"birthday"` //生日
}
type UpdateLdapUserPwdReq struct {
@@ -182,12 +185,14 @@ type GetLdapUserInfoReq struct {
type GetLdapUserInfoRsp struct {
UserId int64 `json:"user_id"`
UserDN string `json:"user_dn"`
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeTpye int64 `json:"employee_tpye"` //雇佣类型 1正式 2实习 3外包
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeTpye int64 `json:"employee_tpye"` //雇佣类型 1正式 2实习 3外包
Gender int64 `json:"gender,options=1|2|3"` //性别 1男 2女 3未知
Birthday string `json:"birthday"` //生日
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
}
type AddLdapOrganizationMemberReq struct {
@@ -211,12 +216,14 @@ type GetLdapOrganizationMembersRsp struct {
type GetLdapOrganizationMembersItem struct {
UserId int64 `json:"userId"`
UserDN string `json:"user_dn"`
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeType int64 `json:"employee_type"`
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
UserName string `json:"user_name"` //用户名
Email string `json:"email"` //邮箱
Mobile string `json:"mobile"` //手机号
Avatar string `json:"avatar"` //头像地址
EmployeeType int64 `json:"employee_type"` //雇佣类型
Gender int64 `json:"gender,options=1|2|3"` //性别 1男 2女 3未知
Birthday string `json:"birthday"` //生日
Status int64 `json:"status,options=0|1"` //状态 1正常0离职
}
type GetLdapUsersReq struct {

25
server/product/internal/logic/getproductmodelslogic.go
View File

@@ -57,12 +57,33 @@ func (l *GetProductModelsLogic) GetProductModels(req *types.GetProductModelsReq,
if len(productList) != len(productIds) {
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "some one product is invalid")
}
//获取产品所有的模型以及配件
modelList, err := l.svcCtx.AllModels.FsProductModel3d.GetAllByProductIdsTags(l.ctx, productIds, []int{constants.TAG_MODEL, constants.TAG_PARTS})
//根据模板标签获取开启了云渲染的模板列表
templateList, err := l.svcCtx.AllModels.FsProductTemplateV2.FindAllCloudRenderTemplateByProductIdsTemplateTag(l.ctx, productIds, req.TemplateTag, "", "id,product_id,model_id")
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get product template list")
}
modelIds := make([]int64, 0, len(templateList))
for _, v := range templateList {
modelIds = append(modelIds, *v.ModelId)
}
//获取模型列表
modelList, err := l.svcCtx.AllModels.FsProductModel3d.GetAllByIds(l.ctx, modelIds, "")
if err != nil {
logx.Error(err)
return resp.SetStatusWithMessage(basic.CodeDbSqlErr, "failed to get model list")
}
partIds := make([]int64, 0, len(modelList))
for _, v := range modelList {
if *v.PartId == 0 {
continue
}
partIds = append(partIds, *v.PartId)
}
//获取配件列表
partList, err := l.svcCtx.AllModels.FsProductModel3d.GetAllByIds(l.ctx, partIds, "")
//合并模型和配件
modelList = append(modelList, partList...)
mapProductModels := make(map[int64][]types.ModelItem)
lightIds := make([]int64, 0, len(modelList))
for _, v := range modelList {

3
server/product/internal/types/types.go
View File

@@ -172,7 +172,8 @@ type TemplateTagColorInfo struct {
}
type GetProductModelsReq struct {
ProductIds string `form:"product_ids"`
ProductIds string `form:"product_ids"`
TemplateTag string `form:"template_tag,optional"`
}
type ProductItem struct {

38
server/websocket/internal/logic/ws_render_image.go
View File

@@ -140,6 +140,11 @@ func (w *wsConnectItem) consumeRenderImageData() {
// 执行渲染任务
func (w *wsConnectItem) renderImage(renderImageData websocket_data.RenderImageReqMsg) {
defer func() {
if err := recover(); err != nil {
logx.Error("render image panic!!!!!!")
}
}()
if renderImageData.RenderData.Logo == "" {
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, "", "请传入logo", renderImageData.RenderData.ProductId, w.userId, w.guestId, 0, 0, 0, 0)
return
@@ -168,22 +173,6 @@ func (w *wsConnectItem) renderImage(renderImageData websocket_data.RenderImageRe
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, "", "选择的模板标签颜色索引越界", renderImageData.RenderData.ProductId, w.userId, w.guestId, 0, 0, 0, 0)
return
}
//获取产品信息(部分字段)
productInfo, err := w.logic.svcCtx.AllModels.FsProduct.FindOne(w.logic.ctx, renderImageData.RenderData.ProductId, "id,is_customization")
if err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) {
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, "", "该产品不存在", renderImageData.RenderData.ProductId, w.userId, w.guestId, 0, 0, 0, 0)
return
}
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, "", "获取产品失败", renderImageData.RenderData.ProductId, w.userId, w.guestId, 0, 0, 0, 0)
logx.Error(err)
return
}
//不可定制
if *productInfo.IsCustomization == 0 {
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, "", "该产品不可定制", renderImageData.RenderData.ProductId, w.userId, w.guestId, 0, 0, 0, 0)
return
}
//获取信息
productSize, productTemplate, model3dInfo, switchInfo, err := w.getProductRelationInfo(&renderImageData)
if err != nil {
@@ -292,15 +281,8 @@ func (w *wsConnectItem) renderImage(renderImageData websocket_data.RenderImageRe
taskId := w.genRenderTaskId(combineImage, renderImageData, model3dInfo, productTemplate, element)
//查询有没有缓存的资源,有就返回
resource, err := w.logic.svcCtx.AllModels.FsResource.FindOneById(w.logic.ctx, taskId)
if err != nil {
if !errors.Is(err, gorm.ErrRecordNotFound) {
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, taskId, "获取unity云渲染缓存失败", renderImageData.RenderData.ProductId, w.userId, w.guestId, productTemplate.Id, model3dInfo.Id, productSize.Id, *productTemplate.ElementModelId)
logx.Error("failed to find render resource:", err)
return
}
//无缓存
logx.Info("无缓存的渲染图，需要unity")
} else { //有缓存
switch err {
case nil: //有缓存
//如果没有debug或者debug模式下开启了缓存则返回缓存
if w.debug == nil || w.debug.IsCache == 1 {
//返回给客户端
@@ -316,6 +298,12 @@ func (w *wsConnectItem) renderImage(renderImageData websocket_data.RenderImageRe
return
}
//否则继续去unity
default: //无缓存
if !errors.Is(err, gorm.ErrRecordNotFound) {
w.renderErrResponse(renderImageData.RequestId, renderImageData.RenderData.TemplateTag, taskId, "获取unity云渲染缓存失败", renderImageData.RenderData.ProductId, w.userId, w.guestId, productTemplate.Id, model3dInfo.Id, productSize.Id, *productTemplate.ElementModelId)
logx.Error("failed to find render resource:", err)
return
}
}
//组装数据
if err = w.assembleRenderDataToUnity(taskId, resolution, combineImage, renderImageData, productTemplate, model3dInfo, element, productSize); err != nil {