测试

cmd/queue/sync_out_store/main.go

@@ -117,7 +117,6 @@ func SyncOutStoreData(operate string, message OutStoreMessage) (err error) {
 		params   map[string]interface{}
 		params   map[string]interface{}
 	)
 	)
 	params = TransformParams(message)
 	params = TransformParams(message)
-	return errors.New("2131232132")
 	//构建请求数据
 	//构建请求数据
 	param := req.BodyJSON(&params)
 	param := req.BodyJSON(&params)
 
 
@@ -131,6 +130,8 @@ func SyncOutStoreData(operate string, message OutStoreMessage) (err error) {
 	billId := message.Data.FSourceBillID
 	billId := message.Data.FSourceBillID
 	if operate == "insert" {
 	if operate == "insert" {
 		resp, err = req.Post(url, param)
 		resp, err = req.Post(url, param)
+		err = errors.New(fmt.Sprintf("%s",resp))
+		return err
 		if err != nil {
 		if err != nil {
 			return
 			return
 		}
 		}