update

consume/mall_add_supply_goods.go

@@ -109,5 +109,7 @@ func handleMallAddSupplyGoodsConsume(msgData []byte) error {
 			return err1
 		}
 	}
+
+	db.Db.Where("id = ?", pushStuct.Affected).Delete(model2.MallAddSupplyGoods{})
 	return nil
 }