用户同步花名册数据

jeeplus-module/jeeplus-test/src/main/java/com/jeeplus/test/cw/projectReport/controller/CwProjectReportSignatureCallBackController.java

@@ -5,6 +5,8 @@ import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.TypeReference;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.collect.Lists;
 import com.google.common.collect.Maps;
 import com.google.gson.Gson;
@@ -12,6 +14,9 @@ import com.google.gson.reflect.TypeToken;
 import com.jeeplus.common.redis.RedisUtils;
 import com.jeeplus.flowable.model.Flow;
 import com.jeeplus.flowable.service.FlowTaskService;
+import com.jeeplus.sys.domain.User;
+import com.jeeplus.sys.service.UserService;
+import com.jeeplus.sys.service.dto.UserDTO;
 import com.jeeplus.sys.utils.Global;
 import com.jeeplus.sys.utils.SpringContextHolder;
 import com.jeeplus.sys.utils.UserUtils;
@@ -39,7 +44,6 @@ import org.flowable.task.api.Task;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.jedis.JedisUtils;
 import org.springframework.http.ResponseEntity;
-import org.springframework.security.core.userdetails.User;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -77,6 +81,8 @@ public class CwProjectReportSignatureCallBackController {
     private ProjectReportWorkAttachmentMapper attachmentMapper;
     @Autowired
     private CwProjectReportMapper reportMapper;
+    @Autowired
+    private UserService userService;
 
     private static final String HTTPTOP = Global.getConfig("signature_http_top");
 
@@ -508,4 +514,22 @@ public class CwProjectReportSignatureCallBackController {
         return true;
     }
 
+    @RequestMapping(value = "/updateAllUser", method= RequestMethod.POST)
+    @ResponseBody
+    public void updateAllUser() {
+        // 查询全部用户
+        Page<UserDTO> page = new Page<>();
+        page.setCurrent(1);
+        page.setSize(-1);
+        IPage<UserDTO> pageList = userService.findPage(page, new QueryWrapper<UserDTO>());
+        // 将全部用户数据执行保存操作
+        pageList.getRecords().stream().forEach(userDTO -> {
+            try {
+                userService.saveOrUpdate(userDTO);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        });
+    }
+
 }