rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/PdaCheckOrderServiceImpl.java
@@ -17,6 +17,7 @@ import com.vincent.rsf.server.manager.enums.*; import com.vincent.rsf.server.manager.service.*; import com.vincent.rsf.server.system.constant.DictTypeCode; import com.vincent.rsf.server.system.constant.SerialRuleCode; import com.vincent.rsf.server.system.entity.DictData; import com.vincent.rsf.server.system.entity.FieldsItem; import com.vincent.rsf.server.system.entity.User; @@ -26,6 +27,7 @@ import com.vincent.rsf.server.system.service.UserService; import com.vincent.rsf.server.system.service.impl.FieldsItemServiceImpl; import com.vincent.rsf.server.system.service.impl.UserServiceImpl; import com.vincent.rsf.server.system.utils.SerialRuleUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -391,12 +393,14 @@ if (!task.getTaskStatus().equals(TaskStsType.WAVE_SEED.id)) { return R.error("任务状态不是等待确认"); } //任务号不能重复,生成新任务号下发至RCS String ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TASK_CODE, null); task.setTaskStatus(TaskStsType.GENERATE_IN.id) .setTaskCode(ruleCode) .setTargLoc(task.getOrgLoc()) .setTaskType(TaskType.TASK_TYPE_CHECK_IN.type) .setUpdateTime(new Date()); if (!taskService.updateById(task)) { throw new CoolException("任务状态修改失败!!"); } rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java
@@ -249,6 +249,7 @@ params.setAction("Update").setOrderType("PD_stock"); HttpEntity httpEntity = new HttpEntity(params, headers); ResponseEntity<String> exchange = restTemplate.exchange(rcsUrl, HttpMethod.POST, httpEntity, String.class); log.info("盘点库存修改,返回结果: {}", exchange); if (Objects.isNull(exchange.getBody())) { rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CheckOrderSchedules.java
@@ -47,7 +47,7 @@ * @description: 自动获取已生成盘点任务的盘点列表 * @version 1.0 */ @Scheduled(cron = "0/15 * * * * ?") // @Scheduled(cron = "0/15 * * * * ?") @Transactional(rollbackFor = Exception.class) public void genReCheck() { List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>() rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
@@ -1492,7 +1492,6 @@ CommonResponse result = objectMapper.readValue(exchange.getBody(), CommonResponse.class); if (result.getCode() == 200) { tasks.forEach(task -> { if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_PICK_IN.type) || task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)