84 lines
2.3 KiB
Go
84 lines
2.3 KiB
Go
package controller
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/baseapi/utils/routinepool"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/business/scheduler"
|
|
_ "git.rosy.net.cn/jx-callback/business/scheduler/defsch" // 导入缺省订单调度器
|
|
"git.rosy.net.cn/jx-callback/globals"
|
|
"github.com/astaxie/beego/orm"
|
|
)
|
|
|
|
var (
|
|
OrderManager *OrderController
|
|
WaybillManager *WaybillController
|
|
routinePool *routinepool.Pool
|
|
)
|
|
|
|
func init() {
|
|
routinePool = routinepool.New(1000, 1000)
|
|
OrderManager = NewOrderManager()
|
|
WaybillManager = NewWaybillManager()
|
|
scheduler.CurrentScheduler.RegisterOrderManager(OrderManager)
|
|
}
|
|
|
|
func addOrderOrWaybillStatus(status *model.OrderStatus, db orm.Ormer) (isDuplicated bool, err error) {
|
|
status.ID = 0
|
|
created, _, err := db.ReadOrCreate(status, "VendorOrderID", "VendorID", "OrderType", "VendorStatus", "StatusTime")
|
|
if err == nil {
|
|
if !created {
|
|
isDuplicated = true
|
|
status.DuplicatedCount++
|
|
_, err = db.Update(status, "DuplicatedCount")
|
|
globals.SugarLogger.Infof("duplicated event:%v", status)
|
|
}
|
|
}
|
|
if err != nil {
|
|
// todo 这里居然会有主键重复错误，逻辑上是不应该的
|
|
globals.SugarLogger.Warnf("access db error:%v", err)
|
|
}
|
|
return isDuplicated, err
|
|
}
|
|
|
|
func CallMsgHandler(handler func(), primaryID string) {
|
|
// handler()
|
|
routinePool.CallFun(func() {
|
|
handler()
|
|
}, primaryID)
|
|
}
|
|
|
|
func GetDataCityCodeFromOrder(order *model.GoodsOrder) (retVal string, err error) {
|
|
var sql string
|
|
if order.VendorID == model.VendorIDJD {
|
|
sql = `
|
|
SELECT t2.tel_code
|
|
FROM jxstoremap t0
|
|
JOIN jxstore t1 ON t0.jxstoreid = t1.storeid
|
|
JOIN city t2 ON t1.area = t2.citycode
|
|
WHERE t0.jdstoreid = ?
|
|
`
|
|
} else if order.VendorID == model.VendorIDELM {
|
|
sql = `
|
|
SELECT t2.tel_code
|
|
FROM jx_to_elm_store_map t0
|
|
JOIN jxstore t1 ON t0.jx_store_id = t1.storeid
|
|
JOIN city t2 ON t1.area = t2.citycode
|
|
WHERE t0.elm_store_id = ?
|
|
`
|
|
} else {
|
|
panic(fmt.Sprintf("wrong vendorid:%d", order.VendorID))
|
|
}
|
|
db := orm.NewOrm()
|
|
var lists []orm.ParamsList
|
|
num, err := db.Raw(sql, utils.Str2Int64(order.VendorStoreID)).ValuesList(&lists)
|
|
if err != nil && num == 1 {
|
|
retVal = lists[0][0].(string)
|
|
} else {
|
|
globals.SugarLogger.Errorf("can not find store info for vendorID:%d, store:%s", order.VendorID, order.VendorStoreID)
|
|
}
|
|
return retVal, err
|
|
}
|