xucaiqin 6 saat önce
ebeveyn
işleme
ccadd9a9d1
42 değiştirilmiş dosya ile 0 ekleme ve 2703 silme
  1. 0 135
      sckw-modules/sckw-example/pom.xml
  2. 0 16
      sckw-modules/sckw-example/src/main/java/com/sckw/example/ExampleApplication.java
  3. 0 208
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/ExcelExportController.java
  4. 0 137
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/FileApiController.java
  5. 0 40
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/MessageApiController.java
  6. 0 143
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/SysUserController.java
  7. 0 53
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/TestController.java
  8. 0 119
      sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/TransportController.java
  9. 0 10
      sckw-modules/sckw-example/src/main/java/com/sckw/example/dao/KwsDeptDao.java
  10. 0 33
      sckw-modules/sckw-example/src/main/java/com/sckw/example/dao/SysUserDao.java
  11. 0 43
      sckw-modules/sckw-example/src/main/java/com/sckw/example/dubbo/FileApiServiceImpl.java
  12. 0 58
      sckw-modules/sckw-example/src/main/java/com/sckw/example/dubbo/RemoteUserService1Impl.java
  13. 0 13
      sckw-modules/sckw-example/src/main/java/com/sckw/example/feign/FileApiFeignServiceImpl.java
  14. 0 23
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Employees.java
  15. 0 55
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/FileInfo.java
  16. 0 24
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/KwsDept.java
  17. 0 22
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Product.java
  18. 0 33
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Student.java
  19. 0 23
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/SysUser.java
  20. 0 39
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/TestSensitive.java
  21. 0 32
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/ProjectPageVo.java
  22. 0 43
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/SysEnterpriseVo.java
  23. 0 34
      sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/SysUserVo.java
  24. 0 226
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/ExcelExportService.java
  25. 0 45
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/FileService.java
  26. 0 13
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/StudentRepository.java
  27. 0 42
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/StudentService.java
  28. 0 24
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/SysSensitiveServiceImpl.java
  29. 0 36
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/SysUserService.java
  30. 0 22
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/TestXxlJobService.java
  31. 0 45
      sckw-modules/sckw-example/src/main/java/com/sckw/example/service/TransportService.java
  32. 0 30
      sckw-modules/sckw-example/src/main/java/com/sckw/example/task/TestXxlJobTask.java
  33. 0 5
      sckw-modules/sckw-example/src/main/resources/banner.txt
  34. 0 24
      sckw-modules/sckw-example/src/main/resources/bootstrap-dev.yml
  35. 0 24
      sckw-modules/sckw-example/src/main/resources/bootstrap-lfdc.yml
  36. 0 154
      sckw-modules/sckw-example/src/main/resources/bootstrap-local.yml
  37. 0 16
      sckw-modules/sckw-example/src/main/resources/bootstrap.yml
  38. 0 154
      sckw-modules/sckw-example/src/main/resources/log4j2.xml
  39. 0 239
      sckw-modules/sckw-example/src/main/resources/mapper/KwsDeptDao.xml
  40. 0 55
      sckw-modules/sckw-example/src/main/resources/mapper/SysUserDao.xml
  41. 0 61
      sckw-modules/sckw-example/src/test/java/com/sckw/example/StudentDaoTest.java
  42. 0 152
      sckw-modules/sckw-example/src/test/java/com/sckw/example/StudentRepositoryTest.java

+ 0 - 135
sckw-modules/sckw-example/pom.xml

@@ -1,135 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <parent>
-        <artifactId>sckw-modules</artifactId>
-        <groupId>com.sckw</groupId>
-        <version>1.0.0</version>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-    <version>${example.revision}</version>
-    <artifactId>sckw-example</artifactId>
-
-    <properties>
-        <maven.compiler.source>17</maven.compiler.source>
-        <maven.compiler.target>17</maven.compiler.target>
-        <upgrade.version>1.1.0</upgrade.version>
-        <basic.version>1.0.0</basic.version>
-    </properties>
-
-    <dependencies>
-        <!-- 核心模块 -->
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-startup</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-core</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-mongo</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-xxljob</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-stream</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-remote</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-redis</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-excel</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-datasource</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-seata</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-common-sentinel</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-system-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-file-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-message-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-order-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-payment-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>com.sckw</groupId>
-            <artifactId>sckw-transport-api</artifactId>
-            <version>${basic.version}</version>
-        </dependency>
-        <!--junit-->
-        <dependency>
-            <groupId>junit</groupId>
-            <artifactId>junit</artifactId>
-            <scope>test</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-test</artifactId>
-            <scope>test</scope>
-        </dependency>
-    </dependencies>
-</project>

+ 0 - 16
sckw-modules/sckw-example/src/main/java/com/sckw/example/ExampleApplication.java

@@ -1,16 +0,0 @@
-package com.sckw.example;
-
-import com.sckw.remote.annotation.SckwRemoteApplication;
-import com.sckw.startup.annotation.SckwCloudApplication;
-import org.springframework.boot.SpringApplication;
-
-@SckwRemoteApplication
-@SckwCloudApplication
-public class ExampleApplication {
-
-    public static void main(String[] args) {
-        // 关闭nacos日志
-        System.setProperty("nacos.logging.default.config.enabled", "false");
-        SpringApplication.run(ExampleApplication.class, args);
-    }
-}

+ 0 - 208
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/ExcelExportController.java

@@ -1,208 +0,0 @@
-package com.sckw.example.controller;
-
-import com.alibaba.fastjson.JSONObject;
-import com.sckw.core.model.constant.NumberConstant;
-import com.sckw.core.model.file.FileInfo;
-import com.sckw.core.utils.IdWorker;
-import com.sckw.core.utils.StringUtils;
-import com.sckw.core.web.constant.HttpStatus;
-import com.sckw.core.web.response.HttpResult;
-import com.sckw.example.dao.KwsDeptDao;
-import com.sckw.example.model.KwsDept;
-import com.sckw.example.model.vo.ProjectPageVo;
-import com.sckw.example.model.vo.SysUserVo;
-import com.sckw.example.service.ExcelExportService;
-import com.sckw.excel.easyexcel.ExcelImportListener;
-import com.sckw.excel.easyexcel.RequestHolder;
-import com.sckw.excel.utils.DateUtil;
-import com.sckw.excel.utils.ExcelUtil;
-import com.sckw.file.api.dubbo.FileApiDubboService;
-import io.seata.core.context.RootContext;
-import io.seata.spring.annotation.GlobalTransactional;
-import jakarta.servlet.http.HttpServletRequest;
-import jakarta.servlet.http.HttpServletResponse;
-import lombok.AllArgsConstructor;
-import lombok.SneakyThrows;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.FileUtils;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.hibernate.validator.constraints.Range;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.util.CollectionUtils;
-import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.File;
-import java.io.UnsupportedEncodingException;
-import java.util.Date;
-import java.util.List;
-
-@Slf4j
-@AllArgsConstructor
-@RestController
-@RequestMapping("/export")
-public class ExcelExportController {
-
-    @Autowired
-    ExcelExportService excelExportService;
-
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    FileApiDubboService fileApiDubboService;
-
-    @Autowired
-    KwsDeptDao kwsDeptDao;
-
-    /**
-     * 模板下载
-     *
-     * @param request  请求流
-     * @param response 响应流
-     * @param type     模板类型
-     * @throws UnsupportedEncodingException
-     */
-    @RequestMapping("/downloadTemplates")
-    public void download(HttpServletRequest request, HttpServletResponse response, @RequestParam("type") Integer type) {
-        try {
-            excelExportService.downloadTemplates(request, response, type);
-        } catch (UnsupportedEncodingException e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-
-    /**
-     * 单个sheet导出
-     *
-     * @return
-     */
-    @GetMapping("/export")
-    public HttpResult export() {
-        HttpServletResponse response = RequestHolder.getResponse();
-        List<SysUserVo> list = excelExportService.export();
-        if (!CollectionUtils.isEmpty(list)) {
-            ExcelUtil.download(response, SysUserVo.class, list);
-            return null;
-        }
-        return HttpResult.error("没有可导出的数据");
-    }
-
-    /**
-     * 多个sheet导出
-     *
-     * @return
-     */
-    @GetMapping("/exportList")
-    public HttpResult exportList() {
-        HttpServletResponse response = RequestHolder.getResponse();
-        List<List> list = excelExportService.exportList();
-        if (!CollectionUtils.isEmpty(list)) {
-            ExcelUtil.download(response, list);
-            return null;
-        }
-        return HttpResult.error("没有可导出的数据");
-    }
-
-    /**
-     * 导入
-     *
-     * @param file 文件
-     * @param type 文件类型-指的是什么模板 用于公共导入处理
-     *
-     * @return
-     */
-    @SneakyThrows
-    @RequestMapping("/importExcel")
-    public HttpResult importExcel(@RequestParam("file") MultipartFile file, @RequestParam("type") @Range(min = 1, max = 10, message = "类型错误") Integer type) {
-        if (ExcelUtil.checkExcel(file)) {
-            throw new UnsupportedOperationException("请上传Excel格式的文件!");
-        }
-        String fileName = file.getOriginalFilename();
-        if (StringUtils.isNotBlank(fileName) && fileName.contains("?")) {
-            String suffix = fileName.substring(fileName.lastIndexOf("."));
-            fileName = "自定义" + suffix;
-        }
-//        String filePath = path + DateUtil.date() + File.separator +
-//               DateUtil.getDateTime("yyyyMMddHHmmssSSS") + "_" + fileName;
-        //String path=""; 系统定义存储文件地址,便于查看上传文件内容
-        String filePath = DateUtil.date() + File.separator +
-                DateUtil.getDateTime("yyyyMMddHHmmssSSS") + "_" + fileName;
-        FileUtils.copyInputStreamToFile(file.getInputStream(), new File(filePath));
-        ExcelImportListener importListener = new ExcelImportListener();
-        return excelExportService.importExcel(file, importListener);
-    }
-
-    /**
-     * 分布式事务验证
-     *
-     * @return
-     */
-    @GlobalTransactional(rollbackFor = Exception.class, name = "example-seata-service-group")
-    @RequestMapping(value = "globalTransactionalDemo", method = RequestMethod.GET)
-    public HttpResult globalTransactionalDemo() {
-        KwsDept dos = new KwsDept();
-        HttpResult result = new HttpResult();
-        result.setMsg(HttpStatus.SUCCESS_MESSAGE);
-        try {
-            long l = new IdWorker(1).nextId();
-            dos.setId(l);
-            dos.setSystemType("1");
-            dos.setAccount("张三");
-            dos.setPassword("password");
-            dos.setName("张三");
-            dos.setPhone("4564789113");
-            dos.setPhoto("44546545");
-            dos.setEmail("45456454");
-            dos.setClientId("7879814");
-            dos.setIsMain(0);
-            dos.setCreateBy(123L);
-            dos.setUpdateBy(123L);
-            dos.setCreateTime(new Date());
-            dos.setUpdateTime(new Date());
-//            kwsDeptDao.insert(dos);
-//            KwsDept kwsDept = new KwsDept();
-            int insert = kwsDeptDao.insert(dos);
-            String xid = RootContext.getXID();
-            System.out.println(xid);
-            System.out.println(l);
-            result = fileApiDubboService.selectAll();
-            long nextId = new IdWorker(NumberConstant.ONE).nextId();
-            dos.setId(nextId);
-            int insert1 = kwsDeptDao.insert(dos);
-            log.info(JSONObject.toJSONString(result));
-        } catch (Exception e) {
-            result.setCode(HttpStatus.GLOBAL_EXCEPTION_CODE);
-            result.setMsg(e.getMessage());
-            throw new RuntimeException(e);
-        }
-        return result;
-    }
-
-    /**
-     * dubboFile文件调用
-     *
-     * @return
-     */
-    @RequestMapping(value = "/fileInfoInsert", method = RequestMethod.POST)
-    public HttpResult fileDubboUpload(@Validated @RequestBody FileInfo fileInfo) {
-        try {
-            return fileApiDubboService.fileInfoInsert(fileInfo);
-        } catch (Exception e) {
-            throw new RuntimeException(e);
-        }
-    }
-
-    /**
-     * 导出注解翻译示例
-     */
-    @RequestMapping(value = "/easyExcelDemo", method = RequestMethod.GET)
-    public HttpResult easyExcelDemo() {
-        HttpServletResponse response = RequestHolder.getResponse();
-        List<ProjectPageVo> list = excelExportService.easyExcelDemo();
-        if (!CollectionUtils.isEmpty(list)) {
-            ExcelUtil.download(response, ProjectPageVo.class, list);
-            return null;
-        }
-        return HttpResult.error("没有可导出的数据");
-    }
-}

+ 0 - 137
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/FileApiController.java

@@ -1,137 +0,0 @@
-//package com.sckw.example.controller;
-//
-//import com.sckw.core.web.response.HttpResult;
-//import com.sckw.example.service.FileService;
-//import com.sckw.file.api.dubbo.FileApiDubboService;
-//import com.sckw.file.api.feign.FileApiFeignService;
-//import lombok.AllArgsConstructor;
-//import org.apache.dubbo.config.annotation.DubboReference;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.web.bind.annotation.*;
-//import org.springframework.web.multipart.MultipartFile;
-//
-//import java.io.IOException;
-//import java.util.HashMap;
-//import java.util.Map;
-//
-///**
-// * @author lfdc
-// * @version 1.0
-// * @className FileApiController
-// * @description alibaba-oss测试用例
-// * z
-// * @company sckw
-// * @date 2023-06-02 16:06:43
-// */
-//@RestController
-//@RequestMapping("/file")
-//@AllArgsConstructor
-//public class FileApiController {
-//
-//    @Autowired
-//    private FileApiFeignService fileApiFeignService;
-//
-//    @DubboReference(version = "1.0.0", group = "design", check = false)
-//    private FileApiDubboService fileApiDubboService;
-//
-//    @Autowired
-//    private FileService fileService;
-//
-//    /**
-//     * 上传文件至OSS
-//     *
-//     * @param file
-//     * @return
-//     */
-//    @RequestMapping(value = "/fileUpload", method = RequestMethod.POST)
-//    public HttpResult fileUpload(@RequestParam("file") MultipartFile file) {
-//        //获取上传文件
-//        String url = fileService.uploadFile(file);
-//        return HttpResult.ok(url);
-//
-//    }
-//
-//    /**
-//     * OSS下载文件/获取文件地址
-//     *
-//     * @return
-//     */
-//    @GetMapping("/fileDownload")
-//    public HttpResult fileDownload() {
-//        String fileName = "测试=JPEG.webp";
-//        //获取上传文件
-//        String url = fileService.fileDownload(fileName);
-//        return HttpResult.ok(url);
-//    }
-//
-//
-//    /**
-//     * 基于feign调用
-//     *
-//     * @param file
-//     * @return
-//     */
-//    @RequestMapping(value = "/fileFeignUpload", method = RequestMethod.POST)
-//    public HttpResult fileFeignUpload(@RequestParam("file") MultipartFile file) {
-//        //example 服务 调用 file服务提供的feign接口
-//        HttpResult result = fileApiFeignService.fileFeignUpload(file);
-//        return result;
-//    }
-//
-//    /**
-//     * 基于feign调用
-//     *
-//     * @param
-//     * @return
-//     */
-//    @RequestMapping(value = "/fileFeignDemo", method = RequestMethod.GET)
-//    //@RequestParam("file") MultipartFile file
-//    public String fileFeignDemo() {
-//        //example 服务 调用 file服务提供的feign接口
-//        return fileApiFeignService.fileFeignDemo("userName");
-//    }
-//
-//    /**
-//     * 基于feign调用
-//     *
-//     * @param
-//     * @return
-//     */
-//    @RequestMapping(value = "/fileFeignDemo1", method = RequestMethod.POST)
-//    public String fileFeignDemo1() {
-//        Map<String, String> map = new HashMap<>();
-//        map.put("123", "456");
-//        map.put("asd", "asd");
-//        return fileApiFeignService.fileFeignDemo1(map);
-//    }
-//
-//
-//    /**
-//     * 基于dubbo调用
-//     *
-//     * @param file
-//     * @return
-//     */
-//    @GetMapping("/fileDubboUpload")
-//    public HttpResult fileDubboUpload(@RequestParam("file") MultipartFile file) throws IOException {
-//        // 调用 file服务提供的dubbo接口
-//        //需要将文件转换成byte否则为空
-//        //获取文件类型
-//        String contentType = file.getContentType();
-//        //获取上传文件的原始文件名
-//        String oFileName = file.getOriginalFilename();
-//        //把文件转化成byte[]
-//        byte[] bytes = file.getBytes();
-////        BigDecimal fileSize = FileUtils.getFileSize(file, "KB");
-////        FileInfo fileInfo = new FileInf0;
-////        fileInfo.setOriginalName(oFileName);
-////        //获取文件后缀
-////        fileInfo.setFileSuffix(FilenameUtils.getExtension(oFileName));
-////        fileInfo.setFileSize(StringUtils.isBlank(fileSize) ? new BigDecimal("0") : fileSize);
-////        HttpResult result = fileApiDubboService.fileUpload(JSONObject.toJSONString(fileInfo), bytes);
-//        HttpResult result = fileApiDubboService.fileUploadTodubbo(file);
-//        return result;
-//    }
-//
-//
-//}

+ 0 - 40
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/MessageApiController.java

@@ -1,40 +0,0 @@
-package com.sckw.example.controller;
-
-import com.sckw.core.common.enums.enums.DictEnum;
-import com.sckw.core.web.response.HttpResult;
-import com.sckw.message.api.dubbo.SmsInfoService;
-import com.sckw.order.api.dubbo.TradeOrderInfoService;
-import com.sckw.order.api.model.OrderDetailRes;
-import lombok.RequiredArgsConstructor;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * @desc: 测试
- * @author: yzc
- * @date: 2023-06-13 14:20
- */
-@RestController
-@RequestMapping(value = "/messageApi")
-@RequiredArgsConstructor
-public class MessageApiController {
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private SmsInfoService smsInfoService;
-
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private TradeOrderInfoService tradeOrderInfoService;
-
-    @GetMapping("/getVerifyCode")
-    public HttpResult getVerifyCode() {
-        String verifyCode = smsInfoService.getVerifyCode(DictEnum.SMS_REGISTER.getValue(),"17780832879");
-        return HttpResult.ok("获取验证码成功", verifyCode);
-    }
-
-    @GetMapping("/getOrderDetail")
-    public HttpResult getOrderDetail() {
-        OrderDetailRes orderDetailById = tradeOrderInfoService.getOrderDetailById(162213167693303808L);
-        return HttpResult.ok("获取订单详情成功", orderDetailById);
-    }
-}

+ 0 - 143
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/SysUserController.java

@@ -1,143 +0,0 @@
-////package com.sckw.example.controller;
-////
-////import cn.hutool.core.lang.UUID;
-////import com.alibaba.csp.sentinel.annotation.SentinelResource;
-////import com.alibaba.fastjson2.JSON;
-////import com.sckw.core.model.page.PageResult;
-////import com.sckw.core.web.exceptionHandler.CustomBlockExceptionHandler;
-////import com.sckw.core.web.response.HttpResult;
-////import com.sckw.example.model.SysUser;
-////import com.sckw.example.model.TestSensitive;
-////import com.sckw.example.service.SysUserService;
-////import com.sckw.stream.enums.SmsCodeEnum;
-////import com.sckw.stream.model.SckwMessage;
-////import com.sckw.stream.model.SckwSms;
-////import lombok.AllArgsConstructor;
-////import lombok.extern.slf4j.Slf4j;
-////import org.redisson.api.RBucket;
-////import org.redisson.api.RedissonClient;
-////import org.springframework.beans.factory.annotation.Autowired;
-////import org.springframework.cloud.stream.function.StreamBridge;
-////import org.springframework.web.bind.annotation.*;
-////
-////import javax.annotation.Resource;
-////import java.util.Date;
-////import java.util.HashMap;
-////import java.util.List;
-////import java.util.Map;
-////
-////@Slf4j
-////@AllArgsConstructor
-////@RestController
-////@RequestMapping("/")
-////public class SysUserController {
-////
-////    @Autowired
-////    SysUserService sysUserService;
-////
-////    @Autowired
-////    RedissonClient redissonClient;
-////
-////    /*@Autowired
-////    RedisService redisService;*/
-////
-////    @GetMapping("index")
-////    public Object test(){
-////        Map result = new HashMap();
-////        result.put("user", System.currentTimeMillis());
-////        result.put("datatime", System.currentTimeMillis());
-////        result.put("database", "redis");
-////
-////        RBucket<Object> mytest = redissonClient.getBucket("mytest");
-////        mytest.set("value");
-////        System.out.println(mytest.get());//value
-////        mytest.set("value2");
-////        System.out.println(mytest.get());//value2
-////        boolean b = mytest.compareAndSet("value2", result); //true
-////        System.out.println(mytest.get());//value3
-////        Object resultObj = mytest.get();
-////
-////        /*result.put("type", "spring boot");
-////        redisService.setCacheMap("value2", result);
-////        resultObj = redisService.getCacheMap("value2");*/
-////
-////        return String.valueOf(resultObj);
-////    }
-////
-////    //@Override
-////    public String getUserInfo(String account) {
-////        return account + String.valueOf(new Date());
-////    }
-////
-////    @PostMapping("findByAccount")
-////    public HttpResult findByAccount(HashMap params) {
-////        List<SysUser> data = sysUserService.findByAccount(params);
-////        return HttpResult.ok(data);
-////    }
-////
-////    @PostMapping("findPage")
-////    public HttpResult findPage(Map<String, Object> params) {
-////        PageResult pageResult = sysUserService.findPage(params);
-////        return HttpResult.ok(pageResult);
-////    }
-////
-////
-////    /**
-////     * 分布式事务示例
-////     * @return
-////     */
-////    @GlobalTransactional
-////    @RequestMapping(value = "/globalTransactionalDemo", method = RequestMethod.GET)
-////    public HttpResult globalTransactionalDemo() {
-////        return HttpResult.ok("globalTransactionalDemo");
-////    }
-//
-//
-//import org.springframework.web.bind.annotation.GetMapping;
-//
-//@GetMapping("/testSensitive")
-//    public HttpResult testSensitive() {
-//        TestSensitive testSensitive = new TestSensitive();
-//        testSensitive.setIdCard("210397198608215431");
-//        testSensitive.setPhone("17640125371");
-//        testSensitive.setAddress("北京市朝阳区某某四合院1203室");
-//        testSensitive.setEmail("17640125371@163.com");
-//        testSensitive.setBankCard("6226456952351452853");
-//        return HttpResult.ok(testSensitive);
-//    }
-//
-//    @Resource
-//    private StreamBridge streamBridge;
-//
-//    @GetMapping("/pushMesg")
-//    public HttpResult pushMesg() {
-//        String uuid = UUID.fastUUID().toString();
-//        SckwSms sckwSms = new SckwSms();
-//        sckwSms.setPhone("17358629955");
-//        sckwSms.setSignName("矿拉拉");
-//        sckwSms.setTemplateCode(SmsCodeEnum.VERIFICATION_CODE);
-//        sckwSms.setParams(new HashMap(){{put("code", "123456");}});
-//        streamBridge.send("sckw-sms", JSON.toJSONString(sckwSms));
-//
-//
-//        SckwMessage message = new SckwMessage();
-//        //person.setName(String.valueOf(System.currentTimeMillis()));
-//        message.setMsgUrl("---");
-//        message.setPushType("====");
-//        message.setClientId("111111111111111");
-//        streamBridge.send("sckw-message", JSON.toJSONString(message));
-//
-//        return HttpResult.ok(uuid);
-//    }
-//
-//    @GetMapping("/pushSms")
-//    public HttpResult pushSms() {
-//        TestSensitive testSensitive = new TestSensitive();
-//        testSensitive.setIdCard("210397198608215431");
-//        testSensitive.setPhone("17640125371");
-//        testSensitive.setAddress("北京市朝阳区某某四合院1203室");
-//        testSensitive.setEmail("17640125371@163.com");
-//        testSensitive.setBankCard("6226456952351452853");
-//        return HttpResult.ok(testSensitive);
-//    }
-//}

+ 0 - 53
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/TestController.java

@@ -1,53 +0,0 @@
-package com.sckw.example.controller;
-
-import com.sckw.payment.api.dubbo.PayCenterDubboService;
-import com.sckw.payment.api.dubbo.PaymentDubboService;
-import com.sckw.payment.api.model.dto.MemberDetail;
-import com.sckw.payment.api.model.dto.WalletDto;
-import com.sckw.payment.api.model.dto.common.R;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.List;
-
-@Slf4j
-@RestController
-@RequestMapping("/test")
-public class TestController {
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private PayCenterDubboService payCenterDubboService;
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private PaymentDubboService paymentDubboService;
-
-    @GetMapping("/detail")
-    public R<MemberDetail> download(/*@RequestParam("uid")*/ Long uid, String channel) {
-        return null;//payCenterDubboService.memberDetail(uid, ChannelEnum.HF);
-    }
-
-    @GetMapping("/wall")
-    public R<List<WalletDto>> wall(@RequestParam("uid") Long uid, String channel, Long filter) {
-        return payCenterDubboService.wallet(uid, null, filter);
-    }
-
-    @GetMapping("/test")
-    public R<Object> test(@RequestParam("entId") Long entId,Integer type) {
-        return R.ok(paymentDubboService.countSell(entId, type));
-    }
-    @GetMapping("/test1")
-    public R<Object> test1(@RequestParam("entId") Long entId,Integer type) {
-        return R.ok(paymentDubboService.countPurchase(entId, type));
-    }
-    @GetMapping("/test2")
-    public R<Object> test2(@RequestParam("entId") Long entId,Integer type) {
-        return R.ok(paymentDubboService.countCarrier(entId, type));
-    }
-    @GetMapping("/test3")
-    public R<Object> test3(@RequestParam("entId") Long entId,Integer type) {
-        return R.ok(paymentDubboService.countShipper(entId, type));
-    }
-
-}

+ 0 - 119
sckw-modules/sckw-example/src/main/java/com/sckw/example/controller/TransportController.java

@@ -1,119 +0,0 @@
-package com.sckw.example.controller;
-
-import com.sckw.core.model.constant.Global;
-import com.sckw.core.web.context.LoginUserHolder;
-import com.sckw.example.service.TransportService;
-import com.sckw.redis.config.RedisLockUtil;
-import com.sckw.redis.utils.RedissonUtils;
-import com.sckw.system.api.RemoteSystemService;
-import com.sckw.system.api.model.dto.res.EntCacheResDto;
-import lombok.AllArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.redisson.api.RSet;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RestController;
-
-import java.util.ArrayList;
-
-/**
- * @desc: 测试
- * @author: lfdc
- * @date: 2023-09-08 14:20
- */
-@Slf4j
-@AllArgsConstructor
-@RestController
-@RequestMapping("/transportTest")
-public class TransportController {
-
-    @Autowired
-    private TransportService transportService;
-
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private RemoteSystemService systemService;
-
-    @Autowired
-    private RedisLockUtil redisLockUtil;
-
-    /**
-     * 统计承运接单
-     *
-     * @param
-     * @return
-     */
-    @RequestMapping(value = "/statisticsLogistics", method = RequestMethod.GET)
-    public Integer statisticsLogistics() {
-        EntCacheResDto entCacheResDto = systemService.queryEntTreeById(LoginUserHolder.getEntId());
-        Long topEntId = entCacheResDto.getId();
-        Integer integer = transportService.statisticsLogistics(topEntId);
-        return integer;
-    }
-
-    /**
-     * 统计调度派车
-     *
-     * @param
-     * @return
-     */
-    @RequestMapping(value = "/statisticsWaybillSendCar", method = RequestMethod.GET)
-    public Integer statisticsWaybillSendCar() {
-        EntCacheResDto entCacheResDto = systemService.queryEntTreeById(LoginUserHolder.getEntId());
-        Long topEntId = entCacheResDto.getId();
-        Integer integer = transportService.statisticsWaybillSendCar(topEntId);
-        return integer;
-    }
-
-    /**
-     * 统计待核运单
-     *
-     * @param
-     * @return
-     */
-    @RequestMapping(value = "/statisticsPendingVerificationWaybill", method = RequestMethod.GET)
-    public Integer statisticsPendingVerificationWaybill() {
-        EntCacheResDto entCacheResDto = systemService.queryEntTreeById(LoginUserHolder.getEntId());
-        Long topEntId = entCacheResDto.getId();
-        Integer integer = transportService.statisticsPendingVerificationWaybill(topEntId);
-        return integer;
-    }
-
-    @RequestMapping(value = "/refreshScopeDemo", method = RequestMethod.GET)
-    public void refreshScopeDemo() {
-        transportService.refreshScopeDemo();
-    }
-
-    @RequestMapping(value = "/getRedissionDemo", method = RequestMethod.GET)
-    public void getRedissionDemo() {
-        long l = System.currentTimeMillis();
-        RedissonUtils.putSet(String.valueOf(l),new ArrayList<Long>(){{add(789456L);add(456789L);add(123456789L);}});
-        RSet<Object> set = RedissonUtils.getSet(String.valueOf(l));
-        long l1 = System.currentTimeMillis();
-        RedissonUtils.put(String.valueOf(l1),new ArrayList<Long>(){{add(789456L);add(456789L);add(123456789L);}}, Global.APP_TOKEN_EXPIRE);
-        RSet<Object> set1 = RedissonUtils.getSet(String.valueOf(l1));
-
-        //redis  set方式
-        long l2 = System.currentTimeMillis();
-        RedissonUtils.putSet(String.valueOf(l2),new ArrayList<Long>(){{add(789456L);add(456789L);add(123456789L);}});
-        RSet<Object> set2 = RedissonUtils.getSet(String.valueOf(l2));
-
-        //redis  set方式 -带有时间
-        long l24 = System.currentTimeMillis();
-        long l241 = System.currentTimeMillis();
-        RedissonUtils.putSet(String.valueOf(l24),new ArrayList<Long>(){{add(789456L);add(456789L);add(123456789L);}});
-
-        RSet<Object> set24 = RedissonUtils.getSet(String.valueOf(l24));
-        RedissonUtils.putSetSeconds(String.valueOf(l241),new ArrayList<Long>(){{add(789456L);add(456789L);add(123456789L);}},Global.PC_BACKGROUND_TOKEN_EXPIRE);
-        RSet<Object> set241 = RedissonUtils.getSet(String.valueOf(l241));
-        boolean b = redisLockUtil.tryLock("20231019A", 1);
-        if (b) {
-            System.out.println("获取到锁");
-        }
-        boolean b1 = redisLockUtil.tryLock("20231019A", 6000000);
-        if (b1) {
-            System.out.println("没获取到锁");
-        }
-    }
-}

+ 0 - 10
sckw-modules/sckw-example/src/main/java/com/sckw/example/dao/KwsDeptDao.java

@@ -1,10 +0,0 @@
-package com.sckw.example.dao;
-
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.sckw.example.model.KwsDept;
-import org.apache.ibatis.annotations.Mapper;
-
-@Mapper
-public interface KwsDeptDao extends BaseMapper<KwsDept> {
-//    int insert(KwsDept kwsDept);
-}

+ 0 - 33
sckw-modules/sckw-example/src/main/java/com/sckw/example/dao/SysUserDao.java

@@ -1,33 +0,0 @@
-package com.sckw.example.dao;
-
-import com.baomidou.dynamic.datasource.annotation.DS;
-import com.sckw.example.model.SysUser;
-import org.apache.ibatis.annotations.Mapper;
-import org.apache.ibatis.annotations.Select;
-import java.util.List;
-import java.util.Map;
-
-@Mapper
-public interface SysUserDao {
-
-    /**
-     * 账号查询用户信息
-     * @param params {account:账号, systemType:系统类别}
-     * @return
-     */
-    @DS("slave_1")
-    SysUser findByAccount(Map params);
-
-    @DS("master")
-    @Select("SELECT * FROM user limit 1")
-    List<SysUser> findUserByAccount(String account);
-
-    @DS("slave_1")
-    @Select("SELECT * FROM sys_user limit 10")
-    List<Map> findUserByAccount1(String account);
-
-    @DS("slave_1")
-    List<Map<String, Object>> findPage(Map<String, Object> params);
-
-    int insert(SysUser sysUser);
-}

+ 0 - 43
sckw-modules/sckw-example/src/main/java/com/sckw/example/dubbo/FileApiServiceImpl.java

@@ -1,43 +0,0 @@
-//package com.sckw.example.dubbo;
-//
-//import com.sckw.core.web.response.HttpResult;
-//import com.sckw.excel.common.NumberConstant;
-//import com.sckw.file.api.dto.FileInfoDTO;
-//import com.sckw.file.api.dubbo.FileApiDubboService;
-//import org.apache.dubbo.config.annotation.DubboService;
-//import org.springframework.web.multipart.MultipartFile;
-//
-//import java.io.InputStream;
-//import java.math.BigDecimal;
-//
-///**
-// * @author lfdc
-// * @description fileDubbo调用
-// * @date 2023/6/20 0020
-// */
-//@DubboService(group = "design", version = "2.0.0")
-//public class FileApiServiceImpl implements FileApiDubboService {
-//
-//    @Override
-//    public HttpResult fileUpload(String str, byte[] fileByte) {
-//        return null;
-//    }
-//
-//    @Override
-//    public HttpResult fileUploadTodubbo(MultipartFile file) {
-//        return null;
-//    }
-//
-//    @Override
-//    public HttpResult selectAll() {
-//        BigDecimal bigDecimal = new BigDecimal(NumberConstant.ZERO);
-//        BigDecimal bigDecimal1 = new BigDecimal(NumberConstant.SIX);
-//        BigDecimal divide = bigDecimal1.divide(bigDecimal);
-//        return null;
-//    }
-//
-//    @Override
-//    public HttpResult fileDubboUpload(InputStream inputStream, FileInfoDTO fileInfo) {
-//        return null;
-//    }
-//}

+ 0 - 58
sckw-modules/sckw-example/src/main/java/com/sckw/example/dubbo/RemoteUserService1Impl.java

@@ -1,58 +0,0 @@
-//package com.sckw.example.dubbo;
-//
-//import com.sckw.auth.model.vo.LoginReqDto;
-//import com.sckw.system.api.RemoteUserService;
-//import com.sckw.auth.model.vo.res.LoginResDto;
-//import com.sckw.system.model.KwsDept;
-//import com.sckw.system.model.KwsEnterprise;
-//import com.sckw.system.model.KwsUser;
-//import com.sckw.system.model.KwsUserDept;
-//import org.apache.dubbo.config.annotation.DubboService;
-//
-//import java.util.Date;
-//import java.util.List;
-//
-//@DubboService(group = "design", version = "2.0.0")
-//public class RemoteUserService1Impl implements RemoteUserService {
-//
-//    @Override
-//    public String getUserInfoV1(String account) {
-//        return "getUserInfoV1:"+new Date() +account;
-//    }
-//
-//    @Override
-//    public KwsUser getUserByAccount(String username) {
-//        return null;
-//    }
-//
-//    @Override
-//    public List<KwsUserDept> queryUserDeptByUserId(Long userId) {
-//        return null;
-//    }
-//
-//    @Override
-//    public List<KwsDept> queryDeptByIds(List<Long> ids) {
-//        return null;
-//    }
-//
-//    @Override
-//    public List<KwsEnterprise> queryEnterpriseByIds(List<Long> ids) {
-//        return null;
-//    }
-//
-//    @Override
-//    public void register(KwsUser kwsUser) {
-//
-//    }
-//
-//    @Override
-//    public void checkPassword(String password, String currentPwd) {
-//
-//    }
-//
-//    @Override
-//    public KwsUser checkUserBase(String username) {
-//        return null;
-//    }
-//
-//}

+ 0 - 13
sckw-modules/sckw-example/src/main/java/com/sckw/example/feign/FileApiFeignServiceImpl.java

@@ -1,13 +0,0 @@
-package com.sckw.example.feign;
-
-/**
- * @author lfdc
- * @version 1.0
- * @className FileApiFeignServiceImpl
- * @description file文件feign实现类
- * @company sckw
- * @date 2023-06-06 10:06:52
- */
-public class FileApiFeignServiceImpl {
-
-}

+ 0 - 23
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Employees.java

@@ -1,23 +0,0 @@
-package com.sckw.example.model;
-
-import lombok.Builder;
-import lombok.Getter;
-import lombok.Setter;
-import lombok.ToString;
-
-/**
- * @author: yzc
- * @date: 2023-06-07 10:26
- * @description:
- */
-@Getter
-@Setter
-@ToString
-@Builder
-public class Employees {
-
-    private String id;
-
-    private String name;
-
-}

+ 0 - 55
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/FileInfo.java

@@ -1,55 +0,0 @@
-//package com.sckw.example.model;
-//
-//import com.sckw.core.model.base.BaseModel;
-//import lombok.Data;
-//
-//import java.math.BigDecimal;
-//
-///**
-// * @author lfdc
-// * @version 1.0
-// * @className KwfFileInfo
-// * @description 文件do
-// * @company sckw
-// * @date 2023-06-08 15:06:24
-// */
-//
-//@Data
-//public class FileInfo extends BaseModel {
-//
-//    private static final long serialVersionUID = 8295075842951977226L;
-//
-//    /**
-//     * 文件存储方式(OSS)
-//     */
-//    private String type;
-//
-//    /**
-//     * 文件原名称
-//     */
-//    private String originalName;
-//
-//    /**
-//     * 文件新名称
-//     */
-//    private String fileName;
-//
-//    /**
-//     * 文件名md5加密
-//     */
-//    private String md5;
-//
-//    /**
-//     * 文件后缀
-//     */
-//    private String fileSuffix;
-//
-//    /**
-//     * 文件大小(kb)
-//     */
-//    private BigDecimal fileSize;
-//    /**
-//     * 文件服务器存储相对路径
-//     */
-//    private String filePath;
-//}

+ 0 - 24
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/KwsDept.java

@@ -1,24 +0,0 @@
-package com.sckw.example.model;
-
-import com.sckw.core.model.base.BaseModel;
-import lombok.Data;
-
-/**
- * @author lfdc
- * @description
- * @date 2023/6/19 0019
- */
-@Data
-public class KwsDept  extends BaseModel {
-    private String name;
-    private String parentIds;
-    private String password;
-    private String account;
-    private String systemType;
-    private String phone;
-    private String email;
-    private String clientId;
-    private String photo;
-    private Integer isMain;
-
-}

+ 0 - 22
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Product.java

@@ -1,22 +0,0 @@
-package com.sckw.example.model;
-
-import lombok.Builder;
-import lombok.Getter;
-import lombok.Setter;
-import lombok.ToString;
-
-/**
- * @desc: TODO
- * @author: yzc
- * @date: 2023-06-12 17:37
- */
-@Getter
-@Setter
-@ToString
-@Builder
-public class Product {
-    private String id;
-    private String name;
-    private String description;
-    private Integer price;
-}

+ 0 - 33
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/Student.java

@@ -1,33 +0,0 @@
-package com.sckw.example.model;
-
-import lombok.Data;
-import org.springframework.data.annotation.Id;
-import java.util.Date;
-
-@Data
-public class Student {
-
-    @Id
-    private Long studentId;
-
-    private String studentName;
-
-    private Integer studentAge;
-
-    private Double studentScore;
-
-    private Date studentBirthday;
-
-    public Student(Long studentId, String studentName, Integer studentAge, Double studentScore, Date studentBirthday) {
-        this.studentId = studentId;
-        this.studentName = studentName;
-        this.studentAge = studentAge;
-        this.studentScore = studentScore;
-        this.studentBirthday = studentBirthday;
-    }
-
-    public Student() {
-    }
-
-
-}

+ 0 - 23
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/SysUser.java

@@ -1,23 +0,0 @@
-package com.sckw.example.model;
-
-import lombok.Data;
-
-import java.io.Serializable;
-
-@Data
-public class SysUser implements Serializable {
-
-    private String id;
-
-    private Integer systemType;
-
-    private String account;
-
-    private String password;
-
-    private String name;
-
-    private String phone;
-
-    private String photo;
-}

+ 0 - 39
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/TestSensitive.java

@@ -1,39 +0,0 @@
-package com.sckw.example.model;
-
-import com.sckw.core.annotation.Sensitive;
-import com.sckw.core.model.enums.SensitiveStrategy;
-import lombok.Data;
-
-@Data
-public class TestSensitive {
-
-    /**
-     * 身份证
-     */
-    @Sensitive(strategy = SensitiveStrategy.ID_CARD)
-    private String idCard;
-
-    /**
-     * 电话
-     */
-    @Sensitive(strategy = SensitiveStrategy.PHONE)
-    private String phone;
-
-    /**
-     * 地址
-     */
-    @Sensitive(strategy = SensitiveStrategy.ADDRESS)
-    private String address;
-
-    /**
-     * 邮箱
-     */
-    @Sensitive(strategy = SensitiveStrategy.EMAIL)
-    private String email;
-
-    /**
-     * 银行卡
-     */
-    @Sensitive(strategy = SensitiveStrategy.BANK_CARD)
-    private String bankCard;
-}

+ 0 - 32
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/ProjectPageVo.java

@@ -1,32 +0,0 @@
-package com.sckw.example.model.vo;
-
-import com.alibaba.excel.annotation.ExcelProperty;
-import com.sckw.core.model.constant.NumberConstant;
-import com.sckw.core.model.enums.ProjectStatusEnum;
-import com.sckw.excel.annotation.EasyExcel;
-import com.sckw.excel.annotation.ExcelContext;
-import com.sckw.excel.config.easyexcel.ExcelConverter;
-import lombok.Data;
-
-/**
- * @author lfdc
- * @description
- * @date 2023-07-28 11:07:15
- */
-@Data
-@ExcelContext(fileName = "企业列表", sheetName = "企业列表")
-public class ProjectPageVo {
-    /**
-     * 项目状态 ,index = 0
-     */
-    @ExcelProperty(value = "项目状态", converter = ExcelConverter.class)
-    @EasyExcel(type = ProjectStatusEnum.class, status = NumberConstant.TWO)
-    private String status;
-
-    /**
-     * 项目备注,index = 0
-     */
-    @ExcelProperty(value = "项目备注")
-    private String remark;
-
-}

+ 0 - 43
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/SysEnterpriseVo.java

@@ -1,43 +0,0 @@
-package com.sckw.example.model.vo;
-
-import com.alibaba.excel.annotation.ExcelProperty;
-import com.sckw.excel.annotation.ExcelContext;
-import lombok.Getter;
-import lombok.Setter;
-import lombok.ToString;
-
-/**
- * @author lfdc
- * @className SysEnterpriseVo
- * @description 页面返回数据
- * @company sckw
- * @date 2023-06-01 11:06:54
- * @version 1.0
- */
-@Getter
-@Setter
-@ToString
-//@Translates({@Translate(field = "orderStatus"),
-//        @Translate(field = "paymentType"),
-//        @Translate(field = "orderSource"),
-//        @Translate(field = "status"),
-//        @Translate(field = "isPushExitFunds")
-//})
-@ExcelContext(fileName = "企业列表", sheetName = "企业列表")
-public class SysEnterpriseVo {
-
-    @ExcelProperty(value = "id")
-    private String id;
-    @ExcelProperty(value = "企业类型")
-    private Integer enterpriseType;
-    @ExcelProperty(value = "企业账号")
-    private String enterpriseAccount;
-    @ExcelProperty(value = "企业密码")
-    private String enterprisePassword;
-    @ExcelProperty(value = "企业名称")
-    private String enterpriseName;
-    @ExcelProperty(value = "企业手机号")
-    private String enterprisePhone;
-
-
-}

+ 0 - 34
sckw-modules/sckw-example/src/main/java/com/sckw/example/model/vo/SysUserVo.java

@@ -1,34 +0,0 @@
-package com.sckw.example.model.vo;
-
-import com.alibaba.excel.annotation.ExcelProperty;
-import com.sckw.excel.annotation.ExcelContext;
-import lombok.Data;
-
-/**
- * @author lfdc
- * @className SysUserVo
- * @description 页面返回数据
- * @company sckw
- * @date 2023-06-01 11:06:54
- * @version 1.0
- */
-@Data
-@ExcelContext(fileName = "系统用户列表", sheetName = "系统用户列表")
-public class SysUserVo {
-
-    @ExcelProperty(value = "id")
-    private String id;
-    @ExcelProperty(value = "类型")
-    private Integer systemType;
-    @ExcelProperty(value = "账号")
-    private String account;
-    @ExcelProperty(value = "密码")
-    private String password;
-    @ExcelProperty(value = "姓名")
-    private String name;
-    @ExcelProperty(value = "手机号")
-    private String phone;
-    @ExcelProperty(value = "照片")
-    private String photo;
-
-}

+ 0 - 226
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/ExcelExportService.java

@@ -1,226 +0,0 @@
-package com.sckw.example.service;
-
-import com.alibaba.excel.EasyExcel;
-import com.alibaba.excel.ExcelReader;
-import com.alibaba.excel.read.metadata.ReadSheet;
-import com.sckw.core.web.constant.HttpStatus;
-import com.sckw.core.web.response.HttpResult;
-import com.sckw.example.model.vo.ProjectPageVo;
-import com.sckw.example.model.vo.SysEnterpriseVo;
-import com.sckw.example.model.vo.SysUserVo;
-import com.sckw.excel.common.FileType;
-import com.sckw.excel.easyexcel.ExcelImportListener;
-import com.sckw.excel.easyexcel.SheetExcelData;
-import jakarta.servlet.http.HttpServletRequest;
-import jakarta.servlet.http.HttpServletResponse;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-import org.springframework.web.multipart.MultipartFile;
-
-import java.io.*;
-import java.net.URLEncoder;
-import java.util.ArrayList;
-import java.util.List;
-
-@Slf4j
-@Service
-public class ExcelExportService {
-    public List<List> exportList() {
-        SysUserVo sysUserVo = new SysUserVo();
-        sysUserVo.setId("1");
-        sysUserVo.setSystemType(1);
-        sysUserVo.setAccount("张三");
-        sysUserVo.setPassword("zhangsan");
-        sysUserVo.setPhone("zhangsantel");
-        SysUserVo sysUserVo1 = new SysUserVo();
-        sysUserVo1.setId("2");
-        sysUserVo1.setSystemType(2);
-        sysUserVo1.setAccount("李四");
-        sysUserVo1.setPassword("lisi");
-        sysUserVo1.setPhone("lisitel");
-        List<SysUserVo> list = new ArrayList<>();
-        list.add(sysUserVo1);
-        list.add(sysUserVo);
-        List<SysEnterpriseVo> enterpriseList = new ArrayList<>();
-        SysEnterpriseVo sysEnterpriseVo = new SysEnterpriseVo();
-        sysEnterpriseVo.setEnterpriseType(1);
-        sysEnterpriseVo.setEnterpriseName("建筑");
-        sysEnterpriseVo.setEnterpriseAccount("建筑account");
-        SysEnterpriseVo sysEnterpriseVo1 = new SysEnterpriseVo();
-        sysEnterpriseVo1.setEnterpriseType(2);
-        sysEnterpriseVo1.setEnterpriseName("IT");
-        sysEnterpriseVo1.setEnterpriseAccount("ItAccount");
-        enterpriseList.add(sysEnterpriseVo);
-        enterpriseList.add(sysEnterpriseVo1);
-        List<List> dataList = new ArrayList<>();
-        dataList.add(list);
-        dataList.add(enterpriseList);
-        return dataList;
-    }
-
-    public void downloadTemplates(HttpServletRequest request, HttpServletResponse response, Integer type) throws UnsupportedEncodingException {
-        // 配置文件下载
-        response.setHeader("content-type", "application/octet-stream");
-        response.setContentType("application/octet-stream");
-        // 下载文件能正常显示中文
-        response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(FileType.getValue(type), "UTF-8"));
-        // 实现文件下载
-        byte[] buffer = new byte[1024];
-        InputStream fis = null;
-        BufferedInputStream bis = null;
-        try {
-            //地址可变动
-            fis = this.getClass().getResourceAsStream("/excel/" + FileType.getValue(type));
-            bis = new BufferedInputStream(fis);
-            OutputStream os = response.getOutputStream();
-            int i = bis.read(buffer);
-            while (i != -1) {
-                os.write(buffer, 0, i);
-                i = bis.read(buffer);
-            }
-        } catch (Exception e) {
-            log.error("下载异常");
-        } finally {
-            if (bis != null) {
-                try {
-                    bis.close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-            }
-            if (fis != null) {
-                try {
-                    fis.close();
-                } catch (IOException e) {
-                    e.printStackTrace();
-                }
-            }
-        }
-    }
-
-    public List<SysUserVo> export() {
-        SysUserVo sysUserVo = new SysUserVo();
-        sysUserVo.setId("1");
-        sysUserVo.setSystemType(1);
-        sysUserVo.setAccount("张三");
-        sysUserVo.setPassword("zhangsan");
-        sysUserVo.setPhone("zhangsantel");
-        SysUserVo sysUserVo1 = new SysUserVo();
-        sysUserVo1.setId("2");
-        sysUserVo1.setSystemType(2);
-        sysUserVo1.setAccount("李四");
-        sysUserVo1.setPassword("lisi");
-        sysUserVo1.setPhone("lisitel");
-        SysUserVo sysUserVo2 = new SysUserVo();
-        sysUserVo2.setId("3");
-        sysUserVo2.setSystemType(3);
-        sysUserVo2.setAccount("王五");
-        sysUserVo2.setPassword("wangwu");
-        sysUserVo2.setPhone("wangwutel");
-        SysUserVo sysUserVo3 = new SysUserVo();
-        sysUserVo3.setId("4");
-        sysUserVo3.setSystemType(4);
-        sysUserVo3.setAccount("陈六");
-        sysUserVo3.setPassword("chenliu");
-        sysUserVo3.setPhone("chenliutel");
-        List<SysUserVo> list = new ArrayList<>();
-        list.add(sysUserVo);
-        list.add(sysUserVo1);
-        list.add(sysUserVo2);
-        list.add(sysUserVo3);
-        return list;
-    }
-
-    public List<SheetExcelData> exportList1() {
-        SysUserVo sysUserVo = new SysUserVo();
-        sysUserVo.setId("1");
-        sysUserVo.setSystemType(1);
-        sysUserVo.setAccount("张三");
-        sysUserVo.setPassword("zhangsan");
-        sysUserVo.setPhone("zhangsantel");
-        SysUserVo sysUserVo1 = new SysUserVo();
-        sysUserVo1.setId("2");
-        sysUserVo1.setSystemType(2);
-        sysUserVo1.setAccount("李四");
-        sysUserVo1.setPassword("lisi");
-        sysUserVo1.setPhone("lisitel");
-        List<SysUserVo> list = new ArrayList<>();
-        list.add(sysUserVo1);
-        list.add(sysUserVo);
-        List<SysEnterpriseVo> enterpriseList = new ArrayList<>();
-        SysEnterpriseVo sysEnterpriseVo = new SysEnterpriseVo();
-        sysEnterpriseVo.setEnterpriseType(1);
-        sysEnterpriseVo.setEnterpriseName("建筑");
-        sysEnterpriseVo.setEnterpriseAccount("建筑account");
-        SysEnterpriseVo sysEnterpriseVo1 = new SysEnterpriseVo();
-        sysEnterpriseVo1.setEnterpriseType(2);
-        sysEnterpriseVo1.setEnterpriseName("IT");
-        sysEnterpriseVo1.setEnterpriseAccount("ItAccount");
-        enterpriseList.add(sysEnterpriseVo);
-        enterpriseList.add(sysEnterpriseVo1);
-        List<List> dataList = new ArrayList<>();
-        dataList.add(list);
-        dataList.add(enterpriseList);
-
-        List<SheetExcelData> sheetExcelDataArrayList = new ArrayList<>();
-        SheetExcelData sheetExcelData = new SheetExcelData();
-        sheetExcelData.setDataList(list);
-        sheetExcelData.setSheetName("A");
-        sheetExcelData.setTClass(List.class);
-        SheetExcelData sheetExcelData1 = new SheetExcelData();
-        sheetExcelData1.setDataList(enterpriseList);
-        sheetExcelData1.setSheetName("B");
-        sheetExcelData1.setTClass(List.class);
-        sheetExcelDataArrayList.add(sheetExcelData);
-        sheetExcelDataArrayList.add(sheetExcelData1);
-        return sheetExcelDataArrayList;
-    }
-
-    public HttpResult importExcel(MultipartFile file, ExcelImportListener importListener) {
-        ExcelReader excelReader = null;
-        List<String> failureMsgList = new ArrayList<>();
-        try {
-            InputStream inputStream = file.getInputStream();
-            excelReader = EasyExcel.read(inputStream, importListener).build();
-            ReadSheet readSheet = EasyExcel.readSheet(0).head(SysUserVo.class).build();
-            excelReader.read(readSheet);
-            if (importListener.getErrorList().size() > 0) {
-                return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, "导入失败", importListener.getErrorList());
-            }
-            if (importListener.getDataList().size() == 0) {
-                return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, "模板为空");
-            }
-            importListener.getDataList().clear();
-            importListener.getErrorList().clear();
-            ReadSheet readSheetSku = EasyExcel.readSheet(1).head(SysEnterpriseVo.class).build();
-            excelReader.read(readSheetSku);
-            if (importListener.getErrorList().size() > 0) {
-                return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, "导入失败", importListener.getErrorList());
-            }
-            if (importListener.getDataList().size() == 0) {
-                return HttpResult.error(HttpStatus.GLOBAL_EXCEPTION_CODE, "模板为空");
-            }
-
-        } catch (IOException e) {
-            throw new RuntimeException(e);
-        } finally {
-            if (excelReader != null) {
-                excelReader.finish();
-            }
-        }
-        return HttpResult.ok(HttpStatus.SUCCESS_CODE);
-    }
-
-    public List<ProjectPageVo> easyExcelDemo() {
-        ProjectPageVo projectPageVo = new ProjectPageVo();
-        projectPageVo.setStatus("0");
-        projectPageVo.setRemark("0");
-        ProjectPageVo projectPageVo1 = new ProjectPageVo();
-        projectPageVo1.setStatus("1");
-        projectPageVo1.setRemark("0");
-        List<ProjectPageVo> list = new ArrayList<>();
-        list.add(projectPageVo);
-        list.add(projectPageVo1);
-        return list;
-    }
-}

+ 0 - 45
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/FileService.java

@@ -1,45 +0,0 @@
-package com.sckw.example.service;
-
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-import org.springframework.web.multipart.MultipartFile;
-
-
-/**
- * @author lfdc
- * @version 1.0
- * @className FileService
- * @description 文件上传下载service
- * @company sckw
- * @date 2023-06-02 16:06:46
- */
-@Slf4j
-@Service
-public class FileService {
-
-
-    /**
-     * 上传文件至OSS
-     *
-     * @param file
-     * @return
-     */
-    public String uploadFile(MultipartFile file) {
-        //
-//        String url = FileUtils.uploadFile(file, FileEnum.DOCUMENT_ADDRESS);
-        //
-        return "url";
-    }
-
-
-    /**
-     * OSS下载文件/获取文件地址
-     *
-     * @return
-     */
-    public String fileDownload(String fileName) {
-//        FileUtils.downloadByObjectName(RequestHolder.getResponse(),fileName);
-        return null;
-    }
-}

+ 0 - 13
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/StudentRepository.java

@@ -1,13 +0,0 @@
-package com.sckw.example.service;
-
-import com.sckw.example.model.Student;
-import org.springframework.data.mongodb.repository.MongoRepository;
-
-/**
- * desc 继承MongoRepository即可,不需要实现类
- * author zk
- * date 2023/5/9 0015
- */
-public interface StudentRepository extends MongoRepository<Student, String> {
-}
-

+ 0 - 42
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/StudentService.java

@@ -1,42 +0,0 @@
-package com.sckw.example.service;
-
-import com.sckw.example.model.Student;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.mongodb.core.MongoTemplate;
-import org.springframework.stereotype.Service;
-import java.util.List;
-
-/**
- * desc TODO
- * author zk
- * date 2023/6/15 0015
- */
-@Service
-public class StudentService {
-    @Autowired
-    private MongoTemplate mongoTemplate;
-
-    public void addOne(Student student) {
-        mongoTemplate.save(student);
-    }
-
-    public void deleteOneById(String studentId) {
-        Student stu = mongoTemplate.findById(studentId, Student.class);
-        if (stu != null) {
-            mongoTemplate.remove(stu);
-        }
-    }
-
-    public void updateOne(Student student) {
-        mongoTemplate.save(student);
-
-    }
-
-    public Student findOneById(String studentId) {
-        return mongoTemplate.findById(studentId, Student.class);
-    }
-
-    public List<Student> findAll() {
-        return mongoTemplate.findAll(Student.class);
-    }
-}

+ 0 - 24
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/SysSensitiveServiceImpl.java

@@ -1,24 +0,0 @@
-package com.sckw.example.service;
-
-import com.sckw.core.service.SensitiveService;
-import org.springframework.stereotype.Service;
-
-/**
- * 脱敏服务
- * 默认管理员不过滤
- * 需自行根据业务重写实现
- * @author zk
- */
-@Service
-public class SysSensitiveServiceImpl implements SensitiveService {
-
-    /**
-     * 是否脱敏
-     */
-    @Override
-    public boolean isSensitive() {
-        //return !LoginHelper.isAdmin();
-        return true;
-    }
-
-}

+ 0 - 36
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/SysUserService.java

@@ -1,36 +0,0 @@
-//package com.sckw.example.service;
-//
-//import com.github.pagehelper.PageHelper;
-//import com.github.pagehelper.PageInfo;
-//import com.sckw.core.model.page.PageHelperUtil;
-//import com.sckw.core.model.page.PageResult;
-//import com.sckw.example.dao.SysUserDao;
-//import com.sckw.example.model.SysUser;
-//import lombok.extern.slf4j.Slf4j;
-//import org.springframework.beans.factory.annotation.Autowired;
-//import org.springframework.stereotype.Service;
-//import java.util.ArrayList;
-//import java.util.HashMap;
-//import java.util.List;
-//import java.util.Map;
-//
-//@Slf4j
-//@Service
-//public class SysUserService {
-//
-//    @Autowired
-//    SysUserDao sysUserDao;
-//
-//    public List<SysUser> findByAccount(HashMap params) {
-//        SysUser sysUser = sysUserDao.findByAccount(params);
-//        return new ArrayList<>(){{add(sysUser);}};
-//    }
-//
-//    public PageResult findPage(Map<String, Object> params) {
-//        // 设置分页参数
-//        PageHelper.startPage(PageResult.getPageNum(params), PageResult.getPageSize(params));
-//        List<Map<String, Object>> list = sysUserDao.findPage(params);
-//        PageResult pageResult = PageHelperUtil.getPageResult(new PageInfo(list));
-//        return pageResult;
-//    }
-//}

+ 0 - 22
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/TestXxlJobService.java

@@ -1,22 +0,0 @@
-package com.sckw.example.service;
-
-import com.sckw.core.utils.StringUtils;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-
-/**
- * @desc: xxl-job测试
- * @author: yzc
- * @date: 2023-06-15 11:25
- */
-@Service
-@Slf4j
-public class TestXxlJobService {
-    public void test(String param) {
-        if (StringUtils.isNotBlank(param)) {
-            log.info("xxl-job任务参数不为空,参数为:{}", param);
-        } else {
-            log.info("xxl-job任务参数为空····");
-        }
-    }
-}

+ 0 - 45
sckw-modules/sckw-example/src/main/java/com/sckw/example/service/TransportService.java

@@ -1,45 +0,0 @@
-package com.sckw.example.service;
-
-import com.sckw.transport.api.dubbo.TransportRemoteStatisticsService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.dubbo.config.annotation.DubboReference;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.cloud.context.config.annotation.RefreshScope;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-
-/**
- * @author lfdc
- * @description 运输服务service
- * @date 2023-09-08 14:09:23
- */
-@Slf4j
-@Service
-@RefreshScope
-public class TransportService {
-
-
-    @Value("${refreshScope.demo}")
-    private String refreshScope;
-
-    @DubboReference(version = "1.0.0", group = "design", check = false)
-    private TransportRemoteStatisticsService statisticsService;
-
-    public Integer statisticsLogistics(Long topEntId) {
-        return statisticsService.statisticsLogistics(topEntId,new ArrayList<>());
-    }
-
-    public Integer statisticsWaybillSendCar(Long topEntId) {
-        return statisticsService.statisticsWaybillSendCar(topEntId);
-    }
-
-    public Integer statisticsPendingVerificationWaybill(Long topEntId) {
-        return statisticsService.statisticsPendingVerificationWaybill(topEntId);
-    }
-
-
-    public void refreshScopeDemo() {
-        System.out.println("refreshScope:" + refreshScope);
-    }
-}

+ 0 - 30
sckw-modules/sckw-example/src/main/java/com/sckw/example/task/TestXxlJobTask.java

@@ -1,30 +0,0 @@
-package com.sckw.example.task;
-
-import com.sckw.example.service.TestXxlJobService;
-import com.xxl.job.core.context.XxlJobHelper;
-import com.xxl.job.core.handler.annotation.XxlJob;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-/**
- * @desc: xxl-job测试
- * @author: yzc
- * @date: 2023-06-15 11:23
- */
-@Component
-@Slf4j
-@RequiredArgsConstructor
-public class TestXxlJobTask {
-
-    private final TestXxlJobService testXxlJobService;
-
-    @XxlJob("TestXxlJobTask")
-    public void process(){
-        String param = XxlJobHelper.getJobParam();
-        log.info("xxl-job测试任务开始...month:{}", param);
-        testXxlJobService.test(param);
-        log.info("xxl-job测试任务结束...month:{}", param);
-    }
-
-}

+ 0 - 5
sckw-modules/sckw-example/src/main/resources/banner.txt

@@ -1,5 +0,0 @@
-====================================================================================================================
-
-                    欢迎使用 [sckw-example] 开物供应链服务平台-示例服务 - Powered By https://www.xxxx.com
-
-====================================================================================================================

+ 0 - 24
sckw-modules/sckw-example/src/main/resources/bootstrap-dev.yml

@@ -1,24 +0,0 @@
-spring:
-  cloud:
-    nacos:
-      discovery:
-        # 服务注册地址
-        server-addr: 10.10.10.230:8848
-        # 命名空间
-        namespace: sckw-service-platform-dev
-        # 共享配置
-        group: sckw-service-platform
-      config:
-        # 配置中心地址
-        server-addr: 10.10.10.230:8848
-        # 配置文件格式
-        file-extension: yaml
-        # 命名空间
-        namespace: sckw-service-platform-dev
-        # 共享配置
-        group: sckw-service-platform
-        #可以读多个配置文件  需要在同一个命名空间下面可以是不同的组
-        extension-configs:
-          - dataId: sckw-common.yml
-            group: sckw-service-platform
-            refresh: true

+ 0 - 24
sckw-modules/sckw-example/src/main/resources/bootstrap-lfdc.yml

@@ -1,24 +0,0 @@
-spring:
-  cloud:
-    nacos:
-      discovery:
-        # 服务注册地址
-        server-addr: 10.10.10.230:8848
-        # 命名空间
-        namespace: sckw_lfdc
-        # 共享配置
-        group: sckw-service-platform
-      config:
-        # 配置中心地址
-        server-addr: 10.10.10.230:8848
-        # 配置文件格式
-        file-extension: yaml
-        # 命名空间
-        namespace: sckw_lfdc
-        # 共享配置
-        group: sckw-service-platform
-        #可以读多个配置文件  需要在同一个命名空间下面可以是不同的组
-        extension-configs:
-          - dataId: sckw-common.yml
-            group: sckw-service-platform
-            refresh: true

+ 0 - 154
sckw-modules/sckw-example/src/main/resources/bootstrap-local.yml

@@ -1,154 +0,0 @@
-spring:
-  rabbitmq:
-    username: admin
-    password: admin
-    host: 10.10.10.138
-    port: 5672
-    virtual-host: /
-  cloud:
-    nacos:
-      discovery:
-        # 服务注册地址
-        #        server-addr: 47.108.162.14:8848
-        server-addr: 127.0.0.1:8848
-        # 命名空间
-        namespace: sckw-service-platform-dev
-        # nacos用户名
-        username: nacos
-        # nacos密码
-        password: nacos
-        # 共享配置
-        group: sckw-service-platform
-        # 权重 1-100 数值越大权重越大分配的流量就越大,通常结合权重负载均衡策略
-      #        weight: 100
-      config:
-        # 配置中心地址
-        #        server-addr: 47.108.162.14:8848
-        server-addr: 127.0.0.1:8848
-        # 配置文件格式
-        file-extension: yaml
-        # 命名空间
-        namespace: sckw-service-platform-dev
-        # 共享配置
-        group: sckw-service-platform
-        enabled: true
-    stream:
-      bindings:
-        sckwSms-out-0:
-          destination: sckw-sms
-          content-type: application/json
-          default-binder: defaultRabbit
-          group: sckw
-        sckwMessage-out-0:
-          destination: sckw-message
-          content-type: application/json
-          default-binder: defaultRabbit
-          group: sckw
-      binders:
-        defaultRabbit:
-          type: rabbit
-          environment:
-            spring:
-              rabbitmq:
-                virtual-host: /
-                host: 39.104.134.114
-                port: 5672
-                username: wph
-                password: Yy123...
-    # sentinel降级配置
-    sentinel:
-      transport:
-        client-ip: ${spring.cloud.client.ip-address} # 获取本机IP地址
-        port: 8719  #默认8719端口,如果被占用会向上扫描。
-        #控制台地址
-        #dashboard: 47.108.162.14:19527
-        dashboard: 127.0.0.1:19527
-      log:
-        #日志路径
-        dir: logs/sentinel
-        # 默认将调用链路收敛,导致链路流控效果无效
-        web-context-unify: false
-        #持久化nacos配置中
-      datasource:
-        #sentinel-rule: # 唯一名称可自定义
-        #限流
-        flow:
-          nacos:
-            # 设置Nacos的连接地址、命名空间和Group ID
-            namespace:  sckw-service-platform-dev
-            server-addr:  ${spring.cloud.nacos.discovery.server-addr}
-            # username: ${spring.cloud.nacos.discovery.username}
-            # password: ${spring.cloud.nacos.discovery.password}
-            # 设置Nacos中配置文件的命名规则
-            # data-id:  ${spring.application.name}-sentinel-flow-rules
-            data-id:  sckw-example-sentinel-flow-rules
-            group-id: SENTINEL_GROUP
-            data-type: json
-            # 必填的重要字段,指定当前规则类型是"限流"
-            rule-type: flow
-        #熔断
-        degrade:
-          nacos:
-            namespace:  sckw-service-platform-dev
-            server-addr: ${spring.cloud.nacos.discovery.server-addr}
-            #data-id: ${spring.application.name}-sentinel-degrade-rules
-            data-id: sckw-example-sentinel-degrade-rules
-            group-id: SENTINEL_GROUP
-            #熔断
-            rule-type: degrade
-      #取消慢加载
-      eager: true
-  datasource:
-    dynamic:
-      seata: true
-#seata:
-#  # seata 服务分组,要与服务端nacos-config.txt中service.vgroup_mapping的后缀对应
-#  # 事务分组名称,要和服务端对应
-#  tx-service-group: example-seata-group
-#  service:
-#    vgroup-mapping:
-#      # key是事务分组名称 value要和服务端的机房名称保持一致
-#      example-seata-group: default
-#  registry:
-#    # 指定nacos作为注册中心
-#    type: nacos
-#    nacos:
-#      server-addr: ${spring.cloud.nacos.discovery.server-addr}
-#      #server-addr: 47.108.162.14:8848
-#      namespace: ${spring.cloud.nacos.discovery.namespace}
-#      #      group: SEATA_GROUP
-#      group: ${spring.cloud.nacos.discovery.group}
-#  config:
-#    # 指定nacos作为配置中心
-#    type: nacos
-#    nacos:
-#      server-addr: ${spring.cloud.nacos.discovery.server-addr}
-#      #server-addr: 47.108.162.14:8848
-#      namespace: ${spring.cloud.nacos.discovery.namespace}
-#      group: ${spring.cloud.nacos.discovery.group}
-#  application-id: ${spring.application.name}
-#  #  当前不生效,使用驼峰
-#  enabled: true
-#  #  enable-auto-data-source-proxy: false
-#  enableAutoDataSourceProxy: false
-##  application-id: sckw-seata-file
-## 支持feign对sentinel支持
-##feign:
-##  sentinel:
-##    enabled: true
-
-dubbo:
-  application:
-    # 此处没有延用spring.application.name是因为当前项目本身也会注册到nacos中,如果dubbo也延用相同的名称,在nacos服务里会看到注册的producer-server服务数为2
-    name: example-dubbo-server
-  protocol:
-    name: dubbo
-    port: -1
-    prefer-serialization: java
-  registry:
-    # 配置dubbo的注册中心为nacos
-    address: nacos://${spring.cloud.nacos.discovery.server-addr}
-    group: ${spring.cloud.nacos.config.group}
-    protocol: nacos
-    #use-as-config-center: false
-    #use-as-metadata-center: false

+ 0 - 16
sckw-modules/sckw-example/src/main/resources/bootstrap.yml

@@ -1,16 +0,0 @@
-server:
-  port: 10300
-
-spring:
-  application:
-    name: sckw-example
-  profiles:
-#    active: @profiles.active@
-    active: ${DEPLOY_MODE:lfdc}
-  main:
-    allow-bean-definition-overriding: true
-    allow-circular-references: true
-logging:
-  level:
-    root: debug
-    com.sckw.example: debug

+ 0 - 154
sckw-modules/sckw-example/src/main/resources/log4j2.xml

@@ -1,154 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<configuration status="info" monitorInterval="30">
-    <properties>
-        <!-- 格式化输出:%date表示日期,%thread表示线程名,%-5level:级别从左显示5个字符宽度 %msg:日志消息,%n是换行符 -->
-        <!-- %logger{36} 表示 Logger 名字最长36个字符 -->
-        <property name="LOG_PATTERN"
-                  value="%clr{%d{yyyy-MM-dd HH:mm:ss.SSS}}{faint} %clr{%5p} %clr{${sys:PID}}{magenta} %clr{---}{faint} %clr{[%t]}{faint} %clr{%c{1.}}{cyan} %clr{:}{faint} %m%n%xwEx"/>
-        <property name="LOG_WITHOUT_COLOR_PATTERN"
-                  value="%d{yyyy-MM-dd HH:mm:ss.SSS} %5p ${sys:PID}--- [%t] %c{1.} : %m%n%xwEx"/>
-        <property name="LOG_PATH" value="logs/sckw-example"/>
-    </properties>
-    <!--DEBUG<INFO<WARNING<ERROR<CRITICAL-->
-    <!-- 先定义所有的appender(附加器)-->
-    <appenders>
-        <!-- 输出控制台的配置 -->
-        <Console name="Console" target="SYSTEM_OUT">
-            <!-- 输出日志的格式 -->
-            <PatternLayout pattern="${LOG_PATTERN}"/>
-        </Console>
-
-        <!--all级别日志-->
-        <RollingFile name="allFileAppender"
-                     fileName="${LOG_PATH}/all.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/all-%d{yyyy-MM-dd}-%i.log.gz">
-            <PatternLayout pattern="${LOG_WITHOUT_COLOR_PATTERN}"/>
-
-            <Policies>
-                <!-- 设置日志文件切分参数 -->
-                <!--<OnStartupTriggeringPolicy/>-->
-                <!--设置日志基础文件大小,超过该大小就触发日志文件滚动更新-->
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <!--设置日志文件滚动更新的时间,依赖于文件命名filePattern的设置-->
-                <TimeBasedTriggeringPolicy/>
-            </Policies>
-            <!--设置日志的文件个数上限,不设置默认为7个,超过大小后会被覆盖;依赖于filePattern中的%i-->
-            <DefaultRolloverStrategy max="100"/>
-        </RollingFile>
-
-        <!--debug级别日志-->
-        <RollingFile name="debugFileAppender"
-                     fileName="${LOG_PATH}/debug.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/debug-%d{yyyy-MM-dd}-%i.log.gz">
-            <Filters>
-                <!--过滤掉info及更高级别日志-->
-                <ThresholdFilter level="info" onMatch="DENY" onMismatch="NEUTRAL"/>
-            </Filters>
-            <!--设置日志格式-->
-            <PatternLayout pattern="${LOG_WITHOUT_COLOR_PATTERN}"/>
-
-            <Policies>
-                <!-- 设置日志文件切分参数 -->
-                <!--<OnStartupTriggeringPolicy/>-->
-                <!--设置日志基础文件大小,超过该大小就触发日志文件滚动更新-->
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <!--设置日志文件滚动更新的时间,依赖于文件命名filePattern的设置-->
-                <TimeBasedTriggeringPolicy/>
-            </Policies>
-            <!--设置日志的文件个数上限,不设置默认为7个,超过大小后会被覆盖;依赖于filePattern中的%i-->
-            <DefaultRolloverStrategy max="100"/>
-        </RollingFile>
-
-        <!--info级别日志-->
-        <RollingFile name="infoFileAppender"
-                     fileName="${LOG_PATH}/info.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/info-%d{yyyy-MM-dd}-%i.log.gz">
-            <Filters>
-                <!--过滤掉warn及更高级别日志-->
-                <ThresholdFilter level="warn" onMatch="DENY" onMismatch="NEUTRAL"/>
-            </Filters>
-            <!--设置日志格式-->
-            <PatternLayout pattern="${LOG_WITHOUT_COLOR_PATTERN}"/>
-
-            <Policies>
-                <!-- 设置日志文件切分参数 -->
-                <!--<OnStartupTriggeringPolicy/>-->
-                <!--设置日志基础文件大小,超过该大小就触发日志文件滚动更新-->
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <!--设置日志文件滚动更新的时间,依赖于文件命名filePattern的设置-->
-                <TimeBasedTriggeringPolicy interval="1" modulate="true"/>
-            </Policies>
-            <!--设置日志的文件个数上限,不设置默认为7个,超过大小后会被覆盖;依赖于filePattern中的%i-->
-            <!--<DefaultRolloverStrategy max="100"/>-->
-        </RollingFile>
-
-        <!--warn级别日志-->
-        <RollingFile name="warnFileAppender"
-                     fileName="${LOG_PATH}/warn.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/warn-%d{yyyy-MM-dd}-%i.log.gz">
-            <Filters>
-                <!--过滤掉error及更高级别日志-->
-                <ThresholdFilter level="error" onMatch="DENY" onMismatch="NEUTRAL"/>
-            </Filters>
-            <!--设置日志格式-->
-            <PatternLayout pattern="${LOG_WITHOUT_COLOR_PATTERN}"/>
-
-            <Policies>
-                <!-- 设置日志文件切分参数 -->
-                <!--<OnStartupTriggeringPolicy/>-->
-                <!--设置日志基础文件大小,超过该大小就触发日志文件滚动更新-->
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <!--设置日志文件滚动更新的时间,依赖于文件命名filePattern的设置-->
-                <TimeBasedTriggeringPolicy/>
-            </Policies>
-            <!--设置日志的文件个数上限,不设置默认为7个,超过大小后会被覆盖;依赖于filePattern中的%i-->
-            <DefaultRolloverStrategy max="100"/>
-        </RollingFile>
-
-        <!--error及更高级别日志-->
-        <RollingFile name="errorFileAppender"
-                     fileName="${LOG_PATH}/error.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/error-%d{yyyy-MM-dd}-%i.log.gz">
-            <!--设置日志格式-->
-            <PatternLayout pattern="${LOG_WITHOUT_COLOR_PATTERN}"/>
-            <Policies>
-                <!-- 设置日志文件切分参数 -->
-                <!--<OnStartupTriggeringPolicy/>-->
-                <!--设置日志基础文件大小,超过该大小就触发日志文件滚动更新-->
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <!--设置日志文件滚动更新的时间,依赖于文件命名filePattern的设置-->
-                <TimeBasedTriggeringPolicy/>
-            </Policies>
-            <!--设置日志的文件个数上限,不设置默认为7个,超过大小后会被覆盖;依赖于filePattern中的%i-->
-            <DefaultRolloverStrategy max="100"/>
-        </RollingFile>
-
-        <!--json格式error级别日志-->
-        <RollingFile name="errorJsonAppender"
-                     fileName="${LOG_PATH}/error-json.log"
-                     filePattern="${LOG_PATH}/$${date:yyyy-MM}/error-json-%d{yyyy-MM-dd}-%i.log.gz">
-            <JSONLayout compact="true" eventEol="true" locationInfo="true"/>
-            <Policies>
-                <SizeBasedTriggeringPolicy size="100 MB"/>
-                <TimeBasedTriggeringPolicy interval="1" modulate="true"/>
-            </Policies>
-        </RollingFile>
-
-    </appenders>
-
-    <loggers>
-        <root level="debug">
-            <AppenderRef ref="allFileAppender" level="all"/>
-            <AppenderRef ref="debugFileAppender" level="debug"/>
-            <AppenderRef ref="infoFileAppender" level="info"/>
-            <AppenderRef ref="warnFileAppender" level="warn"/>
-            <AppenderRef ref="errorFileAppender" level="error"/>
-            <AppenderRef ref="errorJsonAppender" level="error"/>
-            <appender-ref ref="Console" level="info"/>
-        </root>
-        <Logger name="org.springframework" level="info"/>
-        <Logger name="com.alibaba" level="info"/>
-        <Logger name="com.baomidou" level="info"/>
-    </loggers>
-
-</configuration>

+ 0 - 239
sckw-modules/sckw-example/src/main/resources/mapper/KwsDeptDao.xml

@@ -1,239 +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.sckw.example.dao.KwsDeptDao">
-    <resultMap id="BaseResultMap" type="com.sckw.example.model.KwsDept">
-        <id column="kws_user_id" jdbcType="BIGINT" property="id" />
-        <result column="system_type" jdbcType="INTEGER" property="systemType" />
-        <result column="account" jdbcType="VARCHAR" property="account" />
-        <result column="password" jdbcType="VARCHAR" property="password" />
-        <result column="name" jdbcType="VARCHAR" property="name" />
-        <result column="phone" jdbcType="VARCHAR" property="phone" />
-        <result column="photo" jdbcType="VARCHAR" property="photo" />
-        <result column="email" jdbcType="VARCHAR" property="email" />
-        <result column="client_id" jdbcType="VARCHAR" property="clientId" />
-        <result column="is_main" jdbcType="INTEGER" property="isMain" />
-        <result column="remark" jdbcType="VARCHAR" property="remark" />
-        <result column="status" jdbcType="INTEGER" property="status" />
-        <result column="create_by" jdbcType="BIGINT" property="createBy" />
-        <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
-        <result column="update_by" jdbcType="BIGINT" property="updateBy" />
-        <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
-        <result column="del_flag" jdbcType="INTEGER" property="delFlag" />
-    </resultMap>
-    <sql id="Base_Column_List">
-         id as kws_user_id,  system_type as kws_user_system_type,  account as kws_user_account,
-     `password` as `kws_user_password`,  `name` as `kws_user_name`,  phone as kws_user_phone,
-     photo as kws_user_photo,  email as kws_user_email,  client_id as kws_user_client_id,
-     is_main as kws_user_is_main,  remark as kws_user_remark,  `status` as `kws_user_status`,
-     create_by as kws_user_create_by,  create_time as kws_user_create_time,
-     update_by as kws_user_update_by,  update_time as kws_user_update_time,
-     del_flag as kws_user_del_flag
-    </sql>
-    <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
-        select
-        <include refid="Base_Column_List" />
-        from kws_user
-        where  id = #{id,jdbcType=BIGINT}
-    </select>
-    <delete id="deleteByPrimaryKey" parameterType="java.lang.Long">
-        delete from kws_user
-        where id = #{id,jdbcType=BIGINT}
-    </delete>
-    <insert id="insert" parameterType="com.sckw.example.dao.KwsDeptDao">
-        insert into sckw_system.kws_user (id, system_type, account,
-                              `password`, `name`, phone,
-                              photo, email, client_id,
-                              is_main, remark, `status`,
-                              create_by, create_time, update_by,
-                              update_time, del_flag)
-        values (#{id,jdbcType=BIGINT}, #{systemType,jdbcType=INTEGER}, #{account,jdbcType=VARCHAR},
-                #{password,jdbcType=VARCHAR}, #{name,jdbcType=VARCHAR}, #{phone,jdbcType=VARCHAR},
-                #{photo,jdbcType=VARCHAR}, #{email,jdbcType=VARCHAR}, #{clientId,jdbcType=VARCHAR},
-                #{isMain,jdbcType=INTEGER}, #{remark,jdbcType=VARCHAR}, #{status,jdbcType=INTEGER},
-                #{createBy,jdbcType=BIGINT}, #{createTime,jdbcType=TIMESTAMP}, #{updateBy,jdbcType=BIGINT},
-                #{updateTime,jdbcType=TIMESTAMP}, #{delFlag,jdbcType=INTEGER})
-    </insert>
-    <insert id="insertSelective" parameterType="com.sckw.example.dao.KwsDeptDao">
-        insert into kws_user
-        <trim prefix="(" suffix=")" suffixOverrides=",">
-            <if test="id != null">
-                id,
-            </if>
-            <if test="systemType != null">
-                system_type,
-            </if>
-            <if test="account != null">
-                account,
-            </if>
-            <if test="password != null">
-                `password`,
-            </if>
-            <if test="name != null">
-                `name`,
-            </if>
-            <if test="phone != null">
-                phone,
-            </if>
-            <if test="photo != null">
-                photo,
-            </if>
-            <if test="email != null">
-                email,
-            </if>
-            <if test="clientId != null">
-                client_id,
-            </if>
-            <if test="isMain != null">
-                is_main,
-            </if>
-            <if test="remark != null">
-                remark,
-            </if>
-            <if test="status != null">
-                `status`,
-            </if>
-            <if test="createBy != null">
-                create_by,
-            </if>
-            <if test="createTime != null">
-                create_time,
-            </if>
-            <if test="updateBy != null">
-                update_by,
-            </if>
-            <if test="updateTime != null">
-                update_time,
-            </if>
-            <if test="delFlag != null">
-                del_flag,
-            </if>
-        </trim>
-        <trim prefix="values (" suffix=")" suffixOverrides=",">
-            <if test="id != null">
-                #{id,jdbcType=BIGINT},
-            </if>
-            <if test="systemType != null">
-                #{systemType,jdbcType=INTEGER},
-            </if>
-            <if test="account != null">
-                #{account,jdbcType=VARCHAR},
-            </if>
-            <if test="password != null">
-                #{password,jdbcType=VARCHAR},
-            </if>
-            <if test="name != null">
-                #{name,jdbcType=VARCHAR},
-            </if>
-            <if test="phone != null">
-                #{phone,jdbcType=VARCHAR},
-            </if>
-            <if test="photo != null">
-                #{photo,jdbcType=VARCHAR},
-            </if>
-            <if test="email != null">
-                #{email,jdbcType=VARCHAR},
-            </if>
-            <if test="clientId != null">
-                #{clientId,jdbcType=VARCHAR},
-            </if>
-            <if test="isMain != null">
-                #{isMain,jdbcType=INTEGER},
-            </if>
-            <if test="remark != null">
-                #{remark,jdbcType=VARCHAR},
-            </if>
-            <if test="status != null">
-                #{status,jdbcType=INTEGER},
-            </if>
-            <if test="createBy != null">
-                #{createBy,jdbcType=BIGINT},
-            </if>
-            <if test="createTime != null">
-                #{createTime,jdbcType=TIMESTAMP},
-            </if>
-            <if test="updateBy != null">
-                #{updateBy,jdbcType=BIGINT},
-            </if>
-            <if test="updateTime != null">
-                #{updateTime,jdbcType=TIMESTAMP},
-            </if>
-            <if test="delFlag != null">
-                #{delFlag,jdbcType=INTEGER},
-            </if>
-        </trim>
-    </insert>
-    <update id="updateByPrimaryKeySelective" parameterType="com.sckw.example.dao.KwsDeptDao">
-        update kws_user
-        <set>
-            <if test="systemType != null">
-                system_type = #{systemType,jdbcType=INTEGER},
-            </if>
-            <if test="account != null">
-                account = #{account,jdbcType=VARCHAR},
-            </if>
-            <if test="password != null">
-                `password` = #{password,jdbcType=VARCHAR},
-            </if>
-            <if test="name != null">
-                `name` = #{name,jdbcType=VARCHAR},
-            </if>
-            <if test="phone != null">
-                phone = #{phone,jdbcType=VARCHAR},
-            </if>
-            <if test="photo != null">
-                photo = #{photo,jdbcType=VARCHAR},
-            </if>
-            <if test="email != null">
-                email = #{email,jdbcType=VARCHAR},
-            </if>
-            <if test="clientId != null">
-                client_id = #{clientId,jdbcType=VARCHAR},
-            </if>
-            <if test="isMain != null">
-                is_main = #{isMain,jdbcType=INTEGER},
-            </if>
-            <if test="remark != null">
-                remark = #{remark,jdbcType=VARCHAR},
-            </if>
-            <if test="status != null">
-                `status` = #{status,jdbcType=INTEGER},
-            </if>
-            <if test="createBy != null">
-                create_by = #{createBy,jdbcType=BIGINT},
-            </if>
-            <if test="createTime != null">
-                create_time = #{createTime,jdbcType=TIMESTAMP},
-            </if>
-            <if test="updateBy != null">
-                update_by = #{updateBy,jdbcType=BIGINT},
-            </if>
-            <if test="updateTime != null">
-                update_time = #{updateTime,jdbcType=TIMESTAMP},
-            </if>
-            <if test="delFlag != null">
-                del_flag = #{delFlag,jdbcType=INTEGER},
-            </if>
-        </set>
-        where id = #{id,jdbcType=BIGINT}
-    </update>
-    <update id="updateByPrimaryKey" parameterType="com.sckw.example.dao.KwsDeptDao">
-        update kws_user
-        set system_type = #{systemType,jdbcType=INTEGER},
-            account = #{account,jdbcType=VARCHAR},
-            `password` = #{password,jdbcType=VARCHAR},
-            `name` = #{name,jdbcType=VARCHAR},
-            phone = #{phone,jdbcType=VARCHAR},
-            photo = #{photo,jdbcType=VARCHAR},
-            email = #{email,jdbcType=VARCHAR},
-            client_id = #{clientId,jdbcType=VARCHAR},
-            is_main = #{isMain,jdbcType=INTEGER},
-            remark = #{remark,jdbcType=VARCHAR},
-            `status` = #{status,jdbcType=INTEGER},
-            create_by = #{createBy,jdbcType=BIGINT},
-            create_time = #{createTime,jdbcType=TIMESTAMP},
-            update_by = #{updateBy,jdbcType=BIGINT},
-            update_time = #{updateTime,jdbcType=TIMESTAMP},
-            del_flag = #{delFlag,jdbcType=INTEGER}
-        where id = #{id,jdbcType=BIGINT}
-    </update>
-</mapper>

+ 0 - 55
sckw-modules/sckw-example/src/main/resources/mapper/SysUserDao.xml

@@ -1,55 +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.sckw.example.dao.SysUserDao">
-  <resultMap id="BaseResultMap" type="com.sckw.example.model.SysUser">
-    <result column="id" property="id" />
-    <result column="system_type" property="systemType" />
-    <result column="account" property="account" />
-    <result column="password" property="password" />
-    <result column="name" property="name" />
-    <result column="phone" property="phone" />
-    <result column="photo" property="photo" />
-    <result column="email" property="email" />
-    <result column="is_main" property="isMain" />
-    <result column="remark" property="remark" />
-    <result column="status" property="status" />
-    <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="del_flag" property="delFlag" />
-  </resultMap>
-
-  <select id="findByAccount" parameterType="java.util.Map" resultType="com.sckw.example.model.SysUser">
-    SELECT
-      id, system_type systemType, account, password, name, phone, photo, email, is_main isMain,
-      remark, status, create_by createBy, create_time createTime, update_by updateBy, update_time updateTime
-    FROM
-    sys_user
-    where del_flag = 0
-    <if test="systemType != null and systemType != ''">
-      and system_type = #{systemType, jdbcType=VARCHAR}
-    </if>
-    <if test="account != null and account != ''">
-      and account = #{account, jdbcType=VARCHAR}
-    </if>
-  </select>
-
-  <select id="findPage" resultType="java.util.Map" parameterType="java.util.Map" >
-    SELECT
-    id, system_type systemType, account, password, name, phone, photo, email, is_main isMain,
-    remark, status, create_by createBy, create_time createTime, update_by updateBy, update_time updateTime
-    FROM
-    sys_user u
-    where del_flag = 0
-    <if test="systemType != null and systemType != ''">
-      and d.system_type = #{systemType, jdbcType=VARCHAR}
-    </if>
-    <if test="account != null and account != ''">
-      and account = #{account, jdbcType=VARCHAR}
-    </if>
-    ORDER BY create_time desc
-  </select>
-
-
-</mapper>

+ 0 - 61
sckw-modules/sckw-example/src/test/java/com/sckw/example/StudentDaoTest.java

@@ -1,61 +0,0 @@
-package com.sckw.example;
-
-
-import com.sckw.example.model.Student;
-import com.sckw.example.service.StudentService;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import java.util.Date;
-import java.util.List;
-
-@SpringBootTest
-public class StudentDaoTest {
-
-    @Autowired
-    private StudentService studentDao;
-
-    @Test
-    void addOneStudent(){
-//        插入10行
-        Long begtime = System.currentTimeMillis();
-        for (Long count = 0L; count < 1000000; count++) {
-            Student student = new Student();
-            student.setStudentId(count);
-            student.setStudentName("Echo"+count);
-            student.setStudentAge(0);
-            student.setStudentScore(98.5-count);
-            student.setStudentBirthday(new Date());
-            studentDao.addOne(student);
-        }
-        Long enttime = System.currentTimeMillis();
-        System.out.println("------------------"+(enttime - begtime));
-    }
-
-    @Test
-    void deleteOneStudentByStudentId(){
-//        删除id为study_0的学生
-        studentDao.deleteOneById("study_0");
-    }
-
-    @Test
-    void updateOneStudent(){
-//        修改id为study_1的Student年龄为21
-        Student student = studentDao.findOneById("study_1");
-        student.setStudentAge(21);
-        studentDao.updateOne(student);
-
-    }
-
-    @Test
-    void getOneStudentByStudentId(){
-        System.out.println(studentDao.findOneById("study_1"));
-    }
-
-    @Test
-    void getAllStudent(){
-        List<Student> studentList = studentDao.findAll();
-        studentList.forEach(System.out::println);
-    }
-}
-

+ 0 - 152
sckw-modules/sckw-example/src/test/java/com/sckw/example/StudentRepositoryTest.java

@@ -1,152 +0,0 @@
-package com.sckw.example;
-
-import com.sckw.example.model.Student;
-import com.sckw.example.service.StudentRepository;
-import org.junit.jupiter.api.Test;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.data.domain.*;
-import java.util.*;
-
-@SpringBootTest
-public class StudentRepositoryTest {
-
-    @Autowired
-    private StudentRepository studentRepository;
-
-    /**
-     * 插入单条数据
-     */
-    @Test
-    public void insertOne() {
-        Student student = new Student(9L, "tom", 18, 88.2d, new Date());
-        studentRepository.insert(student);
-    }
-
-    /**
-     * 插入多条数据
-     */
-    @Test
-    public void insertMany() {
-        List<Student> list = new ArrayList<>();
-        Long begtime = System.currentTimeMillis();
-        for (long i=0; i<1000; i++) {
-            Student student1 = new Student(i, "jerry", 19, 38.2d, new Date());
-            list.add(student1);
-        }
-        studentRepository.insert(list);
-        Long enttime = System.currentTimeMillis();
-        System.out.println("------------------"+(enttime - begtime));
-    }
-
-    /**
-     * 修改数据
-     */
-    @Test
-    public void update() {
-        Optional<Student> op = studentRepository.findById("009");
-        Student student = op.get();
-        student.setStudentAge(222);
-        studentRepository.save(student);
-    }
-
-    /**
-     * 查询数据
-     */
-    @Test
-    public void query() {
-        Long begtime = System.currentTimeMillis();
-        //根据Id查询单个对象
-        Optional<Student> stuOp = studentRepository.findById("0000");
-        System.out.println(stuOp.get());
-
-        //根据字段查询单个对象
-        Student student = new Student();
-        student.setStudentAge(19);
-        Optional<Student> stuOp1 = studentRepository.findOne(Example.of(student));
-        System.out.println(stuOp1.get());
-
-        //根据id列表查询多个对象
-        Iterable<Student> itStu = studentRepository.findAllById(Arrays.asList(new String[]{"001", "002"}));
-        Iterator<Student> itor = itStu.iterator();
-//        while (itor.hasNext())
-//            System.out.println(itor.next());
-
-        //查询所有
-        List<Student> all = studentRepository.findAll();
-
-        //查询所有并排序
-        List<Student> all1 = studentRepository.findAll(Sort.by(Sort.Order.desc("studentId"), Sort.Order.asc("studentName")));
-//        for (Student stu : all1)
-//            System.out.println(stu);
-
-        System.out.println("0------------------:"+all1.size());
-
-        //根据条件查询所有并排序
-        Student student1 = new Student();
-        student1.setStudentName("tom");
-        List<Student> all2 = studentRepository.findAll(Example.of(student1), Sort.by(Sort.Order.desc("studentId"), Sort.Order.asc("studentName")));
-//        for (Student stu : all2)
-//            System.out.println(stu);
-
-
-
-        //根据条件查询所有并排序,且分页
-        Pageable pageable = PageRequest.of(0, 2);
-        Page<Student> all3 = studentRepository.findAll(pageable);
-        List<Student> content = all3.getContent();
-//        for (Student stu : content)
-//            System.out.println(stu);
-
-        System.out.println("1------------------:"+content.size());
-        Long enttime = System.currentTimeMillis();
-        System.out.println("2------------------:"+(enttime - begtime));
-    }
-
-    /**
-     * 其他操作
-     */
-    @Test
-    public void other() {
-        //count
-        long count = studentRepository.count();
-        System.out.println(count);
-        Student student = new Student();
-        student.setStudentAge(18);
-        long count1 = studentRepository.count(Example.of(student));
-        System.out.println(count1);
-
-        //exists
-        boolean exists = studentRepository.exists(Example.of(student));
-        System.out.println(exists);
-        boolean b = studentRepository.existsById("001");
-        System.out.println(b);
-    }
-
-
-    /**
-     * 删除操作
-     */
-    @Test
-    public void remove() {
-        //根据id删除单个对象
-        studentRepository.deleteById("001");
-
-        //根据字段删除
-        Student student = new Student();
-        student.setStudentAge(20);
-        studentRepository.delete(student);
-
-        //删除所有
-        studentRepository.deleteAll();
-
-        //根据字段删除多个
-        Student student1 = new Student();
-        student1.setStudentName("jerry");
-        List<Student> list = new ArrayList<>();
-        list.add(student);
-        list.add(student1);
-        studentRepository.deleteAll(list);
-    }
-}
-