approval.go 29 KB

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