關於網站簽到功能的設計

1，最近網站要上一個簽到的功能，一個多游戲的平台，每種游戲的官網都有簽到功能，設計打算把數據放到平台。

 

2，首先要設計簽到表，這里直接給出過了一遍dba，需求人員，設計人員腦子的結果：

 

 

最精彩的地方是signHistory的設計，直接存成bigint,通過轉換成二進制來記錄簽到的歷史；

 

3，預覽圖

 

4，功能抽取

非常明顯，只有三個主要的功能，第一個簽到之前的登錄；第二個，簽到；第三個，領取禮包；

功能	功能概述	功能的具體邏輯	接口方法設計
登錄之前的查詢	通過查詢，以前簽過到的，顯示簽到歷史；沒有簽過到的，神馬也不顯示；	查詢dt_sign表，通過gid和uid查詢，如果查詢到，返回簽到信息，如果沒有查到，返回提示信息	SignMsg loginQuery(int gid,int uid)
簽到	點擊簽到，如果當天已經簽過到了，提示已經簽過到了；如果從來沒有簽過到，插入數據，把積分設置為1，連續簽到次數設置為1，最后修改時間設置為當天，歷史為1；如果今天沒有簽過到，首先計算出有多少天沒簽到了，如果是昨天簽了的，連續簽到次數加1，歷史左移一位，積分按照積分規則加上；如果超過兩天沒有簽到，連續簽到次數設置為1，歷史左移天數位，積分加上簽到單次的積分，時間為當前的修改時間；	首先查詢dt_sign，按照gid和uid，如果沒查到，插入記錄；查到了，判斷最后修改時間，做相應的處理；	SignMsg todaySign(int gid,int uid)
領取禮包	點擊領取禮包，如果分數夠，減去積分，允許該用戶領取禮包；如果分數不過，提示積分不夠；	點擊領取禮包，如果分數夠，減去積分，允許該用戶領取禮包；如果分數不過，提示積分不夠；	SignMsg getGiftPack(int gid,int uid,int score)

 

5，具體實現

jdbc實現：

package com.sz7road.userplatform.dao.jdbc;

import com.google.common.base.Strings;
import com.sz7road.userplatform.dao.SignDao;
import com.sz7road.userplatform.ws.sign.ScoreRuleAndMoveByte;
import com.sz7road.userplatform.ws.sign.Sign;
import com.sz7road.userplatform.ws.sign.SignObject;
import com.sz7road.utils.CommonDateUtils;
import org.apache.commons.dbutils.DbUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.*;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.Date;

/**
 * Created with IntelliJ IDEA.
 * User: cutter.li
 * Date: 13-1-18
 * Time: 上午11:01
 */
public class SignDaoJdbcImp extends JdbcDaoSupport<SignObject> implements SignDao {

    private final static Logger log = LoggerFactory.getLogger(SignDaoJdbcImp.class);

    private Connection conn = null;

    @Override
    public Sign querySign(int uid, int gid) {
        Sign sign = new Sign();
        ResultSet rs = null;
        PreparedStatement preparedStatement = null;
        try {
            conn = getQueryRunner().getDataSource().getConnection();
            preparedStatement = conn.prepareStatement(" select * from db_userplatform.dt_sign where userid=? and gameid=? ;");

            preparedStatement.setInt(1, uid);
            preparedStatement.setInt(2, gid);

            rs = preparedStatement.executeQuery();
            if (rs.next()) {
                sign.setCode(200);
                sign.setMsg("成功的查詢到簽到信息!");
                sign.setContinueSignCount(rs.getInt("signCount"));
                sign.setTotalScore(rs.getInt("integration"));
                sign.setLastModifyDate(new Date(rs.getDate("lastModifyTime").getTime()));
                sign.setSignHistory(rs.getLong("signHistory"));
            } else {
                sign.setCode(300);
                sign.setMsg("該用戶從來沒有簽過到！");
            }

        } catch (SQLException e) {
            sign.setCode(404);
            sign.setMsg("平台或者db異常！");
            e.printStackTrace();
        } finally {
            DbUtils.closeQuietly(rs);
            try {
                DbUtils.close(preparedStatement);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            DbUtils.closeQuietly(conn);
        }
        return sign;
    }


    @Override
    public Sign signThenReturn(int uid, int gid) {
        Sign sign = new Sign();
        ResultSet rs = null;
        PreparedStatement preparedStatement = null, executePreparedStatement = null;
        try {
            conn = getQueryRunner().getDataSource().getConnection();
            preparedStatement = conn.prepareStatement(" select * from db_userplatform.dt_sign where userid=? and gameid=? ;");
            preparedStatement.setInt(1, uid);
            preparedStatement.setInt(2, gid);

            rs = preparedStatement.executeQuery();
            if (rs.next()) {//查到了更新
                SignObject signObject = new SignObject();
                signObject.setId(rs.getInt("id"));
                signObject.setUid(rs.getInt("userid"));
                signObject.setGid(rs.getInt("gameid"));
                signObject.setSignCount(rs.getInt("signCount"));
                signObject.setIntegration(rs.getInt("integration"));
                signObject.setLastModifyTime(new Date(rs.getDate("lastModifyTime").getTime()));
                signObject.setSignHistory(rs.getLong("signHistory"));
                signObject.setExt(rs.getString("ext"));


                Timestamp lastModifyTimeStamp = new Timestamp(signObject.getLastModifyTime().getTime());
                Timestamp todayStartTimeStamp = CommonDateUtils.getTodayStartTimeStamp();
                if (todayStartTimeStamp.after(lastModifyTimeStamp)) {//今天沒有簽過到
                 final  long missDays= (System.currentTimeMillis()-signObject.getLastModifyTime().getTime())/(24*60*60*1000);
                    int newSignCount=signObject.getSignCount();
                    String newExt="簽到";
                   if(missDays==1)
                   {  //連續簽到，加分，連續簽到次數增加1 ，簽到歷史移動一位
                     newSignCount+=1;
                   }else
                   {//不連續簽到，加分，連續簽到次數為1，簽到歷史移動missDays位
                    newSignCount=1;
                   }
                    if(newSignCount>=91)
                    { //簽到超過90天，連續簽到次數重置為1
                        newSignCount=1;
                        newExt="連續簽到天數重置為1，時間："+CommonDateUtils.getDate(System.currentTimeMillis());
                    }
                   final long   newSignHistory= ScoreRuleAndMoveByte.moveByte(signObject.getSignHistory(),missDays);
                  final int  newIntegration=signObject.getIntegration()+ScoreRuleAndMoveByte.getScoreByRule(newSignCount);
                    executePreparedStatement = conn.prepareStatement(" update db_userplatform.dt_sign set signCount=? , integration=? , signHistory=? , lastModifyTime=? , ext=? where id=?; ");
                    executePreparedStatement.setInt(1, newSignCount);
                    executePreparedStatement.setInt(2, newIntegration);
                    executePreparedStatement.setLong(3, newSignHistory);
                    java.sql.Date signDate= new java.sql.Date(System.currentTimeMillis());

                    executePreparedStatement.setDate(4,signDate);
                    executePreparedStatement.setString(5,newExt);
                    executePreparedStatement.setInt(6,signObject.getId());

                    int effectRows = executePreparedStatement.executeUpdate();

                    if (effectRows >= 1) {
                        sign.setCode(206);
                        sign.setMsg("簽到成功！成功更新數據!");
                        sign.setContinueSignCount(newSignCount);
                        sign.setLastModifyDate(signDate);
                        sign.setTotalScore(newIntegration);
                        sign.setSignHistory(newSignHistory);
                    } else {
                        sign.setCode(208);
                        sign.setMsg("簽到失敗，更新數據失敗!");
                    }
                }
                else
                {//今天已經簽過到了
                    sign.setCode(300);
                    sign.setMsg("該用戶今天已經簽過到了!");
                    sign.setLastModifyDate(signObject.getLastModifyTime());
                    sign.setContinueSignCount(signObject.getSignCount());
                    sign.setSignHistory(signObject.getSignHistory());
                    sign.setTotalScore(signObject.getIntegration());
                }

            } else {//沒查到，插入
                executePreparedStatement = conn.prepareStatement(" insert into db_userplatform.dt_sign(userid,gameid,signCount,integration,lastModifyTime,signHistory,ext) values(?,?,1,1,?,1,?); ");
                executePreparedStatement.setInt(1, uid);
                executePreparedStatement.setInt(2, gid);
               final java.sql.Date insertDate= new java.sql.Date(System.currentTimeMillis());
                executePreparedStatement.setDate(3, insertDate);
                 executePreparedStatement.setString(4,"首次簽到,時間:"+insertDate);
                int effectRows = executePreparedStatement.executeUpdate();

                if (effectRows >= 1) {
                    sign.setCode(200);
                    sign.setMsg("該用戶第一次簽到！成功插入數據!");
                    sign.setContinueSignCount(1);
                    sign.setLastModifyDate(insertDate);
                    sign.setTotalScore(1);
                    sign.setSignHistory(1);
                } else {
                    sign.setCode(204);
                    sign.setMsg("該用戶第一次簽到，插入數據失敗!");
                }

            }
        } catch (SQLException e) {
            sign.setCode(404);
            sign.setMsg("平台或者db異常！");
            e.printStackTrace();
        } finally {
            DbUtils.closeQuietly(rs);
            try {
                DbUtils.close(preparedStatement);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            DbUtils.closeQuietly(conn);
        }
        return sign;
    }

    @Override
    public Sign getGiftPackThenReturn(int uid, int gid, int giftPackScore) {
        Sign sign = new Sign();
        ResultSet rs = null;
        PreparedStatement preparedStatement = null, executePreparedStatement = null;
        try {
            conn = getQueryRunner().getDataSource().getConnection();
            preparedStatement = conn.prepareStatement(" select * from db_userplatform.dt_sign where userid=? and gameid=? and integration >=? ;");

            preparedStatement.setInt(1, uid);
            preparedStatement.setInt(2, gid);
            preparedStatement.setInt(3, giftPackScore);

            rs = preparedStatement.executeQuery();
            if (rs.next()) { //如果查到了減去積分
                SignObject signObject = new SignObject();

                signObject.setId(rs.getInt("id"));
                signObject.setUid(rs.getInt("userid"));
                signObject.setGid(rs.getInt("gameid"));
                signObject.setSignCount(rs.getInt("signCount"));
                signObject.setIntegration(rs.getInt("integration"));
                signObject.setLastModifyTime(new Date(rs.getDate("lastModifyTime").getTime()));
                signObject.setSignHistory(rs.getLong("signHistory"));
                signObject.setExt(rs.getString("ext"));


                executePreparedStatement = conn.prepareStatement(" update db_userplatform.dt_sign set integration=? where id=? ;");
                executePreparedStatement.setInt(1, signObject.getIntegration() - giftPackScore);
                executePreparedStatement.setInt(2, signObject.getId());

                int effectRows = executePreparedStatement.executeUpdate();

                if (effectRows >= 1) {
                    sign.setCode(200);
                    sign.setMsg("成功領取禮包，積分消耗" + giftPackScore);
                    sign.setLastModifyDate(signObject.getLastModifyTime());
                    sign.setContinueSignCount(signObject.getSignCount());
                    sign.setSignHistory(signObject.getSignHistory());
                    sign.setTotalScore(signObject.getIntegration() - giftPackScore);
                } else { //減去積分失敗
                    sign.setCode(400);
                    sign.setMsg("領取禮包失敗,積分沒有減去！");
                }
            } else { //沒查到，說明積分不夠 返回300
                sign.setCode(300);
                sign.setMsg("積分不夠領取禮包！");
            }
        } catch (Exception e) {//發生異常則是404
            sign.setCode(404);
            sign.setMsg("平台或db異常");
            e.printStackTrace();
        } finally {
            DbUtils.closeQuietly(rs);
            try {
                DbUtils.close(preparedStatement);
            } catch (SQLException e) {
                e.printStackTrace();
            }
            DbUtils.closeQuietly(conn);
        }
        return sign;
    }
}

移位和規則類：

package com.sz7road.userplatform.ws.sign;

import java.math.BigInteger;

/**
 * Created with IntelliJ IDEA.
 * User: cutter.li
 * Date: 13-1-18
 * Time: 下午5:24
 * 移位和積分規則類
 */
public class ScoreRuleAndMoveByte {

    public static Long moveByte(long oldHistory,long moveAmonut)
    {
        long moveResult= oldHistory<<moveAmonut;
       long result=  Long.parseLong(toFullBinaryString(moveResult),2)+1;
        return result;
    }


    /**
     * 讀取
     * @param num
     * @return
     */
    private static String toFullBinaryString(long num) {
        final int size=42;
        char[] chs = new char[size];
        for(int i = 0; i < size; i++) {
            chs[size - 1 - i] = (char)(((num >> i) & 1) + '0');
        }
        return new String(chs);
    }

    /**
     * 按照積分規則，得到積分 ,
     * 積分規則如下：
     簽到功能說明
     1.每天只能簽到一次（按服務器系統時間為准）
     2.連續簽到 額外獎勵積分，同種禮包只能使用一次
     3.連續簽到10天，一次性獎勵2積分
     4.連續簽到30天，一次性獎勵10積分
     5.連續簽到60天，一次性獎勵30積分
     6.連續簽到90天，一次性獎勵100積分
     * @param signCount  連續簽到次數
     * @return 增加的積分
     */
    public static  int getScoreByRule(int signCount)
    {
        int addScore=1;

        if(signCount==10)
        {
            addScore+=2;
        }
        else if(signCount==30)
        {
            addScore+=10;
        }
        else if(signCount==60)
        {
            addScore+=30;
        }
        else if(signCount==90)
        {
            addScore+=100;
        }

        return addScore;
    }



    public static  void main(String[] args)
    {
       long result= moveByte(1,3);

        System.out.println("移位結果："+result);

        System.out.println("連續簽到次數9：所增加的積分："+getScoreByRule(9));
        System.out.println("連續簽到次數10：所增加的積分："+getScoreByRule(10));
        System.out.println("連續簽到次數29：所增加的積分："+getScoreByRule(29));
        System.out.println("連續簽到次數30：所增加的積分："+getScoreByRule(30));
        System.out.println("連續簽到次數59：所增加的積分："+getScoreByRule(59));
        System.out.println("連續簽到次數60：所增加的積分："+getScoreByRule(60));
        System.out.println("連續簽到次數89：所增加的積分："+getScoreByRule(89));
        System.out.println("連續簽到次數90：所增加的積分："+getScoreByRule(90));
        System.out.println("連續簽到次數91：所增加的積分："+getScoreByRule(91));
    }







}

 

  各位屌絲，有什么可以進一步優化的，歡迎聯系我，共同進步是我覺得最開心的事情！

2013-01-22  16:22:24