|
|
@@ -2,6 +2,7 @@ package org.dromara.system.service.impl;
|
|
|
|
|
|
import org.apache.dubbo.config.annotation.DubboReference;
|
|
|
import org.apache.seata.spring.annotation.GlobalTransactional;
|
|
|
+import org.dromara.common.core.constant.CacheNames;
|
|
|
import org.dromara.common.core.utils.MapstructUtils;
|
|
|
import org.dromara.common.core.utils.StringUtils;
|
|
|
import org.dromara.common.mybatis.core.page.TableDataInfo;
|
|
|
@@ -12,13 +13,16 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.dromara.common.mybatis.utils.WrapperUtils;
|
|
|
+import org.dromara.common.redis.utils.CacheUtils;
|
|
|
import org.dromara.common.satoken.utils.LoginHelper;
|
|
|
import org.dromara.service.api.RemoteStoreServiceService;
|
|
|
import org.dromara.service.api.domain.bo.RemoteStoreServiceBo;
|
|
|
import org.dromara.system.constants.StoreConstants;
|
|
|
import org.dromara.system.domain.SysAreaStation;
|
|
|
import org.dromara.system.domain.SysUserStore;
|
|
|
+import org.dromara.system.domain.bo.SysStoreBanBo;
|
|
|
import org.dromara.system.domain.bo.SysStorePageBo;
|
|
|
+import org.dromara.system.domain.bo.SysStoreRenewBo;
|
|
|
import org.dromara.system.domain.vo.*;
|
|
|
import org.dromara.system.enums.AreaStationStatusEnum;
|
|
|
import org.dromara.system.enums.SysStoreStatusEnum;
|
|
|
@@ -165,6 +169,8 @@ public class SysStoreServiceImpl implements ISysStoreService {
|
|
|
throw new RuntimeException("批量插入关系失败");
|
|
|
}
|
|
|
|
|
|
+ CacheUtils.put(CacheNames.SYS_STORE_NAME, add.getId(), add.getName());
|
|
|
+
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
@@ -178,6 +184,9 @@ public class SysStoreServiceImpl implements ISysStoreService {
|
|
|
public Boolean updateByBo(SysStoreBo bo) {
|
|
|
SysStore update = MapstructUtils.convert(bo, SysStore.class);
|
|
|
validEntityBeforeSave(update);
|
|
|
+
|
|
|
+ CacheUtils.put(CacheNames.SYS_STORE_NAME, update.getId(), update.getName());
|
|
|
+
|
|
|
return baseMapper.updateById(update) > 0;
|
|
|
}
|
|
|
|
|
|
@@ -200,6 +209,7 @@ public class SysStoreServiceImpl implements ISysStoreService {
|
|
|
if(isValid){
|
|
|
//TODO 做一些业务上的校验,判断是否需要校验
|
|
|
}
|
|
|
+ ids.forEach(id -> CacheUtils.evict(CacheNames.SYS_STORE_NAME, id));
|
|
|
return baseMapper.deleteByIds(ids) > 0;
|
|
|
}
|
|
|
|
|
|
@@ -280,7 +290,27 @@ public class SysStoreServiceImpl implements ISysStoreService {
|
|
|
vo.setSite(e.getSite());
|
|
|
vo.setAreaCode(e.getAreaCode());
|
|
|
vo.setAddress(e.getDetailAddress());
|
|
|
+ vo.setTenantId(e.getTenantId());
|
|
|
return vo;
|
|
|
}));
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean renew(SysStoreRenewBo bo) {
|
|
|
+ return baseMapper.update(
|
|
|
+ Wrappers.lambdaUpdate(SysStore.class)
|
|
|
+ .eq(SysStore::getId, bo.getId())
|
|
|
+ .set(SysStore::getEndBusinessTime, bo.getTo())
|
|
|
+ .set(SysStore::getStatus, SysStoreStatusEnum.IN_OPERATION.getValue())
|
|
|
+ ) > 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public boolean ban(SysStoreBanBo bo) {
|
|
|
+ return baseMapper.update(
|
|
|
+ Wrappers.lambdaUpdate(SysStore.class)
|
|
|
+ .eq(SysStore::getId, bo.getId())
|
|
|
+ .set(SysStore::getStatus, SysStoreStatusEnum.BANNED.getValue())
|
|
|
+ ) > 0;
|
|
|
+ }
|
|
|
}
|