|
@ -3,7 +3,6 @@ package com.epmet.opendata.mq.listener; |
|
|
import com.alibaba.fastjson.JSON; |
|
|
import com.alibaba.fastjson.JSON; |
|
|
import com.epmet.commons.rocketmq.constants.MQUserPropertys; |
|
|
import com.epmet.commons.rocketmq.constants.MQUserPropertys; |
|
|
import com.epmet.commons.rocketmq.messages.DisputeProcessMQMsg; |
|
|
import com.epmet.commons.rocketmq.messages.DisputeProcessMQMsg; |
|
|
import com.epmet.commons.tools.constant.StrConstant; |
|
|
|
|
|
import com.epmet.commons.tools.distributedlock.DistributedLock; |
|
|
import com.epmet.commons.tools.distributedlock.DistributedLock; |
|
|
import com.epmet.commons.tools.exception.ExceptionUtils; |
|
|
import com.epmet.commons.tools.exception.ExceptionUtils; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
@ -73,10 +72,6 @@ public class OpenDataProjectChangeEventListener implements MessageListenerConcur |
|
|
|
|
|
|
|
|
logger.info("【开放数据事件监听器】-项目信息变更-收到消息内容:{}, 操作:{}, pendingMsgLabel:{}", msg, tags, pendingMsgLabel); |
|
|
logger.info("【开放数据事件监听器】-项目信息变更-收到消息内容:{}, 操作:{}, pendingMsgLabel:{}", msg, tags, pendingMsgLabel); |
|
|
DisputeProcessMQMsg obj = JSON.parseObject(msg, DisputeProcessMQMsg.class); |
|
|
DisputeProcessMQMsg obj = JSON.parseObject(msg, DisputeProcessMQMsg.class); |
|
|
//只推送平阴数据
|
|
|
|
|
|
if (!StrConstant.PY_CUSTOMER.equals(obj.getCustomerId())) { |
|
|
|
|
|
return; |
|
|
|
|
|
} |
|
|
|
|
|
EventInfoFormDTO formDTO = ConvertUtils.sourceToTarget(obj, EventInfoFormDTO.class); |
|
|
EventInfoFormDTO formDTO = ConvertUtils.sourceToTarget(obj, EventInfoFormDTO.class); |
|
|
|
|
|
|
|
|
RLock lock = null; |
|
|
RLock lock = null; |
|
|