seal.go 44 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258
  1. package seal
  2. import (
  3. "errors"
  4. "fmt"
  5. "github.com/beego/beego/v2/client/orm"
  6. "hongze/hz_crm_api/models/company"
  7. "hongze/hz_crm_api/models/contract"
  8. "hongze/hz_crm_api/models/seal"
  9. "hongze/hz_crm_api/models/seal/request"
  10. "hongze/hz_crm_api/models/seal/response"
  11. "hongze/hz_crm_api/models/system"
  12. "hongze/hz_crm_api/services"
  13. "hongze/hz_crm_api/utils"
  14. "mime/multipart"
  15. "reflect"
  16. "strconv"
  17. "strings"
  18. "time"
  19. )
  20. // UploadCheckBackFile 上传签回用印附件(实际操作)
  21. func UploadCheckBackFile(sealId int, fileUrl string, opUser *system.Admin) (sealInfo *seal.Seal, err error) {
  22. //查询当前用印信息
  23. sealInfo, err = seal.GetSealInfoByContractId(sealId)
  24. if err != nil {
  25. return
  26. }
  27. //用印状态判断
  28. if sealInfo.Status != "已审批" && sealInfo.Status != "已签回" {
  29. err = errors.New("用印状态异常,不允许上传签回用印附件,当前用印状态:" + sealInfo.Status)
  30. return
  31. }
  32. sealInfo.CheckBackFileUrl = fileUrl
  33. sealInfo.Status = "已签回"
  34. sealInfo.ModifyTime = time.Now()
  35. sealInfo.CheckBackFileTime = time.Now()
  36. err = sealInfo.Update([]string{"CheckBackFileUrl", "Status", "ModifyTime", "CheckBackFileTime"})
  37. if err != nil {
  38. return
  39. }
  40. // 给销售发送模版消息
  41. sellerInfo, tErr := system.GetSysAdminById(sealInfo.UserId)
  42. if tErr == nil {
  43. if sellerInfo.Mobile != "" {
  44. go services.SendSealFinishedWxTemplateMsg(sellerInfo.Mobile, sealInfo.CompanyName, sealInfo.SealId)
  45. }
  46. }
  47. return
  48. }
  49. // UploadCheckBackFileFromSeal 用印上传签回用印附件
  50. func UploadCheckBackFileFromSeal(sealId int, ext string, fileMulti multipart.File, opUser *system.Admin) (sealInfo *seal.Seal, err error) {
  51. //查询当前用印信息
  52. sealInfo, err = seal.GetSealInfoById(sealId)
  53. if err != nil {
  54. return
  55. }
  56. //用印状态判断
  57. if sealInfo.Status != "已审批" && sealInfo.Status != "已签回" {
  58. err = errors.New("用印状态异常,不允许上传签回用印附件,当前用印状态:" + sealInfo.Status)
  59. return
  60. }
  61. fileName := ``
  62. //保存的文件名
  63. fileName = sealInfo.CompanyName + "_" + sealInfo.Code + "(签回)"
  64. if sealInfo.ContractId > 0 {
  65. //获取合同信息
  66. contractInfo, tmpErr := contract.GetContractById(sealInfo.ContractId)
  67. if tmpErr != nil {
  68. err = tmpErr
  69. return
  70. }
  71. //保存的文件名
  72. fileName = contractInfo.CompanyName + "_" + contractInfo.ContractCode + "(签回)"
  73. }
  74. //非正式环境下,文件名上面还是加上随机数
  75. if utils.RunMode != "release" {
  76. fileName += "_" + utils.GetRandStringNoSpecialChar(10)
  77. }
  78. fileName += ext
  79. //上传到阿里云
  80. resourceUrl, err := services.UploadToOssAndFileName(fileMulti, fileName)
  81. if err != nil {
  82. err = errors.New("文件保存失败,Err:" + err.Error())
  83. return
  84. }
  85. sealInfo.CheckBackFileUrl = resourceUrl
  86. sealInfo.Status = "已签回"
  87. sealInfo.ModifyTime = time.Now()
  88. sealInfo.CheckBackFileTime = time.Now()
  89. err = sealInfo.Update([]string{"CheckBackFileUrl", "Status", "ModifyTime", "CheckBackFileTime"})
  90. if err != nil {
  91. return
  92. }
  93. // 给销售发送模版消息
  94. sellerInfo, tErr := system.GetSysAdminById(sealInfo.UserId)
  95. if tErr == nil {
  96. if sellerInfo.Mobile != "" {
  97. go services.SendSealFinishedWxTemplateMsg(sellerInfo.Mobile, sealInfo.CompanyName, sealInfo.SealId)
  98. }
  99. }
  100. return
  101. }
  102. // ApplySeal 申请用印
  103. func ApplySeal(sysUser *system.Admin, req request.SealApprovalApplyReq) (err error) {
  104. o := orm.NewOrm()
  105. to, err := o.Begin()
  106. if err != nil {
  107. return
  108. }
  109. defer func() {
  110. if err != nil {
  111. _ = to.Rollback()
  112. } else {
  113. _ = to.Commit()
  114. }
  115. }()
  116. // 添加用印
  117. //sealInfo, err := addSeal(sysUser.AdminId, req.ContractId, req.FileNum, req.CompanyId, sysUser.RealName, req.Use, req.CompanyName, req.UseCompanyName, req.CreditCode, req.ServiceType, req.SealType, req.Remark, req.FileUrls, req.AffiliatedCompany, req.StartDate, req.EndDate)
  118. sealInfo, err := addSeal(sysUser.AdminId, req.ContractId, req.FileNum, req.CompanyId, sysUser.RealName, req.Use, req.CompanyName, req.UseCompanyName, req.CreditCode, req.ServiceType, req.SealType, req.Remark, req.FileUrls, req.AffiliatedCompany, req.StartDate, req.EndDate)
  119. if err != nil {
  120. return
  121. }
  122. // 添加操作日志
  123. err = seal.AddSealOperationRecord(sealInfo.SealId, sysUser.AdminId, 0, "apply", sysUser.RealName, "提交审批", "")
  124. if err != nil {
  125. return
  126. }
  127. // 用印审批
  128. err = SubmitApproval(sealInfo)
  129. return
  130. }
  131. // addSeal 新增用印.
  132. //func addSeal(userId, contractId, fileNum, companyId int, userName, use, companyName, useCompanyName, creditCode, serviceType, sealType, remark string, fileUrls []string, affiliatedCompany, startDate, endDate string) (sealInfo *seal.Seal, err error) {
  133. // if !strings.Contains(strings.Join(seal.EnumUse, ","), use) {
  134. // err = errors.New("用印用途异常")
  135. // return
  136. // }
  137. // if !strings.Contains(strings.Join(seal.EnumServiceType, ","), serviceType) {
  138. // err = errors.New("业务类型异常")
  139. // return
  140. // }
  141. //
  142. // sealCode, err := seal.GetSealCode()
  143. // if err != nil {
  144. // return
  145. // }
  146. // fileUrl := ""
  147. // now := time.Now()
  148. // attachments := make([]*seal.Attachment, 0)
  149. // if len(fileUrls) == 1 {
  150. // fileUrl = fileUrls[0]
  151. // }
  152. //
  153. // sealInfo = &seal.Seal{
  154. // Code: sealCode,
  155. // UserId: userId,
  156. // UserName: userName,
  157. // Use: use,
  158. // CompanyName: companyName,
  159. // UseCompanyName: useCompanyName,
  160. // CreditCode: creditCode,
  161. // ServiceType: serviceType,
  162. // SealType: sealType,
  163. // Status: "待提交",
  164. // Remark: remark,
  165. // FileUrl: fileUrl,
  166. // FileNum: fileNum,
  167. // ContractId: contractId,
  168. // ModifyTime: now,
  169. // CreateTime: now,
  170. // AffiliatedCompany: affiliatedCompany,
  171. // }
  172. // err = seal.AddSeal(sealInfo)
  173. // if err != nil {
  174. // return
  175. // }
  176. // if len(fileUrls) > 1 {
  177. // for _, v := range fileUrls {
  178. // tmp := &seal.Attachment{
  179. // SealId: sealInfo.SealId,
  180. // FileUrl: v,
  181. // ModifyTime: now,
  182. // CreateTime: now,
  183. // }
  184. // attachments = append(attachments, tmp)
  185. // }
  186. // err = seal.AddAttachments(attachments)
  187. // }
  188. // return
  189. //}
  190. func addSeal(userId, contractId, fileNum, companyId int, userName, use, companyName, useCompanyName, creditCode, serviceType, sealType, remark string, fileUrls []string, affiliatedCompany, startDate, endDate string) (sealInfo *seal.Seal, err error) {
  191. if !strings.Contains(strings.Join(seal.EnumUse, ","), use) {
  192. err = errors.New("用印用途异常")
  193. return
  194. }
  195. if !strings.Contains(strings.Join(seal.EnumServiceType, ","), serviceType) {
  196. err = errors.New("业务类型异常")
  197. return
  198. }
  199. adminAll, err := system.GetAdminList()
  200. if err != nil {
  201. return
  202. }
  203. //adminMap := make(map[int]*system.AdminView)
  204. mapRaiSllerId := make(map[int]bool) // 是否为权益销售
  205. for _, v := range adminAll {
  206. //adminMap[v.AdminId] = v
  207. if v.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER || v.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP || v.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  208. mapRaiSllerId[v.AdminId] = true
  209. }
  210. }
  211. var sealCode string
  212. var productId int
  213. if mapRaiSllerId[userId] {
  214. sealCode, err = seal.GetSealCodeRai()
  215. productId = utils.COMPANY_PRODUCT_RAI_ID
  216. } else {
  217. sealCode, err = seal.GetSealCode()
  218. }
  219. if err != nil {
  220. return
  221. }
  222. fileUrl := ""
  223. now := time.Now()
  224. attachments := make([]*seal.Attachment, 0)
  225. if len(fileUrls) == 1 {
  226. fileUrl = fileUrls[0]
  227. }
  228. sealInfo = &seal.Seal{
  229. Code: sealCode,
  230. UserId: userId,
  231. UserName: userName,
  232. Use: use,
  233. CompanyName: companyName,
  234. UseCompanyName: useCompanyName,
  235. CreditCode: creditCode,
  236. ServiceType: serviceType,
  237. SealType: sealType,
  238. Status: "待提交",
  239. Remark: remark,
  240. FileUrl: fileUrl,
  241. FileNum: fileNum,
  242. ContractId: contractId,
  243. ModifyTime: now,
  244. CreateTime: now,
  245. AffiliatedCompany: affiliatedCompany,
  246. ProductId: productId,
  247. CompanyId: companyId,
  248. StartDate: startDate,
  249. EndDate: endDate,
  250. }
  251. err = seal.AddSeal(sealInfo)
  252. if err != nil {
  253. return
  254. }
  255. if len(fileUrls) > 1 {
  256. for _, v := range fileUrls {
  257. tmp := &seal.Attachment{
  258. SealId: sealInfo.SealId,
  259. FileUrl: v,
  260. ModifyTime: now,
  261. CreateTime: now,
  262. }
  263. attachments = append(attachments, tmp)
  264. }
  265. err = seal.AddAttachments(attachments)
  266. }
  267. return
  268. }
  269. // EditApply 编辑用印审批
  270. func EditApply(sysUser *system.Admin, req request.SealApprovalEditReq) (err error) {
  271. o := orm.NewOrm()
  272. to, err := o.Begin()
  273. if err != nil {
  274. return
  275. }
  276. defer func() {
  277. if err != nil {
  278. _ = to.Rollback()
  279. } else {
  280. _ = to.Commit()
  281. }
  282. }()
  283. // 编辑用印
  284. sealInfo, err := editSeal(req.SealId, sysUser.AdminId, req.ContractId, req.FileNum, req.Use, req.CompanyName, req.UseCompanyName, req.CreditCode, req.ServiceType, req.SealType, req.Remark, req.FileUrls, req.AffiliatedCompany)
  285. if err != nil {
  286. return
  287. }
  288. // 添加操作日志
  289. err = seal.AddSealOperationRecord(sealInfo.SealId, sysUser.AdminId, 0, "edit", sysUser.RealName, "重提审批", "")
  290. if err != nil {
  291. return
  292. }
  293. // 用印审批
  294. err = SubmitApproval(sealInfo)
  295. return
  296. }
  297. // editSeal 编辑用印申请
  298. func editSeal(sealId, userId, contractId, fileNum int, use, companyName, userCompanyName, creditCode, serviceType, sealType, remark string, fileUrls []string, affiliatedCompany string) (sealInfo *seal.Seal, err error) {
  299. if !strings.Contains(strings.Join(seal.EnumUse, ","), use) {
  300. err = errors.New("用印用途异常")
  301. return
  302. }
  303. if !strings.Contains(strings.Join(seal.EnumServiceType, ","), serviceType) {
  304. err = errors.New("业务类型异常")
  305. return
  306. }
  307. sealInfo, err = seal.GetSealInfoById(sealId)
  308. if err != nil {
  309. if err.Error() == utils.ErrNoRow() {
  310. err = errors.New("获取用印申请失败")
  311. }
  312. return
  313. }
  314. if sealInfo.UserId != userId {
  315. err = errors.New("当前账号无操作权限")
  316. return
  317. }
  318. ignoreStatus := []string{"待提交", "已撤回", "已驳回"}
  319. if !strings.Contains(strings.Join(ignoreStatus, ","), sealInfo.Status) {
  320. err = errors.New("用印状态异常,不允许修改,当前用印状态:" + sealInfo.Status)
  321. return
  322. }
  323. fileUrl := ""
  324. now := time.Now()
  325. attachments := make([]*seal.Attachment, 0)
  326. if len(fileUrls) == 1 {
  327. fileUrl = fileUrls[0]
  328. }
  329. sealInfo.Use = use
  330. sealInfo.CompanyName = companyName
  331. sealInfo.UseCompanyName = userCompanyName
  332. sealInfo.CreditCode = creditCode
  333. sealInfo.ServiceType = serviceType
  334. sealInfo.SealType = sealType
  335. sealInfo.Remark = remark
  336. sealInfo.FileUrl = fileUrl
  337. sealInfo.FileNum = fileNum
  338. sealInfo.ContractId = contractId
  339. sealInfo.ModifyTime = now
  340. sealInfo.CreateTime = now // 更新提交时间
  341. sealInfo.Status = "待提交"
  342. sealInfo.AffiliatedCompany = affiliatedCompany
  343. err = sealInfo.Update([]string{"Use", "CompanyName", "UseCompanyName", "CreditCode", "ServiceType", "SealType", "Remark", "FileUrl", "FileNum", "ContractId", "ModifyTime", "CreateTime", "Status", "AffiliatedCompany"})
  344. if err != nil {
  345. return
  346. }
  347. //删除原有的附件,新增最新的附件
  348. err = seal.DelAttachmentBySealId(sealId)
  349. if err != nil {
  350. return
  351. }
  352. if len(fileUrls) > 1 {
  353. for _, v := range fileUrls {
  354. tmp := &seal.Attachment{
  355. SealId: sealInfo.SealId,
  356. FileUrl: v,
  357. ModifyTime: now,
  358. CreateTime: now,
  359. }
  360. attachments = append(attachments, tmp)
  361. }
  362. err = seal.AddAttachments(attachments)
  363. }
  364. return
  365. }
  366. // VerifierEditApply 合规编辑用印申请
  367. func VerifierEditApply(sysUser *system.Admin, req request.SealApprovalEditReq) (err error) {
  368. // 审批权限校验
  369. sealInfo, approvalInfo, approvalRecord, err := CheckApprovalAuth(req.SealId, sysUser)
  370. if err != nil {
  371. return
  372. }
  373. // 数据状态校验
  374. if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_COMPLIANCE {
  375. err = errors.New("当前账号无修改权限")
  376. return
  377. }
  378. if sealInfo.Status != "待审批" {
  379. err = errors.New("用印状态异常,不允许修改,当前用印状态:" + sealInfo.Status)
  380. return
  381. }
  382. if !strings.Contains(strings.Join(seal.EnumUse, ","), req.Use) {
  383. err = errors.New("用印用途异常")
  384. return
  385. }
  386. if !strings.Contains(strings.Join(seal.EnumServiceType, ","), req.ServiceType) {
  387. err = errors.New("业务类型异常")
  388. return
  389. }
  390. // 变更字段判断
  391. updateCol := make([]string, 0)
  392. updateContent := make([]string, 0)
  393. if sealInfo.Use != req.Use {
  394. updateCol = append(updateCol, "Use")
  395. updateContent = append(updateContent, "用印用途")
  396. }
  397. if sealInfo.SealType != req.SealType {
  398. updateCol = append(updateCol, "SealType")
  399. updateContent = append(updateContent, "加盖何种印章")
  400. }
  401. if sealInfo.Remark != req.Remark {
  402. updateCol = append(updateCol, "Remark")
  403. updateContent = append(updateContent, "备注")
  404. }
  405. if sealInfo.FileNum != req.FileNum {
  406. updateCol = append(updateCol, "FileNum")
  407. updateContent = append(updateContent, "文件份数")
  408. }
  409. //判断附件地址是否相等:
  410. sealAttachements, err := seal.GetAttachmentBySealId(sealInfo.SealId)
  411. if err != nil {
  412. err = errors.New(fmt.Sprint("获取用印附件失败,Err:"+err.Error(), err))
  413. return
  414. }
  415. oldFileUrls := make([]string, 0)
  416. if sealInfo.FileUrl != "" {
  417. oldFileUrls = append(oldFileUrls, sealInfo.FileUrl)
  418. }
  419. if len(sealAttachements) > 0 {
  420. for _, v := range sealAttachements {
  421. oldFileUrls = append(oldFileUrls, v.FileUrl)
  422. }
  423. }
  424. attachmentFlag := false
  425. if !reflect.DeepEqual(oldFileUrls, req.FileUrls) {
  426. updateCol = append(updateCol, "FileUrl")
  427. updateContent = append(updateContent, "文件附件")
  428. attachmentFlag = true
  429. }
  430. if sealInfo.AffiliatedCompany != req.AffiliatedCompany {
  431. updateCol = append(updateCol, "AffiliatedCompany")
  432. updateContent = append(updateContent, "归属公司")
  433. }
  434. if len(updateCol) <= 0 {
  435. err = errors.New("没有变更信息")
  436. return
  437. }
  438. content := "用印修改:" + sysUser.RealName + "修改了" + strings.Join(updateContent, "、")
  439. // 通过盖章类型判断是否需要变更审批流程
  440. originFlowType := GetFlowTypeBySealType(sealInfo.SealType)
  441. reqFlowType := GetFlowTypeBySealType(req.SealType)
  442. //如果变更了盖章类型(涉及到审批流程变更),那么需要变更审批流
  443. //变更审批流:先驳回用印申请,再修改用印,再发消息给申请人,再替申请人重新发起申请,
  444. //然后遍历审批流程,当前操作人节点之前的全部审核通过,最后通过当前操作人的节点(改成如果一级审批人如果是自己,那么直接通过这一级审批,否则不通过,让审批单重走流程)
  445. newFileUrl := ""
  446. if len(req.FileUrls) == 1 {
  447. newFileUrl = req.FileUrls[0]
  448. }
  449. if originFlowType != reqFlowType {
  450. // 先驳回
  451. err = reject(sealInfo, approvalInfo, approvalRecord, sysUser, "")
  452. if err != nil {
  453. return
  454. }
  455. //修改用印申请,给申请人发消息
  456. sealInfo.Use = req.Use
  457. sealInfo.SealType = req.SealType
  458. sealInfo.Remark = req.Remark
  459. sealInfo.FileNum = req.FileNum
  460. sealInfo.FileUrl = newFileUrl
  461. sealInfo.ModifyTime = time.Now()
  462. sealInfo.AffiliatedCompany = req.AffiliatedCompany
  463. verifierEdit(sealInfo, updateCol, approvalRecord.ContractApprovalRecordId, content, sysUser, attachmentFlag, req.FileUrls)
  464. // 重新获取最新的用印单
  465. sealInfo, tmpErr := seal.GetSealInfoById(sealInfo.SealId)
  466. if tmpErr != nil {
  467. err = tmpErr
  468. return
  469. }
  470. err = reapply(sealInfo, sysUser)
  471. if err != nil {
  472. return
  473. }
  474. // 重新发起申请
  475. } else {
  476. // 修改用印申请,给申请人发消息
  477. sealInfo.Use = req.Use
  478. sealInfo.SealType = req.SealType
  479. sealInfo.Remark = req.Remark
  480. sealInfo.FileNum = req.FileNum
  481. sealInfo.FileUrl = newFileUrl
  482. sealInfo.ModifyTime = time.Now()
  483. sealInfo.AffiliatedCompany = req.AffiliatedCompany
  484. verifierEdit(sealInfo, updateCol, approvalRecord.ContractApprovalRecordId, content, sysUser, attachmentFlag, req.FileUrls)
  485. // 审核通过
  486. err = ApprovedApproval(sealInfo.SealId, sysUser, "")
  487. }
  488. // 操作日志
  489. err = seal.AddSealOperationRecord(sealInfo.SealId, sysUser.AdminId, approvalRecord.ContractApprovalRecordId, "edit", sysUser.RealName, "审批人修改信息", "")
  490. if err != nil {
  491. return
  492. }
  493. return
  494. }
  495. // verifierEdit 审批人修改用印信息
  496. func verifierEdit(sealInfo *seal.Seal, updateCol []string, approvalRecordId int, content string, opUser *system.Admin, attachmentFlag bool, fileUrls []string) {
  497. if attachmentFlag {
  498. // 同时更新用印申请和附件
  499. _ = updateSealAndAttachment(sealInfo, updateCol, fileUrls)
  500. } else {
  501. _ = sealInfo.Update(updateCol)
  502. }
  503. //给用印人,发送修改消息
  504. sysUserMobile := ""
  505. sysUser, _ := system.GetSysAdminById(opUser.AdminId)
  506. if sysUser != nil {
  507. sysUserMobile = sysUser.Mobile
  508. }
  509. go services.AddCompanyApprovalMessage(opUser.AdminId, sealInfo.UserId, 0, approvalRecordId, 3, sourceType, 2, sealInfo.CompanyName, content, content, sysUserMobile)
  510. return
  511. }
  512. // reapply 重新提交审批单
  513. func reapply(sealInfo *seal.Seal, opUser *system.Admin) (err error) {
  514. // 发起审批
  515. approvalInfo, contractApprovalRecordList, err := addApproval(sealInfo)
  516. if err != nil {
  517. return
  518. }
  519. // 校验一级审批人是否与当前提交人一致,如果一致的话,那么审批通过且不发送消息给一级审批人
  520. var contractApprovalRecord *contract.ContractApprovalRecord
  521. for _, tmpContractApprovalRecord := range contractApprovalRecordList {
  522. if tmpContractApprovalRecord.NodeId == approvalInfo.CurrNodeId && tmpContractApprovalRecord.ApproveUserId == opUser.AdminId {
  523. contractApprovalRecord = tmpContractApprovalRecord
  524. }
  525. }
  526. // 如果一级审批人和当前提交人一致,那么审批通过,且不发送消息给一级审批人
  527. if contractApprovalRecord != nil {
  528. err = ApprovedApproval(sealInfo.SealId, opUser, "")
  529. } else {
  530. //如果一级审批人和当前提交人不一致,那么发送消息给一级审批人,重走审批流程
  531. //待办通知
  532. {
  533. //发送消息下级审批人
  534. go MessageToNodeUser(contractApprovalRecordList[0].NodeId, approvalInfo.ApplyUserId, approvalInfo.ContractApprovalId, 1, 1, sealInfo.CompanyName, sealInfo.Use)
  535. }
  536. }
  537. return
  538. }
  539. func GetSealApprovalPageList(condition, joinCondition string, pars []interface{}, startSize, pageSize int, sysUser *system.Admin) (newList []*response.SealApprovalList, total int, err error) {
  540. // 1.列表数据
  541. list, total, err := seal.GetSealApprovalListByWhere(condition, joinCondition, pars, startSize, pageSize)
  542. if err != nil {
  543. err = errors.New(fmt.Sprint("获取用印审批列表失败,Err:"+err.Error(), err))
  544. return
  545. }
  546. // 2.操作权限
  547. if len(list) > 0 {
  548. // 取出所有列表最新的审批IDs
  549. approvalIdSlice := make([]string, 0)
  550. // 取出所有列表的关联合同id
  551. contractIdSlice := make([]string, 0)
  552. for i := 0; i < len(list); i++ {
  553. approvalIdSlice = append(approvalIdSlice, strconv.Itoa(list[i].ContractApprovalId))
  554. contractIdSlice = append(contractIdSlice, strconv.Itoa(list[i].ContractId))
  555. }
  556. approvalIdStr := strings.Join(approvalIdSlice, ",")
  557. // 通过审批IDs获取所有的审批流
  558. approvalRecordList, tempErr := contract.GetContractApprovalRecordListByContractApprovalIds(approvalIdStr)
  559. //approvalRecordList, tempErr := contract.GetContractApprovalRecordList(approvalIdStr, sysUser.AdminId)
  560. if tempErr != nil {
  561. err = errors.New(fmt.Sprint("获取审批流失败,Err:"+tempErr.Error(), err))
  562. return
  563. }
  564. // 获取自己的审批流列表数据
  565. selfContractApprovalRecordList, tempErr := contract.GetSelfContractApprovalRecordList(approvalIdStr, sysUser.AdminId)
  566. if tempErr != nil {
  567. err = errors.New(fmt.Sprint("获取审批列表失败,Err:"+tempErr.Error(), err))
  568. return
  569. }
  570. selfContractApprovalRecordMap := make(map[int]*contract.ContractApprovalRecord)
  571. for i := 0; i < len(selfContractApprovalRecordList); i++ {
  572. selfContractApprovalRecordMap[selfContractApprovalRecordList[i].ContractApprovalId] = selfContractApprovalRecordList[i]
  573. }
  574. // 获取所有关联的合同列表
  575. selfContractMap := make(map[int]*contract.ContractList)
  576. {
  577. if len(contractIdSlice) > 0 {
  578. contractIdStr := strings.Join(contractIdSlice, ",")
  579. contractList, tempErr := contract.GetContractListByContractIds(contractIdStr)
  580. if tempErr != nil {
  581. err = errors.New(fmt.Sprint("获取合同失败,Err:"+tempErr.Error(), err))
  582. return
  583. }
  584. for i := 0; i < len(contractList); i++ {
  585. selfContractMap[contractList[i].ContractId] = contractList[i]
  586. }
  587. }
  588. }
  589. for i := 0; i < len(list); i++ {
  590. item := list[i]
  591. list[i].CreateTimeStr = item.CreateTime.Format(utils.FormatDateTime)
  592. list[i].ModifyTimeStr = item.ModifyTime.Format(utils.FormatDateTime)
  593. list[i].ApproveTimeStr = item.ApproveTime.Format(utils.FormatDateTime)
  594. list[i].InvalidTimeStr = item.InvalidTime.Format(utils.FormatDateTime)
  595. list[i].CheckBackFileTimeStr = item.CheckBackFileTime.Format(utils.FormatDateTime)
  596. if item.ApproveStatus == "已审批" || item.ApproveStatus == "已驳回" {
  597. list[i].ApproveTime = item.ModifyTime
  598. list[i].ApproveTimeStr = item.ModifyTime.Format(utils.FormatDateTime)
  599. }
  600. // 如果当前状态是待审批的话,那么校验自己的审批流数据,然后去返回对应的状态
  601. if item.Status == "待审批" {
  602. // 如果是自己发起的审批单,同时已经经过了一轮审批,那么标记为处理中
  603. if item.ApplyUserId == sysUser.AdminId && item.CurrNodeId > item.StartNodeId {
  604. list[i].Status = "处理中"
  605. } else if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN && item.CurrNodeId > item.StartNodeId {
  606. // 如果是超管角色,同时已经经过了一轮审批,那么标记为处理中
  607. list[i].Status = "处理中"
  608. } else {
  609. // 此处可能出现同一审批人同时有权限处理一级二级的情况
  610. maxNodeId := 0
  611. tempStatus := "待审批"
  612. for _, selfRecord := range selfContractApprovalRecordList {
  613. if item.ContractApprovalId == selfRecord.ContractApprovalId {
  614. if selfRecord.NodeId > maxNodeId {
  615. maxNodeId = selfRecord.NodeId
  616. }
  617. if maxNodeId < item.CurrNodeId && selfRecord.NodeType != "cc" {
  618. tempStatus = "处理中"
  619. } else if maxNodeId == item.CurrNodeId && selfRecord.NodeType != "cc" {
  620. tempStatus = "待审批"
  621. }
  622. }
  623. }
  624. list[i].Status = tempStatus
  625. /*if contractApprovalRecord, has := selfContractApprovalRecordMap[item.ContractApprovalId]; has {
  626. if contractApprovalRecord.NodeId < item.CurrNodeId && contractApprovalRecord.NodeType != "cc" {
  627. list[i].Status = "处理中"
  628. }
  629. }*/
  630. }
  631. }
  632. // 合同编码
  633. if selfContract, has := selfContractMap[item.ContractId]; has {
  634. list[i].ContractCode = selfContract.ContractCode
  635. } else {
  636. if item.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  637. list[i].ContractCode = item.Code
  638. }
  639. }
  640. // 取出item对应approval_id的审批流
  641. var tempApprovalRecordMap []*contract.ContractApprovalRecord
  642. for _, recordItem := range approvalRecordList {
  643. if item.ContractApprovalId == recordItem.ContractApprovalId {
  644. tempApprovalRecordMap = append(tempApprovalRecordMap, recordItem)
  645. }
  646. }
  647. // 获取对该条数据的操作权限
  648. opButton, tempErr := handleListOpButton(item, tempApprovalRecordMap, sysUser)
  649. if tempErr != nil {
  650. err = errors.New(fmt.Sprint("获取操作权限失败,Err:"+tempErr.Error(), err))
  651. return
  652. }
  653. tempNewList := &response.SealApprovalList{
  654. SealApprovalItem: item,
  655. OpButton: opButton,
  656. }
  657. newList = append(newList, tempNewList)
  658. }
  659. }
  660. return
  661. }
  662. // GetSealApprovalPageList 获取用印审批分页列表
  663. //func GetSealApprovalPageList(condition, joinCondition string, pars []interface{}, startSize, pageSize int, sysUser *system.Admin) (newList []*response.SealApprovalList, total int, err error) {
  664. // // 1.列表数据
  665. // list, total, err := seal.GetSealApprovalListByWhere(condition, joinCondition, pars, startSize, pageSize)
  666. // if err != nil {
  667. // err = errors.New(fmt.Sprint("获取用印审批列表失败,Err:"+err.Error(), err))
  668. // return
  669. // }
  670. //
  671. // // 2.操作权限
  672. // if len(list) > 0 {
  673. // // 取出所有列表最新的审批IDs
  674. // approvalIdSlice := make([]string, 0)
  675. // // 取出所有列表的关联合同id
  676. // contractIdSlice := make([]string, 0)
  677. // for i := 0; i < len(list); i++ {
  678. // approvalIdSlice = append(approvalIdSlice, strconv.Itoa(list[i].ContractApprovalId))
  679. // contractIdSlice = append(contractIdSlice, strconv.Itoa(list[i].ContractId))
  680. // }
  681. // approvalIdStr := strings.Join(approvalIdSlice, ",")
  682. //
  683. // // 通过审批IDs获取所有的审批流
  684. // approvalRecordList, tempErr := contract.GetContractApprovalRecordListByContractApprovalIds(approvalIdStr)
  685. // //approvalRecordList, tempErr := contract.GetContractApprovalRecordList(approvalIdStr, sysUser.AdminId)
  686. // if tempErr != nil {
  687. // err = errors.New(fmt.Sprint("获取审批流失败,Err:"+tempErr.Error(), err))
  688. // return
  689. // }
  690. //
  691. // // 获取自己的审批流列表数据
  692. // selfContractApprovalRecordList, tempErr := contract.GetSelfContractApprovalRecordList(approvalIdStr, sysUser.AdminId)
  693. // if tempErr != nil {
  694. // err = errors.New(fmt.Sprint("获取审批列表失败,Err:"+tempErr.Error(), err))
  695. // return
  696. // }
  697. // selfContractApprovalRecordMap := make(map[int]*contract.ContractApprovalRecord)
  698. // for i := 0; i < len(selfContractApprovalRecordList); i++ {
  699. // selfContractApprovalRecordMap[selfContractApprovalRecordList[i].ContractApprovalId] = selfContractApprovalRecordList[i]
  700. // }
  701. //
  702. // // 获取所有关联的合同列表
  703. // selfContractMap := make(map[int]*contract.ContractList)
  704. // {
  705. // if len(contractIdSlice) > 0 {
  706. // contractIdStr := strings.Join(contractIdSlice, ",")
  707. // contractList, tempErr := contract.GetContractListByContractIds(contractIdStr)
  708. // if tempErr != nil {
  709. // err = errors.New(fmt.Sprint("获取合同失败,Err:"+tempErr.Error(), err))
  710. // return
  711. // }
  712. // for i := 0; i < len(contractList); i++ {
  713. // selfContractMap[contractList[i].ContractId] = contractList[i]
  714. // }
  715. // }
  716. // }
  717. //
  718. // for i := 0; i < len(list); i++ {
  719. // item := list[i]
  720. // list[i].CreateTimeStr = item.CreateTime.Format(utils.FormatDateTime)
  721. // list[i].ModifyTimeStr = item.ModifyTime.Format(utils.FormatDateTime)
  722. // list[i].ApproveTimeStr = item.ApproveTime.Format(utils.FormatDateTime)
  723. // list[i].InvalidTimeStr = item.InvalidTime.Format(utils.FormatDateTime)
  724. // list[i].CheckBackFileTimeStr = item.CheckBackFileTime.Format(utils.FormatDateTime)
  725. //
  726. // if item.ApproveStatus == "已审批" || item.ApproveStatus == "已驳回" {
  727. // list[i].ApproveTime = item.ModifyTime
  728. // list[i].ApproveTimeStr = item.ModifyTime.Format(utils.FormatDateTime)
  729. // }
  730. //
  731. // // 如果当前状态是待审批的话,那么校验自己的审批流数据,然后去返回对应的状态
  732. // if item.Status == "待审批" {
  733. // // 如果是自己发起的审批单,同时已经经过了一轮审批,那么标记为处理中
  734. // if item.ApplyUserId == sysUser.AdminId && item.CurrNodeId > item.StartNodeId {
  735. // list[i].Status = "处理中"
  736. // } else if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN && item.CurrNodeId > item.StartNodeId {
  737. // // 如果是超管角色,同时已经经过了一轮审批,那么标记为处理中
  738. // list[i].Status = "处理中"
  739. // } else {
  740. // // 此处可能出现同一审批人同时有权限处理一级二级的情况
  741. // maxNodeId := 0
  742. // tempStatus := "待审批"
  743. // for _, selfRecord := range selfContractApprovalRecordList {
  744. // if item.ContractApprovalId == selfRecord.ContractApprovalId {
  745. // if selfRecord.NodeId > maxNodeId {
  746. // maxNodeId = selfRecord.NodeId
  747. // }
  748. // if maxNodeId < item.CurrNodeId && selfRecord.NodeType != "cc" {
  749. // tempStatus = "处理中"
  750. // } else if maxNodeId == item.CurrNodeId && selfRecord.NodeType != "cc" {
  751. // tempStatus = "待审批"
  752. // }
  753. // }
  754. // }
  755. // list[i].Status = tempStatus
  756. // /*if contractApprovalRecord, has := selfContractApprovalRecordMap[item.ContractApprovalId]; has {
  757. // if contractApprovalRecord.NodeId < item.CurrNodeId && contractApprovalRecord.NodeType != "cc" {
  758. // list[i].Status = "处理中"
  759. // }
  760. // }*/
  761. // }
  762. // }
  763. // // 合同编码
  764. //
  765. // //if selfContract, has := selfContractMap[item.ContractId]; has {
  766. // // list[i].ContractCode = selfContract.ContractCode
  767. // //} else {
  768. // // if item.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  769. // // list[i].ContractCode = item.Code
  770. // // }
  771. // //}
  772. //
  773. // if selfContract, has := selfContractMap[item.ContractId]; has {
  774. // list[i].ContractCode = selfContract.ContractCode
  775. // } else {
  776. // if item.ProductId == utils.COMPANY_PRODUCT_RAI_ID {
  777. // list[i].ContractCode = item.Code
  778. // }
  779. // }
  780. //
  781. // // 取出item对应approval_id的审批流
  782. // var tempApprovalRecordMap []*contract.ContractApprovalRecord
  783. // for _, recordItem := range approvalRecordList {
  784. // if item.ContractApprovalId == recordItem.ContractApprovalId {
  785. // tempApprovalRecordMap = append(tempApprovalRecordMap, recordItem)
  786. // }
  787. // }
  788. // // 获取对该条数据的操作权限
  789. // opButton, tempErr := handleListOpButton(item, tempApprovalRecordMap, sysUser)
  790. // if tempErr != nil {
  791. // err = errors.New(fmt.Sprint("获取操作权限失败,Err:"+tempErr.Error(), err))
  792. // return
  793. // }
  794. //
  795. // tempNewList := &response.SealApprovalList{
  796. // SealApprovalItem: item,
  797. // OpButton: opButton,
  798. // }
  799. // newList = append(newList, tempNewList)
  800. // }
  801. // }
  802. //
  803. // return
  804. //}
  805. // handleOpButton 列表数据操作权限
  806. func handleListOpButton(approvalItem *seal.SealApprovalItem, recordList []*contract.ContractApprovalRecord, sysUser *system.Admin) (opButton response.SealApprovalOpButton, err error) {
  807. // 待审批状态下,如果是自己发起的审批单,同时已经经过了一轮审批,那么标记为处理中
  808. if approvalItem.Status == "待审批" {
  809. if approvalItem.ApplyUserId == sysUser.AdminId && approvalItem.CurrNodeId > approvalItem.StartNodeId {
  810. approvalItem.Status = "处理中"
  811. }
  812. }
  813. flowNodeMap := make(map[int][]contract.ContractApprovalRecord, 0)
  814. keySort := make([]int, 0)
  815. for _, approvalRecord := range recordList {
  816. // 如果当前节点正好是该节点,同时审批单状态是待审批状态,然后当前账号又有权限,该账号也正是审批人,那么允许审批操作
  817. if approvalItem.CurrNodeId == approvalRecord.NodeId && approvalItem.Status == "待审批" {
  818. if sysUser.AdminId == approvalRecord.ApproveUserId && approvalRecord.NodeType == "check" {
  819. opButton.Approval = true
  820. }
  821. // 合规在审批过程中具有 部分修改权限
  822. if sysUser.AdminId == approvalRecord.ApproveUserId && sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_COMPLIANCE && approvalRecord.NodeType == "check" {
  823. opButton.CheckEdit = true
  824. }
  825. }
  826. // 如果当前节点正好是该节点,同时审批单状态又是第一层节点
  827. if approvalItem.CurrNodeId == approvalRecord.NodeId && approvalRecord.PrevNodeId == 0 && approvalItem.Status == "待审批" {
  828. // 发起人具有撤回审批单权限
  829. if sysUser.AdminId == approvalItem.ApplyUserId {
  830. opButton.Cancel = true
  831. }
  832. }
  833. if tmpFlowNodeList, ok := flowNodeMap[approvalRecord.NodeId]; ok {
  834. flowNodeMap[approvalRecord.NodeId] = append(tmpFlowNodeList, *approvalRecord)
  835. } else {
  836. tmpFlowNodeList := make([]contract.ContractApprovalRecord, 1)
  837. tmpFlowNodeList[0] = *approvalRecord
  838. flowNodeMap[approvalRecord.NodeId] = tmpFlowNodeList
  839. keySort = append(keySort, approvalRecord.NodeId)
  840. }
  841. // 待审批状态下,如果当前审批节点就是操作人,审批节点超过当前审批节点,且节点类型是抄送人,,那么标记为处理中
  842. if approvalItem.Status == "待审批" {
  843. if approvalRecord.ApproveUserId == sysUser.AdminId && approvalRecord.NodeId < approvalItem.CurrNodeId && approvalRecord.NodeType == "cc" {
  844. approvalItem.Status = "处理中"
  845. }
  846. }
  847. }
  848. // 作废权限
  849. if sysUser.AdminId == approvalItem.ApplyUserId && approvalItem.Status == "已审批" {
  850. opButton.Invalid = true
  851. }
  852. // 是否具有签回合同用印权限
  853. uploadStatus := []string{"已审批", "已签回"}
  854. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_COMPLIANCE && strings.Contains(strings.Join(uploadStatus, ","), approvalItem.Status) {
  855. opButton.UploadFile = true
  856. }
  857. // 编辑权限
  858. editStatus := []string{"已驳回", "待提交", "已撤回"}
  859. if sysUser.AdminId == approvalItem.ApplyUserId && strings.Contains(strings.Join(editStatus, ","), approvalItem.Status) {
  860. opButton.Edit = true
  861. }
  862. return
  863. }
  864. // GetSealApprovalDetail 获取审批详情
  865. func GetSealApprovalDetail(sealId int, sysUser *system.Admin) (sealMore *response.SealMoreResp, flowNodeListResp [][]contract.ContractApprovalRecord, opButton response.SealApprovalOpButton, err error) {
  866. sealInfo, err := seal.GetSealInfoById(sealId)
  867. if err != nil {
  868. err = errors.New(fmt.Sprint("获取用印详情失败,Err:"+err.Error(), err))
  869. return
  870. }
  871. sealAttachements, err := seal.GetAttachmentBySealId(sealId)
  872. if err != nil {
  873. err = errors.New(fmt.Sprint("获取用印附件失败,Err:"+err.Error(), err))
  874. return
  875. }
  876. fileUrls := make([]string, 0)
  877. if sealInfo.FileUrl != "" {
  878. fileUrls = append(fileUrls, sealInfo.FileUrl)
  879. }
  880. for _, v := range sealAttachements {
  881. fileUrls = append(fileUrls, v.FileUrl)
  882. }
  883. sealMore = &response.SealMoreResp{
  884. Seal: sealInfo,
  885. FileUrls: fileUrls,
  886. }
  887. // 查询最近一次审批单信息
  888. lastApprovalInfo, err := contract.GetLastContractApprovalByContractId(sealInfo.SealId, "seal")
  889. if err != nil {
  890. if err.Error() != utils.ErrNoRow() {
  891. err = errors.New("获取最近一次审批单信息失败,ERR:" + err.Error())
  892. }
  893. err = nil
  894. return
  895. }
  896. if lastApprovalInfo != nil {
  897. // 获取审批操作和审批流数据
  898. tmpSealOpButton, tmpFlowNodeListResp, tmpErr := GetSealOpButton(sealInfo, lastApprovalInfo, sysUser)
  899. if tmpErr != nil {
  900. err = errors.New("获取用印按钮权限、审批流程失败,Err:" + tmpErr.Error())
  901. return
  902. }
  903. opButton = tmpSealOpButton
  904. flowNodeListResp = tmpFlowNodeListResp
  905. }
  906. return
  907. }
  908. // GetSealOpButton 获取用印审批操作权限
  909. func GetSealOpButton(sealInfo *seal.Seal, contractApprovalInfo *contract.ContractApproval, opUser *system.Admin) (sealOpButton response.SealApprovalOpButton, flowNodeListResp [][]contract.ContractApprovalRecord, err error) {
  910. // 审批流
  911. approvalRecordList, err := contract.GetApprovalRecordListByApprovalId(contractApprovalInfo.ContractApprovalId)
  912. if err != nil {
  913. err = errors.New("获取审批失败,Err:" + err.Error())
  914. return
  915. }
  916. // 待审批状态下,如果是自己发起的审批单,同时已经经过了一轮审批,那么标记为处理中
  917. if contractApprovalInfo.Status == "待审批" {
  918. if contractApprovalInfo.ApplyUserId == opUser.AdminId && contractApprovalInfo.CurrNodeId > contractApprovalInfo.StartNodeId {
  919. sealInfo.Status = "处理中"
  920. }
  921. }
  922. flowNodeMap := make(map[int][]contract.ContractApprovalRecord, 0)
  923. keySort := make([]int, 0)
  924. for _, approvalRecord := range approvalRecordList {
  925. // 如果当前节点正好是该节点,同时审批单状态是待审批状态,然后当前账号又有权限,该账号也正是审批人,那么允许审批操作
  926. if contractApprovalInfo.CurrNodeId == approvalRecord.NodeId && contractApprovalInfo.Status == "待审批" {
  927. if opUser.AdminId == approvalRecord.ApproveUserId && approvalRecord.NodeType == "check" {
  928. sealOpButton.Approval = true
  929. }
  930. // 合规在审批过程中具有 部分修改权限
  931. if opUser.AdminId == approvalRecord.ApproveUserId && opUser.RoleTypeCode == utils.ROLE_TYPE_CODE_COMPLIANCE && approvalRecord.NodeType == "check" {
  932. sealOpButton.CheckEdit = true
  933. }
  934. }
  935. // 如果当前节点正好是该节点,同时审批单状态又是第一层节点
  936. if contractApprovalInfo.CurrNodeId == approvalRecord.NodeId && approvalRecord.PrevNodeId == 0 && contractApprovalInfo.Status == "待审批" {
  937. // 发起人具有撤回审批单权限
  938. if opUser.AdminId == sealInfo.UserId {
  939. sealOpButton.Cancel = true
  940. }
  941. }
  942. if tmpFlowNodeList, ok := flowNodeMap[approvalRecord.NodeId]; ok {
  943. flowNodeMap[approvalRecord.NodeId] = append(tmpFlowNodeList, *approvalRecord)
  944. } else {
  945. tmpFlowNodeList := make([]contract.ContractApprovalRecord, 1)
  946. tmpFlowNodeList[0] = *approvalRecord
  947. flowNodeMap[approvalRecord.NodeId] = tmpFlowNodeList
  948. keySort = append(keySort, approvalRecord.NodeId)
  949. }
  950. // 待审批状态下,如果当前审批节点就是操作人,审批节点超过当前审批节点,且节点类型是抄送人,,那么标记为处理中
  951. if contractApprovalInfo.Status == "待审批" {
  952. if approvalRecord.ApproveUserId == opUser.AdminId && approvalRecord.NodeId < contractApprovalInfo.CurrNodeId && approvalRecord.NodeType == "cc" {
  953. sealInfo.Status = "处理中"
  954. }
  955. }
  956. }
  957. for _, key := range keySort {
  958. flowNodeListResp = append(flowNodeListResp, flowNodeMap[key])
  959. }
  960. // 作废权限
  961. if opUser.AdminId == sealInfo.UserId && sealInfo.Status == "已审批" {
  962. sealOpButton.Invalid = true
  963. }
  964. // 是否具有签回合同用印权限
  965. uploadStatus := []string{"已审批", "已签回"}
  966. if opUser.RoleTypeCode == utils.ROLE_TYPE_CODE_COMPLIANCE && strings.Contains(strings.Join(uploadStatus, ","), sealInfo.Status) {
  967. sealOpButton.UploadFile = true
  968. }
  969. // 编辑权限
  970. editStatus := []string{"已驳回", "待提交", "已撤回"}
  971. if opUser.AdminId == sealInfo.UserId && strings.Contains(strings.Join(editStatus, ","), sealInfo.Status) {
  972. sealOpButton.Edit = true
  973. }
  974. return
  975. }
  976. // CancelSealApproval 撤回用印审批
  977. func CancelSealApproval(sealId int, sysUser *system.Admin) (err error) {
  978. // 审批信息
  979. sealInfo, err := seal.GetSealInfoById(sealId)
  980. if err != nil {
  981. if err.Error() == utils.ErrNoRow() {
  982. err = errors.New("用印审批信息有误,Err:" + err.Error())
  983. }
  984. return
  985. }
  986. // 审批状态判断
  987. if sealInfo.Status != "待审批" {
  988. err = errors.New("用印状态异常,不允许撤回申请,当前用印状态:" + sealInfo.Status)
  989. return
  990. }
  991. // 操作人与申请人是否一致
  992. if sealInfo.UserId != sysUser.AdminId {
  993. err = errors.New("不允许撤回非本人提交的申请:" + strconv.Itoa(sealInfo.UserId))
  994. return
  995. }
  996. // 获取最近一次待审批的审批单信息
  997. approvalInfo, err := contract.GetLastContractApprovalByContractId(sealInfo.SealId, "seal")
  998. if err != nil {
  999. return
  1000. }
  1001. if approvalInfo.Status != "待审批" {
  1002. err = errors.New("审批单状态异常,审批单状态:" + approvalInfo.Status)
  1003. return
  1004. }
  1005. //获取当前审批单的审批流信息
  1006. approvalRecordList, err := contract.GetContractApprovalRecordListByContractApprovalIdAndNodeId(approvalInfo.ContractApprovalId, approvalInfo.CurrNodeId)
  1007. if err != nil {
  1008. err = errors.New("获取审批流失败,Err:" + err.Error())
  1009. return
  1010. }
  1011. if len(approvalRecordList) <= 0 {
  1012. err = errors.New("找不到对应的审批流")
  1013. return
  1014. }
  1015. for _, tmpApprovalRecord := range approvalRecordList {
  1016. // 判断当前节点是否存在上级节点,如果存在,那么说明
  1017. if tmpApprovalRecord.PrevNodeId > 0 {
  1018. err = errors.New("合同已存在审批操作,不允许撤回申请")
  1019. return
  1020. }
  1021. }
  1022. // 获取当前审批单中所有待审批的流程流
  1023. contractApprovalRecordList, err := contract.GetPendingContractApprovalRecordListByContractId(approvalInfo.ContractApprovalId, approvalInfo.CurrNodeId)
  1024. if err != nil {
  1025. return
  1026. }
  1027. // 撤回审批流
  1028. err = approvalInfo.Cancel(approvalInfo, contractApprovalRecordList)
  1029. if err != nil {
  1030. return
  1031. }
  1032. // 添加操作日志
  1033. err = seal.AddSealOperationRecord(sealInfo.SealId, sysUser.AdminId, 0, "cancel", sysUser.RealName, "撤回申请", "")
  1034. if err != nil {
  1035. return
  1036. }
  1037. // 作废原有消息
  1038. for _, contractApprovalRecord := range contractApprovalRecordList {
  1039. go company.CancelCompanyApprovalMessage(contractApprovalRecord.ContractApprovalRecordId, 3)
  1040. }
  1041. return
  1042. }
  1043. // DelSealApproval 删除用印审批
  1044. func DelSealApproval(sealId int, sysUser *system.Admin) (err error) {
  1045. // 审批信息
  1046. sealInfo, err := seal.GetSealInfoById(sealId)
  1047. if err != nil {
  1048. if err.Error() == utils.ErrNoRow() {
  1049. err = errors.New("用印审批信息有误,Err:" + err.Error())
  1050. }
  1051. return
  1052. }
  1053. // 审批状态判断
  1054. if sealInfo.Status != "已撤回" {
  1055. err = errors.New("用印状态异常,不允许删除,当前用印状态:" + sealInfo.Status)
  1056. return
  1057. }
  1058. // 操作人与申请人是否一致
  1059. if sealInfo.UserId != sysUser.AdminId {
  1060. err = errors.New("不允许删除非本人提交的申请:" + strconv.Itoa(sealInfo.UserId))
  1061. return
  1062. }
  1063. // 删除用印审批
  1064. err = seal.DeleteSeal(sealInfo)
  1065. if err != nil {
  1066. err = errors.New("删除用印申请失败:" + strconv.Itoa(sealInfo.UserId))
  1067. return
  1068. }
  1069. // 添加操作日志
  1070. err = seal.AddSealOperationRecord(sealInfo.SealId, sysUser.AdminId, 0, "del", sysUser.RealName, "删除申请", "")
  1071. if err != nil {
  1072. return
  1073. }
  1074. return
  1075. }
  1076. // InvalidSealApproval 作废用印审批
  1077. func InvalidSealApproval(sealId int, opUser *system.Admin) (err error) {
  1078. //查询当前用印信息
  1079. sealInfo, err := seal.GetSealInfoById(sealId)
  1080. if err != nil {
  1081. if err.Error() == utils.ErrNoRow() {
  1082. err = errors.New(fmt.Sprint("根据用印编号:", sealId, " 找不到初始用印"))
  1083. }
  1084. return
  1085. }
  1086. if sealInfo.UserId != opUser.AdminId && opUser.RoleTypeCode != utils.ROLE_TYPE_CODE_COMPLIANCE {
  1087. err = errors.New("当前账号无操作权限")
  1088. return
  1089. }
  1090. if sealInfo.Status != "已审批" {
  1091. err = errors.New("用印状态异常,不允许作废,当前用印状态:" + sealInfo.Status)
  1092. return
  1093. }
  1094. //如果删除状态 >0,那么代表已经被删除了
  1095. if sealInfo.IsDelete > 0 {
  1096. err = errors.New("该用印已删除")
  1097. return
  1098. }
  1099. //用印作废
  1100. err = seal.Invalid(sealInfo)
  1101. if err != nil {
  1102. return
  1103. }
  1104. // 操作日志
  1105. err = seal.AddSealOperationRecord(sealInfo.SealId, opUser.AdminId, 0, "invalid", opUser.RealName, "作废审批", "")
  1106. if err != nil {
  1107. return
  1108. }
  1109. //获取最近一次提交的审批单信息
  1110. contractApproval, err := contract.GetLastContractApprovalByContractId(sealInfo.SealId, "seal")
  1111. if err != nil {
  1112. err = nil
  1113. return
  1114. }
  1115. //如果有提测信息,那么需要给对应的审批人发送消息
  1116. if contractApproval != nil {
  1117. //作废后需要给审批者发送消息
  1118. contractApprovalRecordList, tmpErr := contract.GetContractApprovalRecordListByContractApprovalId(contractApproval.ContractApprovalId)
  1119. if tmpErr != nil {
  1120. return
  1121. }
  1122. content := fmt.Sprint("作废", sealInfo.CompanyName, "用印申请")
  1123. for _, contractApprovalRecord := range contractApprovalRecordList {
  1124. if contractApprovalRecord.NodeType == "check" { //如果是审批人,那么需要发送消息给对方
  1125. //操作人信息
  1126. sysUserMobile := ""
  1127. sysUser, _ := system.GetSysAdminById(contractApprovalRecord.ApproveUserId)
  1128. if sysUser != nil {
  1129. sysUserMobile = sysUser.Mobile
  1130. }
  1131. go services.AddCompanyApprovalMessage(opUser.AdminId, contractApprovalRecord.ApproveUserId, 0, contractApprovalRecord.ContractApprovalRecordId, 3, sourceType, 2, sealInfo.CompanyName, content, content, sysUserMobile)
  1132. }
  1133. }
  1134. }
  1135. return
  1136. }
  1137. // GetSealOperationRecordList 获取用印操作日志列表
  1138. func GetSealOperationRecordList(sealId int) (list []*seal.SealOperationRecordList, err error) {
  1139. list, err = seal.GetSealOperationListBySealId(sealId)
  1140. if len(list) > 0 {
  1141. for k, item := range list {
  1142. list[k].CreateTimeStr = item.CreateTime.Format(utils.FormatDateTime)
  1143. }
  1144. }
  1145. return
  1146. }
  1147. // updateSealAndAttachment 更新用印申请,并更新附件
  1148. func updateSealAndAttachment(sealInfo *seal.Seal, updateCol []string, fileUrls []string) (err error) {
  1149. o := orm.NewOrm()
  1150. to, err := o.Begin()
  1151. if err != nil {
  1152. return
  1153. }
  1154. defer func() {
  1155. if err != nil {
  1156. _ = to.Rollback()
  1157. } else {
  1158. _ = to.Commit()
  1159. }
  1160. }()
  1161. err = sealInfo.Update(updateCol)
  1162. if err != nil {
  1163. return
  1164. }
  1165. now := time.Now()
  1166. //删除原有的附件,新增最新的附件
  1167. err = seal.DelAttachmentBySealId(sealInfo.SealId)
  1168. if err != nil {
  1169. return
  1170. }
  1171. attachments := make([]*seal.Attachment, 0)
  1172. if len(fileUrls) > 1 {
  1173. for _, v := range fileUrls {
  1174. tmp := &seal.Attachment{
  1175. SealId: sealInfo.SealId,
  1176. FileUrl: v,
  1177. ModifyTime: now,
  1178. CreateTime: now,
  1179. }
  1180. attachments = append(attachments, tmp)
  1181. }
  1182. err = seal.AddAttachments(attachments)
  1183. }
  1184. return
  1185. }