package com.qianwen.smartman.modules.andon.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import java.lang.invoke.SerializedLambda;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Optional;
|
import java.util.stream.Collectors;
|
import com.qianwen.smartman.common.cache.RegionCache;
|
import com.qianwen.smartman.common.constant.ExcelConstant;
|
import com.qianwen.smartman.common.utils.AbstractSqlAdapter;
|
import com.qianwen.smartman.common.utils.Lambda;
|
import com.qianwen.smartman.common.utils.TimeUtils;
|
import com.qianwen.core.excel.util.ExcelUtil;
|
import com.qianwen.core.mp.support.Condition;
|
import com.qianwen.core.mp.support.Query;
|
import com.qianwen.core.oss.model.BladeFile;
|
import com.qianwen.core.tool.utils.DateUtil;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.andon.convert.AndonRecordConvert;
|
import com.qianwen.smartman.modules.andon.entity.AndonRecord;
|
import com.qianwen.smartman.modules.andon.entity.AndonRecordReason;
|
import com.qianwen.smartman.modules.andon.enums.AndonStatusEnum;
|
import com.qianwen.smartman.modules.andon.excel.AndonCallRecordExport;
|
import com.qianwen.smartman.modules.andon.service.IAndonCallRecordService;
|
import com.qianwen.smartman.modules.andon.service.IAndonRecordReasonService;
|
import com.qianwen.smartman.modules.andon.service.IAndonRecordService;
|
import com.qianwen.smartman.modules.andon.vo.AndonCallRecordResVO;
|
import com.qianwen.smartman.modules.andon.vo.AndonCallRecordSearchVO;
|
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/andon/service/impl/AndonCallRecordServiceImpl.class */
|
public class AndonCallRecordServiceImpl implements IAndonCallRecordService {
|
private final IAndonRecordService recordService;
|
|
private final IAndonRecordReasonService reasonService;
|
|
private final OssBuilder ossBuilder;
|
|
public AndonCallRecordServiceImpl(IAndonRecordService recordService, IAndonRecordReasonService reasonService, OssBuilder ossBuilder) {
|
this.recordService = recordService;
|
this.reasonService = reasonService;
|
this.ossBuilder = ossBuilder;
|
}
|
|
|
@Override // org.springblade.modules.andon.service.IAndonCallRecordService
|
public IPage<AndonCallRecordResVO> pageQueryRecord(Query query, AndonCallRecordSearchVO vo) {
|
QueryWrapper<AndonRecord> wrapper = getWrapper(vo);
|
IPage<AndonRecord> page = this.recordService.page(Condition.getPage(query), wrapper);
|
List<AndonRecord> records = page.getRecords();
|
Map<Long, List<AndonRecordReason>> recordReasonMap = (Map<Long, List<AndonRecordReason>>)this.reasonService.list().stream().collect(Collectors.groupingBy(AndonRecordReason::getRecordId));
|
List<AndonCallRecordResVO> vos = (List<AndonCallRecordResVO>)records.stream().map(c -> convert(c, recordReasonMap)).collect(Collectors.toList());
|
Page<AndonCallRecordResVO> page1 = new Page<>(page.getCurrent(), page.getSize(), page.getTotal());
|
page1.setRecords(vos);
|
return page1;
|
}
|
|
@Override // org.springblade.modules.andon.service.IAndonCallRecordService
|
public BladeFile exportRecord(AndonCallRecordSearchVO vo) {
|
List<AndonRecord> records = this.recordService.list(getWrapper(vo));
|
Map<Long, List<AndonRecordReason>> recordReasonMap = (Map<Long, List<AndonRecordReason>>)this.reasonService.list().stream().collect(Collectors.groupingBy(AndonRecordReason::getRecordId));
|
List<AndonCallRecordExport> exports = (List<AndonCallRecordExport>)records.stream().map(c -> convertExport(c, recordReasonMap)).collect(Collectors.toList());
|
String fileName = String.format("%s-%s.xlsx", new Object[] { "安灯确认记录", DateUtil.time() });
|
String sheetName = "安灯确认记录";
|
MultipartFile multipartFile = ExcelUtil.exportToMultipartFile(fileName, sheetName, exports, AndonCallRecordExport.class);
|
return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
|
}
|
|
private AndonCallRecordExport convertExport(AndonRecord record, Map<Long, List<AndonRecordReason>> recordReasonMap) {
|
long callTotalTime;
|
AndonCallRecordExport export = AndonRecordConvert.INSTANCE.convertExport(record);
|
export.setCallTime(DateUtil.formatDateTime(record.getCallTime()));
|
if (Func.notNull(record.getResponseTime())) {
|
export.setResponseTime(DateUtil.formatDateTime(record.getResponseTime()));
|
}
|
if (Func.notNull(record.getEndTime())) {
|
export.setEndTime(DateUtil.formatDateTime(record.getEndTime()));
|
}
|
Integer curStatus = record.getCurStatus();
|
Date now = DateUtil.now();
|
if (AndonStatusEnum.COMPLETE.getStatus().equals(curStatus)) {
|
callTotalTime = DateUtil.between(record.getEndTime(), record.getCallTime()).getSeconds();
|
} else {
|
callTotalTime = DateUtil.between(now, record.getCallTime()).getSeconds();
|
}
|
export.setCallTotalTime(TimeUtils.getUseTime(callTotalTime));
|
Long handTotalTime = null;
|
if (AndonStatusEnum.COMPLETE.getStatus().equals(curStatus)) {
|
handTotalTime = Long.valueOf(DateUtil.between(record.getEndTime(), record.getResponseTime()).getSeconds());
|
} else if (AndonStatusEnum.ALREADY_RECEIVED.getStatus().equals(curStatus)) {
|
handTotalTime = Long.valueOf(DateUtil.between(now, record.getResponseTime()).getSeconds());
|
}
|
export.setHandTotalTime(handTotalTime == null ? "-" : TimeUtils.getUseTime(handTotalTime.longValue()));
|
if (Func.notNull(record.getResponseTime())) {
|
export.setResponseTotalTime(TimeUtils.getUseTime(DateUtil.between(record.getResponseTime(), record.getCallTime()).getSeconds()));
|
}
|
Optional.ofNullable(recordReasonMap.get(record.getId())).ifPresent(rs -> {
|
String reasonCode = (String) rs.stream().map((v0) -> {
|
return v0.getReasonCode();
|
}).collect(Collectors.joining(","));
|
export.setReasonCode(reasonCode);
|
String reasonName = (String) rs.stream().map((v0) -> {
|
return v0.getReasonName();
|
}).collect(Collectors.joining(","));
|
export.setReasonName(reasonName);
|
});
|
return export;
|
}
|
|
private QueryWrapper<AndonRecord> getWrapper(AndonCallRecordSearchVO vo) {
|
QueryWrapper<AndonRecord> queryWrapper = (QueryWrapper<AndonRecord>) (((Wrappers.<AndonRecord>query()
|
.eq(Lambda.getName(AndonRecord::getCurStatus), AndonStatusEnum.COMPLETE.getStatus())
|
.in(Func.isNotEmpty(vo.getWorkstationIds()), Lambda.getName(AndonRecord::getWorkstationId),
|
vo.getWorkstationIds()))
|
.in(Func.isNotEmpty(vo.getTypeIds()), Lambda.getName(AndonRecord::getTypeId), vo.getTypeIds()))
|
.in(Func.isNotEmpty(vo.getHandEmpIds()), Lambda.getName(AndonRecord::getHandEmpId), vo.getHandEmpIds()))
|
.in(Func.isNotEmpty(vo.getCallEmpIds()), Lambda.getName(AndonRecord::getCallEmpId), vo.getCallEmpIds());
|
return AbstractSqlAdapter
|
.dateBetweenAdapter(queryWrapper,
|
(Func.notNull(vo.getStartCallTime()) && Func.notNull(vo.getEndCallTime())),
|
Lambda.getName(AndonRecord::getCallTime), vo.getStartCallTime(), vo.getEndCallTime())
|
.orderByDesc(Lambda.getName(AndonRecord::getEndTime))
|
.orderByAsc(Lambda.getName(AndonRecord::getTypeCode));
|
}
|
|
private AndonCallRecordResVO convert(AndonRecord record, Map<Long, List<AndonRecordReason>> recordReasonMap) {
|
long callTotalTime;
|
AndonCallRecordResVO vo = AndonRecordConvert.INSTANCE.convertCall(record);
|
Integer curStatus = record.getCurStatus();
|
Date now = DateUtil.now();
|
if (AndonStatusEnum.COMPLETE.getStatus().equals(curStatus)) {
|
callTotalTime = DateUtil.between(record.getEndTime(), record.getCallTime()).getSeconds();
|
} else {
|
callTotalTime = DateUtil.between(now, record.getCallTime()).getSeconds();
|
}
|
vo.setCallTotalTime(Integer.valueOf(Math.abs(Math.toIntExact(callTotalTime))));
|
Long handTotalTime = null;
|
if (AndonStatusEnum.COMPLETE.getStatus().equals(curStatus)) {
|
handTotalTime = Long.valueOf(DateUtil.between(record.getEndTime(), record.getResponseTime()).getSeconds());
|
} else if (AndonStatusEnum.ALREADY_RECEIVED.getStatus().equals(curStatus)) {
|
handTotalTime = Long.valueOf(DateUtil.between(now, record.getResponseTime()).getSeconds());
|
}
|
vo.setHandTotalTime((handTotalTime == null) ? null : Integer.valueOf(Math.abs(Math.toIntExact(handTotalTime.longValue()))));
|
if (Func.notNull(record.getResponseTime()))
|
vo.setResponseTotalTime(Integer.valueOf(Math.abs(Math.toIntExact(DateUtil.between(record.getResponseTime(), record.getCallTime()).getSeconds()))));
|
Optional.ofNullable(recordReasonMap.get(record.getId()))
|
.ifPresent(rs -> {
|
String reasonCode = rs.stream().map(AndonRecordReason::getReasonCode).collect(Collectors.joining(","));
|
vo.setReasonCode(reasonCode);
|
String reasonName = rs.stream().map(AndonRecordReason::getReasonName).collect(Collectors.joining(","));
|
vo.setReasonName(reasonName);
|
});
|
return vo;
|
}
|
}
|
