From 62a447d89331aee1feae7724c7616aa1bb2cfe79 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 十月 2024 14:28:37 +0800 Subject: [PATCH] 将CMQ替换为rabbitmq --- fanli/src/main/java/com/yeshi/fanli/service/impl/config/JumpDetailServiceImpl.java | 159 +++++++++++++++++++++++----------------------------- 1 files changed, 71 insertions(+), 88 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/config/JumpDetailServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/config/JumpDetailServiceImpl.java index ad454c4..adbb2a1 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/config/JumpDetailServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/config/JumpDetailServiceImpl.java @@ -1,88 +1,71 @@ -package com.yeshi.fanli.service.impl.config; - -import java.io.Serializable; -import java.util.List; - -import javax.annotation.Resource; -import javax.transaction.Transactional; - -import org.springframework.cache.annotation.Cacheable; -import org.springframework.stereotype.Service; - -import com.yeshi.fanli.dao.config.JumpDetailDao; -import com.yeshi.fanli.entity.common.JumpDetail; -import com.yeshi.fanli.exception.NotExistObjectException; -import com.yeshi.fanli.service.inter.config.JumpDetailService; -import com.yeshi.fanli.service.inter.goods.RecommendBannerService; -import com.yeshi.fanli.service.inter.goods.RecommendSpecialService; -import com.yeshi.fanli.util.Constant; - -@Service -public class JumpDetailServiceImpl implements JumpDetailService { - - @Resource - private JumpDetailDao jumpDetailDao; - - @Resource - private RecommendBannerService recommendBannerService; - - @Resource - private RecommendSpecialService recommendSpecialService; - - public List<JumpDetail> getJumpDetailList(int index, String key) { - - int start = index * Constant.PAGE_SIZE; - - return jumpDetailDao.list("from JumpDetail j where j.name like ? ", start, Constant.PAGE_SIZE, - new Serializable[] { "%" + key + "%" }); - } - - public int getCount(String key) { - Long lcount = jumpDetailDao.getCount("select count(j.id) from JumpDetail j where j.name like ? ", - new Serializable[] { "%" + key + "%" }); - return lcount.intValue(); - } - - public void addJumpDetail(JumpDetail jd) { - jumpDetailDao.create(jd); - } - - public void updateJumpDetail(JumpDetail jd) throws NotExistObjectException { - JumpDetail find = jumpDetailDao.find(JumpDetail.class, jd.getId()); - if (find == null) { - throw new NotExistObjectException("涓嶅瓨鍦ㄨ瀵硅薄"); - } - jumpDetailDao.update(jd); - } - - public JumpDetail getJumpDetail(long id) { - return jumpDetailDao.find(JumpDetail.class, id); - } - - @Transactional - public void deleteJumpDetail(long id) { - recommendBannerService.updateBannerJumpDetail(id); - recommendSpecialService.updateSpecialJumpDetail(id); - jumpDetailDao.delete(new JumpDetail(id)); - } - - public List<JumpDetail> getJumpDetailAllList() { - return jumpDetailDao.list("from JumpDetail"); - } - - public JumpDetail getlastJumpDetail() { - - List<JumpDetail> list = jumpDetailDao.list("from JumpDetail jp order by jp.id desc ", 0, 1, null); - if (list.size() > 0) { - return list.get(0); - } - return null; - } - - @Cacheable(value = "configCache", key = "'getlastJumpDetailCache'") - @Override - public JumpDetail getlastJumpDetailCache() { - return getlastJumpDetail(); - } - -} +package com.yeshi.fanli.service.impl.config; + +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.cache.annotation.Cacheable; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import com.yeshi.fanli.dao.mybatis.common.JumpDetailMapper; +import com.yeshi.fanli.entity.common.JumpDetail; +import com.yeshi.fanli.exception.NotExistObjectException; +import com.yeshi.fanli.service.inter.config.JumpDetailService; +import com.yeshi.fanli.util.Constant; + +@Service +public class JumpDetailServiceImpl implements JumpDetailService { + + @Resource + private JumpDetailMapper jumpDetailMapper; + + + public List<JumpDetail> getJumpDetailList(int index, String key) { + + int start = index * Constant.PAGE_SIZE; + + return jumpDetailMapper.listSearchByName(key, start, Constant.PAGE_SIZE); + } + + public int getCount(String key) { + Long lcount = jumpDetailMapper.countSearchByName(key); + return lcount.intValue(); + } + + public void addJumpDetail(JumpDetail jd) { + jumpDetailMapper.insertSelective(jd); + } + + public void updateJumpDetail(JumpDetail jd) throws NotExistObjectException { + jumpDetailMapper.updateByPrimaryKeySelective(jd); + } + + public JumpDetail getJumpDetail(long id) { + return jumpDetailMapper.selectByPrimaryKey(id); + } + + @Transactional + public void deleteJumpDetail(long id) { + jumpDetailMapper.deleteByPrimaryKey(id); + } + + public List<JumpDetail> getJumpDetailAllList() { + return jumpDetailMapper.listSearchByName("", 0, 500); + } + + public JumpDetail getlastJumpDetail() { + List<JumpDetail> list = getJumpDetailAllList(); + if (list.size() > 0) { + return list.get(list.size() - 1); + } + return null; + } + + @Cacheable(value = "configCache", key = "'getlastJumpDetailCache'") + @Override + public JumpDetail getlastJumpDetailCache() { + return getlastJumpDetail(); + } + +} -- Gitblit v1.8.0