opinionmanagerbean.java

功能完善的java开发框架

package news.ejb;

import javax.ejb.SessionBean;
import javax.ejb.SessionContext;
import javax.ejb.CreateException;
import com.jdon.controller.events.EventModel;
import org.apache.log4j.Logger;
import com.jdon.servicelocator.ejb.ServiceLocator;
import com.jdon.sequence.SequenceGeneratorLocalHome;
import com.jdon.sequence.SequenceGeneratorLocal;
import javax.ejb.EJBException;
import news.ejb.dao.JdbcDao;
import com.jdon.controller.model.PageIterator;
import news.model.NewsOpinion;
import news.Constants;

public class OpinionManagerBean
    implements SessionBean {
  private final static Logger logger = Logger.getLogger(OpinionManagerBean.class);

  SessionContext sessionContext;
  TNewsHome tHome;
  TNewsTypeHome ttHome;
  TNewsOpinionHome toHome;
  SequenceGeneratorLocalHome sequenceHome;
  JdbcDao jdbcDao;

  public void ejbCreate() throws CreateException {
    try {
      ServiceLocator sc = new ServiceLocator();
      logger.debug(" lookup home by JNDI");
      tHome = (TNewsHome)sc.getLocalHome("TNews");
      ttHome = (TNewsTypeHome)sc.getLocalHome("TNewsType");
      toHome = (TNewsOpinionHome)sc.getLocalHome("TNewsOpinion");
      sequenceHome = (SequenceGeneratorLocalHome)sc.getLocalHome("SequenceGeneratorLocal");

      jdbcDao = new JdbcDao();
    }
   catch (Exception ex) {
     logger.error(ex);
   }
  }

  private String getNewsId(String name) {
    try {
      SequenceGeneratorLocal seq = sequenceHome.create();
      return Integer.toString(seq.nextSequenceNumber(name));
    }
    catch (Exception ex) {
      logger.error(ex);
      throw new EJBException(ex);
    }
  }

  public void createOp(EventModel em) {
    NewsOpinion op = (NewsOpinion) em.getModel();
    logger.debug("enter create ..");
    try {
      String id = getNewsId(Constants.SEQ_NAME);
      logger.debug(" got sequence Id ");

      TNewsOpinion to = toHome.create(id);
      to.setOpcontent(op.getOpContent());

      TNews t = tHome.findByPrimaryKey(op.getNews().getNewsId());
      to.setTNews(t); //setup CMR

      jdbcDao.clearAllCache();
      op.getNews().setModified(true);
    }
    catch (Exception ex) {
      logger.error(ex);
    }

  }

  public void updateOp(EventModel em) {
    NewsOpinion op = (NewsOpinion) em.getModel();
     logger.debug("enter create ..");
     try {
       TNewsOpinion to = toHome.findByPrimaryKey(op.getOpId());
       to.setOpcontent(op.getOpContent());

       jdbcDao.clearAllCache();
       op.getNews().setModified(true);

     }
     catch (Exception ex) {
       logger.error(ex);
     }


  }

  public void deleteOp(EventModel em) {
    NewsOpinion op = (NewsOpinion) em.getModel();
    try {
      tHome.remove(op.getOpId());
      op.getNews().setModified(true);
      jdbcDao.clearAllCache();
    }
    catch (Exception ex) {
      logger.error(ex);
    }
  }

  public NewsOpinion getNewsOp(String Id) {
    NewsOpinion newsOpinion = null;
    try {
      newsOpinion = jdbcDao.getNewsOp(Id);
    }
    catch (Exception ex) {
      logger.error(ex);
    }
    return newsOpinion;
  }

  public PageIterator getNewsOpPage(String newsid, int start, int count) {
    PageIterator pageIterator = null;
    try {
      pageIterator = jdbcDao.getNewsOpinions(newsid, start, count);
    }
    catch (Exception ex) {
      logger.error(ex);
    }
    return pageIterator;

  }


  public void ejbRemove() {
  }

  public void ejbActivate() {
  }

  public void ejbPassivate() {
  }

  public void setSessionContext(SessionContext sessionContext) {
    this.sessionContext = sessionContext;
  }

}