approval.go 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749
  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. approvalRecord := contract_approval_record.ContractApprovalRecord{
  244. //ContractApprovalRecordId int `orm:"column(contract_approval_record_id);pk"`
  245. //ContractApprovalId int `orm:"column(contract_approval_id)";description:"审批单id"`
  246. Status: item.ApproveStatus,
  247. ApproveRemark: item.ApproveRemark,
  248. ApproveRoleTypeCode: user.RoleTypeCode,
  249. ApproveUserId: user.AdminId,
  250. ApproveUserName: user.Name,
  251. NodeId: node.NodeId,
  252. NodeType: node.NodeType,
  253. //PrevNodeId int `description:"上级节点id"`
  254. //NextNodeId int `description:"下级节点id"`
  255. AuditType: node.AuditType,
  256. ApproveTime: approveTime,
  257. //ModifyTime time.Time `description:"发起申请时间"`
  258. CreateTime: approvalTime,
  259. }
  260. flowNodeResp = append(flowNodeResp, approvalRecord)
  261. if user.AdminId == item.ApproveUserId {
  262. resp.CompanyApprovalDetail.CurrNodeId = node.NodeId
  263. }
  264. }
  265. flowNodeListResp = append(flowNodeListResp, flowNodeResp)
  266. }
  267. resp.FlowNodeList = flowNodeListResp
  268. this.OkDetailed(resp, "获取成功")
  269. }
  270. // @Title 获取审批单中的权限列表
  271. // @Description 获取审批单中的权限列表接口
  272. // @Param ApprovalId query int true "审批单id"
  273. // @Success 200 {object} approval.CompanyPermissionResp
  274. // @router /getApprovalPermissionList [get]
  275. func (this *ApprovalCommon) GetApprovalPermissionList() {
  276. //this.FailWithMessage("获取失败", "获取数据总数失败,Err:"+err.Error())
  277. //返回基础参数
  278. resp := new(approval.CompanyPermissionResp)
  279. //获取审批单信息
  280. approvalId, _ := this.GetInt("ApprovalId")
  281. if approvalId <= 0 {
  282. this.FailWithMessage("审批单参数异常", "提交审批单参数异常")
  283. return
  284. }
  285. approvalInfo, err := company_approval.GetCompanyApprovalByApprovalId(approvalId)
  286. if err != nil {
  287. this.FailWithMessage("获取失败", "获取审批单数据失败,Err:"+err.Error())
  288. return
  289. }
  290. //子权限切片集合
  291. var permissionClassifyArr []string
  292. if approvalInfo.ProductId == 1 {
  293. for _, v := range utils.PermissionFiccClassifyArr {
  294. permissionClassifyArr = append(permissionClassifyArr, v)
  295. }
  296. } else {
  297. permissionClassifyArr = append(permissionClassifyArr, "权益")
  298. }
  299. //获取需要审批的权限
  300. delayPermissionList, err := company_delay_permission.GetDelayPermissionItems(approvalInfo.CompanyId, approvalInfo.CompanyApprovalId)
  301. if err != nil && err.Error() != utils.ErrNoRow() {
  302. this.FailWithMessage("获取失败", "获取审批权限失败,Err:"+err.Error())
  303. return
  304. }
  305. delayPermissionIdMap := make(map[int]int)
  306. for _, delayPermission := range delayPermissionList {
  307. delayPermissionIdMap[delayPermission.ChartPermissionId] = 0
  308. }
  309. //遍历获取
  310. for _, v := range permissionClassifyArr {
  311. checkList := make([]int, 0)
  312. plist := new(company_report_permission.PermissionLookList)
  313. items, err := company_report_permission.GetPermissionLookItems(approvalInfo.ProductId, v)
  314. if err != nil {
  315. this.FailWithMessage("获取失败", "获取权限信息失败,Err:"+err.Error())
  316. return
  317. }
  318. for _, n := range items {
  319. if _, ok := delayPermissionIdMap[n.ChartPermissionId]; ok {
  320. checkList = append(checkList, n.ChartPermissionId)
  321. }
  322. }
  323. plist.Items = items
  324. plist.ClassifyName = v
  325. plist.CheckList = checkList
  326. if approvalInfo.ProductId == 1 {
  327. resp.FiccPermissionList = append(resp.FiccPermissionList, plist)
  328. } else {
  329. resp.PermissionList = append(resp.PermissionList, plist)
  330. }
  331. }
  332. this.OkDetailed(resp, "获取成功")
  333. }
  334. // @Title 审批
  335. // @Description 审批接口
  336. // @Param request body approval.CompanyApplyApproveReq true "type json string"
  337. // @Success Ret=200 审批成功
  338. // @router /approve [post]
  339. func (this *ApprovalCommon) ApplyApprove() {
  340. sysUser := this.AdminWx
  341. var req approval2.CompanyApplyApproveReq
  342. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  343. if err != nil {
  344. this.FailWithMessage("参数解析异常!", "参数解析失败,Err:"+err.Error())
  345. return
  346. }
  347. roleTypeCode := sysUser.RoleTypeCode
  348. productId := services.GetProductId(roleTypeCode)
  349. if productId == 0 {
  350. this.FailWithMessage("参数错误", "参数解析失败,Err:"+"客户类型为:"+roleTypeCode)
  351. return
  352. }
  353. if req.CompanyId <= 0 {
  354. this.FailWithMessage("参数错误", "客户Id小于等于0")
  355. return
  356. }
  357. if req.Status != 1 && req.Status != 2 {
  358. this.FailWithMessage("参数错误", "审批状态Id小于等于0")
  359. return
  360. }
  361. companyProduct, err := company_product.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, productId)
  362. if err != nil {
  363. this.FailWithMessage("获取信息失败", "获取信息失败,Err:"+err.Error())
  364. return
  365. }
  366. if companyProduct == nil {
  367. this.FailWithMessage("获取审批信息失败", "获取信息失败,Err:"+err.Error())
  368. return
  369. }
  370. approvalItem, err := company_approval.GetCompanyApprovalByCompanyId(req.CompanyId, productId)
  371. if err != nil {
  372. if err.Error() == utils.ErrNoRow() {
  373. this.FailWithMessage("订单已审批,请刷新页面查看最新状态", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  374. } else {
  375. this.FailWithMessage("获取信息失败", "获取信息失败,Err:"+err.Error())
  376. }
  377. return
  378. }
  379. if approvalItem == nil {
  380. this.FailWithMessage("订单已审批,请刷新页面查看最新状态", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  381. return
  382. }
  383. if approvalItem.ApproveRoleTypeCode != roleTypeCode {
  384. this.FailWithMessage("您无权审批", "ApproveRoleTypeCode:"+approvalItem.ApproveRoleTypeCode+";roleTypeCode:"+roleTypeCode)
  385. return
  386. }
  387. var approveStatus, approveContent string
  388. if req.Status == 1 { //通过
  389. //申请类型:1:试用->正式,2:冻结—>试用,3:试用延期,4:原销售申请领取流失客户,5:正式客户申请服务更新
  390. if approvalItem.ApplyMethod == 1 { //试用转正式
  391. //获取合同信息
  392. contract, err := company_contract.GetCompanyContractDetail(req.CompanyId, productId, req.CompanyContractId)
  393. if err != nil {
  394. this.FailWithMessage("待审批信息不存在", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId)+";Err:"+err.Error())
  395. return
  396. }
  397. if contract == nil {
  398. this.FailWithMessage("待审批信息不存在", "待审批信息不存在,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+strconv.Itoa(productId))
  399. return
  400. }
  401. //格式化合同开始时间
  402. contractStartDate, err := time.Parse(utils.FormatDate, contract.StartDate)
  403. if err != nil {
  404. this.FailWithMessage("审批失败", "合同开始时间转换失败,Err:"+err.Error())
  405. return
  406. }
  407. //格式化合同结束日期
  408. contractEndDate, err := time.Parse(utils.FormatDate, contract.EndDate)
  409. if err != nil {
  410. this.FailWithMessage("审批失败", "合同结束时间转换失败,Err:"+err.Error())
  411. return
  412. }
  413. //格式化 产品中 合同结束日期
  414. //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
  415. //if err != nil {
  416. // br.Msg = "审批失败"
  417. // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
  418. // return
  419. //}
  420. //如果合同时间小于等于今天,那么立马执行合同内容
  421. if time.Now().After(contractStartDate) {
  422. err = company_approval.TryOutToFormal(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, contract.CompanyContractId, contract.StartDate, contract.EndDate, sysUser.RealName, companyProduct.ProductName)
  423. if err != nil {
  424. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  425. return
  426. }
  427. } else {
  428. err = company_approval.ApplyApproveContract(req.CompanyId, productId, approvalItem.CompanyApprovalId, contract.CompanyContractId)
  429. if err != nil {
  430. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  431. return
  432. }
  433. }
  434. //如果合同中的结束日期大于产品中的合同结束日期,那么就去修改产品中的合同结束日期
  435. if contractEndDate.After(companyProduct.ContractEndDate) {
  436. companyProduct.ContractEndDate = contractEndDate
  437. cols := make([]string, 0)
  438. cols = append(cols, "ContractEndDate")
  439. _ = companyProduct.Update(cols)
  440. }
  441. } else if approvalItem.ApplyMethod == 2 { //冻结->试用
  442. err = company_approval.FreezeToTryOut(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, approvalItem.ApplyUserId, sysUser.RealName, companyProduct.ProductName)
  443. if err != nil {
  444. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  445. return
  446. }
  447. } else if approvalItem.ApplyMethod == 3 { //试用延期
  448. err = company_approval.TryOutDelay(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, sysUser.RealName, companyProduct.EndDate, companyProduct.ProductName)
  449. if err != nil {
  450. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  451. return
  452. }
  453. } else if approvalItem.ApplyMethod == 4 { //原销售申请领取流失客户
  454. err = company_approval.ApplyReceive(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, approvalItem.ApplyUserId, sysUser.RealName, companyProduct.ProductName)
  455. if err != nil {
  456. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  457. return
  458. }
  459. } else if approvalItem.ApplyMethod == 5 { //正式客户申请服务更新
  460. //获取合同信息
  461. contract, err := company_contract.GetCompanyContractDetail(req.CompanyId, productId, req.CompanyContractId)
  462. if err != nil {
  463. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  464. return
  465. }
  466. if contract == nil {
  467. this.FailWithMessage("审批失败", "审批失败")
  468. return
  469. }
  470. //格式化合同开始时间
  471. contractStartDate, err := time.Parse(utils.FormatDate, contract.StartDate)
  472. if err != nil {
  473. this.FailWithMessage("审批失败", "合同开始时间转换失败,Err:"+err.Error())
  474. return
  475. }
  476. //格式化合同结束日期
  477. contractEndDate, err := time.Parse(utils.FormatDate, contract.EndDate)
  478. if err != nil {
  479. this.FailWithMessage("审批失败", "合同结束时间转换失败,Err:"+err.Error())
  480. return
  481. }
  482. //格式化 产品中 合同结束日期
  483. //productContractEndDate, err := time.Parse(utils.FormatDate, companyProduct.ContractEndDate)
  484. //if err != nil {
  485. // br.Msg = "审批失败"
  486. // br.ErrMsg = "产品中合同结束时间转换失败,Err:" + err.Error()
  487. // return
  488. //}
  489. //如果合同时间小于等于今天,那么立马执行合同内容
  490. if time.Now().After(contractStartDate) {
  491. err = company_approval.ApplyServiceUpdate(req.CompanyId, productId, sysUser.AdminId, approvalItem.CompanyApprovalId, contract.CompanyContractId, companyProduct.StartDate, contract.EndDate, sysUser.RealName, companyProduct.ProductName)
  492. if err != nil {
  493. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  494. return
  495. }
  496. } else {
  497. err = company_approval.ApplyApproveContract(req.CompanyId, productId, approvalItem.CompanyApprovalId, contract.CompanyContractId)
  498. if err != nil {
  499. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  500. return
  501. }
  502. }
  503. //如果合同中的结束日期大于产品中的合同结束日期,那么就去修改产品中的合同结束日期
  504. if contractEndDate.After(companyProduct.ContractEndDate) {
  505. companyProduct.ContractEndDate = contractEndDate
  506. cols := make([]string, 0)
  507. cols = append(cols, "ContractEndDate")
  508. _ = companyProduct.Update(cols)
  509. }
  510. } else {
  511. this.FailWithMessage("审批失败", "无效的审批状态,CompanyId:"+strconv.Itoa(req.CompanyId)+";productId:"+
  512. strconv.Itoa(productId)+";ApplyMethod:"+strconv.Itoa(approvalItem.ApplyMethod)+" ApproveStatus;"+approvalItem.ApproveStatus)
  513. return
  514. }
  515. approveContent = "审批通过"
  516. } else { //拒绝
  517. if req.Remark == "" {
  518. this.FailWithMessage("请填写驳回理由", "请填写驳回理由")
  519. return
  520. }
  521. approveStatus = "驳回"
  522. err = company_approval.ApproveRefuse(req.CompanyId, productId, approveStatus, req.Remark)
  523. approveContent = "审批驳回"
  524. if err != nil {
  525. this.FailWithMessage("审批失败", "审批失败,Err:"+err.Error())
  526. return
  527. }
  528. }
  529. //新增客户产品日志
  530. {
  531. productLog := new(company_product_log.CompanyProductLog)
  532. productLog.CompanyProductId = companyProduct.CompanyProductId
  533. productLog.CompanyId = companyProduct.CompanyId
  534. productLog.ProductId = companyProduct.ProductId
  535. productLog.ProductName = companyProduct.ProductName
  536. productLog.CompanyName = companyProduct.CompanyName
  537. productLog.CompanyName = companyProduct.CompanyName
  538. productLog.Source = companyProduct.Source
  539. productLog.Reasons = companyProduct.Reasons
  540. productLog.Status = companyProduct.Status
  541. productLog.IndustryId = companyProduct.IndustryId
  542. productLog.IndustryName = companyProduct.IndustryName
  543. productLog.SellerId = companyProduct.SellerId
  544. productLog.SellerName = companyProduct.SellerName
  545. productLog.GroupId = companyProduct.GroupId
  546. productLog.DepartmentId = companyProduct.DepartmentId
  547. productLog.IsSuspend = companyProduct.IsSuspend
  548. productLog.SuspendTime = companyProduct.SuspendTime
  549. productLog.ApproveStatus = companyProduct.ApproveStatus
  550. productLog.FreezeTime = companyProduct.FreezeTime
  551. productLog.Remark = companyProduct.Remark
  552. productLog.StartDate = companyProduct.StartDate
  553. productLog.EndDate = companyProduct.EndDate
  554. productLog.CreateTime = companyProduct.CreateTime
  555. productLog.ModifyTime = companyProduct.ModifyTime
  556. productLog.LoseReason = companyProduct.LoseReason
  557. productLog.LossTime = companyProduct.LossTime
  558. productLog.LogType = "modify"
  559. productLog.LogCreateTime = time.Now()
  560. productLog.AdminId = this.AdminWx.AdminId
  561. go company_product_log.AddCompanyProductLog(productLog)
  562. }
  563. //新增操作记录
  564. {
  565. remark := "审批"
  566. operation := "approve"
  567. services.AddCompanyOperationRecord(req.CompanyId, companyProduct.SellerId, sysUser.AdminId, productId, sysUser.AdminId, companyProduct.CompanyName,
  568. companyProduct.ProductName, sysUser.RealName, remark, operation, approveContent, sysUser.RealName, req.Remark, companyProduct.Status)
  569. }
  570. //待办通知
  571. {
  572. content := companyProduct.CompanyName + " " + approvalItem.ApproveContent + approveContent
  573. approvalSysUser, _ := admin.GetAdminById(approvalItem.ApplyUserId)
  574. if sysUser != nil {
  575. approvalStatus := 1
  576. if req.Status == 1 {
  577. approvalStatus = 2
  578. } else {
  579. approvalStatus = 3
  580. }
  581. go services.AddCompanyApprovalMessage(sysUser.AdminId, approvalItem.ApplyUserId, req.CompanyId, approvalItem.CompanyApprovalId, 2, 1, approvalStatus, companyProduct.CompanyName, content, content, approvalSysUser.Mobile)
  582. }
  583. }
  584. this.OkWithMessage("审批操作成功")
  585. }
  586. // @Title 获取审批流详情接口
  587. // @Description 获取审批流详情接口
  588. // @Param FlowId query int true "审批流程id;1:ficc客户审批;2:权益客户审批;3:ficc合同审批,4:权益合同审批,5:用印审批"
  589. // @Success 200 {object} approval_flow.ApprovalFlowItem
  590. // @router /flowDetail [get]
  591. func (this *ApprovalCommon) GetFlowDetail() {
  592. //sysUser := this.AdminWx
  593. flowId, _ := this.GetInt("FlowId", 0)
  594. if flowId <= 0 {
  595. this.FailWithMessage("参数异常", fmt.Sprint("审批流程id异常,FlowId:", flowId))
  596. return
  597. }
  598. flowItem, err := flow.GetApprovalFlow(flowId)
  599. if err != nil {
  600. this.FailWithMessage("获取失败", "获取数据失败,Err:"+err.Error())
  601. return
  602. }
  603. this.OkDetailed(flowItem, "获取成功")
  604. }
  605. //// @Title 审批列表删除
  606. //// @Description 审批列表删除接口
  607. //// @Param request body company.CompanyApplyDeleteReq true "type json string"
  608. //// @Success Ret=200 删除成功
  609. //// @router /approval/delete [post]
  610. //func (this *CompanyApprovalController) ApplyDelete() {
  611. // br := new(models.BaseResponse).Init()
  612. // defer func() {
  613. // this.Data["json"] = br
  614. // this.ServeJSON()
  615. // }()
  616. // sysUser := this.SysUser
  617. // if sysUser == nil {
  618. // br.Msg = "请登录"
  619. // br.ErrMsg = "请登录,SysUser Is Empty"
  620. // br.Ret = 408
  621. // return
  622. // }
  623. // var req company.CompanyApplyDeleteReq
  624. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  625. // if err != nil {
  626. // br.Msg = "参数解析异常!"
  627. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  628. // return
  629. // }
  630. // roleTypeCode := sysUser.RoleTypeCode
  631. // productId := services.GetProductId(roleTypeCode)
  632. // if productId == 0 {
  633. // br.Msg = "参数错误"
  634. // br.ErrMsg = "客户类型为:" + roleTypeCode
  635. // return
  636. // }
  637. // if req.CompanyId <= 0 {
  638. // br.Msg = "参数错误"
  639. // br.ErrMsg = "客户Id小于等于0:"
  640. // return
  641. // }
  642. // companyProduct, err := company.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, productId)
  643. // if err != nil {
  644. // br.Msg = "获取信息失败"
  645. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  646. // return
  647. // }
  648. // if companyProduct == nil {
  649. // br.Msg = "获取信息失败"
  650. // br.ErrMsg = "获取审批信息失败,Err:" + err.Error()
  651. // return
  652. // }
  653. // approvalItem, err := company.GetCompanyApprovalByApprovalId(req.CompanyApprovalId)
  654. // if err != nil {
  655. // if err.Error() == utils.ErrNoRow() {
  656. // br.Msg = "待审批信息不存在"
  657. // br.ErrMsg = "待审批信息不存在,CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  658. // return
  659. // }
  660. // br.Msg = "获取信息失败"
  661. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  662. // return
  663. // }
  664. // if approvalItem == nil {
  665. // br.Msg = "待审批信息不存在"
  666. // br.ErrMsg = "待审批信息不存在,CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  667. // return
  668. // }
  669. // if approvalItem.ApproveStatus != "待审批" && approvalItem.ApproveStatus != "已撤回" {
  670. // br.Msg = "审批状态为:" + approvalItem.ApproveStatus + ";不可删除"
  671. // br.ErrMsg = "审批状态为:" + approvalItem.ApproveStatus + ";不可删除" + ";CompanyId:" + strconv.Itoa(req.CompanyId) + ";productId:" + strconv.Itoa(productId)
  672. // return
  673. // }
  674. // //删除
  675. // err = company.ApplyDelete(req.CompanyId, req.CompanyApprovalId, approvalItem.ProductId)
  676. // if err != nil {
  677. // br.Msg = "删除失败"
  678. // br.ErrMsg = "删除失败,Err:" + err.Error()
  679. // return
  680. // }
  681. // //新增操作记录
  682. // {
  683. // remark := "删除审批申请"
  684. // operation := "approve_delete"
  685. // services.AddCompanyOperationRecord(req.CompanyId, companyProduct.SellerId, sysUser.AdminId, productId, sysUser.AdminId, companyProduct.CompanyName,
  686. // companyProduct.ProductName, sysUser.RealName, remark, operation, remark, sysUser.RealName, "", companyProduct.Status)
  687. // }
  688. // br.Ret = 200
  689. // br.Success = true
  690. // br.Msg = "删除成功"
  691. //}