package com.iailab.module.device.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.iailab.common.constant.BusinessConstant;
|
import com.iailab.framework.common.page.PageData;
|
import com.iailab.framework.common.service.impl.BaseServiceImpl;
|
import com.iailab.framework.common.util.object.ConvertUtils;
|
import com.iailab.module.device.dao.DeviceStatNewnessDao;
|
import com.iailab.module.device.dto.DeviceInfoDTO;
|
import com.iailab.module.device.dto.DeviceStatNewnessDTO;
|
import com.iailab.module.device.entity.DeviceStatNewnessEntity;
|
import com.iailab.module.device.service.DeviceInfoService;
|
import com.iailab.module.device.service.DeviceStatNewnessService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import javax.annotation.Resource;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
@Slf4j
|
@Service
|
public class DeviceStatNewnessServiceImpl extends BaseServiceImpl<DeviceStatNewnessDao, DeviceStatNewnessEntity> implements DeviceStatNewnessService {
|
|
@Resource
|
private DeviceInfoService deviceInfoService;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void statNewness(List<DeviceStatNewnessEntity> list,Date statDate) {
|
// 计划运行时间
|
Map<String, Object> ListParams = new HashMap<>();
|
ListParams.put("pid", "0");
|
List<DeviceInfoDTO> deviceInfoList = deviceInfoService.list(ListParams);
|
Map<String, DeviceInfoDTO> deviceInfoMap = new HashMap<>();
|
deviceInfoList.forEach(item -> {
|
deviceInfoMap.put(item.getNo(), item);
|
});
|
|
List<DeviceStatNewnessEntity> deviceStatNewnessList = new ArrayList<>();
|
for (DeviceStatNewnessEntity entity : list) {
|
DeviceInfoDTO devInfo = deviceInfoMap.get(entity.getDevNo());
|
if (devInfo == null) {
|
continue;
|
}
|
DeviceInfoDTO devInfoUpdate = new DeviceInfoDTO();
|
devInfoUpdate.setId(devInfo.getId());
|
|
entity.setId(UUID.randomUUID().toString());
|
entity.setDate(statDate);
|
entity.setCreateDate(new Date());
|
// 使用年限
|
Integer durableYears = devInfo.getDurableYears() == null ? 0 : devInfo.getDurableYears();
|
BigDecimal durMins = new BigDecimal(durableYears.longValue() * BusinessConstant.YEAR_MINUTE);
|
entity.setDurableTime(durMins.longValue());
|
|
// 已用时长
|
BigDecimal useTime = devInfo.getUseTime() == null ? BigDecimal.ZERO : new BigDecimal(devInfo.getUseTime());
|
BigDecimal useNew = useTime.add(new BigDecimal(entity.getLossTime()));
|
devInfoUpdate.setUseTime(useNew.longValue());
|
|
// 剩余时长
|
BigDecimal residueNew = new BigDecimal(entity.getDurableTime() - useNew.longValue());
|
devInfoUpdate.setResidueTime(residueNew.longValue());
|
entity.setResidueTime(residueNew.longValue());
|
|
// 新度系数
|
BigDecimal newnessRate = residueNew.divide(durMins, 4, BigDecimal.ROUND_FLOOR);
|
devInfoUpdate.setNewnessRate(newnessRate);
|
entity.setNewnessRate(newnessRate);
|
|
deviceStatNewnessList.add(entity);
|
// 更新设备信息
|
deviceInfoService.updateById(devInfoUpdate);
|
|
|
}
|
// 插入明细
|
insertBatch(deviceStatNewnessList);
|
}
|
|
@Override
|
public DeviceStatNewnessEntity getLastByNo(String no) {
|
QueryWrapper<DeviceStatNewnessEntity> wrapper = new QueryWrapper<>();
|
wrapper.eq("dev_no",no);
|
wrapper.orderByDesc("create_date");
|
wrapper.last("limit 1");
|
return baseDao.selectOne(wrapper);
|
}
|
|
@Override
|
public List<DeviceStatNewnessDTO> list(Map<String, Object> params) {
|
List<DeviceStatNewnessEntity> list = baseDao.selectList(getWrapper(params));
|
return ConvertUtils.sourceToTarget(list,DeviceStatNewnessDTO.class);
|
}
|
|
@Override
|
public PageData<DeviceStatNewnessDTO> page(Map<String, Object> params) {
|
params.put("pid","0");
|
IPage<DeviceStatNewnessEntity> page = baseDao.selectPage(getPage(params, "create_date", false), getWrapper(params));
|
return getPageData(page, DeviceStatNewnessDTO.class);
|
}
|
|
public QueryWrapper<DeviceStatNewnessEntity> getWrapper(Map<String, Object> params) {
|
String no = (String) params.get("no");
|
String startTime = (String) params.get("startTime");
|
String endTime = (String) params.get("endTime");
|
|
QueryWrapper<DeviceStatNewnessEntity> wrapper = new QueryWrapper<>();
|
wrapper.eq(StringUtils.isNotBlank(no), "dev_no", no);
|
wrapper.ge(StringUtils.isNotBlank(startTime), "date", startTime);
|
wrapper.le(StringUtils.isNotBlank(endTime), "date", endTime);
|
wrapper.orderByDesc("create_date");
|
return wrapper;
|
}
|
}
|
