| | |
| | | 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.jeecg.common.api.vo.Result; |
| | | import org.jeecg.common.constant.CommonConstant; |
| | | import org.jeecg.common.system.base.controller.JeecgController; |
| | | import org.jeecg.common.util.TranslateDictTextUtils; |
| | | 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; |
| | |
| | | private IEamEquipmentService eamEquipmentService; |
| | | |
| | | @Autowired |
| | | private IEamEquipmentExtendService eamEquipmentExtendService; |
| | | |
| | | @Autowired |
| | | private IMdcEquipmentService mdcEquipmentService; |
| | | |
| | | @Autowired |
| | | private ObjectMapper objectMapper; |
| | | @Autowired |
| | | private TranslateDictTextUtils translateDictTextUtils; |
| | | |
| | | /** |
| | | * 分页列表查询 |
| | |
| | | MdcEquipment mdcEquipment = new MdcEquipment(); |
| | | mdcEquipment.setEquipmentId(entity.getEquipmentCode()); |
| | | mdcEquipment.setEquipmentType(entity.getDeviceType()); |
| | | mdcEquipment.setEquipmentName(entity.getEquipmentName()); |
| | | mdcEquipment.setEquipmentName(entity.getInstallationPosition()); |
| | | mdcEquipment.setEquipmentAddress(entity.getEquipmentName()); |
| | | mdcEquipmentService.addNewEquipmentFromEam(mdcEquipment, eamEquipment.getOrgId()); |
| | | } |
| | | return Result.OK("添加成功!"); |
| | |
| | | @GetMapping(value = "/queryById") |
| | | public Result<?> queryById(@RequestParam(name = "id", required = true) String id) { |
| | | EamEquipment eamEquipment = eamEquipmentService.getById(id); |
| | | return Result.OK(eamEquipment); |
| | | 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("数据转译失败!"); |
| | | } |
| | | } |
| | | |
| | | /** |
| | |
| | | params.setTitleRows(0); |
| | | 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:批量插入数据 |
| | |
| | | sb.append(String.format("设备编码[%s]已存在,无法重复导入\n\r", eamEquipment.getEquipmentCode())); |
| | | continue; |
| | | } |
| | | if (!CommonConstant.DEFAULT_1.equals(eamEquipment.getMdcFlag())) { |
| | | eamEquipment.setMdcFlag(CommonConstant.DEFAULT_0); |
| | | } |
| | | EamEquipment equipment = eamEquipmentService.saveEquipment(eamEquipment); |
| | | if (equipment == null) { |
| | | //保存失败,跳过本次循环 |
| | |
| | | MdcEquipment mdcEquipment = new MdcEquipment(); |
| | | mdcEquipment.setEquipmentId(eamEquipment.getEquipmentCode()); |
| | | mdcEquipment.setEquipmentType(eamEquipment.getDeviceType()); |
| | | mdcEquipment.setEquipmentName(eamEquipment.getEquipmentName()); |
| | | mdcEquipment.setEquipmentName(eamEquipment.getInstallationPosition()); |
| | | mdcEquipment.setEquipmentAddress(eamEquipment.getEquipmentName()); |
| | | mdcEquipmentService.addNewEquipmentFromEam(mdcEquipment, eamEquipment.getOrgId()); |
| | | } |
| | | } |