Certificate.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. package Certificate
  2. import (
  3. "ColdVerify_local/conf"
  4. "ColdVerify_local/lib"
  5. "ColdVerify_local/logs"
  6. "fmt"
  7. orm2 "github.com/beego/beego/v2/client/orm"
  8. _ "github.com/go-sql-driver/mysql"
  9. "strings"
  10. )
  11. type Certificate_ struct {
  12. Id int `orm:"column(ID)"`
  13. T_sn string // 编号
  14. T_layout_no string // 布局编号
  15. }
  16. // 获取列表
  17. func Read_Certificate_List(T_task_id string) ([]Certificate_, error) {
  18. serverOrm := orm2.NewOrmUsingDB(conf.Server_AliasName)
  19. localOrm := orm2.NewOrmUsingDB(conf.Local_AliasName)
  20. var maps []Certificate_
  21. snList := []string{}
  22. sql := "SELECT t_sn FROM z_task_data_" + T_task_id + " GROUP BY t_sn"
  23. fmt.Println(sql)
  24. _, err := localOrm.Raw(sql).QueryRows(&snList)
  25. if err != nil {
  26. logs.Error(lib.FuncName(), err)
  27. return maps, err
  28. }
  29. sql = "SELECT * FROM certificate WHERE t__state=1 AND t_sn not in (" + strings.Join(snList, ",") + ") ORDER BY t_layout_no"
  30. fmt.Println(sql)
  31. _, err = serverOrm.Raw(sql).QueryRows(&maps)
  32. if err != nil {
  33. logs.Error(lib.FuncName(), err)
  34. return maps, err
  35. }
  36. return maps, nil
  37. }