稳定提交

王飞

2025-01-23 2de56e472a41b7feb90be29a54a2d6f5a6c8762e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package com.hxzkappboot.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 
import com.hxzkappboot.mapper.TbFenceMapper;
import com.hxzkappboot.mapper.TbPersonMapper;
import com.hxzkappboot.pojo.TbFence;
import com.hxzkappboot.pojo.TbPerson;
import com.hxzkappboot.pojo.TbTag;
import com.hxzkappboot.pojo.TbWarning;
import com.hxzkappboot.service.TbFenceService;
import com.hxzkappboot.udp.Udp_Out;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
 
/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author wangfei
 * @since 2024-03-08
 */
@Service
public class TbFenceServiceImpl extends ServiceImpl<TbFenceMapper, TbFence> implements TbFenceService {
 
    @Autowired
    TbPersonMapper tbPersonMapper;
 
    @Override
    public List<TbFence> findAllFence(String company) {
        QueryWrapper<TbFence> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("companyid",company);
        return baseMapper.selectList(queryWrapper);
    }
 
    public List<TbFence> earlyWarning() throws ParseException {
        //查当前时间是否<=预警时间
        Date date = new Date();
        SimpleDateFormat formatter = new SimpleDateFormat("HH:mm:ss");
        System.out.println(formatter.format(date));
        QueryWrapper queryWrapper = new QueryWrapper();
 
        queryWrapper.ge("baoliu1", formatter.format(date));
        List<TbFence> fenceList = ((TbFenceMapper)this.baseMapper).selectList(queryWrapper);
        for (int i = 0; i < fenceList.size(); i++) {
            QueryWrapper qw = new QueryWrapper();
            queryWrapper.eq("p_fencename", fenceList.get(i).getName());
            List<TbPerson> people1 = tbPersonMapper.selectList(qw);
            fenceList.get(i).setPersonList(people1);
 
            SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
//1.string->date
            Date parse = dateFormat.parse(fenceList.get(i).getBaoliu1());
            fenceList.get(i).setWarntime(parse);
            //person绑定的fence是一对一还是一对多
//            String xieyi = "BSTOCS1,TOMESSAGE," + people1.get(0).getPTagid() + "," + fenceList.get(i).getBaoliu1() + ",系统,END";
//            Udp_Out.udp_to_cs(xieyi);
        }
        return fenceList;
    }
 
 
    @Override
    public IPage<TbFence> findFence(Page page, String objectid,String company) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
//        queryWrapper.eq("status","未处理");
        if (objectid!=null){
            queryWrapper.eq("name",objectid);
        }
        queryWrapper.eq("companyid",company);
 
        queryWrapper.orderByDesc("addtime");
        IPage<TbFence> CompanyPage = baseMapper.selectPage(page, queryWrapper);
        return CompanyPage;
    }
 
    @Override
    public TbFence updateFence(TbFence tbFence) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("name",tbFence.getName());
        baseMapper.update(tbFence,queryWrapper);
 
        return baseMapper.selectOne(queryWrapper);
    }
 
}