91 lines
3.4 KiB
Go
91 lines
3.4 KiB
Go
package controllers
|
|
|
|
import (
|
|
"encoding/json"
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/business/model/dao"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"strings"
|
|
"sync"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi/ebaiapi"
|
|
"git.rosy.net.cn/jx-callback/business/partner/purchase/ebai"
|
|
"git.rosy.net.cn/jx-callback/globals/api"
|
|
"github.com/astaxie/beego/server/web"
|
|
)
|
|
|
|
type EbaiController struct {
|
|
web.Controller
|
|
}
|
|
|
|
var EBaiVendorStoreIDList = new(sync.Map)
|
|
|
|
func (c *EbaiController) Msg() {
|
|
if c.Ctx.Input.Method() == http.MethodPost {
|
|
obj, callbackResponse := api.EbaiAPI.GetCallbackMsg(c.Ctx.Request, web.BConfig.RunMode)
|
|
if callbackResponse == nil {
|
|
vendorStoreId, _ := utils.TryInterface2Int64(obj.Body["platform_shop_id"])
|
|
if _, have := EBaiVendorStoreIDList.Load(vendorStoreId); vendorStoreId != 0 && !have {
|
|
storeDetail, _ := dao.GetStoreDetailByVendorStoreID(dao.GetDB(), utils.Int64ToStr(vendorStoreId), model.VendorIDEBAI, "")
|
|
if storeDetail == nil {
|
|
switch web.BConfig.RunMode {
|
|
case model.ServerTypeVegetable:
|
|
callbackResponse = c.EBaiMsgPush2FruitsOrPet(model.ServerTypeFruits, utils.Struct2Map(obj, "", false))
|
|
case model.ServerTypeFruits:
|
|
callbackResponse = c.EBaiMsgPush2FruitsOrPet(model.ServerTypePet, utils.Struct2Map(obj, "", false))
|
|
case model.ServerTypePet:
|
|
//ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "47B1E94E8D2411EFB666525400E86DC0", "饿了么菜市推果园,果园退超市未找到门店", fmt.Sprintf("饿了么菜市推果园cmd:%s,storeId:%s", obj.Cmd, vendorStoreId))
|
|
callbackResponse = api.EbaiAPI.Err2CallbackResponse(ebaiapi.GetCmd(c.Ctx.Request), nil, nil) // api.EbaiAPI.Err2CallbackResponse(ebaiapi.GetCmd(c.Ctx.Request), fmt.Errorf("饿了么菜市推果园,果园退超市未找到门店cmd:%s,storeId:%s", obj.Cmd, vendorStoreId), nil)
|
|
return
|
|
}
|
|
c.Data["json"] = callbackResponse
|
|
c.ServeJSON()
|
|
return
|
|
} else {
|
|
EBaiVendorStoreIDList.Store(vendorStoreId, model.YES)
|
|
}
|
|
}
|
|
callbackResponse = ebai.OnCallbackMsg(obj)
|
|
}
|
|
if callbackResponse == nil {
|
|
callbackResponse = api.EbaiAPI.Err2CallbackResponse(ebaiapi.GetCmd(c.Ctx.Request), nil, nil)
|
|
}
|
|
c.Data["json"] = callbackResponse
|
|
c.ServeJSON()
|
|
} else {
|
|
c.Abort("404")
|
|
}
|
|
}
|
|
|
|
func (c *EbaiController) EBaiMsgPush2FruitsOrPet(serverType string, msg map[string]interface{}) *ebaiapi.CallbackResponse {
|
|
msgBody, _ := json.Marshal(msg["body"])
|
|
msg["body"] = string(msgBody)
|
|
cl := http.Client{}
|
|
var request *http.Request
|
|
var err error
|
|
switch serverType {
|
|
case model.ServerTypeFruits:
|
|
request, err = http.NewRequest(http.MethodPost, "http://callback-jxgy.jxc4.com/ebai/msg", strings.NewReader(utils.Map2URLValues(msg).Encode()))
|
|
case model.ServerTypePet:
|
|
request, err = http.NewRequest(http.MethodPost, "http://callback-gblm.jxc4.com/ebai/msg", strings.NewReader(utils.Map2URLValues(msg).Encode()))
|
|
}
|
|
if err != nil {
|
|
return api.EbaiAPI.Err2CallbackResponse(ebaiapi.GetCmd(c.Ctx.Request), err, nil)
|
|
}
|
|
|
|
request.Header.Set("Content-Type", "application/x-www-form-urlencoded")
|
|
request.Header.Set("accept", "application/json, text/plain, */*")
|
|
resp, err := cl.Do(request)
|
|
if err != nil {
|
|
return api.EbaiAPI.Err2CallbackResponse(ebaiapi.GetCmd(c.Ctx.Request), err, nil)
|
|
}
|
|
defer resp.Body.Close()
|
|
byteData, _ := ioutil.ReadAll(resp.Body)
|
|
result := ebaiapi.CallbackResponse{}
|
|
json.Unmarshal(byteData, &result)
|
|
|
|
return &result
|
|
}
|