|
|
|
@ -88,6 +88,7 @@ func ShaMaMq() {
|
|
|
|
|
go OrderShaMaPay()
|
|
|
|
|
go OrderShaMaCancel()
|
|
|
|
|
go OrderShaMaStockOut()
|
|
|
|
|
go ShaMaSkuPrice()
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func TaskMq() {
|
|
|
|
@ -102,6 +103,40 @@ func TaskMq() {
|
|
|
|
|
|
|
|
|
|
const maxRetryNum = 1
|
|
|
|
|
|
|
|
|
|
func ShaMaSkuPrice() {
|
|
|
|
|
q := fmt.Sprintf("sku.price.queue.%s", configs.ConfigJCookAppKey)
|
|
|
|
|
mq.Conn.ListenRetry(q, maxRetryNum, func(data []byte) error {
|
|
|
|
|
client := jcook.GetClient()
|
|
|
|
|
var m model.SkuChange
|
|
|
|
|
err := json.Unmarshal(data, &m)
|
|
|
|
|
if err != nil {
|
|
|
|
|
log.Println(err.Error())
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
rq := jcook.SkuPriceReq{
|
|
|
|
|
SkuIDSet: []uint{m.SkuID},
|
|
|
|
|
}
|
|
|
|
|
var res []jcook.SkuPriceResp
|
|
|
|
|
if err := client.Exec(rq, &res); err != nil {
|
|
|
|
|
log.Println(err.Error())
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
if len(res) == 0 {
|
|
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
t := res[0]
|
|
|
|
|
|
|
|
|
|
var sku goods2.RecookGoodsSkuModel
|
|
|
|
|
if err := mysql.Db.Table(sku.TableName()).Where("third_party_sku_id = ?", t.SkuID).Updates(map[string]interface{}{
|
|
|
|
|
"sale_purchase_price": t.SupplyPrice,
|
|
|
|
|
}).Error; err != nil {
|
|
|
|
|
log.Println(err.Error())
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
return nil
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func OrderShaMaStockOut() {
|
|
|
|
|
q := fmt.Sprintf("order.stock.out.queue.%s", configs.ConfigShaMaAppKey)
|
|
|
|
|
mq.Conn1.ListenRetry(q, maxRetryNum, func(data []byte) error {
|
|
|
|
|