public class EbcSeaPlatformStart {

package com.ai.ipu.server.controller;

import java.io.InputStream;

import java.net.URLEncoder;

import java.util.Calendar;

import java.util.Date;

import java.util.HashMap;

import java.util.Map;

import org.apache.poi.util.IOUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.http.HttpHeaders;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.util.StringUtils;

import org.springframework.validation.annotation.Validated;

@Validated

public class BaseFrontController {

    /**

     * slf4j 日志 logger

     */

    protected final Logger logger = LoggerFactory.getLogger(this.getClass());

    /**

     * 下载文件,纯SpringMVC的API来完成

     *

     * @param is 文件输入流

     * @param name 文件名称,带后缀名

     *

     * @throws Exception

     */

    public ResponseEntity<byte[]> buildResponseEntity(InputStream is, String name) throws Exception {

        logger.info(">>>>>>>>>>>>>>>>>>>>开始下载文件>>>>>>>>>>");

        if (this.logger.isDebugEnabled())

            this.logger.debug("download: " + name);

        HttpHeaders header = new HttpHeaders();

        Calendar cal = Calendar.getInstance();

        int year = cal.get(Calendar.YEAR);//获取年份

        int month=cal.get(Calendar.MONTH)+1;//获取月份

        int day=cal.get(Calendar.DATE);//获取日

        int hour=cal.get(Calendar.HOUR);//小时

        int minute=cal.get(Calendar.MINUTE);//分

        int second=cal.get(Calendar.SECOND);//秒

        String filePrefix = name.substring(0,name.lastIndexOf('.') - 1);

        String fileSuffix = name.substring(name.lastIndexOf('.') + 1);

        fileSuffix = fileSuffix.toLowerCase();

        String fileName=filePrefix+year+month+day+hour+minute+second+"."+fileSuffix;

        Map<String, String> arguments = new HashMap<String, String>();

        arguments.put("xlsx", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet");

        arguments.put("xls", "application/vnd.ms-excel");

        String contentType = arguments.get(fileSuffix);

        header.add("Content-Type", (StringUtils.hasText(contentType) ? contentType : "application/x-download"));

        if(is!=null && is.available()!=0){

            header.add("Content-Length", String.valueOf(is.available()));

            header.add("Content-Disposition", "attachment;filename*=utf-8'zh_cn'" + URLEncoder.encode(fileName, "UTF-8"));

            byte[] bs = IOUtils.toByteArray(is);

            logger.info(">>>>>>>>>>>>>>>>>>>>结束下载文件-有记录>>>>>>>>>>");

            logger.info(">>>>>>>>>>结束导出excel>>>>>>>>>>");

            return new ResponseEntity<>(bs, header, HttpStatus.OK);

        }else{

            String string="数据为空";

            header.add("Content-Length", "0");

            header.add("Content-Disposition", "attachment;filename*=utf-8'zh_cn'" + URLEncoder.encode(fileName, "UTF-8"));

            logger.info(">>>>>>>>>>>>>>>>>>>>结束下载文件-无记录>>>>>>>>>>");

            logger.info(">>>>>>>>>>结束导出excel>>>>>>>>>>");

            return new ResponseEntity<>(string.getBytes(), header, HttpStatus.OK);

        }

    }

}

package com.ai.ipu.server.controller;

import com.ai.ipu.basic.util.IpuUtility;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.service.interfaces.ExportService;

import com.ai.ipu.server.service.interfaces.CallRescuerService;

import com.ai.ipu.server.util.RestScaffoldConstant;

import com.github.pagehelper.PageInfo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

@Controller

@RequestMapping("/terminal")

public class CallRescuerController {

    @Autowired

    @Qualifier("CallRescuerServiceImpl")

    ExportService exportService;

    @Autowired

    CallRescuerService callRescuerService;

    /**

     * 查询终端信息

     */

    @ResponseBody

    @RequestMapping("/queryCallRescuerInfo")

    public JMap queryCallRescuerInfo(JMap params) throws Exception {

        PageInfo terminalList=  callRescuerService.queryCallRescuerInfo(params);

        JMap result = new JsonMap();

        result.put("result", terminalList);

        return result;

    }

    /**

     * 导出地图标记到excel

     */

    @ResponseBody

    @RequestMapping("/exportCallRescuerInfoToExcel")

    public ResponseEntity<byte[]> exportCallRescuerInfoToExcel(JMap params, HttpServletRequest request, HttpServletResponse response) throws Exception {

        return exportService.exportExcel(request,response,params);

    }

    /**

     * 编辑地图标记

     */

    @ResponseBody

    @RequestMapping("/modifyCallRescuerInfo")

    public JMap modifyCallRescuerInfo(JMap params) throws Exception {

        int num=0;

        //取值判断如果有当前id则为修改，否则为新增

        JMap params1 = params.getJMap("params");

        try{

            if(params1.getInt("MAP_TAG_ID")!=0){

                num= callRescuerService.modifyCallRescuerInfo(params1);

            }else{

                num= callRescuerService.addCallRescuerInfo(params1);

            }

        }catch(Exception e){

            e.printStackTrace();

            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);

        }

        JMap result = new JsonMap();

        if(num>0){

            result.put("result", true);

        }else{

            result.put("result", false);

        }

        return result;

    }

    /**

     * 刪除地图标记

     */

    @ResponseBody

    @RequestMapping("/deleteCallRescuerXyInfo")

    public JMap deleteCallRescuerXyInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  callRescuerService.deleteCallRescuerXyInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

}

package com.ai.ipu.server.controller;

import com.ai.ipu.basic.util.IpuUtility;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.service.interfaces.ExportService;

import com.ai.ipu.server.service.interfaces.DeviceManageService;

import com.ai.ipu.server.util.RestScaffoldConstant;

import com.github.pagehelper.PageInfo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

@Controller

@RequestMapping("/device")

public class DeviceManageController {

    @Autowired

    @Qualifier("DeviceManageServiceImpl")

    ExportService exportService;

    @Autowired

    DeviceManageService deviceManageService;

    /**

     * 查询终端信息

     */

    @ResponseBody

    @RequestMapping("/queryDeviceInfo")

    public JMap queryDeviceInfo(JMap params) throws Exception {

        PageInfo deviceList=  deviceManageService.queryDeviceInfo(params);

        JMap result = new JsonMap();

        result.put("result", deviceList);

        return result;

    }

    /**

     * 导出終端设备信息到excel

     */

    @ResponseBody

    @RequestMapping("/exportDeviceInfoToExcel")

    public ResponseEntity<byte[]> exportDeviceInfoToExcel(JMap params, HttpServletRequest request, HttpServletResponse response) throws Exception {

        return exportService.exportExcel(request,response,params);

    }

    /**

     * 编辑地图标记

     */

    @ResponseBody

    @RequestMapping("/modifyDeviceInfo")

    public JMap modifyDeviceInfo(JMap params) throws Exception {

        int num=0;

        //取值判断如果有当前id则为修改，否则为新增

        JMap params1 = params.getJMap("params");

        try{

            if(params1.getInt("MAP_TAG_ID")!=0){

                num= deviceManageService.modifyDeviceInfo(params1);

            }else{

                num= deviceManageService.addDeviceInfo(params1);

            }

        }catch(Exception e){

            e.printStackTrace();

            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);

        }

        JMap result = new JsonMap();

        if(num>0){

            result.put("result", true);

        }else{

            result.put("result", false);

        }

        return result;

    }

    /**

     * 刪除地图标记

     */

    @ResponseBody

    @RequestMapping("/deleteDeviceXyInfo")

    public JMap deleteDeviceXyInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  deviceManageService.deleteDeviceXyInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

}

package com.ai.ipu.server.controller;

import com.ai.ipu.basic.util.IpuUtility;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.service.interfaces.ExportService;

import com.ai.ipu.server.service.interfaces.EquipmentManageService;

import com.ai.ipu.server.util.RestScaffoldConstant;

import com.github.pagehelper.PageInfo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

@Controller

@RequestMapping("/equipment")

public class EquipmentManageController {

    @Autowired

    @Qualifier("EquipmentManageServiceImpl")

    ExportService exportService;

    @Autowired

    EquipmentManageService equipmentManageService;

    /**

     * 查询设备信息

     */

    @ResponseBody

    @RequestMapping("/queryEquipmentInfo")

    public JMap queryEquipmentInfo(JMap params) throws Exception {

        PageInfo equipmentList=  equipmentManageService.queryEquipmentInfo(params);

        JMap result = new JsonMap();

        result.put("result", equipmentList);

        return result;

    }

    /**

     * 导出设备信息到excel

     */

    @ResponseBody

    @RequestMapping("/exportEquipmentInfoToExcel")

    public ResponseEntity<byte[]> exportEquipmentInfoToExcel(JMap params, HttpServletRequest request, HttpServletResponse response) throws Exception {

        return exportService.exportExcel(request,response,params);

    }

    /**

     * 编辑设备信息、新增设备信息

     */

    @ResponseBody

    @RequestMapping("/modifyEquipmentInfo")

    public JMap modifyEquipmentInfo(JMap params) throws Exception {

        int num=0;

        //取值判断如果有当前id则为修改，否则为新增

        JMap params1 = params.getJMap("params");

        try{

            if(params1.getInt("MAP_TAG_ID")!=0){

                num= equipmentManageService.modifyEquipmentInfo(params1);

            }else{

                num= equipmentManageService.addEquipmentInfo(params1);

            }

        }catch(Exception e){

            e.printStackTrace();

            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);

        }

        JMap result = new JsonMap();

        if(num>0){

            result.put("result", true);

        }else{

            result.put("result", false);

        }

        return result;

    }

    /**

     * 刪除删除设备信息

     */

    @ResponseBody

    @RequestMapping("/deleteEquipmentInfo")

    public JMap deleteEquipmentInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  equipmentManageService.deleteEquipmentInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

    /**

     * 批量刪除删除设备信息

     */

    @ResponseBody

    @RequestMapping("/deleteEquipmentsInfo")

    public JMap deleteEquipmentsInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  equipmentManageService.deleteEquipmentsInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

    /**

     * 导入设备信息

     */

    @ResponseBody

    @RequestMapping("/importEquipmentsInfo")

    public JMap importEquipmentsInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  equipmentManageService.importEquipmentInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

}

import com.ai.ipu.server.service.interfaces.ExportService;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.http.MediaType;

import org.springframework.http.ResponseEntity;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.util.Date;

    @Autowired

    @Qualifier("MapTagManageServiceImpl")

    ExportService exportService;

    public ResponseEntity<byte[]> exportMapTagInfoToExcel(JMap params, HttpServletRequest request, HttpServletResponse response) throws Exception {

        return exportService.exportExcel(request,response,params);

    /**

     * 刪除地图标记

     */

    @ResponseBody

    @RequestMapping("/deleteMapTagXyInfo")

    public JMap deleteMapTagXyInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  mapTagManageService.deleteMapTagXyInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

package com.ai.ipu.server.controller;

import com.ai.ipu.basic.util.IpuUtility;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.service.interfaces.ExportService;

import com.ai.ipu.server.service.interfaces.UserManageService;

import com.ai.ipu.server.util.RestScaffoldConstant;

import com.github.pagehelper.PageInfo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.http.ResponseEntity;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

@Controller

@RequestMapping("/user")

public class UserManageController {

    @Autowired

    @Qualifier("UserManageServiceImpl")

    ExportService exportService;

    @Autowired

    UserManageService userManageService;

    /**

     * 查询用户信息

     */

    @ResponseBody

    @RequestMapping("/queryUserInfo")

    public JMap queryUserInfo(JMap params) throws Exception {

        PageInfo userList=  userManageService.queryUserInfo(params);

        JMap result = new JsonMap();

        result.put("result", userList);

        return result;

    }

    /**

     * 导出用户信息到excel

     */

    @ResponseBody

    @RequestMapping("/exportUserInfoToExcel")

    public ResponseEntity<byte[]> exportUserInfoToExcel(JMap params, HttpServletRequest request, HttpServletResponse response) throws Exception {

        return exportService.exportExcel(request,response,params);

    }

    /**

     * 编辑用户信息、新增用户信息

     */

    @ResponseBody

    @RequestMapping("/modifyUserInfo")

    public JMap modifyUserInfo(JMap params) throws Exception {

        int num=0;

        //取值判断如果有当前id则为修改，否则为新增

        JMap params1 = params.getJMap("params");

        try{

            if(params1.getInt("MAP_TAG_ID")!=0){

                num= userManageService.modifyUserInfo(params1);

            }else{

                num= userManageService.addUserInfo(params1);

            }

        }catch(Exception e){

            e.printStackTrace();

            IpuUtility.errorCode(RestScaffoldConstant.SERVER_003);

        }

        JMap result = new JsonMap();

        if(num>0){

            result.put("result", true);

        }else{

            result.put("result", false);

        }

        return result;

    }

    /**

     * 刪除用户信息

     */

    @ResponseBody

    @RequestMapping("/deleteUserInfo")

    public JMap deleteUserXyInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            flag=  userManageService.deleteUserXyInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

    /**

     * 导入用户信息

     */

    @ResponseBody

    @RequestMapping("/importUserInfo")

    public JMap importUserInfo(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            //flag=  userManageService.importUserInfo(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

    /**

     * 关联终端

     */

    @ResponseBody

    @RequestMapping("/associatTerminal")

    public JMap associatTerminal(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            //flag=  userManageService.associatTerminal(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

    /**

     * 解绑终端

     */

    @ResponseBody

    @RequestMapping("/unbundTerminal")

    public JMap unbundTerminal(JMap params) throws Exception {

        boolean flag=false;

        if(params.getInt("MAP_TAG_ID")!=0){

            //flag=  userManageService.unbundTerminal(params);

        }

        JMap result = new JsonMap();

        result.put("result", flag);

        return result;

    }

}

package com.ai.ipu.server.dao.impl;

import com.ai.ipu.data.JList;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonList;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.dao.interfaces.CallRescuerDao;

import com.ai.ipu.sql.mgmt.ISqlMgmtDao;

import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.github.pagehelper.PageHelper;

import com.github.pagehelper.PageInfo;

import org.springframework.stereotype.Component;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

@Component

public class CallRescuerDaoImpl implements CallRescuerDao {

    private String connName = "ebc";

    @Override

    public PageInfo queryCallRescuerInfo(JMap params) throws Exception {

        JMap params1 = params.getJMap("params");

        PageHelper.startPage(params1.getInt("pageNum"),params1.getInt("pageSize"));

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        List<Map<String, Object>> mapTagList= dao.executeSelect("ipu.CallRescuerDao", "queryCallRescuerInfo", params1);

        List<Map<String, Object>> mapTagXyList= dao.executeSelect("ipu.CallRescuerDao", "queryCallRescuerXyInfo", params1);

        //将后台拼接成级联属性

        mapTagList.forEach((mapTag)->{

            ArrayList<Object> arrayList = new ArrayList<>();

            mapTagXyList.forEach((mapTagXy)->{

                if(mapTag.get("MAP_TAG_ID")==mapTagXy.get("MAP_TAG_ID")){

                    arrayList.add(mapTagXy);

                    System.out.println(arrayList.toString());

                }

            });

            mapTag.put("EBC_MAP_TAG_XY",arrayList);

        });

        PageInfo pageInfo = new PageInfo(mapTagList);

        return pageInfo;

    }

    @Override

    public int modifyCallRescuerInfo (JMap params) throws Exception {

        deleteCallRescuerXyInfo(params);

        //将新数据插入

        int num = addCallRescuerInfo(params);

        return num;

    }

    @Override

    public int addCallRescuerInfo(JMap params) throws Exception {

        Object mapTagContent = params.get("MAP_TAG_CONTENT");

        String mapTagContentStr = JSONObject.toJSONString(mapTagContent);

        params.put("MAP_TAG_CONTENT",mapTagContentStr);

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        int num = dao.executeInsert("ipu.CallRescuerManageDao", "addCallRescuerInfo", params);

        if(num>0){

            JMap paramsMap=new JsonMap();

            JList paramsList=new JsonList();

            JList paramsJList = params.getJList("EBC_MAP_TAG_XY");

            paramsJList.forEach(s->{

                HashMap hashMap = JSON.parseObject(JSONObject.toJSONString(s), HashMap.class);

                hashMap.put("MAP_TAG_ID",params.getInt("MAP_TAG_ID"));

                paramsList.add(hashMap);

            });

            paramsMap.put("paramsList",paramsList);

            int i = dao.executeInsert("ipu.CallRescuerDao", "addCallRescuerxyInfo", paramsMap);

        }

        return num;

    }

    @Override

    public boolean deleteCallRescuerXyInfo(JMap params) throws Exception {

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        //先删除子表在删除父表

        dao.executeDelete( "ipu.CallRescuerDao", "deleteCallRescuerXyInfo", params);

        int num = dao.executeDelete("ipu.CallRescuerDao", "deleteCallRescuerInfo", params);

        if(num>0){

            return true;

        }

        return false;

    }

}

package com.ai.ipu.server.dao.impl;

import com.ai.ipu.data.JList;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonList;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.dao.interfaces.DeviceManageDao;

import com.ai.ipu.sql.mgmt.ISqlMgmtDao;

import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.github.pagehelper.PageHelper;

import com.github.pagehelper.PageInfo;

import org.springframework.stereotype.Component;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

@Component

public class DeviceManageDaoImpl implements DeviceManageDao {

    private String connName = "ebc";

    @Override

    public PageInfo queryDeviceInfo(JMap params) throws Exception {

        JMap params1 = params.getJMap("params");

        PageHelper.startPage(params1.getInt("pageNum"),params1.getInt("pageSize"));

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        List<Map<String, Object>> mapTagList= dao.executeSelect("ipu.DeviceManageDao", "queryDeviceInfo", params1);

        List<Map<String, Object>> mapTagXyList= dao.executeSelect("ipu.DeviceManageDao", "queryDeviceXyInfo", params1);

        //将后台拼接成级联属性

        mapTagList.forEach((mapTag)->{

            ArrayList<Object> arrayList = new ArrayList<>();

            mapTagXyList.forEach((mapTagXy)->{

                if(mapTag.get("MAP_TAG_ID")==mapTagXy.get("MAP_TAG_ID")){

                    arrayList.add(mapTagXy);

                    System.out.println(arrayList.toString());

                }

            });

            mapTag.put("EBC_MAP_TAG_XY",arrayList);

        });

        PageInfo pageInfo = new PageInfo(mapTagList);

        return pageInfo;

    }

    @Override

    public int modifyDeviceInfo (JMap params) throws Exception {

        deleteDeviceXyInfo(params);

        //将新数据插入

        int num = addDeviceInfo(params);

        return num;

    }

    @Override

    public int addDeviceInfo(JMap params) throws Exception {

        Object mapTagContent = params.get("MAP_TAG_CONTENT");

        String mapTagContentStr = JSONObject.toJSONString(mapTagContent);

        params.put("MAP_TAG_CONTENT",mapTagContentStr);

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        int num = dao.executeInsert("ipu.DeviceManageDao", "addDeviceInfo", params);

        if(num>0){

            JMap paramsMap=new JsonMap();

            JList paramsList=new JsonList();

            JList paramsJList = params.getJList("EBC_MAP_TAG_XY");

            paramsJList.forEach(s->{

                HashMap hashMap = JSON.parseObject(JSONObject.toJSONString(s), HashMap.class);

                hashMap.put("MAP_TAG_ID",params.getInt("MAP_TAG_ID"));

                paramsList.add(hashMap);

            });

            paramsMap.put("paramsList",paramsList);

            int i = dao.executeInsert("ipu.DeviceManageDao", "addDevicexyInfo", paramsMap);

        }

        return num;

    }

    @Override

    public boolean deleteDeviceXyInfo(JMap params) throws Exception {

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        //先删除子表在删除父表

        dao.executeDelete( "ipu.DeviceManageDao", "deleteDeviceXyInfo", params);

        int num = dao.executeDelete("ipu.DeviceManageDao", "deleteDeviceInfo", params);

        if(num>0){

            return true;

        }

        return false;

    }

}

package com.ai.ipu.server.dao.impl;

import com.ai.ipu.data.JList;

import com.ai.ipu.data.JMap;

import com.ai.ipu.data.impl.JsonList;

import com.ai.ipu.data.impl.JsonMap;

import com.ai.ipu.server.dao.interfaces.EquipmentManageDao;

import com.ai.ipu.sql.mgmt.ISqlMgmtDao;

import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.github.pagehelper.PageHelper;

import com.github.pagehelper.PageInfo;

import org.springframework.stereotype.Component;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

@Component

public class EquipmentManageDaoImpl implements EquipmentManageDao {

    private String connName = "ebc";

    @Override

    public PageInfo queryEquipmentInfo(JMap params) throws Exception {

        JMap params1 = params.getJMap("params");

        PageHelper.startPage(params1.getInt("pageNum"),params1.getInt("pageSize"));

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        List<Map<String, Object>> mapTagList= dao.executeSelect("ipu.EquipmentManageDao", "queryEquipmentInfo", params1);

        List<Map<String, Object>> mapTagXyList= dao.executeSelect("ipu.EquipmentManageDao", "queryEquipmentXyInfo", params1);

        //将后台拼接成级联属性

        mapTagList.forEach((mapTag)->{

            ArrayList<Object> arrayList = new ArrayList<>();

            mapTagXyList.forEach((mapTagXy)->{

                if(mapTag.get("MAP_TAG_ID")==mapTagXy.get("MAP_TAG_ID")){

                    arrayList.add(mapTagXy);

                    System.out.println(arrayList.toString());

                }

            });

            mapTag.put("EBC_MAP_TAG_XY",arrayList);

        });

        PageInfo pageInfo = new PageInfo(mapTagList);

        return pageInfo;

    }

    @Override

    public int modifyEquipmentInfo (JMap params) throws Exception {

        deleteEquipmentXyInfo(params);

        //将新数据插入

        int num = addEquipmentInfo(params);

        return num;

    }

    @Override

    public int addEquipmentInfo(JMap params) throws Exception {

        Object mapTagContent = params.get("MAP_TAG_CONTENT");

        String mapTagContentStr = JSONObject.toJSONString(mapTagContent);

        params.put("MAP_TAG_CONTENT",mapTagContentStr);

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        int num = dao.executeInsert("ipu.EquipmentManageDao", "addEquipmentInfo", params);

        if(num>0){

            JMap paramsMap=new JsonMap();

            JList paramsList=new JsonList();

            JList paramsJList = params.getJList("EBC_MAP_TAG_XY");

            paramsJList.forEach(s->{

                HashMap hashMap = JSON.parseObject(JSONObject.toJSONString(s), HashMap.class);

                hashMap.put("MAP_TAG_ID",params.getInt("MAP_TAG_ID"));

                paramsList.add(hashMap);

            });

            paramsMap.put("paramsList",paramsList);

            int i = dao.executeInsert("ipu.EquipmentManageDao", "addEquipmentxyInfo", paramsMap);

        }

        return num;

    }

    @Override

    public boolean deleteEquipmentXyInfo(JMap params) throws Exception {

        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);

        //先删除子表在删除父表

        dao.executeDelete( "ipu.EquipmentManageDao", "deleteEquipmentXyInfo", params);

        int num = dao.executeDelete("ipu.EquipmentManageDao", "deleteEquipmentInfo", params);

        if(num>0){

            return true;

        }

        return false;

    }

}

import java.util.ArrayList;

        List<Map<String, Object>> mapTagXyList= dao.executeSelect("ipu.MapTagManageDao", "queryMapTagXyInfo", params1);

        //将后台拼接成级联属性

        mapTagList.forEach((mapTag)->{

            ArrayList<Object> arrayList = new ArrayList<>();

            mapTagXyList.forEach((mapTagXy)->{

                if(mapTag.get("MAP_TAG_ID")==mapTagXy.get("MAP_TAG_ID")){

                    arrayList.add(mapTagXy);

                    System.out.println(arrayList.toString());

                }

            });

            mapTag.put("EBC_MAP_TAG_XY",arrayList);

        });

        deleteMapTagXyInfo(params);

        //将新数据插入

        int num = addMapTagInfo(params);