diff --git a/community-security-common/src/main/java/com/zyh/common/domain/dto/PersonNum.java b/community-security-common/src/main/java/com/zyh/common/domain/dto/PersonNum.java new file mode 100644 index 0000000..ae6c6bb --- /dev/null +++ b/community-security-common/src/main/java/com/zyh/common/domain/dto/PersonNum.java @@ -0,0 +1,12 @@ +package com.zyh.common.domain.dto; + +import lombok.Data; + +@Data +public class PersonNum { + private Integer id; + private String buildId; + private Integer unit; + private Integer personNum; + +} diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/ShopApplication.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/ShopApplication.java index 454f2e6..897017c 100644 --- a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/ShopApplication.java +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/ShopApplication.java @@ -4,8 +4,10 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.scheduling.annotation.EnableScheduling; @SpringBootApplication +@EnableScheduling public class ShopApplication { public static void main(String[] args) { diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/controller/BuildController.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/controller/BuildController.java index 477b05d..747808a 100644 --- a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/controller/BuildController.java +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/controller/BuildController.java @@ -57,4 +57,6 @@ public class BuildController { public Result> getHousetype() { return buildService.getHousetype(); } + + } diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/mapper/BuildMapper.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/mapper/BuildMapper.java index ac90aa4..e40dd46 100644 --- a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/mapper/BuildMapper.java +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/mapper/BuildMapper.java @@ -3,6 +3,7 @@ package com.zyh.system.mapper; import com.zyh.common.domain.Building; import com.zyh.common.domain.Households; import com.zyh.common.domain.Housetype; +import com.zyh.common.domain.dto.PersonNum; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; @@ -25,4 +26,8 @@ public interface BuildMapper { Integer updateHouse(Households households); List getHousetype(); + + List getPersonNum(); + + void updateBuildPersonNum(@Param("personNum") Integer personNum,@Param("unit") Integer unit,@Param("buildId") String buildId); } diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/BuildService.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/BuildService.java index f616be6..196b51d 100644 --- a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/BuildService.java +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/BuildService.java @@ -3,6 +3,7 @@ package com.zyh.system.service; import com.zyh.common.domain.Building; import com.zyh.common.domain.Households; import com.zyh.common.domain.Housetype; +import com.zyh.common.domain.dto.PersonNum; import com.zyh.common.result.Result; import java.util.List; @@ -20,4 +21,7 @@ public interface BuildService { Result> getHousetype(); + List getPersonNum(); + + void updateBuildPersonNum(Integer personNum,Integer unit,String buildId); } diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/impl/BuildServicempl.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/impl/BuildServicempl.java index 0484af4..121f15f 100644 --- a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/impl/BuildServicempl.java +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/service/impl/BuildServicempl.java @@ -3,6 +3,7 @@ package com.zyh.system.service.impl; import com.zyh.common.domain.Building; import com.zyh.common.domain.Households; import com.zyh.common.domain.Housetype; +import com.zyh.common.domain.dto.PersonNum; import com.zyh.common.result.Result; import com.zyh.system.mapper.BuildMapper; import com.zyh.system.service.BuildService; @@ -85,4 +86,15 @@ public class BuildServicempl implements BuildService { return Result.success(housetypes); } + @Override + public List getPersonNum() { + return buildMapper.getPersonNum(); + } + + @Override + public void updateBuildPersonNum(Integer personNum,Integer unit,String buildId) { + buildMapper.updateBuildPersonNum(personNum, unit, buildId); + } + + } diff --git a/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/timer/Timer.java b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/timer/Timer.java new file mode 100644 index 0000000..17cd529 --- /dev/null +++ b/community-security-modules/community-security-modules-shop/src/main/java/com/zyh/system/timer/Timer.java @@ -0,0 +1,26 @@ +package com.zyh.system.timer; + +import com.zyh.common.domain.dto.PersonNum; +import com.zyh.system.service.BuildService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; + +@Component +public class Timer { +@Autowired + BuildService buildService; + @Scheduled(cron = "0 * * * * ?") // 每分钟触发一次 + public void myScheduledMethod() { + // 在这里编写定时任务要执行的业务逻辑 + List personNums = buildService.getPersonNum(); + for (PersonNum personNum : personNums) { + //修改楼栋入住人数 + buildService.updateBuildPersonNum(personNum.getPersonNum(),personNum.getUnit(),personNum.getBuildId()); + + } + System.out.println("定时任务执行了"); + } +} diff --git a/community-security-modules/community-security-modules-shop/src/main/resources/mapper/BuildMapper.xml b/community-security-modules/community-security-modules-shop/src/main/resources/mapper/BuildMapper.xml index 7a0f0ef..dac82af 100644 --- a/community-security-modules/community-security-modules-shop/src/main/resources/mapper/BuildMapper.xml +++ b/community-security-modules/community-security-modules-shop/src/main/resources/mapper/BuildMapper.xml @@ -18,6 +18,12 @@ type = #{type} where id = #{id} + + update building set + residents = #{personNum} + where unit = #{unit} + and build_id = #{buildId} + delete from households where id = #{id} @@ -43,4 +49,10 @@ + +