|
@@ -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,17 +466,38 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
}else {
|
|
|
String auditConclusion = result.getAuditConclusion().split(",")[0];
|
|
|
String auditConclusionInfo = result.getAuditConclusion().split(",")[1];
|
|
|
+
|
|
|
+ System.out.println("符合01条件的结论"+auditConclusionInfo);
|
|
|
+
|
|
|
+ //对01,10项错误结论进行保留,去除01,8、01,9两项错误,新增01,3 项去除
|
|
|
if (auditConclusion.equals("01")) {
|
|
|
- if (Integer.valueOf(auditConclusionInfo) > 7) {
|
|
|
- //上面不需要判断auditConclusionInfo是否为空,如果审核结论不是01,就不会进入判断二级菜单的情况。
|
|
|
- //如果不是01则进行删除该对象元素。
|
|
|
+ //如果不是01下第3项 错误结论则进行删除该对象元素。
|
|
|
+ if (Integer.valueOf(auditConclusionInfo) == 3) {
|
|
|
+ iterator.remove();
|
|
|
+ }
|
|
|
+ //如果不是01下第8项 错误结论则进行删除该对象元素。
|
|
|
+ if (Integer.valueOf(auditConclusionInfo) == 8) {
|
|
|
+ iterator.remove();
|
|
|
+ }
|
|
|
+ //如果不是01下第9项 错误结论则进行删除该对象元素。
|
|
|
+ if (Integer.valueOf(auditConclusionInfo) == 9) {
|
|
|
iterator.remove();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- if(tripResultList==null){
|
|
|
+ if(tripResultList==null|| tripResultList.size()<=0){
|
|
|
+ return tripResultList;
|
|
|
+ }
|
|
|
+
|
|
|
+ //应该先判断tripResultList不为空在进行打印测试
|
|
|
+ System.out.println("剔除3,8,9项错误结论后的列表");
|
|
|
+ for (AuditTripResult result : tripResultList) {
|
|
|
+ System.out.println(result.toString());
|
|
|
+ }
|
|
|
+
|
|
|
+ if(tripResultList==null|| tripResultList.size()<=0){
|
|
|
return tripResultList;
|
|
|
}
|
|
|
|
|
@@ -489,21 +506,53 @@ public class AuditTripResultServiceImpl extends ServiceImpl<AuditTripResultMappe
|
|
|
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 +630,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 +646,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提取审核完成的数据
|
|
|
*
|