diff --git a/bundled-schema/DistributionDemo.sql b/bundled-schema/DistributionDemo.sql
new file mode 100644
index 000000000..f8b1dc018
--- /dev/null
+++ b/bundled-schema/DistributionDemo.sql
@@ -0,0 +1,11 @@
+BEGIN;
+
+-- Adds a Distribution that can be accepted up to 20 times that gives one of Item Type 30 (Item Box extra page)
+INSERT INTO distribution (type, event_name, description, times_acceptable) VALUES (1, 'Extra Item Storage', '~C05Adds one new page to your Item Box.', 20);
+INSERT INTO distribution_items (distribution_id, item_type, item_id, quantity) VALUES ((SELECT id FROM distribution ORDER BY id DESC LIMIT 1), 30, 0, 1);
+
+-- Adds a Distribution that can be accepted up to 20 times that gives one of Item Type 31 (Equipment Box extra page)
+INSERT INTO distribution (type, event_name, description, times_acceptable) VALUES (1, 'Extra Equipment Storage', '~C05Adds one new page to your Equipment Box.', 20);
+INSERT INTO distribution_items (distribution_id, item_type, item_id, quantity) VALUES ((SELECT id FROM distribution ORDER BY id DESC LIMIT 1), 31, 0, 1);
+
+END;
\ No newline at end of file
diff --git a/patch-schema/10-rework-distributions.sql b/patch-schema/10-rework-distributions.sql
index 4dc794ad3..7945de343 100644
--- a/patch-schema/10-rework-distributions.sql
+++ b/patch-schema/10-rework-distributions.sql
@@ -7,7 +7,7 @@ CREATE TABLE public.distribution_items
 (
     id serial PRIMARY KEY,
     distribution_id integer NOT NULL,
-    item_type integer,
+    item_type integer NOT NULL,
     item_id integer,
     quantity integer
 );
diff --git a/server/channelserver/handlers_distitem.go b/server/channelserver/handlers_distitem.go
index 7ccf1c74d..97dbfcf15 100644
--- a/server/channelserver/handlers_distitem.go
+++ b/server/channelserver/handlers_distitem.go
@@ -104,13 +104,9 @@ type DistributionItem struct {
 	Quantity uint32 `db:"quantity"`
 }
 
-func handleMsgMhfApplyDistItem(s *Session, p mhfpacket.MHFPacket) {
-	pkt := p.(*mhfpacket.MsgMhfApplyDistItem)
-
-	bf := byteframe.NewByteFrame()
-	bf.WriteUint32(pkt.DistributionID)
+func getDistributionItems(s *Session, i uint32) []DistributionItem {
 	var distItems []DistributionItem
-	rows, err := s.server.db.Queryx(`SELECT id, item_id, item_type, quantity FROM distribution_items WHERE distribution_id=$1`, pkt.DistributionID)
+	rows, err := s.server.db.Queryx(`SELECT id, item_type, COALESCE(item_id, 0) AS item_id, COALESCE(quantity, 0) AS quantity FROM distribution_items WHERE distribution_id=$1`, i)
 	if err == nil {
 		var distItem DistributionItem
 		for rows.Next() {
@@ -121,38 +117,50 @@ func handleMsgMhfApplyDistItem(s *Session, p mhfpacket.MHFPacket) {
 			distItems = append(distItems, distItem)
 		}
 	}
+	return distItems
+}
+
+func handleMsgMhfApplyDistItem(s *Session, p mhfpacket.MHFPacket) {
+	pkt := p.(*mhfpacket.MsgMhfApplyDistItem)
+	bf := byteframe.NewByteFrame()
+	bf.WriteUint32(pkt.DistributionID)
+	distItems := getDistributionItems(s, pkt.DistributionID)
 	bf.WriteUint16(uint16(len(distItems)))
 	for _, item := range distItems {
 		bf.WriteUint8(item.ItemType)
 		bf.WriteUint32(item.ItemID)
 		bf.WriteUint32(item.Quantity)
 		bf.WriteUint32(item.ID)
-		switch item.ItemType {
-		case 17:
-			_ = addPointNetcafe(s, int(item.Quantity))
-		case 19:
-			s.server.db.Exec("UPDATE users u SET gacha_premium=gacha_premium+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
-		case 20:
-			s.server.db.Exec("UPDATE users u SET gacha_trial=gacha_trial+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
-		case 21:
-			s.server.db.Exec("UPDATE users u SET frontier_points=frontier_points+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
-		case 23:
-			saveData, err := GetCharacterSaveData(s, s.charID)
-			if err == nil {
-				saveData.RP += uint16(item.Quantity)
-				saveData.Save(s)
-			}
-		}
 	}
 	doAckBufSucceed(s, pkt.AckHandle, bf.Data())
-
-	if pkt.DistributionID > 0 {
-		_, err = s.server.db.Exec(`INSERT INTO public.distributions_accepted VALUES ($1, $2)`, pkt.DistributionID, s.charID)
-	}
 }
 
 func handleMsgMhfAcquireDistItem(s *Session, p mhfpacket.MHFPacket) {
 	pkt := p.(*mhfpacket.MsgMhfAcquireDistItem)
+	if pkt.DistributionID > 0 {
+		_, err := s.server.db.Exec(`INSERT INTO public.distributions_accepted VALUES ($1, $2)`, pkt.DistributionID, s.charID)
+		if err == nil {
+			distItems := getDistributionItems(s, pkt.DistributionID)
+			for _, item := range distItems {
+				switch item.ItemType {
+				case 17:
+					_ = addPointNetcafe(s, int(item.Quantity))
+				case 19:
+					s.server.db.Exec("UPDATE users u SET gacha_premium=gacha_premium+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
+				case 20:
+					s.server.db.Exec("UPDATE users u SET gacha_trial=gacha_trial+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
+				case 21:
+					s.server.db.Exec("UPDATE users u SET frontier_points=frontier_points+$1 WHERE u.id=(SELECT c.user_id FROM characters c WHERE c.id=$2)", item.Quantity, s.charID)
+				case 23:
+					saveData, err := GetCharacterSaveData(s, s.charID)
+					if err == nil {
+						saveData.RP += uint16(item.Quantity)
+						saveData.Save(s)
+					}
+				}
+			}
+		}
+	}
 	doAckSimpleSucceed(s, pkt.AckHandle, make([]byte, 4))
 }