sku sync字段

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,
 				}

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)
+			temp := string(msg)
-			//fmt.Print(temp)
+			fmt.Print(temp)
 			if err != nil {
 				if messageType == -1 && websocket.IsCloseError(err, websocket.CloseGoingAway, websocket.CloseNormalClosure, websocket.CloseNoStatusReceived) {
 					Manager.DisConnect <- c