记得上下班打卡 | git大法好,push需谨慎

Commit 1c01b7c3 authored by GaoHu's avatar GaoHu

exit

parent fa8d17f2
...@@ -16,7 +16,6 @@ import com.liquidnet.service.smile.entity.SmileUser; ...@@ -16,7 +16,6 @@ import com.liquidnet.service.smile.entity.SmileUser;
import com.liquidnet.service.smile.mapper.SmileSchoolMapper; import com.liquidnet.service.smile.mapper.SmileSchoolMapper;
import com.liquidnet.service.smile.mapper.SmileUserMapper; import com.liquidnet.service.smile.mapper.SmileUserMapper;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Criteria;
...@@ -56,7 +55,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -56,7 +55,7 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
public PageInfo<SmileSchool> schoolList(SmileSchoolParam smileSchoolParam) { public PageInfo<SmileSchool> schoolList(SmileSchoolParam smileSchoolParam) {
PageInfo<SmileSchool> pageInfo; PageInfo<SmileSchool> pageInfo;
try { try {
Map<String,Object> map = BeanUtil.convertBeanToMap(smileSchoolParam); Map<String, Object> map = BeanUtil.convertBeanToMap(smileSchoolParam);
List<SmileSchool> smileSchools = smileSchoolMapper.selectSchoolList(map); List<SmileSchool> smileSchools = smileSchoolMapper.selectSchoolList(map);
pageInfo = new PageInfo<>(smileSchools); pageInfo = new PageInfo<>(smileSchools);
} catch (Exception e) { } catch (Exception e) {
...@@ -76,16 +75,16 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -76,16 +75,16 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
log.debug("smileSchool:{}", smileSchool); log.debug("smileSchool:{}", smileSchool);
LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class); LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class);
queryWrapper.eq(SmileSchool::getName, smileSchool.getName()); queryWrapper.eq(SmileSchool::getName, smileSchool.getName());
queryWrapper.eq(SmileSchool::getDelTag,0); queryWrapper.eq(SmileSchool::getDelTag, 0);
if (smileSchoolMapper.selectOne(queryWrapper) == null) { if (smileSchoolMapper.selectOne(queryWrapper) == null) {
smileSchoolMapper.insert(smileSchool); smileSchoolMapper.insert(smileSchool);
//保存学校 //保存学校
smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()),smileSchool.getName()); smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()), smileSchool.getName());
SmileSchoolVo smileSchoolVo = new SmileSchoolVo().copy(smileSchool); SmileSchoolVo smileSchoolVo = new SmileSchoolVo().copy(smileSchool);
mongoTemplate.insert(smileSchoolVo, SmileSchoolVo.class.getSimpleName()); mongoTemplate.insert(smileSchoolVo, SmileSchoolVo.class.getSimpleName());
//判断是否需要新增redis //判断是否需要新增redis
List<SmileSchoolVo> schoolAll = smileRedisUtils.getSchoolAll(); List<SmileSchoolVo> schoolAll = smileRedisUtils.getSchoolAll();
if (schoolAll != null && schoolAll.size()<20){ if (schoolAll != null && schoolAll.size() < 20) {
updateSchoolRedis(); updateSchoolRedis();
} }
return AjaxResult.success(); return AjaxResult.success();
...@@ -97,15 +96,15 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -97,15 +96,15 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
public AjaxResult updateSchoolById(SmileSchool smileSchool) { public AjaxResult updateSchoolById(SmileSchool smileSchool) {
LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class); LambdaQueryWrapper<SmileSchool> queryWrapper = Wrappers.lambdaQuery(SmileSchool.class);
queryWrapper.eq(SmileSchool::getId, smileSchool.getId()); queryWrapper.eq(SmileSchool::getId, smileSchool.getId());
queryWrapper.eq(SmileSchool::getDelTag,0); queryWrapper.eq(SmileSchool::getDelTag, 0);
if (smileSchoolMapper.update(smileSchool, queryWrapper) > 0) { if (smileSchoolMapper.update(smileSchool, queryWrapper) > 0) {
//更新User表 根据学校id修改用户学校名称 //更新User表 根据学校id修改用户学校名称
smileUserMapper.updateUserSchoolBySchoolId(smileSchool.getId().toString(), smileSchool.getName()); smileUserMapper.updateUserSchoolBySchoolId(smileSchool.getId().toString(), smileSchool.getName());
smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()),smileSchool.getName()); smileRedisUtils.setSchool(String.valueOf(smileSchool.getId()), smileSchool.getName());
//修改数据 //修改数据
Query query = new Query(Criteria.where("id").is(smileSchool.getId())); Query query = new Query(Criteria.where("id").is(smileSchool.getId()));
Update name = Update.update("name", smileSchool.getName()); Update name = Update.update("name", smileSchool.getName());
mongoTemplate.updateFirst(query,name,SmileSchoolVo.class,SmileSchoolVo.class.getSimpleName()); mongoTemplate.updateFirst(query, name, SmileSchoolVo.class, SmileSchoolVo.class.getSimpleName());
//更新redis //更新redis
updateSchoolRedis(); updateSchoolRedis();
return AjaxResult.success(); return AjaxResult.success();
...@@ -117,17 +116,17 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -117,17 +116,17 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
public AjaxResult del(Long id) { public AjaxResult del(Long id) {
//查询是否有用户使用过该学校 //查询是否有用户使用过该学校
LambdaQueryWrapper<SmileUser> queryWrapper = Wrappers.lambdaQuery(SmileUser.class); LambdaQueryWrapper<SmileUser> queryWrapper = Wrappers.lambdaQuery(SmileUser.class);
queryWrapper.eq(SmileUser::getSchoolId,id); queryWrapper.eq(SmileUser::getSchoolId, id);
queryWrapper.eq(SmileUser::getDelTag,0); queryWrapper.eq(SmileUser::getDelTag, 0);
List<SmileUser> smileUsers = smileUserMapper.selectList(queryWrapper); List<SmileUser> smileUsers = smileUserMapper.selectList(queryWrapper);
if (smileUsers.size() > 0){ if (smileUsers.size() > 0) {
return AjaxResult.warn("该学校已被使用,不可删除"); return AjaxResult.warn("该学校已被使用,不可删除");
} }
//学校没有被使用 可以删除 //学校没有被使用 可以删除
smileSchoolMapper.updateDel(id); smileSchoolMapper.updateDel(id);
//mongodb删除 //mongodb删除
Query query = new Query(Criteria.where("id").is(id)); Query query = new Query(Criteria.where("id").is(id));
mongoTemplate.remove(query,SmileSchoolVo.class,SmileSchoolVo.class.getSimpleName()); mongoTemplate.remove(query, SmileSchoolVo.class, SmileSchoolVo.class.getSimpleName());
smileRedisUtils.delSchool(String.valueOf(id)); smileRedisUtils.delSchool(String.valueOf(id));
updateSchoolRedis(); updateSchoolRedis();
return AjaxResult.success(); return AjaxResult.success();
...@@ -137,13 +136,8 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile ...@@ -137,13 +136,8 @@ public class SmileSchoolServiceImpl extends ServiceImpl<SmileSchoolMapper, Smile
private void updateSchoolRedis() { private void updateSchoolRedis() {
List<SmileSchoolVo> smileSchoolVos = new ArrayList<>(); List<SmileSchoolVo> smileSchoolVos = new ArrayList<>();
smileSchoolMapper.selectListLimit().forEach(smileSchool -> { smileSchoolMapper.selectListLimit().forEach(smileSchool -> {
SmileSchoolVo smileSchoolVo = new SmileSchoolVo(); SmileSchoolVo smileSchoolVo = new SmileSchoolVo().copy(smileSchool);
try { smileSchoolVos.add(smileSchoolVo);
smileSchoolVo = smileSchoolVo.copy(smileSchool);
smileSchoolVos.add(smileSchoolVo);
}catch (Exception e) {
log.error("学校集合redis保存updateSchoolRedis()失败:{}",e);
}
}); });
smileRedisUtils.setSchoolAll(smileSchoolVos); smileRedisUtils.setSchoolAll(smileSchoolVos);
} }
......
Markdown is supported
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