智能电表远程抄表缴费管理平台JAVA源码

package com.wwby.worker.ammeter.service.impl; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.wwby.common.dto.Device; import com.wwby.common.dto.MeterRead; import com.wwby.common.exception.BusinessException; import com.wwby.common.mapper.DeviceMapper; import com.wwby.common.model.request.DeviceReq; import com.wwby.common.model.result.DeviceResult; import com.wwby.common.model.result.ReadAmmeterDataResult; import com.wwby.common.model.result.StateResult; import com.wwby.common.pojo.AmmeterDegreeJsonEntity; import com.wwby.common.utils.PointUtil; import com.wwby.worker.ammeter.service.DeviceService; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; /** * @ProjectName: wwby-devices * @Package: com.wwby.common.service.impl * @ClassName: DeviceServiceImpl * @Author: wangqw * @Description: 设备服务实现类 * @Date: 2021/7/23 10:46 * @Version: 1.0 */ @Service public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> implements DeviceService { @Override public DeviceResult getDevice(DeviceReq req) { DeviceResult result = new DeviceResult(); LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.isNull(Device::getDeletedAt); queryWrapper.eq(Device::getDeviceNum, req.getDeviceNum()); result.setDevice(getOne(queryWrapper)); return result; } @Override public ReadAmmeterDataResult getDeviceById(String id) { LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.isNull(Device::getDeletedAt); queryWrapper.eq(Device::getId, id); Device device = getOne(queryWrapper); if (device == null) { throw new BusinessException("不存在：" + id); } BigDecimal bd = new BigDecimal("10000"); ReadAmmeterDataResult result = new ReadAmmeterDataResult(); result.setAmmeterId(id); AmmeterDegreeJsonEntity jsonEntity = new AmmeterDegreeJsonEntity(); SimpleDateFormat format = new SimpleDateFormat("yyMMddHHmm"); jsonEntity.setA1(format.format(device.getReadingTime())); // 抄表时间 jsonEntity.setA2(new BigDecimal(device.getCurCuspValue()).divide(bd).toString()); // 尖 jsonEntity.setA3(new BigDecimal(device.getCurPeakValue()).divide(bd).toString()); // 峰 jsonEntity.setA4(new BigDecimal(device.getCurFlatValue()).divide(bd).toString()); // 平 jsonEntity.setA5(new BigDecimal(device.getCurValleyValue()).divide(bd).toString()); // 谷 jsonEntity.setA6(device.getStatus().toString()); // 开关状态 jsonEntity.setA11(device.getRealPower().toString()); // 实时功率 jsonEntity.setA26(device.getRealEle().toString()); // 实时电流 jsonEntity.setA35(new BigDecimal(device.getCurStandardValue()).divide(bd).toString()); // 总 result.setAmmeterDegree(jsonEntity); return result; } @Override public StateResult<Boolean> delDevice(DeviceReq req) { LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.isNull(Device::getDeletedAt); queryWrapper.eq(Device::getDeviceNum, req.getDeviceNum()); Device device = getOne(queryWrapper); if (device == null) { throw new BusinessException("不存在：" + req.getDeviceNum()); } LambdaUpdateWrapper<Device> updateWrapper = new UpdateWrapper<Device>().lambda(); updateWrapper.eq(Device::getDeviceNum, req.getDeviceNum()); updateWrapper.set(Device::getDeletedAt, new Date()); boolean bool = update(updateWrapper); return new StateResult(bool); } @Override public List<Device> getListByConcentrator(String concentratorId) { LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.eq(Device::getConcentratorId, concentratorId); queryWrapper.isNull(Device::getDeletedAt); return list(queryWrapper); } @Override public boolean updateByConcentrator(MeterRead meterRead) { LambdaUpdateWrapper<Device> updateWrapper = new UpdateWrapper<Device>().lambda(); updateWrapper.set(Device::getReadingTime, meterRead.getCreatedAt()); updateWrapper.set(Device::getCurStandardValue, meterRead.getTotal()); updateWrapper.set(Device::getCurCuspValue, meterRead.getRate1()); updateWrapper.set(Device::getCurPeakValue, meterRead.getRate2()); updateWrapper.set(Device::getCurFlatValue, meterRead.getRate3()); updateWrapper.set(Device::getCurValleyValue, meterRead.getRate4()); updateWrapper.eq(Device::getConcentrator, meterRead.getConcentrator()); int da1 = Integer.parseInt(meterRead.getDa1(), 16); int da2 = Integer.parseInt(meterRead.getDa2(), 16); updateWrapper.eq(Device::getPointId, PointUtil.get(da1, da2)); updateWrapper.isNull(Device::getDeletedAt); return update(updateWrapper); } @Override public boolean updateByConcentratorPreDegree(MeterRead meterRead) { LambdaUpdateWrapper<Device> updateWrapper = new UpdateWrapper<Device>().lambda(); updateWrapper.set(Device::getReadingTime, meterRead.getCreatedAt()); updateWrapper.set(Device::getPreStandardValue, meterRead.getTotal()); updateWrapper.set(Device::getPreCuspValue, meterRead.getRate1()); updateWrapper.set(Device::getPrePeakValue, meterRead.getRate2()); updateWrapper.set(Device::getPreFlatValue, meterRead.getRate3()); updateWrapper.set(Device::getPreValleyValue, meterRead.getRate4()); updateWrapper.eq(Device::getConcentrator, meterRead.getConcentrator()); int da1 = Integer.parseInt(meterRead.getDa1(), 16); int da2 = Integer.parseInt(meterRead.getDa2(), 16); updateWrapper.eq(Device::getPointId, PointUtil.get(da1, da2)); updateWrapper.isNull(Device::getDeletedAt); return update(updateWrapper); } @Override public Device getDeviceByAmmeterId(String ammeterId) { LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.eq(Device::getDeviceNum, ammeterId); queryWrapper.isNull(Device::getDeletedAt); Device device = getOne(queryWrapper); if (device == null) { throw new BusinessException("不存在：" + ammeterId); } return device; } @Override public Device getById(String id) { LambdaQueryWrapper<Device> queryWrapper = new QueryWrapper<Device>().lambda(); queryWrapper.eq(Device::getId, id); queryWrapper.isNull(Device::getDeletedAt); Device device = getOne(queryWrapper); if (device == null) { throw new BusinessException("不存在：" + id); } return device; } @Override public boolean updateRealEleByAmmeter(String concentrator, String ammeter, String data) { LambdaUpdateWrapper<Device> updateWrapper = new UpdateWrapper<Device>().lambda(); updateWrapper.set(Device::getRealEle, Double.parseDouble(data)/1000); updateWrapper.eq(Device::getConcentrator, concentrator); updateWrapper.eq(Device::getDeviceNum, ammeter); updateWrapper.isNull(Device::getDeletedAt); return update(updateWrapper); } @Override