diff --git a/os-ems/src/main/java/com/os/ems/info/controller/DailyFaultRecordController.java b/os-ems/src/main/java/com/os/ems/info/controller/DailyFaultRecordController.java index 525c700..efd070b 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/DailyFaultRecordController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/DailyFaultRecordController.java @@ -20,6 +20,7 @@ import com.os.ems.info.domain.DailyFaultRecord; import com.os.ems.info.service.IDailyFaultRecordService; import com.os.common.utils.poi.ExcelUtil; import com.os.common.core.page.TableDataInfo; +import org.springframework.web.multipart.MultipartFile; /** * 日常故障记录Controller @@ -103,4 +104,29 @@ public class DailyFaultRecordController extends BaseController { return toAjax(dailyFaultRecordService.deleteDailyFaultRecordByIds(ids)); } + + /** + * 导入日常故障记录数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:dailyFaultRecord:import')") + @Log(title = "日常故障记录", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(DailyFaultRecord.class); + List recordList = util.importExcel(file.getInputStream()); + String operName = getUsername(); + String message = dailyFaultRecordService.importDailyFaultRecord(recordList, updateSupport, operName); + return AjaxResult.success(message); + } + + /** + * 获取日常故障记录导入模板 + */ + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(DailyFaultRecord.class); + return util.importTemplateExcel("日常故障记录数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/FaultHandlingRecordController.java b/os-ems/src/main/java/com/os/ems/info/controller/FaultHandlingRecordController.java index 8788816..155c63b 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/FaultHandlingRecordController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/FaultHandlingRecordController.java @@ -20,6 +20,7 @@ import com.os.ems.info.domain.FaultHandlingRecord; import com.os.ems.info.service.IFaultHandlingRecordService; import com.os.common.utils.poi.ExcelUtil; import com.os.common.core.page.TableDataInfo; +import org.springframework.web.multipart.MultipartFile; /** * 故障处置记录Controller @@ -103,4 +104,29 @@ public class FaultHandlingRecordController extends BaseController { return toAjax(faultHandlingRecordService.deleteFaultHandlingRecordByIds(ids)); } + + /** + * 导入故障处置记录数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:faultHandlingRecord:import')") + @Log(title = "故障处置记录", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(FaultHandlingRecord.class); + List recordList = util.importExcel(file.getInputStream()); + String operName = getUsername(); + String message = faultHandlingRecordService.importFaultHandlingRecord(recordList, updateSupport, operName); + return AjaxResult.success(message); + } + + /** + * 获取故障处置记录导入模板 + */ + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(FaultHandlingRecord.class); + return util.importTemplateExcel("故障处置记录数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemPlcBufferBatteryLifecycleController.java b/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemPlcBufferBatteryLifecycleController.java index 97e30ac..180785e 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemPlcBufferBatteryLifecycleController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemPlcBufferBatteryLifecycleController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -103,4 +105,29 @@ public class LuggageSystemPlcBufferBatteryLifecycleController extends BaseContro { return toAjax(luggageSystemPlcBufferBatteryLifecycleService.deleteLuggageSystemPlcBufferBatteryLifecycleByObjids(objids)); } + + /** + * 导入行李系统PLC缓冲电池生命周期数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:plcBufferBatteryLifecycle:import')") + @Log(title = "行李系统PLC缓冲电池生命周期", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, @RequestParam(value = "updateSupport", defaultValue = "false") boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(LuggageSystemPlcBufferBatteryLifecycle.class); + List dataList = util.importExcel(file.getInputStream()); + String message = luggageSystemPlcBufferBatteryLifecycleService.importLuggageSystemPlcBufferBatteryLifecycle(dataList, updateSupport, getUsername()); + return AjaxResult.success(message); + } + + /** + * 获取行李系统PLC缓冲电池生命周期导入模板 + */ + @PreAuthorize("@ss.hasPermi('ems/info:plcBufferBatteryLifecycle:import')") + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(LuggageSystemPlcBufferBatteryLifecycle.class); + return util.importTemplateExcel("行李系统PLC缓冲电池生命周期数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemSecurityDoorBatteryLifecycleController.java b/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemSecurityDoorBatteryLifecycleController.java index 959623d..066a340 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemSecurityDoorBatteryLifecycleController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/LuggageSystemSecurityDoorBatteryLifecycleController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -103,4 +105,29 @@ public class LuggageSystemSecurityDoorBatteryLifecycleController extends BaseCon { return toAjax(luggageSystemSecurityDoorBatteryLifecycleService.deleteLuggageSystemSecurityDoorBatteryLifecycleByObjids(objids)); } + + /** + * 导入行李系统安全门铅酸电池生命周期数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:securityDoorBatteryLifecycle:import')") + @Log(title = "行李系统安全门铅酸电池生命周期", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, @RequestParam(value = "updateSupport", defaultValue = "false") boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(LuggageSystemSecurityDoorBatteryLifecycle.class); + List dataList = util.importExcel(file.getInputStream()); + String message = luggageSystemSecurityDoorBatteryLifecycleService.importLuggageSystemSecurityDoorBatteryLifecycle(dataList, updateSupport, getUsername()); + return AjaxResult.success(message); + } + + /** + * 获取行李系统安全门铅酸电池生命周期导入模板 + */ + @PreAuthorize("@ss.hasPermi('ems/info:securityDoorBatteryLifecycle:import')") + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(LuggageSystemSecurityDoorBatteryLifecycle.class); + return util.importTemplateExcel("行李系统安全门铅酸电池生命周期数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySparePartsRegistrationController.java b/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySparePartsRegistrationController.java index d0026bb..be8ef5f 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySparePartsRegistrationController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySparePartsRegistrationController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -25,7 +27,7 @@ import com.os.common.core.page.TableDataInfo; * 动力能源部行输科废旧备件登记Controller * * @author Yinq - * @date 2025-06-05 + * @date 2024-12-13 */ @RestController @RequestMapping("/ems/info/sparePartsRegistration") @@ -103,4 +105,29 @@ public class PowerEnergySparePartsRegistrationController extends BaseController { return toAjax(powerEnergySparePartsRegistrationService.deletePowerEnergySparePartsRegistrationByObjids(objids)); } + + /** + * 下载模板 + */ + @PostMapping("/importTemplate") + public void importTemplate(HttpServletResponse response) + { + ExcelUtil util = new ExcelUtil(PowerEnergySparePartsRegistration.class); + util.importTemplateExcel(response, "动力能源部行输科废旧备件登记数据"); + } + + /** + * 导入数据 + */ + @Log(title = "动力能源部行输科废旧备件登记", businessType = BusinessType.IMPORT) + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsRegistration:import')") + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(PowerEnergySparePartsRegistration.class); + List recordList = util.importExcel(file.getInputStream()); + String operName = getUsername(); + String message = powerEnergySparePartsRegistrationService.importPowerEnergySparePartsRegistration(recordList, updateSupport, operName); + return success(message); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySupervisionChecklistController.java b/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySupervisionChecklistController.java index 5ea5eda..4b1b949 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySupervisionChecklistController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/PowerEnergySupervisionChecklistController.java @@ -12,6 +12,7 @@ import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -103,4 +104,29 @@ public class PowerEnergySupervisionChecklistController extends BaseController { return toAjax(powerEnergySupervisionChecklistService.deletePowerEnergySupervisionChecklistByIds(ids)); } + + /** + * 下载模板 + */ + @PostMapping("/importTemplate") + public void importTemplate(HttpServletResponse response) + { + ExcelUtil util = new ExcelUtil(PowerEnergySupervisionChecklist.class); + util.importTemplateExcel(response, "动力能源部监督检查清单数据"); + } + + /** + * 导入数据 + */ + @Log(title = "动力能源部监督检查清单", businessType = BusinessType.IMPORT) + @PreAuthorize("@ss.hasPermi('ems/info:supervisionChecklist:import')") + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(PowerEnergySupervisionChecklist.class); + List recordList = util.importExcel(file.getInputStream()); + String operName = getUsername(); + String message = powerEnergySupervisionChecklistService.importPowerEnergySupervisionChecklist(recordList, updateSupport, operName); + return success(message); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryCheckController.java b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryCheckController.java index 2a91fec..7920aa6 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryCheckController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryCheckController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -25,7 +27,7 @@ import com.os.common.core.page.TableDataInfo; * 备件盘点记录明细Controller * * @author Yinq - * @date 2025-06-05 + * @date 2024-12-13 */ @RestController @RequestMapping("/ems/info/sparePartsInventoryCheck") @@ -103,4 +105,29 @@ public class SparePartsInventoryCheckController extends BaseController { return toAjax(sparePartsInventoryCheckService.deleteSparePartsInventoryCheckByIds(ids)); } + + /** + * 导入备件盘点记录明细数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsInventoryCheck:import')") + @Log(title = "备件盘点记录明细", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, @RequestParam(value = "updateSupport", defaultValue = "false") boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(SparePartsInventoryCheck.class); + List dataList = util.importExcel(file.getInputStream()); + String message = sparePartsInventoryCheckService.importSparePartsInventoryCheck(dataList, updateSupport, getUsername()); + return AjaxResult.success(message); + } + + /** + * 获取备件盘点记录明细导入模板 + */ + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsInventoryCheck:import')") + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(SparePartsInventoryCheck.class); + return util.importTemplateExcel("备件盘点记录明细数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryController.java b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryController.java index a2fc4e6..e8ac807 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsInventoryController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -25,7 +27,7 @@ import com.os.common.core.page.TableDataInfo; * 备件库记录主Controller * * @author Yinq - * @date 2025-06-05 + * @date 2024-12-13 */ @RestController @RequestMapping("/ems/info/sparePartsInventory") @@ -103,4 +105,29 @@ public class SparePartsInventoryController extends BaseController { return toAjax(sparePartsInventoryService.deleteSparePartsInventoryByObjids(objids)); } + + /** + * 导入备件库记录主数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsInventory:import')") + @Log(title = "备件库记录主", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, @RequestParam(value = "updateSupport", defaultValue = "false") boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(SparePartsInventory.class); + List dataList = util.importExcel(file.getInputStream()); + String message = sparePartsInventoryService.importSparePartsInventory(dataList, updateSupport, getUsername()); + return AjaxResult.success(message); + } + + /** + * 获取备件库记录主导入模板 + */ + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsInventory:import')") + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(SparePartsInventory.class); + return util.importTemplateExcel("备件库记录主数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsUsageRecordController.java b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsUsageRecordController.java index be80fb4..fc7481b 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/SparePartsUsageRecordController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/SparePartsUsageRecordController.java @@ -12,6 +12,7 @@ import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -103,4 +104,29 @@ public class SparePartsUsageRecordController extends BaseController { return toAjax(sparePartsUsageRecordService.deleteSparePartsUsageRecordByIds(ids)); } + + /** + * 导入动力能源部行输科备件领用更换记录数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:sparePartsUsageRecord:import')") + @Log(title = "动力能源部行输科备件领用更换记录", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(SparePartsUsageRecord.class); + List recordList = util.importExcel(file.getInputStream()); + String operName = getUsername(); + String message = sparePartsUsageRecordService.importSparePartsUsageRecord(recordList, updateSupport, operName); + return AjaxResult.success(message); + } + + /** + * 获取动力能源部行输科备件领用更换记录导入模板 + */ + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(SparePartsUsageRecord.class); + return util.importTemplateExcel("动力能源部行输科备件领用更换记录数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/controller/UpsBatteryLifecycleController.java b/os-ems/src/main/java/com/os/ems/info/controller/UpsBatteryLifecycleController.java index 05ab63d..64e5a46 100644 --- a/os-ems/src/main/java/com/os/ems/info/controller/UpsBatteryLifecycleController.java +++ b/os-ems/src/main/java/com/os/ems/info/controller/UpsBatteryLifecycleController.java @@ -11,7 +11,9 @@ import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.multipart.MultipartFile; import com.os.common.annotation.Log; import com.os.common.core.controller.BaseController; import com.os.common.core.domain.AjaxResult; @@ -25,7 +27,7 @@ import com.os.common.core.page.TableDataInfo; * 行李系统UPS电池生命周期Controller * * @author Yinq - * @date 2025-06-05 + * @date 2024-12-13 */ @RestController @RequestMapping("/ems/info/upsBatteryLifecycle") @@ -103,4 +105,29 @@ public class UpsBatteryLifecycleController extends BaseController { return toAjax(upsBatteryLifecycleService.deleteUpsBatteryLifecycleByIds(ids)); } + + /** + * 导入行李系统UPS电池生命周期数据 + */ + @PreAuthorize("@ss.hasPermi('ems/info:upsBatteryLifecycle:import')") + @Log(title = "行李系统UPS电池生命周期", businessType = BusinessType.IMPORT) + @PostMapping("/importData") + public AjaxResult importData(MultipartFile file, @RequestParam(value = "updateSupport", defaultValue = "false") boolean updateSupport) throws Exception + { + ExcelUtil util = new ExcelUtil(UpsBatteryLifecycle.class); + List dataList = util.importExcel(file.getInputStream()); + String message = upsBatteryLifecycleService.importUpsBatteryLifecycle(dataList, updateSupport, getUsername()); + return AjaxResult.success(message); + } + + /** + * 获取行李系统UPS电池生命周期导入模板 + */ + @PreAuthorize("@ss.hasPermi('ems/info:upsBatteryLifecycle:import')") + @PostMapping("/importTemplate") + public AjaxResult importTemplate() + { + ExcelUtil util = new ExcelUtil(UpsBatteryLifecycle.class); + return util.importTemplateExcel("行李系统UPS电池生命周期数据"); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/domain/PowerEnergySparePartsRegistration.java b/os-ems/src/main/java/com/os/ems/info/domain/PowerEnergySparePartsRegistration.java index 814cf8c..b6515cf 100644 --- a/os-ems/src/main/java/com/os/ems/info/domain/PowerEnergySparePartsRegistration.java +++ b/os-ems/src/main/java/com/os/ems/info/domain/PowerEnergySparePartsRegistration.java @@ -22,8 +22,8 @@ public class PowerEnergySparePartsRegistration extends BaseEntity @Excel(name = "类型") private String type; - /** 参照位置，参考坐标或设备ID */ - @Excel(name = "参照位置，参考坐标或设备ID") + /** 参照位置 */ + @Excel(name = "参照位置") private String referenceLocation; /** 位置描述 */ diff --git a/os-ems/src/main/java/com/os/ems/info/service/IDailyFaultRecordService.java b/os-ems/src/main/java/com/os/ems/info/service/IDailyFaultRecordService.java index 838ca2c..5085340 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/IDailyFaultRecordService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/IDailyFaultRecordService.java @@ -58,4 +58,14 @@ public interface IDailyFaultRecordService * @return 结果 */ public int deleteDailyFaultRecordById(Long id); + + /** + * 导入日常故障记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importDailyFaultRecord(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/IFaultHandlingRecordService.java b/os-ems/src/main/java/com/os/ems/info/service/IFaultHandlingRecordService.java index 96893f1..2013d68 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/IFaultHandlingRecordService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/IFaultHandlingRecordService.java @@ -58,4 +58,14 @@ public interface IFaultHandlingRecordService * @return 结果 */ public int deleteFaultHandlingRecordById(Long id); + + /** + * 导入故障处置记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importFaultHandlingRecord(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemPlcBufferBatteryLifecycleService.java b/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemPlcBufferBatteryLifecycleService.java index 3bf1b00..3e780d6 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemPlcBufferBatteryLifecycleService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemPlcBufferBatteryLifecycleService.java @@ -58,4 +58,14 @@ public interface ILuggageSystemPlcBufferBatteryLifecycleService * @return 结果 */ public int deleteLuggageSystemPlcBufferBatteryLifecycleByObjid(Long objid); + + /** + * 导入行李系统PLC缓冲电池生命周期数据 + * + * @param dataList 行李系统PLC缓冲电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importLuggageSystemPlcBufferBatteryLifecycle(List dataList, Boolean updateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemSecurityDoorBatteryLifecycleService.java b/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemSecurityDoorBatteryLifecycleService.java index dcd837b..8e40f07 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemSecurityDoorBatteryLifecycleService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/ILuggageSystemSecurityDoorBatteryLifecycleService.java @@ -58,4 +58,14 @@ public interface ILuggageSystemSecurityDoorBatteryLifecycleService * @return 结果 */ public int deleteLuggageSystemSecurityDoorBatteryLifecycleByObjid(Long objid); + + /** + * 导入行李系统安全门铅酸电池生命周期数据 + * + * @param dataList 行李系统安全门铅酸电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importLuggageSystemSecurityDoorBatteryLifecycle(List dataList, Boolean updateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySparePartsRegistrationService.java b/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySparePartsRegistrationService.java index 2306962..f85c3aa 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySparePartsRegistrationService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySparePartsRegistrationService.java @@ -58,4 +58,14 @@ public interface IPowerEnergySparePartsRegistrationService * @return 结果 */ public int deletePowerEnergySparePartsRegistrationByObjid(Long objid); + + /** + * 导入动力能源部行输科废旧备件登记数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importPowerEnergySparePartsRegistration(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySupervisionChecklistService.java b/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySupervisionChecklistService.java index 49a1ca5..360979a 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySupervisionChecklistService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/IPowerEnergySupervisionChecklistService.java @@ -58,4 +58,14 @@ public interface IPowerEnergySupervisionChecklistService * @return 结果 */ public int deletePowerEnergySupervisionChecklistById(Long id); + + /** + * 导入动力能源部监督检查清单数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importPowerEnergySupervisionChecklist(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryCheckService.java b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryCheckService.java index 9bd6f22..a51ce74 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryCheckService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryCheckService.java @@ -58,4 +58,14 @@ public interface ISparePartsInventoryCheckService * @return 结果 */ public int deleteSparePartsInventoryCheckById(Long id); + + /** + * 导入备件盘点记录明细数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importSparePartsInventoryCheck(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryService.java b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryService.java index 2a0b6e1..02ffe2a 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsInventoryService.java @@ -58,4 +58,14 @@ public interface ISparePartsInventoryService * @return 结果 */ public int deleteSparePartsInventoryByObjid(Long objid); + + /** + * 导入备件库记录主数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importSparePartsInventory(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsUsageRecordService.java b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsUsageRecordService.java index fc0032a..1b850ca 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/ISparePartsUsageRecordService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/ISparePartsUsageRecordService.java @@ -58,4 +58,14 @@ public interface ISparePartsUsageRecordService * @return 结果 */ public int deleteSparePartsUsageRecordById(Long id); + + /** + * 导入动力能源部行输科备件领用更换记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importSparePartsUsageRecord(List recordList, Boolean isUpdateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/IUpsBatteryLifecycleService.java b/os-ems/src/main/java/com/os/ems/info/service/IUpsBatteryLifecycleService.java index 885ad3d..0e15ed8 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/IUpsBatteryLifecycleService.java +++ b/os-ems/src/main/java/com/os/ems/info/service/IUpsBatteryLifecycleService.java @@ -58,4 +58,14 @@ public interface IUpsBatteryLifecycleService * @return 结果 */ public int deleteUpsBatteryLifecycleById(Long id); + + /** + * 导入行李系统UPS电池生命周期数据 + * + * @param dataList 行李系统UPS电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + public String importUpsBatteryLifecycle(List dataList, Boolean updateSupport, String operName); } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/DailyFaultRecordServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/DailyFaultRecordServiceImpl.java index e46710d..d38c919 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/DailyFaultRecordServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/DailyFaultRecordServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.DailyFaultRecordMapper; import com.os.ems.info.domain.DailyFaultRecord; import com.os.ems.info.service.IDailyFaultRecordService; @@ -90,4 +92,85 @@ public class DailyFaultRecordServiceImpl implements IDailyFaultRecordService { return dailyFaultRecordMapper.deleteDailyFaultRecordById(id); } + + + /** + * 导入日常故障记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importDailyFaultRecord(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (DailyFaultRecord record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + DailyFaultRecord existRecord = null; + if (StringUtils.isNotEmpty(record.getDate()) && StringUtils.isNotEmpty(record.getLocation())) + { + DailyFaultRecord queryRecord = new DailyFaultRecord(); + queryRecord.setDate(record.getDate()); + queryRecord.setLocation(record.getLocation()); + List existRecords = dailyFaultRecordMapper.selectDailyFaultRecordList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertDailyFaultRecord(record); + successNum++; + successMsg.append("
" + successNum + "、日常故障记录 " + record.getLocation() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setId(existRecord.getId()); + record.setUpdateBy(operName); + this.updateDailyFaultRecord(record); + successNum++; + successMsg.append("
" + successNum + "、日常故障记录 " + record.getLocation() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、日常故障记录 " + record.getLocation() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、日常故障记录 " + record.getLocation() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } + } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/FaultHandlingRecordServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/FaultHandlingRecordServiceImpl.java index 00525ef..8dd802e 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/FaultHandlingRecordServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/FaultHandlingRecordServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.FaultHandlingRecordMapper; import com.os.ems.info.domain.FaultHandlingRecord; import com.os.ems.info.service.IFaultHandlingRecordService; @@ -90,4 +92,83 @@ public class FaultHandlingRecordServiceImpl implements IFaultHandlingRecordServi { return faultHandlingRecordMapper.deleteFaultHandlingRecordById(id); } + + /** + * 导入故障处置记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importFaultHandlingRecord(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (FaultHandlingRecord record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + FaultHandlingRecord existRecord = null; + if (StringUtils.isNotEmpty(record.getFaultDate()) && StringUtils.isNotEmpty(record.getFaultLocation())) + { + FaultHandlingRecord queryRecord = new FaultHandlingRecord(); + queryRecord.setFaultDate(record.getFaultDate()); + queryRecord.setFaultLocation(record.getFaultLocation()); + List existRecords = faultHandlingRecordMapper.selectFaultHandlingRecordList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertFaultHandlingRecord(record); + successNum++; + successMsg.append("
" + successNum + "、故障处置记录 " + record.getFaultLocation() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setId(existRecord.getId()); + record.setUpdateBy(operName); + this.updateFaultHandlingRecord(record); + successNum++; + successMsg.append("
" + successNum + "、故障处置记录 " + record.getFaultLocation() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、故障处置记录 " + record.getFaultLocation() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、故障处置记录 " + record.getFaultLocation() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemPlcBufferBatteryLifecycleServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemPlcBufferBatteryLifecycleServiceImpl.java index 1b840e8..c3cd21c 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemPlcBufferBatteryLifecycleServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemPlcBufferBatteryLifecycleServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.LuggageSystemPlcBufferBatteryLifecycleMapper; import com.os.ems.info.domain.LuggageSystemPlcBufferBatteryLifecycle; import com.os.ems.info.service.ILuggageSystemPlcBufferBatteryLifecycleService; @@ -90,4 +92,68 @@ public class LuggageSystemPlcBufferBatteryLifecycleServiceImpl implements ILugga { return luggageSystemPlcBufferBatteryLifecycleMapper.deleteLuggageSystemPlcBufferBatteryLifecycleByObjid(objid); } + + /** + * 导入行李系统PLC缓冲电池生命周期数据 + * + * @param dataList 行李系统PLC缓冲电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importLuggageSystemPlcBufferBatteryLifecycle(List dataList, Boolean updateSupport, String operName) + { + if (StringUtils.isEmpty(dataList) || dataList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (LuggageSystemPlcBufferBatteryLifecycle data : dataList) + { + try + { + // 验证是否存在这个数据 + LuggageSystemPlcBufferBatteryLifecycle u = luggageSystemPlcBufferBatteryLifecycleMapper.selectLuggageSystemPlcBufferBatteryLifecycleByObjid(data.getObjid()); + if (StringUtils.isNull(u)) + { + data.setCreateBy(operName); + this.insertLuggageSystemPlcBufferBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 导入成功"); + } + else if (updateSupport) + { + data.setUpdateBy(operName); + this.updateLuggageSystemPlcBufferBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、" + data.getType() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、" + data.getType() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemSecurityDoorBatteryLifecycleServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemSecurityDoorBatteryLifecycleServiceImpl.java index 827d45d..4551cf8 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemSecurityDoorBatteryLifecycleServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/LuggageSystemSecurityDoorBatteryLifecycleServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.LuggageSystemSecurityDoorBatteryLifecycleMapper; import com.os.ems.info.domain.LuggageSystemSecurityDoorBatteryLifecycle; import com.os.ems.info.service.ILuggageSystemSecurityDoorBatteryLifecycleService; @@ -90,4 +92,68 @@ public class LuggageSystemSecurityDoorBatteryLifecycleServiceImpl implements ILu { return luggageSystemSecurityDoorBatteryLifecycleMapper.deleteLuggageSystemSecurityDoorBatteryLifecycleByObjid(objid); } + + /** + * 导入行李系统安全门铅酸电池生命周期数据 + * + * @param dataList 行李系统安全门铅酸电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importLuggageSystemSecurityDoorBatteryLifecycle(List dataList, Boolean updateSupport, String operName) + { + if (StringUtils.isEmpty(dataList) || dataList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (LuggageSystemSecurityDoorBatteryLifecycle data : dataList) + { + try + { + // 验证是否存在这个数据 + LuggageSystemSecurityDoorBatteryLifecycle u = luggageSystemSecurityDoorBatteryLifecycleMapper.selectLuggageSystemSecurityDoorBatteryLifecycleByObjid(data.getObjid()); + if (StringUtils.isNull(u)) + { + data.setCreateBy(operName); + this.insertLuggageSystemSecurityDoorBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 导入成功"); + } + else if (updateSupport) + { + data.setUpdateBy(operName); + this.updateLuggageSystemSecurityDoorBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、" + data.getType() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、" + data.getType() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySparePartsRegistrationServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySparePartsRegistrationServiceImpl.java index 811040b..2e57c1a 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySparePartsRegistrationServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySparePartsRegistrationServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.PowerEnergySparePartsRegistrationMapper; import com.os.ems.info.domain.PowerEnergySparePartsRegistration; import com.os.ems.info.service.IPowerEnergySparePartsRegistrationService; @@ -90,4 +92,83 @@ public class PowerEnergySparePartsRegistrationServiceImpl implements IPowerEnerg { return powerEnergySparePartsRegistrationMapper.deletePowerEnergySparePartsRegistrationByObjid(objid); } + + /** + * 导入动力能源部行输科废旧备件登记数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importPowerEnergySparePartsRegistration(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (PowerEnergySparePartsRegistration record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + PowerEnergySparePartsRegistration existRecord = null; + if (StringUtils.isNotEmpty(record.getType()) && StringUtils.isNotEmpty(record.getReferenceLocation())) + { + PowerEnergySparePartsRegistration queryRecord = new PowerEnergySparePartsRegistration(); + queryRecord.setType(record.getType()); + queryRecord.setReferenceLocation(record.getReferenceLocation()); + List existRecords = powerEnergySparePartsRegistrationMapper.selectPowerEnergySparePartsRegistrationList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertPowerEnergySparePartsRegistration(record); + successNum++; + successMsg.append("
" + successNum + "、废旧备件登记 " + record.getType() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setObjid(existRecord.getObjid()); + record.setUpdateBy(operName); + this.updatePowerEnergySparePartsRegistration(record); + successNum++; + successMsg.append("
" + successNum + "、废旧备件登记 " + record.getType() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、废旧备件登记 " + record.getType() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、废旧备件登记 " + record.getType() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySupervisionChecklistServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySupervisionChecklistServiceImpl.java index 991b87c..2416ab9 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySupervisionChecklistServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/PowerEnergySupervisionChecklistServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.PowerEnergySupervisionChecklistMapper; import com.os.ems.info.domain.PowerEnergySupervisionChecklist; import com.os.ems.info.service.IPowerEnergySupervisionChecklistService; @@ -90,4 +92,83 @@ public class PowerEnergySupervisionChecklistServiceImpl implements IPowerEnergyS { return powerEnergySupervisionChecklistMapper.deletePowerEnergySupervisionChecklistById(id); } + + /** + * 导入动力能源部监督检查清单数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importPowerEnergySupervisionChecklist(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (PowerEnergySupervisionChecklist record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + PowerEnergySupervisionChecklist existRecord = null; + if (StringUtils.isNotEmpty(record.getDate()) && StringUtils.isNotEmpty(record.getJobName())) + { + PowerEnergySupervisionChecklist queryRecord = new PowerEnergySupervisionChecklist(); + queryRecord.setDate(record.getDate()); + queryRecord.setJobName(record.getJobName()); + List existRecords = powerEnergySupervisionChecklistMapper.selectPowerEnergySupervisionChecklistList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertPowerEnergySupervisionChecklist(record); + successNum++; + successMsg.append("
" + successNum + "、检查记录 " + record.getJobName() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setId(existRecord.getId()); + record.setUpdateBy(operName); + this.updatePowerEnergySupervisionChecklist(record); + successNum++; + successMsg.append("
" + successNum + "、检查记录 " + record.getJobName() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、检查记录 " + record.getJobName() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、检查记录 " + record.getJobName() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryCheckServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryCheckServiceImpl.java index 56ba7da..ed03ae0 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryCheckServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryCheckServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.SparePartsInventoryCheckMapper; import com.os.ems.info.domain.SparePartsInventoryCheck; import com.os.ems.info.service.ISparePartsInventoryCheckService; @@ -90,4 +92,83 @@ public class SparePartsInventoryCheckServiceImpl implements ISparePartsInventory { return sparePartsInventoryCheckMapper.deleteSparePartsInventoryCheckById(id); } + + /** + * 导入备件盘点记录明细数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importSparePartsInventoryCheck(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (SparePartsInventoryCheck record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + SparePartsInventoryCheck existRecord = null; + if (StringUtils.isNotEmpty(record.getCheckDate()) && StringUtils.isNotEmpty(record.getCheckName())) + { + SparePartsInventoryCheck queryRecord = new SparePartsInventoryCheck(); + queryRecord.setCheckDate(record.getCheckDate()); + queryRecord.setCheckName(record.getCheckName()); + List existRecords = sparePartsInventoryCheckMapper.selectSparePartsInventoryCheckList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertSparePartsInventoryCheck(record); + successNum++; + successMsg.append("
" + successNum + "、备件盘点记录 " + record.getCheckName() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setId(existRecord.getId()); + record.setUpdateBy(operName); + this.updateSparePartsInventoryCheck(record); + successNum++; + successMsg.append("
" + successNum + "、备件盘点记录 " + record.getCheckName() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、备件盘点记录 " + record.getCheckName() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、备件盘点记录 " + record.getCheckName() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryServiceImpl.java index acc41b6..4fef26a 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsInventoryServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.SparePartsInventoryMapper; import com.os.ems.info.domain.SparePartsInventory; import com.os.ems.info.service.ISparePartsInventoryService; @@ -90,4 +92,83 @@ public class SparePartsInventoryServiceImpl implements ISparePartsInventoryServi { return sparePartsInventoryMapper.deleteSparePartsInventoryByObjid(objid); } + + /** + * 导入备件库记录主数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importSparePartsInventory(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (SparePartsInventory record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + SparePartsInventory existRecord = null; + if (StringUtils.isNotEmpty(record.getItemName()) && StringUtils.isNotEmpty(record.getOriginalPartNumber())) + { + SparePartsInventory queryRecord = new SparePartsInventory(); + queryRecord.setItemName(record.getItemName()); + queryRecord.setOriginalPartNumber(record.getOriginalPartNumber()); + List existRecords = sparePartsInventoryMapper.selectSparePartsInventoryList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertSparePartsInventory(record); + successNum++; + successMsg.append("
" + successNum + "、备件库记录 " + record.getItemName() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setObjid(existRecord.getObjid()); + record.setUpdateBy(operName); + this.updateSparePartsInventory(record); + successNum++; + successMsg.append("
" + successNum + "、备件库记录 " + record.getItemName() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、备件库记录 " + record.getItemName() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、备件库记录 " + record.getItemName() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsUsageRecordServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsUsageRecordServiceImpl.java index e4a700d..58e8707 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsUsageRecordServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/SparePartsUsageRecordServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.SparePartsUsageRecordMapper; import com.os.ems.info.domain.SparePartsUsageRecord; import com.os.ems.info.service.ISparePartsUsageRecordService; @@ -90,4 +92,83 @@ public class SparePartsUsageRecordServiceImpl implements ISparePartsUsageRecordS { return sparePartsUsageRecordMapper.deleteSparePartsUsageRecordById(id); } + + /** + * 导入动力能源部行输科备件领用更换记录数据 + * + * @param recordList 记录数据列表 + * @param isUpdateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importSparePartsUsageRecord(List recordList, Boolean isUpdateSupport, String operName) + { + if (StringUtils.isNull(recordList) || recordList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (SparePartsUsageRecord record : recordList) + { + try + { + // 设置操作人 + record.setCreateBy(operName); + + // 验证是否存在这个记录 + SparePartsUsageRecord existRecord = null; + if (StringUtils.isNotEmpty(record.getDate()) && StringUtils.isNotEmpty(record.getSparePartName())) + { + SparePartsUsageRecord queryRecord = new SparePartsUsageRecord(); + queryRecord.setDate(record.getDate()); + queryRecord.setSparePartName(record.getSparePartName()); + List existRecords = sparePartsUsageRecordMapper.selectSparePartsUsageRecordList(queryRecord); + if (existRecords.size() > 0) + { + existRecord = existRecords.get(0); + } + } + + if (StringUtils.isNull(existRecord)) + { + this.insertSparePartsUsageRecord(record); + successNum++; + successMsg.append("
" + successNum + "、备件记录 " + record.getSparePartName() + " 导入成功"); + } + else if (isUpdateSupport) + { + record.setId(existRecord.getId()); + record.setUpdateBy(operName); + this.updateSparePartsUsageRecord(record); + successNum++; + successMsg.append("
" + successNum + "、备件记录 " + record.getSparePartName() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、备件记录 " + record.getSparePartName() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、备件记录 " + record.getSparePartName() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } } diff --git a/os-ems/src/main/java/com/os/ems/info/service/impl/UpsBatteryLifecycleServiceImpl.java b/os-ems/src/main/java/com/os/ems/info/service/impl/UpsBatteryLifecycleServiceImpl.java index a9a256d..13f2c27 100644 --- a/os-ems/src/main/java/com/os/ems/info/service/impl/UpsBatteryLifecycleServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/info/service/impl/UpsBatteryLifecycleServiceImpl.java @@ -3,6 +3,8 @@ package com.os.ems.info.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import com.os.common.exception.ServiceException; +import com.os.common.utils.StringUtils; import com.os.ems.info.mapper.UpsBatteryLifecycleMapper; import com.os.ems.info.domain.UpsBatteryLifecycle; import com.os.ems.info.service.IUpsBatteryLifecycleService; @@ -90,4 +92,68 @@ public class UpsBatteryLifecycleServiceImpl implements IUpsBatteryLifecycleServi { return upsBatteryLifecycleMapper.deleteUpsBatteryLifecycleById(id); } + + /** + * 导入行李系统UPS电池生命周期数据 + * + * @param dataList 行李系统UPS电池生命周期数据列表 + * @param updateSupport 是否更新支持，如果已存在，则进行更新数据 + * @param operName 操作用户 + * @return 结果 + */ + @Override + public String importUpsBatteryLifecycle(List dataList, Boolean updateSupport, String operName) + { + if (StringUtils.isEmpty(dataList) || dataList.size() == 0) + { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (UpsBatteryLifecycle data : dataList) + { + try + { + // 验证是否存在这个数据 + UpsBatteryLifecycle u = upsBatteryLifecycleMapper.selectUpsBatteryLifecycleById(data.getId()); + if (StringUtils.isNull(u)) + { + data.setCreateBy(operName); + this.insertUpsBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 导入成功"); + } + else if (updateSupport) + { + data.setUpdateBy(operName); + this.updateUpsBatteryLifecycle(data); + successNum++; + successMsg.append("
" + successNum + "、" + data.getType() + " 更新成功"); + } + else + { + failureNum++; + failureMsg.append("
" + failureNum + "、" + data.getType() + " 已存在"); + } + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "、" + data.getType() + " 导入失败："; + failureMsg.append(msg + e.getMessage()); + } + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else + { + successMsg.insert(0, "恭喜您，数据已全部导入成功！共 " + successNum + " 条，数据如下："); + } + return successMsg.toString(); + } }