南昌市物联网技防平台-后台
tangzy
2021-03-26 afda08833e460a40a2d4e509f9df9d809c6f8f31
Merge remote-tracking branch 'origin/master'
20 files modified
224 ■■■■ changed files
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/mapper/AlarmMapper.xml 1 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/animalheat/mapper/AnimalHeatMapper.xml 1 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java 57 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/entity/Equipment.java 3 ●●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/mapper/EquipmentMapper.java 2 ●●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/mapper/EquipmentMapper.xml 68 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/service/IEquipmentService.java 4 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/service/impl/EquipmentServiceImpl.java 16 ●●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/vo/EquipmentVO.java 1 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/healthcode/mapper/healthcodeMapper.xml 1 ●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/controller/DeptController.java 13 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/mapper/DeptMapper.java 8 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/mapper/DeptMapper.xml 5 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/service/IDeptService.java 9 ●●●●● patch | view | raw | blame | history
blade-service/blade-system/src/main/java/org/springblade/system/service/impl/DeptServiceImpl.java 5 ●●●●● patch | view | raw | blame | history
blade-service/blade-user/src/main/java/org/springblade/system/user/controller/UserController.java 2 ●●● patch | view | raw | blame | history
blade-service/blade-user/src/main/java/org/springblade/system/user/mapper/UserMapper.java 4 ●●●● patch | view | raw | blame | history
blade-service/blade-user/src/main/java/org/springblade/system/user/mapper/UserMapper.xml 16 ●●●●● patch | view | raw | blame | history
blade-service/blade-user/src/main/java/org/springblade/system/user/service/IUserService.java 4 ●●●● patch | view | raw | blame | history
blade-service/blade-user/src/main/java/org/springblade/system/user/service/impl/UserServiceImpl.java 4 ●●●● patch | view | raw | blame | history
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/alarm/mapper/AlarmMapper.xml
@@ -328,6 +328,7 @@
        ) b
         on
         a.click_date = b.datetime
         order by a.click_date asc
    </select>
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/animalheat/mapper/AnimalHeatMapper.xml
@@ -116,5 +116,6 @@
        ) b
         on
         a.click_date = b.datetime
         order by a.click_date asc
    </select>
</mapper>
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/controller/EquipmentController.java
@@ -35,6 +35,7 @@
import org.springblade.jfpt.equipment.vo.EquipmentVO;
import org.springblade.jfpt.equipment.vo.EquipmentVOS;
import org.springblade.jfpt.equipment.wrapper.EqWrapper;
import org.springblade.system.user.entity.User;
import org.springframework.web.bind.annotation.*;
import springfox.documentation.annotations.ApiIgnore;
@@ -182,6 +183,44 @@
    }
    /**
     * 自定义分页(部门挂接)
     */
    @GetMapping("/pageDept")
    @ApiOperationSupport(order = 3)
    @ApiOperation(value = "分页", notes = "传入equipment")
    public R<IPage<EquipmentVO>> pageDept(EquipmentVO equipment, Query query, String pid, HttpServletResponse response) throws ParseException {
        response.setHeader("Access-Control-Allow-Origin", "*");
        response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");
        response.setHeader("Access-Control-Allow-Credentials", "true");
        IPage<EquipmentVO> page = equipmentService.selectDeptPages(Condition.getPage(query), equipment, pid);
        for (int j = 0; j < page.getRecords().size(); j++) {
            String expireTime = page.getRecords().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类型的
            if (expireTime != null){
                long st = sim.parse(expireTime).getTime();
                long en = sim.parse(end).getTime();
                //计算天数
                int day = (int) ((st - en) / 86400000);
                if (day <= 30) {
                    page.getRecords().get(j).setType(1);
                } else {
                    page.getRecords().get(j).setType(0);
                }
            }
        }
        return R.data(page);
    }
    //子节点
    private static List childMenu = new ArrayList();
@@ -274,16 +313,16 @@
            equipment.setHeartbeat(null);
        }
        String deviceName = equipment.getDeviceName();
        String deviceNumber = equipment.getDeviceNumber();
        String pId = equipment.getPid();
        if (equipment.getId() == null){
            catalogService.addCatalog(deviceName,deviceNumber,pId);
        }else{
            catalogService.updateCatalog(deviceName,deviceNumber,pId);
        }
//        String deviceName = equipment.getDeviceName();
//        String deviceNumber = equipment.getDeviceNumber();
//        String pId = equipment.getPid();
//        if (equipment.getId() == null){
//            catalogService.addCatalog(deviceName,deviceNumber,pId);
//        }else{
//            catalogService.updateCatalog(deviceName,deviceNumber,pId);
//        }
        System.out.println(equipment.getDeptId());
        return R.status(equipmentService.saveOrUpdate(equipment));
    }
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/entity/Equipment.java
@@ -115,5 +115,8 @@
    private String state;
    private String reason;
    @TableField("deptId")
    private String deptId;
}
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/mapper/EquipmentMapper.java
@@ -36,6 +36,8 @@
    List<EquipmentVO> selectEquipmentPage(IPage page, EquipmentVO equipment,List childList);
    List<EquipmentVO> selectDeptPages(IPage page, EquipmentVO equipment,List childList);
    void s(Equipment equipment);
    void updateOne(Equipment equipment);
    void updataType(String arr);
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/mapper/EquipmentMapper.xml
@@ -117,6 +117,62 @@
    </select>
    <select id="selectDeptPages" resultMap="equipmentResultMap">
        select equipment.id,equipment.deviceName,equipment.deviceNumber,equipment.deviceType,equipment.ownership
        ,equipment.ownerId,equipment.devicestate,equipment.stime,equipment.dtype,equipment.heartbeat,equipment.expireTime,
        equipment.parent_id,equipment.district,equipment.province,equipment.city,equipment.serialNumber,equipment.channelNumber,
        equipment.jd ,
        equipment.wd ,
        equipment.state,equipment.reason,
        equipment.street,catalog.pid,
        equipment.oneContacts,equipment.onePhone,equipment.oneId,
        equipment.twoContacts,equipment.twoPhone,equipment.twoId,
        equipment.ThreeContacts,equipment.ThreePhone,equipment.threeId,
        equipment.deptId,
        equipment.addvcd,equipment.pay,equipment.expireTime from sys_equipment equipment
        left join sys_catalog catalog on catalog.eqid = equipment.deviceNumber
        where 1=1
        <if test="equipment.deviceName!=null">
            and (deviceName like concat('%',#{equipment.deviceName},'%') or deviceNumber like
            concat('%',#{equipment.deviceName},'%'))
        </if>
        <if test="equipment.beginTime!=null and equipment.beginTime!=''">
            and expireTime&gt;=#{equipment.beginTime}
        </if>
        <if test="equipment.endTime!=null and equipment.endTime!=''">
            and expireTime&lt;=#{equipment.endTime}
        </if>
        <if test="equipment.district!=null">
            and district like concat('%',#{equipment.district},'%')
        </if>
        <if test="equipment.province!=null">
            and province like concat('%',#{equipment.province},'%')
        </if>
        <if test="equipment.city!=null">
            and city like concat('%',#{equipment.city},'%')
        </if>
        <if test="equipment.devicestate!=null">
            and devicestate =#{equipment.devicestate}
        </if>
        <if test="equipment.dtype!=null">
            and dtype=#{equipment.dtype}
        </if>
        <if test="childList!=null and childList.size>0">
            and deptId in
            <foreach collection="childList" index="index" item="item" open="(" separator="," close=")">
                #{item}
            </foreach>
        </if>
    </select>
    <!--新增-->
    <insert id="s" parameterType="org.springblade.jfpt.equipment.entity.Equipment">
       INSERT INTO sys_equipment (deviceName,deviceNumber,deviceType,ownership,ownerId,devicestate,stime,coordinate,parent_id,jd,wd,addvcd,street,dtype) VALUES (#{deviceName},#{deviceNumber},#{deviceType},#{ownership},#{yname},#{devicestate},#{stime},POINT(#{jd},#{wd}),#{parentId},#{jd},#{wd},#{addvcd},#{streeName},#{dtype})
@@ -188,20 +244,16 @@
        update sys_equipment SET devicestate = 0 where id in (${arr})
    </update>
    <update id="updateOnes" parameterType="org.springblade.jfpt.equipment.entity.Equipment">
    update sys_equipment SET deviceName=#{deviceName},deviceNumber=#{deviceNumber},deviceType=#{deviceType},
    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>
    <select id="selectInfo" resultMap="deptVOResultMap"
            parameterType="org.springblade.jfpt.equipment.entity.Equipment">
        SELECT
        dept.id,dept.deviceName,dept.deviceNumber,dept.deviceType,dept.ownership,
        dept.deptId,dept.id,dept.deviceName,dept.deviceNumber,dept.deviceType,dept.ownership,
        dept.ownerId,dept.devicestate,dept.stime,dept.district,dept.province,dept.city,
        ST_ASTEXT(dept.coordinate) as coordinate,dept.dtype,dept.expireTime,dept.heartbeat, dept.state,dept.reason,
        dept.parent_id,dept.jd,dept.wd,dept.street,u.yname,d.addvnm,dept.addvcd,dept.serialNumber,dept.channelNumber,
        dept.oneContacts,dept.onePhone,dept.oneId,
        dept.twoContacts,dept.twoPhone,dept.twoId,
        dept.ThreeContacts,dept.ThreePhone,dept.threeId,
        (
        SELECT
        CASE WHEN count(1) > 0 THEN 1 ELSE 0 END
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/service/IEquipmentService.java
@@ -36,6 +36,10 @@
    IPage<EquipmentVO> selectEquipmentPage(IPage<EquipmentVO> page, EquipmentVO equipment,List childList);
    IPage<EquipmentVO> selectPage(IPage<EquipmentVO> page, EquipmentVO equipment,String pid);
    IPage<EquipmentVO> selectDeptPages(IPage<EquipmentVO> page, EquipmentVO equipment,String pid);
    /**
     * 树形结构
     *
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/service/impl/EquipmentServiceImpl.java
@@ -27,6 +27,7 @@
import org.springblade.jfpt.equipment.service.IEquipmentService;
import org.springblade.jfpt.equipment.vo.EquipmentVO;
import org.springblade.jfpt.equipment.vo.EquipmentVOS;
import org.springblade.system.cache.SysCache;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
@@ -60,6 +61,21 @@
        return page.setRecords(baseMapper.selectEquipmentPage(page,equipment,null));
    }
    @Override
    public IPage<EquipmentVO> selectDeptPages(IPage<EquipmentVO> page, EquipmentVO equipment,String pid) {
        List deptIdList;
        if (!pid.equals("")){
            deptIdList = SysCache.getDeptChildIds(Long.valueOf(pid));
        }else{
            deptIdList = SysCache.getDeptChildIds(null);
        }
        return page.setRecords(baseMapper.selectDeptPages(page,equipment,deptIdList));
    }
    @Override
    public List<EquipmentVOS> tree() {
        return ForestNodeMerger.merge(baseMapper.tree());
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/equipment/vo/EquipmentVO.java
@@ -48,6 +48,5 @@
    private String oneId;
    private String twoId;
    private String threeId;
    private String deptId;
}
blade-service/blade-jfpts/src/main/java/org/springblade/jfpt/healthcode/mapper/healthcodeMapper.xml
@@ -118,6 +118,7 @@
        ) b
         on
         a.click_date = b.datetime
         order by a.click_date asc
    </select>
blade-service/blade-system/src/main/java/org/springblade/system/controller/DeptController.java
@@ -118,6 +118,19 @@
    }
    /**
     * 获取部门树形结构
     *
     * @return
     */
    @GetMapping("/trees")
    @ApiOperationSupport(order = 4)
    @ApiOperation(value = "树形结构", notes = "树形结构")
    public R<List<DeptVO>> trees(String tenantId, BladeUser bladeUser) {
        List<DeptVO> tree = deptService.trees();
        return R.data(tree);
    }
    /**
     * 懒加载获取部门树形结构
     */
    @GetMapping("/lazy-tree")
blade-service/blade-system/src/main/java/org/springblade/system/mapper/DeptMapper.java
@@ -49,6 +49,14 @@
    List<DeptVO> tree(String tenantId);
    /**
     * 获取树形节点
     *
     * @param
     * @return
     */
    List<DeptVO> trees();
    /**
     * 懒加载获取树形节点
     *
     * @param tenantId
blade-service/blade-system/src/main/java/org/springblade/system/mapper/DeptMapper.xml
@@ -74,6 +74,11 @@
        ORDER BY sort
    </select>
    <select id="trees" resultMap="treeNodeResultMap">
        select id, parent_id, dept_name as title, id as "value", id as "key" from blade_dept where is_deleted = 0
        ORDER BY sort
    </select>
    <select id="lazyTree" resultMap="treeNodeResultMap" >
        SELECT
            dept.id,
blade-service/blade-system/src/main/java/org/springblade/system/service/IDeptService.java
@@ -49,6 +49,15 @@
    List<DeptVO> tree(String tenantId);
    /**
     * 树形结构
     *
     * @param
     * @return
     */
    List<DeptVO> trees();
    /**
     * 懒加载树形结构
     *
     * @param tenantId
blade-service/blade-system/src/main/java/org/springblade/system/service/impl/DeptServiceImpl.java
@@ -82,6 +82,11 @@
    }
    @Override
    public List<DeptVO> trees() {
        return ForestNodeMerger.merge(baseMapper.trees());
    }
    @Override
    public List<DeptVO> lazyTree(String tenantId, Long parentId) {
        if (AuthUtil.isAdministrator()) {
            tenantId = StringPool.EMPTY;
blade-service/blade-user/src/main/java/org/springblade/system/user/controller/UserController.java
@@ -138,7 +138,7 @@
    @ApiOperation(value = "列表", notes = "传入account和realName")
    //@PreAuth(RoleConstant.HAS_ROLE_ADMIN)
    public R<IPage<UserVO>> pages(@ApiIgnore User user, Query query, Long deptId, BladeUser bladeUser) {
        IPage<User> pages = userService.selectUserPages(Condition.getPage(query), user, deptId, (bladeUser.getTenantId().equals(BladeConstant.ADMIN_TENANT_ID) ? StringPool.EMPTY : bladeUser.getTenantId()));
        IPage<User> pages = userService.selectUserPages(Condition.getPage(query), user, deptId);
        return R.data(UserWrapper.build().pageVO(pages));
    }
blade-service/blade-user/src/main/java/org/springblade/system/user/mapper/UserMapper.java
@@ -49,10 +49,10 @@
     * @param page
     * @param user
     * @param deptIdList
     * @param tenantId
     * @param
     * @return
     */
    List<User> selectUserPages(IPage<User> page, @Param("user") User user, @Param("deptIdList") List<Long> deptIdList, @Param("tenantId") String tenantId);
    List<User> selectUserPages(IPage<User> page, @Param("user") User user, @Param("deptIdList") List<Long> deptIdList);
    /**
     * 获取用户
blade-service/blade-user/src/main/java/org/springblade/system/user/mapper/UserMapper.xml
@@ -96,24 +96,18 @@
        LEFT JOIN jfpt.sys_position p ON p.snumber = s.CODE
        LEFT JOIN jfpt.sys_enclosure e ON e.anumber = s.CODE
        where is_deleted = 0
        <if test="tenantId!=null and tenantId != ''">
            and tenant_id = #{tenantId}
        </if>
        <if test="user.tenantId!=null and user.tenantId != ''">
            and tenant_id = #{user.tenantId}
        </if>
        where s.is_deleted = 0
        <if test="user.account!=null and user.account != ''">
            and account = #{user.account}
            and s.account = #{user.account}
        </if>
        <if test="user.realName!=null and user.realName != ''">
            and real_name = #{user.realName}
            and s.real_name = #{user.realName}
        </if>
        <if test="user.userType!=null and user.userType != ''">
            and user_type = #{user.userType}
            and s.user_type = #{user.userType}
        </if>
        <if test="deptIdList!=null and deptIdList.size>0">
            and id in (
            and s.id in (
            SELECT
            user_id
            FROM
blade-service/blade-user/src/main/java/org/springblade/system/user/service/IUserService.java
@@ -77,10 +77,10 @@
     * @param page
     * @param user
     * @param deptId
     * @param tenantId
     * @param
     * @return
     */
    IPage<User> selectUserPages(IPage<User> page, User user, Long deptId, String tenantId);
    IPage<User> selectUserPages(IPage<User> page, User user, Long deptId);
    /**
     * 用户信息
blade-service/blade-user/src/main/java/org/springblade/system/user/service/impl/UserServiceImpl.java
@@ -147,9 +147,9 @@
    }
    @Override
    public IPage<User> selectUserPages(IPage<User> page, User user, Long deptId, String tenantId) {
    public IPage<User> selectUserPages(IPage<User> page, User user, Long deptId) {
        List<Long> deptIdList = SysCache.getDeptChildIds(deptId);
        return page.setRecords(baseMapper.selectUserPages(page, user, deptIdList, tenantId));
        return page.setRecords(baseMapper.selectUserPages(page, user, deptIdList));
    }
    @Override