| | |
|---|
| | | .set(Device::getEditDate,new Date()) |
|---|
| | | .set(Device::getEdirot,param.getLoginUserInfo().getId()) |
|---|
| | | .eq(Device::getId,param.getId())); |
|---|
| | | |
|---|
| | | DeviceData data = new DeviceData(); |
|---|
| | | data.setCreateDate(new Date()); |
|---|
| | | data.setEditDate(new Date()); |
|---|
| | | data.setCreator(param.getLoginUserInfo().getId()); |
|---|
| | | data.setEditor(param.getLoginUserInfo().getId()); |
|---|
| | | data.setDeviceId(param.getId()+""); |
|---|
| | | data.setDataType(Constants.ONE);// |
|---|
| | | data.setVal1("远程控制"); |
|---|
| | | data.setVal2(curremak); |
|---|
| | | data.setHappenTime(DateUtil.getPlusTime2(data.getCreateDate())); |
|---|
| | | data.setVal3((Constants.equalsInteger(param.getStatus(),Constants.ONE)?"【开闸】":"【关闸】")); |
|---|
| | | data.setVal4(param.getLoginUserInfo().getRealname()); |
|---|
| | | data.setVal5(param.getChannelNo()); |
|---|
| | | deviceDataMapper.insert(data); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private MqttConfig getMqttConfigByParam(Device model,String index) { |
|---|
| | |
|---|
| | | String[] btns = device.getChannelInfo().split(","); |
|---|
| | | Date startDate = new Date((System.currentTimeMillis()-time*1000));//查询开始时间 |
|---|
| | | List<DeviceData> dataList = deviceDataMapper.selectList(new QueryWrapper<DeviceData>().lambda() |
|---|
| | | .eq(DeviceData::getDataType,Constants.ZERO) |
|---|
| | | .eq(DeviceData::getDeviceId,device.getId()) |
|---|
| | | .in(DeviceData::getVal1,btns) |
|---|
| | | .ge(DeviceData::getHappenTime,DateUtil.getPlusTime2(startDate)) |
|---|
