Subversion Repositories SmartDukaan

package in.shop2020.googleadwords.util;

import java.util.ArrayList;

import java.util.Collections;

import java.util.HashSet;

import java.util.List;

import java.util.Set;

import java.util.regex.Matcher;

import java.util.regex.Pattern;

import org.apache.thrift.TException;

import org.apache.thrift.transport.TTransportException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import adwords.axis.v201309.basicoperations.AddTextAds;

import adwords.axis.v201309.basicoperations.PauseAd;

import in.shop2020.googleadwords.AdwordsAdGroup;

import in.shop2020.googleadwords.AdwordsAdGroupAd;

import in.shop2020.googleadwords.GoogleAdwordsServiceException;

import in.shop2020.googleadwords.GoogleAdwordsService.Client;

import in.shop2020.model.v1.catalog.CatalogServiceException;

import in.shop2020.model.v1.catalog.Item;

import in.shop2020.model.v1.catalog.status;

import in.shop2020.thrift.clients.AdwordsClient;

import in.shop2020.thrift.clients.CatalogClient;

/*

 * Class AdwordsTextAdItemPriceSync - To Change Price of Item in the AdGroup Text Ad 

 * Accordingly to Item Price stored in our system.   

 */

public class AdwordsTextAdItemPriceSync{

	private static Logger logger = LoggerFactory.getLogger(AdwordsTextAdItemPriceSync.class);

	public static void main(String[] args) {

		AdwordsClient adwordsServiceClient= null;

		CatalogClient catalogServiceClient = null;

		try {

			adwordsServiceClient = new AdwordsClient();

			catalogServiceClient = new CatalogClient();

		} catch (TTransportException e1) {

			System.out.println("Error while Getting AdwordsClient.. "+e1.getMessage());

			logger.error("Error while Getting AdwordsClient.. "+e1.getMessage());

		}

		if(adwordsServiceClient!=null){

			Client client = adwordsServiceClient.getClient();

			//Get List of All Running AdGroups

			List<AdwordsAdGroup> adgroupList =null;

			try {

				adgroupList = client.getAllAdwordsAdGroups();

			} catch (GoogleAdwordsServiceException e) {

				System.out.println("Error while Requesting Data from AdwordsClient.. "+e.getMessage());

				logger.error("Error while Requesting Data from AdwordsClient.. "+e.getMessage());

			} catch (TException e) {

				System.out.println("Error while Getting Data from AdwordsClient.. "+e.getMessage());

				logger.error("Error while Getting Data from AdwordsClient.. "+e.getMessage());

			}

			//Creating Set of AdGroups that having Catalog Id greater than zero.

			Set<AdwordsAdGroup> adGroupSet = new HashSet<AdwordsAdGroup>();

			for(AdwordsAdGroup adgroup: adgroupList){

				if(adgroup.getCatalogItemId()>0L){

					adGroupSet.add(adgroup);

				}

			}

			List<Long> errorAdGroupList = new ArrayList<Long>();

			List<Long> errorTextAdList = new ArrayList<Long>();

			for(AdwordsAdGroup adGroup : adGroupSet){

				if(catalogServiceClient!=null){

					long systemItemPrice = 0l;

					in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();

					//Get List of Items corresponding to Catalog Id.

					List<Item> itemList = null;

					try {

						itemList = catalogClient.getItemsByCatalogId(adGroup.getCatalogItemId());

					} catch (CatalogServiceException e) {

						System.out.println("Catalog Service EXception.."+e.getMessage());

						logger.error("Catalog Service EXception.."+e.getMessage());

					} catch (TException e) {

						System.out.println("Error While Getting Data from Catalog Client"+e.getMessage());

						logger.error("Error While Getting Data from Catalog Client"+e.getMessage());

					}

					//Get Item system price. Here minimum item price will be considered.

					List<Double> priceList = new ArrayList<Double>();

					if(itemList!=null){

						for(Item item : itemList){

							if(status.ACTIVE==item.getItemStatus()){

								priceList.add(item.getSellingPrice());

							}

						}

					}

					else{

						continue;

					}

					Collections.sort(priceList);

					systemItemPrice = (long)priceList.get(0).doubleValue();

					long priceAtGoogleEnd = 0l;

					//Get All AdGroup Ads as per AdGroup Id.

					List<AdwordsAdGroupAd> textAdList = null;

					try {

						textAdList = client.getAdwordsAdGroupAdsByAdgroupId(adGroup.getAdgroupId());

						if(textAdList!=null){

							for(AdwordsAdGroupAd textAd : textAdList){

								//Check For Price Pattern in the Ad.

								Pattern pattern = Pattern.compile("Rs(.*?)#");

							    Matcher matcher = pattern.matcher(textAd.getDescription1());

							    String change = "";

							    while (matcher.find()) {

							        change=matcher.group(1);

							    }

							    if("".equalsIgnoreCase(change)){

							    	continue;

							    }

							    try{

							    	priceAtGoogleEnd = Long.parseLong(change);

							    	if(priceAtGoogleEnd > 0l){

							    		//Check for Price Change

							    		if(priceAtGoogleEnd != systemItemPrice){

							    			//Change status of Current Ad to PAUSED and Add a new Ad.

							    			try {

							    				AdwordsAdGroupAd adgrpad = new AdwordsAdGroupAd();

												adgrpad.setAdgroupadId(PauseAd.runExample(textAd.getAdgroupId(), textAd.getAdgroupadId()));

												adgrpad.setAdgroupId(textAd.getAdgroupId());

												adgrpad.setCampaignId(textAd.getCampaignId());

												adgrpad.setDescription1(textAd.getDescription1());

												adgrpad.setDescription2(textAd.getDescription2());

												adgrpad.setDisplayUrl(textAd.getDisplayUrl());

												adgrpad.setHeadline(textAd.getHeadline());

												adgrpad.setUrl(textAd.getUrl());

												client.updateAdwordsAdGroupAd(adgrpad);

											} catch (Exception e1) {

												System.out.println("Error While Pausing the Adwords Text Ad with Ad Id.."+textAd.getAdgroupadId()+"...Exception...."+e1.getMessage());

												logger.error("Error While Pausing the Adwords Text Ad with Ad Id.."+textAd.getAdgroupadId()+"...Exception...."+e1.getMessage());

												continue;

											}

							    			String newDescription1 = textAd.getDescription1().replace(change, systemItemPrice+"");

							    			Long adGroupAdId =0l;

											try {

												adGroupAdId = AddTextAds.runExample(textAd.getAdgroupId(), textAd.getHeadline(), newDescription1, textAd.getDescription2(), textAd.getUrl(), textAd.getDisplayUrl());

											} catch (Exception e) {

												errorAdGroupList.add(textAd.getAdgroupId());

												errorTextAdList.add(textAd.getAdgroupadId());

												continue;

											}

											if(adGroupAdId > 0l){

								    			AdwordsAdGroupAd adgroupad = new AdwordsAdGroupAd();

								    			adgroupad.setAdgroupadId(adGroupAdId);

								    			adgroupad.setAdgroupId(textAd.getAdgroupId());

								    			adgroupad.setCampaignId(textAd.getCampaignId());

								    			adgroupad.setDescription1(newDescription1);

								    			adgroupad.setDescription2(textAd.getDescription2());

								    			adgroupad.setDisplayUrl(textAd.getDisplayUrl());

								    			adgroupad.setHeadline(textAd.getHeadline());

								    			adgroupad.setUrl(textAd.getUrl());

								    			client.addAdwordsAdGroupAd(adgroupad);

											}

							    		}

							    	}

							    } catch(NumberFormatException e){

									System.out.println(e.getMessage());

									continue;

								} 

							}

						}

					} catch (GoogleAdwordsServiceException e) {

						e.printStackTrace();

					} catch (TException e) {

						e.printStackTrace();

					}

				}

			}

			System.out.println("Error Ad Group List");

			for(Long l: errorAdGroupList){

				System.out.println(l);

			}

			System.out.println("Error Text Ad List");

			for(Long l: errorTextAdList){

				System.out.println(l);

			}

		}

	}

}