|
@@ -344,6 +344,24 @@ public class CrowdProjectServiceImpl implements CrowdProjectService {
|
|
reportForProject.setName(project.getName() + "测试报告");
|
|
reportForProject.setName(project.getName() + "测试报告");
|
|
reportForProject.setType(project.getType());
|
|
reportForProject.setType(project.getType());
|
|
reportForProject.setTestObject(project.getName());
|
|
reportForProject.setTestObject(project.getName());
|
|
|
|
+
|
|
|
|
+ // 更新当前用户的接包数量
|
|
|
|
+ Optional<UserTaskCountPO> userTaskCountPOOptional = userTaskCountDao.findByUserId(user.getId());
|
|
|
|
+ if (!userTaskCountPOOptional.isPresent()) {
|
|
|
|
+ if (user.getRoleList().stream().anyMatch(role -> role.getName().equals(RoleType.EVALUATION_USER.getName()))) {
|
|
|
|
+ Long roleType = RoleType.EVALUATION_USER.getId();
|
|
|
|
+ UserTaskCount userTaskCount = new UserTaskCount(user.getId(), 1L, roleType);
|
|
|
|
+ userTaskCountDao.save(Converter.convert(UserTaskCountPO.class, userTaskCount));
|
|
|
|
+ } else if (user.getRoleList().stream().anyMatch(role -> role.getName().equals(RoleType.AGENCY.getName()))) {
|
|
|
|
+ Long roleType = RoleType.AGENCY.getId();
|
|
|
|
+ UserTaskCount userTaskCount = new UserTaskCount(user.getId(), 1L, roleType);
|
|
|
|
+ userTaskCountDao.save(Converter.convert(UserTaskCountPO.class, userTaskCount));
|
|
|
|
+ }
|
|
|
|
+ } else {
|
|
|
|
+ UserTaskCountPO userTaskCountPO = userTaskCountPOOptional.get();
|
|
|
|
+ userTaskCountPO.setCount(userTaskCountPO.getCount() + 1);
|
|
|
|
+ userTaskCountDao.save(userTaskCountPO);
|
|
|
|
+ }
|
|
});
|
|
});
|
|
return projects;
|
|
return projects;
|
|
}
|
|
}
|