1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087 |
- package controllers
- import (
- "encoding/json"
- "eta/eta_api/models"
- "eta/eta_api/models/report_approve"
- "eta/eta_api/services"
- "eta/eta_api/utils"
- "fmt"
- "time"
- )
- type ClassifyController struct {
- BaseAuthController
- }
- func (this *ClassifyController) Add() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.ClassifyAddReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
-
-
- if req.ClassifyName == "" {
- br.Msg = "分类名称不可为空"
- return
- }
-
- item, err := models.GetClassifyByName(req.ClassifyName, req.ParentId)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取分类信息失败,Err:" + err.Error()
- return
- }
- if item != nil {
- br.Msg = "分类名称:" + req.ClassifyName + "已存在"
- return
- }
- nowTime := time.Now().Local()
- classify := new(models.Classify)
- maxSort, e := classify.GetMaxSort()
- if e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "查询品种排序失败, Err: " + e.Error()
- return
- }
- classify.ClassifyName = req.ClassifyName
- classify.ParentId = req.ParentId
- classify.CreateTime = nowTime
- classify.ModifyTime = nowTime
- classify.Sort = maxSort + 1
- classify.Enabled = 1
- classify.ShowType = 1
-
- err = models.AddClassify(classify)
- if err != nil {
- br.Msg = "新增失败"
- br.ErrMsg = "新增失败,Err:" + err.Error()
- return
- }
-
-
-
- if classify.ParentId > 0 {
- err = models.EditChartPermissionSearchKeyWordMappingMulti(req.ClassifyName, req.ChartPermissionIdList)
- if err != nil {
- br.Msg = "修改分类权限失败"
- br.ErrMsg = "修改分类权限失败,Err:" + err.Error()
- return
- }
- go func() {
- _ = services.EditClassifyChartPermissionSync(req.ClassifyName)
- }()
- }
-
-
-
-
-
-
- br.Ret = 200
- br.Success = true
- br.Msg = "新增成功"
- }
- func (this *ClassifyController) CheckDeleteClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- classifyId, err := this.GetInt("ClassifyId")
- if classifyId <= 0 {
- br.Msg = "参数错误"
- return
- }
- classify, err := models.GetClassifyById(classifyId)
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- resp := new(models.CheckDeleteClassifyResp)
- if classify == nil {
- br.Msg = "分类不存在"
- resp.Code = 1
- resp.Msg = "分类不存在"
- br.Data = resp
- br.Ret = 200
- br.Success = true
- return
- }
-
- if classify.ParentId > 0 {
- count, err := models.GetReportCountByClassifyId(classifyId)
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- if count > 0 {
- resp.Code = 2
- resp.Msg = "该分类有关联报告,不允许删除"
- br.Data = resp
- br.Ret = 200
- br.Msg = "该分类有关联报告,不允许删除"
- br.Success = true
- return
- }
- } else {
- subCount, err := models.GetClassifySubCountByClassifyId(classifyId)
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- if subCount > 0 {
- resp.Code = 3
- resp.Msg = "二级分类有关联报告,不允许删除"
- br.Data = resp
- br.Ret = 200
- br.Msg = "二级分类有关联报告,不允许删除"
- br.Success = true
- return
- }
- subTotal, err := models.GetClassifySubCountByParentId(classifyId)
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- if subTotal > 0 {
- resp.Code = 4
- resp.Msg = "请先删除该分类下关联分类"
- br.Data = resp
- br.Ret = 200
- br.Msg = "请先删除该分类下关联分类"
- br.Success = true
- return
- }
- }
-
- flowOb := new(report_approve.ReportApproveFlow)
- flowCond := fmt.Sprintf(` AND (%s = ? OR %s = ?) AND (%s = ? OR %s = ?)`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId)
- flowPars := make([]interface{}, 0)
- flowPars = append(flowPars, report_approve.FlowReportTypeChinese, report_approve.FlowReportTypeSmart, classifyId, classifyId)
- flowCount, e := flowOb.GetCountByCondition(flowCond, flowPars)
- if e != nil {
- br.Msg = "检测失败"
- br.ErrMsg = "获取关联审批流失败, Err: " + e.Error()
- return
- }
- if flowCount > 0 {
- resp.Code = 5
- resp.Msg = "该分类关联审批流,不允许删除"
- br.Data = resp
- br.Ret = 200
- br.Msg = resp.Msg
- br.Success = true
- return
- }
- resp.Code = 0
- resp.Msg = "检测完成,可进行删除操作"
- br.Ret = 200
- br.Data = resp
- br.Success = true
- br.Msg = "检测成功"
- }
- func (this *ClassifyController) Delete() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.DeleteClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "参数错误"
- return
- }
- item, err := models.GetClassifyById(req.ClassifyId)
- if err != nil {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- if item == nil {
- br.Msg = "分类不存在"
- return
- }
- err = models.DeleteClassify(req.ClassifyId)
- if err != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "删除失败,Err:" + err.Error()
- return
- }
-
-
-
-
-
-
- br.Ret = 200
- br.Success = true
- br.Msg = "删除成功"
- }
- func (this *ClassifyController) Edit() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.EditClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
-
-
- if req.ClassifyId <= 0 {
- br.Msg = "参数错误"
- return
- }
- if req.ClassifyName == "" {
- br.Msg = "分类名称不可为空"
- return
- }
-
- item, err := models.GetClassifyById(req.ClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在, 或已被删除"
- br.ErrMsg = "获取分类信息失败, Err: " + err.Error()
- return
- }
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- originName := item.ClassifyName
- oldParentId := item.ParentId
-
-
- existName, e := models.GetClassifyByName(req.ClassifyName, item.ParentId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取重名分类失败, Err: " + err.Error()
- return
- }
- if existName != nil && existName.Id != item.Id {
- br.Msg = "分类名称:" + req.ClassifyName + "已存在"
- return
- }
- item.ClassifyName = req.ClassifyName
- item.ParentId = req.ParentId
- item.ModifyTime = time.Now().Local()
- cols := make([]string, 0)
- cols = append(cols, "ClassifyName", "ParentId", "ModifyTime")
- if e := item.UpdateClassify(cols); e != nil {
- br.Msg = "修改失败"
- br.ErrMsg = "修改失败,Err:" + e.Error()
- return
- }
-
-
- if req.ParentId > 0 {
-
- err = models.EditChartPermissionSearchKeyWordMappingMulti(item.ClassifyName, req.ChartPermissionIdList)
- if err != nil {
- br.Msg = "修改分类权限失败"
- br.ErrMsg = "修改分类权限失败,Err:" + err.Error()
- return
- }
- go func() {
- _ = services.EditClassifyChartPermissionSync(item.ClassifyName)
- }()
-
- }
-
- go func() {
- _ = services.AfterUpdateClassifyNameOrParent(item.Id, item.ParentId, oldParentId, originName, item.ClassifyName)
- }()
-
-
-
-
-
-
-
-
- br.Ret = 200
- br.Success = true
- br.Msg = "修改成功"
- }
- func (this *ClassifyController) ParentClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- items, err := models.ParentClassify()
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- classifyIds := make([]int, 0)
- for i := range items {
- classifyIds = append(classifyIds, items[i].Id)
- }
- classifyLen := len(classifyIds)
- if classifyLen == 0 {
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- return
- }
-
- menuListMap := make(map[int][]*models.ClassifyMenu, 0)
- var menuCond string
- var menuPars []interface{}
- menuCond += ` AND classify_id IN (` + utils.GetOrmInReplace(classifyLen) + `)`
- menuPars = append(menuPars, classifyIds)
- parentMenus, e := models.GetClassifyMenuList(menuCond, menuPars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取一级分类子目录列表失败"
- return
- }
- for i := range parentMenus {
- if menuListMap[parentMenus[i].ClassifyId] == nil {
- menuListMap[parentMenus[i].ClassifyId] = make([]*models.ClassifyMenu, 0)
- }
- menuListMap[parentMenus[i].ClassifyId] = append(menuListMap[parentMenus[i].ClassifyId], parentMenus[i])
- }
- resp := make([]*models.ClassifyItem, 0)
- for i := range items {
- resp = append(resp, &models.ClassifyItem{
- Classify: *items[i],
- ClassifyMenuList: menuListMap[items[i].Id],
- })
- }
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ClassifyController) FindByIdClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.FindByIdClassifyReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- items, err := models.FindByIdClassify(req.ClassifyId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- br.Data = items
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ClassifyController) ListClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- keyWord := this.GetString("KeyWord")
- companyType := this.GetString("CompanyType")
- hideDayWeek, _ := this.GetInt("HideDayWeek")
- reqEnabled, _ := this.GetInt("Enabled", -1)
-
- if utils.BusinessCode != utils.BusinessCodeRelease {
- hideDayWeek = 0
- }
- enabled := -1
- if reqEnabled == 1 {
- enabled = reqEnabled
- }
- list, err := models.GetClassifyList(keyWord, companyType, hideDayWeek, enabled)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- parentIds := make([]int, 0)
- for i := range list {
- parentIds = append(parentIds, list[i].Id)
- }
- parentIdLen := len(parentIds)
- if parentIdLen == 0 {
- resp := &models.ClassifyListResp{
- List: list,
- }
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- return
- }
-
- menuListMap := make(map[int][]*models.ClassifyMenu, 0)
- var menuCond string
- var menuPars []interface{}
- menuCond += ` AND classify_id IN (` + utils.GetOrmInReplace(parentIdLen) + `)`
- menuPars = append(menuPars, parentIds)
- parentMenus, e := models.GetClassifyMenuList(menuCond, menuPars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取一级分类子目录列表失败"
- return
- }
- for i := range parentMenus {
- if menuListMap[parentMenus[i].ClassifyId] == nil {
- menuListMap[parentMenus[i].ClassifyId] = make([]*models.ClassifyMenu, 0)
- }
- menuListMap[parentMenus[i].ClassifyId] = append(menuListMap[parentMenus[i].ClassifyId], parentMenus[i])
- }
-
- children, e := models.GetClassifyChildByParentIds(parentIds, keyWord, enabled)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取子分类失败"
- return
- }
- childrenIds := make([]int, 0)
- for i := range children {
- childrenIds = append(childrenIds, children[i].Id)
- }
- childrenIdsLen := len(childrenIds)
-
- relateMap := make(map[int]int, 0)
- if childrenIdsLen > 0 {
- var relateCond string
- var relatePars []interface{}
- relateCond += ` AND classify_id IN (` + utils.GetOrmInReplace(childrenIdsLen) + `)`
- relatePars = append(relatePars, childrenIds)
- relates, e := models.GetClassifyMenuRelationList(relateCond, relatePars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取二级分类子目录关联失败, Err: " + e.Error()
- return
- }
- for i := range relates {
- relateMap[relates[i].ClassifyId] = relates[i].MenuId
- }
- }
-
- permissionList, _ := models.GetAllPermissionMapping()
- classifyPermissionMap := make(map[string][]int, 0)
- if len(permissionList) > 0 {
- for _, v := range permissionList {
- classifyPermissionMap[v.KeyWord] = append(classifyPermissionMap[v.KeyWord], v.ChartPermissionId)
- }
- }
-
- childrenMap := make(map[int][]*models.ClassifyItem, 0)
- for i := range children {
- if childrenMap[children[i].ParentId] == nil {
- childrenMap[children[i].ParentId] = make([]*models.ClassifyItem, 0)
- }
- tmp := &models.ClassifyItem{
- Classify: *children[i],
- ClassifyMenuId: relateMap[children[i].Id],
- }
- if permissionIds, ok := classifyPermissionMap[children[i].ClassifyName]; ok {
- tmp.ChartPermissionIdList = permissionIds
- }
- childrenMap[children[i].ParentId] = append(childrenMap[children[i].ParentId], tmp)
- }
-
- for i := range list {
- list[i].ClassifyMenuList = menuListMap[list[i].Id]
- list[i].Child = childrenMap[list[i].Id]
- }
- resp := new(models.ClassifyListResp)
- resp.List = list
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ClassifyController) ClassifyPermission() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- classifyId, _ := this.GetInt("ClassifyId")
- if classifyId <= 0 {
- br.Msg = "参数错误"
- return
- }
-
- classifyInfo, err := models.GetClassifyById(classifyId)
- if err != nil {
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
-
- list, err := models.GetPermission(classifyInfo.ClassifyName)
- if err != nil {
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- br.Data = list
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ClassifyController) EditClassifyPermission() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.EditClassifyPermissionReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "参数错误"
- return
- }
- if len(req.ChartPermissionIdList) <= 0 {
- br.Msg = "请选择权限"
- return
- }
-
- classifyInfo, err := models.GetClassifyById(req.ClassifyId)
- if err != nil {
- br.Msg = "获取分类信息失败"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
-
- err = models.EditChartPermissionSearchKeyWordMappingMulti(classifyInfo.ClassifyName, req.ChartPermissionIdList)
- if err != nil {
- br.Msg = "修改分类权限失败"
- br.ErrMsg = "修改分类权限失败,Err:" + err.Error()
- return
- }
- go func() {
- _ = services.EditClassifyChartPermissionSync(classifyInfo.ClassifyName)
- }()
-
-
-
-
-
-
- br.Ret = 200
- br.Success = true
- br.Msg = "修改成功"
- }
- func (this *ClassifyController) TelListClassify() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- resp := make([]*models.SimpleClassifyList, 0)
- var condition, orderRule string
- var pars []interface{}
- if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox {
- condition += ` AND classify_name <> '晨报' AND classify_name <> '周报' `
- }
- telList, e := models.GetClassifyByCondition(condition, orderRule, pars)
- if e != nil {
- return
- }
- firstList := make([]*models.SimpleClassifyList, 0)
- secondList := make([]*models.SimpleClassifyList, 0)
- secondMap := make(map[int][]*models.SimpleClassifyList, 0)
- for i := range telList {
- if telList[i].ParentId == 0 {
- firstList = append(firstList, telList[i])
- } else {
- secondList = append(secondList, telList[i])
- secondMap[telList[i].ParentId] = append(secondMap[telList[i].ParentId], telList[i])
- }
- }
- for i := range firstList {
- firstList[i].Child = secondMap[firstList[i].Id]
- }
- resp = firstList
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ClassifyController) Move() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.ClassifyMoveReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "请选择分类"
- return
- }
- e, msg := services.MoveReportClassify(req)
- if e != nil {
- br.Msg = msg
- br.ErrMsg = "移动分类失败, Err: " + e.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ClassifyController) SetEnabled() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.ClassifySetEnabledReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ClassifyId <= 0 {
- br.Msg = "请选择分类"
- return
- }
- if req.Enabled != 0 && req.Enabled != 1 {
- br.Msg = "请选择正确的启用禁用状态"
- return
- }
- item, err := models.GetClassifyById(req.ClassifyId)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "分类不存在"
- return
- }
- br.Msg = "获取信息失败"
- br.ErrMsg = "获取信息失败,Err:" + err.Error()
- return
- }
- if item == nil {
- br.Msg = "分类不存在"
- return
- }
- ob := new(models.Classify)
-
- err = ob.SetEnabled(req.ClassifyId, req.Enabled)
- if err != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "操作失败,Err:" + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
|