whyclxw
2025-02-08 139f7015c2373a5bba03a7d66045cf40faa1728c
src/main/java/com/whyc/service/LockHisService.java
@@ -2,6 +2,7 @@
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.pojo.db_area.LockInf;
import com.whyc.pojo.db_lock_his.LockHis;
import com.whyc.util.SubTablePageInfoUtil;
import com.whyc.util.ThreadLocalUtil;
@@ -9,6 +10,12 @@
import org.springframework.stereotype.Service;
import java.text.ParseException;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@Service
public class LockHisService {
@@ -22,4 +29,44 @@
                ,"db_lock_his","tb_lock_his_"+lockId,his);
        return new Response().setII(1,pageInfo.getList()!=null,pageInfo,"查询锁的历史状态");
    }
    //实时界面点击查看历史信息
    public Response getLockHisWithReal(int lockId, String startTime, String endTime) throws ParseException {
        LockHis his=new LockHis();
        his.setLockId(lockId);
        List<LockHis> list=util.getLockHisWithReal(ThreadLocalUtil.parse(startTime,1),ThreadLocalUtil.parse(endTime,1)
                ,"db_lock_his","tb_lock_his_"+lockId,his);
        Map<String, Object> map = new HashMap<>();
        map.put("openNum", 0);
        map.put("closeNum", 0);
        map.put("nowopenNum", 0);
        map.put("nowcloseNum", 0);
        map.put("hisList", list);
        Map<Integer, List<LockHis>> statemap = list.stream().collect(Collectors.groupingBy(LockHis::getLockState));
        for (Integer state : statemap.keySet()) {
            if (state == 0) {
                map.put("closeNum", statemap.get(0).size());//关锁
            }
            if (state == 1) {
                map.put("openNum", statemap.get(1).size());//开锁
            }
        }
        Date date = new Date();
        //获取当天得开始时间
        Date nowstartTime = new Date(date.getYear(), date.getMonth(), date.getDate(), 0, 0, 0);
        //获取当天的结束时间
        Date nowendTime = new Date(date.getYear(), date.getMonth(), date.getDate(), 23, 59, 59);
        List<LockHis> nowList =util.getLockHisWithReal(nowstartTime,nowendTime
                ,"db_lock_his","tb_lock_his_"+lockId,his);
        Map<Integer, List<LockHis>> nowstatemap = nowList.stream().collect(Collectors.groupingBy(LockHis::getLockState));
        for (Integer state : nowstatemap.keySet()) {
            if (state == 0) {
                map.put("nowcloseNum", nowstatemap.get(0).size());//关锁
            }
            if (state == 1) {
                map.put("nowopenNum", nowstatemap.get(1).size());//开锁
            }
        }
        return new Response().setII(1,list!=null,map,"实时界面点击查看历史信息");
    }
}