tmpcertsub.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  1. package tmpzcgf
  2. import (
  3. "dashoo.cn/backend/api/business/oilsupplier/suppliercertsub"
  4. "dashoo.cn/backend/api/business/tmpzcgf"
  5. "dashoo.cn/utils"
  6. "fmt"
  7. "strings"
  8. "time"
  9. )
  10. //type TmpCertController struct {
  11. //
  12. // AccessCardNo int `json:"accessCardNo"` //准入证号
  13. // SupplierTypeName string `json:"supplierTypeName"` //准入类别
  14. // InFlag int `json:"inFlag"` //准入标识
  15. // EffectStartTime time.Time `json:"effectStartTime"` //有效期起
  16. // EffectEndTime time.Time `json:"effectEndTime"` //有效期止
  17. // ApplyTime time.Time `json:"applyTime"` //年审日期
  18. //
  19. //}
  20. type TmpCertController struct {
  21. SupplierCertId int
  22. SupplierTypeCode string
  23. AccessRange string
  24. }
  25. // @Title 跟新OilSupplier
  26. // @Description get user by token
  27. // @Success 200 {object}
  28. // @router /insertCertSub[get]
  29. func (this *TmpCertController) InsertCertSub(){
  30. fmt.Printf("Insertsubcert start!")
  31. var total []tmpzcgf.AllId
  32. var one TmpCertController
  33. t := time.Now()
  34. session := utils.DBE.NewSession()
  35. defer session.Close()
  36. err := session.Begin()
  37. svc := tmpzcgf.GetTmpCertService(session)
  38. total = svc.GetAllId()
  39. for index := range total{
  40. id := total[index].Id
  41. //fmt.Printf('%T',id)
  42. one = svc.SelectOne(id)
  43. accessRange := one.AccessRange
  44. accessRanges := strings.Split(accessRange,";")
  45. for index := range accessRanges{
  46. item := strings.Split(accessRanges[index]," ")
  47. code := item[0]
  48. code = code[2:]
  49. name := item[1]
  50. var newOne suppliercertsub.OilSupplierCertSub
  51. newOne.SupplierCertId = one.SupplierCertId
  52. newOne.SupplierTypeCode = one.SupplierTypeCode
  53. newOne.Code = code
  54. newOne.Name = name
  55. subClassId := svc.GetSubClassId(code,one.SupplierTypeCode)
  56. newOne.SubClassId = subClassId
  57. svc.InsertSupplierCertSub(newOne)
  58. fmt.Println("Insertsubcert end!")
  59. }
  60. }
  61. //if err != nil {
  62. // session.Rollback()
  63. //}
  64. err = session.Commit()
  65. fmt.Println(err)
  66. elapsed := time.Since(t)
  67. fmt.Println(elapsed)
  68. }