砍价成功

@@ -26,4 +26,5 @@ public interface CutDownPriceUserRecordMapper {
 
 
     int updateIncreaseUseCount(@Param("userId") Integer userId, @Param("activityId") Integer activityId, @Param("productSkn") Integer productSkn, @Param("cutRecordId") Integer cutRecordId);
     int updateIncreaseUseCount(@Param("userId") Integer userId, @Param("activityId") Integer activityId, @Param("productSkn") Integer productSkn, @Param("cutRecordId") Integer cutRecordId);
 
 
+    int updateCutSuccess(@Param("id") Integer id);
 }
 }

@@ -97,4 +97,11 @@
     and id = #{cutRecordId,jdbcType=INTEGER}
     and id = #{cutRecordId,jdbcType=INTEGER}
     and use_count=0
     and use_count=0
   </update>
   </update>
+
+  <update id="updateCutSuccess" >
+    update cutdown_price_user_record
+    set status=1, update_time= UNIX_TIMESTAMP()
+    where 1=1
+    and id = #{id,jdbcType=INTEGER}
+  </update>
 </mapper>
 </mapper>

@@ -2,6 +2,8 @@ package com.yoho.activity.queue.constant;
 
 
 
 
 public class CutPriceConstant {
 public class CutPriceConstant {
+	// 1：未发起砍价
+	public static final Integer CUT_STATUS_NOT_CREATE = 0;
 	// 1：砍价中
 	// 1：砍价中
 	public static final Integer CUT_STATUS_ONGOING = 1;
 	public static final Integer CUT_STATUS_ONGOING = 1;
 	// 2：已成功
 	// 2：已成功

@@ -430,6 +430,9 @@ public class CutDownPriceServiceImpl implements ICutDownPriceService {
         clearCache(activityId, productSkn, userId, recordDb.getId());
         clearCache(activityId, productSkn, userId, recordDb.getId());
         // 砍价成功时，给用户推送砍价成功消息
         // 砍价成功时，给用户推送砍价成功消息
         if(helpUsers!=null && (helpUsers.size()+1) == cutDownPriceProductBo.getJoinNum()){
         if(helpUsers!=null && (helpUsers.size()+1) == cutDownPriceProductBo.getJoinNum()){
+            // 修改砍价成功状态
+            cutDownPriceUserRecordMapper.updateCutSuccess(recordDb.getId());
+            // 给用户推送砍价成功消息
             pushSuccessMessage(userId, activityBo, cutDownPriceProductBo);
             pushSuccessMessage(userId, activityBo, cutDownPriceProductBo);
         }
         }
 
 
@@ -763,7 +766,8 @@ public class CutDownPriceServiceImpl implements ICutDownPriceService {
             // 活动已结束
             // 活动已结束
             bo.setCutStatus(CutPriceConstant.CUT_STATUS_EXPIRE);
             bo.setCutStatus(CutPriceConstant.CUT_STATUS_EXPIRE);
         }else{
         }else{
-            // 活动进行中
+            // 活动进行中，是否已经发起砍价
+            if(null!=bo.getCreateTime()){
                 // 砍价成功、失败
                 // 砍价成功、失败
                 if(bo.getHasJoinNum() > bo.getJoinNum()){
                 if(bo.getHasJoinNum() > bo.getJoinNum()){
                     // 砍价已成功
                     // 砍价已成功
@@ -786,6 +790,10 @@ public class CutDownPriceServiceImpl implements ICutDownPriceService {
                         bo.setCutEndTime(bo.getCreateTime()+TIME_24_HOUR);
                         bo.setCutEndTime(bo.getCreateTime()+TIME_24_HOUR);
                     }
                     }
                 }
                 }
+            }else{
+                bo.setCutStatus(CutPriceConstant.CUT_STATUS_NOT_CREATE);
+            }
+
         }
         }
     }
     }