messagedaosql.java

JiveJdon 3.0不只是一个论坛程序

        queryParams.add(saveDateTime);
        forumMessage.setModifiedDate(displayDateTime);            
        
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, INSERT_MESSAGE);
        } catch (Exception e) {
            logger.error(e);
            throw new Exception("messageId="+ forumMessage.getMessageId() + " happend " + e);
        }
    }
    
    public  void createMessageReply(ForumMessageReply  forumMessage) throws Exception{
        logger.debug("enter createMessageReply for id:" + forumMessage.getMessageId());
        //differnce with createTopicMessage: parentMessageID,
        String INSERT_MESSAGE =
            "INSERT INTO jiveMessage(messageID, parentMessageID, threadID, forumID, " +
            "userID, subject, body, modValue, rewardPoints, creationDate, modifiedDate) " +
            "VALUES(?,?,?,?,?,?,?,?,?,?,?)";
        List queryParams = new ArrayList();
        queryParams.add(forumMessage.getMessageId());
        queryParams.add(forumMessage.getParentMessage().getMessageId());
        queryParams.add(forumMessage.getForumThread().getThreadId());
        queryParams.add(forumMessage.getForum().getForumId());
        queryParams.add(forumMessage.getAccount().getUserId());
        queryParams.add(forumMessage.getSubject());
        queryParams.add(forumMessage.getBody());
        queryParams.add(new Integer(0));
        queryParams.add(new Integer(forumMessage.getRewardPoints()));
        
        long now = System.currentTimeMillis();   
        String saveDateTime = ToolsUtil.dateToMillis(now);
        String displayDateTime = constants.getDateTimeDisp(saveDateTime);
        queryParams.add(saveDateTime);
        forumMessage.setCreationDate(displayDateTime);
        
        queryParams.add(saveDateTime);
        forumMessage.setModifiedDate(displayDateTime);            
        
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, INSERT_MESSAGE);
        } catch (Exception e) {
            logger.error(e);
            throw new Exception("messageId="+ forumMessage.getMessageId() + " happend " + e);
        }
    }
    
    public void createThread(ForumThread  forumThread) throws Exception{
        String INSERT_THREAD =
            "INSERT INTO jiveThread(threadID,forumID,rootMessageID,modValue, " +
            "rewardPoints,creationDate,modifiedDate) VALUES(?,?,?,?,?,?,?)";
        List queryParams = new ArrayList();
        queryParams.add(forumThread.getThreadId());
        queryParams.add(forumThread.getForum().getForumId());
        queryParams.add(forumThread.getRootMessage().getMessageId());
        queryParams.add(new Integer(0));
        queryParams.add(new Integer(forumThread.getRootMessage().getRewardPoints()));
        
        long now = System.currentTimeMillis();   
        String saveDateTime = ToolsUtil.dateToMillis(now);
        String displayDateTime = constants.getDateTimeDisp(saveDateTime);
        queryParams.add(saveDateTime);
        forumThread.setCreationDate(displayDateTime);
        
        queryParams.add(saveDateTime);
        forumThread.setModifiedDate(displayDateTime);            
        
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, INSERT_THREAD);
        } catch (Exception e) {
            logger.error("forumThread="+ forumThread.getThreadId() + " happend " + e);
            throw new Exception(e);
        }
    }
    
    /**
     * when update the root message, call this method
     * @param forumThread
     */
    public void updateThread(ForumThread  forumThread) throws Exception{
        String SAVE_THREAD =
            "UPDATE jiveThread SET  modifiedDate=? WHERE threadID=?";
        
        List queryParams = new ArrayList();
        
        long now = System.currentTimeMillis();   
        String saveDateTime = ToolsUtil.dateToMillis(now);
        String displayDateTime = constants.getDateTimeDisp(saveDateTime); 
        queryParams.add(saveDateTime);
        forumThread.setModifiedDate(displayDateTime);                      
        queryParams.add(forumThread.getThreadId());
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, SAVE_THREAD);
            
        } catch (Exception e) {
            logger.error("forumThread="+ forumThread.getThreadId() + " happend " + e);
            throw new Exception(e);
        }
    }
    
    public void updateMovingForum(ForumThread  forumThread) throws Exception{
    	  String SQL =
              "UPDATE jiveMessage SET  forumID=? WHERE messageID=?";
          List queryParams = new ArrayList();        
          queryParams.add(forumThread.getForum().getForumId());
          queryParams.add(forumThread.getRootMessage().getMessageId());
          
          String SQL2 =
              "UPDATE jiveThread SET  forumID=? WHERE threadID=?";
          List queryParams2 = new ArrayList();        
          queryParams2.add(forumThread.getForum().getForumId());
          queryParams2.add(forumThread.getThreadId());
          try {
              jdbcTempSource.getJdbcTemp().operate(queryParams, SQL);
              jdbcTempSource.getJdbcTemp().operate(queryParams2, SQL2);
          } catch (Exception e) {
              logger.error(" updateMovingForum forumThread="+ forumThread.getThreadId() + " happend " + e);
              throw new Exception(e);
          }
          
         

          
    }

    /* (non-Javadoc)
     * @see com.jdon.jivejdon.dao.MessageDao#updateMessage(com.jdon.jivejdon.model.ForumMessage)
     */
    public void updateMessage(ForumMessage forumMessage) throws Exception {
        String SAVE_MESSAGE =
            "UPDATE jiveMessage SET userID=?, subject=?, body=?, modValue=?, " +
            "rewardPoints=?, modifiedDate=? WHERE messageID=?";
        List queryParams = new ArrayList();
        queryParams.add(forumMessage.getAccount().getUserId());
        queryParams.add(forumMessage.getSubject());
        queryParams.add(forumMessage.getBody());
        queryParams.add(new Integer(0));
        queryParams.add(new Integer(forumMessage.getRewardPoints()));     
        
        long now = System.currentTimeMillis();   
        String saveDateTime = ToolsUtil.dateToMillis(now);
        String displayDateTime = constants.getDateTimeDisp(saveDateTime); 
        queryParams.add(saveDateTime);
        forumMessage.setModifiedDate(displayDateTime);       
                
        queryParams.add(forumMessage.getMessageId());
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, SAVE_MESSAGE);
            //propertyDaoSql.deleteProperties(Constants.MESSAGE, forumMessage.getMessageId());
            //propertyDaoSql.insertProperties(Constants.MESSAGE, forumMessage.getMessageId(), forumMessage.getPropertys());
            
        } catch (Exception e) {
            logger.error("messageId="+ forumMessage.getMessageId() + " happend " + e);
            throw new Exception(e);
        }
    }

    /* (non-Javadoc)
     * @see com.jdon.jivejdon.dao.MessageDao#deleteMessage(com.jdon.jivejdon.model.ForumMessage)
     */
    public void deleteMessage(Long  forumMessageId) throws Exception {
        String DELETE_MESSAGE =
            "DELETE FROM jiveMessage WHERE messageID=?";
        List queryParams = new ArrayList();
        queryParams.add(forumMessageId);
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, DELETE_MESSAGE);
            
        } catch (Exception e) {
            logger.error(e);
            throw new Exception("messageId="+ forumMessageId + " happend " + e);
        }
    }
    
    
    public void deleteThread(Long threadId) throws Exception{
        String DELETE_THREAD =
            "DELETE FROM jiveThread WHERE threadID=?";        
        List queryParams = new ArrayList();
        queryParams.add(threadId);
        try {
            jdbcTempSource.getJdbcTemp().operate(queryParams, DELETE_THREAD);
        } catch (Exception e) {
            logger.error(e);
            throw new Exception("threadId="+ threadId + " happend " + e);
        }
    }

}