删除冗余文件

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/api/DataTransferControllerApi.java

@@ -1,28 +1,13 @@
 package com.usky.transfer.controller.api;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.usky.common.core.bean.ApiResult;
-import com.usky.common.core.exception.BusinessException;
-import com.usky.common.core.util.BeanMapperUtils;
-import com.usky.common.core.util.FileUtils;
-import com.usky.common.core.util.GlobalUtils;
 import com.usky.transfer.RemoteTransferService;
 import com.usky.transfer.domain.*;
 import com.usky.transfer.service.QueryInfluxdbDataService;
-import com.usky.transfer.service.SysUserService;
-import com.usky.system.RemoteUserService;
-import com.usky.system.domain.SysUserVO;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
 
-import java.io.File;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.List;
 import java.util.Map;
-import java.util.Optional;
 
 @RestController
 public class DataTransferControllerApi implements RemoteTransferService {

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/web/DmpDeviceCommandController.java

@@ -1,21 +0,0 @@
-package com.usky.transfer.controller.web;
-
-
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.stereotype.Controller;
-
-/**
- * <p>
- * 创建下发命令历史记录表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2024-09-24
- */
-@Controller
-@RequestMapping("/dmpDeviceCommand")
-public class DmpDeviceCommandController {
-
-}
-

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/web/DmpDeviceController.java

@@ -1,21 +0,0 @@
-package com.usky.transfer.controller.web;
-
-
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.stereotype.Controller;
-
-/**
- * <p>
- * 设备信息表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2024-09-19
- */
-@Controller
-@RequestMapping("/dmpDevice")
-public class DmpDeviceController {
-
-}
-

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/web/DmpDeviceStatusController.java

@@ -1,21 +0,0 @@
-package com.usky.transfer.controller.web;
-
-
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.stereotype.Controller;
-
-/**
- * <p>
- * 设备状态表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2024-09-19
- */
-@Controller
-@RequestMapping("/dmpDeviceStatus")
-public class DmpDeviceStatusController {
-
-}
-

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/web/DmpProductController.java

@@ -1,21 +0,0 @@
-package com.usky.transfer.controller.web;
-
-
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.stereotype.Controller;
-
-/**
- * <p>
- * 产品信息表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2024-09-19
- */
-@Controller
-@RequestMapping("/dmpProduct")
-public class DmpProductController {
-
-}
-

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/controller/web/SysUserController.java

@@ -1,36 +0,0 @@
-package com.usky.transfer.controller.web;
-
-
-import com.usky.common.core.bean.ApiResult;
-import com.usky.transfer.domain.SysUser;
-import com.usky.transfer.service.SysUserService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.List;
-
-/**
- * <p>
- * 用户信息表 前端控制器
- * </p>
- *
- * @author ya
- * @since 2022-04-21
- */
-@RestController
-@RequestMapping("/sysUser")
-public class SysUserController {
-
-
-    @Autowired
-    private SysUserService sysUserService;
-
-    @GetMapping("/list")
-    public ApiResult<List<SysUser>> list(){
-        return ApiResult.success(sysUserService.list());
-    }
-}
-

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/domain/SysUser.java

@@ -1,123 +0,0 @@
-package com.usky.transfer.domain;
-
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import java.time.LocalDateTime;
-import java.io.Serializable;
-import lombok.Data;
-import lombok.EqualsAndHashCode;
-import lombok.experimental.Accessors;
-
-/**
- * <p>
- * 用户信息表
- * </p>
- *
- * @author ya
- * @since 2022-04-21
- */
-@Data
-@EqualsAndHashCode(callSuper = false)
-@Accessors(chain = true)
-public class SysUser implements Serializable {
-
-    private static final long serialVersionUID=1L;
-
-    /**
-     * 用户ID
-     */
-    @TableId(value = "user_id", type = IdType.AUTO)
-    private Long userId;
-
-    /**
-     * 部门ID
-     */
-    private Long deptId;
-
-    /**
-     * 用户账号
-     */
-    private String userName;
-
-    /**
-     * 用户昵称
-     */
-    private String nickName;
-
-    /**
-     * 用户类型（00系统用户）
-     */
-    private String userType;
-
-    /**
-     * 用户邮箱
-     */
-    private String email;
-
-    /**
-     * 手机号码
-     */
-    private String phonenumber;
-
-    /**
-     * 用户性别（0男 1女 2未知）
-     */
-    private String sex;
-
-    /**
-     * 头像地址
-     */
-    private String avatar;
-
-    /**
-     * 密码
-     */
-    private String password;
-
-    /**
-     * 帐号状态（0正常 1停用）
-     */
-    private String status;
-
-    /**
-     * 删除标志（0代表存在 2代表删除）
-     */
-    private String delFlag;
-
-    /**
-     * 最后登录IP
-     */
-    private String loginIp;
-
-    /**
-     * 最后登录时间
-     */
-    private LocalDateTime loginDate;
-
-    /**
-     * 创建者
-     */
-    private String createBy;
-
-    /**
-     * 创建时间
-     */
-    private LocalDateTime createTime;
-
-    /**
-     * 更新者
-     */
-    private String updateBy;
-
-    /**
-     * 更新时间
-     */
-    private LocalDateTime updateTime;
-
-    /**
-     * 备注
-     */
-    private String remark;
-
-
-}

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/mapper/SysUserMapper.java

@@ -1,27 +0,0 @@
-package com.usky.transfer.mapper;
-
-import com.usky.common.mybatis.core.CrudMapper;
-import com.usky.transfer.domain.DataRealTime;
-import com.usky.transfer.domain.SysUser;
-import org.apache.ibatis.annotations.Param;
-import org.springframework.stereotype.Repository;
-
-import java.util.List;
-
-/**
- * <p>
- * 用户信息表 Mapper 接口
- * </p>
- *
- * @since 2022-04-21
- */
-@Repository
-public interface SysUserMapper extends CrudMapper<SysUser> {
-    void DeviceRealDataToDB(@Param("list") List<DataRealTime> list);
-
-    void DeviceDataToDB(@Param("list") List<DataRealTime> list,@Param("deviceId") String deviceId);
-
-    Integer existTable(@Param("tableName") String tableName);
-
-    void createTable(@Param("tableName") String tableName);
-}

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/SysUserService.java

@@ -1,17 +0,0 @@
-package com.usky.transfer.service;
-
-import com.usky.common.mybatis.core.CrudService;
-import com.usky.transfer.domain.SysUser;
-
-
-/**
- * <p>
- * 用户信息表 服务类
- * </p>
- *
- * @author ya
- * @since 2022-04-21
- */
-public interface SysUserService extends CrudService<SysUser> {
-
-}

data-transfer/data-transfer-biz/src/main/java/com/usky/transfer/service/impl/SysUserServiceImpl.java

@@ -1,18 +0,0 @@
-package com.usky.transfer.service.impl;
-
-import com.usky.common.mybatis.core.AbstractCrudService;
-import com.usky.transfer.domain.SysUser;
-import com.usky.transfer.mapper.SysUserMapper;
-import com.usky.transfer.service.SysUserService;
-import org.springframework.stereotype.Service;
-
-/**
- * <p>
- * 用户信息表 服务实现类
- * </p>
- *
- */
-@Service
-public class SysUserServiceImpl extends AbstractCrudService<SysUserMapper, SysUser> implements SysUserService {
-
-}

data-transfer/data-transfer-biz/src/main/resources/mapper/transfer/SysUserMapper.xml

@@ -1,89 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.usky.transfer.mapper.SysUserMapper">
-
-    <!-- 通用查询映射结果 -->
-    <resultMap id="BaseResultMap" type="com.usky.transfer.domain.SysUser">
-        <id column="user_id" property="userId" />
-        <result column="dept_id" property="deptId" />
-        <result column="user_name" property="userName" />
-        <result column="nick_name" property="nickName" />
-        <result column="user_type" property="userType" />
-        <result column="email" property="email" />
-        <result column="phonenumber" property="phonenumber" />
-        <result column="sex" property="sex" />
-        <result column="avatar" property="avatar" />
-        <result column="password" property="password" />
-        <result column="status" property="status" />
-        <result column="del_flag" property="delFlag" />
-        <result column="login_ip" property="loginIp" />
-        <result column="login_date" property="loginDate" />
-        <result column="create_by" property="createBy" />
-        <result column="create_time" property="createTime" />
-        <result column="update_by" property="updateBy" />
-        <result column="update_time" property="updateTime" />
-        <result column="remark" property="remark" />
-    </resultMap>
-    <insert id="DeviceRealDataToDB" parameterType="java.util.List">
-    insert into data_real_time(
-    device_id,
-    product_code,
-    device_type,
-    attribute_name,
-    attribute_data,
-    data_time,
-    insert_time)
-    values
-    <foreach collection="list" item="item" separator=",">
-        (#{item.deviceId},
-        #{item.productCode},
-        #{item.deviceType},
-        #{item.attributeName},
-        #{item.attributeData},
-        #{item.dataTime},
-        #{item.insertTime})
-    </foreach>
-        ON DUPLICATE KEY UPDATE  attribute_data = values(attribute_data),data_time = values(data_time),insert_time = values(insert_time);
-    </insert>
-    <insert id="DeviceDataToDB" parameterType="java.util.List">
-        insert into sp_d${deviceId}(
-            device_id,
-            product_code,
-            device_type,
-            attribute_name,
-            attribute_data,
-            data_time,
-            insert_time)
-        values
-        <foreach collection="list" item="item" separator=",">
-            (#{item.deviceId},
-            #{item.productCode},
-            #{item.deviceType},
-            #{item.attributeName},
-            #{item.attributeData},
-            #{item.dataTime},
-            #{item.insertTime})
-        </foreach>
-        ON DUPLICATE KEY UPDATE  attribute_data = values(attribute_data),insert_time = values(insert_time);
-    </insert>
-    <!-- 判断表是否存在 -->
-    <select id="existTable" parameterType="string" resultType="java.lang.Integer">
-        SELECT COUNT(*) as count FROM information_schema.TABLES WHERE table_name = #{tableName}
-    </select>
-    <!-- 创建对应设备历史数据表 -->
-    <update id="createTable" parameterType="string">
-        CREATE TABLE IF NOT EXISTS ${tableName} (
-        `id` INT(11) NOT NULL AUTO_INCREMENT COMMENT '主键ID',
-        `device_id` VARCHAR(50) DEFAULT NULL COMMENT '设备ID',
-        `product_code` VARCHAR(50) DEFAULT NULL COMMENT '产品编码',
-        `device_type` INT(5) DEFAULT NULL COMMENT '设备类型',
-        `attribute_name` VARCHAR(50) DEFAULT NULL COMMENT '属性名称',
-        `attribute_data` VARCHAR(20) DEFAULT NULL COMMENT '属性值',
-        `data_time` DATETIME DEFAULT NULL COMMENT '数据时间',
-        `insert_time` DATETIME DEFAULT NULL COMMENT '插入时间',
-        PRIMARY KEY (`id`) USING BTREE,
-        UNIQUE KEY `uid_dad` (`device_id`,`attribute_name`,`data_time`)
-        ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8
-    </update>
-
-</mapper>