feat: 阿拉丁签约接口

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

@@ -70,11 +70,11 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 
     @RabbitHandler
     public void onMessage(String jsonStr, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
-        super.onMessage(jsonStr, deliveryTag, channel, (MqListener<String>) (String result, Channel channel1) -> {
+        super.onMessageAck(jsonStr, deliveryTag, channel, (MqListener<String>) (String result, Channel channel1) -> {
 
 			log.info("直接队列：接收用户签约认证的结果，手动ACK，接收消息TAG:{},消息内容：{}", deliveryTag, result);
 
-//			Map<String, String> resMap = MapUtil.newHashMap(2);
+			Map<String, String> resMap = MapUtil.newHashMap(2);
 
 			JSONObject jsonResult = JSONUtil.parseObj(result);
 			String username = jsonResult.getStr("username");
@@ -83,7 +83,9 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 
 			if (StrUtil.isBlank(username) || StrUtil.isBlank(entpriseCode) || subjectTypes.isEmpty()) {
 				log.error("必传参数空！");
-				return null;
+				resMap.put("key", String.format("%s_%s_%s", CacheConstants.USER_SIGN_CERT_RESPONSE_MQ_KEY, username, entpriseCode));
+				resMap.put("res", JSONUtil.toJsonStr(subjectTypes));
+				return resMap;
 			}
 				// 加redis锁 TODO
 //				redisTemplate.opsForValue().setIfAbsent()
@@ -131,10 +133,10 @@ public class GigSignCertReceiver extends BaseRabbiMqHandler<String> {
 						JSONUtil.toJsonStr(subjectTypes), 1, TimeUnit.MINUTES);
 			}
 
-//				resMap.put("key", String.format("%s_%s_%s", CacheConstants.USER_SIGN_CERT_RESPONSE_MQ_KEY, username, entpriseCode));
-//				resMap.put("res", JSONUtil.toJsonStr(subjectTypes));
+			resMap.put("key", String.format("%s_%s_%s", CacheConstants.USER_SIGN_CERT_RESPONSE_MQ_KEY, username, entpriseCode));
+			resMap.put("res", JSONUtil.toJsonStr(subjectTypes));
 
-			return null;
+			return resMap;
         });
     }