專案實際開發中遇到的事務問題

阿新 • • 發佈：2018-11-30

廢話不多說看功能：
最近做了一個app的記步功能，要求是app一開啟就開始進行步數的計算，然後一分鐘向後臺傳送一次資料儲存到資料庫中，此時儲存的是使用者的走的步數和有效步數（有效步數是在一分鐘內步頻大於90的算是真正的走路）和有效時間，然後當你開啟記步頁面的時候，又一個請求一分鐘一次的向後天傳資料，此時儲存的資料是使用者走的實際的里程和使用者從開啟手機到現在累計消耗的能量，先看實體類的設計

package com.kd.food.model;

import com.kd.framework.data.orm.BaseModel;

/**
 * @author 使用者記步實體類
 *
 */ 

public class RecordStep extends BaseModel {

    private static final long serialVersionUID = -5858855168283954031L;
    /**
     * 使用者ID
     */
    private String userId;
    private int count;
    /**
     * 今日有效步數
     */
    private int effectiveSteps;
    /**
     * 今日實際步數
     */
    private Integer actualStep;
    /**
     * 今日目標步數
     */ 

    private Integer targetStep;
    /**
     * 今日實際運動時間
     */
    private Integer actualTime;
    /**
     * 今日目標運動時間
     */
    private Integer targetTime;
    /**
     * 今日實際運動里程
     */
    private String actualMileage;
    /**
     * 今日目標運動里程
     */
    private String targetMileage;
    /**
     * 今日消實際耗能量
     */ 

    private Integer actualEnergy;
    /**
     * 今日目標能量
     */
    private Integer targetEnergy;

    /**
     * 刪除
     */
    private String deleteFlag;


    public String getUserId() {
        return userId;
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }
    public Integer getActualStep() {
        return actualStep;
    }
    public void setActualStep(Integer actualStep) {
        this.actualStep = actualStep;
    }
    public Integer getTargetStep() {
        return targetStep;
    }
    public void setTargetStep(Integer targetStep) {
        this.targetStep = targetStep;
    }
    public Integer getActualTime() {
        return actualTime;
    }
    public void setActualTime(Integer actualTime) {
        this.actualTime = actualTime;
    }
    public Integer getTargetTime() {
        return targetTime;
    }
    public void setTargetTime(Integer targetTime) {
        this.targetTime = targetTime;
    }
    public String getActualMileage() {
        return actualMileage;
    }
    public void setActualMileage(String actualMileage) {
        this.actualMileage = actualMileage;
    }
    public String getTargetMileage() {
        return targetMileage;
    }
    public void setTargetMileage(String targetMileage) {
        this.targetMileage = targetMileage;
    }
    public Integer getActualEnergy() {
        return actualEnergy;
    }
    public void setActualEnergy(Integer actualEnergy) {
        this.actualEnergy = actualEnergy;
    }
    public Integer getTargetEnergy() {
        return targetEnergy;
    }
    public void setTargetEnergy(Integer targetEnergy) {
        this.targetEnergy = targetEnergy;
    }

    public static long getSerialversionuid() {
        return serialVersionUID;
    }
    public String getDeleteFlag() {
        return deleteFlag;
    }
    public void setDeleteFlag(String deleteFlag) {
        this.deleteFlag = deleteFlag;
    }
    public int getCount() {
        return count;
    }
    public void setCount(int count) {
        this.count = count;
    }
    public int getEffectiveSteps() {
        return effectiveSteps;
    }
    public void setEffectiveSteps(int effectiveSteps) {
        this.effectiveSteps = effectiveSteps;
    }


}

controller層這是app一開啟就開始的請求，現在需要儲存的資料是實際的步數，有效時間，有效步數：


    /**
     * 記步請求 一分鐘請求一次 
     * @return
     */
    @RequestMapping("/saveStep")
    @ResponseBody
    public String saveStep(HttpServletRequest request,HttpServletResponse response){
        try {
            String userId = request.getParameter("id");//使用者ID
            String step = request.getParameter("step");//實際的步數
            String time = request.getParameter("effectiveTime");//有效運動時間
            String effectiveSteps = request.getParameter("effectiveSteps");//有效步數

            RecordStep recordStep=new RecordStep();
            recordStep.setUserId(userId);
            if (StringUtil.isEmpty(step)) {
                step="0";
            }
            recordStep.setActualStep(DataConvert.getInt(step));
            if(StringUtil.isEmpty(effectiveSteps)){
                effectiveSteps="0";
            }
            recordStep.setEffectiveSteps(DataConvert.getInt(effectiveSteps));
            if (StringUtil.isEmpty(time)) {
                time="0";
            }
            recordStep.setActualTime(DataConvert.getInt(time));
            recordStep.setCreateBy(new SimpleDateFormat("yyyy-MM-dd").format(new Date()));

            recordStepService.saverecordStep(recordStep);
            JSONObject json=new JSONObject();
            json.put("success", true);
            return json.toJSONString();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "ok";
    }

這是記步頁面開啟的時候開始的請求，此時需要儲存的是使用者走的里程和實際消耗的能量

/**
     * 開啟記步頁面 儲存里程和卡路里 (一分鐘儲存一次實際里程和消耗能量）
     * (上傳實時運動資料 里程和能量的消耗)
     * @return
     */
    @RequestMapping("/updateStep")
    @ResponseBody
    public String querySteps(HttpServletRequest request,HttpServletResponse response){
        JSONObject json=new JSONObject();
        try {
            String userId = request.getParameter("id");//使用者ID
            String licheng = request.getParameter("sumJourney");//實際里程
            String enenrgy = request.getParameter("sumKcal");//消耗能量
            RecordStep recordStep=new RecordStep();
            recordStep.setUserId(userId);
            //如果傳來NaN
            if("NaN".equals(licheng)){
                return json.toJSONString();
            }
            //實際里程為0 則沒走 也沒消耗能量 直接返回唄
            if (StringUtil.isEmpty(licheng)||"0".equals(licheng)) {
                return json.toJSONString();
            }
            recordStep.setActualMileage(licheng);
            if (StringUtil.isEmpty(enenrgy)) {
                enenrgy="0";
            }
            recordStep.setActualEnergy(DataConvert.getInt(enenrgy));
            recordStep.setCreateBy(new SimpleDateFormat("yyyy-MM-dd").format(new Date()));
            boolean flag = recordStepService.saverecordStep(recordStep);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return json.toJSONString();
    }

這是你會看到，兩個請求訪問的是同一個service，因為表的設計是每天儲存使用者一一條資料，這一條資料就是他這一天的步數里程等等，所以當你app開啟的時候判斷當前使用者今天有沒有走路，有了就插入，沒了就更新資料，實時儲存嘛
service實現層：

    /**
     * 儲存步數(更新and插入操作)
     */
    public boolean saverecordStep(RecordStep recordStep) {

        try {
            baseDao.update("RecordStep.insertStep", recordStep);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

這是mapper檔案：有則更新，沒有則插入

<!--  如果存在就更新 不存在則插入-->
    <insert id="insertStep" useGeneratedKeys="true" keyProperty="id" parameterType="RecordStep">
        <selectKey keyProperty="count" resultType="int" order="BEFORE">
            select count(*)  as count from tj_record_step where  CREATEBY=#{createBy} and USER_ID=#{userId}
      </selectKey>
      <!--如果不存在建立  -->
          <if test="count==0">
            INSERT INTO 
            tj_record_step
        (
            <include refid="SRecordColumns" />
        )VALUES(
            #{userId},
            #{actualTime},
            #{actualEnergy},
            #{actualMileage},
            #{actualStep},
            #{effectiveSteps},
            NOW(),
            NOW()
        )
        </if>
        <!--如果存在,更新時間  -->
        <if test="count > 0">
            UPDATE tj_record_step SET UPDATEBY=NOW() 
            <if test="actualTime !=null and actualTime !=''">
                ,ACTUAL_TIME=#{actualTime}
            </if>
            <if test="actualEnergy !=null and actualEnergy !=''">
                ,ACTUAL_ENERGY=#{actualEnergy}
            </if>
            <if test="actualMileage !=null and actualMileage !=''">
                ,ACTUAL_MILEAGE=#{actualMileage}
            </if>
            <if test="actualStep !=null and actualStep !=''">
                ,ACTUAL_STEP=#{actualStep}
            </if>
            <if test="effectiveSteps !=null and effectiveSteps !=''">
                ,EFFECTIVE_STEPS=#{effectiveSteps}
            </if>
            WHERE  USER_ID=#{userId} and CREATEBY=#{createBy}
        </if>
    </insert>

當時測試的時候是在瀏覽器上，沒有考慮到併發情況，測試的時候都是單執行緒情況，沒一點問題，當撞到手機上之後，我曹，簡直驚呆了。，因為要把使用者的每天走路的步數用圖表展示起來，然後使用者昨天的資料以及前天的資料全部被更新了，然後我趕緊檢視資料庫，我曹，竟然全部被更新了，而且，同時插入了兩條，一臉矇蔽啊，百思不得其解，，，，然後呢，才想到，他媽併發的情況所以呢想到了用事務，

/**
     * 儲存步數(更新and插入操作)
     * Isolation.READ_COMMITTED 隔離級別 防止髒讀
     */
    @Transactional(isolation=Isolation.READ_COMMITTED)
    public boolean saverecordStep(RecordStep recordStep) {

        try {
            baseDao.update("RecordStep.insertStep", recordStep);
            return true;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return false;
    }

ok 解決了

專案實際開發中遇到的事務問題

專案實際開發中遇到的事務問題

實際開發中，Eclipse匯入的專案上紅色感嘆號，jar包無報錯，無缺失兩種解決方案

Java 反射在實際開發中的應用

Java 數據類型在實際開發中應用二枚舉

經驗 windows目錄在實際開發中使用/代替

HTML <area><map>標簽及在實際開發中的應用

tomcat配置虛擬路徑，可以解決實際開發中測試時前端訪問後臺電腦上的圖片的問題

[轉]Java 反射在實際開發中的應用

收集 - 實際開發中的技巧記錄【頁面】

Solr05-Solr在實際開發中的應用

RunLoop六：在實際開發中的應用之控制執行緒生命週期（執行緒保活) 二

RunLoop六：在實際開發中的應用之控制執行緒生命週期（執行緒保活)

RunLoop五：在實際開發中的應用

設計模式在實際開發中的應用

android---實際開發中遇到的問題總結

實際開發中String轉換為json串作為入參發生"JSON parse error:Cannot deserialize value of type Date......not a valid解決

實際開發中，解決iReport中列印圖片不顯示問題

實際開發中，解決列印iReport中獲取list集合遍歷，並且縮小間距

實際開發中，獲得到的list為重複的最後一條資料問題解決

實際開發中遇到java.lang.NoSuchMethodError

專案實際開發中遇到的事務問題

相關推薦