任务更新

This commit is contained in:
ldj_willow
2022-10-27 10:42:04 +08:00
parent 4ff5944d5d
commit dedaff7314
4 changed files with 164 additions and 0 deletions

View File

@@ -0,0 +1,45 @@
package org.nl.wms.sch.tasks.sb;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.nl.wms.sch.AcsTaskDto;
import org.nl.wms.sch.manage.AbstractAcsTask;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* 生箔呼叫空卷轴并送满料
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class SbCallEmptySendMaterialTask extends AbstractAcsTask {
private final String THIS_CLASS = SbCallEmptySendMaterialTask.class.getName();
@Override
public List<AcsTaskDto> addTask() {
return null;
}
@Override
public void updateTaskStatus(JSONObject taskObj, String status) {
}
@Override
public String createTask(JSONObject form) {
return null;
}
@Override
public void forceFinish(String task_id) {
}
@Override
public void cancel(String task_id) {
}
}

View File

@@ -0,0 +1,63 @@
package org.nl.wms.sch.tasks.sb;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.nl.modules.system.util.CodeUtil;
import org.nl.wms.sch.AcsTaskDto;
import org.nl.wms.sch.SchTaskDto;
import org.nl.wms.sch.manage.AbstractAcsTask;
import org.nl.wms.sch.manage.TaskStatusEnum;
import org.nl.wms.util.IdUtil;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* 生箔呼叫空卷轴
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class SbCallEmptyTask extends AbstractAcsTask {
private final String THIS_CLASS = SbCallEmptyTask.class.getName();
@Override
public List<AcsTaskDto> addTask() {
return null;
}
@Override
public void updateTaskStatus(JSONObject taskObj, String status) {
}
@Override
public String createTask(JSONObject form) {
SchTaskDto dto = SchTaskDto.builder().task_id(IdUtil.getLongId())
.task_code(CodeUtil.getNewCode("TASK_CODE"))
.task_type("")
.task_name("生箔呼叫空轴")
.task_status(TaskStatusEnum.SURE_END.getCode())
.point_code2("point_code2")
.acs_task_type("2")
.vehicle_code(form.getString("vehicle_code"))
.vehicle_qty(form.getIntValue("qty"))
.handle_class(THIS_CLASS)
.create_time(DateUtil.now())
.build();
return dto.getTask_id() + "";
}
@Override
public void forceFinish(String task_id) {
}
@Override
public void cancel(String task_id) {
}
}

View File

@@ -0,0 +1,45 @@
package org.nl.wms.sch.tasks.sb;
import com.alibaba.fastjson.JSONObject;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.nl.wms.sch.AcsTaskDto;
import org.nl.wms.sch.manage.AbstractAcsTask;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* 生箔送满料
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class SbSendFullTask extends AbstractAcsTask {
private final String THIS_CLASS = SbSendFullTask.class.getName();
@Override
public List<AcsTaskDto> addTask() {
return null;
}
@Override
public void updateTaskStatus(JSONObject taskObj, String status) {
}
@Override
public String createTask(JSONObject form) {
return null;
}
@Override
public void forceFinish(String task_id) {
}
@Override
public void cancel(String task_id) {
}
}

View File

@@ -0,0 +1,11 @@
package org.nl.wms.util;
public class IdUtil {
public static Long getLongId() {
return cn.hutool.core.util.IdUtil.getSnowflake(1, 1).nextId();
}
public static String getStringId() {
return String.valueOf(IdUtil.getLongId());
}
}