| | |
|---|
| | | if (pageWrap.getModel().getName() != null) { |
|---|
| | | queryWrapper.lambda().like(Device::getName, pageWrap.getModel().getName()); |
|---|
| | | } |
|---|
| | | if (pageWrap.getModel().getDoorNo() != null) { |
|---|
| | | queryWrapper.lambda().like(Device::getDoorNo, pageWrap.getModel().getDoorNo()); |
|---|
| | | } |
|---|
| | | if (pageWrap.getModel().getNo() != null) { |
|---|
| | | queryWrapper.lambda().like(Device::getNo, pageWrap.getModel().getNo()); |
|---|
| | | } |
|---|
| | | if (pageWrap.getModel().getDoorName() != null) { |
|---|
| | | queryWrapper.lambda().like(Device::getDoorName, pageWrap.getModel().getDoorName()); |
|---|
| | | } |
|---|
| | |
|---|
| | | } |
|---|
| | | MqttClientCache.clientMapCache.put("device"+param.getId(),mqttClient); |
|---|
| | | String curremak = "【"+param.getLoginUserInfo().getRealname() |
|---|
| | | +"】于"+ DateUtil.getPlusTime2(new Date()) +"进行了"+(Constants.equalsInteger(param.getStatus(),Constants.ONE)?"【开闸】":"【关闸】")+"操作,开关【"+param.getChannelNo()+"】；"; |
|---|
| | | +"】于"+ DateUtil.getPlusTime2(new Date()) +"进行了"+(Constants.equalsInteger(param.getStatus(),Constants.ONE)?"【合闸】":"【分闸】")+"操作,开关【"+param.getChannelNo()+"】；"; |
|---|
| | | deviceMapper.update(null,new UpdateWrapper<Device>().lambda() |
|---|
| | | // .setSql("remark = concat(ifnull(remark,''),'"+curremak+"','\n')") |
|---|
| | | .set(Device::getRemark,curremak) |
|---|
| | | .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)) |
|---|
