Browse Source

为了提升导入居民效率,去掉分布式锁,限制修改小区的那个

dev
wangxianzhang 3 years ago
parent
commit
feb02f4b2f
  1. 10
      epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java

10
epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java

@ -718,7 +718,8 @@ public class IcResiUserController implements ResultDataResolver {
boolean isAllSuccess = false; boolean isAllSuccess = false;
RLock lock = null; RLock lock = null;
try { try {
lock = distributedLock.getLock(RedisKeys.getXiaoquEditLock(customerId), 120L, 3L, TimeUnit.SECONDS); // todo 导入数据,临时去掉
//lock = distributedLock.getLock(RedisKeys.getXiaoquEditLock(customerId), 120L, 3L, TimeUnit.SECONDS);
List<FormItemResult> formItemList = icResiUserService.listFormItems(customerId, IcFormCodeEnum.RESI_BASE_INFO.getCode()); List<FormItemResult> formItemList = icResiUserService.listFormItems(customerId, IcFormCodeEnum.RESI_BASE_INFO.getCode());
isAllSuccess = icResiUserImportService.importIcResiInfoFromExcel(importTaskId, formItemList, importTempFileSavePath.toString(), response, IC_RESI_UPLOAD_DIR); isAllSuccess = icResiUserImportService.importIcResiInfoFromExcel(importTaskId, formItemList, importTempFileSavePath.toString(), response, IC_RESI_UPLOAD_DIR);
} catch (Throwable e) { } catch (Throwable e) {
@ -759,9 +760,10 @@ public class IcResiUserController implements ResultDataResolver {
epmetMessageOpenFeignClient.sendSystemMsgByMQ(form); epmetMessageOpenFeignClient.sendSystemMsgByMQ(form);
//解锁 //解锁
if (lock != null) { // todo 导入数据临时去掉
lock.unlock(); //if (lock != null) {
} // lock.unlock();
//}
} }
}); });

Loading…
Cancel
Save