approval.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. approval2 "hongze/hongze_mobile_admin/models/request/approval"
  6. "hongze/hongze_mobile_admin/models/response/approval"
  7. "hongze/hongze_mobile_admin/models/tables/admin"
  8. "hongze/hongze_mobile_admin/models/tables/company_approval"
  9. "hongze/hongze_mobile_admin/models/tables/company_contract"
  10. "hongze/hongze_mobile_admin/models/tables/company_delay_permission"
  11. "hongze/hongze_mobile_admin/models/tables/company_product"
  12. "hongze/hongze_mobile_admin/models/tables/company_product_log"
  13. "hongze/hongze_mobile_admin/models/tables/company_report_permission"
  14. "hongze/hongze_mobile_admin/services"
  15. "hongze/hongze_mobile_admin/services/flow"
  16. "hongze/hongze_mobile_admin/utils"
  17. "rdluck_tools/paging"
  18. "strconv"
  19. "time"
  20. )
  21. //客户审批列表
  22. type ApprovalCommon struct {
  23. BaseAuth
  24. }
  25. // @Title 获取审批列表接口
  26. // @Description 获取审批列表接口
  27. // @Param PageSize query int true "每页数据条数"
  28. // @Param CurrentIndex query int true "当前页页码,从1开始"
  29. // @Param Status query string true "状态:'待审批','已审批','驳回','已撤回'"
  30. // @Param KeyWord query string true "搜索关键词"
  31. // @Success 200 {object} approval.CompanyApprovalListResp
  32. // @router /list [get]
  33. func (this *ApprovalCommon) List() {
  34. sysUser := this.AdminWx
  35. roleTypeCode := sysUser.RoleTypeCode
  36. pageSize, _ := this.GetInt("PageSize")
  37. currentIndex, _ := this.GetInt("CurrentIndex")
  38. status := this.GetString("Status")
  39. keyWord := this.GetString("KeyWord")
  40. var startSize int
  41. if pageSize <= 0 {
  42. pageSize = utils.PageSize20
  43. }
  44. if currentIndex <= 0 {
  45. currentIndex = 1
  46. }
  47. startSize = paging.StartIndex(currentIndex, pageSize)
  48. var condition string
  49. var pars []interface{}
  50. if status != "" {
  51. if status == "已审批" {
  52. condition += ` AND c.approve_status IN('已审批','驳回') `
  53. } else {
  54. condition += ` AND c.approve_status=? `
  55. pars = append(pars, status)
  56. }
  57. }
  58. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN { //审批
  59. condition += ` AND c.approve_role_type_code=? `
  60. pars = append(pars, roleTypeCode)
  61. } else if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER { //销售
  62. condition += ` AND c.apply_user_id=? `
  63. pars = append(pars, sysUser.AdminId)
  64. }
  65. if keyWord != "" {
  66. condition += ` AND (a.company_name LIKE '%` + keyWord + `%' OR a.credit_code LIKE '%` + keyWord + `%') `
  67. }
  68. total, err := company_approval.GetApprovalCount(condition, pars)
  69. if err != nil {
  70. this.FailWithMessage("获取失败", "获取数据总数失败,Err:"+err.Error())
  71. return
  72. }
  73. list, err := company_approval.GetApprovalList(condition, pars, startSize, pageSize)
  74. if err != nil {
  75. this.FailWithMessage("获取失败", "获取数据失败,Err:"+err.Error())
  76. return
  77. }
  78. listLen := len(list)
  79. for i := 0; i < listLen; i++ {
  80. item := list[i]
  81. if item.FreezeStartDate != "" && item.FreezeEndDate != "" && item.Status == utils.COMPANY_STATUS_FREEZE {
  82. freezeEndDate, _ := time.Parse(utils.FormatDate, item.FreezeEndDate)
  83. if time.Now().Before(freezeEndDate) {
  84. expireDays := freezeEndDate.Sub(time.Now()).Hours() / 24
  85. list[i].FreezeExpireDays = int(expireDays)
  86. }
  87. }
  88. if item.StartDate != "" && item.EndDate != "" {
  89. endDate, _ := time.Parse(utils.FormatDate, item.EndDate)
  90. if time.Now().Before(endDate) {
  91. expireDays := endDate.Sub(time.Now()).Hours() / 24
  92. list[i].ExpireDay = int(expireDays)
  93. }
  94. }
  95. approvalCount, err := company_approval.GetCompanyApprovalCount(item.CompanyId, item.ProductId)
  96. if err != nil && err.Error() != utils.ErrNoRow() {
  97. this.FailWithMessage("获取失败", "获取延期审批次数失败,Err:"+err.Error())
  98. return
  99. }
  100. list[i].ApprovalCount = approvalCount
  101. if item.ApplyMethod == 3 {
  102. delayPermission, err := company_delay_permission.GetApplyDelayPermission(item.CompanyApprovalId)
  103. if err != nil && err.Error() != utils.ErrNoRow() {
  104. this.FailWithMessage("获取失败", "获取延期审批权限失败,Err:"+err.Error())
  105. return
  106. }
  107. list[i].DelayPermission = delayPermission
  108. }
  109. if item.ApproveRoleTypeCode == roleTypeCode {
  110. list[i].OpButton = true
  111. }
  112. }
  113. page := paging.GetPaging(currentIndex, pageSize, total)
  114. resp := approval.CompanyApprovalListResp{
  115. Paging: page,
  116. List: list,
  117. }
  118. this.OkDetailed(resp, "获取成功")
  119. }
  120. // @Title 获取审批单详情接口
  121. // @Description 获取审批单详情接口
  122. // @Param ApprovalId query int true "审批单id"
  123. // @Success 200 {object} approval.CompanyApprovalDetailResp
  124. // @router /detail [get]
  125. func (this *ApprovalCommon) Detail() {
  126. sysUser := this.AdminWx
  127. roleTypeCode := sysUser.RoleTypeCode
  128. companyApprovalId, _ := this.GetInt("ApprovalId")
  129. var condition string
  130. var pars []interface{}
  131. if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN { //审批
  132. condition += ` AND c.approve_role_type_code=? `
  133. pars = append(pars, roleTypeCode)
  134. } else if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER || roleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER { //销售
  135. condition += ` AND c.apply_user_id=? `
  136. pars = append(pars, sysUser.AdminId)
  137. }
  138. item, err := company_approval.GetApprovalListByApprovalId(condition, pars, companyApprovalId)
  139. if err != nil {
  140. this.FailWithMessage("获取失败", "获取数据失败,Err:"+err.Error())
  141. return
  142. }
  143. if item.FreezeStartDate != "" && item.FreezeEndDate != "" && item.Status == utils.COMPANY_STATUS_FREEZE {
  144. freezeEndDate, _ := time.Parse(utils.FormatDate, item.FreezeEndDate)
  145. if time.Now().Before(freezeEndDate) {
  146. expireDays := freezeEndDate.Sub(time.Now()).Hours() / 24
  147. item.FreezeExpireDays = int(expireDays)
  148. }
  149. }
  150. if item.StartDate != "" && item.EndDate != "" {
  151. endDate, _ := time.Parse(utils.FormatDate, item.EndDate)
  152. if time.Now().Before(endDate) {
  153. expireDays := endDate.Sub(time.Now()).Hours() / 24
  154. item.ExpireDay = int(expireDays)
  155. }
  156. }
  157. approvalCount, err := company_approval.GetCompanyApprovalCount(item.CompanyId, item.ProductId)
  158. if err != nil && err.Error() != utils.ErrNoRow() {
  159. this.FailWithMessage("获取失败", "获取延期审批次数失败,Err:"+err.Error())
  160. return
  161. }
  162. item.ApprovalCount = approvalCount
  163. //if item.ApplyMethod == 3 {
  164. // delayPermission, err := company_delay_permission.GetApplyDelayPermission(item.CompanyApprovalId)
  165. // if err != nil && err.Error() != utils.ErrNoRow() {
  166. // this.FailWithMessage("获取失败", "获取延期审批权限失败,Err:"+err.Error())
  167. // return
  168. // }
  169. // item.DelayPermission = delayPermission
  170. //}
  171. resp := approval.CompanyApprovalDetailResp{
  172. CompanyApprovalDetail: item,
  173. }
  174. //获取权限列表
  175. //子权限切片集合
  176. var permissionClassifyArr []string
  177. if item.ProductId == 1 {
  178. for _, v := range utils.PermissionFiccClassifyArr {
  179. permissionClassifyArr = append(permissionClassifyArr, v)
  180. }
  181. } else {
  182. permissionClassifyArr = append(permissionClassifyArr, "权益")
  183. }
  184. //获取需要审批的权限
  185. delayPermissionList, err := company_delay_permission.GetDelayPermissionItems(item.CompanyId, item.CompanyApprovalId)
  186. if err != nil && err.Error() != utils.ErrNoRow() {
  187. this.FailWithMessage("获取失败", "获取审批权限失败,Err:"+err.Error())
  188. return
  189. }
  190. delayPermissionIdMap := make(map[int]int)
  191. for _, delayPermission := range delayPermissionList {
  192. delayPermissionIdMap[delayPermission.ChartPermissionId] = 0
  193. }
  194. //遍历获取
  195. for _, v := range permissionClassifyArr {
  196. checkList := make([]int, 0)
  197. plist := new(company_report_permission.PermissionLookList)
  198. items, err := company_report_permission.GetPermissionLookItems(item.ProductId, v)
  199. if err != nil {
  200. this.FailWithMessage("获取失败", "获取权限信息失败,Err:"+err.Error())
  201. return
  202. }
  203. for _, n := range items {
  204. if _, ok := delayPermissionIdMap[n.ChartPermissionId]; ok {
  205. checkList = append(checkList, n.ChartPermissionId)
  206. }
  207. }
  208. plist.Items = items
  209. plist.ClassifyName = v
  210. plist.CheckList = checkList
  211. if item.ProductId == 1 {
  212. resp.FiccPermissionList = append(resp.FiccPermissionList, plist)
  213. } else {
  214. resp.PermissionList = append(resp.PermissionList, plist)
  215. }
  216. }
  217. this.OkDetailed(resp, "获取成功")
  218. }
  219. // @Title 获取审批单中的权限列表
  220. // @Description 获取审批单中的权限列表接口
  221. // @Param ApprovalId query int true "审批单id"
  222. // @Success 200 {object} approval.CompanyPermissionResp
  223. // @router /getApprovalPermissionList [get]
  224. func (this *ApprovalCommon) GetApprovalPermissionList() {
  225. //this.FailWithMessage("获取失败", "获取数据总数失败,Err:"+err.Error())
  226. //返回基础参数
  227. resp := new(approval.CompanyPermissionResp)
  228. //获取审批单信息
  229. approvalId, _ := this.GetInt("ApprovalId")
  230. if approvalId <= 0 {
  231. this.FailWithMessage("审批单参数异常", "提交审批单参数异常")
  232. return
  233. }
  234. approvalInfo, err := company_approval.GetCompanyApprovalByApprovalId(approvalId)
  235. if err != nil {
  236. this.FailWithMessage("获取失败", "获取审批单数据失败,Err:"+err.Error())
  237. return
  238. }
  239. //子权限切片集合
  240. var permissionClassifyArr []string
  241. if approvalInfo.ProductId == 1 {
  242. for _, v := range utils.PermissionFiccClassifyArr {
  243. permissionClassifyArr = append(permissionClassifyArr, v)
  244. }
  245. } else {
  246. permissionClassifyArr = append(permissionClassifyArr, "权益")
  247. }
  248. //获取需要审批的权限
  249. delayPermissionList, err := company_delay_permission.GetDelayPermissionItems(approvalInfo.CompanyId, approvalInfo.CompanyApprovalId)
  250. if err != nil && err.Error() != utils.ErrNoRow() {
  251. this.FailWithMessage("获取失败", "获取审批权限失败,Err:"+err.Error())
  252. return
  253. }
  254. delayPermissionIdMap := make(map[int]int)
  255. for _, delayPermission := range delayPermissionList {
  256. delayPermissionIdMap[delayPermission.ChartPermissionId] = 0
  257. }
  258. //遍历获取
  259. for _, v := range permissionClassifyArr {
  260. checkList := make([]int, 0)
  261. plist := new(company_report_permission.PermissionLookList)
  262. items, err := company_report_permission.GetPermissionLookItems(approvalInfo.ProductId, v)
  263. if err != nil {
  264. this.FailWithMessage("获取失败", "获取权限信息失败,Err:"+err.Error())
  265. return
  266. }
  267. for _, n := range items {
  268. if _, ok := delayPermissionIdMap[n.ChartPermissionId]; ok {
  269. checkList = append(checkList, n.ChartPermissionId)
  270. }
  271. }
  272. plist.Items = items
  273. plist.ClassifyName = v
  274. plist.CheckList = checkList
  275. if approvalInfo.ProductId == 1 {
  276. resp.FiccPermissionList = append(resp.FiccPermissionList, plist)
  277. } else {
  278. resp.PermissionList = append(resp.PermissionList, plist)
  279. }
  280. }
  281. this.OkDetailed(resp, "获取成功")
  282. }
  283. // @Title 审批
  284. // @Description 审批接口
  285. // @Param request body approval.CompanyApplyApproveReq true "type json string"
  286. // @Success Ret=200 审批成功
  287. // @router /approve [post]
  288. func (this *ApprovalCommon) ApplyApprove() {
  289. sysUser := this.AdminWx
  290. var req approval2.CompanyApplyApproveReq
  291. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  292. if err != nil {
  293. this.FailWithMessage("参数解析异常!", "参数解析失败,Err:"+err.Error())
  294. return
  295. }
  296. roleTypeCode := sysUser.RoleTypeCode
  297. productId := services.GetProductId(roleTypeCode)
  298. if productId == 0 {
  299. this.FailWithMessage("参数错误", "参数解析失败,Err:"+"客户类型为:"+roleTypeCode)
  300. return
  301. }
  302. if req.CompanyId <= 0 {
  303. this.FailWithMessage("参数错误", "客户Id小于等于0")
  304. return
  305. }
  306. if req.Status != 1 && req.Status != 2 {
  307. this.FailWithMessage("参数错误", "审批状态Id小于等于0")
  308. return
  309. }
  310. companyProduct, err := company_product.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, productId)
  311. if err != nil {
  312. this.FailWithMessage("获取信息失败", "获取信息失败,Err:"+err.Error())
  313. return
  314. }
  315. if companyProduct == nil {
  316. this.FailWithMessage("获取审批信息失败", "获取信息失败,Err:"+err.Error())
  317. return
  318. }
  319. approvalItem, err := company_approval.GetCompanyApprovalByCompanyId(req.CompanyId, productId)
  320. if err != nil {
  321. if err.Error() == utils.ErrNoRow() {
  322. this.FailWithMessage("订单已审批,请刷新页面查看最新状态", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  323. } else {
  324. this.FailWithMessage("获取信息失败", "获取信息失败,Err:"+err.Error())
  325. }
  326. return
  327. }
  328. if approvalItem == nil {
  329. this.FailWithMessage("订单已审批,请刷新页面查看最新状态", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  330. return
  331. }
  332. if approvalItem.ApproveRoleTypeCode != roleTypeCode {
  333. this.FailWithMessage("您无权审批", "ApproveRoleTypeCode:"+approvalItem.ApproveRoleTypeCode+";roleTypeCode:"+roleTypeCode)
  334. return
  335. }
  336. var approveStatus, approveContent string
  337. if req.Status == 1 { //通过
  338. //申请类型:1:试用->正式,2:冻结—>试用,3:试用延期,4:原销售申请领取流失客户,5:正式客户申请服务更新
  339. if approvalItem.ApplyMethod == 1 { //试用转正式
  340. //获取合同信息
  341. contract, err := company_contract.GetCompanyContractDetail(req.CompanyId, productId, req.CompanyContractId)
  342. if err != nil {
  343. this.FailWithMessage("待审批信息不存在", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId)+";Err:"+err.Error())
  344. return
  345. }
  346. if contract == nil {
  347. this.FailWithMessage("待审批信息不存在", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  348. return
  349. }
  350. //格式化合同开始时间
  351. contractStartDate, err := time.Parse(utils.FormatDate, contract.StartDate)
  352. if err != nil {
  353. this.FailWithMessage("审批失败", "合同开始时间转换失败,Err:"+err.Error())
  354. return
  355. }
  356. //格式化合同结束日期
  357. contractEndDate, err := time.Parse(utils.FormatDate, contract.EndDate)
  358. if err != nil {
  359. this.FailWithMessage("审批失败", "合同结束时间转换失败,Err:"+err.Error())
  360. return
  361. }
  362. //格式化 产品中 合同结束日期
  363. //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
  364. //if err != nil {
  365. // br.Msg = "审批失败"
  366. // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
  367. // return
  368. //}
  369. //如果合同时间小于等于今天,那么立马执行合同内容
  370. if time.Now().After(contractStartDate) {
  371. err = company_approval.TryOutToFormal(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, contract.CompanyContractId, contract.StartDate, contract.EndDate, sysUser.RealName, companyProduct.ProductName)
  372. if err != nil {
  373. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  374. return
  375. }
  376. } else {
  377. err = company_approval.ApplyApproveContract(req.CompanyId, productId, approvalItem.CompanyApprovalId, contract.CompanyContractId)
  378. if err != nil {
  379. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  380. return
  381. }
  382. }
  383. //如果合同中的结束日期大于产品中的合同结束日期,那么就去修改产品中的合同结束日期
  384. if contractEndDate.After(companyProduct.ContractEndDate) {
  385. companyProduct.ContractEndDate = contractEndDate
  386. cols := make([]string, 0)
  387. cols = append(cols, "ContractEndDate")
  388. _ = companyProduct.Update(cols)
  389. }
  390. } else if approvalItem.ApplyMethod == 2 { //冻结->试用
  391. err = company_approval.FreezeToTryOut(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, approvalItem.ApplyUserId, sysUser.RealName, companyProduct.ProductName)
  392. if err != nil {
  393. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  394. return
  395. }
  396. } else if approvalItem.ApplyMethod == 3 { //试用延期
  397. err = company_approval.TryOutDelay(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, sysUser.RealName, companyProduct.EndDate, companyProduct.ProductName)
  398. if err != nil {
  399. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  400. return
  401. }
  402. } else if approvalItem.ApplyMethod == 4 { //原销售申请领取流失客户
  403. err = company_approval.ApplyReceive(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, approvalItem.ApplyUserId, sysUser.RealName, companyProduct.ProductName)
  404. if err != nil {
  405. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  406. return
  407. }
  408. } else if approvalItem.ApplyMethod == 5 { //正式客户申请服务更新
  409. //获取合同信息
  410. contract, err := company_contract.GetCompanyContractDetail(req.CompanyId, productId, req.CompanyContractId)
  411. if err != nil {
  412. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  413. return
  414. }
  415. if contract == nil {
  416. this.FailWithMessage("审批失败", "审批失败")
  417. return
  418. }
  419. //格式化合同开始时间
  420. contractStartDate, err := time.Parse(utils.FormatDate, contract.StartDate)
  421. if err != nil {
  422. this.FailWithMessage("审批失败", "合同开始时间转换失败,Err:"+err.Error())
  423. return
  424. }
  425. //格式化合同结束日期
  426. contractEndDate, err := time.Parse(utils.FormatDate, contract.EndDate)
  427. if err != nil {
  428. this.FailWithMessage("审批失败", "合同结束时间转换失败,Err:"+err.Error())
  429. return
  430. }
  431. //格式化 产品中 合同结束日期
  432. //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
  433. //if err != nil {
  434. // br.Msg = "审批失败"
  435. // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
  436. // return
  437. //}
  438. //如果合同时间小于等于今天,那么立马执行合同内容
  439. if time.Now().After(contractStartDate) {
  440. err = company_approval.ApplyServiceUpdate(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, contract.CompanyContractId, companyProduct.StartDate, contract.EndDate, sysUser.RealName, companyProduct.ProductName)
  441. if err != nil {
  442. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  443. return
  444. }
  445. } else {
  446. err = company_approval.ApplyApproveContract(req.CompanyId, productId, approvalItem.CompanyApprovalId, contract.CompanyContractId)
  447. if err != nil {
  448. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  449. return
  450. }
  451. }
  452. //如果合同中的结束日期大于产品中的合同结束日期,那么就去修改产品中的合同结束日期
  453. if contractEndDate.After(companyProduct.ContractEndDate) {
  454. companyProduct.ContractEndDate = contractEndDate
  455. cols := make([]string, 0)
  456. cols = append(cols, "ContractEndDate")
  457. _ = companyProduct.Update(cols)
  458. }
  459. } else {
  460. this.FailWithMessage("审批失败", "无效的审批状态,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+
  461. strconv.Itoa(productId)+";ApplyMethod:"+strconv.Itoa(approvalItem.ApplyMethod)+" ApproveStatus;"+approvalItem.ApproveStatus)
  462. return
  463. }
  464. approveContent = "审批通过"
  465. } else { //拒绝
  466. if req.Remark == "" {
  467. this.FailWithMessage("请填写驳回理由", "请填写驳回理由")
  468. return
  469. }
  470. approveStatus = "驳回"
  471. err = company_approval.ApproveRefuse(req.CompanyId, productId, approveStatus, req.Remark)
  472. approveContent = "审批驳回"
  473. if err != nil {
  474. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  475. return
  476. }
  477. }
  478. //新增客户产品日志
  479. {
  480. productLog := new(company_product_log.CompanyProductLog)
  481. productLog.CompanyProductId = companyProduct.CompanyProductId
  482. productLog.CompanyId = companyProduct.CompanyId
  483. productLog.ProductId = companyProduct.ProductId
  484. productLog.ProductName = companyProduct.ProductName
  485. productLog.CompanyName = companyProduct.CompanyName
  486. productLog.CompanyName = companyProduct.CompanyName
  487. productLog.Source = companyProduct.Source
  488. productLog.Reasons = companyProduct.Reasons
  489. productLog.Status = companyProduct.Status
  490. productLog.IndustryId = companyProduct.IndustryId
  491. productLog.IndustryName = companyProduct.IndustryName
  492. productLog.SellerId = companyProduct.SellerId
  493. productLog.SellerName = companyProduct.SellerName
  494. productLog.GroupId = companyProduct.GroupId
  495. productLog.DepartmentId = companyProduct.DepartmentId
  496. productLog.IsSuspend = companyProduct.IsSuspend
  497. productLog.SuspendTime = companyProduct.SuspendTime
  498. productLog.ApproveStatus = companyProduct.ApproveStatus
  499. productLog.FreezeTime = companyProduct.FreezeTime
  500. productLog.Remark = companyProduct.Remark
  501. productLog.StartDate = companyProduct.StartDate
  502. productLog.EndDate = companyProduct.EndDate
  503. productLog.CreateTime = companyProduct.CreateTime
  504. productLog.ModifyTime = companyProduct.ModifyTime
  505. productLog.LoseReason = companyProduct.LoseReason
  506. productLog.LossTime = companyProduct.LossTime
  507. productLog.LogType = "modify"
  508. productLog.LogCreateTime = time.Now()
  509. productLog.AdminId = this.AdminWx.AdminId
  510. go company_product_log.AddCompanyProductLog(productLog)
  511. }
  512. //新增操作记录
  513. {
  514. remark := "审批"
  515. operation := "approve"
  516. services.AddCompanyOperationRecord(req.CompanyId, companyProduct.SellerId, sysUser.AdminId, productId, sysUser.AdminId, companyProduct.CompanyName,
  517. companyProduct.ProductName, sysUser.RealName, remark, operation, approveContent, sysUser.RealName, req.Remark, companyProduct.Status)
  518. }
  519. //待办通知
  520. {
  521. content := companyProduct.CompanyName + " " + approvalItem.ApproveContent + approveContent
  522. approvalSysUser, _ := admin.GetAdminById(approvalItem.ApplyUserId)
  523. if sysUser != nil {
  524. approvalStatus := 1
  525. if req.Status == 1 {
  526. approvalStatus = 2
  527. } else {
  528. approvalStatus = 3
  529. }
  530. go services.AddCompanyApprovalMessage(sysUser.AdminId, approvalItem.ApplyUserId, req.CompanyId, approvalItem.CompanyApprovalId, 2, 1, approvalStatus, companyProduct.CompanyName, content, content, approvalSysUser.Mobile)
  531. }
  532. }
  533. this.OkWithMessage("审批操作成功")
  534. }
  535. // @Title 获取审批流详情接口
  536. // @Description 获取审批流详情接口
  537. // @Param FlowId query int true "审批流程id;1:ficc客户审批;2:权益客户审批;3:ficc合同审批,4:权益合同审批,5:用印审批"
  538. // @Success 200 {object} approval_flow.ApprovalFlowItem
  539. // @router /flowDetail [get]
  540. func (this *ApprovalCommon) GetFlowDetail() {
  541. //sysUser := this.AdminWx
  542. flowId, _ := this.GetInt("FlowId", 0)
  543. if flowId <= 0 {
  544. this.FailWithMessage("参数异常", fmt.Sprint("审批流程id异常,FlowId:", flowId))
  545. return
  546. }
  547. flowItem, err := flow.GetApprovalFlow(flowId)
  548. if err != nil {
  549. this.FailWithMessage("获取失败", "获取数据失败,Err:"+err.Error())
  550. return
  551. }
  552. this.OkDetailed(flowItem, "获取成功")
  553. }
  554. //// @Title 审批列表删除
  555. //// @Description 审批列表删除接口
  556. //// @Param request body company.CompanyApplyDeleteReq true "type json string"
  557. //// @Success Ret=200 删除成功
  558. //// @router /approval/delete [post]
  559. //func (this *CompanyApprovalController) ApplyDelete() {
  560. // br := new(models.BaseResponse).Init()
  561. // defer func() {
  562. // this.Data["json"] = br
  563. // this.ServeJSON()
  564. // }()
  565. // sysUser := this.SysUser
  566. // if sysUser == nil {
  567. // br.Msg = "请登录"
  568. // br.ErrMsg = "请登录,SysUser Is Empty"
  569. // br.Ret = 408
  570. // return
  571. // }
  572. // var req company.CompanyApplyDeleteReq
  573. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  574. // if err != nil {
  575. // br.Msg = "参数解析异常!"
  576. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  577. // return
  578. // }
  579. // roleTypeCode := sysUser.RoleTypeCode
  580. // productId := services.GetProductId(roleTypeCode)
  581. // if productId == 0 {
  582. // br.Msg = "参数错误"
  583. // br.ErrMsg = "客户类型为:" + roleTypeCode
  584. // return
  585. // }
  586. // if req.CompanyId <= 0 {
  587. // br.Msg = "参数错误"
  588. // br.ErrMsg = "客户Id小于等于0:"
  589. // return
  590. // }
  591. // companyProduct, err := company.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, productId)
  592. // if err != nil {
  593. // br.Msg = "获取信息失败"
  594. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  595. // return
  596. // }
  597. // if companyProduct == nil {
  598. // br.Msg = "获取信息失败"
  599. // br.ErrMsg = "获取审批信息失败,Err:" + err.Error()
  600. // return
  601. // }
  602. // approvalItem, err := company.GetCompanyApprovalByApprovalId(req.CompanyApprovalId)
  603. // if err != nil {
  604. // if err.Error() == utils.ErrNoRow() {
  605. // br.Msg = "待审批信息不存在"
  606. // br.ErrMsg = "待审批信息不存在,CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  607. // return
  608. // }
  609. // br.Msg = "获取信息失败"
  610. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  611. // return
  612. // }
  613. // if approvalItem == nil {
  614. // br.Msg = "待审批信息不存在"
  615. // br.ErrMsg = "待审批信息不存在,CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  616. // return
  617. // }
  618. // if approvalItem.ApproveStatus != "待审批" && approvalItem.ApproveStatus != "已撤回" {
  619. // br.Msg = "审批状态为:" + approvalItem.ApproveStatus + ";不可删除"
  620. // br.ErrMsg = "审批状态为:" + approvalItem.ApproveStatus + ";不可删除" + ";CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  621. // return
  622. // }
  623. // //删除
  624. // err = company.ApplyDelete(req.CompanyId, req.CompanyApprovalId, approvalItem.ProductId)
  625. // if err != nil {
  626. // br.Msg = "删除失败"
  627. // br.ErrMsg = "删除失败,Err:" + err.Error()
  628. // return
  629. // }
  630. // //新增操作记录
  631. // {
  632. // remark := "删除审批申请"
  633. // operation := "approve_delete"
  634. // services.AddCompanyOperationRecord(req.CompanyId, companyProduct.SellerId, sysUser.AdminId, productId, sysUser.AdminId, companyProduct.CompanyName,
  635. // companyProduct.ProductName, sysUser.RealName, remark, operation, remark, sysUser.RealName, "", companyProduct.Status)
  636. // }
  637. // br.Ret = 200
  638. // br.Success = true
  639. // br.Msg = "删除成功"
  640. //}