站点任务功能优化

skyouc

2 天以前 ceab656e93edafbdaa0d908a2f723336af811b5a

 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskSchedules.java

@@ -240,8 +240,8 @@
     * @throws Exception
     */
    @Scheduled(cron = "0/5 * * * * ?  ")
    @Transactional(rollbackFor = Exception.class)
    public void taskToWCS() throws Exception {

    public void taskToWCS() {
        Long loginUserId = SystemAuthUtils.getLoginUserId();
        List<Integer> list = Arrays.asList(TaskType.TASK_TYPE_IN.type, TaskType.TASK_TYPE_OUT.type, TaskType.TASK_TYPE_LOC_MOVE.type, TaskType.TASK_TYPE_EMPITY_IN.type
        ,TaskType.TASK_TYPE_CHECK_IN.type, TaskType.TASK_TYPE_MERGE_IN.type, TaskType.TASK_TYPE_EMPITY_OUT.type,
@@ -278,7 +278,11 @@
//                }
//            }
            //TODO 调用下发任务接口
            try {
            pubTaskToWcs(task);
            } catch (Exception e) {
                log.error(e.getMessage());
            }
        }
    }

@@ -307,10 +311,11 @@

    /**
     * 下发任务至WCS
     *
     * @param task
     */
    @Transactional(rollbackFor = Exception.class)
    public void pubTaskToWcs(Task task) throws Exception{
    public void pubTaskToWcs(Task task) {
        WcsTaskParams taskParams = new WcsTaskParams();
        TaskItemParam itemParam = new TaskItemParam();
        //任务类型，任务编码
@@ -360,10 +365,10 @@
        if (Objects.isNull(exchange.getBody())) {
            throw new CoolException("任务下发失败！！");
        } else {
            try {
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.coercionConfigDefaults()
                    .setCoercion(CoercionInputShape.EmptyString, CoercionAction.AsEmpty);
            try {
                CommonResponse result = objectMapper.readValue(exchange.getBody(), CommonResponse.class);
                if (result.getCode() == 200) {
                    if (task.getTaskType().equals(TaskType.TASK_TYPE_IN.type)
@@ -387,7 +392,6 @@
                            throw new CoolException("任务状态修改失败！！");
                        }
                    }

                } else {
                    throw new CoolException("任务下发失败！！");
                }