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:
邹宗楠
2022-11-17 10:31:09 +08:00
parent 09773496a3
commit a542b8401c
3 changed files with 161 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/cms/sync2.go
View File

@@ -724,10 +724,13 @@ func FullSyncVendorStuff(ctx *jxcontext.Context, parentTask tasksch.ITask, store
switch step {
case 0:
_, err = amendAndPruneVendorStuff(ctx, task, storeID, vendorID, vendorOrgCode, false, isContinueWhenError, AmendPruneAll, false)
globals.SugarLogger.Debugf("========err 1 %s", err)
case 1:
_, err = SyncCategories(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, false)
globals.SugarLogger.Debugf("========err 2 %s", err)
case 2:
_, err = SyncSkus(ctx, task, []int{vendorID}, []string{vendorOrgCode}, nil, nil, false)
globals.SugarLogger.Debugf("========err 3 %s", err)
}
return retVal, err
}, []int{0, 1, 2})

1
business/model/api_config.go
View File

@@ -71,6 +71,7 @@ const (
MTWMStorePSWay13 = "0016" //达达快递
MTWMStorePSWay14 = "0033" //E_代送
)
const BrandIdChengShan = 142 // 成山农场品牌id
type VendorInfo struct {
Name string `json:"name"`

174
controllers/tiktok_order.go
View File

@@ -1,10 +1,12 @@
package controllers
import (
"encoding/json"
"git.rosy.net.cn/baseapi/platformapi/tiktok_shop/tiktok_api"
"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/business/partner/purchase/tiktok_store"
"git.rosy.net.cn/jx-callback/globals"
"git.rosy.net.cn/jx-callback/globals/api"
"github.com/astaxie/beego/server/web"
"strings"
@@ -30,27 +32,12 @@ func (t *TiktokController) CallbackTiktokOrderMsg() {
}
// 2.参数解析
orderStatus, storeMap, resp := api.TiktokStore.CreateOrderCallback(byteList)
orderStatus, resp := api.TiktokStore.CreateOrderCallback(byteList)
if resp.Code != 0 {
t.Data["json"] = resp
t.ServeJSON()
return
}
globals.SugarLogger.Debugf("storeMap %s", utils.Format4Output(storeMap, false))
// 判断订单来源(门店所属菜市,果园,其他方)
//for k, _ := range storeMap {
// vendorStoreId := utils.Int64ToStr(k)
// storeDetail, err := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), vendorStoreId, model.VendorIDDD, "")
// if err != nil {
// globals.SugarLogger.Errorf("门店信息获取失败: %s", err)
// continue
// }
// if storeDetail != nil {
// continue
// } else {
// // 进入这里面就可能是果园或者其他三放的订单了,将当前信息推送过去
// }
//}
for k, v := range orderStatus {
for _, callback := range v {
@@ -67,3 +54,156 @@ func (t *TiktokController) CallbackTiktokOrderMsg() {
t.ServeJSON()
}
func TiktokMsgChange(orderStatus []byte) (map[string][]interface{}, *tiktok_api.CallbackResponse) {
var resp []*tiktok_api.OrderCallback
if err := json.Unmarshal(orderStatus, &resp); err != nil {
return nil, &tiktok_api.CallbackResponse{Code: tiktok_api.CallbackFailCode, Msg: tiktok_api.CallbackFail}
}
callbackResult := make(map[string][]interface{}, 0)
for _, data := range resp {
switch data.Tag {
case tiktok_api.CallbackCreatedOrderMsgTagId: // 创建订单
create := tiktok_api.CreateOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackCreatedOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackCreatedOrderMsgTagId], create)
vendorStoreId := utils.Int64ToStr(create.ShopId)
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), vendorStoreId, model.VendorIDDD, "")
if storeDetail != nil && storeDetail.Store.ID != 0 && storeDetail.Store.BrandID == model.BrandIdChengShan { // 成山农场订单
} else if storeDetail != nil && storeDetail.Store.ID != 0 { // 当前菜市系统订单
continue
} else { // 果园订单
}
case tiktok_api.CallbackPayOrderMsgTagId: // 支付订单
create := tiktok_api.PayOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackPayOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackPayOrderMsgTagId], create)
case tiktok_api.CallbackWaitOrderMsgTagId: // 支付订单待处理(风控审核)
create := tiktok_api.WaitOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackWaitOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackWaitOrderMsgTagId], create)
case tiktok_api.CallbackPartGoodsMsgTagId: // 卖家部分发货
create := tiktok_api.SomeSendOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackPartGoodsMsgTagId] = append(callbackResult[tiktok_api.CallbackPartGoodsMsgTagId], create)
case tiktok_api.CallbackPartAllGoodsMsgTagId: // 卖家发货
create := tiktok_api.BusinessDeliveryData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackPartAllGoodsMsgTagId] = append(callbackResult[tiktok_api.CallbackPartAllGoodsMsgTagId], create)
case tiktok_api.CallbackCancelOrderMsgTagId: // 取消订单
create := tiktok_api.CreateOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackCancelOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackCancelOrderMsgTagId], create)
case tiktok_api.CallbackSuccessOrderMsgTagId: // 卖家确认收货时,会自动完成
create := tiktok_api.SuccessOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackSuccessOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackSuccessOrderMsgTagId], create)
case tiktok_api.CallbackWayBillChangeOrderMsgTagId: // 发货物流消息便跟
create := tiktok_api.WayBillChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackWayBillChangeOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackWayBillChangeOrderMsgTagId], create)
case tiktok_api.CallbackReceivingChangeOrderMsgTagId: // 收货地址消息变更(商家审核通过触发)
create := tiktok_api.ReceivingAddressChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackReceivingChangeOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackReceivingChangeOrderMsgTagId], create)
case tiktok_api.CallbackChangeMoneyMsgTagId: // 卖家修改订单/运单金额回调
create := tiktok_api.UpdateAmountChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackChangeMoneyMsgTagId] = append(callbackResult[tiktok_api.CallbackChangeMoneyMsgTagId], create)
case tiktok_api.CallbackBusinessRemarkMsgTagId: // 买家收货消息变更(手机,地址,姓名),用户C端修改触发(需要上面审核接口)
create := tiktok_api.BuyerUpdateWayBillData{}
if err := json.Unmarshal([]byte(data.Data), create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackBusinessRemarkMsgTagId] = append(callbackResult[tiktok_api.CallbackBusinessRemarkMsgTagId], create)
case tiktok_api.CallbackApplyUpdateAddressMsgTagId: // 商家修改交易备注回调
create := tiktok_api.BusinessUpdateRemakeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackApplyUpdateAddressMsgTagId] = append(callbackResult[tiktok_api.CallbackApplyUpdateAddressMsgTagId], create)
case tiktok_api.CallbackSendOrderTimeChangeMsgTagId: // 订单发货时消息变更回调
create := tiktok_api.AppointmentChangeData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackSendOrderTimeChangeMsgTagId] = append(callbackResult[tiktok_api.CallbackSendOrderTimeChangeMsgTagId], create)
/*********下面属于订单退货消息************/
case tiktok_api.CallbackRefundOrderMsgTagId: // 买家发起售后申请消息
create := tiktok_api.BuyerRefundCreatedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackRefundOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackRefundOrderMsgTagId], create)
case tiktok_api.CallbackUpdateRefundOrderMsgTagId: // 买家修改售后申请消息
create := tiktok_api.BuyerRefundModifiedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackUpdateRefundOrderMsgTagId] = append(callbackResult[tiktok_api.CallbackUpdateRefundOrderMsgTagId], create)
case tiktok_api.CallbackRefundOrderSuccessMsgTagId: // 退款成功消息
create := tiktok_api.BusinessRefundSuccessData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackRefundOrderSuccessMsgTagId] = append(callbackResult[tiktok_api.CallbackRefundOrderSuccessMsgTagId], create)
case tiktok_api.CallbackRefundOrderRefuseMsgTagId: // 拒绝退款消息
create := tiktok_api.BusinessNotRefundRefusedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackRefundOrderRefuseMsgTagId] = append(callbackResult[tiktok_api.CallbackRefundOrderRefuseMsgTagId], create)
case tiktok_api.CallbackRefundShopMsgTagId: // 拒绝退货申请消息
create := tiktok_api.BusinessNotReturnApplyRefusedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackRefundShopMsgTagId] = append(callbackResult[tiktok_api.CallbackRefundShopMsgTagId], create)
case tiktok_api.CallbackReturnApplyAgreedMsgTagId: // 卖家同意时，推送此消息
create := tiktok_api.BusinessReturnApplyAgreedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackReturnApplyAgreedMsgTagId] = append(callbackResult[tiktok_api.CallbackReturnApplyAgreedMsgTagId], create)
case tiktok_api.CallbackReturnRefundAgreedMsgTagId: // 同意退款消息
create := tiktok_api.BusinessRefundAgreedData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackReturnRefundAgreedMsgTagId] = append(callbackResult[tiktok_api.CallbackReturnRefundAgreedMsgTagId], create)
case tiktok_api.CallbackRefundClosedMsgTagId:
create := tiktok_api.UserCancelRefundOrderData{}
if err := json.Unmarshal([]byte(data.Data), &create); err != nil {
return nil, tiktok_api.CallbackResponseErr(false)
}
callbackResult[tiktok_api.CallbackRefundClosedMsgTagId] = append(callbackResult[tiktok_api.CallbackRefundClosedMsgTagId], create)
default:
return nil, tiktok_api.CallbackResponseErr(false)
}
}
return callbackResult, &tiktok_api.CallbackResponse{Code: tiktok_api.CallbackSuccessCode, Msg: tiktok_api.CallbackSuccess}
}