|
|
@@ -4,6 +4,7 @@ package com.pavis.ctr.audit.project.service.impl;
|
|
|
import com.aliyun.oss.OSS;
|
|
|
import com.baidubce.services.bos.BosClient;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.pavis.ctr.audit.common.utils.ConvertObjUtils;
|
|
|
@@ -451,12 +452,7 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- /**
|
|
|
- * 根据user_id和date_dir获取的uploadId获取auditTripResult
|
|
|
- * 且要满足1.审核完成（1） 2.操作结论为操作错误（01）
|
|
|
- * @param tripResultList
|
|
|
- * @return
|
|
|
- */
|
|
|
+
|
|
|
@Override
|
|
|
public List<AuditTripResult> getResultByUserIdUploadId(List<AuditTripResult> tripResultList) {
|
|
|
|
|
|
@@ -470,10 +466,17 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
}else {
|
|
|
String auditConclusion = result.getAuditConclusion().split(",")[0];
|
|
|
String auditConclusionInfo = result.getAuditConclusion().split(",")[1];
|
|
|
+
|
|
|
+ System.out.println("符合条件的结论"+auditConclusionInfo);
|
|
|
+
|
|
|
+ //对01，10项错误结论进行保留，去除01，8、01,9两项错误
|
|
|
if (auditConclusion.equals("01")) {
|
|
|
- if (Integer.valueOf(auditConclusionInfo) > 7) {
|
|
|
- //上面不需要判断auditConclusionInfo是否为空，如果审核结论不是01，就不会进入判断二级菜单的情况。
|
|
|
- //如果不是01则进行删除该对象元素。
|
|
|
+ //如果不是01下第8项 错误结论则进行删除该对象元素。
|
|
|
+ if (Integer.valueOf(auditConclusionInfo) == 8) {
|
|
|
+ iterator.remove();
|
|
|
+ }
|
|
|
+ //如果不是01下第9项 错误结论则进行删除该对象元素。
|
|
|
+ if (Integer.valueOf(auditConclusionInfo) == 9) {
|
|
|
iterator.remove();
|
|
|
}
|
|
|
}
|
|
|
@@ -484,26 +487,64 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
return tripResultList;
|
|
|
}
|
|
|
|
|
|
+ //应该先判断tripResultList不为空在进行打印测试
|
|
|
+ System.out.println("剔除8，9项错误结论后的列表");
|
|
|
+ for (AuditTripResult result : tripResultList) {
|
|
|
+ System.out.println(result.toString());
|
|
|
+ }
|
|
|
+
|
|
|
//对操作错误的二级子菜单进行权重排序。
|
|
|
tripResultList=tripResultList.stream().sorted(Comparator.comparing(
|
|
|
num ->Integer.parseInt(num.getAuditConclusion().split(",")[1].toString())))
|
|
|
.collect(Collectors.toList());
|
|
|
|
|
|
+
|
|
|
+ //由于需要保留第10项 上传无效错误，且该错误权重为1，故不能单纯的按照错误结论子集id进行排序
|
|
|
+ //若排序后的列表最后一项审核结论是01，10就把该项提到排序好的列表首项
|
|
|
+ if(tripResultList.get(tripResultList.size()-1).getAuditConclusion().equals("01,10")){
|
|
|
+
|
|
|
+ List<AuditTripResult> rotateListIndex = this.rotateListIndex(tripResultList);
|
|
|
+
|
|
|
+ System.out.println("返回的列表包含01，10。进行旋转移位后的列表");
|
|
|
+ for (AuditTripResult listIndex : rotateListIndex) {
|
|
|
+ System.out.println(listIndex.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ return rotateListIndex;
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("返回的列表包不含01，10。进行普通按号排序的列表");
|
|
|
+ for (AuditTripResult result : tripResultList) {
|
|
|
+ System.out.println(result.toString());
|
|
|
+ }
|
|
|
+
|
|
|
return tripResultList;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
/**
|
|
|
- * /**
|
|
|
- * 1：每次审核第一次提交时，记录日期用于表示该日上班，一天只记录一次。
|
|
|
- * 2：获取上班日志表中id最大的一个，如果该条记录的时间和当天一致，则id-1获取次日的工作时间。
|
|
|
- * 2.1：根据user_id查询所有审核完成的记录，给这些记录按日期进行排序，第一条称为最新审核记录；
|
|
|
- * 2.2：如果工作日期小于等于最新审核记录则表示有可能存在审核数据
|
|
|
- * 2.2.1：根据工作日期[零点，59]在user_id查询所有审核完成的记录中取对应的数据。
|
|
|
- * 2.3：如果工作日期大于最新审核记录则表示一定没有审核记录，返回空。
|
|
|
- *
|
|
|
- * @param userId
|
|
|
+ * 将传入的list 在某一个下标开始，旋转至列表头部
|
|
|
+ * @param tripResultList
|
|
|
* @return
|
|
|
*/
|
|
|
+ private List<AuditTripResult> rotateListIndex(List<AuditTripResult> tripResultList) {
|
|
|
+
|
|
|
+ int rotateIndex=0;
|
|
|
+
|
|
|
+ //获取tripResultList 中01，10错误结论元素个数
|
|
|
+ for (AuditTripResult result : tripResultList) {
|
|
|
+ if (result.getAuditConclusion().equals("01,10")){
|
|
|
+ rotateIndex++;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ //不需用判断rotateIndex是否为0，进入这个方法rotateIndex至少为1.
|
|
|
+ Collections.rotate(tripResultList,rotateIndex);
|
|
|
+ return tripResultList;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
@Override
|
|
|
public List<AuditTripResult> getTripResult(String userId) {
|
|
|
|
|
|
@@ -581,9 +622,14 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
String startTime = onDutyDate + " 00:00:00";
|
|
|
String endTime = onDutyDate + " 23:59:59";
|
|
|
|
|
|
- auditTripResults1 = collect1.stream().filter(result -> result.getUpdateTime().getTime() >= DateUtils.dateTime("yyyy-MM-dd HH:mm:ss", startTime).getTime() && result.getUpdateTime().getTime() <= DateUtils.dateTime("yyyy-MM-dd HH:mm:ss", endTime).getTime()).collect(toList());
|
|
|
- System.out.println("符合条件的数据");
|
|
|
- auditTripResults1.forEach(System.out::println);
|
|
|
+ auditTripResults1 = collect1.stream().
|
|
|
+ filter(result -> result.getUpdateTime().
|
|
|
+ getTime() >= DateUtils.dateTime("yyyy-MM-dd HH:mm:ss", startTime).getTime()
|
|
|
+ && result.getUpdateTime().getTime() <= DateUtils.dateTime("yyyy-MM-dd HH:mm:ss", endTime).getTime())
|
|
|
+ .collect(toList());
|
|
|
+
|
|
|
+ System.out.println("auditTripResults1.size():"+auditTripResults1.size());
|
|
|
+
|
|
|
|
|
|
return auditTripResults1;
|
|
|
} else {
|
|
|
@@ -592,6 +638,17 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public int pushSign(String uploadId) {
|
|
|
+
|
|
|
+
|
|
|
+ UpdateWrapper<AuditTripResult> auditTripResultUpdateWrapper = new UpdateWrapper<>();
|
|
|
+ auditTripResultUpdateWrapper.eq("upload_id",uploadId).set("remark","pushed");
|
|
|
+ return baseMapper.update(null,auditTripResultUpdateWrapper);
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* 根据uploadId提取审核完成的数据
|
|
|
*
|
