tmpCertSubSession.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. package tmpzcgf
  2. import (
  3. "dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
  4. . "dashoo.cn/backend/api/mydb"
  5. "github.com/go-xorm/xorm"
  6. )
  7. type TmpCertSession struct {
  8. MySessionBase
  9. }
  10. type TmpCertEntity struct {
  11. SupplierCertId int "xorm:"
  12. SupplierTypeCode string
  13. AccessRange string
  14. }
  15. type SubClassId struct{
  16. id int
  17. }
  18. type AllId struct{
  19. Id int
  20. }
  21. func GetTmpCertService(session *xorm.Session) *TmpCertSession {
  22. s := new(TmpCertSession)
  23. s.Session = session
  24. return s
  25. }
  26. //获取tmp_zcgf所有Id
  27. func (s *TmpCertSession) GetAllId() []AllId{
  28. var ids []AllId
  29. sql := `SELECT
  30. id
  31. FROM
  32. tmp_zcgf`
  33. s.Session.SQL(sql).Find(&ids)
  34. return ids
  35. }
  36. //从tmp_zcgf获取一条数据
  37. func (s *TmpCertSession) SelectOne(id int) TmpCertEntity {
  38. var one TmpCertEntity
  39. sql := `SELECT
  40. a.准入范围 AccessRange,
  41. c.id SupplierCertId,
  42. c.SupplierTypeCode SupplierTypeCode
  43. FROM
  44. tmp_zcgf a
  45. LEFT JOIN oilsupplier b ON a.企业名称 = b.SupplierName
  46. JOIN oilsuppliercert c ON b.id = c.SupplierId
  47. AND a.准入类别 = c.SupplierTypeName
  48. WHERE
  49. a.id =` + string(id)
  50. s.Session.SQL(sql).Find(&one)
  51. return one
  52. }
  53. //获取subClassId
  54. func (s *TmpCertSession) GetSubClassId(code string, supplierTypeCode string) int{
  55. //var subClassName
  56. var id SubClassId
  57. var tableName string
  58. switch supplierTypeCode{
  59. case "01":
  60. tableName = "OilGoodsAptitudeClass"
  61. //subClassName = []goodsaptitudeclass.OilGoodsAptitudeClass
  62. case "02":
  63. tableName = "OilBasisBuild"
  64. //subClassName = []basisbuild.OilBasisBuild
  65. case "03":
  66. tableName = "OilTechnologyServiceClass"
  67. //subClassName = []technologyserviceclass.OilTechnologyServiceClass
  68. }
  69. var sql = `SELECT id FROM`+tableName+`WHERE 1 = 1 AND code =`+ code
  70. s.Session.SQL(sql).Find(&id)
  71. return id.id
  72. }
  73. func (s *TmpCertSession) InsertSupplierCertSub(sub suppliercertsub.OilSupplierCertSub) error {
  74. var supplierId = string(sub.SupplierId)
  75. var supplierCertId = string(sub.SupplierCertId)
  76. var supplierTypeCode = sub.SupplierTypeCode
  77. var subClassId = string(sub.SubClassId)
  78. var code = sub.Code
  79. var name = sub.Name
  80. sql := `INSERT INTO OilSupplierCertSub ( SupplierId, SupplierCertId, SupplierTypeCode, SubClassId, CODE, NAME )
  81. VALUES ( ’` + supplierId+`‘,‘`+supplierCertId+`','`+supplierTypeCode+`','`+subClassId+`','`+code+`','`+name+`')`
  82. _,err := s.Session.Query(sql)
  83. return err
  84. }