修复

cmd/queue/sync_out_store/main.go

@@ -130,13 +130,11 @@ 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 err
 		}
 		}
 		if err = resp.ToJSON(&respData); err != nil {
 		if err = resp.ToJSON(&respData); err != nil {
-			return
+			return err
 		}
 		}
 		if respData.Errcode != 0 {
 		if respData.Errcode != 0 {
 			paramJson, _ := json.Marshal(params)
 			paramJson, _ := json.Marshal(params)
@@ -144,7 +142,7 @@ func SyncOutStoreData(operate string, message OutStoreMessage) (err error) {
 		}
 		}
 		//都没问题,代表后端那边已经成功修改,修改同步表的状态
 		//都没问题,代表后端那边已经成功修改,修改同步表的状态
 		if err = logic.SyncOutStoreSuccess(billId, false); err != nil {
 		if err = logic.SyncOutStoreSuccess(billId, false); err != nil {
-			return
+			return err
 		}
 		}
 	}
 	}
 	return
 	return