add(ems/info):页面实现导入功能，但有bug

- 全部页面的模板下载报错
- 更新已有记录无效
- 导入后的日期格式不对，复制粘贴不行，格式化也不行，只有导出的完全不动再导入才能保证正确

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<DailyFaultRecord> util = new ExcelUtil<DailyFaultRecord>(DailyFaultRecord.class);
+        List<DailyFaultRecord> 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<DailyFaultRecord> util = new ExcelUtil<DailyFaultRecord>(DailyFaultRecord.class);
+        return util.importTemplateExcel("日常故障记录数据");
+    }
 }

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<FaultHandlingRecord> util = new ExcelUtil<FaultHandlingRecord>(FaultHandlingRecord.class);
+        List<FaultHandlingRecord> 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<FaultHandlingRecord> util = new ExcelUtil<FaultHandlingRecord>(FaultHandlingRecord.class);
+        return util.importTemplateExcel("故障处置记录数据");
+    }
 }

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<LuggageSystemPlcBufferBatteryLifecycle> util = new ExcelUtil<LuggageSystemPlcBufferBatteryLifecycle>(LuggageSystemPlcBufferBatteryLifecycle.class);
+        List<LuggageSystemPlcBufferBatteryLifecycle> 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<LuggageSystemPlcBufferBatteryLifecycle> util = new ExcelUtil<LuggageSystemPlcBufferBatteryLifecycle>(LuggageSystemPlcBufferBatteryLifecycle.class);
+        return util.importTemplateExcel("行李系统PLC缓冲电池生命周期数据");
+    }
 }

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<LuggageSystemSecurityDoorBatteryLifecycle> util = new ExcelUtil<LuggageSystemSecurityDoorBatteryLifecycle>(LuggageSystemSecurityDoorBatteryLifecycle.class);
+        List<LuggageSystemSecurityDoorBatteryLifecycle> 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<LuggageSystemSecurityDoorBatteryLifecycle> util = new ExcelUtil<LuggageSystemSecurityDoorBatteryLifecycle>(LuggageSystemSecurityDoorBatteryLifecycle.class);
+        return util.importTemplateExcel("行李系统安全门铅酸电池生命周期数据");
+    }
 }

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<PowerEnergySparePartsRegistration> util = new ExcelUtil<PowerEnergySparePartsRegistration>(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<PowerEnergySparePartsRegistration> util = new ExcelUtil<PowerEnergySparePartsRegistration>(PowerEnergySparePartsRegistration.class);
+        List<PowerEnergySparePartsRegistration> recordList = util.importExcel(file.getInputStream());
+        String operName = getUsername();
+        String message = powerEnergySparePartsRegistrationService.importPowerEnergySparePartsRegistration(recordList, updateSupport, operName);
+        return success(message);
+    }
 }

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<PowerEnergySupervisionChecklist> util = new ExcelUtil<PowerEnergySupervisionChecklist>(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<PowerEnergySupervisionChecklist> util = new ExcelUtil<PowerEnergySupervisionChecklist>(PowerEnergySupervisionChecklist.class);
+        List<PowerEnergySupervisionChecklist> recordList = util.importExcel(file.getInputStream());
+        String operName = getUsername();
+        String message = powerEnergySupervisionChecklistService.importPowerEnergySupervisionChecklist(recordList, updateSupport, operName);
+        return success(message);
+    }
 }

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<SparePartsInventoryCheck> util = new ExcelUtil<SparePartsInventoryCheck>(SparePartsInventoryCheck.class);
+        List<SparePartsInventoryCheck> 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<SparePartsInventoryCheck> util = new ExcelUtil<SparePartsInventoryCheck>(SparePartsInventoryCheck.class);
+        return util.importTemplateExcel("备件盘点记录明细数据");
+    }
 }

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<SparePartsInventory> util = new ExcelUtil<SparePartsInventory>(SparePartsInventory.class);
+        List<SparePartsInventory> 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<SparePartsInventory> util = new ExcelUtil<SparePartsInventory>(SparePartsInventory.class);
+        return util.importTemplateExcel("备件库记录主数据");
+    }
 }

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<SparePartsUsageRecord> util = new ExcelUtil<SparePartsUsageRecord>(SparePartsUsageRecord.class);
+        List<SparePartsUsageRecord> 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<SparePartsUsageRecord> util = new ExcelUtil<SparePartsUsageRecord>(SparePartsUsageRecord.class);
+        return util.importTemplateExcel("动力能源部行输科备件领用更换记录数据");
+    }
 }

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<UpsBatteryLifecycle> util = new ExcelUtil<UpsBatteryLifecycle>(UpsBatteryLifecycle.class);
+        List<UpsBatteryLifecycle> 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<UpsBatteryLifecycle> util = new ExcelUtil<UpsBatteryLifecycle>(UpsBatteryLifecycle.class);
+        return util.importTemplateExcel("行李系统UPS电池生命周期数据");
+    }
 }

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;
 
     /** 位置描述 */

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<DailyFaultRecord> recordList, Boolean isUpdateSupport, String operName);
 }

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<FaultHandlingRecord> recordList, Boolean isUpdateSupport, String operName);
 }

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<LuggageSystemPlcBufferBatteryLifecycle> dataList, Boolean updateSupport, String operName);
 }

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<LuggageSystemSecurityDoorBatteryLifecycle> dataList, Boolean updateSupport, String operName);
 }

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<PowerEnergySparePartsRegistration> recordList, Boolean isUpdateSupport, String operName);
 }

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<PowerEnergySupervisionChecklist> recordList, Boolean isUpdateSupport, String operName);
 }

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<SparePartsInventoryCheck> recordList, Boolean isUpdateSupport, String operName);
 }

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<SparePartsInventory> recordList, Boolean isUpdateSupport, String operName);
 }

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<SparePartsUsageRecord> recordList, Boolean isUpdateSupport, String operName);
 }

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<UpsBatteryLifecycle> dataList, Boolean updateSupport, String operName);
 }

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<DailyFaultRecord> 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<DailyFaultRecord> existRecords = dailyFaultRecordMapper.selectDailyFaultRecordList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertDailyFaultRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、日常故障记录 " + record.getLocation() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setId(existRecord.getId());
+                    record.setUpdateBy(operName);
+                    this.updateDailyFaultRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、日常故障记录 " + record.getLocation() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、日常故障记录 " + record.getLocation() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
+
 }

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<FaultHandlingRecord> 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<FaultHandlingRecord> existRecords = faultHandlingRecordMapper.selectFaultHandlingRecordList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertFaultHandlingRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、故障处置记录 " + record.getFaultLocation() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setId(existRecord.getId());
+                    record.setUpdateBy(operName);
+                    this.updateFaultHandlingRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、故障处置记录 " + record.getFaultLocation() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、故障处置记录 " + record.getFaultLocation() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<LuggageSystemPlcBufferBatteryLifecycle> 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("<br/>" + successNum + "、" + data.getType() + " 导入成功");
+                }
+                else if (updateSupport)
+                {
+                    data.setUpdateBy(operName);
+                    this.updateLuggageSystemPlcBufferBatteryLifecycle(data);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、" + data.getType() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、" + data.getType() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<LuggageSystemSecurityDoorBatteryLifecycle> 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("<br/>" + successNum + "、" + data.getType() + " 导入成功");
+                }
+                else if (updateSupport)
+                {
+                    data.setUpdateBy(operName);
+                    this.updateLuggageSystemSecurityDoorBatteryLifecycle(data);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、" + data.getType() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、" + data.getType() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<PowerEnergySparePartsRegistration> 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<PowerEnergySparePartsRegistration> existRecords = powerEnergySparePartsRegistrationMapper.selectPowerEnergySparePartsRegistrationList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertPowerEnergySparePartsRegistration(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、废旧备件登记 " + record.getType() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setObjid(existRecord.getObjid());
+                    record.setUpdateBy(operName);
+                    this.updatePowerEnergySparePartsRegistration(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、废旧备件登记 " + record.getType() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、废旧备件登记 " + record.getType() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<PowerEnergySupervisionChecklist> 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<PowerEnergySupervisionChecklist> existRecords = powerEnergySupervisionChecklistMapper.selectPowerEnergySupervisionChecklistList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertPowerEnergySupervisionChecklist(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、检查记录 " + record.getJobName() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setId(existRecord.getId());
+                    record.setUpdateBy(operName);
+                    this.updatePowerEnergySupervisionChecklist(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、检查记录 " + record.getJobName() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、检查记录 " + record.getJobName() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<SparePartsInventoryCheck> 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<SparePartsInventoryCheck> existRecords = sparePartsInventoryCheckMapper.selectSparePartsInventoryCheckList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertSparePartsInventoryCheck(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件盘点记录 " + record.getCheckName() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setId(existRecord.getId());
+                    record.setUpdateBy(operName);
+                    this.updateSparePartsInventoryCheck(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件盘点记录 " + record.getCheckName() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、备件盘点记录 " + record.getCheckName() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<SparePartsInventory> 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<SparePartsInventory> existRecords = sparePartsInventoryMapper.selectSparePartsInventoryList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertSparePartsInventory(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件库记录 " + record.getItemName() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setObjid(existRecord.getObjid());
+                    record.setUpdateBy(operName);
+                    this.updateSparePartsInventory(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件库记录 " + record.getItemName() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、备件库记录 " + record.getItemName() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<SparePartsUsageRecord> 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<SparePartsUsageRecord> existRecords = sparePartsUsageRecordMapper.selectSparePartsUsageRecordList(queryRecord);
+                    if (existRecords.size() > 0)
+                    {
+                        existRecord = existRecords.get(0);
+                    }
+                }
+                
+                if (StringUtils.isNull(existRecord))
+                {
+                    this.insertSparePartsUsageRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件记录 " + record.getSparePartName() + " 导入成功");
+                }
+                else if (isUpdateSupport)
+                {
+                    record.setId(existRecord.getId());
+                    record.setUpdateBy(operName);
+                    this.updateSparePartsUsageRecord(record);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、备件记录 " + record.getSparePartName() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、备件记录 " + record.getSparePartName() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }

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<UpsBatteryLifecycle> 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("<br/>" + successNum + "、" + data.getType() + " 导入成功");
+                }
+                else if (updateSupport)
+                {
+                    data.setUpdateBy(operName);
+                    this.updateUpsBatteryLifecycle(data);
+                    successNum++;
+                    successMsg.append("<br/>" + successNum + "、" + data.getType() + " 更新成功");
+                }
+                else
+                {
+                    failureNum++;
+                    failureMsg.append("<br/>" + failureNum + "、" + data.getType() + " 已存在");
+                }
+            }
+            catch (Exception e)
+            {
+                failureNum++;
+                String msg = "<br/>" + 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();
+    }
 }