code format.
This commit is contained in:
parent
d1517230a8
commit
57c874a1c8
12 changed files with 68 additions and 62 deletions
|
@ -167,7 +167,8 @@ public class ScheduledJobAction extends BsScheduledJobAction {
|
|||
public String stop() {
|
||||
final ScheduledJob scheduledJob = getScheduledJob();
|
||||
try {
|
||||
JobExecutor jobExecutoer = jobHelper.getJobExecutoer(scheduledJob.getId());
|
||||
final JobExecutor jobExecutoer = jobHelper
|
||||
.getJobExecutoer(scheduledJob.getId());
|
||||
jobExecutoer.shutdown();
|
||||
SAStrutsUtil.addSessionMessage("success.job_stopped",
|
||||
scheduledJob.getName());
|
||||
|
|
|
@ -314,7 +314,7 @@ public class SynonymAction {
|
|||
@Token(save = true, validate = false)
|
||||
@Execute(validator = false, input = "downloadpage")
|
||||
public String downloadpage() {
|
||||
SynonymFile synonymFile = synonymService
|
||||
final SynonymFile synonymFile = synonymService
|
||||
.getSynonymFile(synonymForm.dictId);
|
||||
if (synonymFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -327,7 +327,7 @@ public class SynonymAction {
|
|||
@Token(save = true, validate = true)
|
||||
@Execute(validator = false, input = "downloadpage")
|
||||
public String download() {
|
||||
SynonymFile synonymFile = synonymService
|
||||
final SynonymFile synonymFile = synonymService
|
||||
.getSynonymFile(synonymForm.dictId);
|
||||
if (synonymFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -335,7 +335,7 @@ public class SynonymAction {
|
|||
}
|
||||
try (InputStream in = synonymFile.getInputStream()) {
|
||||
ResponseUtil.download(synonymFile.getSimpleName(), in);
|
||||
} catch (IOException e) {
|
||||
} catch (final IOException e) {
|
||||
throw new SSCActionMessagesException(
|
||||
"errors.failed_to_download_synonym_file");
|
||||
}
|
||||
|
@ -346,7 +346,7 @@ public class SynonymAction {
|
|||
@Token(save = true, validate = false)
|
||||
@Execute(validator = false, input = "uploadpage")
|
||||
public String uploadpage() {
|
||||
SynonymFile synonymFile = synonymService
|
||||
final SynonymFile synonymFile = synonymService
|
||||
.getSynonymFile(synonymForm.dictId);
|
||||
if (synonymFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -359,7 +359,7 @@ public class SynonymAction {
|
|||
@Token(save = false, validate = true)
|
||||
@Execute(validator = true, input = "uploadpage")
|
||||
public String upload() {
|
||||
SynonymFile synonymFile = synonymService
|
||||
final SynonymFile synonymFile = synonymService
|
||||
.getSynonymFile(synonymForm.dictId);
|
||||
if (synonymFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -367,7 +367,7 @@ public class SynonymAction {
|
|||
}
|
||||
try (InputStream in = synonymForm.synonymFile.getInputStream()) {
|
||||
synonymFile.update(in);
|
||||
} catch (IOException e) {
|
||||
} catch (final IOException e) {
|
||||
throw new SSCActionMessagesException(
|
||||
"errors.failed_to_upload_synonym_file");
|
||||
}
|
||||
|
|
|
@ -312,7 +312,7 @@ public class UserDictAction {
|
|||
@Token(save = true, validate = false)
|
||||
@Execute(validator = false, input = "downloadpage")
|
||||
public String downloadpage() {
|
||||
UserDictFile userdictFile = userDictService
|
||||
final UserDictFile userdictFile = userDictService
|
||||
.getUserDictFile(userDictForm.dictId);
|
||||
if (userdictFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -325,7 +325,7 @@ public class UserDictAction {
|
|||
@Token(save = true, validate = true)
|
||||
@Execute(validator = false, input = "downloadpage")
|
||||
public String download() {
|
||||
UserDictFile userdictFile = userDictService
|
||||
final UserDictFile userdictFile = userDictService
|
||||
.getUserDictFile(userDictForm.dictId);
|
||||
if (userdictFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -333,7 +333,7 @@ public class UserDictAction {
|
|||
}
|
||||
try (InputStream in = userdictFile.getInputStream()) {
|
||||
ResponseUtil.download(userdictFile.getSimpleName(), in);
|
||||
} catch (IOException e) {
|
||||
} catch (final IOException e) {
|
||||
throw new SSCActionMessagesException(
|
||||
"errors.failed_to_download_userdict_file");
|
||||
}
|
||||
|
@ -344,7 +344,7 @@ public class UserDictAction {
|
|||
@Token(save = true, validate = false)
|
||||
@Execute(validator = false, input = "uploadpage")
|
||||
public String uploadpage() {
|
||||
UserDictFile userdictFile = userDictService
|
||||
final UserDictFile userdictFile = userDictService
|
||||
.getUserDictFile(userDictForm.dictId);
|
||||
if (userdictFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -357,7 +357,7 @@ public class UserDictAction {
|
|||
@Token(save = false, validate = true)
|
||||
@Execute(validator = true, input = "uploadpage")
|
||||
public String upload() {
|
||||
UserDictFile userdictFile = userDictService
|
||||
final UserDictFile userdictFile = userDictService
|
||||
.getUserDictFile(userDictForm.dictId);
|
||||
if (userdictFile == null) {
|
||||
throw new SSCActionMessagesException(
|
||||
|
@ -365,7 +365,7 @@ public class UserDictAction {
|
|||
}
|
||||
try (InputStream in = userDictForm.userDictFile.getInputStream()) {
|
||||
userdictFile.update(in);
|
||||
} catch (IOException e) {
|
||||
} catch (final IOException e) {
|
||||
throw new SSCActionMessagesException(
|
||||
"errors.failed_to_upload_userdict_file");
|
||||
}
|
||||
|
|
|
@ -115,16 +115,16 @@ public class JsonApiManager extends BaseApiManager implements WebApiManager {
|
|||
|
||||
protected void processPingRequest(HttpServletRequest request,
|
||||
HttpServletResponse response, FilterChain chain) {
|
||||
SearchService searchService = ComponentUtil.getSearchService();
|
||||
final SearchService searchService = ComponentUtil.getSearchService();
|
||||
int status;
|
||||
final StringBuilder buf = new StringBuilder(1000);
|
||||
String errMsg = null;
|
||||
try {
|
||||
PingResponse pingResponse = searchService.ping();
|
||||
final PingResponse pingResponse = searchService.ping();
|
||||
status = pingResponse.getStatus();
|
||||
buf.append("\"result\":[");
|
||||
boolean appended = false;
|
||||
for (Target target : pingResponse.getTargets()) {
|
||||
for (final Target target : pingResponse.getTargets()) {
|
||||
if (appended) {
|
||||
buf.append(',');
|
||||
} else {
|
||||
|
@ -141,7 +141,7 @@ public class JsonApiManager extends BaseApiManager implements WebApiManager {
|
|||
buf.append("}");
|
||||
}
|
||||
buf.append(']');
|
||||
} catch (Exception e) {
|
||||
} catch (final Exception e) {
|
||||
status = 9;
|
||||
errMsg = e.getMessage();
|
||||
if (errMsg == null) {
|
||||
|
|
|
@ -104,15 +104,15 @@ public class XmlApiManager extends BaseApiManager implements WebApiManager {
|
|||
|
||||
protected void processPingRequest(HttpServletRequest request,
|
||||
HttpServletResponse response, FilterChain chain) {
|
||||
SearchService searchService = ComponentUtil.getSearchService();
|
||||
final SearchService searchService = ComponentUtil.getSearchService();
|
||||
int status;
|
||||
final StringBuilder buf = new StringBuilder(1000);
|
||||
String errMsg = null;
|
||||
try {
|
||||
PingResponse pingResponse = searchService.ping();
|
||||
final PingResponse pingResponse = searchService.ping();
|
||||
status = pingResponse.getStatus();
|
||||
buf.append("<result>");
|
||||
for (Target target : pingResponse.getTargets()) {
|
||||
for (final Target target : pingResponse.getTargets()) {
|
||||
buf.append("<server><status>");
|
||||
buf.append(target.getStatus());
|
||||
buf.append("</status><url>");
|
||||
|
@ -124,7 +124,7 @@ public class XmlApiManager extends BaseApiManager implements WebApiManager {
|
|||
buf.append("</search-time></server>");
|
||||
}
|
||||
buf.append("</result>");
|
||||
} catch (Exception e) {
|
||||
} catch (final Exception e) {
|
||||
status = 9;
|
||||
errMsg = e.getMessage();
|
||||
if (errMsg == null) {
|
||||
|
|
|
@ -21,7 +21,6 @@ import java.io.BufferedReader;
|
|||
import java.io.BufferedWriter;
|
||||
import java.io.File;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.FileOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
@ -39,7 +38,6 @@ import jp.sf.fess.dict.DictionaryFile;
|
|||
import org.apache.commons.io.FileUtils;
|
||||
import org.apache.commons.io.IOUtils;
|
||||
import org.codelibs.core.util.StringUtil;
|
||||
import org.seasar.framework.util.FileUtil;
|
||||
import org.seasar.robot.util.StreamUtil;
|
||||
|
||||
public class SynonymFile extends DictionaryFile<SynonymItem> {
|
||||
|
|
|
@ -7,13 +7,13 @@ import java.util.List;
|
|||
import org.apache.solr.client.solrj.response.SolrPingResponse;
|
||||
|
||||
public class PingResponse {
|
||||
private int status = 0;
|
||||
private final int status = 0;
|
||||
|
||||
private Target[] targets;
|
||||
private final Target[] targets;
|
||||
|
||||
public PingResponse(Collection<SolrPingResponse> responses) {
|
||||
List<Target> targetList = new ArrayList<>();
|
||||
for (SolrPingResponse response : responses) {
|
||||
final List<Target> targetList = new ArrayList<>();
|
||||
for (final SolrPingResponse response : responses) {
|
||||
int status = response.getStatus();
|
||||
if (status != 0) {
|
||||
status = 1;
|
||||
|
@ -26,19 +26,19 @@ public class PingResponse {
|
|||
|
||||
public static class Target {
|
||||
|
||||
private int status;
|
||||
private final int status;
|
||||
|
||||
private String url;
|
||||
private final String url;
|
||||
|
||||
private long searchTime;
|
||||
private final long searchTime;
|
||||
|
||||
private int queryTime;
|
||||
private final int queryTime;
|
||||
|
||||
public Target(int status, String url, long elapsedTime, int qTime) {
|
||||
this.status = status;
|
||||
this.url = url;
|
||||
this.searchTime = elapsedTime;
|
||||
this.queryTime = qTime;
|
||||
searchTime = elapsedTime;
|
||||
queryTime = qTime;
|
||||
}
|
||||
|
||||
public int getStatus() {
|
||||
|
|
|
@ -149,7 +149,7 @@ public class FessEncodingFilter extends EncodingFilter {
|
|||
list.add(StringUtil.EMPTY);
|
||||
}
|
||||
}
|
||||
} catch (DecoderException e) {
|
||||
} catch (final DecoderException e) {
|
||||
throw new IOException(e);
|
||||
}
|
||||
|
||||
|
|
|
@ -62,7 +62,7 @@ public class ScreenShotManager {
|
|||
|
||||
public int splitSize = 5;
|
||||
|
||||
private BlockingQueue<ScreenShotTask> screenShotTaskQueue = new LinkedBlockingQueue<ScreenShotTask>();
|
||||
private final BlockingQueue<ScreenShotTask> screenShotTaskQueue = new LinkedBlockingQueue<ScreenShotTask>();
|
||||
|
||||
private boolean generating;
|
||||
|
||||
|
@ -97,9 +97,9 @@ public class ScreenShotManager {
|
|||
while (generating) {
|
||||
try {
|
||||
screenShotTaskQueue.take().generate();
|
||||
} catch (InterruptedException e) {
|
||||
} catch (final InterruptedException e) {
|
||||
logger.debug("Interupted task.", e);
|
||||
} catch (Exception e) {
|
||||
} catch (final Exception e) {
|
||||
logger.warn("Failed to generage a screenshot.", e);
|
||||
}
|
||||
}
|
||||
|
@ -119,8 +119,8 @@ public class ScreenShotManager {
|
|||
if (generator.isTarget(docMap)) {
|
||||
final String url = (String) docMap.get("url");
|
||||
final String path = getImageFilename(docMap);
|
||||
if (!screenShotTaskQueue.offer((new ScreenShotTask(url,
|
||||
new File(baseDir, path), generator)))) {
|
||||
if (!screenShotTaskQueue.offer(new ScreenShotTask(url,
|
||||
new File(baseDir, path), generator))) {
|
||||
logger.warn("Failed to offer a screenshot task: " + url
|
||||
+ " -> " + path);
|
||||
}
|
||||
|
@ -130,7 +130,7 @@ public class ScreenShotManager {
|
|||
}
|
||||
|
||||
protected String getImageFilename(final Map<String, Object> docMap) {
|
||||
StringBuilder buf = new StringBuilder(50);
|
||||
final StringBuilder buf = new StringBuilder(50);
|
||||
final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
|
||||
final String docid = (String) docMap.get(systemHelper.docIdField);
|
||||
for (int i = 0; i < docid.length(); i++) {
|
||||
|
@ -219,30 +219,37 @@ public class ScreenShotManager {
|
|||
final int prime = 31;
|
||||
int result = 1;
|
||||
result = prime * result
|
||||
+ ((outputFile == null) ? 0 : outputFile.hashCode());
|
||||
result = prime * result + ((url == null) ? 0 : url.hashCode());
|
||||
+ (outputFile == null ? 0 : outputFile.hashCode());
|
||||
result = prime * result + (url == null ? 0 : url.hashCode());
|
||||
return result;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean equals(Object obj) {
|
||||
if (this == obj)
|
||||
if (this == obj) {
|
||||
return true;
|
||||
if (obj == null)
|
||||
}
|
||||
if (obj == null) {
|
||||
return false;
|
||||
if (getClass() != obj.getClass())
|
||||
}
|
||||
if (getClass() != obj.getClass()) {
|
||||
return false;
|
||||
ScreenShotTask other = (ScreenShotTask) obj;
|
||||
}
|
||||
final ScreenShotTask other = (ScreenShotTask) obj;
|
||||
if (outputFile == null) {
|
||||
if (other.outputFile != null)
|
||||
if (other.outputFile != null) {
|
||||
return false;
|
||||
} else if (!outputFile.equals(other.outputFile))
|
||||
}
|
||||
} else if (!outputFile.equals(other.outputFile)) {
|
||||
return false;
|
||||
}
|
||||
if (url == null) {
|
||||
if (other.url != null)
|
||||
if (other.url != null) {
|
||||
return false;
|
||||
} else if (!url.equals(other.url))
|
||||
}
|
||||
} else if (!url.equals(other.url)) {
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
|
|
|
@ -72,7 +72,7 @@ public class WebDriverGenerator extends BaseScreenShotGenerator {
|
|||
|
||||
if (webDriver instanceof TakesScreenshot) {
|
||||
webDriver.get(url);
|
||||
File screenshot = ((TakesScreenshot) webDriver)
|
||||
final File screenshot = ((TakesScreenshot) webDriver)
|
||||
.getScreenshotAs(OutputType.FILE);
|
||||
convert(screenshot, outputFile);
|
||||
} else {
|
||||
|
@ -83,18 +83,18 @@ public class WebDriverGenerator extends BaseScreenShotGenerator {
|
|||
|
||||
protected void convert(File inputFile, File outputFile) {
|
||||
try {
|
||||
BufferedImage image = loadImage(inputFile);
|
||||
int screenShotHeight = screenShotWidth * image.getHeight()
|
||||
final BufferedImage image = loadImage(inputFile);
|
||||
final int screenShotHeight = screenShotWidth * image.getHeight()
|
||||
/ windowWidth;
|
||||
BufferedImage screenShotImage = new BufferedImage(screenShotWidth,
|
||||
screenShotHeight, image.getType());
|
||||
final BufferedImage screenShotImage = new BufferedImage(
|
||||
screenShotWidth, screenShotHeight, image.getType());
|
||||
screenShotImage.getGraphics().drawImage(
|
||||
image.getScaledInstance(screenShotWidth, screenShotHeight,
|
||||
Image.SCALE_AREA_AVERAGING), 0, 0, screenShotWidth,
|
||||
screenShotHeight, null);
|
||||
|
||||
ImageIO.write(screenShotImage, imageFormatName, outputFile);
|
||||
} catch (Exception e) {
|
||||
} catch (final Exception e) {
|
||||
logger.warn("Failed to convert " + inputFile.getAbsolutePath(), e);
|
||||
inputFile.renameTo(outputFile);
|
||||
}
|
||||
|
|
|
@ -79,7 +79,7 @@ public class SearchService implements Serializable {
|
|||
@Resource
|
||||
protected SpellChecker spellChecker;
|
||||
|
||||
public PingResponse ping( ) {
|
||||
public PingResponse ping() {
|
||||
final SolrGroup solrGroup = solrGroupManager
|
||||
.getSolrGroup(QueryType.QUERY);
|
||||
return new PingResponse(solrGroup.ping());
|
||||
|
|
|
@ -422,7 +422,7 @@ public class FessXpathTransformer extends AbstractFessXpathTransformer {
|
|||
} else {
|
||||
buf.append(' ');
|
||||
}
|
||||
Node node = list.item(i);
|
||||
final Node node = list.item(i);
|
||||
if (pruned) {
|
||||
final Node n = pruneNode(node.cloneNode(true));
|
||||
buf.append(n.getTextContent());
|
||||
|
@ -509,7 +509,7 @@ public class FessXpathTransformer extends AbstractFessXpathTransformer {
|
|||
: responseData.getUrl());
|
||||
for (final Map.Entry<String, String> entry : childUrlRuleMap
|
||||
.entrySet()) {
|
||||
for (String u : getUrlFromTagAttribute(url, document,
|
||||
for (final String u : getUrlFromTagAttribute(url, document,
|
||||
entry.getKey(), entry.getValue(),
|
||||
responseData.getCharSet())) {
|
||||
anchorList.add(RequestDataBuilder.newRequestData().get()
|
||||
|
@ -523,8 +523,8 @@ public class FessXpathTransformer extends AbstractFessXpathTransformer {
|
|||
// xpathAPI.remove();
|
||||
}
|
||||
|
||||
List<String> urlList = new ArrayList<>(anchorList.size());
|
||||
for (RequestData requestData : anchorList) {
|
||||
final List<String> urlList = new ArrayList<>(anchorList.size());
|
||||
for (final RequestData requestData : anchorList) {
|
||||
urlList.add(requestData.getUrl());
|
||||
}
|
||||
return urlList;
|
||||
|
@ -534,7 +534,7 @@ public class FessXpathTransformer extends AbstractFessXpathTransformer {
|
|||
protected List<RequestData> convertChildUrlList(
|
||||
final List<RequestData> urlList) {
|
||||
if (urlList != null) {
|
||||
for (RequestData requestData : urlList) {
|
||||
for (final RequestData requestData : urlList) {
|
||||
String url = requestData.getUrl();
|
||||
for (final Map.Entry<String, String> entry : convertUrlMap
|
||||
.entrySet()) {
|
||||
|
|
Loading…
Add table
Reference in a new issue