1

jyzb-biz/src/main/java/com/junmp/jyzb/mapper/ExpireMapper.java

-package com.junmp.jyzb.mapper;public class ExpireMapper {
+package com.junmp.jyzb.mapper;
+
+import com.junmp.jyzb.domain.Inventory;
+import org.apache.ibatis.annotations.MapKey;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+import java.util.Map;
+
+@Mapper
+public interface ExpireMapper {
+    @MapKey("id")
+    Map<String,Object> QueryTop1000ExpireInv();
+    @MapKey("id")
+    Map<String,Object> QueryExpireInv(@Param("currentNum")int currentNum,@Param("currentNum")int nextNum);
 }

jyzb-biz/src/main/java/com/junmp/jyzb/task/InvExpireMsg.java

-package com.junmp.jyzb.task;public class InvExpireMsg {
+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.api.util.GenCodeUtil;
+import com.junmp.jyzb.entity.Company;
+import com.junmp.jyzb.mapper.ExpireMapper;
+import com.junmp.jyzb.mapper.MsgMapper;
+import com.junmp.v2.common.util.BeanPlusUtil;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.Map;
+
+
+/**
+* @Author: Zhaojw
+* @Description: 过期物资消息提醒
+* @DateTime: 2023/7/14 16:25
+* @Params: 
+* @Return 
+*/
+@Slf4j
+@Component
+public class InvExpireMsg implements JobAction {
+
+    @Resource
+    private ExpireMapper ExpireMapper;
+    @Resource
+    private ExpireMapper InvertoryMapper;
+
+    @Override
+    public void action() {
+        Company company = new Company();
+//        int InvCount=
+        Map<String,Object> oneMsg = ExpireMapper.QueryTop1000ExpireInv();
+
+    }
 }

jyzb-biz/src/main/resources/mapper/ExpireMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.junmp.junmpProcess.mapper.OrgUserMapper">
-    <resultMap id="UserListDTO" type="com.junmp.junmpProcess.dto.UserListDTO">
-        <!--@mbg.generated-->
-        <!--@Table base_cabinet-->
-        <result column="user_id" jdbcType="VARCHAR" property="userID" />
-        <result column="real_name" jdbcType="VARCHAR" property="realName" />
-    </resultMap>
+<mapper namespace="com.junmp.jyzb.mapper.ExpireMapper">
+<!--    <resultMap id="BaseResultMap" type="com.junmp.jyzb.domain.Inventory">-->
+<!--        &lt;!&ndash;@mbg.generated&ndash;&gt;-->
+<!--        &lt;!&ndash;@Table base_equipment_size&ndash;&gt;-->
+<!--        <id column="id" jdbcType="VARCHAR" property="id" />-->
+<!--        <result column="type_id" jdbcType="VARCHAR" property="typeId" />-->
+<!--        <result column="state" jdbcType="VARCHAR" property="state" />-->
+<!--        <result column="production_date" jdbcType="DATE" property="productionDate" />-->
+<!--        <result column="org_id_int" jdbcType="VARCHAR" property="orgId" />-->
+<!--        <result column="warranty_period" jdbcType="INTEGER" property="warrantyPeriod" />-->
+<!--        <result column="maintenance_period" jdbcType="INTEGER" property="maintenancePeriod" />-->
+<!--        <result column="note" jdbcType="VARCHAR" property="note" />-->
 
-    <select id="QueryUserByRoleId"   resultMap="UserListDTO">
-        SELECT su.user_id,su.real_name FROM `sys_role` sr  join sys_user_role sur on  sr.role_id=sur.role_id  JOIN sys_user su on sur.user_id=su.user_id
-        where sr.role_id in ${roleId}
-        GROUP BY su.user_id,su.real_name
+<!--    </resultMap>-->
+    <select id="QueryTop1000ExpireInv"   resultType="Map">
+        SELECT *
+        FROM base_inventory
+        WHERE DATE_ADD(production_date, INTERVAL warranty_period DAY) &lt; CURDATE()
+        LIMIT 1000; -- 获取第一页的1000条记录
     </select>
-
-    <select id="QueryUserByRoleIdAndOrg"   resultMap="UserListDTO">
-        SELECT su.user_id,su.real_name FROM `sys_role` sr  join sys_user_role sur on  sr.role_id=sur.role_id  JOIN sys_user su on sur.user_id=su.user_id
-        join sys_user_org suo on suo.user_id=su.user_id join pub_org po on po.org_id=suo.org_id
-        where sr.role_id in ${roleId} and po.org_id in ${orgId}
-        GROUP BY su.user_id,su.real_name
+    <select id="QueryExpireInv"   resultType="Map">
+        SELECT *
+        FROM base_inventory
+        WHERE DATE_ADD(production_date, INTERVAL warranty_period DAY) &lt; CURDATE()
+        LIMIT #{currentNum} OFFSET #{nextNum};
     </select>
 </mapper>
\ No newline at end of file