package com.qianwen.smartman.modules.tool.service.impl;
|
|
import java.lang.reflect.Field;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Objects;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import com.alibaba.excel.annotation.ExcelProperty;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.qianwen.core.log.exception.ServiceException;
|
import com.qianwen.core.mp.base.BaseServiceImpl;
|
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.common.constant.ExcelConstant;
|
import com.qianwen.smartman.common.utils.MessageUtils;
|
import com.qianwen.smartman.modules.cps.entity.Employee;
|
import com.qianwen.smartman.modules.cps.service.IEmployeeService;
|
import com.qianwen.smartman.modules.mdc.utils.ExcelStrategyUtil;
|
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
|
import com.qianwen.smartman.modules.tool.convert.ToolChangeRecordConvert;
|
import com.qianwen.smartman.modules.tool.entity.Tool;
|
import com.qianwen.smartman.modules.tool.entity.ToolChangeRecord;
|
import com.qianwen.smartman.modules.tool.entity.ToolParameter;
|
import com.qianwen.smartman.modules.tool.enums.ToolLifeCountMethodEnum;
|
import com.qianwen.smartman.modules.tool.enums.ToolOperationTypeEnum;
|
import com.qianwen.smartman.modules.tool.excel.ToolChangeRecordExcel;
|
import com.qianwen.smartman.modules.tool.mapper.ToolChangeRecordMapper;
|
import com.qianwen.smartman.modules.tool.service.IToolCategoryService;
|
import com.qianwen.smartman.modules.tool.service.IToolChangeRecordService;
|
import com.qianwen.smartman.modules.tool.service.IToolModelService;
|
import com.qianwen.smartman.modules.tool.service.IToolParameterService;
|
import com.qianwen.smartman.modules.tool.vo.ToolChangeRecordQueryVO;
|
import com.qianwen.smartman.modules.tool.vo.ToolChangeRecordVO;
|
|
@Service
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/tool/service/impl/ToolChangeRecordServiceImpl.class */
|
public class ToolChangeRecordServiceImpl extends BaseServiceImpl<ToolChangeRecordMapper, ToolChangeRecord> implements IToolChangeRecordService {
|
private static final Logger log = LoggerFactory.getLogger(ToolChangeRecordServiceImpl.class);
|
private final IToolParameterService toolParameterService;
|
private final OssBuilder ossBuilder;
|
private final IEmployeeService employeeService;
|
private final IToolModelService toolModelService;
|
private final IToolCategoryService toolCategoryService;
|
|
|
public ToolChangeRecordServiceImpl(final IToolParameterService toolParameterService, final OssBuilder ossBuilder, final IEmployeeService employeeService, final IToolModelService toolModelService, final IToolCategoryService toolCategoryService) {
|
this.toolParameterService = toolParameterService;
|
this.ossBuilder = ossBuilder;
|
this.employeeService = employeeService;
|
this.toolModelService = toolModelService;
|
this.toolCategoryService = toolCategoryService;
|
}
|
|
@Override // org.springblade.modules.tool.service.IToolChangeRecordService
|
public IPage<ToolChangeRecordVO> pageToolChangeRecord(ToolChangeRecordQueryVO toolChangeRecordQueryVO, Query query) {
|
IPage<ToolChangeRecord> toolChangeRecordIPage = page(Condition.getPage(query),Wrappers.<ToolChangeRecord>lambdaQuery()
|
.eq((Func.isNotEmpty(toolChangeRecordQueryVO.getToolCategoryId()) && !Objects.equals(toolChangeRecordQueryVO.getToolCategoryId(), "1")), ToolChangeRecord::getToolCategoryId, toolChangeRecordQueryVO.getToolCategoryId())
|
|
.likeRight(Func.isNotEmpty(toolChangeRecordQueryVO.getCode()), ToolChangeRecord::getToolCode, toolChangeRecordQueryVO.getCode())
|
.between((Func.isNotEmpty(toolChangeRecordQueryVO.getStartTime()) && Func.isNotEmpty(toolChangeRecordQueryVO.getEndTime())), ToolChangeRecord::getCreateTime, toolChangeRecordQueryVO.getStartTime(), toolChangeRecordQueryVO.getEndTime())
|
.orderByDesc(Arrays.asList(ToolChangeRecord::getCreateTime, ToolChangeRecord::getId)));
|
/*
|
IPage<ToolChangeRecord> toolChangeRecordIPage = page(Condition.getPage(query), (Wrapper) Wrappers.lambdaQuery().eq(Func.isNotEmpty(toolChangeRecordQueryVO.getToolCategoryId()) && !Objects.equals(toolChangeRecordQueryVO.getToolCategoryId(), "1"), (v0) -> {
|
return v0.getToolCategoryId();
|
}, toolChangeRecordQueryVO.getToolCategoryId()).likeRight(Func.isNotEmpty(toolChangeRecordQueryVO.getCode()), (v0) -> {
|
return v0.getToolCode();
|
}, toolChangeRecordQueryVO.getCode()).between(Func.isNotEmpty(toolChangeRecordQueryVO.getStartTime()) && Func.isNotEmpty(toolChangeRecordQueryVO.getEndTime()), (v0) -> {
|
return v0.getCreateTime();
|
}, toolChangeRecordQueryVO.getStartTime(), toolChangeRecordQueryVO.getEndTime()).orderByDesc((v0) -> {
|
return v0.getCreateTime();
|
}, new SFunction[]{(v0) -> {
|
return v0.getId();
|
}}));*/
|
IPage<ToolChangeRecordVO> toolChangeRecordVOIPage = ToolChangeRecordConvert.INSTANCE.convert(toolChangeRecordIPage);
|
toolChangeRecordVOIPage.getRecords().forEach(toolChangeRecordVO -> {
|
toolChangeRecordVO.setOperationType(Func.isNotEmpty(toolChangeRecordVO.getOperationType()) ? ToolOperationTypeEnum.findByCode(Integer.valueOf(toolChangeRecordVO.getOperationType())).getDesc() : null);
|
});
|
return toolChangeRecordVOIPage;
|
}
|
|
@Override // org.springblade.modules.tool.service.IToolChangeRecordService
|
public BladeFile exportToolChangeRecord(ToolChangeRecordQueryVO toolChangeRecordQueryVO) throws Exception {
|
List<List<String>> head = getHead();
|
List<List<Object>> data = getData(toolChangeRecordQueryVO);
|
String fileName = String.format("%s-%s.xlsx", "装卸刀记录表", DateUtil.time());
|
MultipartFile multipartFile = ExcelStrategyUtil.customerStyleExport(fileName, ExcelConstant.SHEET, head, data);
|
return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
|
}
|
|
public List<List<String>> getHead() {
|
List<List<String>> list = new ArrayList<>();
|
ToolChangeRecordExcel toolChangeRecordExcel = new ToolChangeRecordExcel();
|
Field[] fields = toolChangeRecordExcel.getClass().getDeclaredFields();
|
for (Field field : fields) {
|
field.setAccessible(true);
|
ExcelProperty annotation = field.getAnnotation(ExcelProperty.class);
|
List<String> head = new ArrayList<>();
|
head.add(annotation.value()[0]);
|
list.add(head);
|
}
|
|
List<ToolParameter> toolParameterList = this.toolParameterService.list(Wrappers.<ToolParameter>lambdaQuery().orderByAsc(ToolParameter::getToolParameterCode));
|
List<String> toolParameterNameList = toolParameterList.stream().map(ToolParameter::getToolParameterName).collect(Collectors.toList());
|
/*
|
List<ToolParameter> toolParameterList = this.toolParameterService.list((Wrapper) Wrappers.lambdaQuery().orderByAsc((v0) -> {
|
return v0.getToolParameterCode();
|
}));
|
List<String> toolParameterNameList = (List) toolParameterList.stream().map((v0) -> {
|
return v0.getToolParameterName();
|
}).collect(Collectors.toList());*/
|
Map<String, String> nameUnitMap = toolParameterList.stream().filter(item -> {
|
return Func.isNotEmpty(item.getToolParameterUnit());
|
}).collect(Collectors.toMap((v0) -> {
|
return v0.getToolParameterName();
|
}, (v0) -> {
|
return v0.getToolParameterUnit();
|
}));
|
for (String name : toolParameterNameList) {
|
List<String> head2 = new ArrayList<>();
|
head2.add(nameUnitMap.containsKey(name) ? name + "(" + nameUnitMap.get(name) + ")" : name);
|
list.add(head2);
|
}
|
return list;
|
}
|
|
public List<List<Object>> getData(ToolChangeRecordQueryVO toolChangeRecordQueryVO) throws IllegalAccessException, NoSuchFieldException {
|
List<ToolChangeRecord> toolChangeRecords = list(Wrappers.<ToolChangeRecord>lambdaQuery()
|
.eq((Func.isNotEmpty(toolChangeRecordQueryVO.getToolCategoryId()) && !Objects.equals(toolChangeRecordQueryVO.getToolCategoryId(), "1")), ToolChangeRecord::getToolCategoryId, toolChangeRecordQueryVO.getToolCategoryId())
|
.likeRight(Func.isNotEmpty(toolChangeRecordQueryVO.getCode()), ToolChangeRecord::getToolCode, toolChangeRecordQueryVO.getCode())
|
.between((Func.isNotEmpty(toolChangeRecordQueryVO.getStartTime()) && Func.isNotEmpty(toolChangeRecordQueryVO.getEndTime())), ToolChangeRecord::getCreateTime, toolChangeRecordQueryVO.getStartTime(), toolChangeRecordQueryVO.getEndTime())
|
.orderByDesc(Arrays.asList(ToolChangeRecord::getCreateTime, ToolChangeRecord::getId) ));
|
/*
|
List<ToolChangeRecord> toolChangeRecords = list((Wrapper) Wrappers.lambdaQuery().eq(Func.isNotEmpty(toolChangeRecordQueryVO.getToolCategoryId()) && !Objects.equals(toolChangeRecordQueryVO.getToolCategoryId(), "1"), (v0) -> {
|
return v0.getToolCategoryId();
|
}, toolChangeRecordQueryVO.getToolCategoryId()).likeRight(Func.isNotEmpty(toolChangeRecordQueryVO.getCode()), (v0) -> {
|
return v0.getToolCode();
|
}, toolChangeRecordQueryVO.getCode()).between(Func.isNotEmpty(toolChangeRecordQueryVO.getStartTime()) && Func.isNotEmpty(toolChangeRecordQueryVO.getEndTime()), (v0) -> {
|
return v0.getCreateTime();
|
}, toolChangeRecordQueryVO.getStartTime(), toolChangeRecordQueryVO.getEndTime()).orderByDesc((v0) -> {
|
return v0.getCreateTime();
|
}, new SFunction[]{(v0) -> {
|
return v0.getId();
|
}}));*/
|
List<String> toolParameterCodeList = this.toolParameterService.list(Wrappers.<ToolParameter>lambdaQuery().orderByAsc(ToolParameter::getToolParameterCode)).stream().map(ToolParameter::getToolParameterCode).collect(Collectors.toList());
|
/*
|
List<String> toolParameterCodeList = (List) this.toolParameterService.list((Wrapper) Wrappers.lambdaQuery().orderByAsc((v0) -> {
|
return v0.getToolParameterCode();
|
})).stream().map((v0) -> {
|
return v0.getToolParameterCode();
|
}).collect(Collectors.toList());*/
|
List<List<Object>> list = new ArrayList<>();
|
for (ToolChangeRecord toolChangeRecord : toolChangeRecords) {
|
ToolChangeRecordExcel toolChangeRecordExcel = ToolChangeRecordConvert.INSTANCE.convertToExcel(toolChangeRecord);
|
toolChangeRecordExcel.setLifeCountMethod(Func.isNotEmpty(toolChangeRecord.getLifeCountMethod()) ? ToolLifeCountMethodEnum.findByCode(toolChangeRecord.getLifeCountMethod()).getDesc() : null);
|
toolChangeRecordExcel.setOperationType(Func.isNotEmpty(toolChangeRecord.getOperationType()) ? ToolOperationTypeEnum.findByCode(toolChangeRecord.getOperationType()).getDesc() : null);
|
List<Object> objectList = new ArrayList<>();
|
Field[] fields = toolChangeRecordExcel.getClass().getDeclaredFields();
|
for (Field field : fields) {
|
field.setAccessible(true);
|
objectList.add(field.get(toolChangeRecordExcel));
|
}
|
for (String code : toolParameterCodeList) {
|
Field field2 = ToolChangeRecord.class.getDeclaredField(code);
|
field2.setAccessible(true);
|
Object codeValue = field2.get(toolChangeRecord);
|
objectList.add(codeValue);
|
}
|
list.add(objectList);
|
}
|
return list;
|
}
|
|
@Override // org.springblade.modules.tool.service.IToolChangeRecordService
|
public void dischargeToolChangeRecord(List<Tool> toolManageList, Long employeeId) {
|
List<ToolChangeRecord> toolChangeRecords = ToolChangeRecordConvert.INSTANCE.toolToConvert(toolManageList);
|
Employee employee = (Employee) this.employeeService.getById(employeeId);
|
Map<Long, String> modelNameMap = this.toolModelService.list().stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getModel();
|
}));
|
Map<Long, String> categoryNameMap = this.toolCategoryService.list().stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getName();
|
}));
|
if (Func.isEmpty(employee)) {
|
throw new ServiceException(MessageUtils.message("sys.outer.user.not.bind.employee", new Object[0]));
|
}
|
toolChangeRecords.forEach(toolChangeRecord -> {
|
toolChangeRecord.setToolModel((String) modelNameMap.get(toolChangeRecord.getToolModelId()));
|
toolChangeRecord.setToolCategory((String) categoryNameMap.get(toolChangeRecord.getToolCategoryId()));
|
toolChangeRecord.setEmployeeId(employeeId);
|
toolChangeRecord.setEmployeeName(employee.getName());
|
toolChangeRecord.setOperationType(ToolOperationTypeEnum.DISCHARGE.getCode());
|
});
|
saveBatch(toolChangeRecords);
|
}
|
|
@Override // org.springblade.modules.tool.service.IToolChangeRecordService
|
public void equipmentToolChangeRecord(Tool toolManage, Long employeeId) {
|
Employee employee = (Employee) this.employeeService.getById(employeeId);
|
Map<Long, String> modelNameMap = this.toolModelService.list().stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getModel();
|
}));
|
Map<Long, String> categoryNameMap = this.toolCategoryService.list().stream().collect(Collectors.toMap((v0) -> {
|
return v0.getId();
|
}, (v0) -> {
|
return v0.getName();
|
}));
|
if (Func.isEmpty(employee)) {
|
throw new ServiceException(MessageUtils.message("sys.outer.user.not.bind.employee", new Object[0]));
|
}
|
ToolChangeRecord toolChangeRecord = ToolChangeRecordConvert.INSTANCE.toolToConvert(toolManage);
|
toolChangeRecord.setEmployeeName(employee.getName()).setEmployeeId(employee.getId()).setOperationType(ToolOperationTypeEnum.EQUIP.getCode());
|
toolChangeRecord.setToolModel(modelNameMap.get(toolChangeRecord.getToolModelId()));
|
toolChangeRecord.setToolCategory(categoryNameMap.get(toolChangeRecord.getToolCategoryId()));
|
save(toolChangeRecord);
|
}
|
}
|
