264 lines
9.3 KiB
Go
264 lines
9.3 KiB
Go
package orderman
|
||
|
||
import (
|
||
"fmt"
|
||
|
||
"git.rosy.net.cn/baseapi/utils"
|
||
"git.rosy.net.cn/jx-callback/business/model"
|
||
"git.rosy.net.cn/jx-callback/business/model/dao"
|
||
"git.rosy.net.cn/jx-callback/globals"
|
||
)
|
||
|
||
func (c *OrderManager) LoadAfsOrder(vendorAfsOrderID string, vendorID int) (afsOrder *model.AfsOrder, err error) {
|
||
return c.loadAfsOrder(dao.GetDB(), vendorAfsOrderID, vendorID)
|
||
}
|
||
|
||
func (c *OrderManager) loadAfsOrder(db *dao.DaoDB, vendorAfsOrderID string, vendorID int) (afsOrder *model.AfsOrder, err error) {
|
||
afsOrder = &model.AfsOrder{
|
||
AfsOrderID: vendorAfsOrderID,
|
||
VendorID: vendorID,
|
||
}
|
||
err = dao.GetEntity(db, afsOrder, "AfsOrderID", "VendorID")
|
||
return afsOrder, err
|
||
}
|
||
|
||
func (c *OrderManager) OnAfsOrderAdjust(afsOrder *model.AfsOrder, orderStatus *model.OrderStatus) (err error) {
|
||
return c.onAfsOrderNew(afsOrder, orderStatus, true)
|
||
}
|
||
|
||
func (c *OrderManager) OnAfsOrderNew(afsOrder *model.AfsOrder, orderStatus *model.OrderStatus) (err error) {
|
||
return c.onAfsOrderNew(afsOrder, orderStatus, false)
|
||
}
|
||
|
||
func (c *OrderManager) onAfsOrderNew(afsOrder *model.AfsOrder, orderStatus *model.OrderStatus, isAdjust bool) (err error) {
|
||
db := dao.GetDB()
|
||
dao.Begin(db)
|
||
defer func() {
|
||
if r := recover(); r != nil || err != nil {
|
||
dao.Rollback(db)
|
||
panic(r)
|
||
}
|
||
}()
|
||
isDuplicated, err := addOrderOrWaybillStatus(orderStatus, db)
|
||
if err != nil || isDuplicated {
|
||
if err == nil {
|
||
dao.Commit(db)
|
||
}
|
||
return err
|
||
}
|
||
_, err = c.loadAfsOrder(db, afsOrder.AfsOrderID, afsOrder.VendorID)
|
||
if dao.IsNoRowsError(err) {
|
||
err = c.SaveAfsOrder(db, afsOrder, isAdjust)
|
||
}
|
||
if err != nil {
|
||
return err
|
||
}
|
||
dao.Commit(db)
|
||
if orderStatus.Status == model.AfsOrderStatusWait4Approve {
|
||
|
||
} else {
|
||
|
||
}
|
||
return err
|
||
}
|
||
|
||
func (c *OrderManager) SaveAfsOrder(db *dao.DaoDB, afsOrder *model.AfsOrder, isDeleteFirst bool) (err error) {
|
||
globals.SugarLogger.Debug(afsOrder.AfsOrderID)
|
||
if db == nil {
|
||
db = dao.GetDB()
|
||
}
|
||
if err = c.updateAfsOrderOtherInfo(db, afsOrder); err != nil {
|
||
return err
|
||
}
|
||
dao.Begin(db)
|
||
defer func() {
|
||
if r := recover(); r != nil || err != nil {
|
||
dao.Rollback(db)
|
||
if r != nil {
|
||
panic(r)
|
||
}
|
||
}
|
||
}()
|
||
if isDeleteFirst {
|
||
err = utils.CallFuncLogError(func() error {
|
||
_, err = dao.DeleteEntity(db, afsOrder, "AfsOrderID")
|
||
return err
|
||
}, "SaveAfsOrder delete AfsOrder, afsOrderID:%s", afsOrder.AfsOrderID)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
err = utils.CallFuncLogError(func() error {
|
||
_, err = dao.DeleteEntity(db, &model.OrderSkuFinancial{
|
||
AfsOrderID: afsOrder.AfsOrderID,
|
||
}, "AfsOrderID")
|
||
return err
|
||
}, "SaveAfsOrder delete OrderSkuFinancial, afsOrderID:%s", afsOrder.AfsOrderID)
|
||
if err != nil {
|
||
return err
|
||
}
|
||
}
|
||
// 平台结算扣除汇总--平台补贴，售后产生运费，平台收包装费，同城运费、、、
|
||
deductionsByPm := afsOrder.PmSubsidyMoney + afsOrder.AfsFreightMoney + afsOrder.BoxMoney + afsOrder.TongchengFreightMoney
|
||
afsOrder.RefundMoneyByCal = afsOrder.SkuUserMoney + afsOrder.FreightUserMoney + deductionsByPm - afsOrder.PmRefundMoney
|
||
// order.TotalMoney += order.SkuJxMoney // 退款单京西补贴部分先不作计算
|
||
if err = dao.CreateEntity(db, afsOrder); err != nil {
|
||
globals.SugarLogger.Warnf("On SaveAfsOrder afsOrder.AfsOrderID:%s err: SaveAfsOrder is err", afsOrder.AfsOrderID)
|
||
return err
|
||
}
|
||
|
||
// 京西结算扣除汇总，先不作计算,计算单条sku最终扣款金额（+该条sku承担的平台结算扣除金额）
|
||
for _, orderSku := range afsOrder.Skus[1:] {
|
||
orderSku.RefundMoneyByCal = orderSku.PmSkuSubsidyMoney +
|
||
utils.Float64TwoInt64(float64(afsOrder.RefundMoneyByCal-afsOrder.PmSkuSubsidyMoney)*float64(orderSku.UserMoney+orderSku.PmSubsidyMoney-orderSku.PmSkuSubsidyMoney)/float64(afsOrder.SkuUserMoney+afsOrder.PmSubsidyMoney-afsOrder.PmSkuSubsidyMoney))
|
||
afsOrder.Skus[0].RefundMoneyByCal += orderSku.RefundMoneyByCal
|
||
if err = dao.CreateEntity(db, orderSku); err != nil {
|
||
globals.SugarLogger.Warnf("On SaveAfsOrder afsOrder.AfsOrderID:%s err: SaveAfsOrderSku is err", afsOrder.AfsOrderID)
|
||
return err
|
||
}
|
||
}
|
||
if len(afsOrder.Skus) > 0 {
|
||
orderSku := afsOrder.Skus[0]
|
||
orderSku.RefundMoneyByCal = afsOrder.RefundMoneyByCal - orderSku.RefundMoneyByCal
|
||
if err = dao.CreateEntity(db, orderSku); err != nil {
|
||
globals.SugarLogger.Warnf("On SaveAfsOrder afsOrder.AfsOrderID:%s err: SaveAfsOrderSku is err", afsOrder.AfsOrderID)
|
||
return err
|
||
}
|
||
} else {
|
||
globals.SugarLogger.Warnf("On SaveAfsOrder afsOrder.AfsOrderID:%s err: afsOrder have no sku", afsOrder.AfsOrderID)
|
||
}
|
||
dao.Commit(db)
|
||
return err
|
||
}
|
||
|
||
func (c *OrderManager) OnAfsOrderStatusChanged(orderStatus *model.OrderStatus) (err error) {
|
||
db := dao.GetDB()
|
||
dao.Begin(db)
|
||
defer func() {
|
||
if r := recover(); r != nil || err != nil {
|
||
dao.Rollback(db)
|
||
if r != nil {
|
||
panic(r)
|
||
}
|
||
}
|
||
}()
|
||
isDuplicated, _, err := c.addAfsOrderStatus(db, orderStatus)
|
||
if err != nil || isDuplicated {
|
||
if err == nil {
|
||
dao.Commit(db)
|
||
}
|
||
return err
|
||
}
|
||
dao.Commit(db)
|
||
return err
|
||
}
|
||
|
||
func (c *OrderManager) addAfsOrderStatus(db *dao.DaoDB, orderStatus *model.OrderStatus) (isDuplicated bool, order *model.AfsOrder, err error) {
|
||
globals.SugarLogger.Debugf("addAfsOrderStatus refOrderID:%s, orderID:%s", orderStatus.RefVendorOrderID, orderStatus.VendorOrderID)
|
||
if db == nil {
|
||
db = dao.GetDB()
|
||
}
|
||
isDuplicated, err = addOrderOrWaybillStatus(orderStatus, db)
|
||
if err == nil && !isDuplicated && (orderStatus.Status != model.OrderStatusUnknown && orderStatus.Status != model.OrderStatusMsg) {
|
||
order = &model.AfsOrder{
|
||
AfsOrderID: orderStatus.VendorOrderID,
|
||
VendorID: orderStatus.VendorID,
|
||
}
|
||
if err = db.Db.ReadForUpdate(order, "AfsOrderID", "VendorID"); err == nil {
|
||
if orderStatus.Status > model.OrderStatusUnknown { // todo 要求status不能回绕
|
||
order.VendorStatus = orderStatus.VendorStatus
|
||
order.Status = orderStatus.Status
|
||
updateFields := []string{
|
||
"VendorStatus",
|
||
"Status",
|
||
}
|
||
if model.IsAfsOrderFinalStatus(orderStatus.Status) {
|
||
order.AfsFinishedAt = orderStatus.StatusTime
|
||
updateFields = append(updateFields, "AfsFinishedAt")
|
||
}
|
||
utils.CallFuncLogError(func() error {
|
||
_, err = dao.UpdateEntity(db, order, updateFields...)
|
||
return err
|
||
}, "addAfsOrderStatus update orderID:%s, status:%v", order.VendorOrderID, orderStatus)
|
||
} else {
|
||
isDuplicated = true
|
||
}
|
||
} else {
|
||
if dao.IsNoRowsError(err) { // todo 消息错序
|
||
err = nil
|
||
} else {
|
||
globals.SugarLogger.Warnf("addAfsOrderStatus orderID:%s read failed with error:%v", order.VendorOrderID, err)
|
||
}
|
||
}
|
||
}
|
||
return isDuplicated, order, err
|
||
}
|
||
|
||
func (c *OrderManager) updateAfsOrderSkuOtherInfo(db *dao.DaoDB, order *model.AfsOrder) (err error) {
|
||
globals.SugarLogger.Debugf("updateAfsOrderSkuOtherInfo orderID:%s, VendorStoreID:%s", order.VendorOrderID, order.VendorStoreID)
|
||
jxStoreID := order.JxStoreID
|
||
if jxStoreID == 0 {
|
||
jxStoreID = order.StoreID
|
||
}
|
||
opNumStr := "2"
|
||
if jxStoreID == 0 {
|
||
globals.SugarLogger.Infof("updateAfsOrderSkuOtherInfo [运营%s]订单在京西与平台都找不到京西门店信息orderID:%s, VendorStoreID:%s", opNumStr, order.VendorOrderID, order.VendorStoreID)
|
||
return nil
|
||
}
|
||
orderSkus := order.Skus
|
||
vendorSkuIDs := make([]int64, 0)
|
||
for _, v := range orderSkus {
|
||
intVendorSkuID := utils.Str2Int64WithDefault(v.VendorSkuID, 0)
|
||
if intVendorSkuID != 0 {
|
||
vendorSkuIDs = append(vendorSkuIDs, intVendorSkuID)
|
||
}
|
||
}
|
||
if len(vendorSkuIDs) > 0 {
|
||
tableName := "t2"
|
||
if model.MultiStoresVendorMap[order.VendorID] == 1 {
|
||
tableName = "t1"
|
||
}
|
||
fieldPrefix := dao.ConvertDBFieldPrefix(model.VendorNames[order.VendorID])
|
||
sql := `
|
||
SELECT %s.%s_id vendor_sku_id, t1.id sku_id, t2.price, t1.weight
|
||
FROM sku t1
|
||
LEFT JOIN store_sku_bind t2 ON t1.id = t2.sku_id AND t2.deleted_at = ? AND t2.store_id = ?
|
||
WHERE t1.deleted_at = ? AND %s.%s_id IN (-1, ` + dao.GenQuestionMarks(len(vendorSkuIDs)) + ")"
|
||
sql = fmt.Sprintf(sql, tableName, fieldPrefix, tableName, fieldPrefix)
|
||
var skuInfos []*tStoreSkuBindAndVendorSkuID
|
||
if err = dao.GetRows(db, &skuInfos, sql, utils.DefaultTimeValue, jxStoreID, utils.DefaultTimeValue, vendorSkuIDs); err != nil {
|
||
globals.SugarLogger.Errorf("updateAfsOrderSkuOtherInfo can not get sku info for orderID:%s, error:%v", order.VendorOrderID, err)
|
||
return err
|
||
}
|
||
skumapper := make(map[int64]*tStoreSkuBindAndVendorSkuID)
|
||
for _, v := range skuInfos {
|
||
skumapper[v.VendorSkuID] = v
|
||
}
|
||
for _, v := range orderSkus {
|
||
v.JxStoreID = jxStoreID
|
||
intVendorSkuID := utils.Str2Int64WithDefault(v.VendorSkuID, 0)
|
||
if intVendorSkuID != 0 && v.VendorSkuID != "-70000" { // todo hard code
|
||
skuBindInfo := skumapper[intVendorSkuID]
|
||
if skuBindInfo == nil {
|
||
globals.SugarLogger.Infof("updateAfsOrderSkuOtherInfo [运营%s]%s订单sku找不到门店价格（或商品映射），orderID:%s, StoreID:%d, VendorSkuID:%s, sku:%v", opNumStr, model.VendorChineseNames[order.VendorID], order.VendorOrderID, jxStoreID, v.VendorSkuID, v)
|
||
} else {
|
||
v.JxSkuID = skuBindInfo.SkuID
|
||
}
|
||
}
|
||
}
|
||
}
|
||
return nil
|
||
}
|
||
|
||
func (c *OrderManager) updateAfsOrderOtherInfo(db *dao.DaoDB, order *model.AfsOrder) (err error) {
|
||
globals.SugarLogger.Debugf("updateAfsOrderOtherInfo orderID:%s, VendorStoreID:%s", order.VendorOrderID, order.VendorStoreID)
|
||
if storeDetail, err := dao.GetStoreDetailByVendorStoreID(db, order.VendorStoreID, 0); err == nil {
|
||
order.JxStoreID = storeDetail.Store.ID
|
||
}
|
||
if err == nil {
|
||
if err = c.updateAfsOrderSkuOtherInfo(db, order); err == nil {
|
||
|
||
}
|
||
}
|
||
return err
|
||
}
|