1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- package Certificate
- import (
- "ColdVerify_local/conf"
- "ColdVerify_local/lib"
- "ColdVerify_local/logs"
- "fmt"
- orm2 "github.com/beego/beego/v2/client/orm"
- _ "github.com/go-sql-driver/mysql"
- "strings"
- )
- type Certificate_ struct {
- Id int `orm:"column(ID)"`
- T_sn string // 编号
- T_layout_no string // 布局编号
- }
- // 获取列表
- func Read_Certificate_List(T_task_id string) ([]Certificate_, error) {
- serverOrm := orm2.NewOrmUsingDB(conf.Server_AliasName)
- localOrm := orm2.NewOrmUsingDB(conf.Local_AliasName)
- var maps []Certificate_
- snList := []string{}
- sql := "SELECT t_sn FROM z_task_data_" + T_task_id + " GROUP BY t_sn"
- fmt.Println(sql)
- _, err := localOrm.Raw(sql).QueryRows(&snList)
- if err != nil {
- logs.Error(lib.FuncName(), err)
- return maps, err
- }
- sql = "SELECT * FROM certificate WHERE t__state=1 AND t_sn not in (" + strings.Join(snList, ",") + ") ORDER BY t_layout_no"
- fmt.Println(sql)
- _, err = serverOrm.Raw(sql).QueryRows(&maps)
- if err != nil {
- logs.Error(lib.FuncName(), err)
- return maps, err
- }
- return maps, nil
- }
|