泓浒考勤同步修改

fhKeeper/formulahousekeeper/collectdata/src/main/java/com/management/collectdata/controller/DataCollectController.java

@@ -329,10 +329,14 @@ public class DataCollectController {
 
 
     @RequestMapping("/getWorkDayDataSum")
-    public String getWorkDayDataSum() {
-        String sqlCount = "select count(*) from att_work_hour_day where create_date >= DATE_SUB(CURDATE(), INTERVAL 14 DAY) and come1 is not null and go1 is not null";
+    public String getWorkDayDataSum(@RequestBody PageBO pageBO) {
+        String sqlCount = "select count(*) from att_work_hour_day where "+
+                (pageBO.getStartDate() == null ? "attendance_date >= DATE_SUB(CURDATE(), INTERVAL 14 DAY)" : (String.format("date_format(attendance_date,'%%Y-%%m-%%d') between '%s' and '%s'", pageBO.getStartDate(), pageBO.getEndDate())))
+                + (pageBO.getJobNumber() == null ? "" : (String.format(" and emp_no = '%s'", pageBO.getJobNumber())))
+                +" and come1 is not null and go1 is not null";
         int totalCount = 0;
         try (Connection connection = mysqlDataSource.getConnection()) {
+            System.out.println("getWorkDayDataSum 查询Sql="+sqlCount);
             PreparedStatement countStmt = connection.prepareStatement(sqlCount);
             ResultSet countRs = countStmt.executeQuery();
             if (countRs.next()) {
@@ -348,7 +352,10 @@ public class DataCollectController {
     @RequestMapping("/getWorkDayDataList")
     public List<UserFvTime> getWorkDayDataList(@RequestBody PageBO pageBO) {
         String sqlQuery = " select id,emp_no,emp_name,attendance_date,come1,go1,if(worktime_total_hour=0,off_hour,worktime_total_hour) as worktime_total_hour,overtime_total_hour " +
-                " from att_work_hour_day  where create_date >= DATE_SUB(CURDATE(), INTERVAL 14 DAY) and come1 is not null and go1 is not null order by id limit ?,? ";
+                " from att_work_hour_day  where "+
+                (pageBO.getStartDate() == null ? "attendance_date >= DATE_SUB(CURDATE(), INTERVAL 14 DAY)" : (String.format("date_format(attendance_date,'%%Y-%%m-%%d') between '%s' and '%s'", pageBO.getStartDate(), pageBO.getEndDate())))
+                + (pageBO.getJobNumber() == null ? "" : (String.format(" and emp_no = '%s'", pageBO.getJobNumber())))
+                +" and come1 is not null and go1 is not null order by id limit ?,? ";
         List<UserFvTime> resList = new ArrayList<>();
         SimpleDateFormat sdfYmd = new SimpleDateFormat("yyyy-MM-dd");
 
@@ -367,8 +374,8 @@ public class DataCollectController {
                     userFvTime.setUserId(resultSet.getString("emp_no"));
                     userFvTime.setWorkDate(null==resultSet.getDate("attendance_date")?null:LocalDate.parse(sdfYmd.format(resultSet.getDate("attendance_date")), DateTimeFormatter.ofPattern("yyyy-MM-dd")));
                     String startTime = resultSet.getString("come1");
-                    //从9:00开始计算，小于9:00的以9:00为准，向上取30分钟， 比如9:09，就转换为9:30
-                    if (startTime.compareTo("09:00") < 0) {
+                    //从9:05开始计算，小于9:05的以9:00为准，向上取30分钟， 比如9:09，就转换为9:30
+                    if (startTime.compareTo("09:05") <= 0) {
                         startTime = "09:00";
                     }
                     String[] startTimeArr = startTime.split(":");

fhKeeper/formulahousekeeper/collectdata/src/main/java/com/management/collectdata/entity/bo/PageBO.java

@@ -6,4 +6,7 @@ import lombok.Data;
 public class PageBO {
     private int pageNo = 0;
     private int pageSize = 10;
+    private String jobNumber;
+    private String startDate;
+    private String endDate;
 }

fhKeeper/formulahousekeeper/management-platform/src/main/java/com/management/platform/controller/UserFvTimeController.java

@@ -448,9 +448,26 @@ public class UserFvTimeController {
     }
 
     @RequestMapping("/syncHongHuFvTime")
-    public HttpRespMsg syncHongHuFvTime() {
+    public HttpRespMsg syncHongHuFvTime(String userId, String startDate, String endDate) {
         HttpRespMsg httpRespMsg = new HttpRespMsg();
-        userFvTimeService.syncUserFvTime(7536);
+        userFvTimeService.syncUserFvTime(7536, userId, startDate, endDate);
+        //查询返回
+        if (startDate == null || endDate == null) {
+            httpRespMsg.setError("请指定日期范围");
+            return httpRespMsg;
+        }
+        QueryWrapper<UserFvTime> eq = new QueryWrapper<UserFvTime>().eq("company_id", 7536).between("work_date", startDate, endDate);
+        if (userId != null) {
+            eq.eq("user_id", userId);
+        }
+        List<UserFvTime> userFvTimeList = userFvTimeService.list(eq);
+        if (userId != null) {
+            if (userFvTimeList.size() > 0) {
+                httpRespMsg.setData(userFvTimeList.get(0));
+            }
+        } else {
+            httpRespMsg.setData(userFvTimeList);
+        }
         return httpRespMsg;
     }
 

fhKeeper/formulahousekeeper/management-platform/src/main/java/com/management/platform/service/UserFvTimeService.java

@@ -13,5 +13,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface UserFvTimeService extends IService<UserFvTime> {
 
-    public void syncUserFvTime(Integer specialCompanyId);
+    public void syncUserFvTime(Integer specialCompanyId, String userId,  String startDate, String endDate);
 }

fhKeeper/formulahousekeeper/management-platform/src/main/java/com/management/platform/service/impl/UserFvTimeServiceImpl.java

@@ -38,16 +38,37 @@ public class UserFvTimeServiceImpl extends ServiceImpl<UserFvTimeMapper, UserFvT
     private UserMapper userMapper;
 
     @Override
-    public void syncUserFvTime(Integer specialCompanyId) {
+    public void syncUserFvTime(Integer specialCompanyId, String userId, String startDate, String endDate) {
         RestTemplate restTemplate = new RestTemplate();
         String sumUrl = PREFIX_URL+"/dataCollect/getWorkDayDataSum";
         String listUrl = PREFIX_URL+"/dataCollect/getWorkDayDataList";
 
         try {
+            List<UserFvTime> toAddList = new ArrayList<>();
+            List<UserFvTime> toUpdateList = new ArrayList<>();
+            LambdaQueryWrapper<User> eq = new LambdaQueryWrapper<User>().eq(User::getCompanyId, specialCompanyId);
+            if (StringUtils.isNotBlank(userId)) {
+                eq.eq(User::getId, userId);
+            }
+            List<User> users = userMapper.selectList(eq);
+            String targetJobNumber = null;
+            //获取指定用户的考勤
+            if (StringUtils.isNotBlank(userId)) {
+                targetJobNumber = users.get(0).getJobNumber();
+            }
+            Map<String, Object> requestBody = new HashMap<>();
+            requestBody.put("jobNumber", targetJobNumber);
+            requestBody.put("startDate", startDate);
+            requestBody.put("endDate", endDate);
+            requestBody.put("pageNo", 0);
+            requestBody.put("pageSize", 0);
+            HttpHeaders headers = new HttpHeaders();
+            headers.setContentType(MediaType.APPLICATION_JSON);
+            HttpEntity<Object> requestEntity = new HttpEntity<>(requestBody, headers);
             ResponseEntity<String> sumResponse = restTemplate.exchange(
                     sumUrl,
-                    HttpMethod.GET,
-                    null,
+                    HttpMethod.POST,
+                    requestEntity,
                     String.class
             );
             Integer totalNum = 0;
@@ -59,18 +80,12 @@ public class UserFvTimeServiceImpl extends ServiceImpl<UserFvTimeMapper, UserFvT
             if(totalNum > 0){
                 int pageSize = 1000;
                 int offset = 0;
-                List<UserFvTime> toAddList = new ArrayList<>();
-                List<UserFvTime> toUpdateList = new ArrayList<>();
-                List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().eq(User::getCompanyId, specialCompanyId));
+
                 Map<String, User> userMap = users.stream().filter(t -> StringUtils.isNotBlank(t.getJobNumber()))
                         .collect(Collectors.toMap(User::getJobNumber, t -> t));
                 while (offset < totalNum) {
-                    HttpHeaders headers = new HttpHeaders();
-                    headers.setContentType(MediaType.APPLICATION_JSON);
-                    Map<String, Object> requestBody = new HashMap<>();
                     requestBody.put("pageNo", offset);
                     requestBody.put("pageSize", pageSize);
-                    HttpEntity<Object> requestEntity = new HttpEntity<>(requestBody, headers);
                     ResponseEntity<List<UserFvTime>> listResponse = restTemplate.exchange(
                             listUrl,
                             HttpMethod.POST,
@@ -118,6 +133,8 @@ public class UserFvTimeServiceImpl extends ServiceImpl<UserFvTimeMapper, UserFvT
                     toAddList.clear();
                     offset += pageSize;
                 }
+            } else {
+                System.out.println("无数据");
             }
         } catch (Exception e) {
             System.out.println("请求发生异常: " + e.getMessage());

fhKeeper/formulahousekeeper/management-platform/src/main/java/com/management/platform/task/DataCollectTask.java

@@ -284,7 +284,12 @@ public class DataCollectTask {
     public void workDayTask(){
         if(isDev){return;}
         if(isPrivateDeploy) return;
-        userFvTimeService.syncUserFvTime(specialCompanyId);
+        //自动同步过去7天内的数据(不含今天)
+        LocalDate now = LocalDate.now();
+        LocalDate endDate = now.minusDays(1);
+        LocalDate startDate = now.minusDays(8);
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        userFvTimeService.syncUserFvTime(specialCompanyId, null, formatter.format(startDate),formatter.format(endDate));
     }
 
     @Scheduled(cron = "0 0 2 * * ?")