approval_new.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  1. package controllers
  2. import (
  3. "encoding/json"
  4. approval2 "hongze/hongze_mobile_admin/models/request/approval"
  5. approvalResp "hongze/hongze_mobile_admin/models/response/approval"
  6. "hongze/hongze_mobile_admin/models/tables/company_approval"
  7. "hongze/hongze_mobile_admin/models/tables/company_delay_permission"
  8. "hongze/hongze_mobile_admin/models/tables/company_product"
  9. "hongze/hongze_mobile_admin/models/tables/company_report_permission"
  10. "hongze/hongze_mobile_admin/models/tables/contract"
  11. "hongze/hongze_mobile_admin/models/tables/contract_approval"
  12. "hongze/hongze_mobile_admin/models/tables/contract_approval_record"
  13. company_apply "hongze/hongze_mobile_admin/services/company_approval"
  14. "hongze/hongze_mobile_admin/utils"
  15. "rdluck_tools/paging"
  16. "strconv"
  17. "strings"
  18. "time"
  19. )
  20. // ListV2
  21. // @Title 获取审批列表接口
  22. // @Description 获取审批列表接口
  23. // @Param PageSize query int true "每页数据条数"
  24. // @Param CurrentIndex query int true "当前页页码,从1开始"
  25. // @Param Status query string true "状态:'待审批','已审批','驳回','已撤回'"
  26. // @Param KeyWord query string true "搜索关键词"
  27. // @Param Keyword query string true "搜索关键词"
  28. // @Param KeywordEq query string true "搜索关键词(全等)"
  29. // @Success 200 {object} approval.CompanyApprovalListResp
  30. // @router /list [get]
  31. func (c *ApprovalCommon) ListV2() {
  32. sysUser := c.AdminWx
  33. pageSize, _ := c.GetInt("PageSize")
  34. currentIndex, _ := c.GetInt("CurrentIndex")
  35. status := c.GetString("Status")
  36. keyword := c.GetString("Keyword")
  37. keywordEq := c.GetString("KeywordEq")
  38. condition := ""
  39. pars := make([]interface{}, 0)
  40. ////如果不是超管或者合规,那么只能查看自己的合同
  41. //join表字段
  42. //归属
  43. if status == "待审批" {
  44. condition += ` AND ( (((c.apply_user_id = ? and a.start_node_id = a.curr_node_id) OR (f.approve_user_id = ? and a.curr_node_id=f.node_id ) ) and c.approve_status="待审批") or (f.approve_user_id = ? and a.curr_node_id > f.node_id and f.node_type="cc") )`
  45. pars = append(pars, sysUser.AdminId, sysUser.AdminId, sysUser.AdminId)
  46. } else {
  47. condition += ` AND (c.apply_user_id = ? or (f.approve_user_id = ? and f.node_id <= a.curr_node_id) )`
  48. pars = append(pars, sysUser.AdminId, sysUser.AdminId)
  49. }
  50. //审批状态
  51. if status != "" {
  52. if status == "已审批" {
  53. condition += ` AND c.approve_status in ("已审批","驳回") `
  54. } else {
  55. condition += ` AND c.approve_status = ? `
  56. if status == "处理中" {
  57. pars = append(pars, "待审批")
  58. } else {
  59. pars = append(pars, status)
  60. }
  61. }
  62. } else {
  63. condition += ` AND c.approve_status != "已撤回" `
  64. }
  65. //关键字
  66. if keyword != "" {
  67. condition += ` AND ( e.company_name LIKE '%` + keyword + `%' OR e.credit_code LIKE '%` + keyword + `%' ) `
  68. }
  69. //关键字(全等)
  70. if keywordEq != "" {
  71. condition += ` AND e.company_name =? `
  72. pars = append(pars, keywordEq)
  73. }
  74. var startSize int
  75. if pageSize <= 0 {
  76. pageSize = utils.PageSize20
  77. }
  78. if currentIndex <= 0 {
  79. currentIndex = 1
  80. }
  81. startSize = paging.StartIndex(currentIndex, pageSize)
  82. total, err := contract_approval.GetCompanyApprovalCount(condition, pars)
  83. if err != nil {
  84. c.FailWithMessage("获取失败", "获取数据总数失败,Err:"+err.Error())
  85. return
  86. }
  87. list, err := contract_approval.GetCompanyApprovalList(condition, pars, startSize, pageSize)
  88. if err != nil {
  89. c.FailWithMessage("获取审批列表失败!", "获取审批列表失败,Err:"+err.Error())
  90. return
  91. }
  92. respList := make([]*company_approval.CompanyApprovalList, 0)
  93. listLen := len(list)
  94. if listLen > 0 {
  95. contractApprovalIdSlice := make([]string, 0)
  96. for i := 0; i < len(list); i++ {
  97. contractApprovalIdSlice = append(contractApprovalIdSlice, strconv.Itoa(list[i].ContractApprovalId))
  98. }
  99. contractApprovalIdStr := strings.Join(contractApprovalIdSlice, ",")
  100. //获取审批流列表数据
  101. contractApprovalRecordList, err := contract_approval_record.GetContractApprovalRecordList(contractApprovalIdStr, sysUser.AdminId)
  102. if err != nil {
  103. c.FailWithMessage("获取审批流列表失败!", "获取审批流列表失败,Err:"+err.Error())
  104. return
  105. }
  106. contractApprovalRecordMap := make(map[int]*contract_approval_record.ContractApprovalRecord)
  107. for i := 0; i < len(contractApprovalRecordList); i++ {
  108. contractApprovalRecordMap[contractApprovalRecordList[i].ContractApprovalId] = contractApprovalRecordList[i]
  109. }
  110. for i := 0; i < len(list); i++ {
  111. item := list[i]
  112. list[i].StartDateStr = item.StartDate.Format(utils.FormatDate)
  113. list[i].EndDateStr = item.EndDate.Format(utils.FormatDate)
  114. list[i].CreateTimeStr = item.CreateTime.Format(utils.FormatDateTime)
  115. list[i].ModifyTimeStr = item.ModifyTime.Format(utils.FormatDateTime)
  116. list[i].ApproveTimeStr = item.ApproveTime.Format(utils.FormatDateTime)
  117. //合同审批权限
  118. ApprovalButton := false
  119. var contractDetail contract.ContractDetail
  120. jsonErr := json.Unmarshal([]byte(list[i].ContractDetail), &contractDetail)
  121. if jsonErr != nil {
  122. c.FailWithMessage("审批合同数据转换失败!", "审批合同数据转换失败,Err:"+jsonErr.Error())
  123. return
  124. }
  125. list[i].ContractInfo = contractDetail
  126. //校验最新审批流数据
  127. if contractApprovalRecord, has := contractApprovalRecordMap[item.ContractApprovalId]; has {
  128. //审批流id
  129. list[i].ContractApprovalRecordId = contractApprovalRecord.ContractApprovalRecordId
  130. //审批时间
  131. list[i].ApproveTime = contractApprovalRecord.ApproveTime
  132. list[i].ApproveTimeStr = contractApprovalRecord.ApproveTime.Format(utils.FormatDateTime)
  133. //判断是否有操作权限
  134. list[i].Status = contractApprovalRecord.Status
  135. //判断是否处于待审批状态
  136. if contractApprovalRecord.Status == "待审批" {
  137. //如果不是审批者,那么不能审批操作
  138. if contractApprovalRecord.NodeType != "check" {
  139. continue
  140. }
  141. //如果没有指定审批人的话
  142. if contractApprovalRecord.ApproveUserId <= 0 {
  143. //判断是否与审批角色一致,如果一致,那么允许操作审批
  144. if contractApprovalRecord.ApproveRoleTypeCode == sysUser.RoleTypeCode {
  145. ApprovalButton = true
  146. }
  147. } else if contractApprovalRecord.ApproveUserId == sysUser.AdminId {
  148. //如果指定审批人就是自己的话,那么操作审批
  149. ApprovalButton = true
  150. }
  151. }
  152. }
  153. //撤销权限(本人才有,然后没有审核操作过的才允许撤销)
  154. //if item.Status == "待审批" && item.StartNodeId == item.CurrNodeId && item.ApplyUserId == sysUser.AdminId {
  155. // opButton.Cancel = true
  156. //}
  157. respTmp := &company_approval.CompanyApprovalList{
  158. CompanyId: item.CompanyId,
  159. ProductId: item.ProductId,
  160. CompanyName: item.CompanyName,
  161. CreditCode: item.CreditCode,
  162. CompanyType: item.CompanyType,
  163. IndustryName: item.IndustryName,
  164. SellerName: item.SellerName,
  165. CreateTime: item.CreateTimeStr,
  166. ApprovalTime: item.CreateTime.Format(utils.FormatDateTime),
  167. ApproveTime: item.ApproveTimeStr,
  168. Status: item.CompanyProductStatus,
  169. ApproveContent: item.ApplyContent,
  170. ApproveStatus: item.ApproveStatus,
  171. ApplyMethod: item.ApplyMethod,
  172. ApplyReasons: item.ApplyReasons,
  173. FreezeStartDate: item.FreezeStartDate,
  174. FreezeEndDate: item.FreezeEndDate,
  175. FreezeExpireDays: item.FreezeExpireDays,
  176. Address: item.Address,
  177. Source: item.Source,
  178. ApproveRemark: item.ApproveRemark,
  179. StartDate: item.StartDate.Format(utils.FormatDate),
  180. EndDate: item.EndDate.Format(utils.FormatDate),
  181. ExpireDay: item.ExpireDay,
  182. CompanyApprovalId: item.CompanyApprovalId,
  183. //ApprovalCount int `description:"已延期审批次数"`
  184. CompanyContractId: item.CompanyContractId,
  185. //DelayPermission :
  186. ApplyRealName: item.ApplyRealName,
  187. OpButton: ApprovalButton,
  188. }
  189. if respTmp.FreezeStartDate != "" && respTmp.FreezeEndDate != "" && respTmp.Status == utils.COMPANY_STATUS_FREEZE {
  190. freezeEndDate, _ := time.Parse(utils.FormatDate, item.FreezeEndDate)
  191. if time.Now().Before(freezeEndDate) {
  192. expireDays := freezeEndDate.Sub(time.Now()).Hours() / 24
  193. respTmp.FreezeExpireDays = int(expireDays)
  194. }
  195. }
  196. if respTmp.StartDate != "" && respTmp.EndDate != "" {
  197. endDate, _ := time.Parse(utils.FormatDate, respTmp.EndDate)
  198. if time.Now().Before(endDate) {
  199. expireDays := endDate.Sub(time.Now()).Hours() / 24
  200. list[i].ExpireDay = int(expireDays)
  201. }
  202. }
  203. approvalCount, err := company_approval.GetCompanyApprovalCount(item.CompanyId, item.ProductId)
  204. if err != nil && err.Error() != utils.ErrNoRow() {
  205. c.FailWithMessage("获取失败", "获取延期审批次数失败,Err:"+err.Error())
  206. return
  207. }
  208. respTmp.ApprovalCount = approvalCount
  209. if respTmp.ApplyMethod == 3 {
  210. delayPermission, err := company_delay_permission.GetApplyDelayPermission(item.CompanyApprovalId)
  211. if err != nil && err.Error() != utils.ErrNoRow() {
  212. c.FailWithMessage("获取失败", "获取延期审批权限失败,Err:"+err.Error())
  213. return
  214. }
  215. respTmp.DelayPermission = delayPermission
  216. }
  217. respList = append(respList, respTmp)
  218. }
  219. }
  220. page := paging.GetPaging(currentIndex, pageSize, total)
  221. c.OkDetailed(approvalResp.CompanyApprovalListResp{
  222. List: respList,
  223. Paging: page,
  224. }, "获取成功")
  225. }
  226. // @Title 获取审批单详情接口
  227. // @Description 获取审批单详情接口
  228. // @Param ApprovalId query int true "审批单id"
  229. // @Success 200 {object} approval.CompanyApprovalDetailResp
  230. // @router /detail [get]
  231. func (c *ApprovalCommon) Detail() {
  232. companyApprovalId, _ := c.GetInt("ApprovalId")
  233. //if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN { //审批
  234. // condition += ` AND c.approve_role_type_code=? `
  235. // pars = append(pars, roleTypeCode)
  236. //} else if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER { //销售
  237. // condition += ` AND c.apply_user_id=? `
  238. // pars = append(pars, sysUser.AdminId)
  239. //}
  240. item, flowNodeListResp, err := company_apply.GetApprovalDetailByCompanyApprovalId(companyApprovalId, c.AdminWx)
  241. if err != nil {
  242. c.FailWithMessage("获取失败", "获取数据失败,Err:"+err.Error())
  243. return
  244. }
  245. resp := approvalResp.CompanyApprovalDetailResp{
  246. CompanyApprovalDetail: item,
  247. FlowNodeList: flowNodeListResp,
  248. }
  249. //获取权限列表
  250. //子权限切片集合
  251. var permissionClassifyArr []string
  252. if item.ProductId == 1 {
  253. for _, v := range utils.PermissionFiccClassifyArr {
  254. permissionClassifyArr = append(permissionClassifyArr, v)
  255. }
  256. } else {
  257. permissionClassifyArr = append(permissionClassifyArr, "权益")
  258. }
  259. //获取需要审批的权限
  260. delayPermissionList, err := company_delay_permission.GetDelayPermissionItems(item.CompanyId, item.CompanyApprovalId)
  261. if err != nil && err.Error() != utils.ErrNoRow() {
  262. c.FailWithMessage("获取失败", "获取审批权限失败,Err:"+err.Error())
  263. return
  264. }
  265. delayPermissionIdMap := make(map[int]int)
  266. for _, delayPermission := range delayPermissionList {
  267. delayPermissionIdMap[delayPermission.ChartPermissionId] = 0
  268. }
  269. //遍历获取
  270. for _, v := range permissionClassifyArr {
  271. checkList := make([]int, 0)
  272. plist := new(company_report_permission.PermissionLookList)
  273. items, err := company_report_permission.GetPermissionLookItems(item.ProductId, v)
  274. if err != nil {
  275. c.FailWithMessage("获取失败", "获取权限信息失败,Err:"+err.Error())
  276. return
  277. }
  278. for _, n := range items {
  279. if _, ok := delayPermissionIdMap[n.ChartPermissionId]; ok {
  280. checkList = append(checkList, n.ChartPermissionId)
  281. }
  282. }
  283. plist.Items = items
  284. plist.ClassifyName = v
  285. plist.CheckList = checkList
  286. if item.ProductId == 1 {
  287. resp.FiccPermissionList = append(resp.FiccPermissionList, plist)
  288. } else {
  289. resp.PermissionList = append(resp.PermissionList, plist)
  290. }
  291. }
  292. c.OkDetailed(resp, "获取成功")
  293. }
  294. // ApplyApprove
  295. // @Title 审批
  296. // @Description 审批接口
  297. // @Param request body approval.CompanyApplyApproveReq true "type json string"
  298. // @Success Ret=200 审批成功
  299. // @router /approve [post]
  300. func (c *ApprovalCommon) ApplyApprove() {
  301. sysUser := c.AdminWx
  302. var req approval2.CompanyApplyApproveReq
  303. err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
  304. if err != nil {
  305. c.FailWithMessage("参数解析异常!", "参数解析失败,Err:"+err.Error())
  306. return
  307. }
  308. //roleTypeCode := sysUser.RoleTypeCode
  309. //productId := services.GetProductId(roleTypeCode)
  310. //if productId == 0 {
  311. // c.FailWithMessage("参数错误", "参数解析失败,Err:"+"客户类型为:"+roleTypeCode)
  312. // return
  313. //}
  314. if req.CompanyId <= 0 {
  315. c.FailWithMessage("参数错误", "客户Id小于等于0")
  316. return
  317. }
  318. var condition string
  319. var pars []interface{}
  320. approvalItem, err := company_approval.GetApprovalInfoByApprovalId(condition, pars, req.CompanyApprovalId)
  321. if err != nil {
  322. c.FailWithMessage("获取审批信息失败", "获取信息失败,Err:"+err.Error())
  323. }
  324. if req.Status != 1 && req.Status != 2 {
  325. c.FailWithMessage("参数错误", "审批状态Id小于等于0")
  326. return
  327. }
  328. companyProduct, err := company_product.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, approvalItem.ProductId)
  329. if err != nil {
  330. c.FailWithMessage("获取信息失败", "获取信息失败,Err:"+err.Error())
  331. return
  332. }
  333. if companyProduct == nil {
  334. c.FailWithMessage("获取审批信息失败", "获取信息失败,companyProduct is null")
  335. return
  336. }
  337. //CompanyApprovalId
  338. //数据校验(校验是否具有审批权限)
  339. _, _, approvalRecord, err := company_apply.CheckApproveAuth(req.CompanyId, approvalItem.ProductId, sysUser)
  340. if err != nil {
  341. c.FailWithMessage("审核失败!", "审核失败,Err:"+err.Error())
  342. return
  343. }
  344. //真实审核操作
  345. if req.Status == 1 {
  346. err = company_apply.Approved(approvalRecord, sysUser, req.Remark)
  347. if err != nil {
  348. c.FailWithMessage("审核失败!", "审核失败,Err:"+err.Error())
  349. return
  350. }
  351. } else {
  352. err = company_apply.Reject(approvalRecord, sysUser, req.Remark)
  353. if err != nil {
  354. c.FailWithMessage("审核失败!", "审核失败,Err:"+err.Error())
  355. return
  356. }
  357. }
  358. c.OkWithMessage("审批操作成功")
  359. }