publish 2.0.6

# Conflicts:
#	springboot-ademo/src/main/java/com/tiesheng/demo/controller/TestController.java

CHANGELOG.md

@@ -1,3 +1,12 @@
+## 2.0.0.rc46
+
+现在导入导出都接入底层流程，无需新增接口，只需要实现接口即可。
+
+- 过程日志不再和操作日志同时存在
+- 过程日志新增params参数
+- 通过实现*TsImportHandler*接口编写导入逻辑
+- 通过实现*TsExportHandler*接口编写导出逻辑
+
 ## 2.0.0.rc4
 
 - perf：TsTokenConfig不在提供静态方法

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.tiesheng.springboot-parent</groupId>
     <artifactId>springboot-parent</artifactId>
-    <version>2.0.0.rc42</version>
+    <version>2.0.6</version>
     <packaging>pom</packaging>
     <name>springboot-parent</name>
     <description>杭州铁晟科技有限公司基础依赖</description>
@@ -23,10 +23,8 @@
         <module>springboot-login</module>
         <module>springboot-web</module>
         <module>springboot-util</module>
-        <module>springboot-poi</module>
         <module>springboot-platform</module>
         <module>springboot-message</module>
-        <module>springboot-encrypt</module>
         <module>springboot-annotation</module>
         <module>springboot-role</module>
     </modules>
@@ -35,6 +33,8 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+
+        <hutool.version>5.8.31</hutool.version>
     </properties>
 
     <developers>
@@ -58,61 +58,49 @@
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-database</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-login</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-web</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-util</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-platform</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-message</artifactId>
-                <version>2.0.0.rc42</version>
-            </dependency>
-
-            <dependency>
-                <groupId>com.tiesheng.springboot-parent</groupId>
-                <artifactId>springboot-encrypt</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-role</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>
                 <groupId>com.tiesheng.springboot-parent</groupId>
                 <artifactId>springboot-annotation</artifactId>
-                <version>2.0.0.rc42</version>
-            </dependency>
-
-            <dependency>
-                <groupId>com.tiesheng.springboot-parent</groupId>
-                <artifactId>springboot-poi</artifactId>
-                <version>2.0.0.rc42</version>
+                <version>2.0.6</version>
             </dependency>
 
             <dependency>

springboot-ademo/pom.xml

@@ -6,11 +6,11 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-ademo</artifactId>
-    <version>2.0.0.rc42</version>
+    <version>2.0.6</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

springboot-ademo/src/main/java/com/tiesheng/demo/config/DemoWebConfigurer.java

@@ -25,7 +25,6 @@ public class DemoWebConfigurer implements TieshengWebConfigurer, TsLoginConfigur
         RequestUserInfo info = new RequestUserInfo();
         info.setId(tokenBean.getId());
         info.setName(tokenBean.getExtra());
-        info.setData(info);
         return info;
     }
 

springboot-ademo/src/main/java/com/tiesheng/demo/controller/TestController.java

@@ -1,35 +1,41 @@
 package com.tiesheng.demo.controller;
 
-import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.date.TimeInterval;
+import cn.hutool.core.io.FileUtil;
 import cn.hutool.log.LogFactory;
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.context.AnalysisContext;
 import com.alibaba.excel.read.listener.ReadListener;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.tiesheng.annotation.role.RoleAuthority;
 import com.tiesheng.annotation.token.TokenIgnore;
 import com.tiesheng.database.config.DbBackupConfig;
 import com.tiesheng.demo.pojos.JsonTest;
 import com.tiesheng.demo.pojos.PoiBean;
-import com.tiesheng.demo.pojos.TestFile;
 import com.tiesheng.platform.config.ding.PlatformDingConfig;
 import com.tiesheng.platform.config.ding.bean.DingUserInfo;
 import com.tiesheng.util.config.EncryptConfig;
 import com.tiesheng.util.config.GlobalConfig;
 import com.tiesheng.util.config.Ip2regionConfig;
 import com.tiesheng.util.config.TsTokenConfig;
+import com.tiesheng.util.exception.ApiException;
 import com.tiesheng.util.pojos.ApiResp;
 import com.tiesheng.util.pojos.FileUploadPath;
 import com.tiesheng.util.service.TsCacheService;
+import com.tiesheng.util.service.http.OkHttpUtil;
 import com.tiesheng.web.service.CoreLogService;
+import okhttp3.Request;
+import okhttp3.Response;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
 
 import javax.servlet.http.HttpServletResponse;
 import java.io.File;
-import java.util.List;
 import java.util.function.Consumer;
 
 /**
@@ -67,7 +73,9 @@ public class TestController {
     @RequestMapping("/redirect")
     @TokenIgnore
     @RoleAuthority("redirect")
-    public ApiResp<JsonTest> redirect(@RequestBody JsonTest dto, HttpServletResponse response) {
+    public ApiResp<JsonTest> redirect(HttpServletResponse response) {
+
+        encryptConfig.passwdCreate("111111@Zz", "");
 
         JsonTest jsonTest = new JsonTest();
         jsonTest.setNow(DateUtil.date());
@@ -76,7 +84,8 @@ public class TestController {
         String jsonString = JSON.toJSONString(jsonTest);
         LogFactory.get().info(jsonString);
 
-        LogFactory.get().info(JSON.toJSONString(dto));
+        String s = OkHttpUtil.get("http://toolbox.tieshengkeji.com/test/login/23232/3232");
+        LogFactory.get().info(s);
 
 //        ArrayList<String> strings = CollUtil.newArrayList("11111", "22222");
 //        coreLogService.addProcess("fdfd", strings, new ProcessImportConsumer<String>() {
@@ -154,16 +163,6 @@ public class TestController {
         return ApiResp.respOK(search);
     }
 
-    @RequestMapping("desensitize")
-    @TokenIgnore
-    public ApiResp<List<TestFile>> desensitize() {
-        TestFile file = new TestFile("11111");
-        file.setTest("111111");
-        TestFile file1 = new TestFile("22222");
-        file1.setTest("22222");
-        return ApiResp.respOK(CollUtil.newArrayList(file, file1));
-    }
-
 
     @RequestMapping("passwd")
     @TokenIgnore
@@ -201,4 +200,31 @@ public class TestController {
         return ApiResp.respOK("");
     }
 
+
+    @GetMapping("getwxacode")
+    @TokenIgnore
+    public ApiResp<String> getwxacode() {
+        String id = "test_1111111";
+        FileUploadPath path = FileUploadPath.random("png");
+        JSONObject paramJson = new JSONObject();
+        paramJson.put("page", "pages/login/index");
+        paramJson.put("scene", "no=" + id);
+        paramJson.put("env_version", "develop");
+        paramJson.put("width", 430);
+        paramJson.put("is_hyaline", false);
+        paramJson.put("auto_color", false);
+        FileUploadPath file = FileUploadPath.file(id + ".png");
+        try {
+            Request request = OkHttpUtil.ofPost("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" +
+                            "83_7xqG36kdgwuf8zzWLY3jtz7bg4ucziN-0oxbE0X9zBzwbjZ4S4Ss2RM9uHeSIcRp2K-wEp6MLzWhqo2AXj0Jpzd6IiJdUsRxqdHPvEWqAdOgt83vzZwdDf7tZBkGNGeAFASZS",
+                    paramJson);
+            Response execute1 = OkHttpUtil.ofHttpClient().build().newCall(request).execute();
+            FileUtil.writeFromStream(execute1.body().byteStream(), file.getAbsolutePath());
+            execute1.close();
+        } catch (Exception e) {
+            throw new ApiException("每分钟最多生成5000个二维码，请稍后再试！");
+        }
+        return ApiResp.respOK(path.getHttpPath());
+    }
+
 }

springboot-ademo/src/main/java/com/tiesheng/demo/pojos/TestFile.java

@@ -1,21 +0,0 @@
-package com.tiesheng.demo.pojos;
-
-import com.tiesheng.poi.pojos.PoiWriteBase;
-
-
-public class TestFile extends TestParent implements PoiWriteBase {
-
-    private String name;
-
-    public TestFile(String name) {
-        this.name = name;
-    }
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name;
-    }
-}

springboot-ademo/src/main/java/com/tiesheng/demo/pojos/TestParent.java

@@ -1,31 +0,0 @@
-package com.tiesheng.demo.pojos;
-
-import com.tiesheng.poi.pojos.PoiWriteBase;
-
-
-public class TestParent implements PoiWriteBase {
-
-    private String id;
-
-    private String test;
-
-    ///////////////////////////////////////////////////////////////////////////
-    // setter、getter
-    ///////////////////////////////////////////////////////////////////////////
-
-    public String getId() {
-        return id;
-    }
-
-    public void setId(String id) {
-        this.id = id;
-    }
-
-    public String getTest() {
-        return test;
-    }
-
-    public void setTest(String test) {
-        this.test = test;
-    }
-}

springboot-ademo/src/main/java/com/tiesheng/demo/service/UserImportHandler.java

@@ -0,0 +1,39 @@
+package com.tiesheng.demo.service;
+
+import cn.hutool.core.collection.CollUtil;
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.web.pojos.imex.ImportDealDTO;
+import com.tiesheng.web.service.imex.TsImportHandler;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+
+@Service
+public class UserImportHandler implements TsImportHandler<String> {
+
+    @Override
+    public List<String> ready(ImportDealDTO dto, TokenBean token) {
+        return CollUtil.newArrayList("11111");
+    }
+
+    @Override
+    public String getTemplateUrl() {
+        return "/template/xsxxzx_teacher_leader.xlsx";
+    }
+
+    @Override
+    public String getAction() {
+        return "user_import";
+    }
+
+    @Override
+    public int batchHandler(List<String> list) {
+        return 0;
+    }
+
+    @Override
+    public String getResultFile() {
+        return "";
+    }
+}

springboot-annotation/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-annotation</artifactId>

springboot-database/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-database</artifactId>

springboot-encrypt/pom.xml

@@ -1,40 +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">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>com.tiesheng.springboot-parent</groupId>
-        <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
-    </parent>
-
-    <artifactId>springboot-encrypt</artifactId>
-
-    <properties>
-        <maven.compiler.source>8</maven.compiler.source>
-        <maven.compiler.target>8</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    </properties>
-
-    <dependencies>
-
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-web</artifactId>
-            <scope>provided</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>com.tiesheng.springboot-parent</groupId>
-            <artifactId>springboot-util</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>com.tiesheng.springboot-parent</groupId>
-            <artifactId>springboot-annotation</artifactId>
-        </dependency>
-
-    </dependencies>
-
-</project>

springboot-encrypt/src/main/java/com/tiesheng/encrypt/EncryptAutoConfigurer.java

@@ -1,10 +0,0 @@
-package com.tiesheng.encrypt;
-
-
-import org.springframework.context.annotation.ComponentScan;
-
-@ComponentScan({
-        "com.tiesheng.encrypt.**.*",
-})
-public class EncryptAutoConfigurer {
-}

springboot-login/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-login</artifactId>

springboot-login/src/main/java/com/tiesheng/login/controller/LoginController.java

@@ -65,7 +65,7 @@ public class LoginController {
     @OperationIgnore
     public void uniqueIndex(UniqueIndexDTO dto, HttpServletResponse response) {
         if (tsTokenConfig.isValidLoginSign() && !dto.validSign()) {
-            corePlatformUniqueService.onSignError(response);
+            corePlatformUniqueService.redirect(null, dto.getTo(), dto.getExtra(), response);
             return;
         }
 
@@ -86,7 +86,7 @@ public class LoginController {
     public ApiResp<String> uniqueIndex(@RequestBody UniqueIndexDTO dto) {
         TokenBean tokenBean = corePlatformUniqueService.login(new DoLoginInfo("web_unique_index",
                 dto.getNo(), dto.getPlatform(), dto.getInfo()));
-        if (tokenBean == null || StrUtil.isEmpty(tokenBean.getId())) {
+        if (!TsTokenConfig.validToken(tokenBean)) {
             throw new ApiException("登录失败");
         }
         return ApiResp.respOK(tokenBean.toToken());
@@ -219,7 +219,7 @@ public class LoginController {
 
         WxminiLoginVo loginVo = new WxminiLoginVo();
         loginVo.setOpenid(openid);
-        if (tokenBean != null) {
+        if (TsTokenConfig.validToken(tokenBean)) {
             loginVo.setToken(tokenBean.toToken());
         }
         return ApiResp.respOK(loginVo);

springboot-login/src/main/java/com/tiesheng/login/mapper/CoreLogLoginMapper.java

@@ -2,6 +2,17 @@ package com.tiesheng.login.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.tiesheng.login.pojos.dao.CoreLogLogin;
+import org.apache.ibatis.annotations.Param;
 
 public interface CoreLogLoginMapper extends BaseMapper<CoreLogLogin> {
+
+
+    /**
+     * 获取登录失败的次数
+     *
+     * @param ip
+     * @return
+     */
+    int getLoginErrorTimes(@Param("ip") String ip);
+
 }

springboot-login/src/main/java/com/tiesheng/login/pojos/DoLoginInfo.java

@@ -1,5 +1,9 @@
 package com.tiesheng.login.pojos;
 
+import com.tiesheng.util.ServletKit;
+
+import javax.servlet.http.HttpServletRequest;
+
 public class DoLoginInfo {
 
     private String appId;
@@ -7,12 +11,17 @@ public class DoLoginInfo {
     private String platform;
     private String info;
     private String extra;
+    private String loginIp;
 
     public DoLoginInfo(String appId, String unique, String platform, String info) {
         this.appId = appId;
         this.unique = unique;
         this.platform = platform;
         this.info = info;
+
+        // 设置IP
+        HttpServletRequest request = ServletKit.getRequest();
+        this.loginIp = ServletKit.getClientIP(request);
     }
 
     ///////////////////////////////////////////////////////////////////////////
@@ -58,4 +67,12 @@ public class DoLoginInfo {
     public void setExtra(String extra) {
         this.extra = extra;
     }
+
+    public String getLoginIp() {
+        return loginIp;
+    }
+
+    public void setLoginIp(String loginIp) {
+        this.loginIp = loginIp;
+    }
 }

springboot-login/src/main/java/com/tiesheng/login/pojos/dao/CoreLogLogin.java

@@ -16,13 +16,13 @@ public class CoreLogLogin extends DaoBase {
     private String userId;
 
     /**
-     * 用户id
+     * 用户姓名
      */
     @TableField(value = "user_name")
     private String userName;
 
     /**
-     * ip
+     * 登录方式
      */
     @TableField(value = "platform")
     private String platform;
@@ -39,6 +39,18 @@ public class CoreLogLogin extends DaoBase {
     @TableField(value = "address")
     private String address;
 
+    /**
+     * 登录结果,0否，1是
+     */
+    @TableField(value = "`result`")
+    private Integer result;
+
+    /**
+     * 请求参数
+     */
+    @TableField(value = "params")
+    private String params;
+
     /**
      * 获取用户id
      *
@@ -57,18 +69,38 @@ public class CoreLogLogin extends DaoBase {
         this.userId = userId;
     }
 
+    /**
+     * 获取用户姓名
+     *
+     * @return user_name - 用户姓名
+     */
     public String getUserName() {
         return userName;
     }
 
+    /**
+     * 设置用户姓名
+     *
+     * @param userName 用户姓名
+     */
     public void setUserName(String userName) {
         this.userName = userName;
     }
 
+    /**
+     * 获取登录方式
+     *
+     * @return platform - 登录方式
+     */
     public String getPlatform() {
         return platform;
     }
 
+    /**
+     * 设置登录方式
+     *
+     * @param platform 登录方式
+     */
     public void setPlatform(String platform) {
         this.platform = platform;
     }
@@ -108,4 +140,40 @@ public class CoreLogLogin extends DaoBase {
     public void setAddress(String address) {
         this.address = address;
     }
+
+    /**
+     * 获取登录结果,0否，1是
+     *
+     * @return result - 登录结果,0否，1是
+     */
+    public Integer getResult() {
+        return result;
+    }
+
+    /**
+     * 设置登录结果,0否，1是
+     *
+     * @param result 登录结果,0否，1是
+     */
+    public void setResult(Integer result) {
+        this.result = result;
+    }
+
+    /**
+     * 获取请求参数
+     *
+     * @return params - 请求参数
+     */
+    public String getParams() {
+        return params;
+    }
+
+    /**
+     * 设置请求参数
+     *
+     * @param params 请求参数
+     */
+    public void setParams(String params) {
+        this.params = params;
+    }
 }

springboot-login/src/main/java/com/tiesheng/login/service/CorePlatformUniqueService.java

@@ -1,23 +1,23 @@
 package com.tiesheng.login.service;
 
 import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
 import com.tiesheng.login.mapper.CoreLogLoginMapper;
 import com.tiesheng.login.mapper.CorePlatformUniqueMapper;
 import com.tiesheng.login.pojos.DoLoginInfo;
 import com.tiesheng.login.pojos.RequestUserInfo;
 import com.tiesheng.login.pojos.dao.CoreLogLogin;
 import com.tiesheng.login.pojos.dao.CorePlatformUnique;
-import com.tiesheng.util.ServletKit;
 import com.tiesheng.util.config.Ip2regionConfig;
+import com.tiesheng.util.config.TsTokenConfig;
+import com.tiesheng.util.exception.ApiException;
 import com.tiesheng.util.pojos.TokenBean;
 import com.tiesheng.util.service.TsCacheService;
 import com.tiesheng.util.service.TsServiceBase;
 import com.tiesheng.util.service.role.TsAuthorityHandler;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import java.util.Objects;
 
@@ -35,9 +35,19 @@ public class CorePlatformUniqueService extends TsServiceBase<CorePlatformUniqueM
     TsLoginConfigurer tsLoginConfigurer;
 
 
-    @Transactional(rollbackFor = Exception.class)
+    /**
+     * 登录操作
+     *
+     * @param loginInfo
+     * @return
+     */
     public TokenBean login(DoLoginInfo loginInfo) {
 
+        int loginErrorTimes = coreLogLoginMapper.getLoginErrorTimes(loginInfo.getLoginIp());
+        if (loginErrorTimes > 4) {
+            throw new ApiException("登录失败已达5次，请10分钟后再试");
+        }
+
         CorePlatformUnique platformUnique = getOneByColumn("unique_id", loginInfo.getUnique());
         if (platformUnique == null) {
             platformUnique = new CorePlatformUnique();
@@ -48,24 +58,32 @@ public class CorePlatformUniqueService extends TsServiceBase<CorePlatformUniqueM
         platformUnique.setInfo(loginInfo.getInfo());
         saveOrUpdate(platformUnique);
 
-        String oldUserId = platformUnique.getUserId();
-        TokenBean tokenBean = tsLoginConfigurer.login(platformUnique);
-        if (tokenBean != null) {
+        TokenBean tokenBean = null;
+        String errorMsg = null;
+        try {
+            tokenBean = tsLoginConfigurer.login(platformUnique);
+        } catch (Exception e) {
+            errorMsg = e.getMessage();
+        }
+
+        if (TsTokenConfig.validToken(tokenBean)) {
 
             // 清除授权信息
-            TsCacheService.of().remove(StrUtil.format(TsAuthorityHandler.CACHE_HAS_AUTHORITY,
+            TsCacheService.of().remove(StrUtil.format(TsAuthorityHandler.CACHE_AUTHORITY,
                     tokenBean.getRoleId(), tokenBean.getId()));
 
-            // 添加登录日志
-            addLoginLog(platformUnique, tokenBean);
-
             // 更新唯一值
-            if (!StrUtil.isEmpty(tokenBean.getId()) &&
-                    !Objects.equals(oldUserId, tokenBean.getId())) {
+            String oldUserId = platformUnique.getUserId();
+            if (!Objects.equals(oldUserId, tokenBean.getId())) {
                 platformUnique.setUserId(tokenBean.getId());
                 saveOrUpdate(platformUnique);
             }
+        }
 
+        addLoginLog(tokenBean, loginInfo);
+
+        if (StrUtil.isNotEmpty(errorMsg)) {
+            throw new ApiException(errorMsg);
         }
 
         return tokenBean;
@@ -78,40 +96,37 @@ public class CorePlatformUniqueService extends TsServiceBase<CorePlatformUniqueM
      * @param bean
      */
     public void redirect(TokenBean bean, String to, String extra, HttpServletResponse response) {
-        tsLoginConfigurer.redirect(bean, to, extra, response);
+        if (TsTokenConfig.validToken(bean)) {
+            tsLoginConfigurer.redirect(bean, to, extra, response);
+        } else {
+            tsLoginConfigurer.onLoginError(to, response);
+        }
     }
 
 
-    /**
-     * 签名错误的时候
-     */
-    public void onSignError(HttpServletResponse response) {
-        tsLoginConfigurer.onSignError(response);
-    }
-
-    ///////////////////////////////////////////////////////////////////////////
-    // 登录日志
-    ///////////////////////////////////////////////////////////////////////////
-
     /**
      * 添加登录日志
      *
-     * @param platformUnique
      * @param tokenBean
+     * @param info
      */
-    public void addLoginLog(CorePlatformUnique platformUnique, TokenBean tokenBean) {
-
-        HttpServletRequest request = ServletKit.getRequest();
-        String ip = ServletKit.getClientIP(request);
+    public void addLoginLog(TokenBean tokenBean, DoLoginInfo info) {
 
         CoreLogLogin login = new CoreLogLogin();
-        login.setUserId(tokenBean.getId());
-        login.setPlatform(platformUnique.getPlatform());
+        login.setPlatform(info.getPlatform());
+        login.setParams(JSON.toJSONString(info));
 
-        RequestUserInfo requestUserInfo = tsLoginConfigurer.getCachedUserInfo(tokenBean, true);
-        login.setUserName(requestUserInfo.getName());
+        if (TsTokenConfig.validToken(tokenBean)) {
+            RequestUserInfo requestUserInfo = tsLoginConfigurer.getCachedUserInfo(tokenBean, true);
+            login.setUserId(tokenBean.getId());
+            login.setUserName(requestUserInfo.getName());
+            login.setResult(1);
+        } else {
+            login.setUserName(info.getUnique());
+            login.setResult(0);
+        }
 
-        login.setIp(ip);
+        login.setIp(info.getLoginIp());
         login.setAddress(ip2regionConfig.search(login.getIp()));
         coreLogLoginMapper.insert(login);
     }

springboot-login/src/main/java/com/tiesheng/login/service/TsLoginConfigurer.java

@@ -34,9 +34,9 @@ public interface TsLoginConfigurer {
 
 
     /**
-     * 签名错误的时候
+     * 登录失败的时候
      */
-    default void onSignError(HttpServletResponse response) {
+    default void onLoginError(String to,HttpServletResponse response) {
         ServletKit.write(response, "404", "text");
     }
 

springboot-login/src/main/resources/mapper/CoreLogLoginMapper.xml

@@ -13,9 +13,21 @@
     <result column="platform" jdbcType="VARCHAR" property="platform" />
     <result column="ip" jdbcType="VARCHAR" property="ip" />
     <result column="address" jdbcType="VARCHAR" property="address" />
+    <result column="result" jdbcType="INTEGER" property="result" />
+    <result column="params" jdbcType="LONGVARCHAR" property="params" />
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
-    id, create_time, update_time, is_deleted, user_id, user_name, platform, ip, address
+    id, create_time, update_time, is_deleted, user_id, user_name, platform, ip, address,
+    `result`, params
   </sql>
+
+  <select id="getLoginErrorTimes" resultType="int">
+      select count(1)
+      from core_log_login
+      where ip = #{ip}
+        and result = 0
+        and create_time > date_add(now(), interval -10 minute)
+  </select>
+
 </mapper>

springboot-message/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-message</artifactId>

springboot-platform/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-platform</artifactId>

springboot-platform/src/main/java/com/tiesheng/platform/config/ding/PlatformDingConfig.java

@@ -246,7 +246,7 @@ public class PlatformDingConfig {
         JSONObject object = new JSONObject();
         object.put("dept_id", deptId);
         object.put("cursor", cursor);
-        object.put("size", 100);
+        object.put("size", 200);
 
         return doRequest(service, "https://oapi.dingtalk.com/topapi/v2/user/list",
                 object, new TypeReference<DingResponse<DingUserListVo>>() {

springboot-poi/pom.xml

@@ -1,34 +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">
-    <modelVersion>4.0.0</modelVersion>
-    <parent>
-        <groupId>com.tiesheng.springboot-parent</groupId>
-        <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
-    </parent>
-
-    <artifactId>springboot-poi</artifactId>
-
-    <properties>
-        <maven.compiler.source>8</maven.compiler.source>
-        <maven.compiler.target>8</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    </properties>
-
-    <dependencies>
-        <dependency>
-            <groupId>com.alibaba</groupId>
-            <artifactId>easyexcel</artifactId>
-            <scope>provided</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>com.tiesheng.springboot-parent</groupId>
-            <artifactId>springboot-util</artifactId>
-        </dependency>
-
-    </dependencies>
-
-</project>

springboot-poi/src/main/java/com/tiesheng/poi/pojos/PoiReadBase.java

@@ -1,8 +0,0 @@
-package com.tiesheng.poi.pojos;
-
-/**
- * @author hao
- */
-public interface PoiReadBase {
-
-}

springboot-poi/src/main/java/com/tiesheng/poi/pojos/PoiWriteBase.java

@@ -1,19 +0,0 @@
-package com.tiesheng.poi.pojos;
-
-import com.alibaba.excel.annotation.write.style.*;
-import com.alibaba.excel.enums.poi.HorizontalAlignmentEnum;
-import com.alibaba.excel.enums.poi.VerticalAlignmentEnum;
-
-/**
- * @author hao
- */
-@HeadRowHeight(24)
-@HeadFontStyle(fontHeightInPoints = 13)
-@HeadStyle(horizontalAlignment = HorizontalAlignmentEnum.LEFT)
-@ContentRowHeight(20)
-@ContentFontStyle(fontHeightInPoints = 12)
-@ContentStyle(verticalAlignment = VerticalAlignmentEnum.CENTER)
-@ColumnWidth(20)
-public interface PoiWriteBase {
-
-}

springboot-poi/src/main/java/com/tiesheng/poi/util/PoiReadUtil.java

@@ -1,23 +0,0 @@
-package com.tiesheng.poi.util;
-
-import com.alibaba.excel.EasyExcel;
-import com.alibaba.excel.read.listener.ReadListener;
-import com.tiesheng.poi.pojos.PoiReadBase;
-
-import java.io.File;
-
-public class PoiReadUtil {
-
-
-    /**
-     * 读取文件
-     *
-     * @param file
-     * @param readListener
-     * @return
-     */
-    public static <T extends PoiReadBase> void read(File file, Class<T> tClass, ReadListener<T> readListener) {
-        EasyExcel.read(file, tClass, readListener).autoTrim(true).headRowNumber(1).sheet().doRead();
-    }
-
-}

springboot-poi/src/main/java/com/tiesheng/poi/util/PoiWriteUtil.java

@@ -1,38 +0,0 @@
-package com.tiesheng.poi.util;
-
-import com.alibaba.excel.EasyExcel;
-import com.alibaba.excel.annotation.write.style.*;
-import com.alibaba.excel.enums.poi.HorizontalAlignmentEnum;
-import com.alibaba.excel.enums.poi.VerticalAlignmentEnum;
-import com.alibaba.excel.support.ExcelTypeEnum;
-import com.tiesheng.poi.pojos.PoiWriteBase;
-
-import java.util.List;
-
-/**
- * @author hao
- */
-@HeadRowHeight(24)
-@HeadFontStyle(fontHeightInPoints = 13)
-@HeadStyle(horizontalAlignment = HorizontalAlignmentEnum.LEFT)
-@ContentRowHeight(20)
-@ContentFontStyle(fontHeightInPoints = 12)
-@ContentStyle(verticalAlignment = VerticalAlignmentEnum.CENTER)
-@ColumnWidth(20)
-public class PoiWriteUtil {
-
-
-    /**
-     * 导出数据
-     *
-     * @param list
-     * @return
-     */
-    public static <T extends PoiWriteBase> boolean export(List<T> list, Class<T> tClass, String absPath, String sheetName) {
-        EasyExcel.write(absPath, tClass).excelType(ExcelTypeEnum.XLSX)
-                .sheet(sheetName)
-                .doWrite(list);
-        return true;
-    }
-
-}

springboot-role/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-role</artifactId>

springboot-role/src/main/java/com/tiesheng/role/controller/CommRoleController.java

@@ -3,10 +3,13 @@ package com.tiesheng.role.controller;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.tiesheng.role.pojos.dao.CoreRoleAuthority;
+import com.tiesheng.role.pojos.dao.CoreRoleGroup;
 import com.tiesheng.role.pojos.dao.CoreRoleServer;
 import com.tiesheng.role.pojos.dto.OwnerMenuDTO;
 import com.tiesheng.role.pojos.dto.OwnerPointDTO;
+import com.tiesheng.role.pojos.vo.GroupTypeDTO;
 import com.tiesheng.role.pojos.vo.ServiceMenuVO;
 import com.tiesheng.role.service.CoreRoleService;
 import com.tiesheng.util.pojos.ApiResp;
@@ -101,4 +104,24 @@ public class CommRoleController {
     }
 
 
+    /**
+     * 角色、职位列表
+     *
+     * @return
+     */
+    @GetMapping("/group")
+    public ApiResp<List<CoreRoleGroup>> groupPage(@Valid GroupTypeDTO dto) {
+
+        QueryWrapper<CoreRoleGroup> queryWrapper = new QueryWrapper<CoreRoleGroup>()
+                .eq("is_deleted", 0)
+                .eq(StrUtil.isNotEmpty(dto.getType()), "type", dto.getType())
+                .orderByAsc("sort");
+        dto.likeColumns(queryWrapper, "name");
+
+        Page<CoreRoleGroup> page = dto.pageObj();
+        coreRoleService.page(page, queryWrapper);
+
+        return ApiResp.respOK(page.getRecords(), page.getTotal());
+    }
+
 }

springboot-role/src/main/java/com/tiesheng/role/service/CoreRoleService.java

@@ -138,7 +138,6 @@ public class CoreRoleService extends TsServiceBase<CoreRoleGroupMapper, CoreRole
             coreRoleGroupRxMapper.batchInsert(list);
             onRoleChange(dto.getId(), "");
         }
-
     }
 
 
@@ -148,13 +147,16 @@ public class CoreRoleService extends TsServiceBase<CoreRoleGroupMapper, CoreRole
      * @param roleUser
      */
     public void roleUserUpdate(CoreRoleUser roleUser) {
+        Validator.validateNotEmpty(roleUser.getType(), "请选择授权方式");
+        Validator.validateNotEmpty(roleUser.getTypeId(), "请选择授权" + (Objects.equals(roleUser.getType(), "menu") ? "菜单" : "职位"));
+
         if (StrUtil.isNotEmpty(roleUser.getId())) {
             coreRoleUserMapper.updateById(roleUser);
         } else {
             coreRoleUserMapper.insert(roleUser);
         }
 
-        onRoleChange(roleUser.getTypeId(), roleUser.getUserId());
+        onRoleChange("", roleUser.getUserId());
     }
 
 
@@ -171,7 +173,7 @@ public class CoreRoleService extends TsServiceBase<CoreRoleGroupMapper, CoreRole
         coreRoleUser.setIsDeleted(1);
         coreRoleUserMapper.updateById(coreRoleUser);
 
-        onRoleChange(coreRoleUser.getTypeId(), coreRoleUser.getUserId());
+        onRoleChange("", coreRoleUser.getUserId());
     }
 
 
@@ -179,8 +181,13 @@ public class CoreRoleService extends TsServiceBase<CoreRoleGroupMapper, CoreRole
      * 当授权发生变化时
      */
     public void onRoleChange(String roleId, String userId) {
-        TsCacheService.of().keys(StrUtil.format(TsAuthorityHandler.CACHE_HAS_AUTHORITY,
-                roleId, userId)).forEach(key -> TsCacheService.of().remove(key));
+        if (StrUtil.isEmpty(roleId)) {
+            TsCacheService.of().keys(StrUtil.replace(TsAuthorityHandler.CACHE_AUTHORITY,
+                    ":{}", "")).forEach(key -> TsCacheService.of().remove(key));
+        } else {
+            TsCacheService.of().keys(StrUtil.format(TsAuthorityHandler.CACHE_AUTHORITY,
+                    roleId, userId)).forEach(key -> TsCacheService.of().remove(key));
+        }
     }
 
 

springboot-role/src/main/java/com/tiesheng/role/service/RoleAuthorityHandler.java

@@ -60,6 +60,7 @@ public class RoleAuthorityHandler implements TsAuthorityHandler {
             groupAuthority.setParent(parentId);
             groupAuthority.setVersion(version);
             groupAuthority.setSource("auto");
+            groupAuthority.setDeps("[]");
             groupAuthority.setId(StrUtil.join("_", groupAuthority.getService(), groupAuthority.getNo()));
             list.add(groupAuthority);
         }

springboot-util/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-util</artifactId>
@@ -15,7 +15,6 @@
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <hutool.version>5.8.31</hutool.version>
     </properties>
 
     <dependencies>

springboot-util/src/main/java/com/tiesheng/util/config/EncryptConfig.java

@@ -1,15 +1,12 @@
 package com.tiesheng.util.config;
 
 import cn.hutool.core.codec.Base64;
-import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.RandomUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
 import cn.hutool.crypto.SmUtil;
 import cn.hutool.crypto.symmetric.SM4;
-import com.tiesheng.util.ServletKit;
 import com.tiesheng.util.exception.ApiException;
-import com.tiesheng.util.service.TsCacheService;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Configuration;
 
@@ -31,6 +28,7 @@ public class EncryptConfig {
     private String key = "WmdUzPJXbngVNiaSsQrihg==";
     private Integer saltSize = 8;
     private boolean body = false;
+    private String pwdPatten = "^(?![A-Za-z0-9]+$)(?![a-z0-9\\W]+$)(?![A-Za-z\\W]+$)(?![A-Z0-9\\W]+$)[a-zA-Z0-9\\W]{8,}$";
 
     public EncryptConfig() {
         sm4 = SmUtil.sm4(Base64.decode(getKey()));
@@ -76,25 +74,13 @@ public class EncryptConfig {
         if (StrUtil.isEmpty(salt) || StrUtil.length(salt) != getSaltSize()) {
             salt = RandomUtil.randomString(saltSize);
         }
-        if (!passwdComplexity(inputPasswd)) {
-            throw new ApiException("需要包含数字、大小写字母、特殊符号，且长度不低于8位");
+        if (!inputPasswd.matches(getPwdPatten())) {
+            throw new ApiException("密码复杂度不够，请重新设置");
         }
         return encrypt(salt + SecureUtil.sha1(salt + inputPasswd));
     }
 
 
-    /**
-     * 复杂度校验
-     *
-     * @param inputPasswd
-     * @return
-     */
-    public boolean passwdComplexity(String inputPasswd) {
-        String password = "^(?![A-Za-z0-9]+$)(?![a-z0-9\\W]+$)(?![A-Za-z\\W]+$)(?![A-Z0-9\\W]+$)[a-zA-Z0-9\\W]{8,}$";
-        return inputPasswd.matches(password);
-    }
-
-
     /**
      * 密码校验
      *
@@ -104,12 +90,6 @@ public class EncryptConfig {
         String salt = decrypt(encrypted).substring(0, saltSize);
         String inputEncrypted = passwdCreate(inputPasswd, salt);
         if (!StrUtil.equals(inputEncrypted, encrypted)) {
-            String clientIp = "passwdVerify_" + ServletKit.getClientIP();
-            int num = NumberUtil.parseInt(TsCacheService.of().get(clientIp, -1));
-            if (num > 5) {
-                throw new ApiException("登录失败已达6次，请10分钟后再试");
-            }
-            TsCacheService.of().put(clientIp, String.valueOf(num + 1), 10 * 60);
             throw new ApiException("账号或密码错误");
         }
     }
@@ -142,4 +122,12 @@ public class EncryptConfig {
     public void setBody(boolean body) {
         this.body = body;
     }
+
+    public String getPwdPatten() {
+        return pwdPatten;
+    }
+
+    public void setPwdPatten(String pwdPatten) {
+        this.pwdPatten = pwdPatten;
+    }
 }

springboot-util/src/main/java/com/tiesheng/util/config/TsTokenConfig.java

@@ -66,6 +66,16 @@ public class TsTokenConfig {
         return validToken(token, thrExp);
     }
 
+    /**
+     * token是否有效
+     *
+     * @param token
+     * @return
+     */
+    public static boolean validToken(TokenBean token) {
+        return token != null && StrUtil.isNotEmpty(token.getId());
+    }
+
 
     /**
      * 验证token

springboot-util/src/main/java/com/tiesheng/util/service/TsCacheService.java

@@ -68,11 +68,11 @@ public class TsCacheService {
     /**
      * 获取key
      *
-     * @param pattern
+     * @param prefix
      * @return
      */
-    public Set<String> keys(String pattern) {
-        return tsCacheHandler.keys(pattern);
+    public Set<String> keys(String prefix) {
+        return tsCacheHandler.keys(prefix);
     }
 
 

springboot-util/src/main/java/com/tiesheng/util/service/role/TsAuthorityHandler.java

@@ -9,7 +9,7 @@ import java.util.List;
 @Service
 public interface TsAuthorityHandler {
 
-    String CACHE_HAS_AUTHORITY = "CACHE:HAS_AUTHORITY:{}:{}";
+    String CACHE_AUTHORITY = "CACHE:AUTHORITY:{}:{}";
 
 
     /**

springboot-web/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.tiesheng.springboot-parent</groupId>
         <artifactId>springboot-parent</artifactId>
-        <version>2.0.0.rc42</version>
+        <version>2.0.6</version>
     </parent>
 
     <artifactId>springboot-web</artifactId>
@@ -49,11 +49,6 @@
             <artifactId>springboot-database</artifactId>
         </dependency>
 
-        <dependency>
-            <groupId>com.tiesheng.springboot-parent</groupId>
-            <artifactId>springboot-poi</artifactId>
-        </dependency>
-
         <dependency>
             <groupId>com.tiesheng.springboot-parent</groupId>
             <artifactId>springboot-login</artifactId>
@@ -64,11 +59,6 @@
             <artifactId>springboot-message</artifactId>
         </dependency>
 
-        <dependency>
-            <groupId>com.tiesheng.springboot-parent</groupId>
-            <artifactId>springboot-encrypt</artifactId>
-        </dependency>
-
     </dependencies>
 
 </project>

springboot-web/src/main/java/com/tiesheng/web/EnableTieshengWeb.java

@@ -1,7 +1,6 @@
 package com.tiesheng.web;
 
 import com.tiesheng.database.DatabaseAutoConfigurer;
-import com.tiesheng.encrypt.EncryptAutoConfigurer;
 import com.tiesheng.message.MessageAutoConfigurer;
 import com.tiesheng.platform.PlatformAutoConfigurer;
 import com.tiesheng.util.UtilAutoConfigurer;
@@ -21,7 +20,6 @@ import java.lang.annotation.*;
         MessageAutoConfigurer.class,
         WebAutoConfigurer.class,
         DatabaseAutoConfigurer.class,
-        EncryptAutoConfigurer.class,
         PlatformAutoConfigurer.class,
 })
 public @interface EnableTieshengWeb {

springboot-web/src/main/java/com/tiesheng/web/config/encrypt/DecryptRequestBodyAdvice.java

@@ -1,4 +1,4 @@
-package com.tiesheng.encrypt.config;
+package com.tiesheng.web.config.encrypt;
 
 import cn.hutool.core.io.IoUtil;
 import cn.hutool.core.util.CharsetUtil;

springboot-web/src/main/java/com/tiesheng/web/config/encrypt/EncryptResponseBodyAdvice.java

@@ -1,4 +1,4 @@
-package com.tiesheng.encrypt.config;
+package com.tiesheng.web.config.encrypt;
 
 import cn.hutool.core.annotation.AnnotationUtil;
 import cn.hutool.log.LogFactory;

springboot-web/src/main/java/com/tiesheng/web/config/role/RoleAuthorityAspect.java

@@ -56,7 +56,7 @@ public class RoleAuthorityAspect {
 
         HttpServletRequest request = ServletKit.getRequest();
         TokenBean tokenBean = tsTokenConfig.validToken(request, true);
-        String cacheKey = StrUtil.format(TsAuthorityHandler.CACHE_HAS_AUTHORITY, tokenBean.getRoleId(), tokenBean.getId());
+        String cacheKey = StrUtil.format(TsAuthorityHandler.CACHE_AUTHORITY, tokenBean.getRoleId(), tokenBean.getId());
         List<String> authorityList = StrUtil.split(TsCacheService.of().get(cacheKey), ";")
                 .stream().filter(StrUtil::isNotEmpty).collect(Collectors.toList());
         if (CollUtil.isEmpty(authorityList)) {

springboot-web/src/main/java/com/tiesheng/web/config/role/RoleAuthorityCreator.java

@@ -5,12 +5,12 @@ import cn.hutool.core.date.DateUtil;
 import com.tiesheng.annotation.role.RoleAuthority;
 import com.tiesheng.util.service.role.TsAuthorityHandler;
 import org.springframework.aop.support.AopUtils;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationListener;
 import org.springframework.context.event.ContextRefreshedEvent;
 import org.springframework.stereotype.Service;
 
-import javax.annotation.Resource;
 import java.lang.reflect.Method;
 import java.util.ArrayList;
 import java.util.Date;
@@ -20,12 +20,17 @@ import java.util.Map;
 @Service
 public class RoleAuthorityCreator implements ApplicationListener<ContextRefreshedEvent> {
 
-    @Resource
+    @Autowired(required = false)
     TsAuthorityHandler tsAuthorityHandler;
 
 
     @Override
     public void onApplicationEvent(ContextRefreshedEvent event) {
+
+        if (tsAuthorityHandler == null) {
+            return;
+        }
+
         ApplicationContext applicationContext = event.getApplicationContext();
         Map<String, Object> beansOfType = applicationContext.getBeansWithAnnotation(RoleAuthority.class);
 

springboot-web/src/main/java/com/tiesheng/web/config/template/TieshengTemplateHandler.java

@@ -1,34 +0,0 @@
-package com.tiesheng.web.config.template;
-
-import com.tiesheng.web.pojos.dto.TemplateDealDTO;
-import org.springframework.stereotype.Service;
-
-@Service
-public class TieshengTemplateHandler implements ToolTemplateHandler {
-    @Override
-    public String handler(TemplateDealDTO dto) {
-        return "";
-    }
-
-    @Override
-    public String getTemplateUrl() {
-        return "";
-    }
-
-    @Override
-    public Object getParms(Object params) {
-        return "";
-    }
-
-
-    @Override
-    public String getAction() {
-        return "";
-    }
-
-    @Override
-    public int getSort() {
-        return 0;
-    }
-
-}

springboot-web/src/main/java/com/tiesheng/web/config/template/ToolTemplateHandler.java

@@ -1,54 +0,0 @@
-package com.tiesheng.web.config.template;
-
-import cn.hutool.core.util.StrUtil;
-import com.tiesheng.web.pojos.dto.TemplateDealDTO;
-import org.springframework.stereotype.Service;
-
-@Service
-public interface ToolTemplateHandler {
-
-
-    /**
-     * 处理对象
-     *
-     * @param dto
-     * @return
-     */
-    String handler(TemplateDealDTO dto);
-
-
-    /**
-     * 获取模版地址
-     *
-     * @return
-     */
-    String getTemplateUrl();
-
-    Object getParms(Object params);
-
-
-    /**
-     * 动作说明（唯一）
-     *
-     * @return
-     */
-    String getAction();
-
-
-    /**
-     * 排序，如果action相同，只会使用sort大的来处理
-     *
-     * @return
-     */
-    int getSort();
-
-    /**
-     * 获取模版ID
-     *
-     * @return
-     */
-    default String getTeamplateId() {
-        return StrUtil.format("{}_{}", getAction(), getSort());
-    }
-
-}

springboot-web/src/main/java/com/tiesheng/web/controller/comm/CommWebController.java

@@ -62,6 +62,7 @@ public class CommWebController {
         QueryWrapper<CoreConfigEnum> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("is_deleted", 0);
         queryWrapper.eq("type", dto.getType());
+        queryWrapper.orderByAsc("type", "sort");
         List<CoreConfigEnum> selectList = coreConfigService.getEnumMapper().selectList(queryWrapper);
 
         return ApiResp.respOK(selectList);

springboot-web/src/main/java/com/tiesheng/web/controller/comm/ToolController.java

@@ -4,19 +4,33 @@ package com.tiesheng.web.controller.comm;
 import cn.hutool.captcha.LineCaptcha;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.tiesheng.annotation.operation.OperationIgnore;
 import com.tiesheng.annotation.token.TokenIgnore;
-import com.tiesheng.util.service.TsCacheService;
-import com.tiesheng.web.config.template.ToolTemplateHandler;
-import com.tiesheng.web.pojos.dto.*;
-import com.tiesheng.web.pojos.vo.TemplateInfoVO;
-import com.tiesheng.web.pojos.vo.PicVerifyVo;
-import com.tiesheng.web.service.FileUploadService;
 import com.tiesheng.util.exception.ApiException;
 import com.tiesheng.util.pojos.ApiResp;
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.util.service.TsCacheService;
+import com.tiesheng.web.pojos.dao.CoreLogProcess;
+import com.tiesheng.web.pojos.dto.ChunkCheckDTO;
+import com.tiesheng.web.pojos.dto.ChunkMergeDTO;
+import com.tiesheng.web.pojos.dto.ChunkStartDTO;
+import com.tiesheng.web.pojos.dto.ImageCodeDTO;
+import com.tiesheng.web.pojos.imex.ExportDealDTO;
+import com.tiesheng.web.pojos.imex.ImportDealDTO;
+import com.tiesheng.web.pojos.imex.ImportInfoDTO;
+import com.tiesheng.web.pojos.imex.ImportInfoVO;
+import com.tiesheng.web.pojos.vo.PicVerifyVo;
+import com.tiesheng.web.service.CoreLogService;
+import com.tiesheng.web.service.FileUploadService;
+import com.tiesheng.web.service.imex.TsExportHandler;
+import com.tiesheng.web.service.imex.TsImportHandler;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
+import javax.validation.Valid;
 import java.util.List;
 import java.util.Objects;
 import java.util.stream.Collectors;
@@ -35,7 +49,11 @@ public class ToolController {
     @Autowired
     FileUploadService fileUploadService;
     @Autowired
-    List<ToolTemplateHandler> templateHandlerList;
+    List<TsImportHandler> importHandlers;
+    @Autowired
+    List<TsExportHandler> exportHandlers;
+    @Autowired
+    CoreLogService coreLogService;
 
 
     /**
@@ -124,40 +142,102 @@ public class ToolController {
     }
 
 
-    @TokenIgnore
-    @GetMapping("/template/info")
-    public ApiResp<TemplateInfoVO> templateInfo(TemplateInfoDTO dto) {
+    ///////////////////////////////////////////////////////////////////////////
+    // import
+    ///////////////////////////////////////////////////////////////////////////
 
-        List<ToolTemplateHandler> collect = templateHandlerList.stream()
-                .filter(it -> Objects.equals(it.getAction(), dto.getAction()))
-                .sorted((it, it2) -> it2.getSort() - it.getSort())
-                .collect(Collectors.toList());
-        if (CollUtil.isEmpty(collect)) {
-            throw new ApiException("没有找到对应的模版");
+    @TokenIgnore
+    @GetMapping("/imex/info")
+    public ApiResp<ImportInfoVO> importInfo(@Valid ImportInfoDTO dto) {
+
+        ImportInfoVO template = new ImportInfoVO();
+
+        if (Objects.equals(dto.getType(), "import")) {
+            List<TsImportHandler> collect = importHandlers.stream()
+                    .filter(it -> Objects.equals(it.getAction(), dto.getAction()))
+                    .sorted((it, it2) -> it2.getSort() - it.getSort())
+                    .collect(Collectors.toList());
+
+            if (CollUtil.isNotEmpty(collect)) {
+                TsImportHandler toolTemplateHandler = collect.get(0);
+                template.setTemplateUrl(toolTemplateHandler.getTemplateUrl());
+                template.setImexId(toolTemplateHandler.getImexId());
+            }
+        } else if (Objects.equals(dto.getType(), "export")) {
+            List<TsExportHandler> collect = exportHandlers.stream()
+                    .filter(it -> Objects.equals(it.getAction(), dto.getAction()))
+                    .sorted((it, it2) -> it2.getSort() - it.getSort())
+                    .collect(Collectors.toList());
+
+            if (CollUtil.isNotEmpty(collect)) {
+                TsExportHandler toolTemplateHandler = collect.get(0);
+                template.setImexId(toolTemplateHandler.getImexId());
+            }
         }
 
-        ToolTemplateHandler toolTemplateHandler = collect.get(0);
-
-        TemplateInfoVO template = new TemplateInfoVO();
-        template.setTemplateUrl(toolTemplateHandler.getTemplateUrl());
-        template.setParams(toolTemplateHandler.getParms(dto.getParams()));
-        template.setTemplateId(toolTemplateHandler.getTeamplateId());
+        if (StrUtil.isEmpty(template.getImexId())) {
+            throw new ApiException("没有找到对应的模版");
+        }
 
         return ApiResp.respOK(template);
     }
 
-    @TokenIgnore
-    @PostMapping("/template/deal")
-    public ApiResp<String> templateDeal(@RequestBody TemplateDealDTO dto) {
 
-        List<ToolTemplateHandler> collect = templateHandlerList.stream().
-                filter(it -> Objects.equals(it.getTeamplateId(), dto.getTemplateId()))
+    @TokenIgnore
+    @OperationIgnore
+    @PostMapping("/import/deal")
+    public ApiResp<String> importDeal(@RequestBody @Valid ImportDealDTO dto, TokenBean token) {
+
+        List<TsImportHandler> collect = importHandlers.stream().
+                filter(it -> Objects.equals(it.getImexId(), dto.getImexId()))
                 .collect(Collectors.toList());
         if (CollUtil.isEmpty(collect)) {
-            throw new ApiException("模版ID不存在");
+            throw new ApiException("导入ID不存在");
         }
 
-        return ApiResp.respOK(collect.get(0).handler(dto));
+        TsImportHandler tsImportHandler = collect.get(0);
+        tsImportHandler.validToken(token);
+        List read = tsImportHandler.ready(dto, token);
+        if (CollUtil.isEmpty(read)) {
+            throw new ApiException("没有数据可以导入");
+        }
+        CoreLogProcess coreLogProcess = coreLogService.addProcess(tsImportHandler.getImexId(), read, tsImportHandler);
+        coreLogProcess.setParams(JSON.toJSONString(dto));
+        coreLogService.getCoreLogProcessMapper().updateById(coreLogProcess);
+
+        return ApiResp.respOK(coreLogProcess.getId());
     }
 
+
+    ///////////////////////////////////////////////////////////////////////////
+    // export
+    ///////////////////////////////////////////////////////////////////////////
+
+    @TokenIgnore
+    @OperationIgnore
+    @PostMapping("/export/deal")
+    public ApiResp<String> exportDeal(@RequestBody @Valid ExportDealDTO dto, TokenBean token) {
+
+        List<TsExportHandler> collect = exportHandlers.stream().
+                filter(it -> Objects.equals(it.getImexId(), dto.getImexId()))
+                .collect(Collectors.toList());
+        if (CollUtil.isEmpty(collect)) {
+            throw new ApiException("导出ID不存在");
+        }
+
+        TsExportHandler tsExportHandler = collect.get(0);
+        tsExportHandler.validToken(token);
+        List read = tsExportHandler.ready(dto, token);
+        if (CollUtil.isEmpty(read)) {
+            throw new ApiException("没有数据可以导出");
+        }
+        CoreLogProcess coreLogProcess = coreLogService.addProcess(tsExportHandler.getImexId(), read, tsExportHandler);
+        coreLogProcess.setType("export");
+        coreLogProcess.setParams(JSON.toJSONString(dto));
+        coreLogService.getCoreLogProcessMapper().updateById(coreLogProcess);
+
+        return ApiResp.respOK(coreLogProcess.getId());
+    }
+
+
 }

springboot-web/src/main/java/com/tiesheng/web/controller/system/ConfigEnumController.java

@@ -41,6 +41,7 @@ public class ConfigEnumController {
         if (!StrUtil.isEmpty(dto.getType())) {
             queryWrapper.eq("type", dto.getType());
         }
+        queryWrapper.orderByAsc("type", "sort");
         List<CoreConfigEnum> selectList = coreConfigService.getEnumMapper().selectList(queryWrapper);
 
         return ApiResp.respOK(selectList);

springboot-web/src/main/java/com/tiesheng/web/controller/system/LogApiController.java

@@ -41,7 +41,7 @@ public class LogApiController {
         if (!StrUtil.isEmpty(result)) {
             queryWrapper.eq("result", result);
         }
-        dto.likeColumns(queryWrapper, "type", "content");
+        dto.likeColumns(queryWrapper, "type", "url", "content");
         queryWrapper.orderByDesc("create_time");
 
         Page<CoreLogApi> page = dto.pageObj();

springboot-web/src/main/java/com/tiesheng/web/pojos/dao/CoreConfigEnum.java

@@ -5,8 +5,8 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import com.tiesheng.util.pojos.DaoBase;
 
 /**
-    * 配置-枚举
-    */
+ * 配置-枚举
+ */
 @TableName(value = "core_config_enum")
 public class CoreConfigEnum extends DaoBase {
     /**
@@ -21,6 +21,12 @@ public class CoreConfigEnum extends DaoBase {
     @TableField(value = "`name`")
     private String name;
 
+    /**
+     * 排序
+     */
+    @TableField(value = "sort")
+    private Integer sort;
+
     /**
      * 备注
      */
@@ -69,6 +75,24 @@ public class CoreConfigEnum extends DaoBase {
         this.name = name;
     }
 
+    /**
+     * 获取排序
+     *
+     * @return sort - 排序
+     */
+    public Integer getSort() {
+        return sort;
+    }
+
+    /**
+     * 设置排序
+     *
+     * @param sort 排序
+     */
+    public void setSort(Integer sort) {
+        this.sort = sort;
+    }
+
     /**
      * 获取备注
      *

springboot-web/src/main/java/com/tiesheng/web/pojos/dao/CoreLogProcess.java

@@ -48,14 +48,8 @@ public class CoreLogProcess extends DaoBase {
     /**
      * 失败的文件
      */
-    @TableField(value = "fail_file")
-    private String failFile;
-
-    /**
-     * 异常说明
-     */
-    @TableField(value = "error")
-    private String error;
+    @TableField(value = "result_file")
+    private String resultFile;
 
     /**
      * 进度
@@ -63,6 +57,12 @@ public class CoreLogProcess extends DaoBase {
     @TableField(value = "`process`")
     private Integer process;
 
+    /**
+     * 异常说明
+     */
+    @TableField(value = "params")
+    private String params;
+
     /**
      * 获取标题
      *
@@ -174,37 +174,19 @@ public class CoreLogProcess extends DaoBase {
     /**
      * 获取失败的文件
      *
-     * @return fail_file - 失败的文件
+     * @return result_file - 失败的文件
      */
-    public String getFailFile() {
-        return failFile;
+    public String getResultFile() {
+        return resultFile;
     }
 
     /**
      * 设置失败的文件
      *
-     * @param failFile 失败的文件
+     * @param resultFile 失败的文件
      */
-    public void setFailFile(String failFile) {
-        this.failFile = failFile;
-    }
-
-    /**
-     * 获取异常说明
-     *
-     * @return error - 异常说明
-     */
-    public String getError() {
-        return error;
-    }
-
-    /**
-     * 设置异常说明
-     *
-     * @param error 异常说明
-     */
-    public void setError(String error) {
-        this.error = error;
+    public void setResultFile(String resultFile) {
+        this.resultFile = resultFile;
     }
 
     /**
@@ -224,4 +206,22 @@ public class CoreLogProcess extends DaoBase {
     public void setProcess(Integer process) {
         this.process = process;
     }
+
+    /**
+     * 获取异常说明
+     *
+     * @return params - 异常说明
+     */
+    public String getParams() {
+        return params;
+    }
+
+    /**
+     * 设置异常说明
+     *
+     * @param params 异常说明
+     */
+    public void setParams(String params) {
+        this.params = params;
+    }
 }

springboot-web/src/main/java/com/tiesheng/web/pojos/dto/ImageCodeDTO.java

@@ -26,6 +26,10 @@ public class ImageCodeDTO {
         if (height == null) {
             height = 62;
         }
+
+        width = Math.min(width, 500);
+        height = Math.min(height, 200);
+
         LineCaptcha lineCaptcha = CaptchaUtil.createLineCaptcha(width, height, 4, lineCount);
         lineCaptcha.setGenerator(new RandomGenerator("0123456789", 4));
 

springboot-web/src/main/java/com/tiesheng/web/pojos/imex/ExportDealDTO.java

@@ -0,0 +1,33 @@
+package com.tiesheng.web.pojos.imex;
+
+import com.alibaba.fastjson.JSONObject;
+
+import javax.validation.constraints.NotEmpty;
+
+public class ExportDealDTO {
+
+    @NotEmpty(message = "模版ID")
+    private String imexId;
+    private JSONObject params;
+
+    ///////////////////////////////////////////////////////////////////////////
+    // setter\getter
+    ///////////////////////////////////////////////////////////////////////////
+
+
+    public String getImexId() {
+        return imexId;
+    }
+
+    public void setImexId(String imexId) {
+        this.imexId = imexId;
+    }
+
+    public JSONObject getParams() {
+        return params;
+    }
+
+    public void setParams(JSONObject params) {
+        this.params = params;
+    }
+}

springboot-web/src/main/java/com/tiesheng/web/pojos/imex/ImportDealDTO.java

@@ -1,25 +1,27 @@
-package com.tiesheng.web.pojos.dto;
+package com.tiesheng.web.pojos.imex;
+
+import com.alibaba.fastjson.JSONObject;
 
 import javax.validation.constraints.NotEmpty;
 
-public class TemplateDealDTO {
+public class ImportDealDTO {
 
     @NotEmpty(message = "模版ID")
-    private String templateId;
+    private String imexId;
     @NotEmpty(message = "文件路径必填")
     private String file;
-    private Object params;
+    private JSONObject params;
 
     ///////////////////////////////////////////////////////////////////////////
     // setter\getter
     ///////////////////////////////////////////////////////////////////////////
 
-    public String getTemplateId() {
-        return templateId;
+    public String getImexId() {
+        return imexId;
     }
 
-    public void setTemplateId(String templateId) {
-        this.templateId = templateId;
+    public void setImexId(String imexId) {
+        this.imexId = imexId;
     }
 
     public String getFile() {
@@ -30,11 +32,11 @@ public class TemplateDealDTO {
         this.file = file;
     }
 
-    public Object getParams() {
+    public JSONObject getParams() {
         return params;
     }
 
-    public void setParams(Object params) {
+    public void setParams(JSONObject params) {
         this.params = params;
     }
 }

springboot-web/src/main/java/com/tiesheng/web/pojos/imex/ImportInfoDTO.java

@@ -1,10 +1,15 @@
-package com.tiesheng.web.pojos.dto;
+package com.tiesheng.web.pojos.imex;
 
 
-public class TemplateInfoDTO {
+import javax.validation.constraints.NotEmpty;
 
+public class ImportInfoDTO {
+
+    @NotEmpty(message = "操作必须存在")
     private String action;
-    private Object params;
+
+    @NotEmpty(message = "类型必须存在")
+    private String type;
 
     ///////////////////////////////////////////////////////////////////////////
     // setter\getter
@@ -18,11 +23,11 @@ public class TemplateInfoDTO {
         this.action = action;
     }
 
-    public Object getParams() {
-        return params;
+    public String getType() {
+        return type;
     }
 
-    public void setParams(Object params) {
-        this.params = params;
+    public void setType(String type) {
+        this.type = type;
     }
 }

springboot-web/src/main/java/com/tiesheng/web/pojos/imex/ImportInfoVO.java

@@ -0,0 +1,29 @@
+package com.tiesheng.web.pojos.imex;
+
+
+public class ImportInfoVO {
+
+    private String imexId;
+    private String templateUrl;
+
+    ///////////////////////////////////////////////////////////////////////////
+    // setter\getter
+    ///////////////////////////////////////////////////////////////////////////
+
+    public String getImexId() {
+        return imexId;
+    }
+
+    public void setImexId(String imexId) {
+        this.imexId = imexId;
+    }
+
+    public String getTemplateUrl() {
+        return templateUrl;
+    }
+
+    public void setTemplateUrl(String templateUrl) {
+        this.templateUrl = templateUrl;
+    }
+
+}

springboot-web/src/main/java/com/tiesheng/web/pojos/vo/ProcessDetailVo.java

@@ -5,7 +5,7 @@ package com.tiesheng.web.pojos.vo;
  */
 public class ProcessDetailVo {
 
-    private String title;
+    private String id;
 
     private Integer total;
 
@@ -15,13 +15,17 @@ public class ProcessDetailVo {
 
     private Integer process;
 
-    private String type;
-
     private Integer status;
 
-    private String failFile;
+    private String resultFile;
 
-    private String error;
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
 
     public Integer getStatus() {
         return status;
@@ -31,14 +35,6 @@ public class ProcessDetailVo {
         this.status = status;
     }
 
-    public String getTitle() {
-        return title;
-    }
-
-    public void setTitle(String title) {
-        this.title = title;
-    }
-
     public Integer getTotal() {
         return total;
     }
@@ -63,20 +59,12 @@ public class ProcessDetailVo {
         this.failNum = failNum;
     }
 
-    public String getType() {
-        return type;
+    public String getResultFile() {
+        return resultFile;
     }
 
-    public void setType(String type) {
-        this.type = type;
-    }
-
-    public String getFailFile() {
-        return failFile;
-    }
-
-    public void setFailFile(String failFile) {
-        this.failFile = failFile;
+    public void setResultFile(String resultFile) {
+        this.resultFile = resultFile;
     }
 
     public Integer getProcess() {
@@ -87,11 +75,4 @@ public class ProcessDetailVo {
         this.process = process;
     }
 
-    public String getError() {
-        return error;
-    }
-
-    public void setError(String error) {
-        this.error = error;
-    }
 }

springboot-web/src/main/java/com/tiesheng/web/pojos/vo/TemplateInfoVO.java

@@ -1,37 +0,0 @@
-package com.tiesheng.web.pojos.vo;
-
-
-public class TemplateInfoVO {
-
-    private String templateId;
-    private String templateUrl;
-    private Object params;
-
-    ///////////////////////////////////////////////////////////////////////////
-    // setter\getter
-    ///////////////////////////////////////////////////////////////////////////
-
-    public String getTemplateId() {
-        return templateId;
-    }
-
-    public void setTemplateId(String templateId) {
-        this.templateId = templateId;
-    }
-
-    public String getTemplateUrl() {
-        return templateUrl;
-    }
-
-    public void setTemplateUrl(String templateUrl) {
-        this.templateUrl = templateUrl;
-    }
-
-    public Object getParams() {
-        return params;
-    }
-
-    public void setParams(Object params) {
-        this.params = params;
-    }
-}

springboot-web/src/main/java/com/tiesheng/web/service/CoreLogService.java

@@ -23,7 +23,6 @@ import com.tiesheng.web.util.ProcessSyncConsumer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -32,11 +31,6 @@ import java.util.List;
 @Service
 public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLogOperation> {
 
-    /**
-     * 日志缓存
-     */
-    private static final List<CoreLogOperation> cacheOperations = new ArrayList<>();
-
     @Autowired
     TieshengWebConfigurer tieshengWebConfigurer;
     @Autowired
@@ -79,33 +73,24 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
         coreLogProcess.setSuccessNum(0);
         coreLogProcess.setFailNum(0);
         coreLogProcess.setProcess(0);
-        coreLogProcess.setError("");
+        coreLogProcess.setParams("");
         coreLogProcessMapper.insert(coreLogProcess);
 
         ThreadUtil.execute(() -> {
-            List<Exception> errorList = new ArrayList<>();
             CollUtil.split(list, 100).forEach((it) -> {
-                int accept = 0;
-                try {
-                    accept = consumer.accept(it);
-                } catch (Exception e) {
-                    errorList.add(e);
-                }
+                int accept = consumer.batchHandler(it);
                 coreLogProcess.setProcess(coreLogProcess.getProcess() + it.size());
                 coreLogProcess.setSuccessNum(coreLogProcess.getSuccessNum() + accept);
                 coreLogProcess.setFailNum(coreLogProcess.getFailNum() + it.size() - accept);
-                coreLogProcess.setError(JSON.toJSONString(errorList));
                 coreLogProcessMapper.updateById(coreLogProcess);
             });
 
             // 执行结束
-            coreLogProcess.setFailFile(consumer.getFailFile());
+            coreLogProcess.setResultFile(consumer.getResultFile());
             coreLogProcess.setStatus(1);
-            coreLogProcess.setError(JSON.toJSONString(errorList));
             coreLogProcessMapper.updateById(coreLogProcess);
         });
 
-
         return coreLogProcess;
     }
 
@@ -126,29 +111,24 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
         coreLogProcess.setFailNum(0);
         coreLogProcess.setTotal(0);
         coreLogProcess.setProcess(0);
-        coreLogProcess.setError("");
         coreLogProcessMapper.insert(coreLogProcess);
 
         ThreadUtil.execute(() -> {
             int pageSize = 1000;
             int pageNum = 1, lastCount = pageSize;
-            List<Exception> errorList = new ArrayList<>();
             while (lastCount == pageSize) {
                 try {
                     lastCount = consumer.accept(pageNum, pageSize);
                     coreLogProcess.setTotal(coreLogProcess.getTotal() + lastCount);
                     coreLogProcess.setProcess(coreLogProcess.getTotal());
-                    coreLogProcess.setError(JSON.toJSONString(errorList));
                     coreLogProcess.setSuccessNum(coreLogProcess.getSuccessNum() + lastCount);
-                } catch (Exception e) {
-                    errorList.add(e);
+                } catch (Exception ignored) {
                 }
                 coreLogProcessMapper.updateById(coreLogProcess);
                 pageNum++;
             }
 
             // 执行结束
-            coreLogProcess.setError(JSON.toJSONString(errorList));
             coreLogProcess.setStatus(1);
             coreLogProcessMapper.updateById(coreLogProcess);
         });
@@ -194,14 +174,7 @@ public class CoreLogService extends TsServiceBase<CoreLogOperationMapper, CoreLo
         if (params != null) {
             operation.setParams(JSON.toJSONString(params));
         }
-
-        synchronized (CoreLogOperation.class) {
-            cacheOperations.add(operation);
-            if (cacheOperations.size() >= 100) {
-                getBaseMapper().batchInsert(cacheOperations);
-                cacheOperations.clear();
-            }
-        }
+        save(operation);
     }
 
 

springboot-web/src/main/java/com/tiesheng/web/service/OkHttpLogInterceptor.java

@@ -1,6 +1,7 @@
 package com.tiesheng.web.service;
 
 import cn.hutool.core.thread.ThreadUtil;
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.tiesheng.util.service.http.OkHttpUtil;
 import com.tiesheng.web.mapper.CoreLogApiMapper;
@@ -13,7 +14,7 @@ import javax.annotation.Resource;
 import javax.validation.constraints.NotNull;
 
 @Component
-public class LogApiOkHttpInterceptor implements Interceptor {
+public class OkHttpLogInterceptor implements Interceptor {
 
     @Resource
     CoreLogApiMapper coreLogApiMapper;
@@ -32,10 +33,15 @@ public class LogApiOkHttpInterceptor implements Interceptor {
         Response response;
         try {
             response = chain.proceed(request);
-            ResponseBody peekBody = response.peekBody(Long.MAX_VALUE);
-            logApi.setRespBody(peekBody.string());
             logApi.setResult(response.code());
-            peekBody.close();
+
+            // 如果是json,xml,text，则保存记录
+            if (response.body() != null && StrUtil.containsAll(response.body().contentType().toString(),
+                    "json", "xml", "text")) {
+                ResponseBody peekBody = response.peekBody(Long.MAX_VALUE);
+                logApi.setRespBody(peekBody.string());
+                peekBody.close();
+            }
         } catch (Exception e) {
 
             JSONObject object = new JSONObject();
@@ -46,6 +52,9 @@ public class LogApiOkHttpInterceptor implements Interceptor {
 
             response = new Response.Builder()
                     .request(request)
+                    .protocol(Protocol.HTTP_1_1)
+                    .code(logApi.getResult())
+                    .message(e.getMessage())
                     .body(OkHttpUtil.ofJsonResponse(logApi.getRespBody()))
                     .build();
         }

springboot-web/src/main/java/com/tiesheng/web/service/imex/DefaultImexHandler.java

@@ -0,0 +1,44 @@
+package com.tiesheng.web.service.imex;
+
+import cn.hutool.core.collection.CollUtil;
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.web.pojos.imex.ExportDealDTO;
+import com.tiesheng.web.pojos.imex.ImportDealDTO;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+
+@Service
+public class DefaultImexHandler implements TsImportHandler<String>, TsExportHandler<String> {
+
+    @Override
+    public List<String> ready(ExportDealDTO dto, TokenBean token) {
+        return CollUtil.newArrayList();
+    }
+
+    @Override
+    public List<String> ready(ImportDealDTO dto, TokenBean token) {
+        return CollUtil.newArrayList();
+    }
+
+    @Override
+    public String getTemplateUrl() {
+        return "";
+    }
+
+    @Override
+    public String getAction() {
+        return "";
+    }
+
+    @Override
+    public int batchHandler(List<String> list) {
+        return 0;
+    }
+
+    @Override
+    public String getResultFile() {
+        return "";
+    }
+}

springboot-web/src/main/java/com/tiesheng/web/service/imex/TsExportHandler.java

@@ -0,0 +1,19 @@
+package com.tiesheng.web.service.imex;
+
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.web.pojos.imex.ExportDealDTO;
+
+import java.util.List;
+
+public interface TsExportHandler<T> extends TsImexBase<T> {
+
+
+    /**
+     * 数据准备中
+     *
+     * @return
+     */
+    List<T> ready(ExportDealDTO dto, TokenBean token);
+
+
+}

springboot-web/src/main/java/com/tiesheng/web/service/imex/TsImexBase.java

@@ -0,0 +1,47 @@
+package com.tiesheng.web.service.imex;
+
+import cn.hutool.core.util.StrUtil;
+import com.tiesheng.util.exception.ApiException;
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.web.util.ProcessImportConsumer;
+
+public interface TsImexBase<T> extends ProcessImportConsumer<T> {
+
+    /**
+     * 动作说明（唯一）
+     *
+     * @return
+     */
+    String getAction();
+
+    /**
+     * 排序，如果action相同，只会使用sort大的来处理
+     *
+     * @return
+     */
+    default int getSort() {
+        return 0;
+    }
+
+    /**
+     * 验证是否登录
+     *
+     * @param tokenBean
+     */
+    default void validToken(TokenBean tokenBean) {
+        if (tokenBean == null || StrUtil.isEmpty(tokenBean.getId())) {
+            throw new ApiException("请先登录");
+        }
+    }
+
+
+    /**
+     * 获取模版ID
+     *
+     * @return
+     */
+    default String getImexId() {
+        return StrUtil.format("{}_{}", getAction(), getSort());
+    }
+
+}

springboot-web/src/main/java/com/tiesheng/web/service/imex/TsImportHandler.java

@@ -0,0 +1,27 @@
+package com.tiesheng.web.service.imex;
+
+import com.tiesheng.util.pojos.TokenBean;
+import com.tiesheng.web.pojos.imex.ImportDealDTO;
+
+import java.util.List;
+
+public interface TsImportHandler<T> extends TsImexBase<T> {
+
+
+    /**
+     * 读取文件内容
+     *
+     * @param dto
+     * @return
+     */
+    List<T> ready(ImportDealDTO dto, TokenBean token);
+
+
+    /**
+     * 获取模版地址
+     *
+     * @return
+     */
+    String getTemplateUrl();
+
+}

springboot-web/src/main/java/com/tiesheng/web/util/ProcessImportConsumer.java

@@ -6,20 +6,19 @@ public interface ProcessImportConsumer<T> {
 
 
     /**
-     * 处理数据
+     * 分批处理
      *
      * @param list
-     * @param <T>
      * @return 返回成功的数量
      */
-    int accept(List<T> list);
+    int batchHandler(List<T> list);
 
 
     /**
-     * 获取失败的文件路径
+     * 获取导入结果文件
      *
      * @return
      */
-    String getFailFile();
+    String getResultFile();
 
 }

springboot-web/src/main/resources/db/migration/tiesheng_init_config.sql

@@ -33,4 +33,7 @@ CREATE TABLE `core_config_system`
 ) ENGINE = InnoDB
   DEFAULT CHARSET = utf8mb4 COMMENT ='配置-系统';
 
+alter table core_config_enum
+    add sort int(10) not null default 0 comment '排序' after name;
+
 SET FOREIGN_KEY_CHECKS = 1;

springboot-web/src/main/resources/db/migration/tiesheng_init_log.sql

@@ -72,4 +72,18 @@ CREATE TABLE `core_log_operation`
   DEFAULT CHARSET = utf8mb4 COMMENT ='日志-操作';
 
 
+alter table core_log_process
+    change error params longtext null comment '异常说明';
+
+alter table core_log_process
+    change fail_file result_file varchar(500) null comment '失败的文件';
+
+## 2.0.2
+
+alter table core_log_login
+    add result int(10) not null default 1 comment '登录结果,0否，1是';
+
+alter table core_log_login
+    add params longtext null comment '请求参数';
+
 SET FOREIGN_KEY_CHECKS = 1;

springboot-web/src/main/resources/mapper/CoreConfigEnumMapper.xml

@@ -10,11 +10,12 @@
     <result column="is_deleted" jdbcType="INTEGER" property="isDeleted" />
     <result column="type" jdbcType="VARCHAR" property="type" />
     <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="sort" jdbcType="INTEGER" property="sort" />
     <result column="remark" jdbcType="VARCHAR" property="remark" />
     <result column="ext" jdbcType="VARCHAR" property="ext" />
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
-    id, create_time, update_time, is_deleted, `type`, `name`, remark, ext
+    id, create_time, update_time, is_deleted, `type`, `name`, sort, remark, ext
   </sql>
-</mapper>
+</mapper>

springboot-web/src/main/resources/mapper/CoreLogProcessMapper.xml

@@ -14,13 +14,13 @@
     <result column="fail_num" jdbcType="INTEGER" property="failNum" />
     <result column="type" jdbcType="VARCHAR" property="type" />
     <result column="status" jdbcType="INTEGER" property="status" />
-    <result column="fail_file" jdbcType="VARCHAR" property="failFile" />
-    <result column="error" jdbcType="LONGVARCHAR" property="error" />
+    <result column="result_file" jdbcType="VARCHAR" property="resultFile" />
     <result column="process" jdbcType="INTEGER" property="process" />
+    <result column="params" jdbcType="LONGVARCHAR" property="params" />
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
-    id, create_time, update_time, is_deleted, title, total, success_num, fail_num, `type`,
-    `status`, fail_file, error, `process`
+    id, create_time, update_time, is_deleted, title, total, success_num, fail_num, `type`, 
+    `status`, result_file, `process`, params
   </sql>
-</mapper>
+</mapper>