Merge branch 'master' of http://10.1.235.20:3000/asiainfo/ebc.git

location-rescue-service/pom.xml

@@ -113,6 +113,12 @@
            <version>1.2</version>
        </dependency>
        <dependency>
            <groupId>org.apache.poi</groupId>
            <artifactId>poi-ooxml</artifactId>
            <version>3.6</version>
        </dependency>
        <!--	<dependency>
                     <groupId>com.ai.ipu</groupId>
                     <artifactId>ipu-data</artifactId>

location-rescue-service/src/main/java/com/ai/bss/location/rescue/controller/EquipmentManageController.java

@@ -1,17 +1,27 @@
package com.ai.bss.location.rescue.controller;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import com.ai.bss.location.rescue.util.ImportExcelUtil;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
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.ResponseBody;
import com.ai.abc.api.model.CommonRequest;
@@ -21,6 +31,7 @@ import com.ai.bss.location.rescue.service.interfaces.EquipmentManageService;
import com.ai.bss.location.rescue.util.EbcConstant;
import com.ai.bss.work.tool.model.ResourceTool;
import com.ai.bss.work.tool.model.ResourceToolType;
import org.springframework.web.multipart.MultipartFile;
/**
 * 设备管理
@@ -95,18 +106,37 @@ public class EquipmentManageController {
    }
    /**
	 * 获取所有不可绑定的设备
	 */
	@ResponseBody
	@RequestMapping("/queryAllEquipmentNotBind")
	public CommonResponse<List<Map<String, Object>>> queryAllEquipmentNotBind(HttpServletRequest request) throws Exception {
		HashMap<String, Object> dataMap = new HashMap<String, Object>();
		//TODO 组织ID 权限控制
		//JSONObject userInfo = new LoginUserInfoUtil().getUserInfo(request);
     * 获取所有不可绑定的设备
     */
    @ResponseBody
    @RequestMapping("/queryAllEquipmentNotBind")
    public CommonResponse<List<Map<String, Object>>> queryAllEquipmentNotBind(HttpServletRequest request) throws Exception {
        HashMap<String, Object> dataMap = new HashMap<String, Object>();
        //TODO 组织ID 权限控制
        //JSONObject userInfo = new LoginUserInfoUtil().getUserInfo(request);
        //dataMap.put("workOrgId", userInfo.get("USER_ORG_ID").toString());
		dataMap.put("workOrgId", "0000");
        dataMap.put("workOrgId", "0000");
        dataMap.put("isAllowBindTerminal", EbcConstant.TOOL_BIND_REJECT);
		return equipmentManageService.queryAllEquipmentNotBind(dataMap);
	}
        return equipmentManageService.queryAllEquipmentNotBind(dataMap);
    }
    /**
     * 批量导入设备
     * @return
     */
    @ResponseBody
    @RequestMapping("/importEquipmentInfos")
    public CommonResponse<Object> importEquipmentInfos(@RequestParam("file") MultipartFile file) throws Exception {
        if (file.isEmpty()) {
            return CommonResponse.fail("0","文件为空");
        }
        CommonResponse<Object> result=equipmentManageService.importEquipmentInfos(file);
        //获取数据
        List<List<Object>> olist = ImportExcelUtil.getListByExcel(file.getInputStream(), file.getOriginalFilename());
        CommonResponse<Object> ok = CommonResponse.ok(olist);
        return ok;
    }
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/impl/EquipmentManageServiceImpl.java

@@ -1,9 +1,16 @@
package com.ai.bss.location.rescue.service.impl;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.ai.bss.location.rescue.util.ImportExcelUtil;
import com.ai.ipu.basic.string.StringUtil;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -18,6 +25,7 @@ import com.ai.bss.work.tool.model.ResourceTool;
import com.ai.bss.work.tool.model.ResourceToolType;
import com.ai.bss.work.tool.service.api.ResourceToolCommand;
import com.ai.bss.work.tool.service.api.ResourceToolQuery;
import org.springframework.web.multipart.MultipartFile;
@Service
public class EquipmentManageServiceImpl<EquipmentManageDao> implements EquipmentManageService {
@@ -69,4 +77,104 @@ public class EquipmentManageServiceImpl<EquipmentManageDao> implements Equipment
		return CommonResponse.ok(response.getData().getData());
	}
	@Override
	public CommonResponse<Object> importEquipmentInfos(MultipartFile file) {
		//校验结果
		boolean reqFlag = true;
		//回复消息
		String reqMsg = "";
		//报错消息数
		Integer error = 0;
		List<List<Object>> list = null;
		//创建Excel工作薄
		try {
			Workbook work = ImportExcelUtil.getWorkbook(file.getInputStream(),file.getOriginalFilename());
			if(null == work){
				throw new Exception("创建Excel工作薄为空！");
			}
			Sheet sheet = null;
			Row row = null;
			Cell cell = null;
			list = new ArrayList<List<Object>>();
			//遍历Excel中所有的sheet
			for (int i = 0; i < work.getNumberOfSheets(); i++) {
				sheet = work.getSheetAt(i);
				if(sheet==null){continue;}
				//遍历当前sheet中的所有行
				for (int j = sheet.getFirstRowNum(); j < sheet.getLastRowNum()+1; j++) {
					row = sheet.getRow(j);
					if(row==null||row.getFirstCellNum()==j){continue;}
					//遍历所有的列
					List<Object> li = new ArrayList<Object>();
					for (int y = row.getFirstCellNum(); y < row.getLastCellNum(); y++) {
						cell = row.getCell(y);
						//效验参数 j是行 y是列
						if (j < 4 && "".equals(row.getCell(y).getStringCellValue())) { //----这里判断必填项（前4列）
							reqFlag = false;
							reqMsg += "第" + (i + 1) + "行错误，错误信息：" + "必填项缺漏";
							reqMsg += "<br>";
							error++;
							break;
						}
						String cellString = row.getCell(y).getStringCellValue();
						cellString = cellString.trim();
						switch (j) {
							/*case 1: {
								//进行校验处理，例如手机号
								if (!StringUtil.isMobileNo(cellString)) {
									reqFlag = false;
									reqMsg += "第" + (i + 1) + "行错误，错误信息：" + "联系电话有误";
									reqMsg += "<br>";
									error++;
								} else {
									map.put(j, cellString);
								}
								break;
							}
							case 2: { ###  break; }
							case 3: { ###  break; }
							//无需校验，归入default
							default: {
								map.put(j, cell.getContents());
							}*/
						}
						//将结果放到list里
						li.add(ImportExcelUtil.getCellValue(cell));
					}
					list.add(li);
				}
				if (reqFlag) {//校验通过
					//mapList.add(map);
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		//效验通过插入数据库
		//入库
	/*	try {
			if (mapList.size() > 0 && reqFlag) {
				//此处try,catch应优化为事务处理maplist实现全记录成功或失败
				result.setSuccess("提交成功");
			} else {
				if (error > 10) {//设置要显示的错误数
					int index = StringUtil.getIndex(reqMsg, 10, "<br>");
					reqMsg = reqMsg.substring(0, index + 4);
					reqMsg += "未显示错误数：" + (error - 10) + "条";
					reqMsg += "<br>";
				}
				result.setFailure(reqMsg);
			}
		} catch (Exception e) {
			result.setFailure("入库错误，请联系管理员！");
			e.printStackTrace();
		}*/
		return null;
	}
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/service/interfaces/EquipmentManageService.java

@@ -9,6 +9,7 @@ import com.ai.abc.api.model.CommonResponse;
import com.ai.bss.components.common.model.PageBean;
import com.ai.bss.work.tool.model.ResourceTool;
import com.ai.bss.work.tool.model.ResourceToolType;
import org.springframework.web.multipart.MultipartFile;
public interface EquipmentManageService {
@@ -23,4 +24,6 @@ public interface EquipmentManageService {
    CommonResponse<List<ResourceToolType>> loadAllResourceToolType(CommonRequest commonRequest);
    CommonResponse<List<Map<String, Object>>> queryAllEquipmentNotBind(HashMap<String, Object> dataMap) throws Exception;
    CommonResponse<Object> importEquipmentInfos(MultipartFile file);
}

location-rescue-service/src/main/java/com/ai/bss/location/rescue/util/ImportExcelUtil.java

@@ -0,0 +1,119 @@
package com.ai.bss.location.rescue.util;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.*;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import java.io.IOException;
import java.io.InputStream;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
public class ImportExcelUtil {
    private final static String excel2003L =".xls";    //2003- 版本的excel
    private final static String excel2007U =".xlsx";   //2007+ 版本的excel
    /**
     * 描述：获取IO流中的数据，组装成List<List<Object>>对象
     * @param in,fileName
     * @return
     * @throws IOException
     */
    public static List<List<Object>> getListByExcel(InputStream in,String fileName) throws Exception{
        List<List<Object>> list = null;
        //创建Excel工作薄
        Workbook work = ImportExcelUtil.getWorkbook(in,fileName);
        if(null == work){
            throw new Exception("创建Excel工作薄为空！");
        }
        Sheet sheet = null;
        Row row = null;
        Cell cell = null;
        list = new ArrayList<List<Object>>();
        //遍历Excel中所有的sheet
        for (int i = 0; i < work.getNumberOfSheets(); i++) {
            sheet = work.getSheetAt(i);
            if(sheet==null){continue;}
            //遍历当前sheet中的所有行
            for (int j = sheet.getFirstRowNum(); j < sheet.getLastRowNum()+1; j++) {
                row = sheet.getRow(j);
                if(row==null||row.getFirstCellNum()==j){continue;}
                //遍历所有的列
                List<Object> li = new ArrayList<Object>();
                for (int y = row.getFirstCellNum(); y < row.getLastCellNum(); y++) {
                    cell = row.getCell(y);
                    li.add(ImportExcelUtil.getCellValue(cell));
                }
                list.add(li);
            }
        }
        return list;
    }
    /**
     * 描述：根据文件后缀，自适应上传文件的版本
     * @param inStr,fileName
     * @return
     * @throws Exception
     */
    public static Workbook getWorkbook(InputStream inStr, String fileName) throws Exception{
        Workbook wb = null;
        String fileType = fileName.substring(fileName.lastIndexOf("."));
        if(excel2003L.equals(fileType)){
            wb = new HSSFWorkbook(inStr);  //2003-
        }else if(excel2007U.equals(fileType)){
            wb = new XSSFWorkbook(inStr);  //2007+
        }else{
            throw new Exception("解析的文件格式有误！");
        }
        return wb;
    }
    /**
     * 描述：对表格中数值进行格式化
     * @param cell
     * @return
     */
    public  static Object getCellValue(Cell cell){
        Object value = null;
        //DecimalFormat df = new DecimalFormat("0");  //格式化number String字符
        SimpleDateFormat sdf = new SimpleDateFormat("yyy-MM-dd");  //日期格式化
        DecimalFormat df2 = new DecimalFormat("0.00");  //格式化数字
        switch (cell.getCellType()) {
            case Cell.CELL_TYPE_STRING:
                value = cell.getRichStringCellValue().getString();
                break;
            case Cell.CELL_TYPE_NUMERIC:
                if("General".equals(cell.getCellStyle().getDataFormatString())){
                    //value = df.format(cell.getNumericCellValue());
                    value = cell.getNumericCellValue();
                }else if("m/d/yy".equals(cell.getCellStyle().getDataFormatString())){
                    value = sdf.format(cell.getDateCellValue());
                }else{
                    value = df2.format(cell.getNumericCellValue());
                }
                break;
            case Cell.CELL_TYPE_BOOLEAN:
                value = cell.getBooleanCellValue();
                break;
            case Cell.CELL_TYPE_BLANK:
                value = "";
                break;
            default:
                break;
        }
        return value;
    }
}