Author: ssanbern
Date: 2007-01-08 11:31:32 +0100 (Mon, 08 Jan 2007)
New Revision: 4275
Modified:
trunk/core-api/src/main/java/no/schibstedsok/searchportal/mode/command/BlocketSearchCommand.java
Log:
Modified:
trunk/core-api/src/main/java/no/schibstedsok/searchportal/mode/command/BlocketSearchCommand.java
===================================================================
---
trunk/core-api/src/main/java/no/schibstedsok/searchportal/mode/command/BlocketSearchCommand.java
2007-01-08 09:56:02 UTC (rev 4274)
+++
trunk/core-api/src/main/java/no/schibstedsok/searchportal/mode/command/BlocketSearchCommand.java
2007-01-08 10:31:32 UTC (rev 4275)
@@ -3,10 +3,8 @@
import java.net.MalformedURLException;
import java.rmi.RemoteException;
-
import java.util.Map;
-
import javax.xml.rpc.ServiceException;
import javax.xml.rpc.holders.LongHolder;
import javax.xml.rpc.holders.StringHolder;
@@ -23,81 +21,72 @@
import no.schibstedsok.searchportal.result.BasicSearchResult;
import no.schibstedsok.searchportal.result.SearchResult;
-
-
public class BlocketSearchCommand extends AbstractWebServiceSearchCommand {
-
+
private static final Logger LOG = Logger
- .getLogger(BlocketSearchCommand.class);
+ .getLogger(BlocketSearchCommand.class);
+
private static final String ERR_FAILED_BLOCKET_SEARCH = "Failed
Prisjakt search command";
-
-
-
+
public BlocketSearchCommand(final Context cxt,
final Map<String, Object> parameters) {
- super(cxt, parameters);}
+ super(cxt, parameters);
+ }
@Override
- public SearchResult execute()
- {
-
+ public SearchResult execute() {
+
final TokenEvaluationEngine engine =
context.getTokenEvaluationEngine();
-
- final boolean isBlocket =
engine.evaluateQuery(TokenPredicate.BLOCKET,context.getQuery());
-
- BlocketSearchConfiguration bsc = (BlocketSearchConfiguration)
context.getSearchConfiguration();
-
+
+ final boolean isBlocket =
engine.evaluateQuery(TokenPredicate.BLOCKET,
+ context.getQuery());
+
+ BlocketSearchConfiguration bsc = (BlocketSearchConfiguration)
context
+ .getSearchConfiguration();
+
Map m = bsc.getBlocketMap();
-
+
final SearchLocator service = new SearchLocator();
-
- final SearchResult result = new BasicSearchResult(this);
- if(isBlocket)
- {
- try
- {
- final SearchPortType port =
service.getsearchPort(new java.net.URL(service.getsearchPortAddress()));
+
+ final SearchResult result = new BasicSearchResult(this);
+ if (isBlocket) {
+ try {
+ final SearchPortType port = service
+ .getsearchPort(new
java.net.URL(service
+
.getsearchPortAddress()));
String query = getTransformedQuery();
-
+
LongHolder lholder = new LongHolder();
StringHolder sholder = new StringHolder();
String trimQ =
StringUtils.deleteWhitespace(query);
- String categoryIndex =(String) m.get(trimQ);
- if(categoryIndex!=null)
- {
- port.search(query,
Integer.parseInt(categoryIndex), lholder, sholder);
+ String categoryIndex = (String) m.get(trimQ);
+ if (categoryIndex != null) {
+ port.search(query,
Integer.parseInt(categoryIndex),
+ lholder, sholder);
}
-
+
String nads = Long.toString(lholder.value);
result.addField("searchquery", query);
result.addField("numberofads", nads);
result.addField("blocketbackurl",
sholder.value);
-
+
result.setHitCount(1);
-
-
-
- }
- catch (ServiceException se)
- {
+
+ } catch (ServiceException se) {
LOG.error(ERR_FAILED_BLOCKET_SEARCH, se);
throw new InfrastructureException(se);
- }
- catch (MalformedURLException murle)
- {
+ } catch (MalformedURLException murle) {
LOG.error(ERR_FAILED_BLOCKET_SEARCH, murle);
throw new InfrastructureException(murle);
- }
- catch (RemoteException re)
- {
+ } catch (RemoteException re) {
LOG.error(ERR_FAILED_BLOCKET_SEARCH, re);
throw new InfrastructureException(re);
}
-
+
}
-
+
return result;
-
+
}
}
_______________________________________________
Kernel-commits mailing list
[email protected]
http://sesat.no/mailman/listinfo/kernel-commits
