feat: 回调认证状态记录

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/mq/GigSignCertReceiver.java

@@ -284,9 +284,9 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 		}
 		if (CollUtil.isNotEmpty(resultMap)) {
 			String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + user.getUserId();
-			if (redisTemplate.hasKey(key)) {
-				// key已存在，则追加写入新的渠道的状态
-				String qResult = (String) redisTemplate.opsForValue().get(key);
+			// key已存在，则追加写入新的渠道的状态
+			String qResult = (String) redisTemplate.opsForValue().get(key);
+			if (JSONUtil.isJsonObj(qResult)) {
 				JSONObject qResultObj = JSONUtil.parseObj(qResult);
 				if (o1Map != null) {
 					qResultObj.append(GigTypeEnum.OLADING.name(), o1Map);

hnqz-upms/hnqz-upms-biz/src/main/java/com/qunzhixinxi/hnqz/admin/service/gig/impl/GigThirdApiServiceImpl.java

@@ -278,8 +278,8 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
-		if (redisTemplate.hasKey(key)) {
-			String qResult = (String) redisTemplate.opsForValue().get(key);
+		String qResult = (String) redisTemplate.opsForValue().get(key);
+		if (JSONUtil.isJsonObj(qResult)) {
 			JSONObject qResultObj = JSONUtil.parseObj(qResult);
 			qResultObj.append(userSub.getGigType().name(), MapUtil.builder("certStatus", currentCertStatus.name()).build());
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(qResultObj), 1, TimeUnit.MINUTES);
@@ -362,8 +362,8 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
-		if (redisTemplate.hasKey(key)) {
-			String qResult = (String) redisTemplate.opsForValue().get(key);
+		String qResult = (String) redisTemplate.opsForValue().get(key);
+		if (JSONUtil.isJsonObj(qResult)) {
 			JSONObject qResultObj = JSONUtil.parseObj(qResult);
 			qResultObj.append(userSub.getGigType().name(), MapUtil.builder("certStatus", currentCertStatus.name()).build());
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(qResultObj), 1, TimeUnit.MINUTES);
@@ -444,8 +444,8 @@ public class GigThirdApiServiceImpl implements GigThirdApiService {
 
 		// 结果放到redis
 		String key = CacheConstants.USER_SIGN_CERT_RESPONSE_KEY + userSub.getUserId();
-		if (redisTemplate.hasKey(key)) {
-			String qResult = (String) redisTemplate.opsForValue().get(key);
+		String qResult = (String) redisTemplate.opsForValue().get(key);
+		if (JSONUtil.isJsonObj(qResult)) {
 			JSONObject qResultObj = JSONUtil.parseObj(qResult);
 			qResultObj.append(userSub.getGigType().name(), MapUtil.builder("certStatus", currentCertStatus.name()).build());
 			redisTemplate.opsForValue().set(key, JSONUtil.toJsonStr(qResultObj), 1, TimeUnit.MINUTES);