approval.go 28 KB

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