入库任务

whycxzp

2025-04-18 b9e6c20168ddb9d8b0d6e7278e0b591f58319b56

入库任务

 src/main/java/com/whyc/controller/InterfaceWmsController.java

@@ -3,6 +3,7 @@
import com.whyc.dto.Response;
import com.whyc.dto.TaskDto;
import com.whyc.dto.WmsPalletDto;
import com.whyc.dto.WmsTaskDto;
import com.whyc.pojo.db_wms.Task;
import com.whyc.service.WmsService;
import io.swagger.annotations.Api;
@@ -41,6 +42,17 @@
    }

    /**
     * 下发入库任务
     * @param taskDto
     * @return
     */
    @PostMapping("sendTaskInbound")
    public Response sendTaskInbound(@RequestBody WmsTaskDto taskDto){

        return service.sendTaskInbound(taskDto);
    }

    /**
     * 任务状态上报接口
     * TODO 待现场确认含义 API名称    上层系统提供
     */

 src/main/java/com/whyc/dto/WmsTaskDto.java

New file
@@ -0,0 +1,13 @@
package com.whyc.dto;

import lombok.Data;
import lombok.ToString;

@Data
@ToString
public class WmsTaskDto {

    private Integer type;
    private String startlocation_code;
    private String pallet_code;
}

 src/main/java/com/whyc/dto/WmsTaskResponse.java

New file
@@ -0,0 +1,17 @@
package com.whyc.dto;

import lombok.Data;
import lombok.ToString;

import java.util.LinkedList;

@ToString
@Data
public class WmsTaskResponse<T> {
    private Integer code;
    private String message;
    private T data;
    /**任务编号*/
    private String task_no;

}

 src/main/java/com/whyc/service/WmsService.java

@@ -92,6 +92,39 @@
        return response;
    }

    public Response sendTaskInbound(WmsTaskDto taskDto) {
        String httpUrl = "http://192.168.10.133:8051"+"/api/wms_task/inbound";
        Response response = HttpUtil.doPost(httpUrl, JsonUtil.getGson().toJson(taskDto));
        //对结果进行处理
        if(response.getCode() == 1){ //请求成功,data有正常数据
            String dataStr = (String) response.getData();
            WmsTaskResponse responseInside = JsonUtil.getGson().fromJson(dataStr, WmsTaskResponse.class);
            response.set(1,responseInside);
            if(responseInside.getCode() ==0) {
                //对下发的任务进行数据库存储
                Date date = new Date();
                String pallet = taskDto.getPallet_code();
                String startLocationCode = taskDto.getStartlocation_code();
                //1=搬运空托,2=搬运电池. 转化到字段Des中,1001=搬运空托,1002=搬运电池
                Integer type = taskDto.getType();
                String taskNo = responseInside.getTask_no();

                Task task = new Task();
                task.setTaskNo(taskNo);
                task.setPallets(pallet);
                task.setStartLocationCode(startLocationCode);
                task.setDes(type ==1?1001:1002);

                task.setCreateTime(date);

                taskService.add(task);


            }
        }
        return response;
    }

    public Response getLocationList() {
        String httpUrl = "http://192.168.10.133:8051"+"/api/wms_location/get_all";
        Response response = HttpUtil.doGet(httpUrl, (String) null);