liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-12-29 11:32:39 +08:00
parent 5ecfc002fb
commit a759f0afe6
4 changed files with 69 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
business/jxcallback/orderman/order.go
View File

@@ -2655,25 +2655,45 @@ func ExportOrderWithSku(ctx *jxcontext.Context, orders []*model.GoodsOrderExt) (
}
// UpdateTiktokShopTotalMoney 定时任务更新抖店订单的平台结算
func UpdateTiktokShopTotalMoney() {
db := dao.GetDB()
var goodsOrders []*model.GoodsOrder
func UpdateTiktokShopTotalMoney(storeId int64, startTime, endTime time.Time) error {
var (
db = dao.GetDB()
goodsOrders = make([]*model.GoodsOrder, 0, 0)
nextStartIndex = ""
errList = make([]string, 0, 0)
)
globals.SugarLogger.Debugf("=============time:= %s", utils.Format4Output(time.Now(), false))
sql := `SELECT g.* FROM goods_order g WHERE g.order_created_at >= ? AND g.status = ? AND g.vendor_id = ? AND total_shop_money = ? ORDER BY g.order_created_at desc`
orderCreateTime := time.Now().AddDate(0, 0, -50)
param := []interface{}{orderCreateTime, model.OrderStatusFinished, model.VendorIDDD, model.NO}
if err := dao.GetRows(db, &goodsOrders, sql, param...); err != nil {
globals.SugarLogger.Debugf("Update GoodsOrder Total shop money err %s", err)
return
sql := `SELECT g.* FROM goods_order g WHERE 1=1 `
param := []interface{}{}
if storeId != 0 {
sql += `AND g.store_id = ?`
param = append(param, storeId)
}
if !utils.IsTimeZero(startTime) {
sql += ` AND g.order_created_at >= ? `
param = append(param, startTime)
}
if !utils.IsTimeZero(endTime) {
sql += ` AND g.order_created_at <= ? `
param = append(param, endTime)
}
if utils.IsTimeZero(startTime) && utils.IsTimeZero(endTime) {
orderCreateTime := time.Now().AddDate(0, 0, -50)
sql += ` AND g.order_created_at >= ? `
param = append(param, orderCreateTime)
}
sql += ` AND g.status = ? AND g.vendor_id = ? AND total_shop_money = ? ORDER BY g.order_created_at desc`
param = append(param, []interface{}{model.OrderStatusFinished, model.VendorIDDD, model.NO}...)
if err := dao.GetRows(db, &goodsOrders, sql, param...); err != nil {
return err
}
nextStartIndex := ""
for _, v := range goodsOrders {
globals.SugarLogger.Debugf("=============goods := %s", utils.Format4Output(goodsOrders, false))
globals.SugarLogger.Debugf("=============测试打印: %s", v.VendorOrderID)
orderDetail, err := tiktok_store.GetOrderDetail(v.VendorOrgCode, v.VendorOrderID)
if err != nil {
globals.SugarLogger.Errorf("定时任务:查询订单详情错误,更新订单结算信息,[%s]", err)
errList = append(errList, fmt.Sprintf("详情错误orderID[%s],%v", v.VendorOrderID, err))
continue
}
@@ -2684,7 +2704,7 @@ func UpdateTiktokShopTotalMoney() {
totalShopMoney, next, err := tiktok_store.GetOrderTotalShopMoney(v.VendorOrgCode, strings.Join(childrenOrderList, ","), nextStartIndex)
if err != nil {
globals.SugarLogger.Errorf("获取平台订单异常 : %s", err)
errList = append(errList, fmt.Sprintf("结算错误orderID[%s],%v", v.VendorOrderID, err))
continue
}
nextStartIndex = next
@@ -2703,10 +2723,11 @@ func UpdateTiktokShopTotalMoney() {
}
}
if _, err = dao.UpdateEntity(db, v, "TotalShopMoney", "NewEarningPrice"); err != nil {
globals.SugarLogger.Errorf("更新本地订单结算信息错误 : %s", err)
errList = append(errList, fmt.Sprintf("修改本地结算错误orderID[%s],%v", v.VendorOrderID, err))
continue
}
}
return fmt.Errorf(strings.Join(errList, "|"))
}
// UpdateTaoSettleInfo 定时任务更新淘鲜达结算信息