diff --git a/business/jd/controller/order.go b/business/jd/controller/order.go index c8abbcd3b..7ba57ab6e 100644 --- a/business/jd/controller/order.go +++ b/business/jd/controller/order.go @@ -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() diff --git a/compat/corm/corm.go b/compat/corm/corm.go deleted file mode 100644 index baab6e02c..000000000 --- a/compat/corm/corm.go +++ /dev/null @@ -1,5 +0,0 @@ -package corm - -type DBErrorChecker interface { - ErrorIsDuplicate(error) bool -} diff --git a/compat/corm/corm_mysql.go b/compat/corm/corm_mysql.go deleted file mode 100644 index 3a9855b1b..000000000 --- a/compat/corm/corm_mysql.go +++ /dev/null @@ -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 -}