Merge remote-tracking branch 'origin/master'

zhangherong

2025-07-10 82cae82571a0c6c57ee5dc357efaf0e238c20ac9

 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentController.java

@@ -1,508 +1,390 @@
package org.jeecg.modules.eam.controller;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.common.system.base.controller.JeecgController;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.common.util.TranslateDictTextUtils;
import org.jeecg.common.util.oConvertUtils;
import org.jeecg.modules.eam.dto.EamEquipmentDto;
import org.jeecg.modules.eam.entity.EamEquipment;
import org.jeecg.modules.eam.entity.EamEquipmentExtend;
import org.jeecg.modules.eam.request.EamEquipmentQuery;
import org.jeecg.modules.eam.service.IEamEquipmentExtendService;
import org.jeecg.modules.eam.service.IEamEquipmentService;
import org.jeecg.modules.eam.vo.EamEquipmentTree;
import org.jeecg.modules.eam.vo.EquipmentSearchResult;
import org.jeecg.modules.system.entity.BaseFactory;
import org.jeecg.modules.system.entity.EamBaseRepairDepart;
import org.jeecg.modules.system.service.IBaseFactoryService;
import org.jeecg.modules.system.service.IEamBaseRepairDepartService;
import org.jeecgframework.poi.excel.ExcelImportUtil;
import org.jeecgframework.poi.excel.def.NormalExcelConstants;
import org.jeecgframework.poi.excel.entity.ExportParams;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.jeecgframework.poi.excel.view.JeecgEntityExcelView;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.stream.Collectors;

import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.common.system.api.ISysBaseAPI;
import org.jeecg.common.system.base.entity.SysUpload;
import org.jeecg.common.system.query.QueryGenerator;
import org.jeecg.modules.eam.entity.*;
import org.jeecg.modules.eam.model.DepartVo;
import org.jeecg.modules.eam.service.*;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;

import org.jeecg.common.system.base.controller.JeecgController;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.jeecg.common.aspect.annotation.AutoLog;

 /**
 * @Description: mom_eam_equipment
/**
 * @Description: 设备台账
 * @Author: jeecg-boot
 * @Date:   2023-03-23
 * @Date: 2025-03-19
 * @Version: V1.0
 */
@Api(tags="mom_eam_equipment")
@Slf4j
@Api(tags = "设备台账")
@RestController
@RequestMapping("/eam/equipment")
@Slf4j
public class EamEquipmentController extends JeecgController<Equipment, IEamEquipmentService> {
   @Autowired
   private IEamEquipmentService equipmentService;
public class EamEquipmentController extends JeecgController<EamEquipment, IEamEquipmentService> {
    @Autowired
    private IEamEquipmentService eamEquipmentService;

   @Autowired
   private IPrecisionParametersTemplateDetailService precisionParametersTemplateDetailService;
    @Autowired
    private IEamEquipmentExtendService eamEquipmentExtendService;

   @Autowired
   private IProcessParametersTemplateDetailService processParametersTemplateDetailService;
//    @Autowired
//    private IMdcEquipmentService mdcEquipmentService;

    @Autowired
   private IEquipmentProcessParametersService equipmentProcessParametersService;

    @Autowired
   private IEquipmentPrecisionParametersService equipmentPrecisionParametersService;

    @Autowired
    private IPrecisionParametersTemplateService precisionParametersTemplateService;

    @Autowired
    private IProcessParametersTemplateService processParametersTemplateService;

//    @Autowired
//    private IUploadRelaService uploadRelaService;

    @Autowired
    private ISysBaseAPI sysBaseApi;

    @Autowired
    @Lazy
    private IEquipmentSealDetailService equipmentSealDetailService;

    @Autowired
    @Lazy
    private IInspectionOrderDetailService inspectionOrderDetailService;

    @Autowired
    @Lazy
    private ISpecialtyInspectionOrderDetailService specialtyInspectionOrderDetailService;

    @Autowired
    private ICalibrationOrderDetailService calibrationOrderDetailService;

    @Autowired
    private ICalibrationOrderReportService calibrationOrderReportService;
   /**
    * 分页列表查询
    *
    * @param equipment
    * @param pageNo
    * @param pageSize
    * @param req
    * @return
    */
   //@AutoLog(value = "mom_eam_equipment-分页列表查询")
   @ApiOperation(value="mom_eam_equipment-分页列表查询", notes="mom_eam_equipment-分页列表查询")
   @GetMapping(value = "/list")
   public Result<IPage<Equipment>> queryPageList(Equipment equipment,
                                      @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                      @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
                                      HttpServletRequest req) {
      //QueryWrapper<Equipment> queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap());
      QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
      if(StringUtils.isNotBlank(equipment.getNum())){
         queryWrapper.like("num",equipment.getNum());
      }
      if(StringUtils.isNotBlank(equipment.getName())){
         queryWrapper.like("name",equipment.getName());
      }
      if(StringUtils.isNotBlank(equipment.getEquipmentStatus())){
         queryWrapper.eq("equipment_status",equipment.getEquipmentStatus());
      }
      if(StringUtils.isNotBlank(equipment.getTechnologyStatus())){
         queryWrapper.eq("technology_status",equipment.getTechnologyStatus());
      }
      if(StringUtils.isNotBlank(equipment.getEquipmentCategoryId())){
         queryWrapper.eq("equipment_category_id",equipment.getEquipmentCategoryId());
      }

      queryWrapper.eq("status","1");
      queryWrapper.eq("del_flag",0);
      queryWrapper.orderByDesc("create_time");

      Page<Equipment> page = new Page<Equipment>(pageNo, pageSize);
      IPage<Equipment> pageList = equipmentService.page(page, queryWrapper);
      List<Equipment> equipmentList = pageList.getRecords();
      for (Equipment eq : equipmentList) {
         String precisionParametersTemplateId = eq.getPrecisionParametersTemplateId();
         if(StringUtils.isNotBlank(precisionParametersTemplateId)){
            PrecisionParametersTemplate precisionParametersTemplate = precisionParametersTemplateService.getById(precisionParametersTemplateId);
            if(precisionParametersTemplate != null){
               eq.setPrecisionParametersTemplateName(precisionParametersTemplate.getName());
            }else{
               eq.setPrecisionParametersTemplateName("");
            }
         }else{
            eq.setPrecisionParametersTemplateName("");
         }

//         String processParametersTemplateId = eq.getProcessParametersTemplateId();
//         if(StringUtils.isNotBlank(processParametersTemplateId)){
//            ProcessParametersTemplate processParametersTemplate = processParametersTemplateService.getById(processParametersTemplateId);
//            if(processParametersTemplate != null){
//               eq.setProcessParametersTemplateName(processParametersTemplate.getName());
//            }else{
//               eq.setProcessParametersTemplateName("");
//            }
//         }else{
//            eq.setProcessParametersTemplateName("");
//         }
         //查询封存原因和封存日期
         List<EquipmentSealDetail> equipmentSealDetailList = equipmentSealDetailService.lambdaQuery().eq(EquipmentSealDetail::getEquipmentId,eq.getId())
               .eq(EquipmentSealDetail::getDelFlag, CommonConstant.DEL_FLAG_0).orderByDesc(EquipmentSealDetail::getCreateTime).list();
         if(CollectionUtils.isNotEmpty(equipmentSealDetailList)){
            eq.setSealReason(equipmentSealDetailList.get(0).getSealReason());
            eq.setSealDate(equipmentSealDetailList.get(0).getSealDate());
         }
      }
      return Result.OK(pageList);
   }


    /**
     * 设备保修  获取设备列表组件
     * qsw 2023-7-14
     */
    @GetMapping(value = "/getEquipmentList")
    public Result<IPage<Equipment>> getEquipmentList(Equipment equipment,
                                       @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                       @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
                                       HttpServletRequest req) {
       QueryWrapper<Equipment> queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap());
       Page<Equipment> page = new Page<Equipment>(pageNo, pageSize);
       IPage<Equipment> pageList = equipmentService.page(page, queryWrapper);
       return Result.OK(pageList);
    }
	
   /**
    *   添加
    *
    * @param equipment
    * @return
    */
   @AutoLog(value = "mom_eam_equipment-添加")
   @ApiOperation(value="mom_eam_equipment-添加", notes="mom_eam_equipment-添加")
   @PostMapping(value = "/add")
   @Transactional(rollbackFor = { Exception.class })
   public Result<String> add(@RequestBody Equipment equipment) {
      equipmentService.save(equipment);
      //获取工艺参数模板明细
      String processParametersTemplateId = equipment.getProcessParametersTemplateId();
      List<ProcessParametersTemplateDetail> processParameters = processParametersTemplateDetailService.lambdaQuery()
            .eq(ProcessParametersTemplateDetail::getProcessParametersTemplateId, processParametersTemplateId)
            .eq(ProcessParametersTemplateDetail::getDelFlag, 0).list();
      for (ProcessParametersTemplateDetail processParameter : processParameters) {
         EquipmentProcessParameters equipmentProcessParameters = new EquipmentProcessParameters();
         equipmentProcessParameters.setEquipmentId(equipment.getId());
         equipmentProcessParameters.setProcessParametersId(processParameter.getProcessParametersId());
         equipmentProcessParametersService.save(equipmentProcessParameters);
      }
      //获取设备精度参数模板明细
      String precisionParametersTemplateId = equipment.getPrecisionParametersTemplateId();
      List<PrecisionParametersTemplateDetail> precisionParameters = precisionParametersTemplateDetailService.lambdaQuery()
            .eq(PrecisionParametersTemplateDetail::getPrecisionParametersTemplateId, precisionParametersTemplateId)
            .eq(PrecisionParametersTemplateDetail::getDelFlag, 0).list();
      for (PrecisionParametersTemplateDetail precisionParameter : precisionParameters) {
         EquipmentPrecisionParameters equipmentPrecisionParameters = new EquipmentPrecisionParameters();
         equipmentPrecisionParameters.setEquipmentId(equipment.getId());
         equipmentPrecisionParameters.setPrecisionParametersId(precisionParameter.getPrecisionParametersId());
         equipmentPrecisionParametersService.save(equipmentPrecisionParameters);
      }

      List<SysUpload> sysUploads = equipment.getSysUploadList();
      if (sysUploads!= null){
//         uploadRelaService.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId());
         sysBaseApi.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId());
      }
      return Result.OK("添加成功！");
   }
	
   /**
    *  编辑
    *
    * @param equipment
    * @return
    */
   @AutoLog(value = "mom_eam_equipment-编辑")
   @ApiOperation(value="mom_eam_equipment-编辑", notes="mom_eam_equipment-编辑")
   @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST})
   @Transactional(rollbackFor = { Exception.class })
   public Result<String> edit(@RequestBody Equipment equipment) {

      List<EquipmentProcessParameters> proParameters = equipmentProcessParametersService.lambdaQuery()
            .eq(EquipmentProcessParameters::getEquipmentId, equipment.getId())
            .eq(EquipmentProcessParameters::getDelFlag, 0).list();
      for (EquipmentProcessParameters proParameter : proParameters) {
         equipmentProcessParametersService.removeById(proParameter);
      }

      List<EquipmentPrecisionParameters> preParameters = equipmentPrecisionParametersService.lambdaQuery()
            .eq(EquipmentPrecisionParameters::getEquipmentId, equipment.getId())
            .eq(EquipmentPrecisionParameters::getDelFlag, 0).list();
      for (EquipmentPrecisionParameters preParameter : preParameters) {
         equipmentPrecisionParametersService.removeById(preParameter);
      }

      //获取工艺参数模板明细
      String processParametersTemplateId = equipment.getProcessParametersTemplateId();
      List<ProcessParametersTemplateDetail> processParameters = processParametersTemplateDetailService.lambdaQuery()
            .eq(ProcessParametersTemplateDetail::getProcessParametersTemplateId, processParametersTemplateId)
            .eq(ProcessParametersTemplateDetail::getDelFlag, 0).list();
      for (ProcessParametersTemplateDetail processParameter : processParameters) {
         EquipmentProcessParameters equipmentProcessParameters = new EquipmentProcessParameters();
         equipmentProcessParameters.setEquipmentId(equipment.getId());
         equipmentProcessParameters.setProcessParametersId(processParameter.getProcessParametersId());
         equipmentProcessParametersService.save(equipmentProcessParameters);
      }
      //获取设备精度参数模板明细
      String precisionParametersTemplateId = equipment.getPrecisionParametersTemplateId();
      List<PrecisionParametersTemplateDetail> precisionParameters = precisionParametersTemplateDetailService.lambdaQuery()
            .eq(PrecisionParametersTemplateDetail::getPrecisionParametersTemplateId, precisionParametersTemplateId)
            .eq(PrecisionParametersTemplateDetail::getDelFlag, 0).list();
      for (PrecisionParametersTemplateDetail precisionParameter : precisionParameters) {
         EquipmentPrecisionParameters equipmentPrecisionParameters = new EquipmentPrecisionParameters();
         equipmentPrecisionParameters.setEquipmentId(equipment.getId());
         equipmentPrecisionParameters.setPrecisionParametersId(precisionParameter.getPrecisionParametersId());
         equipmentPrecisionParametersService.save(equipmentPrecisionParameters);
      }

      equipmentService.updateById(equipment);

      List<SysUpload> sysUploads = equipment.getSysUploadList();
      if (sysUploads!= null){
//         uploadRelaService.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId());
         sysBaseApi.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId());
      }
      return Result.OK("编辑成功!");
   }
	
   /**
    *   通过id删除
    *
    * @param id
    * @return
    */
   @AutoLog(value = "mom_eam_equipment-通过id删除")
   @ApiOperation(value="mom_eam_equipment-通过id删除", notes="mom_eam_equipment-通过id删除")
   //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:delete")
   @DeleteMapping(value = "/delete")
   public Result<String> delete(@RequestParam(name="id",required=true) String id) {
      Equipment equipment = equipmentService.getById(id);
      equipment.setDelFlag(1);
      equipmentService.updateById(equipment);
      return Result.OK("删除成功!");
   }
	
   /**
    *  批量删除
    *
    * @param ids
    * @return
    */
   @AutoLog(value = "mom_eam_equipment-批量删除")
   @ApiOperation(value="mom_eam_equipment-批量删除", notes="mom_eam_equipment-批量删除")
   //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:deleteBatch")
   @DeleteMapping(value = "/deleteBatch")
   public Result<String> deleteBatch(@RequestParam(name="ids",required=true) String ids) {
      List<String> stringList = Arrays.asList(ids.split(","));
      for (String id : stringList) {
         Equipment equipment = equipmentService.getById(id);
         equipment.setDelFlag(1);
         equipmentService.updateById(equipment);
      }
//      this.equipmentService.removeByIds(Arrays.asList(ids.split(",")));
      return Result.OK("批量删除成功!");
   }
	
   /**
    * 通过id查询
    *
    * @param id
    * @return
    */
   //@AutoLog(value = "mom_eam_equipment-通过id查询")
   @ApiOperation(value="mom_eam_equipment-通过id查询", notes="mom_eam_equipment-通过id查询")
   @GetMapping(value = "/queryById")
   public Result<Equipment> queryById(@RequestParam(name="id",required=true) String id) {
      Equipment equipment = equipmentService.getById(id);
      if(equipment==null) {
         return Result.error("未找到对应数据");
      }
      return Result.OK(equipment);
   }

    @Autowired
    private ObjectMapper objectMapper;
    @Autowired
    private TranslateDictTextUtils translateDictTextUtils;
    @Autowired
    private IBaseFactoryService baseFactoryService;
    @Autowired
    private IEamBaseRepairDepartService eamBaseRepairDepartService;
    /**
    * 导出excel
    *
    * @param request
    * @param equipment
    */
    //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:exportXls")
    @RequestMapping(value = "/exportXls")
    public ModelAndView exportXls(HttpServletRequest request, Equipment equipment) {
        return super.exportXls(request, equipment, Equipment.class, "mom_eam_equipment");
     * 分页列表查询
     *
     * @param eamEquipment
     * @param pageNo
     * @param pageSize
     * @return
     */
//    @AutoLog(value = "设备台账-分页列表查询")
    @ApiOperation(value = "设备台账-分页列表查询", notes = "设备台账-分页列表查询")
    @GetMapping(value = "/list")
    public Result<?> queryPageList(EamEquipmentQuery eamEquipment,
                                   @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo,
                                   @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize) {
//        QueryWrapper<EamEquipment> queryWrapper = QueryGenerator.initQueryWrapper(eamEquipment, req.getParameterMap());
        IPage<EamEquipment> page = new Page<>(pageNo, pageSize);
        IPage<EamEquipment> pageList = eamEquipmentService.queryPageList(page, eamEquipment);
        return Result.OK(pageList);
    }

    /**
      * 通过excel导入数据
    *
    * @param request
    * @param response
    * @return
    */
    //@RequiresPermissions("mom_eam_equipment:importExcel")
     * 添加
     *
     * @param eamEquipment
     * @return
     */
//    @AutoLog(value = "设备台账-添加")
    @ApiOperation(value = "设备台账-添加", notes = "设备台账-添加")
    @PostMapping(value = "/add")
    public Result<?> add(@RequestBody EamEquipment eamEquipment) {
        EamEquipment entity = eamEquipmentService.saveEquipment(eamEquipment);
        if (entity == null) {
            return Result.OK("添加失败！");
        }
        //调用mdcEquipment插入MDC设备
//        if (CommonConstant.DEFAULT_1.equals(eamEquipment.getMdcFlag())) {
            //插入MDC设备
//            MdcEquipment mdcEquipment = new MdcEquipment();
//            mdcEquipment.setEquipmentId(entity.getEquipmentCode());
//            mdcEquipment.setEquipmentType(entity.getDeviceType());
//            mdcEquipment.setEquipmentName(entity.getEquipmentName());
//            mdcEquipmentService.addNewEquipmentFromEam(mdcEquipment, eamEquipment.getOrgId());
//        }
        return Result.OK("添加成功！");
    }

    /**
     * 编辑
     *
     * @param eamEquipment
     * @return
     */
    @ApiOperation(value = "设备台账-编辑", notes = "设备台账-编辑")
    @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST})
    public Result<?> edit(@RequestBody EamEquipment eamEquipment) {
        eamEquipmentService.updateEquipment(eamEquipment);
        return Result.OK("编辑成功!");
    }

    /**
     * 通过id删除
     *
     * @param id
     * @return
     */
    @ApiOperation(value = "设备台账-通过id删除", notes = "设备台账-通过id删除")
    @DeleteMapping(value = "/delete")
    public Result<?> delete(@RequestParam(name = "id", required = true) String id) {
        EamEquipment entity = eamEquipmentService.getById(id);
        if (entity != null) {
            entity.setDelFlag(CommonConstant.DEL_FLAG_1);
            eamEquipmentService.updateById(entity);
        }
        return Result.OK("删除成功!");
    }

    /**
     * 批量删除
     *
     * @param ids
     * @return
     */
    @ApiOperation(value = "设备台账-批量删除", notes = "设备台账-批量删除")
    @DeleteMapping(value = "/deleteBatch")
    public Result<?> deleteBatch(@RequestParam(name = "ids", required = true) String ids) {
        List<String> list = Arrays.asList(ids.split(","));
        list.forEach(id -> {
            EamEquipment entity = eamEquipmentService.getById(id);
            if (entity != null) {
                entity.setDelFlag(CommonConstant.DEL_FLAG_1);
                eamEquipmentService.updateById(entity);
            }
        });
        return Result.OK("批量删除成功！");
    }

    /**
     * 通过id查询
     *
     * @param id
     * @return
     */
    @ApiOperation(value = "设备台账-通过id查询", notes = "设备台账-通过id查询")
    @GetMapping(value = "/queryById")
    public Result<?> queryById(@RequestParam(name = "id", required = true) String id) {
        EamEquipment eamEquipment = eamEquipmentService.getById(id);
        if (eamEquipment == null) {
            return Result.error("未找到对应数据");
        }
        EamEquipmentExtend extend = eamEquipmentExtendService.getById(id);
        if(extend != null){
            eamEquipment.setRepairStatus(extend.getRepairStatus());
            eamEquipment.setMaintenanceStatus(extend.getMaintenanceStatus());
        }
        try {
            String json = objectMapper.writeValueAsString(eamEquipment);
            JSONObject item = JSONObject.parseObject(json, Feature.OrderedField);
            translateDictTextUtils.translateField("createBy", eamEquipment.getCreateBy(), item, "sys_user,realname,username");
            translateDictTextUtils.translateField("updateBy", eamEquipment.getUpdateBy(), item, "sys_user,realname,username");
//            translateDictTextUtils.translateField("technologyStatus", eamEquipment.getTechnologyStatus(), item, "technology_status");
//            translateDictTextUtils.translateField("orgId", eamEquipment.getOrgId(), item, "mdc_production,production_name,id");
//            translateDictTextUtils.translateField("equipmentManager", eamEquipment.getEquipmentManager(), item, "sys_user,realname,username");
            translateDictTextUtils.translateField("equipmentCategory", eamEquipment.getEquipmentCategory(), item, "equipment_category");
            translateDictTextUtils.translateField("assetStatus", eamEquipment.getAssetStatus(), item, "asset_status");
            translateDictTextUtils.translateField("repairStatus", eamEquipment.getRepairStatus(), item, "equipment_repair_status");
            translateDictTextUtils.translateField("maintenanceStatus", eamEquipment.getMaintenanceStatus(), item, "equipment_maintenance_status");
            return Result.OK(item);
        } catch (JsonProcessingException e) {
            return Result.error("数据转译失败！");
        }
    }

    /**
     * 导出excel
     * @param eamEquipment
     */
    @RequestMapping(value = "/exportXls")
    public ModelAndView exportXls(HttpServletRequest request,EamEquipmentQuery eamEquipment) {
        LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
        List<EamEquipment> equipmentList=eamEquipmentService.exportList(eamEquipment);
        List<EamEquipmentDto> eamEquipmentDtos=new ArrayList<>();
        String selections = request.getParameter("selections");
        if (oConvertUtils.isNotEmpty(selections)) {
            List<String> selectionList = Arrays.asList(selections.split(","));
            equipmentList = equipmentList.stream().filter(item -> selectionList.contains(item.getId())).collect(Collectors.toList());
        }
        equipmentList.forEach(item -> {
            EamEquipmentDto eamEquipmentDto = new EamEquipmentDto();
            BeanUtils.copyProperties(item,eamEquipmentDto);
            if (eamEquipmentDto.getFactoryOrgCode().length()==12){
                eamEquipmentDto.setFactoryOrgCode(
                        baseFactoryService.factoryDataNameByOrgCode(eamEquipmentDto.getZxfactoryOrgCode())
                        +"/"+baseFactoryService.factoryDataNameByOrgCode(eamEquipmentDto.getGqfactoryOrgCode())+"/"+
                                baseFactoryService.factoryDataNameByOrgCode(eamEquipmentDto.getFactoryOrgCode()));
            }else {
                eamEquipmentDto.setFactoryOrgCode(
                        baseFactoryService.factoryDataNameByOrgCode(eamEquipmentDto.getZxfactoryOrgCode())
                                +"/"+ baseFactoryService.factoryDataNameByOrgCode(eamEquipmentDto.getFactoryOrgCode()));
            }
            eamEquipmentDto.setEquipmentWeightStr(eamEquipmentDto.getEquipmentWeight().toEngineeringString());
            eamEquipmentDtos.add(eamEquipmentDto);
        });
        // Step.3 AutoPoi 导出Excel
        ModelAndView mv = new ModelAndView(new JeecgEntityExcelView());
        mv.addObject(NormalExcelConstants.FILE_NAME, "设备台账"); //此处设置的filename无效 ,前端会重更新设置一下
        mv.addObject(NormalExcelConstants.CLASS, EamEquipmentDto.class);
        mv.addObject(NormalExcelConstants.PARAMS, new ExportParams("设备台账" + "报表", "导出人:" + sysUser.getRealname(), "设备台账"));
        mv.addObject(NormalExcelConstants.DATA_LIST, eamEquipmentDtos);
        return mv;

    }

    /**
     * 通过excel导入数据
     *
     * @param request
     * @param response
     * @return
     */
    @RequestMapping(value = "/importExcel", method = RequestMethod.POST)
    public Result<?> importExcel(HttpServletRequest request, HttpServletResponse response) {
        return super.importExcel(request, response, Equipment.class);
        MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request;
        Map<String, MultipartFile> fileMap = multipartRequest.getFileMap();
        for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) {
            // 获取上传文件对象
            MultipartFile file = entity.getValue();
            ImportParams params = new ImportParams();
            params.setTitleRows(2);
            params.setHeadRows(1);
            params.setNeedSave(true);
            params.setStartSheetIndex(0);
            params.setSheetNum(1);
            try {
                List<EamEquipment> list = ExcelImportUtil.importExcel(file.getInputStream(), EamEquipment.class, params);
                //update-begin-author:taoyan date:20190528 for:批量插入数据
                long start = System.currentTimeMillis();
//                service.saveBatch(list);
                StringBuilder sb = new StringBuilder();
                for (EamEquipment eamEquipment : list) {
                    //必填字段校验
                    if (StringUtils.isBlank(eamEquipment.getEquipmentCode()) || StringUtils.isBlank(eamEquipment.getEquipmentName())) {
                        sb.append(String.format("设备编码[%s]或设备名称[%s]为空，无法导入\n\n", eamEquipment.getEquipmentCode(), eamEquipment.getEquipmentName()));
                        continue;
                    }
                    if (StringUtils.isBlank(eamEquipment.getEquipmentCategory())) {
                        sb.append(String.format("设备编码[%s]设备分类为空，无法导入\n\n", eamEquipment.getEquipmentCode()));
                        continue;
                    }
                    EamEquipment one = eamEquipmentService.getOne(new LambdaQueryWrapper<EamEquipment>().eq(EamEquipment::getEquipmentCode, eamEquipment.getEquipmentCode()).eq(EamEquipment::getDelFlag, CommonConstant.DEL_FLAG_0));
                    if (one != null) {
                        sb.append(String.format("设备编码[%s]已存在，无法重复导入\n\r", eamEquipment.getEquipmentCode()));
                        continue;
                    }
                    BaseFactory baseFactory=baseFactoryService.searchCenterByKeyWord(eamEquipment.getFactoryOrgCode());
                    if(baseFactory==null){
                        sb.append(String.format("EAM中心信息[%s]不存在，无法导入\n\r", eamEquipment.getFactoryOrgCode()));
                        continue;
                    }else {
                        eamEquipment.setFactoryOrgCode(baseFactory.getOrgCode());
                    }
                    EamBaseRepairDepart eamBaseRepairDepart=eamBaseRepairDepartService.searchCenterByKeyWord(eamEquipment.getRepairDepartOrgCode());
                    if(eamBaseRepairDepart==null){
                        sb.append(String.format("维修班组信息[%s]不存在，无法导入\n\r", eamEquipment.getRepairDepartOrgCode()));
                        continue;
                    }else {
                        eamEquipment.setRepairDepartOrgCode(eamBaseRepairDepart.getOrgCode());
                    }
                    EamEquipment equipment = eamEquipmentService.saveEquipment(eamEquipment);
                    if (equipment == null) {
                        //保存失败，跳过本次循环
                        sb.append(String.format("设备编码[%s]保存失败，无法导入\n\r", eamEquipment.getEquipmentCode()));
                        continue;
                    }
                    EamEquipmentExtend eamEquipmentExtend=new EamEquipmentExtend();
                    BeanUtils.copyProperties(eamEquipmentExtend,equipment);
                    eamEquipmentExtendService.save(eamEquipmentExtend);
                }
                log.info("消耗时间" + (System.currentTimeMillis() - start) + "毫秒");
                //update-end-author:taoyan date:20190528 for:批量插入数据
                if (sb.length() > 0) {
                    return Result.ok(sb.toString());
                }
                return Result.ok("文件导入成功！数据行数：" + list.size());
            } catch (Exception e) {
                //update-begin-author:taoyan date:20211124 for: 导入数据重复增加提示
                String msg = e.getMessage();
                log.error(msg, e);
                if (msg != null && msg.indexOf("Duplicate entry") >= 0) {
                    return Result.error("文件导入失败:有重复数据！");
                } else {
                    return Result.error("文件导入失败:" + e.getMessage());
                }
                //update-end-author:taoyan date:20211124 for: 导入数据重复增加提示
            } finally {
                try {
                    file.getInputStream().close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return Result.error("文件导入失败！");
    }

    @ApiOperation(value = "设备表-通过车间ids获取设备树", notes = "设备表-通过车间ids获取设备树")
    @GetMapping(value = "/loadTreeListByProductionIds")
    public Result<List<EamEquipmentTree>> loadTreeListByProductionIds(@RequestParam(name = "ids", required = true) String ids) {
        Result<List<EamEquipmentTree>> result = new Result<>();
        try {
            List<EamEquipmentTree> mdcEquipmentTreeList = eamEquipmentService.loadTreeListByProductionIds(ids);
            result.setSuccess(true);
            result.setResult(mdcEquipmentTreeList);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return result;
    }

    /**
     * 设备建账  获取组织部门
     * qsw 2023-4-28
     */
    @GetMapping("getSysDeparts")
    public Result<?> getSysDeparts() {
       List<DepartVo> sysDeparts = equipmentService.getSysDeparts();
       return Result.ok(sysDeparts);
    }
    @ApiOperation(value = "设备表-通过EAM中心ids获取设备树", notes = "设备表-通过EAM中心ids获取设备树")
    @GetMapping(value = "/loadTreeListByEamCenterIds")
    public Result<List<EamEquipmentTree>> loadTreeListByEamCenterIds(@RequestParam(name = "ids", required = true) String ids) {
        Result<List<EamEquipmentTree>> result = new Result<>();
        try {
            List<EamEquipmentTree> mdcEquipmentTreeList = eamEquipmentService.loadTreeListByEamCenterIds(ids);
            result.setSuccess(true);
            result.setResult(mdcEquipmentTreeList);
        } catch (Exception e) {
            log.error(e.getMessage(), e);
        }
        return result;
    }


    /**
     *设备履历 获取设备使用记录
     * qsw 2023-7-28
     */
    @GetMapping(value = "/getResumeUseRecordList")
    public Result<?> getResumeUseRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeUseRecordList = equipmentService.getResumeUseRecordList(pageNo, pageSize, params);
       return Result.ok(resumeUseRecordList);
    }

    /**
     *设备履历 获取设备点检记录
     * qsw 2023-7-28
     */
    @GetMapping(value = "/getResumeInspectionRecordList")
    public Result<?> getResumeInspectionRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeInspectionRecordList = equipmentService.getResumeInspectionRecordList(pageNo, pageSize, params);
       for (Map<String, Object> record : resumeInspectionRecordList.getRecords()) {
          String id = (String)record.get("id");
          String inspectionType = (String)record.get("inspectionType");
          if("日常点检".equals(inspectionType)){
             List<InspectionOrderDetail> failCount = inspectionOrderDetailService.lambdaQuery()
                   .eq(InspectionOrderDetail::getInspectionOrderId, id)
                   .eq(InspectionOrderDetail::getJudgmentResult, "fail")
                   .eq(InspectionOrderDetail::getDelFlag, 0).list();

             List<InspectionOrderDetail> passCount = inspectionOrderDetailService.lambdaQuery()
                   .eq(InspectionOrderDetail::getInspectionOrderId, id)
                   .eq(InspectionOrderDetail::getJudgmentResult,"pass")
                   .eq(InspectionOrderDetail::getDelFlag, 0).list();
             record.put("result","正常:"+passCount.size()+"，"+"异常:"+failCount.size());
          }else{
             List<SpecialtyInspectionOrderDetail> failCount = specialtyInspectionOrderDetailService.lambdaQuery()
                   .eq(SpecialtyInspectionOrderDetail::getSpecialtyInspectionOrderId, id)
                   .eq(SpecialtyInspectionOrderDetail::getJudgmentResult,"fail")
                   .eq(SpecialtyInspectionOrderDetail::getDelFlag, 0).list();

             List<SpecialtyInspectionOrderDetail> passCount = specialtyInspectionOrderDetailService.lambdaQuery()
                   .eq(SpecialtyInspectionOrderDetail::getSpecialtyInspectionOrderId, id)
                   .eq(SpecialtyInspectionOrderDetail::getJudgmentResult,"pass")
                   .eq(SpecialtyInspectionOrderDetail::getDelFlag, 0).list();
             record.put("result","正常:"+passCount.size()+"，"+"异常:"+failCount.size());
          }
       }
       return Result.ok(resumeInspectionRecordList);
    }

    /**
     *设备履历 获取设备保养记录
     * qsw 2023-7-31
     */
    @GetMapping(value = "/getResumeMaintenanceRecordList")
    public Result<?> getResumeMaintenanceRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeMaintenanceRecordList = equipmentService.getResumeMaintenanceRecordList(pageNo, pageSize, params);
       return Result.ok(resumeMaintenanceRecordList);
    }

    /**
     *设备履历 获取设备维修记录
     * qsw 2023-7-31
     */
    @GetMapping(value = "/getResumeRepairRecordList")
    public Result<?> getResumeRepairRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeRepairRecordList = equipmentService.getResumeRepairRecordList(pageNo, pageSize, params);
       return Result.ok(resumeRepairRecordList);
    }

    /**
     *设备履历 获取设备检定记录
     * qsw 2023-7-31
     */
    @GetMapping(value = "/getResumeCalibrationRecordList")
    public Result<?> getResumeCalibrationRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeCalibrationRecordList = equipmentService.getResumeCalibrationRecordList(pageNo, pageSize, params);
       for (Map<String, Object> record : resumeCalibrationRecordList.getRecords()) {
          String id = (String)record.get("id");
          String status = (String)record.get("status");
          String managementMode = (String)record.get("managementMode");
          if("4".equals(status)){
             if("data".equals(managementMode)){
                List<CalibrationOrderDetail> calibrationOrderDetails = calibrationOrderDetailService.lambdaQuery()
                      .eq(CalibrationOrderDetail::getCalibrationOrderId, id)
                      .eq(CalibrationOrderDetail::getJudgmentResult, "fail")
                      .eq(CalibrationOrderDetail::getDelFlag,"0").list();
                if(calibrationOrderDetails.size()>0){
                   record.put("calibrationResult","异常");
                }else{
                   record.put("calibrationResult","正常常");
                }
             }else{
                List<CalibrationOrderReport> calibrationOrderReports = calibrationOrderReportService.lambdaQuery()
                      .eq(CalibrationOrderReport::getCalibrationOrderId, id)
                      .eq(CalibrationOrderReport::getJudgmentResult, "fail")
                      .eq(CalibrationOrderReport::getDelFlag, "0").list();
                if(calibrationOrderReports.size()>0){
                   record.put("calibrationResult","异常");
                }else{
                   record.put("calibrationResult","正常常");
                }
             }
          }
       }
       return Result.ok(resumeCalibrationRecordList);
    }

    /**
     *设备履历 获取设备处置记录
     * qsw 2023-7-31
     */
    @GetMapping(value = "/getResumeChangeRecordList")
    public Result<?> getResumeChangeRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeChangeRecordList = equipmentService.getResumeChangeRecordList(pageNo, pageSize, params);
       return Result.ok(resumeChangeRecordList);
    }

    /**
     * 根据状态查询设备列表
     */
    @GetMapping(value = "/getEquipmentListByStatus")
    public Result<IPage<Equipment>> getEquipmentList(Equipment equipment,String status,
                                         @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                         @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
                                         HttpServletRequest req) {
       QueryWrapper<Equipment> queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap());
       List<String> statusList = Arrays.asList(status.split(","));
       Page<Equipment> page = new Page<Equipment>(pageNo, pageSize);
       queryWrapper.in("equipment_status",statusList);
       IPage<Equipment> pageList = equipmentService.page(page, queryWrapper);
       return Result.OK(pageList);
    }
    /**
     * 检索设备
     * @param keyword 查询关键词 设备编号，设备名称模糊匹配
     * @param pageSize 一次返回多少记录
     * @param id 设备主键
     * @return
     */
    @ApiOperation(value = "设备表-异步加载设备列表", notes = "设备表-异步加载设备列表")
    @GetMapping(value = "/asyncLoadEquipment")
    public Result<?> asyncLoadEquipment(@RequestParam(name="keyword",required = false) String keyword,
                                        @RequestParam(value = "pageSize", required = false, defaultValue = "20") Integer pageSize,
                                        @RequestParam(name="id",required = false) String id) {
        List<EquipmentSearchResult> resultList = eamEquipmentService.asyncLoadEquipment(keyword, pageSize, id);
        return Result.ok(resultList);
    }

}