2021与蓝度共同重构项目,服务端
zhanzhiqin
2022-08-29 a4cb35efe9e789d575f5605d7ae688426052f96c
固件升级
已添加1个文件
已修改5个文件
127 ■■■■■ 文件已修改
dao/src/main/java/com/sandu/ximon/dao/bo/RemoteUpdateFileBo.java 61 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/java/com/sandu/ximon/dao/domain/RemoteUpdateFile.java 12 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/java/com/sandu/ximon/dao/mapper/RemoteUpdateFileMapper.java 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/resources/mapper/RemoteUpdateFileMapper.xml 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
ximon-admin/src/main/java/com/sandu/ximon/admin/controller/WaterQualityDataController.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
ximon-admin/src/main/java/com/sandu/ximon/admin/service/RemoteUpdateService.java 44 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
dao/src/main/java/com/sandu/ximon/dao/bo/RemoteUpdateFileBo.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,61 @@
package com.sandu.ximon.dao.bo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.sandu.ximon.dao.domain.RemoteUpdateFile;
import lombok.Data;
import java.math.BigDecimal;
import java.time.LocalDateTime;
/**
 * @author ZZQ
 * @date 2022/8/29 17:30
 */
@Data
public class RemoteUpdateFileBo extends RemoteUpdateFile {
    /**
     *
     */
    private Integer id;
    /**
     * ä¸Šä¼ è€…昵称
     */
    private String uploadName;
    /**
     * å‡çº§æ–‡ä»¶å
     */
    private String filename;
    /**
     * è½¯ä»¶ç‰ˆæœ¬
     */
    private BigDecimal softwareVersion;
    /**
     * ç¡¬ä»¶ç‰ˆæœ¬
     */
    private BigDecimal hardwareVersion;
    /**
     * é˜¿é‡Œæ–‡ä»¶å­˜å‚¨åœ°å€
     */
    private String aliAddress;
    /**
     * æ–‡ä»¶ç±»åž‹
     */
    private String fileType;
    /**
     *
     */
    private LocalDateTime createTime;
    /**
     * æ–‡ä»¶é•¿åº¦
     */
    private String fileLength;
}
dao/src/main/java/com/sandu/ximon/dao/domain/RemoteUpdateFile.java
@@ -4,13 +4,14 @@
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDateTime;
import lombok.Data;
/**
 *
 * @TableName remote_update_file
 */
@TableName(value ="remote_update_file")
@@ -21,6 +22,15 @@
     */
    @TableId(type = IdType.AUTO)
    private Integer id;
    /**
     * ä¸Šä¼ è€…ID
     */
    private Long uploadUserId;
    /**
     * ä¸Šä¼ è€…类型,0:管理员;1:普通用户上传
     */
    private Integer uploadUserType;
    /**
     * å‡çº§æ–‡ä»¶å
dao/src/main/java/com/sandu/ximon/dao/mapper/RemoteUpdateFileMapper.java
@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
/**
 * @Entity com.sandu.ximon.dao.domain.RemoteUpdateFile
 */
dao/src/main/resources/mapper/RemoteUpdateFileMapper.xml
@@ -6,6 +6,8 @@
    <resultMap id="BaseResultMap" type="com.sandu.ximon.dao.domain.RemoteUpdateFile">
            <id property="id" column="id" jdbcType="INTEGER"/>
        <result property="uploadUserId" column="upload_user_id" jdbcType="BIGINT"/>
        <result property="uploadUserType" column="upload_user_type" jdbcType="INTEGER"/>
            <result property="filename" column="filename" jdbcType="VARCHAR"/>
            <result property="softwareVersion" column="software_version" jdbcType="DECIMAL"/>
            <result property="hardwareVersion" column="hardware_version" jdbcType="DECIMAL"/>
@@ -15,9 +17,4 @@
            <result property="fileLength" column="file_length" jdbcType="VARCHAR"/>
    </resultMap>
    <sql id="Base_Column_List">
        id,filename,software_version,
        hardware_version,ali_address,file_type,
        create_time,file_length
    </sql>
</mapper>
ximon-admin/src/main/java/com/sandu/ximon/admin/controller/WaterQualityDataController.java
@@ -26,7 +26,7 @@
    /**
     * æ°´è´¨æ•°æ®æŸ¥è¯¢
     *
     * @return
     * @returnlistWaterQualityData
     */
    @GetMapping("/listWaterQualityData")
    public ResponseVO<Object> listWaterQualityDataByKeyword(BaseConditionVO baseConditionVO, @RequestParam(value = "keyword", required = false) String keyword) {
ximon-admin/src/main/java/com/sandu/ximon/admin/service/RemoteUpdateService.java
@@ -1,7 +1,10 @@
package com.sandu.ximon.admin.service;
import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.dto.RemoteFileDto;
import com.sandu.ximon.admin.dto.RemoteUpdateTypeDto;
import com.sandu.ximon.admin.manager.iot.frame.A5Frame;
@@ -11,14 +14,19 @@
import com.sandu.ximon.admin.manager.iot.rrpc.enums.RemoteUpdateTypeEnum;
import com.sandu.ximon.admin.manager.iot.rrpc.mainboard.MainBoardInvokeSyncService;
import com.sandu.ximon.admin.manager.iot.rrpc.util.FileProcessingUtils;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
import com.sandu.ximon.admin.utils.StringUtil;
import com.sandu.ximon.dao.bo.RemoteUpdateFileBo;
import com.sandu.ximon.dao.domain.Admin;
import com.sandu.ximon.dao.domain.Client;
import com.sandu.ximon.dao.domain.RemoteUpdateFile;
import com.sandu.ximon.dao.mapper.RemoteUpdateFileMapper;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;
/**
@@ -27,6 +35,8 @@
 */
@Service
public class RemoteUpdateService extends BaseServiceImpl<RemoteUpdateFileMapper, RemoteUpdateFile> {
    private RemoteUpdateFileMapper remoteUpdateFileMapper;
    /**
     * æ·»åŠ æ–‡ä»¶æ›´æ–°å†…å®¹
     *
@@ -41,6 +51,8 @@
        RemoteUpdateFile remoteUpdateFile = new RemoteUpdateFile();
        remoteUpdateFile.setAliAddress(aliAddress);
        remoteUpdateFile.setFileType(fileType);
        remoteUpdateFile.setUploadUserId(SecurityUtils.getUserId());
        remoteUpdateFile.setUploadUserType(SecurityUtils.getClientId() == null ? 0 : 1);
        remoteUpdateFile.setSoftwareVersion(new BigDecimal(softwareVersion).setScale(2, BigDecimal.ROUND_DOWN));
        remoteUpdateFile.setHardwareVersion(new BigDecimal(hardwareVersion).setScale(2, BigDecimal.ROUND_DOWN));
        remoteUpdateFile.setFilename(filename);
@@ -76,8 +88,36 @@
     *
     * @return
     */
    public List<RemoteUpdateFile> getRemoteFileList() {
        return list();
    public List<RemoteUpdateFileBo> getRemoteFileList() {
        List<RemoteUpdateFile> list = list();
        List<Admin> adminList = SpringContextHolder.getBean(AdminService.class).list();
        List<Client> clientList = SpringContextHolder.getBean(ClientService.class).list();
        List<RemoteUpdateFileBo> remoteUpdateFileBoList = new ArrayList<>();
        RemoteUpdateFileBo remoteUpdateFileBo;
        for (RemoteUpdateFile bean : list) {
            remoteUpdateFileBo = new RemoteUpdateFileBo();
            BeanUtil.copyProperties(bean, remoteUpdateFileBo);
            if (bean.getUploadUserType() == 0) {
                for (Admin admin : adminList) {
                    if (bean.getUploadUserId().equals(admin.getId())) {
                        remoteUpdateFileBo.setUploadName(admin.getNickName());
                    }
                }
            } else if (bean.getUploadUserType() == 1) {
                for (Client client : clientList) {
                    if (bean.getUploadUserId().equals(client.getId())) {
                        remoteUpdateFileBo.setUploadName(client.getClientName());
                    }
                }
            } else {
                remoteUpdateFileBo.setUploadName("未知用户!");
            }
            remoteUpdateFileBoList.add(remoteUpdateFileBo);
        }
        return remoteUpdateFileBoList;
    }