1.2970存量数据刷库

amos-boot-system-tzs/amos-boot-module-tcm/amos-boot-module-tcm-biz/src/main/java/com/yeejoin/amos/boot/module/tcm/biz/controller/HistoryDataDealController.java

+package com.yeejoin.amos.boot.module.tcm.biz.controller;
+
+import com.yeejoin.amos.boot.module.tcm.biz.service.impl.HistoryDataDealServiceImpl;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.web.bind.annotation.PutMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+/**
+ * @author Administrator
+ */
+@RestController
+@RequestMapping(value = "/history-data")
+@Api(tags = "历史数据处理控制器")
+public class HistoryDataDealController {
+
+    private HistoryDataDealServiceImpl historyDataDealService;
+
+    public HistoryDataDealController(HistoryDataDealServiceImpl historyDataDealService) {
+        this.historyDataDealService = historyDataDealService;
+    }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @PutMapping(value = "/user-permission/update")
+    @ApiOperation(httpMethod = "PUT", value = "人员需求2970新增资质后, 资质存量数据刷库")
+    public ResponseModel<Integer> userPermissionUpdate() {
+        return ResponseHelper.buildResponse(historyDataDealService.userPermissionUpdate());
+    }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @PutMapping(value = "/user-person-type/update")
+    @ApiOperation(httpMethod = "PUT", value = "人员需求2970新增资质后, 人员类型去掉维保，归到作业人员")
+    public ResponseModel<Integer> userPersonTypeUpdate() {
+        return ResponseHelper.buildResponse(historyDataDealService.userPersonTypeUpdate());
+    }
+
+}

amos-boot-system-tzs/amos-boot-module-tcm/amos-boot-module-tcm-biz/src/main/java/com/yeejoin/amos/boot/module/tcm/biz/service/impl/HistoryDataDealServiceImpl.java

+package com.yeejoin.amos.boot.module.tcm.biz.service.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.yeejoin.amos.boot.module.common.api.entity.TzsUserPermission;
+import com.yeejoin.amos.boot.module.tcm.api.entity.TzsUserInfo;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StopWatch;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @author Administrator
+ */
+@Service
+@Slf4j
+public class HistoryDataDealServiceImpl {
+
+    private TzsUserInfoServiceImpl userInfoService;
+
+    private TzsUserPermissionServiceImpl userPermissionService;
+
+    public HistoryDataDealServiceImpl(TzsUserInfoServiceImpl userInfoService, TzsUserPermissionServiceImpl userPermissionService) {
+        this.userInfoService = userInfoService;
+        this.userPermissionService = userPermissionService;
+    }
+
+    public int userPermissionUpdate() {
+        log.info("刷存量人员资质开始");
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start();
+        List<TzsUserInfo> usersOfHavingPermission = userInfoService.list(new LambdaQueryWrapper<TzsUserInfo>().isNotNull(TzsUserInfo::getPermissionData));
+        List<TzsUserPermission> allWaitFlushData = new ArrayList<>();
+        usersOfHavingPermission.forEach(u -> {
+            JSON.parseObject(u.getPermissionData()).forEach((k, v) -> {
+                List<TzsUserPermission> userPermissions = JSONArray.parseArray(v.toString(), TzsUserPermission.class);
+                userPermissions.forEach(p -> {
+                    p.setUserSeq(u.getSequenceNbr());
+                    p.setPermissionPost(k);
+                    p.setRecDate(new Date());
+                    p.setRecUserName(u.getRecUserName());
+                    p.setRecUserId(u.getRecUserId());
+                    p.setRemark("存量数据刷入");
+                });
+                allWaitFlushData.addAll(userPermissions);
+            });
+        });
+        if (allWaitFlushData.size() > 0) {
+            userPermissionService.saveBatch(allWaitFlushData);
+        }
+        stopWatch.stop();
+        log.info("刷存量人员资质结束,有资质的人员数量:{}, 插入的资质条数：{}，耗时：{}秒", usersOfHavingPermission.size(), allWaitFlushData.size(), stopWatch.getTotalTimeSeconds());
+        return allWaitFlushData.size();
+    }
+
+    public Integer userPersonTypeUpdate() {
+        log.info("刷存量人员类型开始");
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start();
+        List<TzsUserInfo> users = userInfoService.list();
+        users.forEach(u->{
+            // 维保人员人员类型去掉，数据规避到作业人员
+            u.setNewPost(u.getPost().replace("6618","6552"));
+        });
+        userInfoService.saveOrUpdateBatch(users);
+        stopWatch.stop();
+        log.info("刷存量人员类型结束，人员数量:{}，耗时：{}秒", users.size(), stopWatch.getTotalTimeSeconds());
+        return users.size();
+    }
+}