From 71594bd2dc9201834aa533099e9e49a9b84506cd Mon Sep 17 00:00:00 2001 From: wangfei <3597712270@qq.com> Date: 星期四, 12 六月 2025 15:32:25 +0800 Subject: [PATCH] 新增韩语 --- hangzhoumesParent/common/servicebase/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java | 102 ++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 97 insertions(+), 5 deletions(-) diff --git a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java index f5c0ad9..6ee1204 100644 --- a/hangzhoumesParent/common/servicebase/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java +++ b/hangzhoumesParent/common/servicebase/src/main/java/com/mes/rawglasstask/service/impl/RawGlassRawGlassStorageTaskServiceImpl.java @@ -2,7 +2,13 @@ import cn.hutool.core.collection.CollectionUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.mes.common.config.Const; +import com.mes.rawglassdetails.entity.RawGlassStorageDetails; +import com.mes.rawglassdetails.service.RawGlassStorageDetailsService; +import com.mes.rawglassstation.entity.RawGlassStorageStation; import com.mes.rawglasstask.entity.RawGlassStorageTask; import com.mes.rawglasstask.entity.request.RawGlassTaskRequest; import com.mes.rawglasstask.mapper.RawGlassStorageTaskMapper; @@ -13,6 +19,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.Date; import java.util.List; /** @@ -25,6 +33,24 @@ @Autowired RedisUtil redisUtil; + + @Resource + RawGlassStorageDetailsService rawGlassStorageDetailsService; + + @Override + public Page<RawGlassStorageTask> queryRawGlassHistoryTask(RawGlassTaskRequest request) { + if (request.getBeginDate() == null) { + //璁剧疆榛樿鏃堕棿 startDate锛氬紑濮嬫椂闂� endDate锛氱粨鏉熸椂闂� + request.setBeginDate(DateUtil.getBeginDate()); + request.setEndDate(DateUtil.getEndDate()); + } + Page<RawGlassStorageTask> page = new Page<>(request.getPageNo(), request.getPageSize()); + return page(page, new LambdaQueryWrapper<RawGlassStorageTask>() + .between(RawGlassStorageTask::getCreateTime, request.getBeginDate(), request.getEndDate()) + .in(CollectionUtil.isNotEmpty(request.getTaskState()), RawGlassStorageTask::getTaskState, request.getTaskState()) + .in(CollectionUtil.isNotEmpty(request.getTaskType()), RawGlassStorageTask::getTaskType, request.getTaskType()) + .orderByDesc(RawGlassStorageTask::getCreateTime)); + } @Override public List<RawGlassStorageTask> listRawGlassTask() { @@ -43,11 +69,6 @@ .in(CollectionUtil.isNotEmpty(request.getTaskType()), RawGlassStorageTask::getTaskType, request.getTaskType()) .orderByDesc(RawGlassStorageTask::getCreateTime)); -// return list(new QueryWrapper<RawGlassStorageTask>() -// .in(CollectionUtil.isNotEmpty(request.getTaskState()), "task_state", request.getTaskState()) -// .in(CollectionUtil.isNotEmpty(request.getTaskType()), "task_type", request.getTaskType()) -// .between("create_time", request.getBeginDate(), request.getEndDate()) -// .orderByDesc("create_time")); } @Override @@ -60,4 +81,75 @@ log.info("鍓嶇浼犲叆鍙傛暟锛歿}", request); return "success"; } + + @Override + public Boolean taskSuccess(Long taskId) { + //鑾峰彇浠诲姟姝e湪鎵ц鐨勪换鍔′俊鎭� + RawGlassStorageTask task = this.getById(taskId); + //鍘昏鎯呰〃鑾峰彇姝e湪鎵ц鐨勫師鐗囪鎯呬俊鎭� + RawGlassStorageDetails details = rawGlassStorageDetailsService.getOne(new LambdaQueryWrapper<RawGlassStorageDetails>() + .ne(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_OUT).eq(RawGlassStorageDetails::getSlot, task.getStartSlot()) + ); + if(details!=null){ + RawGlassStorageDetails targetDetails = rawGlassStorageDetailsService.generateDetails(details, task.getEndSlot()); + int deviceId = details.getDeviceId(); + Integer taskType = task.getTaskType(); + log.info("灏嗚鎯呰〃鐨勭姸鎬佹敼涓哄凡鍑哄簱"); + rawGlassStorageDetailsService.update(new LambdaUpdateWrapper<RawGlassStorageDetails>() + .set(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_OUT) + .ne(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_OUT) + .eq(RawGlassStorageDetails::getSlot, task.getStartSlot())); + log.info("浠诲姟鐘舵�佸凡鏇存敼涓猴細宸插畬鎴�"); + this.update(new LambdaUpdateWrapper<RawGlassStorageTask>() + .eq(RawGlassStorageTask::getTaskState, Const.RAW_GLASS_TASK_NEW) + .set(RawGlassStorageTask::getTaskState, Const.RAW_GLASS_TASK_SUCCESS)); + switch (taskType) { + case 1: + case 3: + log.info("1銆佸叆搴擄紝3銆佽皟搴︿换鍔°�倇}", taskType); + if (details.getRemainQuantity() > 0) { + rawGlassStorageDetailsService.save(targetDetails); + } + break; + case 2: + case 4: + log.info("2銆佸嚭鐗�,4銆佸叆搴撹姹傘�倇}", taskType); + targetDetails = new RawGlassStorageDetails(); + targetDetails.setSlot(task.getEndSlot()); + targetDetails.setDeviceId(deviceId); + targetDetails.setShelf(task.getStartSlot()); + targetDetails.setState(Const.RAW_GLASS_STATE_IN); + rawGlassStorageDetailsService.save(targetDetails); + break; + default: + break; + } + } + return Boolean.TRUE; + } + + + @Override + public Boolean taskError(Long taskId) { + //鑾峰彇浠诲姟姝e湪鎵ц鐨勪换鍔′俊鎭� + RawGlassStorageTask task = this.getById(taskId); + Integer taskType = task.getTaskType(); + if (taskType.equals(Const.RAW_GLASS_TASK_TYPE_IN_REQUEST)) { + rawGlassStorageDetailsService.update(new LambdaUpdateWrapper<RawGlassStorageDetails>() + .set(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_OUT) + .eq(RawGlassStorageDetails::getSlot, task.getStartSlot()) + .in(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_RUNNING, Const.RAW_GLASS_STATE_CAR)); + } else { + rawGlassStorageDetailsService.update(new LambdaUpdateWrapper<RawGlassStorageDetails>() + .set(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_IN) + .eq(RawGlassStorageDetails::getSlot, task.getStartSlot()) + .in(RawGlassStorageDetails::getState, Const.RAW_GLASS_STATE_RUNNING, Const.RAW_GLASS_STATE_CAR)); + } + this.update(new LambdaUpdateWrapper<RawGlassStorageTask>() + .eq(RawGlassStorageTask::getTaskState, Const.RAW_GLASS_TASK_NEW) + .set(RawGlassStorageTask::getTaskState, Const.RAW_GLASS_TASK_FAILURE)); + return Boolean.TRUE; + } + + } \ No newline at end of file -- Gitblit v1.8.0