From 611a816801c58abcc81d511a7dfc368f8d8fb24e Mon Sep 17 00:00:00 2001 From: zhangchao <zc857179121@qq.com> Date: 星期五, 22 十一月 2024 14:16:59 +0800 Subject: [PATCH] 修改定时任务触发方式,不是以固定时间执行,以执行完成任务,间隔多少时间在此执行 --- src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java | 54 +++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 53 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java b/src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java index 336a9e6..885fb64 100644 --- a/src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java +++ b/src/main/java/com/zy/asrs/mapper/AgvBasDevpMapper.java @@ -2,15 +2,67 @@ import com.baomidou.mybatisplus.mapper.BaseMapper; import com.zy.asrs.entity.AgvBasDevp; -import com.zy.asrs.entity.BasDevp; +import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; import org.springframework.stereotype.Repository; import java.util.List; +import java.util.Map; @Mapper @Repository public interface AgvBasDevpMapper extends BaseMapper<AgvBasDevp> { + @Delete("delete from agv_bas_devp") + void deleteAll(); + + @Select("select dev_no from agv_bas_devp where loc_sts = 'O'") + List<String> getAvailableEmptyInSite(); + + @Select("select station_code from agv_bas_devp where cache_shelves = 'N' and in_enable = 'Y' group by station_code") + List<String> selectCacheShelvesStationCodeByFloor(@Param("floor") int floor); + + //@Select("select dev_no from agv_bas_devp where loc_type1 = #{locType} and out_enable = 'Y'") + @Select("SELECT\n" + + "\tdev_no \n" + + "FROM\n" + + "\tagv_bas_devp\n" + + "\tLEFT JOIN agv_wrk_mast ON agv_bas_devp.dev_no = agv_wrk_mast.loc_no \n" + + "WHERE\n" + + "\tagv_wrk_mast.loc_no IS NULL \n" + + "\tAND agv_bas_devp.loc_type1 = #{locType} \n" + + "\tAND agv_bas_devp.floor = #{floor} \n" + + "\tAND agv_bas_devp.out_enable = 'Y'") + List<String> selectCacheShelvesStationCodeByLocType(@Param("locType") Short locType, @Param("floor") int floor); + + @Select("SELECT\n" + + "\tdev_no \n" + + "FROM\n" + + "\tagv_bas_devp\n" + + "\tLEFT JOIN agv_wrk_mast ON agv_bas_devp.dev_no = agv_wrk_mast.source_loc_no \n" + + "WHERE\n" + + "\tagv_wrk_mast.loc_no IS NULL \n" + + "\tAND agv_bas_devp.loc_type1 = #{locType} \n" + + "\tAND agv_bas_devp.floor = #{floor} \n" + + "\tAND agv_bas_devp.out_enable = 'Y'") + List<String> selectCacheShelvesStationCodeByLocType2(@Param("locType") Short locType, @Param("floor") int floor); + + @Select("SELECT\n" + + "\tbas.dev_no,\n" + + "\tCOUNT ( mast.loc_no ) AS num \n" + + "FROM\n" + + "\tagv_bas_devp bas\n" + + "\tLEFT JOIN agv_wrk_mast mast ON bas.dev_no = mast.loc_no \n" + + "WHERE\n" + + "\tbas.station_code = #{stationCode} AND bas.loc_sts != 'X' \n" + + "GROUP BY\n" + + "\tbas.dev_no \n" + + "ORDER BY\n" + + "\tnum") + List<Map<String,Object>> selectDevNoAndNumBystationCode(@Param("stationCode") String stationCode); + + @Select("select station_code from agv_bas_devp group by station_code") + List<String> selectAllStationCode(); } -- Gitblit v1.9.1