diff --git a/wrenchboard/src/shared_tool/account.cc b/wrenchboard/src/shared_tool/account.cc
index 56d42b03..03a1fde2 100644
--- a/wrenchboard/src/shared_tool/account.cc
+++ b/wrenchboard/src/shared_tool/account.cc
@@ -683,11 +683,10 @@ CREATE TABLE members_myfiles (
     ADD CONSTRAINT members_myfiles_id_key UNIQUE (id);
 
 */
-
-long WrenchGetRecentDash(CVars in, CVars &out) {
 long WrenchJobCount(long member_id);
 long WrenchFamilyCount(long member_id);
 
+long WrenchGetRecentDash(CVars in, CVars &out) {
 
 logfmt(logINFO, "WrenchGetRecentDash()");
     char vname[30];
diff --git a/wrenchboard/src/shared_tool/market.cc b/wrenchboard/src/shared_tool/market.cc
index d4c50f05..699bc6cb 100644
--- a/wrenchboard/src/shared_tool/market.cc
+++ b/wrenchboard/src/shared_tool/market.cc
@@ -15,6 +15,7 @@
 #include "cfg.h"
 #include <curl/curl.h>
 
+long WrenchMarketImport(CVars in, CVars &out);
 
 long market_calls(CVars in, CVars &out) {
     logfmt(logINFO, "market_calls()");
@@ -24,16 +25,14 @@ long market_calls(CVars in, CVars &out) {
         try {
         long action = REQ_LONG( in, "action", 1, -1 );
             switch(action){
-                    case WRENCHBOARD_MARKET_PLAN01_START:
-                      snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
-                      market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
+                case WRENCHBOARD_MARKET_PLAN01_START:
+                    return  WrenchMarketImport(in, out);
+                break;
 
-                    break;
-
-                    case WRENCHBOARD_MARKET_PLAN01_NEXT1:
-                      snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
-                     market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
-                    break;
+                case WRENCHBOARD_MARKET_PLAN01_NEXT1:
+                  snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
+                //  market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
+                break;
             }
 
     } catch (bad_parameter) {
@@ -43,6 +42,41 @@ long market_calls(CVars in, CVars &out) {
     return ret;
 }
 
+
+long WrenchMarketImport(CVars in, CVars &out) {
+logfmt(logINFO, "WrenchMarketImport()");
+    char vname[30];
+    long ret = PHP_API_BAD_PARAM;
+
+    try {
+         out["total_record"] = "0";
+        const PGresult *res;
+        res = pgsql_query("SELECT * FROM market_import WHERE status =1 LIMIT 4");
+
+        if (res != NULL && pgsql_num_rows(res) > 0) {
+            out["total_record"] = pgsql_num_rows(res);
+
+            for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
+                map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
+                if (f.empty()) continue;
+                CVars rec;
+                map_to_cvars(f, rec);
+
+               market_email(WRENCHBOARD_MARKET_PLAN01_START, rec, rec);
+
+            }
+        }
+        ret = PHP_API_OK;
+        out["status"] = "OK";
+    } catch (bad_parameter) {
+        logfmt(logINFO, "ERROR CALL long WrenchMarketImport(CVars in, CVars &out)");
+    }
+    logfmt(logINFO, "/WrenchMarketImport()");
+
+    return ret;
+}
+
+
 /*
 #define WRENCHBOARD_MARKET_PLAN01_START   220001
 #define WRENCHBOARD_MARKET_PLAN01_NEXT1   220003