update 优化代码

dev
疯狂的狮子Li 1 year ago
parent 91a36299ac
commit c506997810

@ -15,17 +15,6 @@ import java.util.concurrent.*;
@NoArgsConstructor(access = AccessLevel.PRIVATE) @NoArgsConstructor(access = AccessLevel.PRIVATE)
public class Threads { public class Threads {
/**
* sleep,
*/
public static void sleep(long milliseconds) {
try {
Thread.sleep(milliseconds);
} catch (InterruptedException e) {
return;
}
}
/** /**
* 线 * 线
* 使shutdown, . * 使shutdown, .

@ -43,7 +43,13 @@ public class MailProperties {
private String pass; private String pass;
/** /**
* RFC-822 * RFC-822<br>
*
*
* <pre>
* 1. user@xxx.xx
* 2. name &lt;user@xxx.xx&gt;
* </pre>
*/ */
private String from; private String from;

@ -1,5 +1,6 @@
package org.dromara.demo.controller; package org.dromara.demo.controller;
import cn.hutool.core.thread.ThreadUtil;
import org.dromara.common.core.constant.CacheNames; import org.dromara.common.core.constant.CacheNames;
import org.dromara.common.core.domain.R; import org.dromara.common.core.domain.R;
import org.dromara.common.redis.utils.RedisUtils; import org.dromara.common.redis.utils.RedisUtils;
@ -83,11 +84,7 @@ public class RedisCacheController {
RedisUtils.setCacheObject(key, value); RedisUtils.setCacheObject(key, value);
boolean flag = RedisUtils.expire(key, Duration.ofSeconds(10)); boolean flag = RedisUtils.expire(key, Duration.ofSeconds(10));
System.out.println("***********" + flag); System.out.println("***********" + flag);
try { ThreadUtil.sleep(11 * 1000);
Thread.sleep(11 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
Object obj = RedisUtils.getCacheObject(key); Object obj = RedisUtils.getCacheObject(key);
return R.ok(value.equals(obj)); return R.ok(value.equals(obj));
} }

@ -1,5 +1,6 @@
package org.dromara.demo.controller; package org.dromara.demo.controller;
import cn.hutool.core.thread.ThreadUtil;
import com.baomidou.lock.LockInfo; import com.baomidou.lock.LockInfo;
import com.baomidou.lock.LockTemplate; import com.baomidou.lock.LockTemplate;
import com.baomidou.lock.annotation.Lock4j; import com.baomidou.lock.annotation.Lock4j;
@ -34,11 +35,7 @@ public class RedisLockController {
@GetMapping("/testLock4j") @GetMapping("/testLock4j")
public R<String> testLock4j(String key, String value) { public R<String> testLock4j(String key, String value) {
System.out.println("start:" + key + ",time:" + LocalTime.now()); System.out.println("start:" + key + ",time:" + LocalTime.now());
try { ThreadUtil.sleep(10000);
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("end :" + key + ",time:" + LocalTime.now()); System.out.println("end :" + key + ",time:" + LocalTime.now());
return R.ok("操作成功", value); return R.ok("操作成功", value);
} }
@ -54,11 +51,7 @@ public class RedisLockController {
} }
// 获取锁成功,处理业务 // 获取锁成功,处理业务
try { try {
try { ThreadUtil.sleep(8000);
Thread.sleep(8000);
} catch (InterruptedException e) {
//
}
System.out.println("执行简单方法1 , 当前线程:" + Thread.currentThread().getName()); System.out.println("执行简单方法1 , 当前线程:" + Thread.currentThread().getName());
} finally { } finally {
//释放锁 //释放锁

@ -97,7 +97,7 @@ public class SysClientController extends BaseController {
@Log(title = "客户端管理", businessType = BusinessType.UPDATE) @Log(title = "客户端管理", businessType = BusinessType.UPDATE)
@PutMapping("/changeStatus") @PutMapping("/changeStatus")
public R<Void> changeStatus(@RequestBody SysClientBo bo) { public R<Void> changeStatus(@RequestBody SysClientBo bo) {
return toAjax(sysClientService.updateUserStatus(bo.getClientId(), bo.getStatus())); return toAjax(sysClientService.updateClientStatus(bo.getClientId(), bo.getStatus()));
} }
/** /**

@ -219,7 +219,7 @@ public class SysUserController extends BaseController {
@GetMapping("/optionselect") @GetMapping("/optionselect")
public R<List<SysUserVo>> optionselect(@RequestParam(required = false) Long[] userIds, public R<List<SysUserVo>> optionselect(@RequestParam(required = false) Long[] userIds,
@RequestParam(required = false) Long deptId) { @RequestParam(required = false) Long deptId) {
return R.ok(userService.selectUserByIds(userIds == null ? null : List.of(userIds), deptId)); return R.ok(userService.selectUserByIds(ArrayUtil.isEmpty(userIds) ? null : List.of(userIds), deptId));
} }
/** /**

@ -48,7 +48,7 @@ public interface ISysClientService {
/** /**
* *
*/ */
int updateUserStatus(String clientId, String status); int updateClientStatus(String clientId, String status);
/** /**
* *

@ -122,7 +122,7 @@ public class SysClientServiceImpl implements ISysClientService {
*/ */
@CacheEvict(cacheNames = CacheNames.SYS_CLIENT, key = "#clientId") @CacheEvict(cacheNames = CacheNames.SYS_CLIENT, key = "#clientId")
@Override @Override
public int updateUserStatus(String clientId, String status) { public int updateClientStatus(String clientId, String status) {
return baseMapper.update(null, return baseMapper.update(null,
new LambdaUpdateWrapper<SysClient>() new LambdaUpdateWrapper<SysClient>()
.set(SysClient::getStatus, status) .set(SysClient::getStatus, status)

@ -109,7 +109,7 @@ public class SysDeptServiceImpl implements ISysDeptService {
.setName(dept.getDeptName()) .setName(dept.getDeptName())
.setWeight(dept.getOrderNum()) .setWeight(dept.getOrderNum())
.putExtra("disabled", SystemConstants.DISABLE.equals(dept.getStatus()))); .putExtra("disabled", SystemConstants.DISABLE.equals(dept.getStatus())));
Tree<Long> tree = trees.stream().filter(it -> it.getId().longValue() == d.getDeptId()).findFirst().get(); Tree<Long> tree = StreamUtils.findFirst(trees, it -> it.getId().longValue() == d.getDeptId());
treeList.add(tree); treeList.add(tree);
} }
} }

@ -42,8 +42,7 @@ public class SysLogininforServiceImpl implements ISysLogininforService {
.between(params.get("beginTime") != null && params.get("endTime") != null, .between(params.get("beginTime") != null && params.get("endTime") != null,
SysLogininfor::getLoginTime, params.get("beginTime"), params.get("endTime")); SysLogininfor::getLoginTime, params.get("beginTime"), params.get("endTime"));
if (StringUtils.isBlank(pageQuery.getOrderByColumn())) { if (StringUtils.isBlank(pageQuery.getOrderByColumn())) {
pageQuery.setOrderByColumn("info_id"); lqw.orderByDesc(SysLogininfor::getInfoId);
pageQuery.setIsAsc("desc");
} }
Page<SysLogininforVo> page = baseMapper.selectVoPage(pageQuery.build(), lqw); Page<SysLogininforVo> page = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(page); return TableDataInfo.build(page);

@ -36,8 +36,7 @@ public class SysOperLogServiceImpl implements ISysOperLogService {
public TableDataInfo<SysOperLogVo> selectPageOperLogList(SysOperLogBo operLog, PageQuery pageQuery) { public TableDataInfo<SysOperLogVo> selectPageOperLogList(SysOperLogBo operLog, PageQuery pageQuery) {
LambdaQueryWrapper<SysOperLog> lqw = buildQueryWrapper(operLog); LambdaQueryWrapper<SysOperLog> lqw = buildQueryWrapper(operLog);
if (StringUtils.isBlank(pageQuery.getOrderByColumn())) { if (StringUtils.isBlank(pageQuery.getOrderByColumn())) {
pageQuery.setOrderByColumn("oper_id"); lqw.orderByDesc(SysOperLog::getOperId);
pageQuery.setIsAsc("desc");
} }
Page<SysOperLogVo> page = baseMapper.selectVoPage(pageQuery.build(), lqw); Page<SysOperLogVo> page = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(page); return TableDataInfo.build(page);

Loading…
Cancel
Save