|
|
@@ -0,0 +1,267 @@
|
|
|
+/*
|
|
|
+ * Copyright (c) 2018-2028, Chill Zhuang All rights reserved.
|
|
|
+ *
|
|
|
+ * Redistribution and use in source and binary forms, with or without
|
|
|
+ * modification, are permitted provided that the following conditions are met:
|
|
|
+ *
|
|
|
+ * Redistributions of source code must retain the above copyright notice,
|
|
|
+ * this list of conditions and the following disclaimer.
|
|
|
+ * Redistributions in binary form must reproduce the above copyright
|
|
|
+ * notice, this list of conditions and the following disclaimer in the
|
|
|
+ * documentation and/or other materials provided with the distribution.
|
|
|
+ * Neither the name of the dreamlu.net developer nor the names of its
|
|
|
+ * contributors may be used to endorse or promote products derived from
|
|
|
+ * this software without specific prior written permission.
|
|
|
+ * Author: Chill 庄骞 (smallchill@163.com)
|
|
|
+ */
|
|
|
+package org.springblade.los.lock.controller;
|
|
|
+
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
+import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
|
|
+import io.swagger.annotations.Api;
|
|
|
+import io.swagger.annotations.ApiOperation;
|
|
|
+import io.swagger.annotations.ApiParam;
|
|
|
+import lombok.AllArgsConstructor;
|
|
|
+import org.springblade.core.boot.ctrl.BladeController;
|
|
|
+import org.springblade.core.mp.support.Condition;
|
|
|
+import org.springblade.core.mp.support.Query;
|
|
|
+import org.springblade.core.secure.utils.AuthUtil;
|
|
|
+import org.springblade.core.secure.utils.SecureUtil;
|
|
|
+import org.springblade.core.tool.api.R;
|
|
|
+import org.springblade.core.tool.utils.Func;
|
|
|
+import org.springblade.los.lock.entity.LosLock;
|
|
|
+import org.springblade.los.lock.entity.LosLockConfig;
|
|
|
+import org.springblade.los.lock.service.ILosLockConfigService;
|
|
|
+import org.springblade.los.lock.service.ILosLockService;
|
|
|
+import org.springblade.los.lock.vo.LosLockVO;
|
|
|
+import org.springframework.web.bind.annotation.*;
|
|
|
+
|
|
|
+import javax.validation.Valid;
|
|
|
+import java.text.SimpleDateFormat;
|
|
|
+import java.util.Date;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 控制器
|
|
|
+ *
|
|
|
+ * @author BladeX
|
|
|
+ * @since 2022-01-22
|
|
|
+ */
|
|
|
+@RestController
|
|
|
+@AllArgsConstructor
|
|
|
+@RequestMapping("/losLock")
|
|
|
+@Api(value = "", tags = "接口")
|
|
|
+public class LockController extends BladeController {
|
|
|
+
|
|
|
+ private final ILosLockService lockService;
|
|
|
+
|
|
|
+ private final ILosLockConfigService lockConfigService;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 详情
|
|
|
+ */
|
|
|
+ @GetMapping("/detail")
|
|
|
+ @ApiOperationSupport(order = 1)
|
|
|
+ @ApiOperation(value = "详情", notes = "传入lock")
|
|
|
+ public R<LosLock> detail(LosLock lock) {
|
|
|
+ lock.setTenantId(SecureUtil.getTenantId());
|
|
|
+ LosLock detail = lockService.getOne(Condition.getQueryWrapper(lock));
|
|
|
+ return R.data(detail);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 分页
|
|
|
+ */
|
|
|
+ @GetMapping("/list")
|
|
|
+ @ApiOperationSupport(order = 2)
|
|
|
+ @ApiOperation(value = "分页", notes = "传入lock")
|
|
|
+ public R<IPage<LosLock>> list(LosLock lock, Query query) {
|
|
|
+ lock.setTenantId(SecureUtil.getTenantId());
|
|
|
+ IPage<LosLock> pages = lockService.page(Condition.getPage(query), Condition.getQueryWrapper(lock));
|
|
|
+ return R.data(pages);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 自定义分页
|
|
|
+ */
|
|
|
+ @GetMapping("/page")
|
|
|
+ @ApiOperationSupport(order = 3)
|
|
|
+ @ApiOperation(value = "分页", notes = "传入lock")
|
|
|
+ public R<IPage<LosLockVO>> page(LosLockVO lock, Query query) {
|
|
|
+ lock.setTenantId(SecureUtil.getTenantId());
|
|
|
+ IPage<LosLockVO> pages = lockService.selectLockPage(Condition.getPage(query), lock);
|
|
|
+ return R.data(pages);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增
|
|
|
+ */
|
|
|
+ @PostMapping("/save")
|
|
|
+ @ApiOperationSupport(order = 4)
|
|
|
+ @ApiOperation(value = "新增", notes = "传入lock")
|
|
|
+ public R save(@Valid @RequestBody LosLock lock) {
|
|
|
+ return R.status(lockService.save(lock));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 修改
|
|
|
+ */
|
|
|
+ @PostMapping("/update")
|
|
|
+ @ApiOperationSupport(order = 5)
|
|
|
+ @ApiOperation(value = "修改", notes = "传入lock")
|
|
|
+ public R update(@Valid @RequestBody LosLock lock) {
|
|
|
+ return R.status(lockService.updateById(lock));
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增或修改
|
|
|
+ */
|
|
|
+ @PostMapping("/submit")
|
|
|
+ @ApiOperationSupport(order = 6)
|
|
|
+ @ApiOperation(value = "新增或修改", notes = "传入lock")
|
|
|
+ public R submit(@Valid @RequestBody LosLock lock) {
|
|
|
+ return R.status(lockService.saveOrUpdate(lock));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 删除
|
|
|
+ */
|
|
|
+ @PostMapping("/remove")
|
|
|
+ @ApiOperationSupport(order = 8)
|
|
|
+ @ApiOperation(value = "删除", notes = "传入ids")
|
|
|
+ public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) {
|
|
|
+ return R.status(lockService.removeByIds(Func.toLongList(ids)));
|
|
|
+ }
|
|
|
+
|
|
|
+ //检查当前表单是否可以编辑
|
|
|
+ @GetMapping("checkLock")
|
|
|
+ @ApiOperationSupport(order = 8)
|
|
|
+ @ApiOperation(value = "检查当前表单是否可以编辑", notes = "")
|
|
|
+ public R<?> checkLock(@ApiParam(value = "模块名称", required = true) @RequestParam String moduleName,
|
|
|
+ @ApiParam(value = "数据表名称", required = true) @RequestParam String tableName,
|
|
|
+ @ApiParam(value = "电脑序列号", required = true) @RequestParam String no,
|
|
|
+ @ApiParam(value = "单据id", required = true) @RequestParam Long billId) {
|
|
|
+ //先查看当前租户是在此模块否配置锁,如果没有锁或者没开启,直接返回true
|
|
|
+ LambdaQueryWrapper<LosLockConfig> lockConfigLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lockConfigLambdaQueryWrapper
|
|
|
+ .eq(LosLockConfig::getModuleName, moduleName)
|
|
|
+ .eq(LosLockConfig::getTableName, tableName)
|
|
|
+ .eq(LosLockConfig::getTenantId, AuthUtil.getTenantId());
|
|
|
+ LosLockConfig lockConfig = lockConfigService.getOne(lockConfigLambdaQueryWrapper, false);
|
|
|
+ if (lockConfig == null || lockConfig.getIsEnable() != 1) {
|
|
|
+ return R.success("目前订单可以编辑");
|
|
|
+ }
|
|
|
+ SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
|
|
|
+ //如果存在配置,则查看是否需要已经上锁,如果上锁,且上锁人不是自己,直接返回false。如果是自己直接返回true
|
|
|
+ LambdaQueryWrapper<LosLock> lockLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lockLambdaQueryWrapper
|
|
|
+ .eq(LosLock::getBillId, billId)
|
|
|
+ .eq(LosLock::getMoudleName, moduleName)
|
|
|
+ .eq(LosLock::getTableName, tableName)
|
|
|
+ .eq(LosLock::getTenantId, AuthUtil.getTenantId());
|
|
|
+ LosLock lock = lockService.getOne(lockLambdaQueryWrapper, false);
|
|
|
+ Long userId = AuthUtil.getUserId();
|
|
|
+ //没有锁
|
|
|
+ if (lock == null) {
|
|
|
+ return R.success("目前订单可以编辑");
|
|
|
+ }
|
|
|
+ //有锁 不是自己
|
|
|
+ else if (lock.getUserId().longValue() != userId.longValue()) {
|
|
|
+ return R.fail("账号:" + lock.getRealName() + "于" + simpleDateFormat.format(lock.getLockTime()) + "正在编辑请稍后再试!");
|
|
|
+ }
|
|
|
+ //有锁 是自己 是自己的机器
|
|
|
+ else if (lock.getUserId().longValue() == userId.longValue() && lock.getLockNo().equals(no + AuthUtil.getUserName())) {
|
|
|
+ return R.success("目前订单可以编辑");
|
|
|
+ }
|
|
|
+ //有锁 是自己 不是当前机器
|
|
|
+ else if (lock.getUserId().longValue() == userId.longValue() && !lock.getLockNo().equals(no + AuthUtil.getUserName())) {
|
|
|
+ return R.fail("账号:" + lock.getRealName() + "于" + simpleDateFormat.format(lock.getLockTime()) + "正在编辑请稍后再试!");
|
|
|
+ }
|
|
|
+ //其他情况 视为 不可编辑
|
|
|
+ else {
|
|
|
+ return R.fail("账号:" + lock.getRealName() + "于" + simpleDateFormat.format(lock.getLockTime()) + "正在编辑请稍后再试!");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //上锁
|
|
|
+ @PostMapping("onLock")
|
|
|
+ @ApiOperationSupport(order = 8)
|
|
|
+ @ApiOperation(value = "上锁", notes = "")
|
|
|
+ public R onLock(@ApiParam(value = "模块名称", required = true) @RequestParam String moduleName,
|
|
|
+ @ApiParam(value = "数据表名称", required = true) @RequestParam String tableName,
|
|
|
+ @ApiParam(value = "电脑序列号", required = true) @RequestParam String no,
|
|
|
+ @RequestParam(value = "billNo", required = false) String billNo,
|
|
|
+ @ApiParam(value = "单据id", required = true) @RequestParam Long billId) {
|
|
|
+ //校验防止上锁多次
|
|
|
+ LambdaQueryWrapper<LosLock> lockLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lockLambdaQueryWrapper
|
|
|
+ .eq(LosLock::getBillId, billId)
|
|
|
+ .eq(LosLock::getMoudleName, moduleName)
|
|
|
+ .eq(LosLock::getTableName, tableName)
|
|
|
+ .eq(LosLock::getTenantId, AuthUtil.getTenantId());
|
|
|
+ int count = lockService.count(lockLambdaQueryWrapper);
|
|
|
+ //存在锁,不再新增锁
|
|
|
+ if (count > 0) {
|
|
|
+ LosLock lock = lockService.getOne(lockLambdaQueryWrapper, false);
|
|
|
+ //存在自己的锁
|
|
|
+ if (lock.getUserId().longValue() == AuthUtil.getUserId().longValue()) {
|
|
|
+ //并且是自己的上锁序列号
|
|
|
+ if ((no + AuthUtil.getUserName()).equals(lock.getLockNo())) {
|
|
|
+ return R.success("OK");
|
|
|
+ } else {
|
|
|
+ return R.fail("上锁失败:当前用户在其他设备上已上锁");
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ //存在别人的锁, 直接报错
|
|
|
+ else if (lock.getUserId().longValue() != AuthUtil.getUserId().longValue()) {
|
|
|
+ return R.fail("上锁失败:存在其他用户的锁");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ //不存在锁,新增锁
|
|
|
+ else {
|
|
|
+ LosLock lock = new LosLock();
|
|
|
+ lock.setUserId(AuthUtil.getUserId());
|
|
|
+ lock.setRealName(AuthUtil.getUserName());
|
|
|
+ lock.setLockTime(new Date());
|
|
|
+ lock.setMoudleName(moduleName);
|
|
|
+ lock.setTableName(tableName);
|
|
|
+ lock.setBillId(billId);
|
|
|
+ lock.setBillNo(billNo);
|
|
|
+ //生成16位 code
|
|
|
+ /*int code = (no + AuthUtil.getUserName()).hashCode();*/
|
|
|
+ lock.setLockNo(no + AuthUtil.getUserName());
|
|
|
+ lock.setCreateTime(new Date());
|
|
|
+ lock.setCreateUser(AuthUtil.getUserId());
|
|
|
+ lockService.save(lock);
|
|
|
+ return R.success("OK");
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ //释放锁
|
|
|
+ @DeleteMapping("unLock")
|
|
|
+ @ApiOperationSupport(order = 8)
|
|
|
+ @ApiOperation(value = "释放锁", notes = "")
|
|
|
+ public R unLock(@ApiParam(value = "模块名称", required = true) @RequestParam String moduleName,
|
|
|
+ @ApiParam(value = "数据表名称", required = true) @RequestParam String tableName,
|
|
|
+ @ApiParam(value = "单据id", required = true) @RequestParam Long billId) {
|
|
|
+ LambdaQueryWrapper<LosLock> lockLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
|
|
+ lockLambdaQueryWrapper.eq(LosLock::getMoudleName, moduleName);
|
|
|
+ lockLambdaQueryWrapper.eq(LosLock::getTableName, tableName);
|
|
|
+ lockLambdaQueryWrapper.eq(LosLock::getBillId, billId);
|
|
|
+ lockLambdaQueryWrapper.eq(LosLock::getTenantId, AuthUtil.getTenantId());
|
|
|
+ LosLock lock = lockService.getOne(lockLambdaQueryWrapper);
|
|
|
+ if (lock != null) {
|
|
|
+ lockService.removeById(lock.getId());
|
|
|
+ return R.success("释放锁成功");
|
|
|
+ } else {
|
|
|
+ return R.success("释放锁成功");
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+}
|