0ct0pu5/fess
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

CrawlingSessionService.java

Browse source
This commit is contained in:
Shunji Makino 2015-04-22 16:49:47 +09:00
parent 482a85eee8
commit 72e7f52d8a
2 changed files with 64 additions and 107 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

101
src/main/java/org/codelibs/fess/crud/service/BsCrawlingSessionService.java
View file

@ -1,101 +0,0 @@
/*
* Copyright 2009-2015 the CodeLibs Project and the Others.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
* either express or implied. See the License for the specific language
* governing permissions and limitations under the License.
*/
package org.codelibs.fess.crud.service;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.codelibs.fess.crud.CommonConstants;
import org.codelibs.fess.crud.CrudMessageException;
import org.codelibs.fess.db.cbean.CrawlingSessionCB;
import org.codelibs.fess.db.exbhv.CrawlingSessionBhv;
import org.codelibs.fess.db.exentity.CrawlingSession;
import org.codelibs.fess.pager.CrawlingSessionPager;
import org.dbflute.cbean.result.PagingResultBean;
import org.seasar.framework.beans.util.Beans;
public abstract class BsCrawlingSessionService {
@Resource
protected CrawlingSessionBhv crawlingSessionBhv;
public BsCrawlingSessionService() {
super();
}
public List<CrawlingSession> getCrawlingSessionList(final CrawlingSessionPager crawlingSessionPager) {
final PagingResultBean<CrawlingSession> crawlingSessionList = crawlingSessionBhv.selectPage(cb -> {
cb.paging(crawlingSessionPager.getPageSize(), crawlingSessionPager.getCurrentPageNumber());
setupListCondition(cb, crawlingSessionPager);
});
// update pager
Beans.copy(crawlingSessionList, crawlingSessionPager).includes(CommonConstants.PAGER_CONVERSION_RULE).execute();
crawlingSessionPager.setPageNumberList(crawlingSessionList.pageRange(op -> {
op.rangeSize(5);
}).createPageNumberList());
return crawlingSessionList;
}
public CrawlingSession getCrawlingSession(final Map<String, String> keys) {
final CrawlingSession crawlingSession = crawlingSessionBhv.selectEntity(cb -> {
cb.query().setId_Equal(Long.parseLong(keys.get("id")));
setupEntityCondition(cb, keys);
}).orElse(null);//TODO
if (crawlingSession == null) {
// TODO exception?
return null;
}
return crawlingSession;
}
public void store(final CrawlingSession crawlingSession) throws CrudMessageException {
setupStoreCondition(crawlingSession);
crawlingSessionBhv.insertOrUpdate(crawlingSession);
}
public void delete(final CrawlingSession crawlingSession) throws CrudMessageException {
setupDeleteCondition(crawlingSession);
crawlingSessionBhv.delete(crawlingSession);
}
protected void setupListCondition(final CrawlingSessionCB cb, final CrawlingSessionPager crawlingSessionPager) {
if (crawlingSessionPager.id != null) {
cb.query().setId_Equal(Long.parseLong(crawlingSessionPager.id));
}
// TODO Long, Integer, String supported only.
}
protected void setupEntityCondition(final CrawlingSessionCB cb, final Map<String, String> keys) {
}
protected void setupStoreCondition(final CrawlingSession crawlingSession) {
}
protected void setupDeleteCondition(final CrawlingSession crawlingSession) {
}
}

70
src/main/java/org/codelibs/fess/service/CrawlingSessionService.java
View file

@ -25,6 +25,7 @@ import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
import javax.annotation.Resource;
@ -38,8 +39,10 @@ import org.apache.commons.logging.LogFactory;
import org.codelibs.core.CoreLibConstants;
import org.codelibs.core.util.StringUtil;
import org.codelibs.fess.FessSystemException;
import org.codelibs.fess.crud.service.BsCrawlingSessionService;
import org.codelibs.fess.crud.CommonConstants;
import org.codelibs.fess.crud.CrudMessageException;
import org.codelibs.fess.db.cbean.CrawlingSessionCB;
import org.codelibs.fess.db.exbhv.CrawlingSessionBhv;
import org.codelibs.fess.db.exbhv.CrawlingSessionInfoBhv;
import org.codelibs.fess.db.exentity.CrawlingSession;
import org.codelibs.fess.db.exentity.CrawlingSessionInfo;
@ -47,8 +50,10 @@ import org.codelibs.fess.pager.CrawlingSessionPager;
import org.codelibs.fess.util.ComponentUtil;
import org.dbflute.bhv.readable.EntityRowHandler;
import org.dbflute.cbean.result.ListResultBean;
import org.dbflute.cbean.result.PagingResultBean;
import org.seasar.framework.beans.util.Beans;
public class CrawlingSessionService extends BsCrawlingSessionService implements Serializable {
public class CrawlingSessionService implements Serializable {
private static final long serialVersionUID = 1L;
@ -57,9 +62,64 @@ public class CrawlingSessionService extends BsCrawlingSessionService implements
@Resource
protected CrawlingSessionInfoBhv crawlingSessionInfoBhv;
@Override
@Resource
protected CrawlingSessionBhv crawlingSessionBhv;
public CrawlingSessionService() {
super();
}
public List<CrawlingSession> getCrawlingSessionList(final CrawlingSessionPager crawlingSessionPager) {
final PagingResultBean<CrawlingSession> crawlingSessionList = crawlingSessionBhv.selectPage(cb -> {
cb.paging(crawlingSessionPager.getPageSize(), crawlingSessionPager.getCurrentPageNumber());
setupListCondition(cb, crawlingSessionPager);
});
// update pager
Beans.copy(crawlingSessionList, crawlingSessionPager).includes(CommonConstants.PAGER_CONVERSION_RULE).execute();
crawlingSessionPager.setPageNumberList(crawlingSessionList.pageRange(op -> {
op.rangeSize(5);
}).createPageNumberList());
return crawlingSessionList;
}
public CrawlingSession getCrawlingSession(final Map<String, String> keys) {
final CrawlingSession crawlingSession = crawlingSessionBhv.selectEntity(cb -> {
cb.query().setId_Equal(Long.parseLong(keys.get("id")));
setupEntityCondition(cb, keys);
}).orElse(null);//TODO
if (crawlingSession == null) {
// TODO exception?
return null;
}
return crawlingSession;
}
public void store(final CrawlingSession crawlingSession) throws CrudMessageException {
setupStoreCondition(crawlingSession);
crawlingSessionBhv.insertOrUpdate(crawlingSession);
}
public void delete(final CrawlingSession crawlingSession) throws CrudMessageException {
setupDeleteCondition(crawlingSession);
crawlingSessionBhv.delete(crawlingSession);
}
protected void setupEntityCondition(final CrawlingSessionCB cb, final Map<String, String> keys) {
}
protected void setupListCondition(final CrawlingSessionCB cb, final CrawlingSessionPager crawlingSessionPager) {
super.setupListCondition(cb, crawlingSessionPager);
if (crawlingSessionPager.id != null) {
cb.query().setId_Equal(Long.parseLong(crawlingSessionPager.id));
}
// TODO Long, Integer, String supported only.
if (StringUtil.isNotBlank(crawlingSessionPager.sessionId)) {
cb.query().setSessionId_LikeSearch(crawlingSessionPager.sessionId, op -> {
op.likeContain();
@ -68,7 +128,6 @@ public class CrawlingSessionService extends BsCrawlingSessionService implements
cb.query().addOrderBy_CreatedTime_Desc();
}
@Override
protected void setupStoreCondition(final CrawlingSession crawlingSession) {
if (crawlingSession == null) {
throw new FessSystemException("Crawling Session is null.");
@ -79,7 +138,6 @@ public class CrawlingSessionService extends BsCrawlingSessionService implements
}
}
@Override
protected void setupDeleteCondition(final CrawlingSession crawlingSession) {
crawlingSessionInfoBhv.varyingQueryDelete(cb -> {
cb.query().setCrawlingSessionId_Equal(crawlingSession.getId());