This commit is contained in:
LiJianZhao 2025-05-13 10:59:00 +08:00
parent d7a65f186e
commit 97ee2a0955
6 changed files with 44 additions and 7 deletions

View File

@ -81,6 +81,8 @@
</dependency>
<!-- 其他依赖 -->
<dependency>
<groupId>org.projectlombok</groupId>

View File

@ -1,5 +1,6 @@
package com.syjiaer.clinic.server.common.api.output;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.syjiaer.clinic.server.common.api.annotations.OMField;
import lombok.Getter;
import lombok.Setter;
@ -40,6 +41,7 @@ public class OM1101 extends BaseOutputModel{
@OMField(key="naty",name = "民族")
private String naty;
@OMField(key="brdy",name = "出生日期")
@JsonFormat(pattern = "yyyy-MM-dd")
private LocalDate brdy;
@OMField(key="age",name = "年龄")
private BigDecimal age;

View File

@ -16,7 +16,6 @@ public class RedisConfig {
RedisTemplate<String, Object> template = new RedisTemplate<>();
template.setConnectionFactory(connectionFactory);
template.setKeySerializer(new StringRedisSerializer());
template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
return template;
}

View File

@ -1,5 +1,7 @@
package com.syjiaer.clinic.server.common.util;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
@ -11,12 +13,21 @@ public class CacheUtil {
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public void save(String key, Object value,Integer seconds) {
redisTemplate.opsForValue().set(key, value,seconds, TimeUnit.SECONDS);
public void set(String key, Object value, Integer seconds) {
String s = JSONObject.toJSONString(value);
redisTemplate.opsForValue().set(key, s, seconds, TimeUnit.SECONDS);
}
public Object get(String key) {
return redisTemplate.opsForValue().get(key);
public <T> T get(String key, Class<T> clazz) {
Object object = redisTemplate.opsForValue().get(key);
T t = JSON.parseObject((String) object, clazz);
return t;
}
public JSONObject get(String key) {
return JSONObject.parseObject(JSON.toJSONString(redisTemplate.opsForValue().get(key)));
}
public void delete(String key) {

View File

@ -26,4 +26,13 @@ public class SocialPersonController extends BaseController {
return success(socialUserService.getSocialInfo(im1101));
}
@RequestMapping("getSocialInfoByPsnNo")
public Result<SocialPersonInfoVo> getSocialInfoByPsnNo() {
String psnNo = parmsUtil.getString("psnNo");
if (psnNo == null) {
return error("没有带数据");
}
return success(socialUserService.getSocialInfoFromCache(psnNo));
}
}

View File

@ -3,12 +3,12 @@ package com.syjiaer.clinic.server.service.social;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.syjiaer.clinic.server.common.api.input.*;
import com.syjiaer.clinic.server.common.api.output.OM1101;
import com.syjiaer.clinic.server.common.api.output.OM2001;
import com.syjiaer.clinic.server.common.api.output.OM5267;
import com.syjiaer.clinic.server.common.api.output.OM5283;
import com.syjiaer.clinic.server.common.api.request.SocialRequest;
import com.syjiaer.clinic.server.common.config.Config;
import com.syjiaer.clinic.server.common.exception.MessageException;
import com.syjiaer.clinic.server.common.util.CacheUtil;
import com.syjiaer.clinic.server.entity.social.SocialUser;
import com.syjiaer.clinic.server.entity.social.vo.SocialPersonInfoVo;
import com.syjiaer.clinic.server.mapper.social.SocialUserMapper;
@ -19,7 +19,6 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDate;
import java.time.LocalDateTime;
/*
* 医保用户
@ -33,6 +32,8 @@ public class SocialUserService {
private SocialUserMapper socialUserMapper;
@Autowired
private Config config;
@Autowired
private CacheUtil cacheUtil;
/*
* 获取医保信息
@ -77,7 +78,20 @@ public class SocialUserService {
socialPersonInfoVo.setBlockInfo(om5267);
socialPersonInfoVo.setHospitalizationInfo(om5283);
//缓存入redis
String key = "social_user_info:" + socialPersonInfoVo.getBaseinfo().getPsn_no();
cacheUtil.set(key, socialPersonInfoVo, 60 * 10);
return socialPersonInfoVo;
}
/**
* 读redis的信息
* @param psnNo
* @return
*/
public SocialPersonInfoVo getSocialInfoFromCache(String psnNo) {
String key = "social_user_info:" + psnNo;
return cacheUtil.get(key, SocialPersonInfoVo.class);
}
}