package com.yc.puffer.serviceimpl.channel;
import com.alibaba.fastjson.JSONObject;
import com.yc.puffer.common.constant.GlobalConstants;
import com.yc.puffer.common.redis.global.ProductGlobal;
import com.yc.puffer.common.redis.global.RedisGlobal;
import com.yc.puffer.dao.mapper.BaseMapper;
import com.yc.puffer.dao.mapper.channel.ProductInfoMapper;
import com.yc.puffer.dao.model.channel.ProductInfo;
import com.yc.puffer.dao.model.channel.ProductInfoExample;
import com.yc.puffer.service.channel.ProductInfoService;
import com.yc.puffer.serviceimpl.BaseServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @description:
* @author: haibin
* @create: 2019-08-09 15:01
*/
@Slf4j
@Service
@Transactional
public class ProductInfoServiceImplextends BaseServiceImplimplements ProductInfoService {
@Resource
private ProductInfoMapper productInfoMapper;
@Override
public BaseMapper getMapper() {
return productInfoMapper;
}
/**
* 初始化產(chǎn)品Key到Redis中
*/
@Override
public void initProduct() {
log.info("初始化Product信息......start......");
ProductInfoExample example =new ProductInfoExample();
example.createCriteria().andStatusEqualTo(GlobalConstants.STATUS_ON);
List productInfos = productInfoMapper.selectByExample(example);
Map productMap =new HashMap<>();
productInfos.stream().forEach(productInfo -> {
productMap.put(productInfo.getId().toString(), JSONObject.toJSON(productInfo));
});
RedisGlobal global = ProductGlobal.getGlobal();
global.del();
global.set(productMap);
log.info("初始化Product信息......end......");
}
/**
* 根據(jù)產(chǎn)品ID獲取產(chǎn)品信息
* @param productId
* @return
*/
@Override
public ProductInfo queryProductInfoByProductId(Long productId) {
ProductInfoExample example =new ProductInfoExample();
example.createCriteria().andIdEqualTo(productId);
return this.selectSingleByExample(example);
}
}
Redisson 分布式鎖深入理解分析
最后編輯于 :
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
- 文/潘曉璐 我一進店門啊奄,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人掀潮,你說我怎么就攤上這事∏砀唬” “怎么了仪吧?”我有些...
- 文/不壞的土叔 我叫張陵,是天一觀的道長鞠眉。 經(jīng)常有香客問我薯鼠,道長,這世上最難降的妖魔是什么械蹋? 我笑而不...
- 正文 為了忘掉前任出皇,我火速辦了婚禮,結(jié)果婚禮上哗戈,老公的妹妹穿的比我還像新娘郊艘。我一直安慰自己,他們只是感情好,可當我...
- 文/花漫 我一把揭開白布纱注。 她就那樣靜靜地躺著畏浆,像睡著了一般。 火紅的嫁衣襯著肌膚如雪狞贱。 梳的紋絲不亂的頭發(fā)上刻获,一...
- 文/蒼蘭香墨 我猛地睜開眼挑胸,長吁一口氣:“原來是場噩夢啊……” “哼痒筒!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起茬贵,我...
- 正文 年R本政府宣布,位于F島的核電站红且,受9級特大地震影響坝茎,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜暇番,卻給世界環(huán)境...
- 文/蒙蒙 一嗤放、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧壁酬,春花似錦次酌、人聲如沸恨课。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽庄呈。三九已至,卻和暖如春派阱,著一層夾襖步出監(jiān)牢的瞬間诬留,已是汗流浹背。 一陣腳步聲響...
推薦閱讀更多精彩內(nèi)容
- 上次搭建好三主三從的rediscluster集群之后趾断,也試了試redission的加鎖解鎖的API拒名,那么redis...
- 1 .需要客戶端和服務器之間的真正低延遲增显,接近實時的連接,就使用websocket脐帝,這可能需要考慮如何構(gòu)建服務端應...
- Leon and Amy: 昨天我?guī)讉€同學在肇慶幾個景點走了一下,我是在本地堵腹,他們算是來旅游的炸站,今天我們就說一下...