应用集成平台服务端
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

862 lines
23 KiB

package taskflow
import (
"appPlatform/models/modelAppPlatform"
"appPlatform/models/modelshr"
"appPlatform/overall"
"appPlatform/overall/publicmethod"
"fmt"
"sort"
"strconv"
"strings"
"time"
)
/*
*
@ 作者: 秦东
@ 时间: 2023-11-01 10:28:48
@ 功能: 生成步进工作流
@ 参数
#creater 发起人信息
#orgId 执行行政组织
@ 返回值
#
@ 方法原型
#
*/
func (f *FlowMainBody) GenerateFlow(creater modelshr.ManCont, orgId int64, condition []ConditionListInfo) (workFlowInfo []RunFlow) {
//生成工作流
workFlowInfo = f.NodeConfig.CircularParsing(1, creater, orgId, condition)
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-01 10:52:35
@ 功能: 无限极循环节点
@ 参数
#step 步进值
#creater 当前操作人
#orgId 执行行政组织
#condition 判定条件值
@ 返回值
#
@ 方法原型
#
*/
func (n *NodePublicInfo) CircularParsing(step int, creater modelshr.ManCont, orgId int64, condition []ConditionListInfo) (nodeList []RunFlow) {
fmt.Printf("step: %v; name:%v; Types:%v\n", step, n.NodeName, n.Types)
var nodeInfo RunFlow
nodeInfo.Step = step
nodeInfo.Types = n.Types
nodeInfo.NodeKey = n.NodeNumber
nodeInfo.NodeName = n.NodeName
nodeInfo.Status = 1
nodeInfo.FromNode = n.FromNode
if n.SendBackNode == "" {
nodeInfo.GoBackNode = "beginnode"
} else {
nodeInfo.GoBackNode = n.SendBackNode
}
nodeInfo.ExamineMode = n.ExamineMode
nodeInfo.NoHanderAction = n.NoHanderAction
//判断节点类型
//0:发起人;1:审批;2:抄送;3:执行人;4:条件;5:路由
switch n.Types {
case 1, 3:
// 审批人设置 1:指定成员; 2:主管;3:行政岗位; 4:发起人自选; 5:发起人自己;6:连续多级主管;7:指定前置审批为本节点设置审批人;8:表单字段;9:权限矩阵
switch n.Settype {
case 1: //指定成员
nodeInfo.Operator = OperatorHandle(n.NodeUserList)
case 2: //主管
var levelUserList ContinuousMultiLevelSupervisor
levelUserList.MaxLevel = n.DirectorLevel
levelUserList.Continuity = false
if n.Attribute == 1 {
//申请人
nodeInfo.Operator = levelUserList.ObtainRelevantLevelLeaders(creater.AdminOrg)
} else {
//执行部门
nodeInfo.Operator = levelUserList.ObtainRelevantLevelLeaders(orgId)
}
case 3: //行政岗位
if n.Attribute == 1 {
nodeInfo.Operator = GainOrgPostUserList(creater.AdminOrg, n.NodeUserList)
} else {
nodeInfo.Operator = GainOrgPostUserList(orgId, n.NodeUserList)
}
case 4: //发起人自选
case 5: //发起人自己
var myCont modelshr.PersonArchives
myCont.GetCont(map[string]interface{}{"`id`": creater.Id}, "`key`", "`name`", "`number`", "`icon`", "`icon_photo`", "`wechat`", "`work_wechat`", "`admin_org`", "`position`", "`teamid`")
nodeInfo.Operator = append(nodeInfo.Operator, TransformPublicUs(myCont))
case 6: //连续多级主管
var levelUserList ContinuousMultiLevelSupervisor
levelUserList.MaxLevel = n.ExamineEndDirectorLevel
levelUserList.Continuity = true
if n.Attribute == 1 {
//申请人
nodeInfo.Operator = levelUserList.ObtainRelevantLevelLeaders(creater.AdminOrg)
} else {
//执行部门
nodeInfo.Operator = levelUserList.ObtainRelevantLevelLeaders(orgId)
}
case 7: //指定前置审批为本节点设置审批人
case 8: //表单字段
case 9: //权限矩阵
if n.Attribute == 1 {
nodeInfo.Operator = GainMatrixUserList(creater.AdminOrg, n.Matrix)
} else {
nodeInfo.Operator = GainMatrixUserList(orgId, n.Matrix)
}
default:
}
nodeList = append(nodeList, nodeInfo)
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step+1, creater, orgId, condition)...)
}
case 2:
nodeInfo.Operator = OperatorHandle(n.NodeUserList)
nodeList = append(nodeList, nodeInfo)
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step+1, creater, orgId, condition)...)
}
case 4:
case 5:
if len(n.ConditionNodes) > 0 {
//根据维度序号排序
sort.Slice(n.ConditionNodes, func(i, j int) bool {
return n.ConditionNodes[i].PriorityLevel < n.ConditionNodes[j].PriorityLevel
})
lastStrp := step
for _, pv := range n.ConditionNodes { //循环解析相关条件
routerNodes := pv.ResolveRouting(step, creater, orgId, condition)
if len(routerNodes) > 0 {
lastStrp = lastStrp + len(routerNodes)
nodeList = append(nodeList, routerNodes...)
break
}
}
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(lastStrp, creater, orgId, condition)...)
}
} else {
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step+1, creater, orgId, condition)...)
}
}
default:
//发起人
var originator OperatorList
originator.Id = strconv.FormatInt(creater.Key, 10) //操作人ID
originator.Types = 1 //1:人员;2:角色;3:行政组织
originator.Name = creater.Name //操作人姓名
originator.Number = creater.Number //操作人工号
originator.Icon = creater.Icon //操作人头像
originator.IconBase64 = creater.IconPhpto //操作人头像
originator.Wechat = creater.Wechat //微信Openid
if creater.WorkWechat != "" {
originator.Wechat = creater.WorkWechat //企业微信Openid
}
_, companyId, _, _, _ := publicmethod.GetOrgStructurees(creater.AdminOrg)
originator.DepartmentId = companyId //分厂Id
if companyId != 0 {
var orgCont modelshr.AdministrativeOrganization
orgCont.GetCont(map[string]interface{}{"`id`": companyId}, "`name`")
originator.DepartmentName = orgCont.Name //分厂名称
}
//获取岗位
if creater.Position != 0 {
var postCont modelshr.Position
postCont.GetCont(map[string]interface{}{"`id`": creater.Position}, "`name`")
originator.PostId = creater.Position //职务Id
originator.PostName = postCont.Name //职务名称
}
if creater.TeamId != 0 {
var teamCont modelshr.TeamGroup
teamCont.GetCont(map[string]interface{}{"`id`": creater.TeamId}, "`name`")
originator.Tema = creater.TeamId //班组Id
originator.TemaName = teamCont.Name //班组名称
}
var logCont LogList
logCont.State = 1 //状态 1、未操作;2、通过;3、驳回
logCont.TimeVal = publicmethod.UnixTimeToDay(time.Now().Unix(), 24)
// originator.LogList = append(originator.LogList, logCont) //操作记录
nodeInfo.Operator = append(nodeInfo.Operator, originator)
nodeList = append(nodeList, nodeInfo)
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step+1, creater, orgId, condition)...)
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-16 09:44:25
@ 功能: 解析条件
@ 参数
#step 步进值
#creater 当前操作人
#orgId 执行行政组织
#condition 判定条件值
@ 返回值
#nodeList 操作节点
@ 方法原型
#
*/
func (n *NodePublicInfoES) ResolveRouting(step int, creater modelshr.ManCont, orgId int64, condition []ConditionListInfo) (nodeList []RunFlow) {
// fmt.Printf("解析条件---》%v\n", n.NodeName)
if len(n.ConditionList) > 0 {
// fmt.Printf("解析条件--1-》%v\n", n.ConditionList)
termAry := 0
for _, v := range n.ConditionList {
//条件类型:1:人员、行政组织、角色;2:自定义字段;3:关联表单字段;
switch v.Types {
case 1:
if JudgingTermPeoOrgRoles(v.NodeUserList, creater) { //判断申请人是否在可允许范围之内
// termAry = append(termAry, 1)
termAry++
}
case 2:
if JudgingCustomConditions(v.CustomFields, condition) {
termAry++
}
case 3:
if ProcessMultipleSelectionResults(v, condition) { //判断表单
// termAry = append(termAry, 3)
termAry++
}
default:
}
}
// fmt.Printf("termAry:%v----->%v\n", len(n.ConditionList), termAry)
// if len(termAry) == len(n.ConditionList) {
if termAry == len(n.ConditionList) {
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step, creater, orgId, condition)...)
}
}
} else {
if n.ChildNode != nil {
nodeList = append(nodeList, n.ChildNode.CircularParsing(step, creater, orgId, condition)...)
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-17 09:20:37
@ 功能: 处理自定义条件
@ 参数
#CustomFields 条件集合
#presetVal 提交项目
@ 返回值
#isTrue true条件符合验证通过false不通过
@ 方法原型
#
*/
func JudgingCustomConditions(customFields []CustomFieldsInfo, presetVal []ConditionListInfo) (isTrue bool) {
isTrue = false
if len(presetVal) < 1 {
return
}
var subCustomFields []CustomFieldsInfo
for _, v := range presetVal {
if v.Types == 2 && len(v.CustomFields) > 0 {
subCustomFields = append(subCustomFields, v.CustomFields...)
}
}
if len(subCustomFields) < 1 {
return
}
isOk := 0
for _, s := range subCustomFields { //提交的条件结果
for _, c := range customFields { //预设定条件
if s.Wordfield == c.Wordfield {
switch c.OptType {
case "1": //小于
sLeftVal, sErr := strconv.ParseFloat(s.LeftVal, 64)
if sErr == nil {
cLeftVal, cErr := strconv.ParseFloat(c.LeftVal, 64)
if cErr == nil {
if sLeftVal < cLeftVal {
isOk++
}
}
}
case "2": //大于
sLeftVal, sErr := strconv.ParseFloat(s.LeftVal, 64)
if sErr == nil {
cLeftVal, cErr := strconv.ParseFloat(c.LeftVal, 64)
if cErr == nil {
if sLeftVal > cLeftVal {
isOk++
}
}
}
case "3": //小于等于
sLeftVal, sErr := strconv.ParseFloat(s.LeftVal, 64)
if sErr == nil {
cLeftVal, cErr := strconv.ParseFloat(c.LeftVal, 64)
if cErr == nil {
if sLeftVal <= cLeftVal {
isOk++
}
}
}
case "4": //等于
sLeftVal, sErr := strconv.ParseFloat(s.LeftVal, 64)
if sErr == nil {
cLeftVal, cErr := strconv.ParseFloat(c.LeftVal, 64)
if cErr == nil {
if sLeftVal == cLeftVal {
isOk++
}
}
}
case "5": //大于等于
sLeftVal, sErr := strconv.ParseFloat(s.LeftVal, 64)
if sErr == nil {
cLeftVal, cErr := strconv.ParseFloat(c.LeftVal, 64)
if cErr == nil {
if sLeftVal >= cLeftVal {
isOk++
}
}
}
case "6": //介于两个数之间
leftIsOk := false
rightIsOk := false
sLeftVal, sLErr := strconv.ParseFloat(s.LeftVal, 64)
sRightVal, sRErr := strconv.ParseFloat(s.RightVal, 64)
if sLErr == nil && sRErr == nil {
cLeftVal, cLErr := strconv.ParseFloat(c.LeftVal, 64)
cRightVal, cRErr := strconv.ParseFloat(c.RightVal, 64)
if cLErr == nil && cRErr == nil {
if c.LeftOptType == "1" {
if sLeftVal > cLeftVal {
leftIsOk = true
}
} else {
if sLeftVal >= cLeftVal {
leftIsOk = true
}
}
if c.RightOptType == "1" {
if sRightVal < cRightVal {
rightIsOk = true
}
} else {
if sRightVal <= cRightVal {
rightIsOk = true
}
}
}
}
if leftIsOk && rightIsOk {
isOk++
}
case "7": //包含
setUpValAry := strings.Split(c.LeftVal, ",")
// fmt.Printf("处理自定义条件-abc->%v-->%v-->%v-->%v\n", s.Wordfield, c.Wordfield, setUpValAry, publicmethod.IsInTrue[string](s.LeftVal, setUpValAry))
if publicmethod.IsInTrue[string](s.LeftVal, setUpValAry) {
isOk++
}
case "8": //不包含
setUpValAry := strings.Split(c.LeftVal, ",")
if !publicmethod.IsInTrue[string](s.LeftVal, setUpValAry) {
isOk++
}
default:
}
}
}
}
// fmt.Printf("处理自定义条件-->%v-->%v\n", isOk, len(customFields))
if isOk == len(customFields) {
isTrue = true
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-17 08:48:24
@ 功能: 处理选择条件
@ 参数
#judging 选择条件
#presetVal 提交的判断提交
@ 返回值
#isTrue true条件符合验证通过false不通过
@ 方法原型
#
*/
func ProcessMultipleSelectionResults(judging ConditionListInfo, presetVal []ConditionListInfo) (isTrue bool) {
isTrue = false
if len(presetVal) < 1 {
return
}
for _, v := range presetVal {
if v.Types == 3 && judging.Factorid == v.Factorid {
if judging.IsCheckbox {
//多选
if len(v.Answers) <= len(judging.Answers) { //判断答案个数是否小于等于设定条件值个数
isTrue = true
for i := 0; i < len(v.Answers); i++ {
if !publicmethod.IsInTrue[string](v.Answers[i], judging.Answers) {
isTrue = false
}
}
}
} else { //单选
if len(v.Answers) == len(judging.Answers) {
isTrue = true
for i := 0; i < len(v.Answers); i++ {
if !publicmethod.IsInTrue[string](v.Answers[i], judging.Answers) {
isTrue = false
}
}
}
}
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-17 08:12:29
@ 功能: 转变人员信息
@ 参数
#condition 判断条件中的人员信息
@ 返回值
#usAry 转变后的人员列表
@ 方法原型
#
*/
func CondToNodeUser(condition []FlowPermissionInfo) (usAry []NodeUserListInfo) {
if len(condition) < 1 {
return
}
for _, v := range condition {
var usCont NodeUserListInfo
usCont.Types = v.Types // 1:人员;2:角色;3:行政组织;4:职务
usCont.TargetId = v.TargetId // /相关内容识别符
usCont.Name = v.Name //相关内容名称
usCont.Icon = v.Icon //头像
usCont.IconToBase64 = v.IconToBase64 //头像Base64
usAry = append(usAry, usCont)
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-17 08:04:57
@ 功能: 判断路由条件人员行政组织角色是否满足
@ 参数
#term 预设可操作此节点的人
#creater 流程发起人
@ 返回值
#isTrue true条件符合验证通过false不通过
@ 方法原型
#
*/
func JudgingTermPeoOrgRoles(term []FlowPermissionInfo, creater modelshr.ManCont) (isTrue bool) {
isTrue = false
usList := CondToNodeUser(term)
operatorList := OperatorHandle(usList) //获取所有可操作的人
var usKey []string
for i := 0; i < len(operatorList); i++ { //提取可操作人的唯一识别符
if !publicmethod.IsInTrue[string](operatorList[i].Id, usKey) {
usKey = append(usKey, operatorList[i].Id)
}
}
creKey := strconv.FormatInt(creater.Key, 10)
if publicmethod.IsInTrue[string](creKey, usKey) { //判断当前操作人是否在可执行人当中
isTrue = true
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 14:57:03
@ 功能: 矩阵拆分
@ 参数
#
@ 返回值
#
@ 方法原型
#
*/
func GainMatrixUserList(orgId int64, matrix MatrixInfo) (UserList []OperatorList) {
allOrgId := publicmethod.HaveAllOrgRelation(orgId) //获取全部归属行政单位
fmt.Printf("全部行政组织:%v---->%v\n", orgId, allOrgId)
var keyVal int64
err := overall.CONSTANT_DB_AppPlatform.Model(&modelAppPlatform.MatrixHandler{}).Select("`number`").Where("`types` = 1 AND `mc_id` = ? AND `mh_id` = ? AND `hand_id` IN ?", matrix.MatrixId, matrix.FactorId, allOrgId).First(&keyVal).Error
if err != nil {
return
}
var userKeys []int64
err = overall.CONSTANT_DB_AppPlatform.Model(&modelAppPlatform.MatrixHandler{}).Select("`hand_id`").Where("`types` = 2 AND `mc_id` = ? AND `mh_id` = ? AND `number` = ?", matrix.MatrixId, matrix.OutcomeId, keyVal).Find(&userKeys).Error
if err != nil || len(userKeys) < 1 {
return
}
var userInfoAry []modelshr.PersonArchives
overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`,`name`,`number`,`icon`,`icon_photo`,`wechat`,`work_wechat`,`admin_org`,`position`,`teamid`").Where("`key` IN ? AND `emp_type` BETWEEN ? AND ?", userKeys, 1, 10).Find(&userInfoAry)
if len(userInfoAry) > 0 {
for _, uv := range userInfoAry {
UserList = append(UserList, TransformPublicUs(uv))
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 13:24:29
@ 功能: 岗位操作人解析
@ 参数
#orgId 行政组织
#approvers 审批人岗位
@ 返回值
#UserList 操作人
@ 方法原型
#
*/
func GainOrgPostUserList(orgId int64, approvers []NodeUserListInfo) (UserList []OperatorList) {
if len(approvers) > 0 {
allOrgId := publicmethod.HaveAllOrgRelation(orgId) //获取全部归属行政单位
var userAry MultiLeveUserList
for _, v := range approvers { //逐行分析职务
if v.Types == 4 {
syncSeting.Add(1)
go userAry.GainOrgPostPeople(allOrgId, v.Options)
}
}
syncSeting.Wait()
UserList = userAry.UserList
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 14:30:08
@ 功能: 获取职务相关人员
@ 参数
#orgId 行政组织
#options 操作职务
@ 返回值
#
@ 方法原型
#
*/
func (m *MultiLeveUserList) GainOrgPostPeople(orgId []int64, options []OptionsInfo) {
if len(options) > 0 { //判断职务编号
var postId []int
for i := 0; i < len(options); i++ {
piVal, _ := strconv.Atoi(options[i].Value)
if !publicmethod.IsInTrue[int](piVal, postId) {
postId = append(postId, piVal)
}
}
if len(postId) > 0 {
var userInfoAry []modelshr.PersonArchives
overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`,`name`,`number`,`icon`,`icon_photo`,`wechat`,`work_wechat`,`admin_org`,`position`,`teamid`").Where("`person_in_charge` = 1 AND `admin_org` IN ? AND position = ? AND `emp_type` BETWEEN ? AND ?", orgId, postId, 1, 10).Find(&userInfoAry)
if len(userInfoAry) > 0 {
for _, uv := range userInfoAry {
m.UserList = append(m.UserList, TransformPublicUs(uv))
}
}
}
}
defer syncSeting.Done()
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 11:05:55
@ 功能: 获取单级或多级主管审批人
@ 参数
#orgId 行政组织
@ 返回值
#
@ 方法原型
#
*/
func (c *ContinuousMultiLevelSupervisor) ObtainRelevantLevelLeaders(orgId int64) (UserList []OperatorList) {
if c.MaxLevel == 0 {
c.MaxLevel = 1
}
c.ObtainRelevantLevelLeadersUser(1, orgId)
if len(c.UserList) > 0 {
if c.Continuity { //连续层级主管
sort.Slice(c.UserList, func(i, j int) bool {
return c.UserList[i].Level < c.UserList[j].Level
})
for _, v := range c.UserList {
UserList = append(UserList, v.UserList...)
}
} else { //单一层级
for i := c.MaxLevel; i > 0; i-- {
UserList = GainOneLevel(i, c.UserList)
if len(UserList) > 0 {
return
}
}
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 11:50:01
@ 功能:
@ 参数
#level 层级
#UserList 操作人信息
@ 返回值
#UserAry 操作人列表
@ 方法原型
#
*/
func GainOneLevel(level int, UserList []MultiLeveUserList) (UserAry []OperatorList) {
for _, v := range UserList {
if v.Level == level {
UserAry = v.UserList
return
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 11:49:24
@ 功能: 循环获取主管层级负责人
@ 参数
#level 当前主管层级
#orgId 目标行政组织
@ 返回值
#
@ 方法原型
#
*/
func (c *ContinuousMultiLevelSupervisor) ObtainRelevantLevelLeadersUser(level int, orgId int64) {
var orgInfo modelshr.AdministrativeOrganization
err := orgInfo.GetCont(map[string]interface{}{"`id`": orgId}, "`superior`")
if err == nil {
var userList []modelshr.PersonArchives
err = overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`,`name`,`number`,`icon`,`icon_photo`,`wechat`,`work_wechat`,`admin_org`,`position`,`teamid`").Where("`person_in_charge` = 1 AND `admin_org` = ? AND `emp_type` BETWEEN ? AND ?", orgId, 1, 10).Find(&userList).Error
if err == nil {
var userAry MultiLeveUserList
userAry.Level = level
for _, v := range userList {
userAry.UserList = append(userAry.UserList, TransformPublicUs(v))
}
c.UserList = append(c.UserList, userAry)
}
nextLevel := level + 1
if nextLevel <= c.MaxLevel {
c.ObtainRelevantLevelLeadersUser(nextLevel, orgInfo.Superior)
}
}
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-01 16:16:33
@ 功能: 处理操作人
@ 参数
#userList 节点处理人
@ 返回值
#userAry 人员列表信息
@ 方法原型
#
*/
func OperatorHandle(userList []NodeUserListInfo) (userAry []OperatorList) {
if len(userList) > 0 {
var userIdAry []int64
for _, v := range userList {
switch v.Types { //1:人员;2:角色;3:行政组织
case 1:
myKey, myErr := strconv.ParseInt(v.TargetId, 10, 64)
if myErr == nil {
userIdAry = append(userIdAry, myKey)
}
case 2: //角色
var usIdList []int64
overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`").Where("FIND_IN_SET(?,`role`) AND `emp_type` BETWEEN ? AND ?", v.TargetId, 1, 10).Find(&usIdList)
if len(usIdList) > 0 {
userIdAry = append(userIdAry, usIdList...)
}
case 3: //行政组织
myKey, myErr := strconv.ParseInt(v.TargetId, 10, 64)
if myErr == nil {
var sunOrg publicmethod.GetOrgAllParent
sunOrg.GetOrgSonAllId(myKey)
sunOrg.Id = append(sunOrg.Id, myKey)
var usIdList []int64
overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`").Where("`admin_org` IN ? AND `emp_type` BETWEEN ? AND ?", sunOrg.Id, 1, 10).Find(&usIdList)
if len(usIdList) > 0 {
userIdAry = append(userIdAry, usIdList...)
}
}
default:
}
}
var userContMap []modelshr.PersonArchives
overall.CONSTANT_DB_HR.Model(&modelshr.PersonArchives{}).Select("`key`,`name`,`number`,`icon`,`icon_photo`,`wechat`,`work_wechat`,`admin_org`,`position`,`teamid`").Where("`key` IN ?", userIdAry).Find(&userContMap)
for _, v := range userContMap {
userAry = append(userAry, TransformPublicUs(v))
}
}
return
}
/*
*
@ 作者: 秦东
@ 时间: 2023-11-15 11:37:00
@ 功能: 装通用执行人数据
@ 参数
#v 人员信息
@ 返回值
#userCont 统一操作人信息
@ 方法原型
#
*/
func TransformPublicUs(v modelshr.PersonArchives) (userCont OperatorList) {
userCont.Id = strconv.FormatInt(v.Key, 10)
userCont.Types = 1 //1:人员;2:角色;3:行政组织
userCont.Name = v.Name //操作人姓名
userCont.Number = v.Number //操作人工号
userCont.Icon = v.Icon //操作人头像
userCont.IconBase64 = v.IconPhoto //操作人头像
userCont.Wechat = v.Wechat //微信Openid
if v.WorkWechat != "" {
userCont.Wechat = v.WorkWechat //微信Openid
}
_, companyId, _, _, _ := publicmethod.GetOrgStructurees(v.AdminOrg)
userCont.DepartmentId = companyId //分厂Id
if companyId != 0 {
var orgCont modelshr.AdministrativeOrganization
orgCont.GetCont(map[string]interface{}{"`id`": companyId}, "`name`")
userCont.DepartmentName = orgCont.Name //分厂名称
}
//获取岗位
if v.Position != 0 {
var postCont modelshr.Position
postCont.GetCont(map[string]interface{}{"`id`": v.Position}, "`name`")
userCont.PostId = v.Position //职务Id
userCont.PostName = postCont.Name //职务名称
}
if v.TeamId != 0 {
var teamCont modelshr.TeamGroup
teamCont.GetCont(map[string]interface{}{"`id`": v.TeamId}, "`name`")
userCont.Tema = v.TeamId //班组Id
userCont.TemaName = teamCont.Name //班组名称
}
return
}