Subversion Repositories SmartDukaan

package in.shop2020.ui.util;

import in.shop2020.model.v1.catalog.CatalogService.Client;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.thrift.clients.CatalogClient;

import java.io.OutputStreamWriter;
import java.io.Serializable;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.ResourceBundle;

import com.google.gson.Gson;

public class CatalogUploderToGAE implements Serializable {
    private static final long serialVersionUID = -326425176723602170L;
    private static final String NAME_KEY = "name";
    private static final String ID_KEY = "id";
    private static final String CATALOG_ID_KEY = "catalog_id";
    private static final String BRAND_KEY = "brand";
    private static final String COLOR_KEY = "color";
    
    private static ResourceBundle properties = ResourceBundle.getBundle(CatalogUploderToGAE.class.getName());
    private static String googleAppUrl = properties.getString("googleappurl");

    public void uploadItems(List<Item> items) {
        List<Map<String, String>> jsonItems = new ArrayList<Map<String, String>>();
        for (Item item : items) {
            String name = ((item.getBrand() != null) ? item.getBrand().trim()
                    + " " : "")
                    + ((item.getModelName() != null) ? item.getModelName()
                            .trim() + " " : "")
                    + ((item.getModelNumber() != null) ? item.getModelNumber()
                            .trim() : "");
            Map<String, String> jsonItem = new HashMap<String, String>();
            jsonItem.put(ID_KEY, Long.toString(item.getId()));
            jsonItem.put(CATALOG_ID_KEY, Long.toString(item.getCatalogItemId()));
            jsonItem.put(NAME_KEY, name);
            jsonItem.put(BRAND_KEY, item.getBrand());
            jsonItem.put(COLOR_KEY, item.getColor());
            jsonItems.add(jsonItem);
        }
        Gson gson = new Gson();
        postRequest(gson.toJson(jsonItems));
    }

    public static void main(String[] args) throws Exception {
        CatalogClient csc = new CatalogClient();
        Client client = csc.getClient();
        List<Item> allItems = client.getAllItems(false);
        allItems.addAll(client.getAllItems(true));
        CatalogUploderToGAE catalogUploaderToGAE = new CatalogUploderToGAE();
        catalogUploaderToGAE.uploadItems(allItems);
    }

    private void postRequest(String postData) {
        try {
            URL url = new URL("http://" + googleAppUrl + "/upload-catalog-items");
            URLConnection conn = url.openConnection();
            conn.setDoOutput(true);
            OutputStreamWriter wr = new OutputStreamWriter(conn.getOutputStream());
            String data = URLEncoder.encode("data", "UTF-8") + "=" + URLEncoder.encode(postData.toString(), "UTF-8");
            wr.write(data);
            wr.close();
            
            conn.getInputStream().close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}