小小训练营

mec-biz/src/main/java/com/ym/mec/biz/dal/dao/LiveGoodsMapperDao.java

@@ -13,7 +13,7 @@ public interface LiveGoodsMapperDao extends BaseDAO<Integer, LiveGoodsMapper> {
 
     List<LiveGoodsMapper> findByLiveGoodsIdAndStatus(@Param("liveGoodsId") Integer liveGoodsId, @Param("status") Boolean status);
 
-    void updateStatus(@Param("liveId") String liveId, @Param("liveGoodsId") Integer liveGoodsId, @Param("status") boolean status);
+    int updateStatus(@Param("liveId") String liveId, @Param("liveGoodsId") Integer liveGoodsId, @Param("status") boolean status);
 
     LiveGoodsMapper findByLiveIdAndGoodsId(@Param("liveId") String liveId, @Param("liveGoodsId") Integer liveGoodsId);
 

mec-biz/src/main/java/com/ym/mec/biz/service/impl/LiveGoodsMapperServiceImpl.java

@@ -53,7 +53,10 @@ public class LiveGoodsMapperServiceImpl extends BaseServiceImpl<Integer, LiveGoo
 	@Override
 	@Transactional(rollbackFor = Exception.class)
 	public void upGoods(Integer liveGoodsId, String liveId) {
-		liveGoodsMapperDao.updateStatus(liveId,liveGoodsId,true);
+		int i = liveGoodsMapperDao.updateStatus(liveId, liveGoodsId, true);
+		if (i == 0) {
+			return;
+		}
 		ImLiveBroadcastRoom imLiveBroadcastRoom = Optional
 				.of(imLiveBroadcastRoomService.getBaseMapper().selectOne(new QueryWrapper<ImLiveBroadcastRoom>().eq("room_uid_",liveId))).
 				orElseThrow(() -> new RuntimeException("直播间不存在"));
@@ -120,7 +123,10 @@ public class LiveGoodsMapperServiceImpl extends BaseServiceImpl<Integer, LiveGoo
 			throw new BizException("该商品已下架");
 		}
 		//下架直播间商品
-		liveGoodsMapperDao.updateStatus(liveId,liveGoodsId,false);
+		int i = liveGoodsMapperDao.updateStatus(liveId, liveGoodsId, false);
+		if (i == 0) {
+			return;
+		}
 		//通知直播间，商品信息变更
 		this.publishRoomMsg(imLiveBroadcastRoom);
 		//商品下架后，将缓存的库存设置为0
@@ -138,7 +144,10 @@ public class LiveGoodsMapperServiceImpl extends BaseServiceImpl<Integer, LiveGoo
 		List<LiveGoodsMapper> liveGoodsMappers = liveGoodsMapperDao.findByLiveGoodsIdAndStatus(liveGoodsId,true);
 		if(liveGoodsMappers.size()>0){
 			//下架直播间商品
-			liveGoodsMapperDao.updateStatus(null,liveGoodsId,false);
+			int i = liveGoodsMapperDao.updateStatus(null, liveGoodsId, false);
+			if (i == 0) {
+				return;
+			}
 			//通知直播间，商品信息变更
 			for (LiveGoodsMapper liveGoodsMapper : liveGoodsMappers) {
 				ImLiveBroadcastRoom imLiveBroadcastRoom = Optional

mec-biz/src/main/resources/config/mybatis/LiveGoodsMapperMapper.xml

@@ -105,7 +105,10 @@
 	</select>
 
 	<select id="findByLiveGoodsIdAndStatus" resultMap="LiveGoodsMapper">
-		SELECT * FROM live_goods_mapper WHERE goods_id_ = #{liveGoodsId} AND status_ = #{status}
+		SELECT * FROM live_goods_mapper WHERE goods_id_ = #{liveGoodsId}
+		<if test="status != null">
+			AND status_ = #{status}
+		</if>
 	</select>
 	<select id="findByLiveIdAndGoodsId" resultMap="LiveGoodsMapper">
 		SELECT * FROM live_goods_mapper WHERE live_id_ = #{liveId} AND goods_id_ = #{liveGoodsId}