esign.go 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104
  1. package models
  2. import (
  3. "fmt"
  4. "mtp2_if/db"
  5. "github.com/xormplus/xorm"
  6. )
  7. // GetUseresignRecord 通过ID获取记录
  8. func GetUseresignRecord(id uint64) (useresignrecord *Useresignrecord, err error) {
  9. datas := make([]Useresignrecord, 0)
  10. err = db.GetEngine().Where("RECORDID = ?", id).Find(&datas)
  11. if err == nil {
  12. if len(datas) == 0 {
  13. err = xorm.ErrNotExist
  14. return
  15. }
  16. useresignrecord = &datas[0]
  17. }
  18. return
  19. }
  20. // GetUseresignRecordByFlowID 通过合同编号获取记录
  21. func GetUseresignRecordByFlowID(flowId string) (useresignrecord *Useresignrecord, err error) {
  22. datas := make([]Useresignrecord, 0)
  23. err = db.GetEngine().Where("CONTRACTNO = ?", flowId).Find(&datas)
  24. if err == nil {
  25. if len(datas) == 0 {
  26. err = xorm.ErrNotExist
  27. return
  28. }
  29. useresignrecord = &datas[0]
  30. }
  31. return
  32. }
  33. func (t *Useresignrecord) Update(cols string) (err error) {
  34. _, err = db.GetEngine().Cols(cols).Where("RECORDID = ?", t.RECORDID).Update(t)
  35. return
  36. }
  37. func QueryUsereSignRecords(userId, memberUserId int, recordId, templateConfigId, templatetype *int) (records []Useresignrecord, err error) {
  38. records = make([]Useresignrecord, 0)
  39. session := db.GetEngine().Table("USERESIGNRECORD").Where("USERID = ? AND AREAUSERID = ?", userId, memberUserId)
  40. if recordId != nil {
  41. session = session.And("RECORDID = ?", recordId)
  42. }
  43. if templateConfigId != nil {
  44. session = session.And("TEMPLATECONFIGID = ?", templateConfigId)
  45. }
  46. if templatetype != nil {
  47. session = session.And("TEMPLATETYPE = ?", templatetype)
  48. }
  49. err = session.Find(&records)
  50. return
  51. }
  52. func QueryMdUserSwapProtocol(userId int, areaUserId *int64) (datas []Mduserswapprotocol, err error) {
  53. session := db.GetEngine().Table("MD_USERSWAPPROTOCOL").Where("USERID = ?", userId)
  54. if areaUserId != nil {
  55. session = session.And("AREAUSERID = ?", areaUserId)
  56. }
  57. err = session.Find(&datas)
  58. return
  59. }
  60. func (t *Mduserswapprotocol) Update(cols string) (err error) {
  61. _, err = db.GetEngine().Cols(cols).Where("USERID = ? AND AREAUSERID = ?", t.USERID, t.AREAUSERID).Update(t)
  62. return
  63. }
  64. func QueryEsignTemplateConfigs(esignType, templateType int) (datas []Esigntemplateconfig, err error) {
  65. err = db.GetEngine().Table("ESIGNTEMPLATECONFIG").Where("ESIGNTYPE = ? AND TEMPLATETYPE = ?", esignType, templateType).Find(&datas)
  66. return
  67. }
  68. func InsertMdUserSwapProtocol(userId, areaUserId int, session *xorm.Session) (err error) {
  69. sql := fmt.Sprintf(`
  70. INSERT INTO MD_USERSWAPPROTOCOL
  71. (USERID,AREAUSERID,PROTOCOLSTATUS,AUDITTIME,UPDATETIME)
  72. VALUES
  73. (%v,%v,1,sysdate,sysdate)
  74. `, userId, areaUserId)
  75. _, err = session.Exec(sql)
  76. return
  77. }
  78. func InsertUserEsignRecord(userId, areaUserId int, econfig Esigntemplateconfig, session *xorm.Session) (err error) {
  79. sql := fmt.Sprintf(`
  80. INSERT INTO USERESIGNRECORD
  81. (RECORDID,USERID,TEMPLATECONFIGID,TEMPLATETYPE,TEMPLATENAME,ORDERINDEX,RECORDSTATUS,CREATETIME,UPDATETIME,AREAUSERID)
  82. VALUES
  83. (SEQ_USERESIGNRECORD.nextval,%v,%v,%v,'%v',%v,1,sysdate,sysdate,%v)
  84. `, userId, econfig.TEMPLATECONFIGID, econfig.TEMPLATETYPE, econfig.TEMPLATENAME, econfig.ORDERINDEX, areaUserId)
  85. _, err = session.Exec(sql)
  86. return
  87. }