approval.go 29 KB

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