更新

whycxzp

2025-03-26 fca1721e4ef9d92242942f6151d026400ab9bd0b

更新

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

@@ -2,6 +2,7 @@

import com.whyc.dto.Response;
import com.whyc.dto.WmsPalletDto;
import com.whyc.pojo.db_wms.Task;
import com.whyc.service.WmsService;
import io.swagger.annotations.Api;
import org.springframework.beans.factory.annotation.Autowired;
@@ -60,4 +61,14 @@
        return service.getPalletList();
    }

    /**
     * 提供给第三方的接口,用于接收任务状态
     * @param task
     * @return
     */
    @PostMapping("sendTaskStatus")
    public Response sendTaskStatus(@RequestBody Task task){
        return service.sendTaskStatus(task);
    }

}

 src/main/java/com/whyc/pojo/db_batt/PowerInf.java

@@ -23,7 +23,7 @@
@TableName(schema = "db_batt",value = "power_inf")
public class PowerInf {

    @TableId(type = IdType.AUTO)
    @TableId(type = IdType.AUTO,value = "power_id")
    @ApiModelProperty("电源id")
    private Integer powerId;

@@ -82,15 +82,19 @@
    private Float loadCurr;

    @ApiModelProperty("sip编号")
    @TableField("sip_num")
    private String sipNum;

    @ApiModelProperty("视频流频道数")
    @TableField("channel_count")
    private Integer channelCount;

    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @TableField("create_time")
    private Date createTime;

    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    @TableField("update_time")
    private Date updateTime;

    @TableField(exist = false)

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

@@ -110,19 +110,21 @@
        }
        //电源id查询最大值
        int powerId = mapper.getMaxPowerId();
        powerInf.setPowerId(powerId);
        powerInf.setPowerId(powerId+1);
        //对站点名称进行查询,如果存在则直接绑定关系
        //如果不存在,则新增后,再绑定关系
        StationInf stationInf = stationInfService.getByStationName(powerInf.getStationName());
        Integer stationId = stationInf.getSinfId();
        if(stationInf == null){
            StationInf stationNew = new StationInf();
            stationNew.setSinfName(powerInf.getStationName());
            int stationId = stationInfService.getMaxStationId();
            stationNew.setSinfId(stationId+1);
            int stationIdInDB = stationInfService.getMaxStationId();
            stationId = stationIdInDB + 1;
            stationNew.setSinfId(stationId);
            stationInfService.add(stationNew);
        }
            //站点和电源id关联
            stationPowerRelationService.add(stationId,powerId);
        }
        mapper.insert(powerInf);
        return new Response().setII(1,"新增完成");
    }

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

@@ -107,4 +107,17 @@
        }
        return response;
    }

    public Response sendTaskStatus(Task task) {
        //对接收到的任务进行逻辑判断和数据存储
        /*String taskNo = task.getTaskNo();
        Integer status = task.getStatus();
        if(status == 13 || status == 23){ //电池放置在活化仓内
            task.setExecuteTime(task.getStatusTime());
        }else if(status == 14 || status == 24){
            task.setExecuteEndTime(task.getStatusTime());
        }*/

        return null;
    }
}

 src/main/resources/mapper/PowerInfMapper.xml

@@ -3,9 +3,9 @@
<mapper namespace="com.whyc.mapper.PowerInfMapper" >

    <select id="selectMaxBattGroupId" resultType="java.lang.Integer">
        select max(binf_id) from power_inf
        select max(binf_id) from db_batt.power_inf
    </select>
    <select id="getMaxPowerId" resultType="java.lang.Integer">
        select max(power_id) from power_inf
        select max(power_id) from db_batt.power_inf
    </select>
</mapper>