diff --git a/discount/init.py b/discount/init.py
index 55a1bdf..d45e1ab 100644
--- a/discount/init.py
+++ b/discount/init.py
@@ -434,7 +434,7 @@ async def delete_discount_detail(sor, detail_id):
 
 async def create_marketing(request, params_kw):
     """Create a marketing plan (reseller operator only)."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     resellerid = await env.get_userorgid()
     user_id = await env.get_user()
@@ -473,7 +473,7 @@ async def create_marketing(request, params_kw):
 
 async def update_marketing(request, params_kw):
     """Update a marketing plan."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     marketing_id = params_kw.get('id')
     resellerid = await env.get_userorgid()
@@ -498,7 +498,7 @@ async def update_marketing(request, params_kw):
 
 async def delete_marketing(request, params_kw):
     """Delete a marketing plan and its promo codes."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     marketing_id = params_kw.get('id')
     resellerid = await env.get_userorgid()
@@ -522,7 +522,7 @@ async def delete_marketing(request, params_kw):
 
 async def get_marketing(request, params_kw):
     """Get marketing plan detail with its discount details."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     marketing_id = params_kw.get('id')
     resellerid = await env.get_userorgid()
@@ -558,7 +558,7 @@ async def get_marketing(request, params_kw):
 
 async def list_marketings(request, params_kw):
     """List all marketing plans for current reseller."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     resellerid = await env.get_userorgid()
     
@@ -601,7 +601,7 @@ async def generate_promo_code(request, params_kw):
 
 async def disable_promo_code(request, params_kw):
     """Disable a promo code."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     code_id = params_kw.get('id')
     resellerid = await env.get_userorgid()
@@ -791,7 +791,7 @@ WHERE discountid = ${discountid}$ AND prodtypeid = ${prodtypeid}$ AND productid
 
 async def get_customer_bind(request, params_kw):
     """Get customer's binding info."""
-    env = ServerEnv()
+    env = request._run_ns
     dbname = env.get_module_dbname('discount')
     customerid = params_kw.get('customerid') or await env.get_userorgid()