1.修改导出数据

2.设备信息导出下载后删除
3.设备信息页面增加更新数据

cneeds-common-data/db/cneeds_server.sql

@@ -369,4 +369,11 @@ CREATE TABLE `device_info_export` (
   `status` int(10) DEFAULT NULL COMMENT '状态：0未完成，1完成',
   `update_time` datetime DEFAULT NULL COMMENT '更新时间',
   PRIMARY KEY (`device_info_export_id`)
-) ENGINE=InnoDB DEFAULT CHARSET=utf8;
\ No newline at end of file
+) ENGINE=InnoDB DEFAULT CHARSET=utf8;
+
+
+-- 2020-07-31
+ALTER TABLE `cneeds_server`.`device_info_export`
+ADD UNIQUE INDEX `Name_Unique`(`name`) USING HASH;
+ALTER TABLE `cneeds_server`.`device_info`
+ADD COLUMN `update_time` datetime(0) COMMENT '更新时间状态' AFTER `ca_certificate_status`;
\ No newline at end of file

cneeds-common-data/src/main/java/com/mx/cneeds/server/entity/DeviceInfoEntity.java

@@ -62,6 +62,11 @@ public class DeviceInfoEntity implements Serializable {
 	private Date createTime;
 
 	/**
+	 * 修改时间
+	 */
+	private Date updateTime;
+
+	/**
 	 * 激活时间
 	 */
 	private Date activeTime;

cneeds-common-data/src/main/resources/mapper/DeviceInfoDao.xml

@@ -13,6 +13,7 @@
         <result property="deviceVersion" column="device_version"/>
         <result property="seriesId" column="series_id"/>
         <result property="createTime" column="create_time"/>
+        <result property="updateTime" column="update_time"/>
         <result property="activeTime" column="active_time"/>
         <result property="channelNumsMessage" column="channel_nums_message"/>
         <result property="channelRules" column="channel_rules"/>

cneeds-common-pojo/src/main/java/com/mx/cneeds/common/dto/DeviceInfoDto.java

@@ -55,6 +55,11 @@ public class DeviceInfoDto {
     private Date createTime;
 
     /**
+     * 修改时间
+     */
+    private Date updateTime;
+
+    /**
      * 激活时间
      */
     private Date activeTime;

cneeds-common-pojo/src/main/java/com/mx/cneeds/common/vo/DeviceInfoVo.java

@@ -56,6 +56,11 @@ public class DeviceInfoVo {
     private Date createTime;
 
     /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
      * 激活时间
      */
     private String activeTime;

cneeds-server-authorization/src/main/resources/application.yml

 spring:
   profiles:
-    active: prod
+    active: dev
   application:
     name: cneeds-server-authorization
 server:

cneeds-server-datashow/src/main/java/com/mx/cneeds/server/datashow/client/DeviceClient.java

@@ -134,5 +134,10 @@ public interface DeviceClient {
     @PostMapping("device/info/addDeviceInfoExport")
     void addDeviceInfoExport(@RequestBody DeviceInfoExportDto deviceInfoExportDto);
 
+    @PostMapping("device/info/deleteDeviceInfoExport")
+    void deleteDeviceInfoExport(@RequestBody Long deviceInfoExportId);
+
+    @PostMapping("device/info/deleteDeviceInfoExportByName")
+    void deleteDeviceInfoExportByName(@RequestBody String fileName);
 
 }

cneeds-server-datashow/src/main/java/com/mx/cneeds/server/datashow/web/device/DeviceController.java

@@ -426,7 +426,9 @@ public class DeviceController {
     @RequestMapping("/device/uploadNewDeviceInfo")
     public R uploadNewDeviceInfo(DeviceInfoVo vo){
         if (vo.getImei() == null || vo.getImei().isEmpty()){
-            return  R.error(ResultCode.PARAMERROR,"没有传入imei");
+            String message = "没有传入imei";
+            log.info(message);
+            return  R.error(ResultCode.PARAMERROR,message);
         }
 
         DeviceInfoDto dto = new DeviceInfoDto();
@@ -447,9 +449,12 @@ public class DeviceController {
         DeviceInfoDto deviceInfoDto = deviceClient.queryDeviceByImei(vo.getImei());
 
         if (deviceInfoDto == null){
+            String message = "系统没有该设备imei: " + vo.getImei();
+            log.info(message);
             return R.error(ResultCode.NOTFOUND_IMEI,"系统没有该设备");
         }
 
+        dto.setUpdateTime(new Date());
         // 再进行设置
         deviceClient.updateDevice(dto);
         return R.ok();

cneeds-server-datashow/src/main/java/com/mx/cneeds/server/datashow/web/device/DeviceFileController.java

 package com.mx.cneeds.server.datashow.web.device;
 
 import com.mx.cneeds.common.constant.FilePath;
+import com.mx.cneeds.server.datashow.client.DeviceClient;
 import com.mx.hbasefile.hadoop.hdfs.api.HdfsTemplate;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -25,6 +26,9 @@ import java.io.InputStream;
 public class DeviceFileController {
 
     @Autowired
+    private DeviceClient deviceClient;
+
+    @Autowired
     private HdfsTemplate hdfsTemplate;
 
     @RequestMapping("/deviceFileDownload/{fileSize}/{fileName}")
@@ -49,5 +53,7 @@ public class DeviceFileController {
             total-=1024;
         }
         outputStream.close();
+        hdfsTemplate.deleteFile(dirPath.toString(), fileName);
+        deviceClient.deleteDeviceInfoExportByName(fileName);
     }
 }

cneeds-server-device/src/main/java/com/mx/cneeds/server/device/web/DeviceInfoController.java

@@ -454,6 +454,13 @@ public class DeviceInfoController {
         deviceInfoExportService.removeById(deviceInfoExportId);
     }
 
+    @RequestMapping("/deleteDeviceInfoExportByName")
+    public void deleteDeviceInfoExportByName(@RequestBody String fileName){
+        Map<String,Object> map = new HashMap<>();
+        map.put("name",fileName);
+        deviceInfoExportService.removeByMap(map);
+    }
+
     @RequestMapping("updateDeviceInfoExport")
     public void updateDeviceInfoExport(@RequestBody DeviceInfoExportDto deviceInfoExportDto){
         DeviceInfoExportEntity entity = new DeviceInfoExportEntity();

cneeds-server-logupload/src/main/resources/application.yml

 spring:
   profiles:
-    active: prod
+    active: dev
   application:
     name: cneeds-server-logupload
 

cneeds-server-user/src/main/resources/application.yml

 spring:
   profiles:
-    active: prod
+    active: dev
   application:
     name: cneeds-server-user