|
|
@@ -0,0 +1,1142 @@
|
|
|
+package cn.iocoder.yudao.module.iscs.service.hardwareapi;
|
|
|
+
|
|
|
+import cn.hutool.core.lang.Assert;
|
|
|
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
|
|
+import cn.iocoder.yudao.framework.redis.RedisCacheUtil;
|
|
|
+import cn.iocoder.yudao.module.iscs.controller.admin.isolationpoint.vo.IsolationPointRespVO;
|
|
|
+import cn.iocoder.yudao.module.iscs.controller.admin.isolationpoint.vo.PointDetailVO;
|
|
|
+import cn.iocoder.yudao.module.iscs.controller.admin.jobticket.vo.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.hardware.HardwareDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.isolationpoint.IsolationPointDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.jobcard.JobCardDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.jobticket.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.key.KeyDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.lock.LockDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.lockcabinetslots.LockCabinetSlotsDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.lockset.LocksetDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dataobject.rfidtoken.RfidTokenDO;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dto.exUpdate.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.dal.dto.hardwareApi.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.enums.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.hardware.HardwareService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.isolationpoint.IsolationPointService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.jobcard.JobCardService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.jobticket.*;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.key.KeyService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.lock.LockService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.lockcabinetslots.LockCabinetSlotsService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.lockset.LocksetService;
|
|
|
+import cn.iocoder.yudao.module.iscs.service.rfidtoken.RfidTokenService;
|
|
|
+import cn.iocoder.yudao.module.system.service.attribute.AttributeService;
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
+
|
|
|
+import java.util.Date;
|
|
|
+import java.util.HashSet;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Set;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
+import static cn.iocoder.yudao.framework.web.core.util.WebFrameworkUtils.getLoginUserId;
|
|
|
+import static cn.iocoder.yudao.module.system.dal.redis.RedisKeyConstants.ISCS_ATTR;
|
|
|
+
|
|
|
+
|
|
|
+/**
|
|
|
+ * 硬件Service业务层处理
|
|
|
+ *
|
|
|
+ * @author cgj
|
|
|
+ * @date 2024-10-16
|
|
|
+ */
|
|
|
+@Slf4j
|
|
|
+@Service
|
|
|
+public class HardwareApiServiceImpl implements HardwareApiService {
|
|
|
+ @Autowired
|
|
|
+ private JobTicketService isJobTicketService;
|
|
|
+ @Autowired
|
|
|
+ private KeyService isKeyService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketKeyService iIsJobTicketKeyService;
|
|
|
+ @Autowired
|
|
|
+ private LockService iIsLockService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketLockService iIsJobTicketLockService;
|
|
|
+ @Autowired
|
|
|
+ private IsolationPointService iIsIsolationPointService;
|
|
|
+ @Autowired
|
|
|
+ private LocksetService iIsLocksetService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketLocksetService iIsJobTicketLocksetService;
|
|
|
+ @Autowired
|
|
|
+ private HardwareService isHardwareService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketPointsService iIsJobTicketPointsService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketUserService iIsJobTicketUserService;
|
|
|
+ @Autowired
|
|
|
+ private JobCardService iIsJobCardService;
|
|
|
+ @Autowired
|
|
|
+ private AttributeService isSystemAttributeService;
|
|
|
+ @Autowired
|
|
|
+ private RfidTokenService iIsRfidTokenService;
|
|
|
+ @Autowired
|
|
|
+ private LockCabinetSlotsService iIsLockCabinetSlotsService;
|
|
|
+ @Autowired
|
|
|
+ private TicketOperLogService isTicketOperLogService;
|
|
|
+ @Autowired
|
|
|
+ private JobTicketStepService iIsJobTicketStepService;
|
|
|
+ @Autowired
|
|
|
+ private RedisCacheUtil redisCacheUtil;
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出钥匙
|
|
|
+ *
|
|
|
+ * @param dto
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean updateTakeOutKey(TakeOutKeyDTO dto) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getKeyNfc(), "请告诉我钥匙的NFC!");
|
|
|
+ Assert.notBlank(dto.getSerialNumber(), "请告知归还到哪里!");
|
|
|
+ // 1.获取作业票数据
|
|
|
+ JobTicketDO jobTicket = isJobTicketService.getById(dto.getTicketId());
|
|
|
+ Assert.notNull(jobTicket, "作业票数据丢失啦!");
|
|
|
+ // 1.1获取上锁时取出的锁的信息
|
|
|
+ KeyDO startKey = isKeyService.getOne(Wrappers.<KeyDO>lambdaQuery().eq(KeyDO::getKeyNfc, dto.getKeyNfc()));
|
|
|
+ Assert.notNull(startKey, "钥匙数据丢失啦!");
|
|
|
+ // 1.2通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery()
|
|
|
+ .eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 1.3初始化时间参数
|
|
|
+ Date date = new Date();
|
|
|
+ // 1.4获取上锁时的数据
|
|
|
+ JobTicketKeyDO jobTicketKey = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, dto.getTicketId())
|
|
|
+ .ne(JobTicketKeyDO::getKeyStatus, "2")
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, "0"));
|
|
|
+ // 2.根据作业票判断到了哪一阶段了，如果未归还的上锁数据不为空并且上锁数据中这两个数据有空的，那肯定是上锁阶段还没有完成
|
|
|
+ if (jobTicketKey!=null && (jobTicketKey.getCollectTime() == null || jobTicketKey.getGiveBackTime() == null)) {
|
|
|
+ // 3.上锁阶段取钥匙
|
|
|
+ iIsJobTicketKeyService.update(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getId, jobTicketKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getKeyId, startKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getFromHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketKeyDO::getCollectTime, date)
|
|
|
+ .set(JobTicketKeyDO::getKeyStatus, KeyStatusEnum.TAKED.status));
|
|
|
+ // 上锁阶段需要变更状态
|
|
|
+ // TODO
|
|
|
+ /*JobTicketUpdateProgressReqVO reqVO = new JobTicketUpdateProgressReqVO();
|
|
|
+ reqVO.userId = SecurityUtils.getUserId();
|
|
|
+ reqVO.ticketId = dto.getTicketId();
|
|
|
+ reqVO.equipStatus = 3;
|
|
|
+ isJobTicketService.updateTicketProgress(reqVO);*/
|
|
|
+ } else {
|
|
|
+ JobTicketKeyDO jobTicketKey1 = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, dto.getTicketId())
|
|
|
+ .ne(JobTicketKeyDO::getKeyStatus, "2")
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, "1"));
|
|
|
+ // 3.1解锁阶段取钥匙
|
|
|
+ iIsJobTicketKeyService.update(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getId, jobTicketKey1.getId())
|
|
|
+ .set(JobTicketKeyDO::getKeyId, startKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getFromHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketKeyDO::getCollectTime, date)
|
|
|
+ .set(JobTicketKeyDO::getKeyStatus, KeyStatusEnum.TAKED.status));
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 上锁阶段，取钥匙时更新状态
|
|
|
+ *
|
|
|
+ * @param ticketId
|
|
|
+ */
|
|
|
+ private void updateFirstProgress(Long ticketId) {
|
|
|
+ // 判断作业票的整体状态，防止状态回退异常
|
|
|
+ JobTicketUserDO jobTicketUser = iIsJobTicketUserService.getOne(Wrappers.<JobTicketUserDO>lambdaQuery()
|
|
|
+ .eq(JobTicketUserDO::getTicketId, ticketId)
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue()));
|
|
|
+ Assert.isFalse(Integer.parseInt(jobTicketUser.getJobStatus()) > JobStatusEnum.ACQUIRE_KEY.status, "作业票已完成设备拿取，无法操作！");
|
|
|
+ JobTicketDO isJobTicket = isJobTicketService.getOne(Wrappers.<JobTicketDO>lambdaQuery()
|
|
|
+ .eq(JobTicketDO::getId, ticketId));
|
|
|
+ Assert.isFalse(Integer.parseInt(isJobTicket.getTicketStatus()) > Integer.parseInt(TicketStatusEnum.READY_TO_LOCK.status), "作业票已完成设备拿取，无法进行操作！");
|
|
|
+ // 上锁阶段取钥匙，更新is_job_ticket_user和is_job_ticket
|
|
|
+ // 1.新更人员状态
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getTicketId, ticketId)
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, JobStatusEnum.ACQUIRE_KEY.status));
|
|
|
+ // 2.获取设备取出状态
|
|
|
+ boolean b = checkTakeStatus(ticketId);
|
|
|
+ // 3.根据设备去除状态更新is_job_ticket
|
|
|
+ if (b) {
|
|
|
+ isJobTicketService.update(Wrappers.<JobTicketDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketDO::getId, ticketId)
|
|
|
+ .set(JobTicketDO::getTicketStatus, TicketStatusEnum.READY_TO_LOCK.status));
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 检查上锁前的设备是否全部取出完毕
|
|
|
+ *
|
|
|
+ * @param ticketId
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ private boolean checkTakeStatus(Long ticketId) {
|
|
|
+ // 1.检查钥匙是否取出
|
|
|
+ int keyCount = (int) iIsJobTicketKeyService.count(Wrappers.<JobTicketKeyDO>lambdaQuery()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, ticketId)
|
|
|
+ .eq(JobTicketKeyDO::getKeyStatus, KeyStatusEnum.WAIT_TAKE.status)
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, 0));
|
|
|
+ // 2.检查挂锁是否全部取出
|
|
|
+ int lockCount = (int) iIsJobTicketLockService.count(Wrappers.<JobTicketLockDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, ticketId)
|
|
|
+ .eq(JobTicketLockDO::getLockStatus, LockStatusEnum.WAIT_TAKE.status));
|
|
|
+ // 3.检查辅件是否全部取出
|
|
|
+ int locksetCount = (int) iIsJobTicketLocksetService.count(Wrappers.<JobTicketLocksetDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLocksetDO::getJobTicketId, ticketId)
|
|
|
+ .eq(JobTicketLocksetDO::getLocksetStatus, LocksetStatusEnum.WAIT_TAKE.status));
|
|
|
+ if (keyCount == 0 && lockCount == 0 && locksetCount == 0) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 归还钥匙
|
|
|
+ *
|
|
|
+ * @param dto
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Transactional
|
|
|
+ @Override
|
|
|
+ public Boolean updateReturnKey(ReturnKeyDTO dto) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getKeyNfc(), "请告诉我钥匙的NFC!");
|
|
|
+ Assert.notBlank(dto.getSerialNumber(), "请告知归还到哪里!");
|
|
|
+ // 1.获取作业票数据
|
|
|
+ JobTicketDO jobTicket = isJobTicketService.getById(dto.getTicketId());
|
|
|
+ Assert.notNull(jobTicket, "作业票数据丢失啦!");
|
|
|
+ // 1.1获取上锁时取出的锁的信息
|
|
|
+ KeyDO startKey = isKeyService.getOne(Wrappers.<KeyDO>lambdaQuery().eq(KeyDO::getKeyNfc, dto.getKeyNfc()));
|
|
|
+ Assert.notNull(startKey, "钥匙数据丢失啦!");
|
|
|
+ // 1.2通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery()
|
|
|
+ .eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 1.3初始化时间参数
|
|
|
+ Date date = new Date();
|
|
|
+ // 1.4获取上锁时的数据
|
|
|
+ JobTicketKeyDO jobTicketKey = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, dto.getTicketId())
|
|
|
+ .ne(JobTicketKeyDO::getKeyStatus, "2")
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, "0"));
|
|
|
+ // 2.根据作业票判断到了哪一阶段了，如果未归还的上锁数据不为空并且上锁数据中这两个数据有空的，那肯定是上锁阶段还没有完成
|
|
|
+ if (jobTicketKey!=null && (jobTicketKey.getCollectTime() == null || jobTicketKey.getGiveBackTime() == null)) {
|
|
|
+ // 3.1上锁阶段还钥匙
|
|
|
+ iIsJobTicketKeyService.update(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getId, jobTicketKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getKeyId, startKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketKeyDO::getGiveBackTime, date)
|
|
|
+ .set(JobTicketKeyDO::getKeyStatus, KeyStatusEnum.RETURNED.status));
|
|
|
+ // 3.1.1还完钥匙判断点位是不是都上锁完成，如果都上锁完成，则更新作业进度
|
|
|
+ List<JobTicketPointsDO> pointsLock = iIsJobTicketPointsService.list(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointStatus, "0"));
|
|
|
+ if (pointsLock.isEmpty()) {
|
|
|
+ isJobTicketService.update(Wrappers.<JobTicketDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketDO::getId, dto.getTicketId())
|
|
|
+ .set(JobTicketDO::getTicketStatus, "3"));
|
|
|
+ } else {
|
|
|
+ // 3.1.2如果没上完，允许再次获取一个新钥匙去上锁，所以要在生成一个取钥匙的初始化数据
|
|
|
+ JobTicketKeyDO isJobTicketKey = new JobTicketKeyDO();
|
|
|
+ isJobTicketKey.setTicketId(dto.getTicketId());
|
|
|
+ isJobTicketKey.setKeyStatus("0");
|
|
|
+ isJobTicketKey.setTicketType(0);
|
|
|
+ iIsJobTicketKeyService.save(isJobTicketKey);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ JobTicketKeyDO jobTicketKey1 = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, dto.getTicketId())
|
|
|
+ .ne(JobTicketKeyDO::getKeyStatus, "2")
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, "1"));
|
|
|
+ // 3.2解锁阶段还钥匙
|
|
|
+ iIsJobTicketKeyService.update(Wrappers.<JobTicketKeyDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketKeyDO::getId, jobTicketKey1.getId())
|
|
|
+ .set(JobTicketKeyDO::getKeyId, startKey.getId())
|
|
|
+ .set(JobTicketKeyDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketKeyDO::getGiveBackTime, date)
|
|
|
+ .set(JobTicketKeyDO::getKeyStatus, KeyStatusEnum.RETURNED.status));
|
|
|
+ // 3.2.1还完钥匙判断点位是不是都解锁完成，如果都解锁完成，则更新作业进度
|
|
|
+ List<JobTicketPointsDO> pointsLock = iIsJobTicketPointsService.list(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointStatus, "2"));
|
|
|
+ if (pointsLock.isEmpty()) {
|
|
|
+ isJobTicketService.update(Wrappers.<JobTicketDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketDO::getId, dto.getTicketId())
|
|
|
+ .set(JobTicketDO::getTicketStatus, "4"));
|
|
|
+ } else {
|
|
|
+ // 3.1.2如果没解完，允许再次获取一个新钥匙去解锁，所以要在生成一个解锁时取钥匙的初始化数据
|
|
|
+ JobTicketKeyDO isJobTicketKey = new JobTicketKeyDO();
|
|
|
+ isJobTicketKey.setTicketId(dto.getTicketId());
|
|
|
+ isJobTicketKey.setKeyStatus("0");
|
|
|
+ isJobTicketKey.setTicketType(1);
|
|
|
+ iIsJobTicketKeyService.save(isJobTicketKey);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出挂锁时更新数据
|
|
|
+ *
|
|
|
+ * @param list
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public synchronized Boolean updateTicketLockTake(List<TakeTicketLockDTO> list) {
|
|
|
+ Assert.isFalse(list.isEmpty(), "请取出至少一把挂锁!");
|
|
|
+ // 情况复杂，遍历处理吧
|
|
|
+ for (TakeTicketLockDTO dto : list) {
|
|
|
+ Assert.notBlank(dto.getLockNfc(), "挂锁nfc缺失!");
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getSerialNumber(), "请告知归还到哪一个柜子!");
|
|
|
+ // 1.查询挂锁信息
|
|
|
+ LockDO lock = iIsLockService.getOne(Wrappers.<LockDO>lambdaQuery()
|
|
|
+ .eq(LockDO::getLockNfc, dto.getLockNfc()));
|
|
|
+ Assert.notNull(lock, "该nfc无对应的挂锁信息!");
|
|
|
+ // 1.1检查这把锁是不是已经在该作业票中使用
|
|
|
+ List<JobTicketLockDO> jobTicketLockList = iIsJobTicketLockService.list(Wrappers.<JobTicketLockDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId()));
|
|
|
+ Assert.isFalse(!jobTicketLockList.isEmpty(), lock.getLockName() + "已被取出!");
|
|
|
+ // 1.2通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery()
|
|
|
+ .eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 2.获取本次作业票产生的和挂锁关联的数据,按照从上到下的顺序，取一个可以使用的
|
|
|
+ JobTicketLockDO isJobTicketLock = iIsJobTicketLockService.getOne(Wrappers.<JobTicketLockDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .isNull(JobTicketLockDO::getLockId)
|
|
|
+ .orderByAsc(JobTicketLockDO::getId)
|
|
|
+ .last("limit 1"));
|
|
|
+ Assert.notNull(isJobTicketLock, "无初始化数据来提供给该挂锁更新");
|
|
|
+ // 1.2开始补充该条数据
|
|
|
+ isJobTicketLock.setLockId(lock.getId());
|
|
|
+ isJobTicketLock.setFromHardwareId(isHardware.getId());
|
|
|
+ isJobTicketLock.setLockStatus(LockStatusEnum.NOT_LOCK.status);
|
|
|
+ iIsJobTicketLockService.updateById(isJobTicketLock);
|
|
|
+ }
|
|
|
+
|
|
|
+ List<JobTicketLockDO> lockList = iIsJobTicketLockService.list(Wrappers.<JobTicketLockDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, list.get(0).getTicketId()));
|
|
|
+ // 已取锁数量
|
|
|
+ int takeCount = (int) lockList.stream().filter(data -> data.getLockId() != null).count();
|
|
|
+ int status = takeCount == lockList.size() ? 2 : 1;
|
|
|
+
|
|
|
+ // TODO
|
|
|
+ /*JobTicketUpdateProgressReqVO reqVO = new JobTicketUpdateProgressReqVO();
|
|
|
+ reqVO.ticketId = list.get(0).getTicketId();
|
|
|
+ reqVO.userId = SecurityUtils.getUserId();
|
|
|
+ reqVO.equipStatus = status;
|
|
|
+ isJobTicketService.updateTicketProgress(reqVO);*/
|
|
|
+
|
|
|
+
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 归还挂锁时更新数据
|
|
|
+ *
|
|
|
+ * @param dto
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean updateTicketLockReturn(ReturnTicketLockDTO dto) {
|
|
|
+ // Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getLockNfc(), "挂锁nfc缺失!");
|
|
|
+ Assert.notBlank(dto.getSerialNumber(), "请告知归还到哪一个柜子!");
|
|
|
+ // 1.通过nfc查询挂锁信息
|
|
|
+ LockDO lock = iIsLockService.getOne(Wrappers.<LockDO>lambdaQuery()
|
|
|
+ .eq(LockDO::getLockNfc, dto.getLockNfc()));
|
|
|
+ Assert.notNull(lock, "该nfc无对应的挂锁信息!");
|
|
|
+ // 1.1通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery().eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 2.开始更新归还信息
|
|
|
+ if (dto.getTicketId() != null) {
|
|
|
+ // 2.1登陆后归还， 判断钥匙在哪个阶段，根据不同阶段更新不一样
|
|
|
+ Integer lockStateByNfc = getLockStateByNfc(dto.getLockNfc(), dto.getTicketId());
|
|
|
+ if (lockStateByNfc.equals(0) || lockStateByNfc.equals(2)) {
|
|
|
+ // 0-上锁未取钥匙(可锁-需更改还锁逻辑)
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getLockId, null)
|
|
|
+ .set(JobTicketLockDO::getFromHardwareId, null)
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.WAIT_TAKE.status));
|
|
|
+ } else if (lockStateByNfc.equals(1)) {
|
|
|
+ // 1-上锁取了钥匙(不可锁)
|
|
|
+ return true;
|
|
|
+ } else {
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.RETURN_LOCK.status));
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 2.2不登陆状态下归还
|
|
|
+ // 查一下哪个作业票用了这个挂锁，而且还没有完成
|
|
|
+ List<JobTicketLockDO> jobTicketLockList = iIsJobTicketLockService.getLockJob(lock.getId());
|
|
|
+ if (jobTicketLockList.isEmpty()) {
|
|
|
+ log.error("当前挂锁未找到关联的作业票, nfc: {}, name : {}", dto.getLockNfc(), lock.getLockName());
|
|
|
+ return null;
|
|
|
+ } else if (jobTicketLockList.size() == 1) {
|
|
|
+ // 2.1登陆后归还， 判断钥匙在哪个阶段，根据不同阶段更新不一样
|
|
|
+ Integer lockStateByNfc = getLockStateByNfc(dto.getLockNfc(), jobTicketLockList.get(0).getTicketId());
|
|
|
+ if (lockStateByNfc.equals(0) || lockStateByNfc.equals(2)) {
|
|
|
+ // 0-上锁未取钥匙(可锁-需更改还锁逻辑)
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, jobTicketLockList.get(0).getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getLockId, null)
|
|
|
+ .set(JobTicketLockDO::getFromHardwareId, null)
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.WAIT_TAKE.status));
|
|
|
+ } else if (lockStateByNfc.equals(1)) {
|
|
|
+ // 1-上锁取了钥匙(不可锁)
|
|
|
+ return true;
|
|
|
+ } else {
|
|
|
+ // 说明找到的就是
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.RETURN_LOCK.status));
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 出现了多条对应
|
|
|
+ log.error("当前挂锁找到多条关联的作业票, nfc: {}, name : {}", dto.getLockNfc(), lock.getLockName());
|
|
|
+ }
|
|
|
+ // TODO
|
|
|
+ /* JobTicketUpdateProgressReqVO reqVO = new JobTicketUpdateProgressReqVO();
|
|
|
+ reqVO.userId = SecurityUtils.getUserId();
|
|
|
+ reqVO.ticketId = jobTicketLockList.get(0).getTicketId();
|
|
|
+ reqVO.equipStatus = 3;
|
|
|
+ isJobTicketService.updateTicketProgress(reqVO);*/
|
|
|
+ }
|
|
|
+
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 批量更新作业票下隔离点的上锁状况
|
|
|
+ *
|
|
|
+ * @param list
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Transactional
|
|
|
+ @Override
|
|
|
+ public Boolean updateLockPointBatch(List<LockPointBatchDTO> list) {
|
|
|
+ Assert.isFalse(list.isEmpty(), "没有接收到数据啊!");
|
|
|
+ // 情况复杂，循环处理
|
|
|
+ for (LockPointBatchDTO dto : list) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ // 1.获取作业票数据
|
|
|
+ JobTicketDO jobTicket = isJobTicketService.getById(dto.getTicketId());
|
|
|
+ Assert.notNull(jobTicket, "作业票数据丢失啦!");
|
|
|
+ Assert.notBlank(dto.getLockNfc(), "挂锁nfc缺失!");
|
|
|
+ Assert.notBlank(dto.getPointNfc(), "请告知隔离点信息!");
|
|
|
+ Assert.notNull(dto.getTarget(), "请告我是去挂锁还是解锁!");
|
|
|
+ Assert.notNull(dto.getStatus(), "请告我任务当前状态!");
|
|
|
+ Assert.notBlank(dto.getKeyNfc(), "钥匙信息不可为空!");
|
|
|
+ // 1.通过nfc查询挂锁信息
|
|
|
+ LockDO lock = iIsLockService.getOne(Wrappers.<LockDO>lambdaQuery()
|
|
|
+ .eq(LockDO::getLockNfc, dto.getLockNfc()));
|
|
|
+ Assert.notNull(lock, "该nfc无对应的挂锁信息");
|
|
|
+ // 1.1通过nfc查询钥匙信息
|
|
|
+ KeyDO key = isKeyService.getOne(Wrappers.<KeyDO>lambdaQuery()
|
|
|
+ .eq(KeyDO::getKeyNfc, dto.getKeyNfc()));
|
|
|
+ Assert.notNull(lock, "该nfc无对应的钥匙信息");
|
|
|
+ // 2.通过nfc查询隔离点信息
|
|
|
+ IsolationPointRespVO point = iIsIsolationPointService.getOneByNfc(dto.getPointNfc());
|
|
|
+ Assert.notNull(point, "该nfc无对应的隔离点信息");
|
|
|
+ Date date = new Date();
|
|
|
+ if (dto.getTarget().equals(0)) {
|
|
|
+ log.info("--------------开始上锁-----------");
|
|
|
+ // 重复点位模式检查
|
|
|
+ checkBeforeLockKeyBack(isSystemAttributeService.getAttributeByKey("sys.job.lock_type").getSysAttrValue(), BeanUtils.toBean(point, IsolationPointDO.class), lock);
|
|
|
+ // 2.1更新隔离点上锁信息
|
|
|
+ iIsJobTicketPointsService.update(Wrappers.<JobTicketPointsDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointId, point.getId())
|
|
|
+ .set(JobTicketPointsDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketPointsDO::getLockedByKeyId, key.getId())
|
|
|
+ .set(JobTicketPointsDO::getLockTime, date)
|
|
|
+ .set(JobTicketPointsDO::getPointStatus, PointStatusEnum.LOCKED.status));
|
|
|
+ // 3.开始更新上锁时挂锁信息
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getIsolationPointId, point.getId())
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.LOCKED.status));
|
|
|
+ // 4.如果隔离点上锁完毕，则更新作业负责人的任务状态
|
|
|
+ int count = (int) iIsJobTicketPointsService.count(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointStatus, "0"));
|
|
|
+ if (count == 0) {
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue())
|
|
|
+ .eq(JobTicketUserDO::getTicketId, dto.getTicketId())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, "4"));
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ log.info("--------------开始解锁-----------");
|
|
|
+ // 2.1.1更新隔离点解锁信息
|
|
|
+ iIsJobTicketPointsService.update(Wrappers.<JobTicketPointsDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointId, point.getId())
|
|
|
+ .set(JobTicketPointsDO::getUnlockedByKeyId, key.getId())
|
|
|
+ .set(JobTicketPointsDO::getUnlockTime, date)
|
|
|
+ .set(JobTicketPointsDO::getPointStatus, PointStatusEnum.REMOVE_LOCK.status));
|
|
|
+ // 3.1开始更新解锁时挂锁信息
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, lock.getId())
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.REMOVED_LOCK.status));
|
|
|
+ // 4.1如果都解锁了，则更新作业负责人的任务状态
|
|
|
+ int count = (int) iIsJobTicketPointsService.count(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, dto.getTicketId())
|
|
|
+ .ne(JobTicketPointsDO::getPointStatus, "2"));
|
|
|
+ if (count == 0) {
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue())
|
|
|
+ .eq(JobTicketUserDO::getTicketId, dto.getTicketId())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, "5"));
|
|
|
+ }
|
|
|
+ // 4.2开始更新因为重合点位，当时没有解锁的点位的数据
|
|
|
+ // updateConflictPoints(point.getPointId(), key.getKeyId(), date, lock.getLockId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /*JobTicketUpdateProgressReqVO reqVO = new JobTicketUpdateProgressReqVO();
|
|
|
+ reqVO.userId = SecurityUtils.getUserId();
|
|
|
+ reqVO.ticketId = list.get(0).getTicketId();
|
|
|
+ reqVO.equipStatus = 3;
|
|
|
+ isJobTicketService.updateTicketProgress(reqVO);*/
|
|
|
+ // 4.更新下作业票的状态，如果是上锁时的操作
|
|
|
+ if (list.get(0).getTarget() != null && list.get(0).getTarget().equals(0)) {
|
|
|
+ isJobTicketService.update(Wrappers.<JobTicketDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketDO::getId, list.get(0).getTicketId())
|
|
|
+ .set(JobTicketDO::getTicketStatus, "2"));
|
|
|
+ }
|
|
|
+ // 完成上锁
|
|
|
+ // 完成解锁
|
|
|
+ lockLog(list);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void lockLog(List<LockPointBatchDTO> list) {
|
|
|
+ // 上锁日志
|
|
|
+ List<LockPointBatchDTO> lockList = list.stream().filter(o -> o.getTarget().equals(0)).collect(Collectors.toList());
|
|
|
+ if (!lockList.isEmpty()) {
|
|
|
+ JobTicketDO byId = isJobTicketService.getById(lockList.get(0).getTicketId());
|
|
|
+ if (byId != null) {
|
|
|
+ List<String> nfcList = lockList.stream().map(LockPointBatchDTO::getPointNfc).collect(Collectors.toList());
|
|
|
+ List<RfidTokenDO> list2 = iIsRfidTokenService.list(Wrappers.<RfidTokenDO>lambdaQuery()
|
|
|
+ .in(RfidTokenDO::getRfid, nfcList));
|
|
|
+ List<Long> collect = list2.stream().map(RfidTokenDO::getId).collect(Collectors.toList());
|
|
|
+ List<IsolationPointDO> list1 = iIsIsolationPointService.list(Wrappers.<IsolationPointDO>lambdaQuery()
|
|
|
+ .in(IsolationPointDO::getRfidId, collect));
|
|
|
+ // String pointNames = list1.stream().map(IsIsolationPoint::getPointName).collect(Collectors.joining(","));
|
|
|
+ StringBuilder pointNames = new StringBuilder();
|
|
|
+ for (IsolationPointDO isIsolationPoint : list1) {
|
|
|
+ pointNames.append("<").append(isIsolationPoint.getPointIcon()).append(">").append("[").append(isIsolationPoint.getPointName()).append("] ");
|
|
|
+ }
|
|
|
+ // 完成上锁
|
|
|
+ isTicketOperLogService.addLog5(byId.getId(), byId.getTicketName(), pointNames.toString());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<LockPointBatchDTO> unlockList = list.stream().filter(o -> o.getTarget().equals(1)).collect(Collectors.toList());
|
|
|
+ if (!unlockList.isEmpty()) {
|
|
|
+ JobTicketDO byId = isJobTicketService.getById(unlockList.get(0).getTicketId());
|
|
|
+ if (byId != null) {
|
|
|
+ List<String> nfcList = unlockList.stream().map(LockPointBatchDTO::getPointNfc).collect(Collectors.toList());
|
|
|
+ List<RfidTokenDO> list2 = iIsRfidTokenService.list(Wrappers.<RfidTokenDO>lambdaQuery()
|
|
|
+ .in(RfidTokenDO::getRfid, nfcList));
|
|
|
+ List<Long> collect = list2.stream().map(RfidTokenDO::getId).collect(Collectors.toList());
|
|
|
+ List<IsolationPointDO> list1 = iIsIsolationPointService.list(Wrappers.<IsolationPointDO>lambdaQuery()
|
|
|
+ .in(IsolationPointDO::getRfidId, collect));
|
|
|
+ StringBuilder pointNames = new StringBuilder();
|
|
|
+ for (IsolationPointDO isIsolationPoint : list1) {
|
|
|
+ pointNames.append("<").append(isIsolationPoint.getPointIcon()).append(">").append("[").append(isIsolationPoint.getPointName()).append("] ");
|
|
|
+ }
|
|
|
+ // 完成解锁
|
|
|
+ isTicketOperLogService.addLog9(byId.getId(), byId.getTicketName(), String.valueOf(pointNames));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 需要增加上锁还钥匙的时候锁的验证
|
|
|
+ * 1）、强制共享锁，交叉点位的锁rfid还钥匙时必须相同
|
|
|
+ * 2）、强制多锁，交叉点位的锁rfid还钥匙时必须不同
|
|
|
+ * 3）、非强制共享锁，交叉点位的锁rfid还钥匙时可相同
|
|
|
+ * <p>
|
|
|
+ * 上锁后还钥匙
|
|
|
+ */
|
|
|
+ private void checkBeforeLockKeyBack(String type, IsolationPointDO point, LockDO lock) {
|
|
|
+ if (type.equals("1")) {
|
|
|
+ // 强制共享锁，交叉点位的锁rfid还钥匙时必须相同，即重复点位锁信息需与已上的锁的信息校验
|
|
|
+ // 开始查询已经上锁的点位信息
|
|
|
+ JobTicketPointsDO lockingData = iIsJobTicketPointsService.getLockingData(point.getId());
|
|
|
+ if (lockingData != null) {
|
|
|
+ Assert.isTrue(lock.getId().equals(lockingData.getLockId()),
|
|
|
+ "点位挂锁错误！点位[" + point.getPointName() + "]当前正在被" + iIsLockService.getById(lockingData.getLockId()).getLockNfc() + "挂锁锁定！");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if (type.equals("2")) {
|
|
|
+ // 强制多锁，交叉点位的锁rfid还钥匙时必须不同
|
|
|
+ // 开始查询已经上锁的点位信息
|
|
|
+ JobTicketPointsDO lockingData = iIsJobTicketPointsService.getLockingData(point.getId());
|
|
|
+ if (lockingData != null) {
|
|
|
+ Assert.isFalse(lock.getId().equals(lockingData.getLockId()), "点位挂锁错误，重复点位[" + point.getPointName() + "]请多锁完成重复点位上锁！");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 解锁时，解除因为点位冲突而没有被解除的点位数据
|
|
|
+ */
|
|
|
+ public void updateConflictPoints(Long pointId, Long unlockedByKeyId, Date date, Long lockId) {
|
|
|
+ // 查询当前点位是否有取了钥匙去解锁的作业票，如果有则更新
|
|
|
+ List<JobTicketPointsDO> notFinishConflictJob = iIsJobTicketPointsService.getNotFinishConflictJob(pointId, lockId);
|
|
|
+ // 查询当前点位是否有已经完成的作业票，但是该点位没有解锁的
|
|
|
+ List<JobTicketPointsDO> finishConflictJob = iIsJobTicketPointsService.getFinishConflictJob(pointId, lockId);
|
|
|
+ finishConflictJob.addAll(notFinishConflictJob);
|
|
|
+ HashSet<JobTicketPointsDO> isJobTicketPoints1 = new HashSet<>(finishConflictJob);
|
|
|
+ // 查询都是去解锁的
|
|
|
+ if (!finishConflictJob.isEmpty()) {
|
|
|
+ for (JobTicketPointsDO isJobTicketPoints : isJobTicketPoints1) {
|
|
|
+ // 2.1.1更新隔离点解锁信息
|
|
|
+ iIsJobTicketPointsService.update(Wrappers.<JobTicketPointsDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketPointsDO::getId, isJobTicketPoints.getId())
|
|
|
+ .set(JobTicketPointsDO::getUnlockedByKeyId, unlockedByKeyId)
|
|
|
+ .set(JobTicketPointsDO::getUnlockTime, date)
|
|
|
+ .set(JobTicketPointsDO::getPointStatus, PointStatusEnum.REMOVE_LOCK.status));
|
|
|
+ // 3.1开始更新解锁时挂锁信息
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, isJobTicketPoints.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getIsolationPointId, pointId)
|
|
|
+ .eq(JobTicketLockDO::getLockId, lockId)
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.REMOVED_LOCK.status));
|
|
|
+ // 4.1如果都解锁了，则更新作业负责人的任务状态
|
|
|
+ int count = (int) iIsJobTicketPointsService.count(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, isJobTicketPoints.getTicketId())
|
|
|
+ .ne(JobTicketPointsDO::getPointStatus, "2"));
|
|
|
+ if (count == 0) {
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue())
|
|
|
+ .eq(JobTicketUserDO::getTicketId, isJobTicketPoints.getTicketId())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, "5"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 取出辅件时更新数据
|
|
|
+ *
|
|
|
+ * @param list
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean updateLocksetTake(List<TakeLocksetDTO> list) {
|
|
|
+ Assert.isFalse(list.isEmpty(), "请取出至少一个辅件!");
|
|
|
+ // 情况复杂，软条件过多，单条剥离处理吧
|
|
|
+ for (TakeLocksetDTO dto : list) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getLocksetNfc(), "辅件nfc缺失!");
|
|
|
+ // 1.查询辅件的详情
|
|
|
+ LocksetDO lockset = iIsLocksetService.getOne(Wrappers.<LocksetDO>lambdaQuery().eq(LocksetDO::getLocksetNfc, dto.getLocksetNfc()));
|
|
|
+ Assert.notNull(lockset, dto.getLocksetNfc() + "无对应的辅件信息!");
|
|
|
+ // 1.1通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery()
|
|
|
+ .eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 1.2获取该辅件的类型，找到is_job_ticket_lockset有没有对应的，可能会有多条，取其中一条即可，
|
|
|
+ JobTicketLocksetDO jobTicketLockset = iIsJobTicketLocksetService.getOne(Wrappers.<JobTicketLocksetDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLocksetDO::getJobTicketId, dto.getTicketId())
|
|
|
+ // 未使用过的数据
|
|
|
+ .isNull(JobTicketLocksetDO::getLocksetId)
|
|
|
+ // 处理下多条取一条用,按照从上倒下顺序使用
|
|
|
+ .orderByAsc(JobTicketLocksetDO::getJobTicketId)
|
|
|
+ .last("limit 1"));
|
|
|
+ Assert.notNull(jobTicketLockset, "无初始化数据来提供给该辅件更新");
|
|
|
+ // 1.3开始补充该条数据
|
|
|
+ jobTicketLockset.setLocksetId(lockset.getId());
|
|
|
+ jobTicketLockset.setFromHardwareId(isHardware.getId());
|
|
|
+ jobTicketLockset.setLocksetStatus(LocksetStatusEnum.TAKED.status);
|
|
|
+ jobTicketLockset.setCollectTime(new Date());
|
|
|
+ iIsJobTicketLocksetService.updateById(jobTicketLockset);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 辅件绑定隔离点(辅件和给隔离点上锁时)
|
|
|
+ *
|
|
|
+ * @param dto
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean updateLocksetPoint(LocksetPointDTO dto) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "请告诉我关于哪个作业票!");
|
|
|
+ Assert.notBlank(dto.getLocksetNfc(), "辅件nfc缺失!");
|
|
|
+ Assert.notNull(dto.getPointNfc(), "请告知隔离点信息!");
|
|
|
+ // 1.通过nfc查询挂锁信息
|
|
|
+ LocksetDO lockset = iIsLocksetService.getOne(Wrappers.<LocksetDO>lambdaQuery()
|
|
|
+ .eq(LocksetDO::getLocksetNfc, dto.getLocksetNfc()));
|
|
|
+ Assert.notNull(lockset, "该nfc无对应的辅件信息");
|
|
|
+ // 2.通过nfc查询隔离点信息
|
|
|
+ IsolationPointRespVO point = iIsIsolationPointService.getOneByNfc(dto.getPointNfc());
|
|
|
+ Assert.notNull(point, "该nfc无对应的隔离点信息");
|
|
|
+ // 3.开始更新绑定关系
|
|
|
+ iIsJobTicketLocksetService.update(Wrappers.<JobTicketLocksetDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLocksetDO::getJobTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLocksetDO::getLocksetId, lockset.getId())
|
|
|
+ .set(JobTicketLocksetDO::getPointId, point.getId())
|
|
|
+ .set(JobTicketLocksetDO::getLocksetStatus, LocksetStatusEnum.USING.status));
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 辅件归还物资柜
|
|
|
+ *
|
|
|
+ * @param dto
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Boolean updateLocksetReturn(ReturnLocksetDTO dto) {
|
|
|
+ Assert.notBlank(dto.getLocksetNfc(), "辅件nfc缺失!");
|
|
|
+ Assert.notBlank(dto.getSerialNumber(), "请告知归还到哪一个柜子!");
|
|
|
+ // 1.通过nfc查询辅件信息
|
|
|
+ LocksetDO lockset = iIsLocksetService.getOne(Wrappers.<LocksetDO>lambdaQuery()
|
|
|
+ .eq(LocksetDO::getLocksetNfc, dto.getLocksetNfc()));
|
|
|
+ Assert.notNull(lockset, "该nfc无对应的辅件信息!");
|
|
|
+ // 1.1通过序列号查询柜子信息
|
|
|
+ HardwareDO isHardware = isHardwareService.getOne(Wrappers.<HardwareDO>lambdaQuery().eq(HardwareDO::getSerialNumber, dto.getSerialNumber()));
|
|
|
+ Assert.notNull(isHardware, "该序列号无对应的硬件信息!");
|
|
|
+ // 2.开始更新归还信息
|
|
|
+ if (dto.getTicketId() != null) {
|
|
|
+ // 2.1登陆后归还
|
|
|
+ iIsJobTicketLocksetService.update(Wrappers.<JobTicketLocksetDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLocksetDO::getJobTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketLocksetDO::getLocksetId, lockset.getId())
|
|
|
+ .set(JobTicketLocksetDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketLocksetDO::getLocksetStatus, LocksetStatusEnum.RETURNED.status));
|
|
|
+ } else {
|
|
|
+ // 2.2不登陆状态下归还
|
|
|
+ // 查一下哪个作业票用了这个挂锁，而且还没有完成
|
|
|
+ List<JobTicketLocksetDO> jobTicketLocksetList = iIsJobTicketLocksetService.list(Wrappers.<JobTicketLocksetDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLocksetDO::getLocksetId, lockset.getId())
|
|
|
+ .ne(JobTicketLocksetDO::getLocksetStatus, LocksetStatusEnum.RETURNED.status));
|
|
|
+ if (jobTicketLocksetList.isEmpty()) {
|
|
|
+ log.error("当前辅件未找到关联的作业票, nfc: {}, name : {}", dto.getLocksetNfc(), lockset.getLocksetName());
|
|
|
+ } else if (jobTicketLocksetList.size() == 1) {
|
|
|
+ // 说明找到的就是
|
|
|
+ iIsJobTicketLocksetService.update(Wrappers.<JobTicketLocksetDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLocksetDO::getLocksetId, lockset.getId())
|
|
|
+ .set(JobTicketLocksetDO::getToHardwareId, isHardware.getId())
|
|
|
+ .set(JobTicketLocksetDO::getLocksetStatus, LocksetStatusEnum.RETURNED.status));
|
|
|
+ } else {
|
|
|
+ // 出现了多条对应
|
|
|
+ log.error("当前辅件找到多条关联的作业票, nfc: {}, name : {}", dto.getLocksetNfc(), lockset.getLocksetName());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取作业票和关联数据
|
|
|
+ *
|
|
|
+ * @param ticketId
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public JobTicketRespVO selectTicketDetailById(Long ticketId) {
|
|
|
+ Assert.notNull(ticketId, "作业票id不可为空!");
|
|
|
+ // 1.查询作业票信息
|
|
|
+ JobTicketDO isJobTicket = isJobTicketService.getById(ticketId);
|
|
|
+ Assert.notNull(isJobTicket, "作业票信息丢失！");
|
|
|
+ JobTicketRespVO jobTicketVO = BeanUtils.toBean(isJobTicket, JobTicketRespVO.class);
|
|
|
+ // 2.查询钥匙数据
|
|
|
+ List<JobTicketKeyDO> ticketKeyList = iIsJobTicketKeyService.list(Wrappers.<JobTicketKeyDO>lambdaQuery()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, ticketId));
|
|
|
+ List<JobTicketKeyRespVO> ticketKeyVOList = BeanUtils.toBean(ticketKeyList, JobTicketKeyRespVO.class);
|
|
|
+ // 3.查询挂锁数据
|
|
|
+ List<JobTicketLockRespVO> ticketLockVOList = iIsJobTicketLockService.getTicketLockByTicketId(ticketId);
|
|
|
+ // 4.查询辅件数据
|
|
|
+ List<JobTicketLocksetDO> jobTicketLocksetList = iIsJobTicketLocksetService.list(Wrappers.<JobTicketLocksetDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLocksetDO::getJobTicketId, ticketId));
|
|
|
+ List<JobTicketLocksetRespVO> ticketLocksetVOList = BeanUtils.toBean(jobTicketLocksetList, JobTicketLocksetRespVO.class);
|
|
|
+ // 5.查询用户数据
|
|
|
+ List<JobTicketUserDO> jobTicketUserList = iIsJobTicketUserService.list(Wrappers.<JobTicketUserDO>lambdaQuery()
|
|
|
+ .eq(JobTicketUserDO::getTicketId, ticketId));
|
|
|
+ List<JobTicketUserRespVO> ticketUserVOList = BeanUtils.toBean(jobTicketUserList, JobTicketUserRespVO.class);
|
|
|
+ // 6.查询隔离点数据
|
|
|
+ List<JobTicketPointsRespVO> ticketPointsVOList = iIsJobTicketPointsService.listByTicketId(ticketId);
|
|
|
+ if (!ticketPointsVOList.isEmpty()) {
|
|
|
+ List<Long> pointIds = ticketPointsVOList.stream().map(JobTicketPointsRespVO::getPointId).collect(Collectors.toList());
|
|
|
+ List<PointDetailVO> pointDetailList = iIsIsolationPointService.getPointDetailList(pointIds);
|
|
|
+ for (JobTicketPointsRespVO jobTicketPointsVO : ticketPointsVOList) {
|
|
|
+ for (PointDetailVO pointDetailVO : pointDetailList) {
|
|
|
+ if (jobTicketPointsVO.getPointId().equals(pointDetailVO.getId())) {
|
|
|
+ // jobTicketPointsVO.setPointCode(pointDetailVO.getPointCode());
|
|
|
+ jobTicketPointsVO.setPointName(pointDetailVO.getPointName());
|
|
|
+ jobTicketPointsVO.setPointType(pointDetailVO.getPointType());
|
|
|
+ jobTicketPointsVO.setPointTypeName(pointDetailVO.getPointTypeName());
|
|
|
+ jobTicketPointsVO.setPointNfc(pointDetailVO.getPointNfc());
|
|
|
+ jobTicketPointsVO.setWorkshopName(pointDetailVO.getWorkshopName());
|
|
|
+ jobTicketPointsVO.setWorkareaName(pointDetailVO.getWorkareaName());
|
|
|
+ jobTicketPointsVO.setWorkstationId(pointDetailVO.getWorkstationId());
|
|
|
+ jobTicketPointsVO.setWorkstationName(pointDetailVO.getWorkstationName());
|
|
|
+ jobTicketPointsVO.setLotoId(pointDetailVO.getLotoId());
|
|
|
+ jobTicketPointsVO.setLotoName(pointDetailVO.getLotoName());
|
|
|
+ jobTicketPointsVO.setPowerType(pointDetailVO.getPowerType());
|
|
|
+ jobTicketPointsVO.setPowerTypeName(pointDetailVO.getPowerTypeName());
|
|
|
+ jobTicketPointsVO.setIsolationMethod(pointDetailVO.getIsolationMethod());
|
|
|
+ jobTicketPointsVO.setPointIcon(pointDetailVO.getPointIcon());
|
|
|
+ jobTicketPointsVO.setPointPicture(pointDetailVO.getPointPicture());
|
|
|
+ jobTicketPointsVO.setLockTypeId(pointDetailVO.getLockTypeId());
|
|
|
+ jobTicketPointsVO.setLockTypeCode(pointDetailVO.getLockTypeCode());
|
|
|
+ jobTicketPointsVO.setLockTypeName(pointDetailVO.getLockTypeName());
|
|
|
+ jobTicketPointsVO.setLockTypeIcon(pointDetailVO.getLockTypeIcon());
|
|
|
+ jobTicketPointsVO.setLockTypeImg(pointDetailVO.getLockTypeImg());
|
|
|
+ // jobTicketPointsVO.setLockNfc(pointDetailVO.getLockNfc());
|
|
|
+ jobTicketPointsVO.setLocksetTypeId(pointDetailVO.getLocksetTypeId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 7.解锁时，提供的不可解锁的点位数据
|
|
|
+ Set<JobTicketPointsRespVO> noUnlockTicketPointsVOSet = new HashSet<>();
|
|
|
+ // if (isSystemAttributeService.getIsSystemAttributeByKey("sys.job.lock_type").getSysAttrValue().equals("1")) {
|
|
|
+ // 查找点位相同并且用了同一个锁没有解锁的作业点位(存在虚拟锁的冲突点位)
|
|
|
+ for (JobTicketPointsRespVO jobTicketPointsVO : ticketPointsVOList) {
|
|
|
+ List<JobTicketPointsDO> virtualLockConflictPoint = iIsJobTicketPointsService.getVirtualLockConflictPoint(jobTicketPointsVO.getPointId(), jobTicketPointsVO.getLockId(), jobTicketPointsVO.getTicketId());
|
|
|
+ if (!virtualLockConflictPoint.isEmpty()) {
|
|
|
+ noUnlockTicketPointsVOSet.add(jobTicketPointsVO);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // }
|
|
|
+
|
|
|
+ // 8.组装数据
|
|
|
+ jobTicketVO.setTicketKeyList(ticketKeyVOList);
|
|
|
+ jobTicketVO.setTicketLockList(ticketLockVOList);
|
|
|
+ // jobTicketVO.setTicketLocksetList(ticketLocksetVOList);
|
|
|
+ jobTicketVO.setTicketUserList(ticketUserVOList);
|
|
|
+ jobTicketVO.setTicketPointsList(ticketPointsVOList);
|
|
|
+ jobTicketVO.setNoUnlockTicketPointsVOSet(noUnlockTicketPointsVOSet);
|
|
|
+ return jobTicketVO;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean updateColockerStatus(UpdateColockerStatusDTO dto) {
|
|
|
+ Assert.notNull(dto.getTicketId(), "作业票id不能为空!");
|
|
|
+ Assert.notBlank(dto.getJobStatus(), "操作的共锁/解锁状态不能为空!");
|
|
|
+ Assert.notBlank(dto.getCardNfc(), "工作卡NFC不能为空!");
|
|
|
+ // 1.根据作业卡获取当前人员状态
|
|
|
+ JobCardDO card = iIsJobCardService.getOne(Wrappers.<JobCardDO>lambdaQuery().eq(JobCardDO::getCardNfc, dto.getCardNfc()));
|
|
|
+ Assert.isFalse(card == null, "该工作卡未绑定用户!");
|
|
|
+ // 2.检测获取这个人在该作业票中状态
|
|
|
+ JobTicketUserDO jobTicketUser = iIsJobTicketUserService.getOne(Wrappers.<JobTicketUserDO>lambdaQuery()
|
|
|
+ .eq(JobTicketUserDO::getUserId, card.getUserId())
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtcolocker").getSysAttrValue())
|
|
|
+ .eq(JobTicketUserDO::getTicketId, dto.getTicketId()));
|
|
|
+ Assert.isFalse(jobTicketUser == null, "该员工卡绑定的员工暂无作业任务!");
|
|
|
+ // 2.1判断状态
|
|
|
+ JobTicketDO isJobTicket = isJobTicketService.getById(dto.getTicketId());
|
|
|
+ Assert.isFalse("0".equals(isJobTicket.getTicketStatus()), "该作业票未开始，请勿共锁！");
|
|
|
+ Assert.isFalse("4".equals(dto.getJobStatus()) && "4".equals(jobTicketUser.getJobStatus()), "您已共锁，请勿重复共锁！");
|
|
|
+ Assert.isFalse(Integer.parseInt(jobTicketUser.getJobStatus()) < 4 && "5".equals(dto.getJobStatus()), "您还未共锁，请勿操作解除共锁！");
|
|
|
+ Assert.isFalse("5".equals(jobTicketUser.getJobStatus()) && "5".equals(dto.getJobStatus()), "您已解除共锁，请勿重复解除锁！");
|
|
|
+ // 3.开始操作
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getTicketId, dto.getTicketId())
|
|
|
+ .eq(JobTicketUserDO::getUserId, card.getUserId())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, dto.getJobStatus()));
|
|
|
+ // 添加共锁
|
|
|
+ if (dto.getJobStatus().equals("4")) {
|
|
|
+ isTicketOperLogService.addLog6(isJobTicket.getId(), isJobTicket.getTicketName(), jobTicketUser.getUserName());
|
|
|
+ }
|
|
|
+ // 解除共锁
|
|
|
+ if (dto.getJobStatus().equals("5")) {
|
|
|
+ isTicketOperLogService.addLog7(isJobTicket.getId(), isJobTicket.getTicketName(), jobTicketUser.getUserName());
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean updateSwitchList(UpdateSwitchParam dto) {
|
|
|
+ Assert.isFalse(dto.getList().isEmpty(), "点位开关数据不可为空！");
|
|
|
+ dto.getList().forEach(o -> {
|
|
|
+ Assert.notBlank(o.getPointSerialNumber(), "序列号不可为空！");
|
|
|
+ });
|
|
|
+ redisCacheUtil.setCacheList(ISCS_ATTR + "sys.points.switch.last", dto.getList());
|
|
|
+ redisCacheUtil.expire(ISCS_ATTR + "sys.points.switch.last", 60, TimeUnit.SECONDS);
|
|
|
+ redisCacheUtil.deleteObject(ISCS_ATTR + "sys.points.switch.records");
|
|
|
+ redisCacheUtil.setCacheList(ISCS_ATTR + "sys.points.switch.records", dto.getList());
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional
|
|
|
+ @Override
|
|
|
+ public Boolean checkBeforeToLock(Long ticketId) {
|
|
|
+ Assert.notNull(ticketId, "当前作业票id不能为空！");
|
|
|
+ // 0.检查是不是取了锁 但是没有取钥匙，如果是说明数据有问题，断过网
|
|
|
+ JobTicketDO isJobTicket = isJobTicketService.getById(ticketId);
|
|
|
+ // 4.更新下作业票的状态，如果是上锁时的操作
|
|
|
+ isJobTicketService.update(Wrappers.<JobTicketDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketDO::getId, ticketId)
|
|
|
+ .set(JobTicketDO::getTicketStatus, "2"));
|
|
|
+ // 启动上锁
|
|
|
+ isTicketOperLogService.addLog4(isJobTicket.getId(), isJobTicket.getTicketName());
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 纠正异常取锁
|
|
|
+ */
|
|
|
+ private void checkExTakeLock(Long ticketId) {
|
|
|
+ // 检查是否取出钥匙去上锁，如果没有取到钥匙，但是取出了挂锁，说明有问题，则清空挂锁信息
|
|
|
+ JobTicketKeyDO one = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaQuery()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, ticketId)
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, 0)
|
|
|
+ .isNull(JobTicketKeyDO::getKeyId));
|
|
|
+ List<JobTicketLockDO> list = iIsJobTicketLockService.list(Wrappers.<JobTicketLockDO>lambdaQuery()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, ticketId)
|
|
|
+ .isNotNull(JobTicketLockDO::getLockId));
|
|
|
+ if (one != null && !list.isEmpty()) {
|
|
|
+ // 现在是上锁前检查，但是钥匙已经取出来了，有问题啊，现在开始置空
|
|
|
+ for (JobTicketLockDO isJobTicketLock : list) {
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getId, isJobTicketLock.getId())
|
|
|
+ .set(JobTicketLockDO::getLockId, null)
|
|
|
+ .set(JobTicketLockDO::getLockStatus, "0")
|
|
|
+ .set(JobTicketLockDO::getFromHardwareId, null)
|
|
|
+ );
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean checkBeforeToUnlock(Long ticketId) {
|
|
|
+ Assert.notNull(ticketId, "当前作业票id不能为空！");
|
|
|
+ // 1.查询当前作业票需要解锁的点位信息
|
|
|
+ List<JobTicketPointsDO> listByTicketId = iIsJobTicketPointsService.list(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, ticketId));
|
|
|
+ if (!listByTicketId.isEmpty()) {
|
|
|
+ // 如果存在冲突的作业，检查下到了哪个阶段（取了钥匙上锁还未归还、上锁钥匙已归还、取了钥匙去解锁未归还、解锁完成钥匙已归还）
|
|
|
+ List<Long> points = listByTicketId.stream().map(JobTicketPointsDO::getPointId).collect(Collectors.toList());
|
|
|
+ // 2.如果有重复点位，取了钥匙去上锁没有归还的作业
|
|
|
+ List<JobTicketDetailVO> jobTicketDetailVOS1 = isJobTicketService.selectConflictTicket1(points, ticketId);
|
|
|
+ if (!jobTicketDetailVOS1.isEmpty()) {
|
|
|
+ Assert.isFalse(true, "请等待作业票[" + jobTicketDetailVOS1.get(0).getTicketName() + "]上锁完成！");
|
|
|
+ }
|
|
|
+ // 3.如果取了钥匙去上锁已经归还，代表别的上锁已经完成，我可以解除不是重复的点位，然后手动完成作业，这样别人作业结束以后可以直接解除物理锁
|
|
|
+ // List<JobTicketDetailVO> jobTicketDetailVOS2 = isJobTicketService.selectConflictTicket2(points, ticketId);
|
|
|
+ // 4.如果别人取了钥匙去解锁，说明都是去解锁，我可以解全部
|
|
|
+
|
|
|
+ // 5.如果别人解除完了回来完成了作业，我可以解除全部
|
|
|
+ }
|
|
|
+ // 启动解锁
|
|
|
+ isTicketOperLogService.addLog8(ticketId, isJobTicketService.getById(ticketId).getTicketName());
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean updateCoincideToUnLock(CoincidePointToUnLockDTO dto) {
|
|
|
+ if (!dto.getNoUnlockTicketPointsVOSet().isEmpty()) {
|
|
|
+ Date date = new Date();
|
|
|
+ for (JobTicketPointsRespVO jobTicketPointsVO : dto.getNoUnlockTicketPointsVOSet()) {
|
|
|
+ iIsJobTicketPointsService.update(Wrappers.<JobTicketPointsDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketPointsDO::getId, jobTicketPointsVO.getId())
|
|
|
+ .set(JobTicketPointsDO::getUnlockedByKeyId, jobTicketPointsVO.getLockedByKeyId())
|
|
|
+ .set(JobTicketPointsDO::getUnlockTime, date)
|
|
|
+ .set(JobTicketPointsDO::getPointStatus, PointStatusEnum.REMOVE_LOCK.status));
|
|
|
+ // 3.1开始更新解锁时挂锁信息
|
|
|
+ iIsJobTicketLockService.update(Wrappers.<JobTicketLockDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketLockDO::getTicketId, jobTicketPointsVO.getTicketId())
|
|
|
+ .eq(JobTicketLockDO::getLockId, jobTicketPointsVO.getLockId())
|
|
|
+ .set(JobTicketLockDO::getLockStatus, LockStatusEnum.REMOVED_LOCK.status));
|
|
|
+ // 4.1如果都解锁了，则更新作业负责人的任务状态
|
|
|
+ int count = (int) iIsJobTicketPointsService.count(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, jobTicketPointsVO.getTicketId())
|
|
|
+ .ne(JobTicketPointsDO::getPointStatus, "2"));
|
|
|
+ if (count == 0) {
|
|
|
+ iIsJobTicketUserService.update(Wrappers.<JobTicketUserDO>lambdaUpdate()
|
|
|
+ .eq(JobTicketUserDO::getUserRole, isSystemAttributeService.getAttributeByKey("role.jtlocker").getSysAttrValue())
|
|
|
+ .eq(JobTicketUserDO::getTicketId, jobTicketPointsVO.getTicketId())
|
|
|
+ .set(JobTicketUserDO::getJobStatus, "5"));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Transactional
|
|
|
+ @Override
|
|
|
+ public Boolean updateHardwareEsStatus(ExDTO dto) {
|
|
|
+ // 1.开始更新钥匙
|
|
|
+ if (!dto.getKeyExDTOList().isEmpty()) {
|
|
|
+ List<String> keyNfcList = dto.getKeyExDTOList().stream().map(IsKeyExDTO::getKeyNfc).collect(Collectors.toList());
|
|
|
+ List<KeyDO> isKeyList = isKeyService.list(Wrappers.<KeyDO>lambdaQuery()
|
|
|
+ .in(KeyDO::getKeyNfc, keyNfcList));
|
|
|
+ for (KeyDO isKey : isKeyList) {
|
|
|
+ for (IsKeyExDTO isKeyExDTO : dto.getKeyExDTOList()) {
|
|
|
+ if (isKey.getKeyNfc().equals(isKeyExDTO.getKeyNfc())) {
|
|
|
+ isKey.setExStatus(isKeyExDTO.getExStatus());
|
|
|
+ isKey.setExRemark(isKeyExDTO.getExRemark());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ isKeyService.updateBatchById(isKeyList);
|
|
|
+ }
|
|
|
+ // 2.开始更新挂锁
|
|
|
+ if (!dto.getLockExDTOList().isEmpty()) {
|
|
|
+ List<String> lockNfcList = dto.getLockExDTOList().stream().map(IsLockExDTO::getLockNfc).collect(Collectors.toList());
|
|
|
+ List<LockDO> isLockList = iIsLockService.list(Wrappers.<LockDO>lambdaQuery()
|
|
|
+ .in(LockDO::getLockNfc, lockNfcList));
|
|
|
+ for (LockDO isLock : isLockList) {
|
|
|
+ for (IsLockExDTO isLockExDTO : dto.getLockExDTOList()) {
|
|
|
+ if (isLock.getLockNfc().equals(isLockExDTO.getLockNfc())) {
|
|
|
+ isLock.setExStatus(isLockExDTO.getExStatus());
|
|
|
+ isLock.setExRemark(isLockExDTO.getExRemark());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ iIsLockService.updateBatchById(isLockList);
|
|
|
+ }
|
|
|
+ // 3.开始更新工卡
|
|
|
+ if (!dto.getJobCardExDTOList().isEmpty()) {
|
|
|
+ List<String> cardNfcList = dto.getJobCardExDTOList().stream().map(IsJobCardExDTO::getCardNfc).collect(Collectors.toList());
|
|
|
+ List<JobCardDO> cardList = iIsJobCardService.list(Wrappers.<JobCardDO>lambdaQuery()
|
|
|
+ .in(JobCardDO::getCardNfc, cardNfcList));
|
|
|
+ for (JobCardDO isJobCard : cardList) {
|
|
|
+ for (IsJobCardExDTO isJobCardExDTO : dto.getJobCardExDTOList()) {
|
|
|
+ if (isJobCard.getCardNfc().equals(isJobCardExDTO.getCardNfc())) {
|
|
|
+ isJobCard.setExStatus(isJobCardExDTO.getExStatus());
|
|
|
+ isJobCard.setExRemark(isJobCardExDTO.getExRemark());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ iIsJobCardService.updateBatchById(cardList);
|
|
|
+ }
|
|
|
+ // 4.开始更新锁仓
|
|
|
+ if (!dto.getSlotsExDTOList().isEmpty()) {
|
|
|
+ for (IsLockCabinetSlotsExDTO slotsExDTO : dto.getSlotsExDTOList()) {
|
|
|
+ if (StringUtils.isNotBlank(slotsExDTO.getRow()) && StringUtils.isNotBlank(slotsExDTO.getCol())) {
|
|
|
+ iIsLockCabinetSlotsService.update(Wrappers.<LockCabinetSlotsDO>lambdaUpdate()
|
|
|
+ .eq(LockCabinetSlotsDO::getRow, slotsExDTO.getRow())
|
|
|
+ .eq(LockCabinetSlotsDO::getCol, slotsExDTO.getCol())
|
|
|
+ .set(LockCabinetSlotsDO::getStatus, slotsExDTO.getStatus())
|
|
|
+ .set(LockCabinetSlotsDO::getRemark, slotsExDTO.getRemark()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public Boolean getMySelfState() {
|
|
|
+ // 当前登陆人
|
|
|
+ Long userId = getLoginUserId();
|
|
|
+ // 获取当前登陆人未完成的作业
|
|
|
+ List<JobTicketUserDO> myJobs = iIsJobTicketUserService.getMyJob(userId);
|
|
|
+ System.out.println("myJobs=" + myJobs.toString());
|
|
|
+ if (myJobs.isEmpty()) {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ // 如果有，检查一下这个人是否是需要去上锁
|
|
|
+ for (JobTicketUserDO myJob : myJobs) {
|
|
|
+ List<JobTicketStepDO> steps = iIsJobTicketStepService.list(Wrappers.<JobTicketStepDO>lambdaQuery()
|
|
|
+ .eq(JobTicketStepDO::getTicketId, myJob.getTicketId())
|
|
|
+ .eq(JobTicketStepDO::getStepIndex, "5")
|
|
|
+ .eq(JobTicketStepDO::getStepStatus, "0"));
|
|
|
+ System.out.println("steps=" + steps.toString());
|
|
|
+ if (!steps.isEmpty()) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ // 检查是否有需要解锁的，如果共锁人都已经解锁，但是点位存在没解锁
|
|
|
+ for (JobTicketUserDO myJob : myJobs) {
|
|
|
+ List<JobTicketUserDO> list = iIsJobTicketUserService.list(Wrappers.<JobTicketUserDO>lambdaQuery()
|
|
|
+ .eq(JobTicketUserDO::getTicketId, myJob.getTicketId())
|
|
|
+ .eq(JobTicketUserDO::getUserRole, JobUserEnum.JTCOLOCKER)
|
|
|
+ .eq(JobTicketUserDO::getJobStatus, "5"));
|
|
|
+ List<JobTicketPointsDO> list1 = iIsJobTicketPointsService.list(Wrappers.<JobTicketPointsDO>lambdaQuery()
|
|
|
+ .eq(JobTicketPointsDO::getTicketId, myJob.getTicketId())
|
|
|
+ .eq(JobTicketPointsDO::getPointStatus, "1"));
|
|
|
+ System.out.println("list=" + list.toString() + "----------list1=" + list1.toString());
|
|
|
+ if (list.isEmpty() && !list1.isEmpty()) {
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 判断挂锁关联作业处于哪个阶段 0-上锁未取钥匙(可锁-需更改还锁逻辑) 1-上锁取了钥匙(不可锁) 2-上锁归还了钥匙(可锁) 3-解锁取了钥匙(可锁) 4-解锁归还了钥匙(可锁) 5-和作业无关(可锁)
|
|
|
+ *
|
|
|
+ * @param nfc
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ @Override
|
|
|
+ public Integer getLockStateByNfc(String nfc, Long ticketId) {
|
|
|
+ Assert.notBlank(nfc, "该锁nfc不能为空！");
|
|
|
+ // 查询当前锁是否存在
|
|
|
+ LockDO lock = iIsLockService.getOne(Wrappers.<LockDO>lambdaQuery()
|
|
|
+ .eq(LockDO::getLockNfc, nfc));
|
|
|
+ Assert.isFalse(lock == null, nfc + "对应的挂锁数据不存在！");
|
|
|
+ // 查询这个挂锁有没有不是完成或者取消的作业，然后判断作业能不能
|
|
|
+ JobTicketLockDO lockJobByBfc = iIsJobTicketLockService.getLockJobByBfc(nfc, ticketId);
|
|
|
+ if (lockJobByBfc != null) {
|
|
|
+ // 判断作业到了什么阶段
|
|
|
+ // 获取上锁时钥匙的最新一条数据
|
|
|
+ JobTicketKeyDO lockLast = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaQuery()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, lockJobByBfc.getTicketId())
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, 0)
|
|
|
+ .orderByDesc(JobTicketKeyDO::getId)
|
|
|
+ .last("limit 1"));
|
|
|
+ // 获取解锁时钥匙的最新一条数据
|
|
|
+ JobTicketKeyDO unlockLast = iIsJobTicketKeyService.getOne(Wrappers.<JobTicketKeyDO>lambdaQuery()
|
|
|
+ .eq(JobTicketKeyDO::getTicketId, lockJobByBfc.getTicketId())
|
|
|
+ .eq(JobTicketKeyDO::getTicketType, 1)
|
|
|
+ .orderByDesc(JobTicketKeyDO::getId)
|
|
|
+ .last("limit 1"));
|
|
|
+ // 判断阶段
|
|
|
+ if (lockLast.getKeyStatus().equals("0")) {
|
|
|
+ return 0;
|
|
|
+ } else if (lockLast.getKeyStatus().equals("1")) {
|
|
|
+ return 1;
|
|
|
+ } else if (lockLast.getKeyStatus().equals("2") && unlockLast.getKeyStatus().equals("0")) {
|
|
|
+ return 2;
|
|
|
+ } else if (unlockLast.getKeyStatus().equals("1")) {
|
|
|
+ return 3;
|
|
|
+ } else if (unlockLast.getKeyStatus().equals("2")) {
|
|
|
+ return 4;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return 5;
|
|
|
+ }
|
|
|
+}
|
