From 37ad4f4417c940b2b376cbcdcc22a097f2cd12a9 Mon Sep 17 00:00:00 2001
From: lyh <925863403@qq.com>
Date: 星期四, 14 八月 2025 16:55:35 +0800
Subject: [PATCH] 二保批量打印接口
---
lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamRepairOrderServiceImpl.java | 118 ++++++++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 108 insertions(+), 10 deletions(-)
diff --git a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamRepairOrderServiceImpl.java b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamRepairOrderServiceImpl.java
index 92eb973..1f74848 100644
--- a/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamRepairOrderServiceImpl.java
+++ b/lxzn-module-eam-common/src/main/java/org/jeecg/modules/eam/service/impl/EamRepairOrderServiceImpl.java
@@ -19,6 +19,7 @@
import org.jeecg.modules.eam.aspect.annotation.EquipmentHistoryLog;
import org.jeecg.modules.eam.constant.*;
import org.jeecg.modules.eam.dto.EamRepairOrderDto;
+import org.jeecg.modules.eam.dto.EamRepairOrderExport;
import org.jeecg.modules.eam.entity.EamEquipment;
import org.jeecg.modules.eam.entity.EamRepairOrder;
import org.jeecg.modules.eam.entity.EamRepairPerson;
@@ -36,6 +37,7 @@
import org.jeecg.modules.flowable.apithird.service.FlowCommonService;
import org.jeecg.modules.flowable.service.IFlowDefinitionService;
import org.jeecg.modules.flowable.service.IFlowTaskService;
+import org.jeecg.modules.flowable.util.TimeUtil;
import org.jeecg.modules.system.entity.BaseFactory;
import org.jeecg.modules.system.entity.BaseFactoryUser;
import org.jeecg.modules.system.service.IBaseFactoryService;
@@ -205,6 +207,18 @@
}
BeanUtils.copyProperties(eamRepairOrderDto,eamRepairOrder);
eamRepairOrder.setRepairStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name());
+ eamRepairOrder.setActualEndTime(new Date());
+ //璁＄畻缁翠慨鏃堕棿涓庢晠闅滄椂闂�
+ Date startTime;
+ Date endTime;
+ //缁翠慨缁撴潫鏃堕棿-缁翠慨寮�濮嬫椂闂�=缁翠慨鏃堕暱
+ startTime=eamRepairOrder.getActualStartTime();
+ endTime=eamRepairOrder.getActualEndTime();
+ eamRepairOrder.setRepairDuration(TimeUtil.howLong(startTime,endTime,2));
+ //缁翠慨缁撴潫鏃堕棿-鏁呴殰鎶ヤ慨鏃堕棿=鏁呴殰鏃堕暱
+ startTime=eamRepairOrder.getCreateTime();
+ endTime=eamRepairOrder.getActualEndTime();
+ eamRepairOrder.setFaultDuration(TimeUtil.howLong(startTime,endTime,2));
this.updateById(eamRepairOrder);
EamReportRepair eamReportRepair=eamReportRepairService.getById(eamRepairOrder.getReportId());
if (eamReportRepair==null){
@@ -212,14 +226,16 @@
}
eamReportRepair.setReportStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name());
eamReportRepairService.updateById(eamReportRepair);
+ List<EamRepairPerson> eamRepairPersonList=new ArrayList<>();
iEamRepairPersonService.remove(new QueryWrapper<EamRepairPerson>().eq("repair_id",eamRepairOrderDto.getId()));
- if(CollectionUtils.isNotEmpty(eamRepairOrderDto.getEamRepairPersonList())) {
- List<EamRepairPerson> persons = eamRepairOrderDto.getEamRepairPersonList().stream()
- .map(person -> new EamRepairPerson()
- .setRepairId(eamRepairOrder.getId())
- .setDelFlag(CommonConstant.DEL_FLAG_0))
- .collect(Collectors.toList());
- iEamRepairPersonService.saveBatch(persons);
+ if (CollectionUtils.isNotEmpty(eamRepairOrderDto.getEamRepairPersonList())) {
+ eamRepairOrderDto.getEamRepairPersonList().forEach(eamRepairPerson -> {
+ eamRepairPerson.setId(null);
+ eamRepairPerson.setRepairId(eamRepairOrder.getId());
+ eamRepairPerson.setDelFlag(CommonConstant.DEL_FLAG_0);
+ eamRepairPersonList.add(eamRepairPerson);
+ });
+ iEamRepairPersonService.saveBatch(eamRepairPersonList);
}
return true;
}
@@ -233,7 +249,21 @@
if (CollectionUtils.isEmpty(eamRepairPersonList)) {
throw new RuntimeException("缁翠慨浜哄憳涓嶈兘涓虹┖");
}
- if (StrUtil.isEmpty(eamRepairOrder.getRepairCode())) {}
+ if (StrUtil.isEmpty(eamRepairOrder.getRepairCode())) {
+ throw new RuntimeException("宸ュ崟缂栧彿涓虹┖");
+ }
+ if (StrUtil.isEmpty(eamRepairOrder.getFaultReason())){
+ throw new RuntimeException("鏁呴殰鍘熷洜涓虹┖");
+ }
+ if (StrUtil.isEmpty(eamRepairOrder.getFaultAnalysis())){
+ throw new RuntimeException("鏁呴殰鍒嗘瀽涓虹┖");
+ }
+ if (StrUtil.isEmpty(eamRepairOrder.getFaultProcess())){
+ throw new RuntimeException("鎺掓晠杩囩▼涓虹┖");
+ }
+ if (StrUtil.isEmpty(eamRepairOrder.getFaultPrevent())){
+ throw new RuntimeException("鏁呴殰棰勯槻涓虹┖");
+ }
LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
EamEquipment eamEquipment = eamEquipmentService.getById(eamRepairOrder.getEquipmentId());
List<UserSelector> userSelectorList = sysUserService.selectOperatorList(eamEquipment.getEquipmentCode(), eamEquipment.getFactoryOrgCode(), BusinessCodeConst.PCR0001);
@@ -325,7 +355,7 @@
if ("1".equals(request.getConfirmResult())) {
order.setRepairStatus(EamRepairOrderRepairStatusEnum.REPAIR_COMPLETED.name());
}else {
- order.setRepairStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name());
+ order.setRepairStatus(EamRepairOrderRepairStatusEnum.REJECTED.name());
}
}
order.setConfirmer(user.getUsername());
@@ -334,7 +364,7 @@
order.setConfirmComment(request.getConfirmComment());
this.baseMapper.updateById(order);
EamReportRepair eamReportRepair=eamReportRepairService.getById(order.getReportId());
- eamReportRepair.setReportStatus(EamRepairOrderRepairStatusEnum.UNDER_MAINTENANCE.name());
+ eamReportRepair.setReportStatus(order.getRepairStatus());
eamReportRepairService.updateById(eamReportRepair);
return order;
}
@@ -349,6 +379,74 @@
return eamRepairOrderResponse;
}
+ /**
+ * 缁翠慨宸ュ崟瀵煎嚭
+ * @param eamRepairOrderQuery
+ * @return
+ */
+ @Override
+ public List<EamRepairOrderExport> exportList(EamRepairOrderQuery eamRepairOrderQuery){
+ QueryWrapper<EamRepairOrderExport> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("wmo.del_flag", CommonConstant.DEL_FLAG_0);
+ //鐢ㄦ埛鏁版嵁鏉冮檺
+ LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
+ if (sysUser == null) {
+ return new ArrayList<>();
+ }
+ if (StringUtils.isNotBlank(sysUser.getEamEquipmentIds())) {
+ //閫夋嫨浜嗚澶囷紝鏍规嵁璁惧id杩囨护璁惧
+ List<String> equipArr = Arrays.asList(sysUser.getEamEquipmentIds().split(","));
+ queryWrapper.in("e.equipment_code", equipArr);
+ } else {
+ //娌℃湁閫夋嫨璁惧锛屾牴鎹腑蹇冭繃婊よ澶�
+ List<BaseFactoryUser> baseFactoryUserList = baseFactoryUserService.
+ list(new LambdaQueryWrapper<BaseFactoryUser>().eq(BaseFactoryUser::getUserId, sysUser.getId()));
+ if (!CollectionUtils.isEmpty(baseFactoryUserList)) {
+ Set<String> factoryIds = baseFactoryUserList.stream().map(BaseFactoryUser::getFactoryId).collect(Collectors.toSet());
+ Set<String> factoryCode = baseFactoryService.listByIds(factoryIds).stream().map(BaseFactory::getOrgCode).collect(Collectors.toSet());
+ queryWrapper.in("e.factory_org_code", factoryCode);
+ } else {
+ return new ArrayList<>();
+ }
+ }
+ //鏌ヨ鏉′欢杩囨护
+ if (eamRepairOrderQuery != null) {
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentId())) {
+ queryWrapper.eq("wmo.equipment_id", eamRepairOrderQuery.getEquipmentId());
+ }
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentCode())) {
+ queryWrapper.like("e.equipment_code", eamRepairOrderQuery.getEquipmentCode());
+ }
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getEquipmentName())) {
+ queryWrapper.like("e.equipment_name", eamRepairOrderQuery.getEquipmentName());
+ }
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getRepairStatus())) {
+ queryWrapper.eq("wmo.repair_status", eamRepairOrderQuery.getRepairStatus());
+ }
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getRepairCode())) {
+ queryWrapper.like("wmo.repair_code", eamRepairOrderQuery.getRepairCode());
+ }
+ //鎺掑簭
+ if (StringUtils.isNotBlank(eamRepairOrderQuery.getColumn()) && StringUtils.isNotBlank(eamRepairOrderQuery.getOrder())) {
+ String column = eamRepairOrderQuery.getColumn();
+ if (column.endsWith(CommonConstant.DICT_TEXT_SUFFIX)) {
+ column = column.substring(0, column.lastIndexOf(CommonConstant.DICT_TEXT_SUFFIX));
+ }
+ if (DataBaseConstant.SQL_ASC.equalsIgnoreCase(eamRepairOrderQuery.getOrder())) {
+ queryWrapper.orderByAsc("wmo." + oConvertUtils.camelToUnderline(column));
+ } else {
+ queryWrapper.orderByDesc("wmo." + oConvertUtils.camelToUnderline(column));
+ }
+ } else {
+ queryWrapper.orderByDesc("wmo.create_time");
+ }
+ } else {
+ queryWrapper.orderByDesc("wmo.create_time");
+ }
+ return this.baseMapper.queryExportList(queryWrapper);
+
+ }
+
private boolean claimTask(String taskId, LoginUser user) {
Task task = taskService.createTaskQuery().taskId(taskId).singleResult();
if (task == null) {
--
Gitblit v1.9.3