|
|
@@ -512,13 +512,13 @@ class OnlineDataRequest(object):
|
|
|
print("上传商品api==>resultData", resultData)
|
|
|
return resultData
|
|
|
|
|
|
- def sendSocketMessage(self, code=0, msg="", data=None, device_status=2):
|
|
|
+ def sendSocketMessage(self, code=0, msg="", data=None, device_status=2,msg_type="upload_goods_progress"):
|
|
|
data = {
|
|
|
"code": code,
|
|
|
"msg": msg,
|
|
|
"status": device_status,
|
|
|
"data": data,
|
|
|
- "msg_type": self.msg_type,
|
|
|
+ "msg_type": msg_type,
|
|
|
}
|
|
|
loop = asyncio.get_event_loop()
|
|
|
loop.create_task(message_queue.put(data))
|
|
|
@@ -530,7 +530,7 @@ class OnlineDataRequest(object):
|
|
|
code=0,
|
|
|
msg="开始上传商品数据",
|
|
|
data={"online_stores": online_stores, "status": "进行中"},
|
|
|
- message_type=message_type,
|
|
|
+ msg_type=message_type,
|
|
|
)
|
|
|
if goods_no_dict == None:
|
|
|
return
|
|
|
@@ -631,7 +631,7 @@ class OnlineDataRequest(object):
|
|
|
code=0,
|
|
|
msg="商品上传第三方成功",
|
|
|
data={"online_stores": online_stores, "status": "已完成"},
|
|
|
- message_type=message_type,
|
|
|
+ msg_type=message_type,
|
|
|
)
|
|
|
|
|
|
|
rambo