wip:发票状态修改

internal/service/invoiceCallback_blue.go

@@ -83,6 +83,9 @@ func updateOrderInvoiceStatus(ctx context.Context, callBackId, invoiceNum string
 		return err
 	}
 	err = g.DB().Transaction(ctx, func(ctx context.Context, tx gdb.TX) error {
+		if queryItem == "" || queryValue == "" {
+			return gerror.Wrap(err, "updateOrderInvoiceStatus 回调字段异常")
+		}
 		//invoice_status: 0新开 2红冲后新开
 		record, sqlErr := tx.GetOne(fmt.Sprintf("SELECT only_Identifying,invoice_changed FROM invoice WHERE %s =? AND invoice_status in(0,2) ORDER BY id desc", queryItem), queryValue)
 		if err != nil {
@@ -93,14 +96,11 @@ func updateOrderInvoiceStatus(ctx context.Context, callBackId, invoiceNum string
 		}
 
 		var (
-			invoiceChanged = gconv.Int(record["invoice_changed"]) == 1                         //换票
-			isBackInvoice  = strings.HasPrefix(gconv.String(record["only_Identifying"]), "xx") //是否是管理后台的开票
+			invoiceChanged = gconv.Int(record["invoice_changed"]) == 1 //换票
+			onlyId         = gconv.String(record["only_Identifying"])
+			isBackInvoice  = strings.HasPrefix(onlyId, "xx") //是否是管理后台的开票
 		)
 
-		if queryItem == "" || queryValue == "" {
-			return gerror.Wrap(err, "updateOrderInvoiceStatus 回调字段异常")
-		}
-
 		//更新发票内容
 		_, err = tx.Update("invoice", g.Map{
 			"invoice_number": invoiceNum,
@@ -114,7 +114,7 @@ func updateOrderInvoiceStatus(ctx context.Context, callBackId, invoiceNum string
 
 		// 管理后台非换票的开票，需要更新订单是否全部开票完成
 		if !invoiceChanged && isBackInvoice {
-			if sqlErr = selfInvoicing(tx, queryValue); err != nil {
+			if sqlErr = selfInvoicing(tx, onlyId); err != nil {
 				return gerror.Wrap(sqlErr, "更新订单是否全部开票完成异常")
 			}
 		}