任务下发接口更新

whycxzp

2025-03-25 921b909c2cdebb8e387e578169a53b3f41556828

任务下发接口更新

 src/main/java/com/whyc/mapper/TaskMapper.java

New file
@@ -0,0 +1,8 @@
package com.whyc.mapper;

import com.whyc.pojo.db_wms.Task;
import org.apache.ibatis.annotations.Insert;

public interface TaskMapper extends CustomMapper<Task>{

}

 src/main/java/com/whyc/pojo/db_wms/Task.java

@@ -6,6 +6,7 @@
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.ToString;
import org.springframework.format.annotation.DateTimeFormat;

import java.util.Date;

@@ -18,7 +19,7 @@
@ToString
public class Task {

    @TableId(type = IdType.AUTO)
    @TableId(type = IdType.AUTO,value = "id")
    private Integer id;
    @ApiModelProperty(value = "任务编号")
    private String taskNo;
@@ -36,14 +37,19 @@
    private String endLocationCode;
    @ApiModelProperty(value = "状态：1=开始取货、2=取货完成、4=放货完成； 11=开始取活化电池、12=取到活化电池、13=活化电池放置到活化仓内、14=开始取活化结束的电池、15=取到活化结束的电池、16=活化返库完成； 21=开始取测压电池、22=取到测压电池、23=测压电池放置到活化仓内、24=开始取测压结束的电池、25=取到测压结束的电池、26=测压返库完成")
    private Integer status;
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "状态时间")
    private Date statusTime;
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "活化或者测压动作的开始时间")
    private Date executeTime;
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "活化或者测压动作的结束时间")
    private Date executeEndTime;
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "创建时间")
    private Date createTime;
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @ApiModelProperty(value = "完成时间")
    private Date endTime;


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

New file
@@ -0,0 +1,18 @@
package com.whyc.service;

import com.whyc.mapper.TaskMapper;
import com.whyc.pojo.db_wms.Task;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class TaskService {

    @Resource
    private TaskMapper mapper;

    public void add(Task task) {
        mapper.insert(task);
    }
}

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

@@ -2,14 +2,22 @@

import com.google.gson.reflect.TypeToken;
import com.whyc.dto.*;
import com.whyc.pojo.db_wms.Task;
import com.whyc.util.HttpUtil;
import com.whyc.util.JsonUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class WmsService {

    @Autowired
    private TaskService taskService;

    public Response getMaterialList() {
        String httpUrl = "http://192.168.10.133:8051"+"/api/Wms_material/get_all";
@@ -48,6 +56,21 @@
            WmsResponse responseInside = JsonUtil.getGson().fromJson(dataStr, WmsResponse.class);
            response.set(1,responseInside);
            //对下发的任务进行数据库存储
            Task task = new Task();
            task.setTaskNo(responseInside.getTask_no());
            task.setDes(palletDto.getDes());
            //将字符串列表转为1组字符串,每个元素用逗号分割
            List<String> pallets = palletDto.getPallets();
            task.setPallets(String.join(",", pallets));

            List<String> activateParameter = palletDto.getActivateParameter();
            task.setActivateParameter(String.join(",",activateParameter));

            Date date = new Date();
            task.setCreateTime(date);

            taskService.add(task);


        }
        return response;