- remove corm.
This commit is contained in:
@@ -7,7 +7,6 @@ import (
|
||||
"git.rosy.net.cn/baseapi/utils"
|
||||
"git.rosy.net.cn/jx-callback/business/controllers"
|
||||
"git.rosy.net.cn/jx-callback/business/jd/models"
|
||||
"git.rosy.net.cn/jx-callback/compat/corm"
|
||||
"git.rosy.net.cn/jx-callback/globals"
|
||||
"git.rosy.net.cn/jx-callback/globals/globals2"
|
||||
"github.com/astaxie/beego/orm"
|
||||
@@ -18,7 +17,6 @@ const (
|
||||
)
|
||||
|
||||
var (
|
||||
errChecker corm.DBErrorChecker
|
||||
orderMsgChan chan jdapi.CallbackOrderMsg
|
||||
)
|
||||
|
||||
@@ -26,8 +24,6 @@ type OrderController struct {
|
||||
}
|
||||
|
||||
func InitOrder() {
|
||||
errChecker = new(corm.MysqlErrorChecker)
|
||||
|
||||
orderMsgChan = make(chan jdapi.CallbackOrderMsg, 128)
|
||||
go orderMsgHandlerRoutine()
|
||||
|
||||
|
||||
@@ -1,5 +0,0 @@
|
||||
package corm
|
||||
|
||||
type DBErrorChecker interface {
|
||||
ErrorIsDuplicate(error) bool
|
||||
}
|
||||
@@ -1,17 +0,0 @@
|
||||
package corm
|
||||
|
||||
import (
|
||||
"github.com/go-sql-driver/mysql"
|
||||
)
|
||||
|
||||
type MysqlErrorChecker struct {
|
||||
}
|
||||
|
||||
func (c MysqlErrorChecker) ErrorIsDuplicate(err error) bool {
|
||||
if err == nil {
|
||||
return false
|
||||
}
|
||||
|
||||
realErr := err.(*mysql.MySQLError)
|
||||
return realErr.Number == 1062
|
||||
}
|
||||
Reference in New Issue
Block a user