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

Commit 7e8fedd6 authored by 张国柄's avatar 张国柄

~api:藏品转赠结果查询队列及处理;

parent 639305d7
package com.liquidnet.service.consumer.base.receiver; package com.liquidnet.service.consumer.base.receiver;
import com.fasterxml.jackson.databind.JsonNode;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.HttpUtil; import com.liquidnet.commons.lang.util.HttpUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
......
...@@ -58,12 +58,12 @@ public class ConsumerGoblinBizArtworkTransQueryReceiver extends AbstractBizRedis ...@@ -58,12 +58,12 @@ public class ConsumerGoblinBizArtworkTransQueryReceiver extends AbstractBizRedis
@Override @Override
protected String getRedisStreamKey() { protected String getRedisStreamKey() {
return MQConst.GoblinQueue.BIZ_ARTWORK_CLQ.getKey(); return MQConst.GoblinQueue.BIZ_ARTWORK_TRANS_QUERY.getKey();
} }
@Override @Override
protected String getRedisStreamGroup() { protected String getRedisStreamGroup() {
return MQConst.GoblinQueue.BIZ_ARTWORK_CLQ.getGroup(); return MQConst.GoblinQueue.BIZ_ARTWORK_TRANS_QUERY.getGroup();
} }
private boolean bizArtworkTransQueryProcessing(String transferOrderId) { private boolean bizArtworkTransQueryProcessing(String transferOrderId) {
......
package com.liquidnet.service.consumer.base.receiver; package com.liquidnet.service.consumer.base.receiver;
import com.fasterxml.jackson.databind.JsonNode;
import com.liquidnet.commons.lang.util.CollectionUtil; import com.liquidnet.commons.lang.util.CollectionUtil;
import com.liquidnet.commons.lang.util.HttpUtil; import com.liquidnet.commons.lang.util.HttpUtil;
import com.liquidnet.commons.lang.util.JsonUtils;
import com.liquidnet.service.base.constant.MQConst; import com.liquidnet.service.base.constant.MQConst;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
......
...@@ -347,6 +347,7 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr ...@@ -347,6 +347,7 @@ public class GoblinUserDigitalArtworkServiceImpl implements IGoblinUserDigitalAr
userDigitalArtworkVo.getTransferOrderId(), userDigitalArtworkVo.getTransferState(), nowTime, userDigitalArtworkVo.getArtworkId() userDigitalArtworkVo.getTransferOrderId(), userDigitalArtworkVo.getTransferState(), nowTime, userDigitalArtworkVo.getArtworkId()
}); });
queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(), SqlMapping.gets(toMqSqls, updateUserDigitalArtworkObjs)); queueUtils.sendMsgByRedis(MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey(), SqlMapping.gets(toMqSqls, updateUserDigitalArtworkObjs));
return true;
} }
return false; return false;
} }
......
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