package com.product.device.service;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.beust.jcommander.internal.Lists;
|
import com.product.core.config.CoreConst;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.device.config.DeviceCode;
|
import com.product.device.config.DeviceConst;
|
import com.product.device.service.idel.IDeviceMainenanceService;
|
import com.product.module.sys.entity.SystemUser;
|
import com.product.task.device.service.DeviceManagerTaskService;
|
import com.product.util.BaseUtil;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
|
|
/**
|
* 设备维修
|
*
|
* @Author
|
* @Date 2022/3/8 16:33
|
* @Desc 功能相关 service
|
*/
|
@Service
|
public class DeviceMainenanceService extends AbstractBaseService implements IDeviceMainenanceService {
|
|
@Autowired
|
public BaseDao baseDao;
|
@Autowired
|
DeviceManagerService deviceManagerService;
|
@Autowired
|
DeviceManagerTaskService deviceManagerTaskService;
|
|
/**
|
* 获取设备信息 包括子设备
|
*
|
* @return
|
*/
|
@Transactional
|
public String saveDeviceFailure(FieldSetEntity fs) {
|
SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
|
if (fs != null) {
|
fs.setValue("org_level_uuid", currentUser.getOrg_level_uuid());
|
}
|
fs.setTableName(DeviceConst.TABLE_PRODUCT_REPAIR_FAILURE);
|
boolean b = baseDao.saveFieldSetEntity(fs);
|
if (b) {
|
//修改设备的状态为停机维修
|
deviceManagerService.deviceStatusChange(fs.getString("asset_code"), "2");
|
// //上报任务生成
|
// deviceManagerTaskService.createTask();
|
//设备运行记录
|
deviceManagerService.appendDeivceManageLog(fs.getString("asset_code"), fs.getString("created_by"), "", "设备故障上报", "product_device_repair_failure_record", fs.getString("uuid"));
|
}
|
|
return fs.getString(CoreConst.UUID);
|
}
|
|
/**
|
* 创建维修任务，第一次可能选中的是调度人，也可能是维修人员
|
*
|
* @param fs
|
*/
|
public void createMaintainTask(FieldSetEntity fs) {
|
|
deviceManagerTaskService.createTask();
|
}
|
|
|
/**
|
* 获取本年已完成的保养记录
|
*/
|
public DataTableEntity getMaintainByCurrentYear(FieldSetEntity fse) {
|
StringBuilder sql = new StringBuilder();
|
sql.append("\nSELECT b.*,a.plan_maintenance_time,a.maintenance_user,a.maintenance_time,a.check_user,a.check_time FROM `product_device_maintenance_record` a ");
|
sql.append("\nINNER JOIN `product_device_info` b ON a. device_uuid=b.uuid ");
|
sql.append("\nwhere length(a.check_user)>0 ");
|
String elevatorVariety = fse.getString("elevator_variety");
|
String maintenanceUnit = fse.getString("maintenance_unit");
|
List<Object> params = StringUtils.isAnyEmpty(elevatorVariety, maintenanceUnit) ? new ArrayList<>() : null;
|
if (!StringUtils.isEmpty(elevatorVariety)) {
|
String[] split = elevatorVariety.split(",");
|
sql.append("\nAND ").append(BaseUtil.buildQuestionMarkFilter("b.elevator_variety", split.length, true));
|
params.addAll(CollectionUtil.toList(split));
|
}
|
if (!StringUtils.isEmpty(maintenanceUnit)) {
|
sql.append("\nAND b.maintenance_unit=? ");
|
params.add(elevatorVariety);
|
}
|
Integer cpage = fse.getInteger(DeviceConst.CPAGE);
|
Integer pageSize = fse.getInteger(DeviceConst.PAGESIZE);
|
//查询已复核过的记录
|
sql.append(" order by a.maintenance_time desc ");
|
DataTableEntity result = baseDao.listTable(sql.toString(), params.toArray(), pageSize, cpage);
|
result.getMeta().addAliasTable("product_device_info", "b");
|
result.getMeta().addAliasTable("product_device_maintenance_record", "a");
|
baseDao.loadPromptData(result);
|
return result;
|
}
|
|
|
public DataTableEntity getMaintainMonth(FieldSetEntity fse) {
|
Integer cpage = fse.getInteger(DeviceConst.CPAGE);
|
Integer pageSize = fse.getInteger(DeviceConst.PAGESIZE);
|
StringBuilder sql = new StringBuilder();
|
sql.append("\nSELECT b.*,a.maintenance_user, a.plan_finish_time FROM `product_device_maintenance_plan_sub`a ");
|
sql.append("\nINNER JOIN `product_device_info`b ON a.device_uuid = b.uuid ");
|
//sql查询plan_finish_time时间是否属于当月
|
sql.append("\nWHERE MONTH(a.plan_finish_time) = MONTH(NOW()) AND a.is_finish=1");
|
String elevatorVariety = fse.getString("elevator_variety");
|
String maintenanceUnit = fse.getString("maintenance_unit");
|
List<Object> params = StringUtils.isAnyEmpty(elevatorVariety, maintenanceUnit) ? new ArrayList<>() : null;
|
if (!StringUtils.isEmpty(elevatorVariety)) {
|
String[] split = elevatorVariety.split(",");
|
sql.append("\nAND ").append(BaseUtil.buildQuestionMarkFilter("b.elevator_variety", split.length, true));
|
params.addAll(CollectionUtil.toList(split));
|
}
|
if (!StringUtils.isEmpty(maintenanceUnit)) {
|
sql.append("\nAND b.maintenance_unit=? ");
|
params.add(elevatorVariety);
|
}
|
DataTableEntity result = baseDao.listTable(sql.toString(), params.toArray(), pageSize, cpage);
|
result.getMeta().addAliasTable("product_device_info", "b");
|
result.getMeta().addAliasTable("product_device_maintenance_plan_sub", "a");
|
return result;
|
}
|
|
/**
|
* 维保记录复核
|
*/
|
public boolean maintenanceReview(FieldSetEntity fse) {
|
String uuids = fse.getString("uuids");
|
if (StringUtils.isBlank(uuids)) {
|
throw new BaseException(DeviceCode.SYSTEM_FORM_COUNT);
|
}
|
|
String[] split = (SpringMVCContextHolder.getCurrentUserId() + "," + uuids).split(",");
|
return baseDao.executeUpdate("update `product_device_maintenance_record` set check_time=now(),check_user=? where is_finish=1 and " + BaseUtil.buildQuestionMarkFilter("uuid", split.length - 1, true), split);
|
}
|
|
/**
|
* 维保单位年度维保统计
|
*
|
* @param fse
|
* @return
|
*/
|
public DataTableEntity yearMaintenance(FieldSetEntity fse) {
|
// 电梯品种
|
String elevatorVariety = null;
|
// 维保单位
|
String maintenanceUnit = null;
|
if (fse != null) {
|
elevatorVariety = fse.getString("elevator_variety");
|
maintenanceUnit = fse.getString("maintenance_unit");
|
}
|
StringBuilder sql = new StringBuilder(128);
|
sql.append("\nSELECT u.`name`,count(r.uuid) record_count");
|
sql.append("\nFROM product_device_maintenance_unit u");
|
sql.append("\nLEFT JOIN product_device_info a on a.maintenance_unit=u.uuid");
|
sql.append("\nLEFT JOIN product_device_maintenance_record r on r.device_uuid=a.uuid");
|
StringBuilder filterSql = new StringBuilder(32);
|
List<String> param = Lists.newArrayList();
|
if (!StringUtils.isEmpty(elevatorVariety)) {
|
String[] arr = elevatorVariety.split(",");
|
filterSql.append(BaseUtil.buildQuestionMarkFilter("elevator_variety", arr.length, true));
|
param.addAll(Arrays.asList(arr));
|
}
|
if (!StringUtils.isEmpty(maintenanceUnit)) {
|
if (filterSql.length() > 0) {
|
filterSql.append(" AND ");
|
}
|
String[] arr = maintenanceUnit.split(",");
|
filterSql.append(BaseUtil.buildQuestionMarkFilter("maintenance_unit", arr.length, true));
|
param.addAll(Arrays.asList(arr));
|
}
|
if (filterSql.length() > 0) {
|
sql.append("\nWHERE ").append(filterSql);
|
}
|
sql.append("\nGROUP BY u.uuid");
|
return baseDao.listTable(sql.toString(), param.toArray());
|
}
|
|
/**
|
* 维保单位年度维保任务完成情况
|
*
|
* @param fse
|
* @return
|
*/
|
public DataTableEntity yearMaintenanceFinish(FieldSetEntity fse) {
|
// 电梯品种
|
String elevatorVariety = null;
|
// 维保单位
|
String maintenanceUnit = null;
|
if (fse != null) {
|
elevatorVariety = fse.getString("elevator_variety");
|
maintenanceUnit = fse.getString("maintenance_unit");
|
}
|
StringBuilder sql = new StringBuilder(128);
|
sql.append("\nSELECT T.*,CASE WHEN record_count = 0 THEN 0 ELSE ROUND(finish_count / record_count, 4) END finish_rate");
|
sql.append("\nFROM (");
|
sql.append("\n SELECT u.name,a.device_number,a.device_unit,a.device_code,d.manufacture_company,count(r.uuid) record_count, count(r.is_finish) + 1 finish_count");
|
sql.append("\n FROM product_device_maintenance_unit u");
|
sql.append("\n JOIN product_device_info a on a.maintenance_unit=u.uuid");
|
sql.append("\n JOIN product_device_archives d on a.archives_uuid=d.uuid");
|
sql.append("\n JOIN product_device_maintenance_record r on r.device_uuid=a.uuid");
|
StringBuilder filterSql = new StringBuilder(32);
|
List<String> param = Lists.newArrayList();
|
if (!StringUtils.isEmpty(elevatorVariety)) {
|
String[] arr = elevatorVariety.split(",");
|
filterSql.append(BaseUtil.buildQuestionMarkFilter("elevator_variety", arr.length, true));
|
param.addAll(Arrays.asList(arr));
|
}
|
if (!StringUtils.isEmpty(maintenanceUnit)) {
|
if (filterSql.length() > 0) {
|
filterSql.append(" AND ");
|
}
|
String[] arr = maintenanceUnit.split(",");
|
filterSql.append(BaseUtil.buildQuestionMarkFilter("maintenance_unit", arr.length, true));
|
param.addAll(Arrays.asList(arr));
|
}
|
if (filterSql.length() > 0) {
|
sql.append("\n WHERE ").append(filterSql);
|
}
|
sql.append("\n GROUP BY 1,2,3,4,5");
|
sql.append("\n) T");
|
return baseDao.listTable(sql.toString(), param.toArray());
|
}
|
|
/**
|
* 设备的保养配置
|
*
|
* @param asset_code 设备编号
|
* @param manceType 保养类型
|
* @return
|
*/
|
public FieldSetEntity findDeviceMaintenanceSetting(String uuid, String manceType) {
|
|
FieldSetEntity device = deviceManagerService.findDevice(uuid);
|
|
FieldSetEntity record = new FieldSetEntity("product_device_maintenance_record");
|
record.setValue("device_uuid", device.getString("device_name"));
|
record.setValue("device_number", device.getString("device_number"));
|
record.setValue("device_uuid_save_value", device.getString("uuid"));
|
String sql = "select c.item_uuid,c.content ,c.criterion from product_device_maintenance_setting a left join product_device_maintenance_item_config b on\r\n"
|
+ "a.maintenance_item=b.uuid join \r\n"
|
+ "product_device_maintenance_item_detail c on b.uuid= c.item_uuid\r\n"
|
+ "where device_uuid=? and maintenance_type=? and c.is_used=1 \r\n"
|
+ "order by item_uuid";
|
DataTableEntity dataTableEntity = baseDao.listTable(sql, new String[]{uuid, manceType});
|
record.addSubDataTable(dataTableEntity);
|
|
return record;
|
}
|
}
|
