Browse Source

修改巡查锁机制

master
jianjun 3 years ago
parent
commit
8f0ea3e73c
  1. 2
      epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataPatrolChangeEventListener.java

2
epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/mq/listener/OpenDataPatrolChangeEventListener.java

@ -83,7 +83,7 @@ public class OpenDataPatrolChangeEventListener implements MessageListenerConcurr
} }
RLock lock = null; RLock lock = null;
try { try {
lock = distributedLock.getLock(String.format("lock:open_data_patrol:%s", msgObj.getPatrolId()), lock = distributedLock.getLock(String.format("lock:open_data_patrol:%s:%s",tags, msgObj.getObjectId()),
30L, 30L, TimeUnit.SECONDS); 30L, 30L, TimeUnit.SECONDS);
UpsertPatrolRecordForm patrolRecordForm = new UpsertPatrolRecordForm(); UpsertPatrolRecordForm patrolRecordForm = new UpsertPatrolRecordForm();
patrolRecordForm.setCustomerId(msgObj.getCustomerId()); patrolRecordForm.setCustomerId(msgObj.getCustomerId());

Loading…
Cancel
Save