zengh
2021-01-13 b5bc0b851586c8ac4c74602a173fa5c141ef1353
客户列表接口修改
6 files modified
83 ■■■■ changed files
src/main/java/org/springblade/modules/Netty/controller/nettyController.java 23 ●●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/equipment/controller/EquipmentController.java 36 ●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/equipment/mapper/EquipmentMapper.java 2 ●●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/equipment/mapper/EquipmentMapper.xml 8 ●●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/equipment/service/IEquipmentService.java 4 ●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/equipment/service/impl/EquipmentServiceImpl.java 10 ●●●●● patch | view | raw | blame | history
src/main/java/org/springblade/modules/Netty/controller/nettyController.java
@@ -159,21 +159,33 @@
        int zT = 0;
        String arr = "";
        //将得到的设备与查询所得设备进行匹配
        for (int i = 0; i < childList.size(); i++) {
            for (int j = 0; j < pages.size(); j++) {
                if (childList.get(i).get("eqid") != null) {
                    if (childList.get(i).get("eqid").equals(pages.get(j).getDeviceNumber())) {
                        zT = 1;
                        arr += pages.get(j).getId() + ",";
                        List<String> outData = new ArrayList<>();
                        outData.add("LC8109085B#@");
                        Channel channel = channelHashMap.get(pages.get(j).getDeviceNumber());
                        channel.writeAndFlush(Unpooled.copiedBuffer(outData.get(0), CharsetUtil.UTF_8));
                        break;
                    }
                }
            }
        }
        if (!arr.equals("")){
            String substring = arr.substring(0, arr.length() - 1);
            equipmentService.updataType(substring);
        }
        if (zT == 0) {
            return R.success("暂无设备撤");
            return R.success("暂无设备布防");
        }
        return R.success("设备布防");
    }
@@ -201,11 +213,15 @@
        int zT = 0;
        String arr = "";
        //将得到的设备与查询所得设备进行匹配
        for (int i = 0; i < childList.size(); i++) {
            for (int j = 0; j < pages.size(); j++) {
                if (childList.get(i).get("eqid") != null) {
                    if (childList.get(i).get("eqid").equals(pages.get(j).getDeviceNumber())) {
                        zT = 1;
                        arr += pages.get(j).getId() + ",";
                        List<String> outData = new ArrayList<>();
                        outData.add("LC8109085C#@");
                        Channel channel = channelHashMap.get(pages.get(j).getDeviceNumber());
@@ -215,6 +231,11 @@
            }
        }
        if (!arr.equals("")){
            String substring = arr.substring(0, arr.length() - 1);
            equipmentService.updataTypeC(substring);
        }
        if (zT == 0) {
            return R.success("暂无设备布防");
        }
src/main/java/org/springblade/modules/equipment/controller/EquipmentController.java
@@ -108,16 +108,8 @@
        List<EquipmentVO> datas = new ArrayList<>();
        if (pid == null) {
            datas = pages;
        } else {
            List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber(pid);
            //根据传入的id递归出该节点下所有的设备
            List<Map<String, Object>> childList = treeMenuList(treedatas, Integer.parseInt(pid));
            //将得到的设备与查询所得设备进行匹配
            for (int i = 0; i < childList.size(); i++) {
        if (pid == null || pid.equals("")) {
                for (int j = 0; j < pages.size(); j++) {
                    String expireTime = pages.get(j).getExpireTime();
                    //1.获取当前时间
                    Date dd = new Date();
@@ -130,6 +122,32 @@
                    int day = (int) ((st - en) / 86400000);
                    if (day <= 30) {
                        pages.get(j).setType(1);
                } else {
                    pages.get(j).setType(0);
                }
            }
            datas = pages;
        } else {
            List<Map<String, Object>> treedatas = catalogService.selectCatalogEqNUmber(pid);
            //根据传入的id递归出该节点下所有的设备
            List<Map<String, Object>> childList = treeMenuList(treedatas, Integer.parseInt(pid));
            //将得到的设备与查询所得设备进行匹配
            for (int i = 0; i < childList.size(); i++) {
                for (int j = 0; j < pages.size(); j++) {
                    String expireTime = pages.get(j).getExpireTime();
                    //1.获取当前时间
                    Date dd = new Date();
                    SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    String end = sim.format(dd);
                    //把string类型转换为long类型的
                    long st = sim.parse(expireTime).getTime();
                    long en = sim.parse(end).getTime();
                    //计算天数
                    int day = (int) ((st - en) / 86400000);
                    if (day <= 30) {
                        pages.get(j).setType(1);
                    } else {
                        pages.get(j).setType(0);
                    }
                    if (childList.get(i).get("eqid") != null) {
src/main/java/org/springblade/modules/equipment/mapper/EquipmentMapper.java
@@ -38,6 +38,8 @@
    void s(Equipment equipment);
    void updateOne(Equipment equipment);
    void updataType(String arr);
    void updataTypeC(String arr);
    /**
     * 树形结构
     *
src/main/java/org/springblade/modules/equipment/mapper/EquipmentMapper.xml
@@ -135,6 +135,14 @@
    ownership=#{ownership},ownerId=#{yname},devicestate=#{devicestate},stime=#{stime},
    coordinate=POINT(#{jd},#{wd}),parent_id=#{parentId},jd=#{jd},wd=#{wd},addvcd=#{addvnm},street=#{streeName},dtype=#{dtype} where id=#{id}
</update>
    <update id="updataType">
        update sys_equipment SET devicestate = 1 where id in (#{arr})
    </update>
    <update id="updataTypeC">
        update sys_equipment SET devicestate = 0 where id in (#{arr})
    </update>
    <update id="updateOnes" parameterType="org.springblade.modules.equipment.entity.Equipment">
    update sys_equipment SET deviceName=#{deviceName},deviceNumber=#{deviceNumber},deviceType=#{deviceType},
src/main/java/org/springblade/modules/equipment/service/IEquipmentService.java
@@ -47,6 +47,10 @@
    void s(Equipment equipment);
    void updataType(String arr);
    void updataTypeC(String arr);
    /**
     * 懒加载
     *
src/main/java/org/springblade/modules/equipment/service/impl/EquipmentServiceImpl.java
@@ -69,6 +69,16 @@
    }
    @Override
    public void updataType(String arr) {
        baseMapper.updataType(arr);
    }
    @Override
    public void updataTypeC(String arr) {
        baseMapper.updataTypeC(arr);
    }
    @Override
    public List<EquipmentVOS> lazyList(Long parentId, Map<String, Object> param) {
        // 判断点击搜索但是没有查询条件的情况
        if (Func.isEmpty(param.get(PARENT_ID)) && param.size() == 1) {