test

db/db_taobao_relation_pid.go

@@ -36,14 +36,13 @@ func GetRelationPid(eg *xorm.Engine, unionId int, pid []string, relationId strin
 func TaobaoRelationListByTaobaoIds(Db *xorm.Engine, unionId int, ids []int64) (*[]model.TaobaoRelation, error) {
 	var o []model.TaobaoRelation
 	if err := Db.In("relation_id", ids).Where("union_id=?", unionId).Find(&o); err != nil {
-		return nil, logx.Error(err)
+		return nil, err
 	}
 	return &o, nil
 }
 func TaobaoRelationListInsert(Db *xorm.Engine, m *model.TaobaoRelation) bool {
 	_, err := Db.InsertOne(m)
 	if err != nil {
-		logx.Warn(err)
 		return false
 	}
 	return true

db/model/taobao_relation.go

@@ -0,0 +1,8 @@
+package model
+
+type TaobaoRelation struct {
+	Id         int64  `json:"id" xorm:"pk autoincr comment('主键') BIGINT(10)"`
+	UnionId    int    `json:"union_id" xorm:"not null default 0 comment('') INT(11)"`
+	Count      int    `json:"count" xorm:"not null default 0 comment('')  INT(11)"`
+	RelationId string `json:"relation_id" xorm:"not null default ''  unique(relation_id) VARCHAR(255)"`
+}