Orm更换完成

models/activity_meet_detail_log.go

@@ -82,8 +82,10 @@ func UpdateActivityMeetDetailLogByUser(mobile string, num int) (err error) {
 
 //添加线上到会记录
 func AddCygxActivityMeetDetailLogOnline(list []*CygxActivityAttendanceDetail, activityId int) (err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {

models/activity_meeting_reminder.go

@@ -32,8 +32,10 @@ type CygxActivityMeetingReminderLog struct {
 
 //添加会议提醒信息
 func AddActivityMeetingReminder(item *CygxActivityMeetingReminder) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {
@@ -97,8 +99,10 @@ func GetActivityMeetingReminderCount(uid, activityId int) (count int, err error)
 
 //取消会议提醒
 func CancelActivityMeetingReminder(item *CygxActivityMeetingReminder) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {

models/activity_signup.go

@@ -69,8 +69,10 @@ type CygxActivitySignupLog struct {
 
 //添加报名信息
 func AddActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {
@@ -129,8 +131,10 @@ func AddActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
 
 //仅绑定邮箱的用户修改报名后，添加报名信息
 func AddActivitySignupFromEmail(item *CygxActivitySignup) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {
@@ -194,8 +198,10 @@ func AddActivitySignupFromEmail(item *CygxActivitySignup) (lastId int64, err err
 
 //添加报名信息
 func AddActivitySignupNoSchedule(item *CygxActivitySignup) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {
@@ -287,8 +293,10 @@ func GetUserSignupCount(uid int) (count int, err error) {
 
 //取消报名
 func CancelActivitySignup(item *CygxActivitySignup) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {
@@ -339,8 +347,10 @@ func GetActivitySignupDetail(activityId, uid int) (item *CygxActivitySignup, err
 
 //解除报名限制之后二次报名
 func AddActivitySignupByRestrict(item *CygxActivitySignup) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {

models/activity_user_search_content.go

@@ -23,8 +23,10 @@ type CygxActivityUserSearchContent struct {
 
 //更新搜索信息
 func AddUserSearchContent(item *CygxActivityUserSearchContent, ttlTime time.Duration) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {

models/apply_record.go

@@ -16,8 +16,10 @@ type CygxApplyRecord struct {
 }
 
 func AddApplyRecord(item *ApplyTryReq, mobile, companyNamePay string, userId, companyIdPay int) (err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		if err != nil {
 			o.Rollback()

models/article.go

@@ -470,8 +470,7 @@ type ReportDetail struct {
 }
 
 func GetReportList() (items []*ReportDetail, err error) {
-	o := orm.NewOrm()
-	o.Using("rddp")
+	o := orm.NewOrmUsingDB("rddp")
 	sql := `SELECT * FROM report WHERE  classify_id_second = '57'`
 	_, err = o.Raw(sql).QueryRows(&items)
 	return

models/article_history_record.go

@@ -23,8 +23,10 @@ type CygxArticleHistoryRecord struct {
 
 //添加历史信息
 func AddCygxArticleHistoryRecord(item *CygxArticleHistoryRecord) (lastId int64, err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {

models/msg_code.go

@@ -18,15 +18,13 @@ type MsgCode struct {
 
 //添加用户session信息
 func AddMsgCode(item *MsgCode) (err error) {
-	o := orm.NewOrm()
-	o.Using("rddp")
+	o := orm.NewOrmUsingDB("rddp")
 	_, err = o.Insert(item)
 	return
 }
 
 func GetMsgCode(mobile, code string) (item *MsgCode, err error) {
-	o := orm.NewOrm()
-	o.Using("rddp")
+	o := orm.NewOrmUsingDB("rddp")
 	sql := `SELECT * FROM msg_code WHERE mobile=? AND code=? AND FROM_UNIXTIME(expired_in)>=NOW() `
 	err = o.Raw(sql, mobile, code).QueryRow(&item)
 	return

models/resource.go

@@ -19,15 +19,13 @@ type ResourceResp struct {
 }
 
 func AddResource(item *Resource) (newId int64, err error) {
-	o := orm.NewOrm()
-	o.Using("rddp")
+	o := orm.NewOrmUsingDB("rddp")
 	newId, err = o.Insert(item)
 	return
 }
 
 func GetResourceById(id string) (item *Resource, err error) {
-	o := orm.NewOrm()
-	o.Using("rddp")
+	o := orm.NewOrmUsingDB("rddp")
 	sql := "SELECT * FROM resource WHERE id=? "
 	err = o.Raw(sql, id).QueryRow(&item)
 	return

models/tactics.go

@@ -26,8 +26,7 @@ type Tactics struct {
 }
 
 func GetTacticsList(endDate string) (list []*Tactics, err error) {
-	o := orm.NewOrm()
-	o.Using("tactics")
+	o := orm.NewOrmUsingDB("tactics")
 	sql := `SELECT a.*,b.body,b.abstract,b.annotation,b.article_id,d.category_name,d.sub_category_name,c.category_id
 				FROM article_articleinfo AS a
 				INNER JOIN article_content AS b ON a.id=b.article_id
@@ -40,8 +39,7 @@ func GetTacticsList(endDate string) (list []*Tactics, err error) {
 }
 
 func GetTacticsListAll() (list []*Tactics, err error) {
-	o := orm.NewOrm()
-	o.Using("tactics")
+	o := orm.NewOrmUsingDB("tactics")
 	sql := `SELECT a.*,b.body,b.abstract,b.annotation,b.article_id,d.category_name,d.sub_category_name,c.category_id
 			FROM article_articleinfo AS a
 			INNER JOIN article_content AS b ON a.id=b.article_id
@@ -83,8 +81,7 @@ type Tactics2 struct {
 }
 
 func GetTacticsList2(endDate string) (list []*Tactics2, err error) {
-	o := orm.NewOrm()
-	o.Using("tactics")
+	o := orm.NewOrmUsingDB("tactics")
 	sql := `SELECT a.*,b.body,b.abstract,b.annotation,b.article_id,d.category_name,d.sub_category_name,c.category_id
 			FROM article_articleinfo AS a
 			INNER JOIN article_content AS b ON a.id=b.article_id
@@ -98,8 +95,7 @@ func GetTacticsList2(endDate string) (list []*Tactics2, err error) {
 }
 
 func GetTacticsListAll2() (list []*Tactics2, err error) {
-	o := orm.NewOrm()
-	o.Using("tactics")
+	o := orm.NewOrmUsingDB("tactics")
 	sql := `SELECT a.*,b.body,b.abstract,b.annotation,b.article_id,d.category_name,d.sub_category_name,c.category_id
 			FROM article_articleinfo AS a
 			INNER JOIN article_content AS b ON a.id=b.article_id

models/user.go

@@ -233,8 +233,10 @@ type OutboundMobileItem struct {
 }
 
 func AddOutboundMobile(item *OutboundMobileItem, userId int) (err error) {
-	o := orm.NewOrm()
-	o.Begin()
+	o, err := orm.NewOrm().Begin()
+	if err != nil {
+		return
+	}
 	defer func() {
 		fmt.Println(err)
 		if err == nil {