123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936 |
- package report_approve
- import (
- "encoding/json"
- "eta/eta_api/controllers"
- "eta/eta_api/models"
- "eta/eta_api/models/report_approve"
- "eta/eta_api/services"
- "eta/eta_api/utils"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/paging"
- "sort"
- "strconv"
- "strings"
- "time"
- )
- type ReportApproveController struct {
- controllers.BaseAuthController
- }
- func (this *ReportApproveController) List() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- params := new(report_approve.ReportApproveListReq)
- if e := this.ParseForm(params); e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "入参解析失败, Err: " + e.Error()
- return
- }
- if params.ListType != 1 && params.ListType != 2 && params.ListType != 3 {
- br.Msg = "列表类型有误"
- return
- }
-
- cnClassifyIdName, enClassifyIdName := make(map[int]string), make(map[int]string)
- cnClassify, e := models.GetAllClassify()
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取中文分类失败, Err: " + e.Error()
- return
- }
- for _, v := range cnClassify {
- cnClassifyIdName[v.Id] = v.ClassifyName
- }
- enClassify, e := models.GetEnglishClassifies()
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取英文分类失败, Err: " + e.Error()
- return
- }
- enRootIdMap := make(map[int]int)
- for _, v := range enClassify {
- enClassifyIdName[v.Id] = v.ClassifyName
- enRootIdMap[v.Id] = v.RootId
- }
-
- var startSize int
- if params.PageSize <= 0 {
- params.PageSize = utils.PageSize20
- }
- if params.CurrentIndex <= 0 {
- params.CurrentIndex = 1
- }
- startSize = utils.StartIndex(params.CurrentIndex, params.PageSize)
- resp := new(report_approve.ReportApproveListResp)
- respTotal := 0
- respList := make([]*report_approve.ReportApproveItem, 0)
- timeField := map[int]string{1: fmt.Sprintf("a.%s", report_approve.ReportApproveCols.CreateTime), 2: fmt.Sprintf("a.%s", report_approve.ReportApproveRecordCols.ApproveTime), 3: fmt.Sprintf("b.%s", report_approve.ReportApproveCols.ApproveTime)}
- mineTimeField := map[int]string{1: fmt.Sprintf("%s", report_approve.ReportApproveCols.CreateTime), 3: fmt.Sprintf("%s", report_approve.ReportApproveCols.ApproveTime)}
- orderRules := map[int]string{1: "ASC", 2: "DESC"}
- ormList := make([]*report_approve.ReportApproveItemOrm, 0)
-
- if params.ListType == 1 {
- cond := fmt.Sprintf(` AND a.%s = ? AND b.%s = ? AND a.%s = ?`, report_approve.ReportApproveRecordCols.State, report_approve.ReportApproveCols.State, report_approve.ReportApproveRecordCols.ApproveUserId)
- pars := make([]interface{}, 0)
- pars = append(pars, report_approve.ReportApproveStateApproving, report_approve.ReportApproveStateApproving, sysUser.AdminId)
- order := ""
-
- if params.ReportType > 0 && params.ClassifySecondId > 0 {
- cond += fmt.Sprintf(` AND b.%s = ? AND b.%s = ?`, report_approve.ReportApproveCols.ReportType, report_approve.ReportApproveCols.ClassifySecondId)
- pars = append(pars, params.ReportType, params.ClassifySecondId)
- }
- if params.TimeType <= 0 {
- params.TimeType = 1
- }
- if params.TimeType == 1 && params.StartTime != "" && params.EndTime != "" {
- _, e := time.Parse(utils.FormatDate, params.StartTime)
- if e != nil {
- br.Msg = "开始时间格式有误"
- return
- }
- _, e = time.Parse(utils.FormatDate, params.EndTime)
- if e != nil {
- br.Msg = "结束时间格式有误"
- return
- }
- st := fmt.Sprintf("%s %s", params.StartTime, "00:00:00")
- ed := fmt.Sprintf("%s %s", params.EndTime, "23:59:59")
- cond += fmt.Sprintf(` AND (b.%s BETWEEN ? AND ?)`, report_approve.ReportApproveCols.CreateTime)
- pars = append(pars, st, ed)
- }
- params.Keyword = strings.TrimSpace(params.Keyword)
- if params.Keyword != "" {
- kw := fmt.Sprint("%", params.Keyword, "%")
- cond += fmt.Sprintf(` AND b.%s LIKE ?`, report_approve.ReportApproveCols.ReportTitle)
- pars = append(pars, kw)
- }
- if params.SortField > 0 && params.SortRule > 0 {
- orderField := timeField[params.SortField]
- if orderField == "" {
- br.Msg = "时间排序字段有误"
- return
- }
- orderRule := orderRules[params.SortRule]
- if orderRule == "" {
- br.Msg = "时间排序方式有误"
- return
- }
- order = fmt.Sprintf("%s %s", orderField, orderRule)
- }
- total, e := report_approve.GetApprovingReportApproveCount(cond, pars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApprovingReportApproveCount err: " + e.Error()
- return
- }
- respTotal = total
- list, e := report_approve.GetApprovingReportApprovePageList(cond, pars, order, startSize, params.PageSize)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApprovingReportApprovePageList err: " + e.Error()
- return
- }
- ormList = list
- }
-
- if params.ListType == 2 {
- cond := fmt.Sprintf(` AND a.%s = ? AND a.%s IN (%s)`, report_approve.ReportApproveRecordCols.ApproveUserId, report_approve.ReportApproveRecordCols.State, utils.GetOrmInReplace(2))
- pars := make([]interface{}, 0)
- pars = append(pars, sysUser.AdminId, []int{report_approve.ReportApproveStatePass, report_approve.ReportApproveStateRefuse})
- order := ""
-
- if params.ReportType > 0 && params.ClassifySecondId > 0 {
- cond += fmt.Sprintf(` AND b.%s = ? AND b.%s = ?`, report_approve.ReportApproveCols.ReportType, report_approve.ReportApproveCols.ClassifySecondId)
- pars = append(pars, params.ReportType, params.ClassifySecondId)
- }
- if params.TimeType > 0 && params.StartTime != "" && params.EndTime != "" {
- _, e := time.Parse(utils.FormatDate, params.StartTime)
- if e != nil {
- br.Msg = "开始时间格式有误"
- return
- }
- _, e = time.Parse(utils.FormatDate, params.EndTime)
- if e != nil {
- br.Msg = "结束时间格式有误"
- return
- }
- st := fmt.Sprintf("%s %s", params.StartTime, "00:00:00")
- ed := fmt.Sprintf("%s %s", params.EndTime, "23:59:59")
- cond += fmt.Sprintf(` AND (%s BETWEEN ? AND ?)`, timeField[params.TimeType])
- pars = append(pars, st, ed)
- }
- params.Keyword = strings.TrimSpace(params.Keyword)
- if params.Keyword != "" {
- kw := fmt.Sprint("%", params.Keyword, "%")
- cond += fmt.Sprintf(` AND b.%s LIKE ?`, report_approve.ReportApproveCols.ReportTitle)
- pars = append(pars, kw)
- }
- if params.SortField > 0 && params.SortRule > 0 {
- orderField := timeField[params.SortField]
- if orderField == "" {
- br.Msg = "时间排序字段有误"
- return
- }
- orderRule := orderRules[params.SortRule]
- if orderRule == "" {
- br.Msg = "时间排序方式有误"
- return
- }
- order = fmt.Sprintf("%s %s", orderField, orderRule)
- }
- if params.ApproveState > 0 {
- cond += fmt.Sprintf(` AND a.%s = ?`, report_approve.ReportApproveRecordCols.State)
- pars = append(pars, params.ApproveState)
- }
- total, e := report_approve.GetApprovedReportApproveCount(cond, pars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApprovedReportApproveCount err: " + e.Error()
- return
- }
- respTotal = total
- list, e := report_approve.GetApprovedReportApprovePageList(cond, pars, order, startSize, params.PageSize)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApprovedReportApprovePageList err: " + e.Error()
- return
- }
- ormList = list
- }
-
- if params.ListType == 3 {
- cond := fmt.Sprintf(` AND a.%s = ?`, report_approve.ReportApproveCols.ApplyUserId)
- pars := make([]interface{}, 0)
- pars = append(pars, sysUser.AdminId)
- order := ""
-
- if params.ReportType > 0 && params.ClassifySecondId > 0 {
- cond += fmt.Sprintf(` AND a.%s = ? AND a.%s = ?`, report_approve.ReportApproveCols.ReportType, report_approve.ReportApproveCols.ClassifySecondId)
- pars = append(pars, params.ReportType, params.ClassifySecondId)
- }
- if params.TimeType > 0 && params.StartTime != "" && params.EndTime != "" {
- _, e := time.Parse(utils.FormatDate, params.StartTime)
- if e != nil {
- br.Msg = "开始时间格式有误"
- return
- }
- _, e = time.Parse(utils.FormatDate, params.EndTime)
- if e != nil {
- br.Msg = "结束时间格式有误"
- return
- }
- st := fmt.Sprintf("%s %s", params.StartTime, "00:00:00")
- ed := fmt.Sprintf("%s %s", params.EndTime, "23:59:59")
- field := mineTimeField[params.TimeType]
- if field == "" {
- br.Msg = "筛选时间有误"
- return
- }
- cond += fmt.Sprintf(` AND (%s BETWEEN ? AND ?)`, field)
- pars = append(pars, st, ed)
- }
- params.Keyword = strings.TrimSpace(params.Keyword)
- if params.Keyword != "" {
- kw := fmt.Sprint("%", params.Keyword, "%")
- cond += fmt.Sprintf(` AND a.%s LIKE ?`, report_approve.ReportApproveCols.ReportTitle)
- pars = append(pars, kw)
- }
- if params.SortField > 0 && params.SortRule > 0 {
- orderField := mineTimeField[params.SortField]
- if orderField == "" {
- br.Msg = "时间排序字段有误"
- return
- }
- orderRule := orderRules[params.SortRule]
- if orderRule == "" {
- br.Msg = "时间排序方式有误"
- return
- }
- order = fmt.Sprintf("%s %s", orderField, orderRule)
- }
- if params.ApproveState > 0 {
- cond += fmt.Sprintf(` AND a.%s = ?`, report_approve.ReportApproveRecordCols.State)
- pars = append(pars, params.ApproveState)
- }
- total, e := report_approve.GetApplyReportApproveCount(cond, pars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApplyReportApproveCount err: " + e.Error()
- return
- }
- respTotal = total
- list, e := report_approve.GetApplyReportApprovePageList(cond, pars, order, startSize, params.PageSize)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "GetApplyReportApprovePageList err: " + e.Error()
- return
- }
- ormList = list
- }
-
- for _, v := range ormList {
- t := report_approve.FormatReportApproveOrm2Item(v)
- if v.ReportType == report_approve.FlowReportTypeEnglish {
- t.ReportClassify = fmt.Sprintf("%s/%s/%s/%s", report_approve.FlowReportTypeMap[v.ReportType], enClassifyIdName[enRootIdMap[v.ClassifySecondId]], enClassifyIdName[v.ClassifyFirstId], enClassifyIdName[v.ClassifySecondId])
- } else {
- t.ReportClassify = fmt.Sprintf("%s/%s/%s", report_approve.FlowReportTypeMap[v.ReportType], cnClassifyIdName[v.ClassifyFirstId], cnClassifyIdName[v.ClassifySecondId])
- }
- respList = append(respList, t)
- }
- page := paging.GetPaging(params.CurrentIndex, params.PageSize, respTotal)
- resp.Paging = page
- resp.List = respList
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ReportApproveController) Detail() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- approveId, _ := this.GetInt("ReportApproveId")
- if approveId <= 0 {
- br.Msg = "参数有误"
- br.ErrMsg = fmt.Sprintf("参数有误, ReportApproveId: %d", approveId)
- return
- }
- approveOb := new(report_approve.ReportApprove)
- approveItem, e := approveOb.GetItemById(approveId)
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "审批已被删除, 请刷新页面"
- return
- }
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批失败, Err: " + e.Error()
- return
- }
-
- detail := new(report_approve.ReportApproveDetail)
- detail.Approve = new(report_approve.ReportApproveDetailItem)
- detail.Approve.ReportApproveId = approveItem.ReportApproveId
- detail.Approve.State = approveItem.State
- detail.Approve.FlowId = approveItem.FlowId
- detail.Approve.FlowVersion = approveItem.FlowVersion
- detail.Approve.StartNodeId = approveItem.StartNodeId
- detail.Approve.CurrNodeId = approveItem.CurrNodeId
- detail.Approve.ApplyUserId = approveItem.ApplyUserId
- detail.Approve.ApplyUserName = approveItem.ApplyUserName
- detail.Approve.ApproveTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.ApproveTime)
- detail.Approve.CreateTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.CreateTime)
- detail.Approve.ModifyTime = utils.TimeTransferString(utils.FormatDateTime, approveItem.ModifyTime)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- nodeOb := new(report_approve.ReportApproveNode)
- nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, report_approve.ReportApproveNodeCols.ReportApproveFlowId, report_approve.ReportApproveNodeCols.CurrVersion)
- nodePars := make([]interface{}, 0)
- nodePars = append(nodePars, approveItem.FlowId, approveItem.FlowVersion)
- nodeItems, e := nodeOb.GetItemsByCondition(nodeCond, nodePars, []string{}, "")
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批节点失败, Err: " + e.Error()
- return
- }
-
- recordOb := new(report_approve.ReportApproveRecord)
- recordCond := fmt.Sprintf(` AND %s = ?`, report_approve.ReportApproveRecordCols.ReportApproveId)
- recordPars := make([]interface{}, 0)
- recordPars = append(recordPars, approveItem.ReportApproveId)
- recordItems, e := recordOb.GetItemsByCondition(recordCond, recordPars, []string{}, fmt.Sprintf("%s DESC", report_approve.ReportApproveRecordCols.ApproveTime))
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批记录失败, Err: " + e.Error()
- return
- }
- recordMap := make(map[string]*report_approve.ReportApproveRecord)
- for _, v := range recordItems {
- k := fmt.Sprintf("%d-%d", v.NodeId, v.ApproveUserId)
- recordMap[k] = v
- }
-
- detail.ApproveFlowNodes = make([]*report_approve.ReportApproveDetailNodes, 0)
- for _, v := range nodeItems {
- t := new(report_approve.ReportApproveDetailNodes)
- t.ReportApproveNodeId = v.ReportApproveNodeId
- t.ReportApproveFlowId = v.ReportApproveFlowId
- t.PrevNodeId = v.PrevNodeId
- t.NextNodeId = v.NextNodeId
- t.NodeType = v.NodeType
- t.ApproveType = v.ApproveType
- t.Users = make([]*report_approve.ReportApproveDetailNodeUser, 0)
- us := make([]*report_approve.ReportApproveNodeUserReq, 0)
- if v.Users != "" {
- e = json.Unmarshal([]byte(v.Users), &us)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "节点用户解析失败, Err: " + e.Error()
- return
- }
- }
- for _, vu := range us {
- u := new(report_approve.ReportApproveDetailNodeUser)
- u.UserType = vu.UserType
- u.UserId = vu.UserId
- u.UserName = vu.UserName
- u.Sort = vu.Sort
-
- k := fmt.Sprintf("%d-%d", v.ReportApproveNodeId, vu.UserId)
- r := recordMap[k]
- if r != nil {
- u.ApproveRecord = new(report_approve.ReportApproveDetailNodeUserRecord)
- u.ApproveRecord.ReportApproveRecordId = r.ReportApproveRecordId
- u.ApproveRecord.State = r.State
- u.ApproveRecord.ApproveUserId = r.ApproveUserId
- u.ApproveRecord.ApproveUserName = r.ApproveUserName
- u.ApproveRecord.ApproveRemark = r.ApproveRemark
- u.ApproveRecord.ApproveTime = utils.TimeTransferString(utils.FormatDateTime, r.ApproveTime)
- }
- t.Users = append(t.Users, u)
- }
- sort.Slice(t.Users, func(k, j int) bool {
- return t.Users[k].Sort < t.Users[j].Sort
- })
- detail.ApproveFlowNodes = append(detail.ApproveFlowNodes, t)
- }
-
- cnClassifyIdName, enClassifyIdName := make(map[int]string), make(map[int]string)
- cnClassify, e := models.GetAllClassify()
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取中文分类失败, Err: " + e.Error()
- return
- }
- for _, v := range cnClassify {
- cnClassifyIdName[v.Id] = v.ClassifyName
- }
- enClassify, e := models.GetEnglishClassifies()
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取英文分类失败, Err: " + e.Error()
- return
- }
- enRootIdMap := make(map[int]int)
- for _, v := range enClassify {
- enClassifyIdName[v.Id] = v.ClassifyName
- enRootIdMap[v.Id] = v.RootId
- }
- detail.Report = new(report_approve.ReportApproveDetailReport)
- detail.Report.ReportType = approveItem.ReportType
- detail.Report.ReportId = approveItem.ReportId
- detail.Report.ReportTitle = approveItem.ReportTitle
-
- if approveItem.ReportType == report_approve.FlowReportTypeChinese {
- detail.Report.ReportCode = utils.MD5(strconv.Itoa(approveItem.ReportId))
- detail.Report.ReportClassify = fmt.Sprintf("%s/%s/%s", report_approve.FlowReportTypeMap[approveItem.ReportType], cnClassifyIdName[approveItem.ClassifyFirstId], cnClassifyIdName[approveItem.ClassifySecondId])
- }
- if approveItem.ReportType == report_approve.FlowReportTypeEnglish {
- detail.Report.ReportCode = utils.MD5(strconv.Itoa(approveItem.ReportId))
- detail.Report.ReportClassify = fmt.Sprintf("%s/%s/%s/%s", report_approve.FlowReportTypeMap[approveItem.ReportType], enClassifyIdName[enRootIdMap[approveItem.ClassifySecondId]], enClassifyIdName[approveItem.ClassifyFirstId], enClassifyIdName[approveItem.ClassifySecondId])
- }
- if approveItem.ReportType == report_approve.FlowReportTypeSmart {
- detail.Report.ReportCode = utils.MD5(fmt.Sprint("smart_", approveItem.ReportId))
- detail.Report.ReportClassify = fmt.Sprintf("%s/%s/%s", report_approve.FlowReportTypeMap[approveItem.ReportType], cnClassifyIdName[approveItem.ClassifyFirstId], cnClassifyIdName[approveItem.ClassifySecondId])
- }
- br.Data = detail
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ReportApproveController) Approve() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req report_approve.ReportApprovePassReq
- if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
- br.Msg = "参数有误"
- br.ErrMsg = "参数解析失败, Err: " + e.Error()
- return
- }
- if req.ReportApproveId <= 0 {
- br.Msg = "参数有误"
- br.ErrMsg = fmt.Sprintf("参数有误, ReportApproveId: %d", req.ReportApproveId)
- return
- }
- approveOb := new(report_approve.ReportApprove)
- approveItem, e := approveOb.GetItemById(req.ReportApproveId)
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "审批不存在, 请刷新页面"
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "获取审批信息失败, Err: " + e.Error()
- return
- }
- if approveItem.State != report_approve.ReportApproveStateApproving {
- br.Msg = "审批状态有误, 请刷新页面"
- br.ErrMsg = fmt.Sprintf("审批状态有误, State: %d", approveItem.State)
- return
- }
-
- recordOb := new(report_approve.ReportApproveRecord)
- recordCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveRecordCols.ReportApproveId, report_approve.ReportApproveRecordCols.ApproveUserId, report_approve.ReportApproveRecordCols.State)
- recordPars := make([]interface{}, 0)
- recordPars = append(recordPars, approveItem.ReportApproveId, sysUser.AdminId, report_approve.ReportApproveStateApproving)
- recordItem, e := recordOb.GetItemByCondition(recordCond, recordPars, "")
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "无权审批"
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "获取审批记录失败, Err: " + e.Error()
- return
- }
-
- tips, e := services.PassReportApprove(approveItem, recordItem, sysUser.AdminId, req.ReportUrl)
- if e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "通过审批失败, Err: " + e.Error()
- return
- }
- if tips != "" {
- br.Msg = tips
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportApproveController) Refuse() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req report_approve.ReportApproveRefuseReq
- if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
- br.Msg = "参数有误"
- br.ErrMsg = "参数解析失败, Err: " + e.Error()
- return
- }
- if req.ReportApproveId <= 0 {
- br.Msg = "参数有误"
- br.ErrMsg = fmt.Sprintf("参数有误, ReportApproveId: %d", req.ReportApproveId)
- return
- }
- approveOb := new(report_approve.ReportApprove)
- approveItem, e := approveOb.GetItemById(req.ReportApproveId)
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "审批不存在, 请刷新页面"
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "获取审批信息失败, Err: " + e.Error()
- return
- }
- if approveItem.State != report_approve.ReportApproveStateApproving {
- br.Msg = "审批状态有误, 请刷新页面"
- br.ErrMsg = fmt.Sprintf("审批状态有误, State: %d", approveItem.State)
- return
- }
-
- recordOb := new(report_approve.ReportApproveRecord)
- recordCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveRecordCols.ReportApproveId, report_approve.ReportApproveRecordCols.ApproveUserId, report_approve.ReportApproveRecordCols.State)
- recordPars := make([]interface{}, 0)
- recordPars = append(recordPars, approveItem.ReportApproveId, sysUser.AdminId, report_approve.ReportApproveStateApproving)
- recordItem, e := recordOb.GetItemByCondition(recordCond, recordPars, "")
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "无权审批"
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "获取审批记录失败, Err: " + e.Error()
- return
- }
-
- if e = services.RefuseReportApprove(approveItem, recordItem, req.ApproveRemark, sysUser.AdminId); e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "驳回审批失败, Err: " + e.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportApproveController) Cancel() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req report_approve.ReportApproveCancelReq
- if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
- br.Msg = "参数有误"
- br.ErrMsg = "参数解析失败, Err: " + e.Error()
- return
- }
- if req.ReportApproveId <= 0 {
- br.Msg = "参数有误"
- br.ErrMsg = fmt.Sprintf("参数有误, ReportApproveId: %d", req.ReportApproveId)
- return
- }
- approveOb := new(report_approve.ReportApprove)
- approveItem, e := approveOb.GetItemById(req.ReportApproveId)
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "审批已被删除, 请刷新页面"
- return
- }
- br.Msg = "操作失败"
- br.ErrMsg = "获取审批失败, Err: " + e.Error()
- return
- }
- if approveItem.ApplyUserId != sysUser.AdminId {
- br.Msg = "非申请人不可撤销"
- return
- }
-
- e = services.CancelReportApprove(approveItem.ReportType, approveItem.ReportId, approveItem.ReportApproveId, sysUser.AdminId, sysUser.RealName)
- if e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "撤销审批失败, Err: " + e.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportApproveController) MessageList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- params := new(report_approve.ReportApproveListReq)
- if e := this.ParseForm(params); e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "入参解析失败, Err: " + e.Error()
- return
- }
-
- var startSize int
- if params.PageSize <= 0 {
- params.PageSize = utils.PageSize20
- }
- if params.CurrentIndex <= 0 {
- params.CurrentIndex = 1
- }
- startSize = utils.StartIndex(params.CurrentIndex, params.PageSize)
- resp := new(report_approve.ReportApproveMessageListResp)
- resp.List = make([]*report_approve.ReportApproveMessageItem, 0)
- cond := fmt.Sprintf(` AND %s = ?`, report_approve.ReportApproveMessageCols.ReceiveUserId)
- pars := make([]interface{}, 0)
- pars = append(pars, sysUser.AdminId)
- order := fmt.Sprintf(`%s ASC, %s DESC`, report_approve.ReportApproveMessageCols.IsRead, report_approve.ReportApproveMessageCols.CreateTime)
- messageOb := new(report_approve.ReportApproveMessage)
- total, e := messageOb.GetCountByCondition(cond, pars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批消息列表总数失败, Err: " + e.Error()
- return
- }
- list, e := messageOb.GetPageItemsByCondition(cond, pars, []string{}, order, startSize, params.PageSize)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批消息列表失败, Err: " + e.Error()
- return
- }
- for _, v := range list {
- t := report_approve.FormatReportApproveMessage2Item(v)
- resp.List = append(resp.List, t)
- }
-
- cond += fmt.Sprintf(` AND %s = ?`, report_approve.ReportApproveMessageCols.IsRead)
- pars = append(pars, 0)
- unreadTotal, e := messageOb.GetCountByCondition(cond, pars)
- if e != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批消息列表总数失败, Err: " + e.Error()
- return
- }
- resp.UnreadTotal = unreadTotal
- page := paging.GetPaging(params.CurrentIndex, params.PageSize, total)
- resp.Paging = page
- br.Data = resp
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- }
- func (this *ReportApproveController) MessageRead() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req report_approve.ReportApproveMessageReadReq
- if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
- br.Msg = "参数有误"
- br.ErrMsg = "参数解析失败, Err: " + e.Error()
- return
- }
- if req.MessageId <= 0 {
- br.Msg = "参数有误"
- br.ErrMsg = fmt.Sprintf("参数有误, MessageId: %d", req.MessageId)
- return
- }
- messageOb := new(report_approve.ReportApproveMessage)
- messageItem, e := messageOb.GetItemById(req.MessageId)
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- br.Msg = "消息不存在, 请刷新页面"
- return
- }
- br.Msg = "获取失败"
- br.ErrMsg = "获取审批消息失败, Err: " + e.Error()
- return
- }
- messageItem.IsRead = 1
- messageItem.ModifyTime = time.Now().Local()
- cols := []string{"IsRead", "ModifyTime"}
- if e = messageItem.Update(cols); e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "更新审批消息已读失败, Err: " + e.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportApproveController) CheckApproveOpen() {
- br := new(models.BaseResponse).Init()
- defer func() {
- if br.ErrMsg == "" {
- br.IsSendEmail = false
- }
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req report_approve.ReportApproveCheckApproveOpenReq
- if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
- br.Msg = "参数有误"
- br.ErrMsg = "参数解析失败, Err: " + e.Error()
- return
- }
-
- opening, e := services.CheckReportOpenApprove(req.ReportType, req.ClassifyFirstId, req.ClassifySecondId)
- if e != nil {
- br.Msg = "操作失败"
- br.ErrMsg = "校验报告是否开启审批流失败, Err: " + e.Error()
- return
- }
- br.Data = opening
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
|