Skip to content
GitLab
Commit 03caebe8 authored by HuangBingGui's avatar HuangBingGui
Browse files

no commit message

parent 6e7c95e7
Hide whitespace changes
Inline Side-by-side
JeeSpringCloud/src/main/java/com/company/project/modules/ylttrip/service/TfTicketService.java → JeeSpringCloud/src/main/java/com/company/project/modules/ylttrip/service/TfTicketServiceImpl.java
View file @ 03caebe8
...@@ -5,7 +5,6 @@ package com.company.project.modules.ylttrip.service; ...@@ -5,7 +5,6 @@ package com.company.project.modules.ylttrip.service;
import java.util.List; import java.util.List;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -13,23 +12,21 @@ import com.jeespring.common.persistence.Page; ...@@ -13,23 +12,21 @@ import com.jeespring.common.persistence.Page;
import com.jeespring.common.service.AbstractBaseService; import com.jeespring.common.service.AbstractBaseService;
import com.company.project.modules.ylttrip.entity.TfTicket; import com.company.project.modules.ylttrip.entity.TfTicket;
import com.company.project.modules.ylttrip.dao.TfTicketDao; import com.company.project.modules.ylttrip.dao.TfTicketDao;
import com.company.project.modules.ylttrip.service.ITfTicketService;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.jeespring.common.redis.RedisUtils; import com.jeespring.common.redis.RedisUtils;
import com.jeespring.common.security.MD5Tools;
//import com.alibaba.dubbo.config.annotation.Service; //import com.alibaba.dubbo.config.annotation.Service;
import com.jeespring.common.config.Global;
/** /**
* 订单Service * 订单Service
* @author JeeSpring * @author JeeSpring
* @version 2018-10-12 * @version 2018-10-15
*/ */
//启用dubbo服务器时，要去掉下面注解 //启用dubbo服务器时，要去掉下面注解
//com.alibaba.dubbo.config.annotation.Service(interfaceClass = ISysServerService.class,version = "1.0.0", timeout = 60000) //com.alibaba.dubbo.config.annotation.Service(interfaceClass = ISysServerService.class,version = "1.0.0", timeout = 60000)
@org.springframework.stereotype.Service @org.springframework.stereotype.Service
@Transactional(readOnly = true) @Transactional(readOnly = true)
public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> implements ITfTicketService{ public class TfTicketServiceImpl extends AbstractBaseService<TfTicketDao, TfTicket> implements ITfTicketService{
/** /**
* redis caches * redis caches
...@@ -37,34 +34,42 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> ...@@ -37,34 +34,42 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket>
@Autowired @Autowired
private RedisUtils redisUtils; private RedisUtils redisUtils;
@Override
public TfTicket get(String id) { public TfTicket get(String id) {
//获取数据库数据 //获取数据库数据
TfTicket tfTicket=super.get(id); TfTicket tfTicket=super.get(id);
return tfTicket; return tfTicket;
} }
@Override
public TfTicket getCache(String id) { public TfTicket getCache(String id) {
//获取缓存数据 //获取缓存数据
TfTicket tfTicket=(TfTicket)redisUtils.get(RedisUtils.getIdKey(TfTicketService.class.getName(),id)); TfTicket tfTicket=(TfTicket)redisUtils.get(RedisUtils.getIdKey(TfTicketServiceImpl.class.getName(),id));
if( tfTicket!=null) return tfTicket; if( tfTicket!=null) {
return tfTicket;
}
//获取数据库数据 //获取数据库数据
tfTicket=super.get(id); tfTicket=super.get(id);
//设置缓存数据 //设置缓存数据
redisUtils.set(RedisUtils.getIdKey(TfTicketService.class.getName(),id),tfTicket); redisUtils.set(RedisUtils.getIdKey(TfTicketServiceImpl.class.getName(),id),tfTicket);
return tfTicket; return tfTicket;
} }
@Override
public List<TfTicket> total(TfTicket tfTicket) { public List<TfTicket> total(TfTicket tfTicket) {
//获取数据库数据 //获取数据库数据
List<TfTicket> tfTicketList=super.total(tfTicket); List<TfTicket> tfTicketList=super.total(tfTicket);
return tfTicketList; return tfTicketList;
} }
@Override
public List<TfTicket> totalCache(TfTicket tfTicket) { public List<TfTicket> totalCache(TfTicket tfTicket) {
//获取缓存数据 //获取缓存数据
String totalKey = RedisUtils.getTotalKey(TfTicketService.class.getName(),JSON.toJSONString(tfTicket)); String totalKey = RedisUtils.getTotalKey(TfTicketServiceImpl.class.getName(),JSON.toJSONString(tfTicket));
List<TfTicket> tfTicketList=(List<TfTicket>)redisUtils.get(totalKey); List<TfTicket> tfTicketList=(List<TfTicket>)redisUtils.get(totalKey);
if(tfTicketList!=null) return tfTicketList; if(tfTicketList!=null) {
return tfTicketList;
}
//获取数据库数据 //获取数据库数据
tfTicketList=super.total(tfTicket); tfTicketList=super.total(tfTicket);
//设置缓存数据 //设置缓存数据
...@@ -72,6 +77,7 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> ...@@ -72,6 +77,7 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket>
return tfTicketList; return tfTicketList;
} }
@Override
public List<TfTicket> findList(TfTicket tfTicket) { public List<TfTicket> findList(TfTicket tfTicket) {
//获取数据库数据 //获取数据库数据
List<TfTicket> tfTicketList=super.findList(tfTicket); List<TfTicket> tfTicketList=super.findList(tfTicket);
...@@ -79,11 +85,14 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> ...@@ -79,11 +85,14 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket>
return tfTicketList; return tfTicketList;
} }
@Override
public List<TfTicket> findListCache(TfTicket tfTicket) { public List<TfTicket> findListCache(TfTicket tfTicket) {
//获取缓存数据 //获取缓存数据
String findListKey = RedisUtils.getFindListKey(TfTicketService.class.getName(),JSON.toJSONString(tfTicket)); String findListKey = RedisUtils.getFindListKey(TfTicketServiceImpl.class.getName(),JSON.toJSONString(tfTicket));
List<TfTicket> tfTicketList=(List<TfTicket>)redisUtils.get(findListKey); List<TfTicket> tfTicketList=(List<TfTicket>)redisUtils.get(findListKey);
if(tfTicketList!=null) return tfTicketList; if(tfTicketList!=null) {
return tfTicketList;
}
//获取数据库数据 //获取数据库数据
tfTicketList=super.findList(tfTicket); tfTicketList=super.findList(tfTicket);
//设置缓存数据 //设置缓存数据
...@@ -94,35 +103,46 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> ...@@ -94,35 +103,46 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket>
public TfTicket findListFirst(TfTicket tfTicket) {; public TfTicket findListFirst(TfTicket tfTicket) {;
//获取数据库数据 //获取数据库数据
List<TfTicket> tfTicketList=super.findList(tfTicket); List<TfTicket> tfTicketList=super.findList(tfTicket);
if(tfTicketList.size()>0) tfTicket=tfTicketList.get(0); if(tfTicketList.size()>0) {
tfTicket = tfTicketList.get(0);
}
return tfTicket; return tfTicket;
} }
public TfTicket findListFirstCache(TfTicket tfTicket) { public TfTicket findListFirstCache(TfTicket tfTicket) {
//获取缓存数据 //获取缓存数据
String findListFirstKey = RedisUtils.getFindListFirstKey(TfTicketService.class.getName(),JSON.toJSONString(tfTicket)); String findListFirstKey = RedisUtils.getFindListFirstKey(TfTicketServiceImpl.class.getName(),JSON.toJSONString(tfTicket));
TfTicket tfTicketRedis=(TfTicket)redisUtils.get(findListFirstKey); TfTicket tfTicketRedis=(TfTicket)redisUtils.get(findListFirstKey);
if(tfTicketRedis!=null) return tfTicketRedis; if(tfTicketRedis!=null) {
return tfTicketRedis;
}
//获取数据库数据 //获取数据库数据
List<TfTicket> tfTicketList=super.findList(tfTicket); List<TfTicket> tfTicketList=super.findList(tfTicket);
if(tfTicketList.size()>0) tfTicket=tfTicketList.get(0); if(tfTicketList.size()>0) {
else tfTicket=new TfTicket(); tfTicket = tfTicketList.get(0);
} else {
tfTicket = new TfTicket();
}
//设置缓存数据 //设置缓存数据
redisUtils.set(findListFirstKey,tfTicket); redisUtils.set(findListFirstKey,tfTicket);
return tfTicket; return tfTicket;
} }
@Override
public Page<TfTicket> findPage(Page<TfTicket> page, TfTicket tfTicket) { public Page<TfTicket> findPage(Page<TfTicket> page, TfTicket tfTicket) {
//获取数据库数据 //获取数据库数据
Page<TfTicket> pageReuslt=super.findPage(page, tfTicket); Page<TfTicket> pageReuslt=super.findPage(page, tfTicket);
return pageReuslt; return pageReuslt;
} }
@Override
public Page<TfTicket> findPageCache(Page<TfTicket> page, TfTicket tfTicket) { public Page<TfTicket> findPageCache(Page<TfTicket> page, TfTicket tfTicket) {
//获取缓存数据 //获取缓存数据
String findPageKey = RedisUtils.getFindPageKey(TfTicketService.class.getName(),JSON.toJSONString(page)+JSON.toJSONString(tfTicket)); String findPageKey = RedisUtils.getFindPageKey(TfTicketServiceImpl.class.getName(),JSON.toJSONString(page)+JSON.toJSONString(tfTicket));
Page<TfTicket> pageReuslt=(Page<TfTicket>)redisUtils.get(findPageKey); Page<TfTicket> pageReuslt=(Page<TfTicket>)redisUtils.get(findPageKey);
if(pageReuslt!=null) return pageReuslt; if(pageReuslt!=null) {
return pageReuslt;
}
//获取数据库数据 //获取数据库数据
pageReuslt=super.findPage(page, tfTicket); pageReuslt=super.findPage(page, tfTicket);
//设置缓存数据 //设置缓存数据
...@@ -130,37 +150,40 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket> ...@@ -130,37 +150,40 @@ public class TfTicketService extends AbstractBaseService<TfTicketDao, TfTicket>
return pageReuslt; return pageReuslt;
} }
@Override
@Transactional(readOnly = false) @Transactional(readOnly = false)
public void save(TfTicket tfTicket) { public void save(TfTicket tfTicket) {
//保存数据库记录 //保存数据库记录
super.save(tfTicket); super.save(tfTicket);
//设置清除缓存数据 //设置清除缓存数据
redisUtils.remove(RedisUtils.getIdKey(TfTicketService.class.getName(),tfTicket.getId())); redisUtils.remove(RedisUtils.getIdKey(TfTicketServiceImpl.class.getName(),tfTicket.getId()));
//清除列表和页面缓存数据 //清除列表和页面缓存数据
redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketServiceImpl.class.getName()));
redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketServiceImpl.class.getName()));
} }
@Override
@Transactional(readOnly = false) @Transactional(readOnly = false)
public void delete(TfTicket tfTicket) { public void delete(TfTicket tfTicket) {
//清除记录缓存数据 //清除记录缓存数据
redisUtils.remove(RedisUtils.getIdKey(TfTicketService.class.getName(),tfTicket.getId())); redisUtils.remove(RedisUtils.getIdKey(TfTicketServiceImpl.class.getName(),tfTicket.getId()));
//删除数据库记录 //删除数据库记录
super.delete(tfTicket); super.delete(tfTicket);
//清除列表和页面缓存数据 //清除列表和页面缓存数据
redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketServiceImpl.class.getName()));
redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketServiceImpl.class.getName()));
} }
@Override
@Transactional(readOnly = false) @Transactional(readOnly = false)
public void deleteByLogic(TfTicket tfTicket) { public void deleteByLogic(TfTicket tfTicket) {
//清除记录缓存数据 //清除记录缓存数据
redisUtils.remove(RedisUtils.getIdKey(TfTicketService.class.getName(),tfTicket.getId())); redisUtils.remove(RedisUtils.getIdKey(TfTicketServiceImpl.class.getName(),tfTicket.getId()));
//逻辑删除数据库记录 //逻辑删除数据库记录
super.deleteByLogic(tfTicket); super.deleteByLogic(tfTicket);
//清除列表和页面缓存数据 //清除列表和页面缓存数据
redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFindListKeyPattern(TfTicketServiceImpl.class.getName()));
redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketService.class.getName())); redisUtils.removePattern(RedisUtils.getFinPageKeyPattern(TfTicketServiceImpl.class.getName()));
} }
} }
\ No newline at end of file
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment