From 4b82890145759ffe3f74dad924b61c0142ae4625 Mon Sep 17 00:00:00 2001 From: richboo111 Date: Wed, 10 May 2023 16:00:00 +0800 Subject: [PATCH] =?UTF-8?q?sku=20sync=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/store_sku.go | 15 ++++++++------- business/partner/purchase/im/im_server.go | 4 ++-- 2 files changed, 10 insertions(+), 9 deletions(-) diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go index 088f8403c..bdbc50ec8 100644 --- a/business/jxstore/cms/store_sku.go +++ b/business/jxstore/cms/store_sku.go @@ -408,20 +408,21 @@ func GetStoresSkusForStore(ctx *jxcontext.Context, storeID int, isFocus, isAct b func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { v := batchItemList[0].(*dao.StoreSkuNameExt2) var skus []*dao.StoreSkuExt + // sql2 := ` + // SELECT a.id sku_id, a.spec_quality sku_spec_quality, a.spec_unit sku_spec_unit, a.status sku_status, a.comment, + // b.stock, b.price bind_price, b.unit_price, + // b.status store_sku_status + // FROM sku a + // JOIN sku_name c ON a.name_id = c.id AND c.deleted_at = ? AND c.status = ? + //` sql2 := ` SELECT a.id sku_id, a.spec_quality sku_spec_quality, a.spec_unit sku_spec_unit, a.status sku_status, a.comment, - b.stock, b.price bind_price, b.unit_price, + b.stock, b.price bind_price, b.unit_price,b.jd_sync_status,b.mtwm_id,b.mtwm_sync_status,b.ebai_id,b.ebai_sync_status, b.status store_sku_status FROM sku a JOIN sku_name c ON a.name_id = c.id AND c.deleted_at = ? AND c.status = ? ` - // sql2 := ` - // SELECT a.*,b.* - // FROM sku a - // JOIN sku_name c ON a.name_id = c.id AND c.deleted_at = ? AND c.status = ? - //` - sqlParams2 := []interface{}{ utils.DefaultTimeValue, model.SkuStatusNormal, } diff --git a/business/partner/purchase/im/im_server.go b/business/partner/purchase/im/im_server.go index d635146dc..798b39b71 100644 --- a/business/partner/purchase/im/im_server.go +++ b/business/partner/purchase/im/im_server.go @@ -155,8 +155,8 @@ func (c *Client) Read() { go func() { for { messageType, msg, err := c.Socket.ReadMessage() - //temp := string(msg) - //fmt.Print(temp) + temp := string(msg) + fmt.Print(temp) if err != nil { if messageType == -1 && websocket.IsCloseError(err, websocket.CloseGoingAway, websocket.CloseNormalClosure, websocket.CloseNoStatusReceived) { Manager.DisConnect <- c