测试

cmd/queue/sync_out_store/main.go

@@ -61,7 +61,6 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 	if err = json.Unmarshal(dataByte, &message); err != nil {
 	if err = json.Unmarshal(dataByte, &message); err != nil {
 		goto ERR
 		goto ERR
 	}
 	}
-	return nil
 	//判断操作类型
 	//判断操作类型
 	switch message.Type {
 	switch message.Type {
 	case "save":
 	case "save":
@@ -94,6 +93,8 @@ func (t *RecvPro) Consumer(dataByte []byte) error {
 		err = errors.New("同步出货单出现不存在的操作类型" + operateType)
 		err = errors.New("同步出货单出现不存在的操作类型" + operateType)
 		goto ERR
 		goto ERR
 	}
 	}
+	err = errors.New("123213")
+	goto ERR
 	//没有操作类型,代表的是已经后端同步成功过一次的了,直接去请求金蝶同步状态即可
 	//没有操作类型,代表的是已经后端同步成功过一次的了,直接去请求金蝶同步状态即可
 	if operateType != "" {
 	if operateType != "" {
 		//操作成功后还要去请求后端接口同步数据
 		//操作成功后还要去请求后端接口同步数据