| | |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import com.ycl.api.CommonResult; |
| | | import com.ycl.bo.AdminUserDetails; |
| | | import com.ycl.common.constant.BaseCaseStatus; |
| | | import com.ycl.common.constant.StepName; |
| | |
| | | import com.ycl.service.caseHandler.*; |
| | | import com.ycl.service.resources.IImageResourcesService; |
| | | import com.ycl.vo.MyBacklogVO; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | * @since 2022-09-24 |
| | | */ |
| | | @Service |
| | | @Slf4j |
| | | public class DisposeRecordServiceImpl extends ServiceImpl<DisposeRecordMapper, DisposeRecord> implements IDisposeRecordService { |
| | | |
| | | @Resource |
| | |
| | | } |
| | | |
| | | @Override |
| | | public Long listMyTaskCount(String num, Long userId, Short type, Short source, Short time) { |
| | | LocalDateTime alarmTimeStart = null; |
| | | LocalDateTime alarmTimeEnd = null; |
| | | if (Objects.equals(time, LAST_WEEK)) { |
| | | alarmTimeStart = LocalDateTime.now().minusDays(7); |
| | | alarmTimeEnd = LocalDateTime.now(); |
| | | } else if (Objects.equals(time, LAST_MONTH)) { |
| | | alarmTimeStart = LocalDateTime.now().minusMonths(1); |
| | | alarmTimeEnd = LocalDateTime.now(); |
| | | } else if (Objects.equals(time, LAST_THREEMONTH)) { |
| | | alarmTimeStart = LocalDateTime.now().minusMonths(3); |
| | | alarmTimeEnd = LocalDateTime.now(); |
| | | } |
| | | return disposeRecordMapper.selectMyBackListTotal(userId, num, alarmTimeStart, alarmTimeEnd, source, type); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Boolean saveOrUpdateUpload(UploadDisposingResultParam uploadDisposingResultParam) { |
| | | public CommonResult saveOrUpdateUpload(UploadDisposingResultParam uploadDisposingResultParam) { |
| | | log.info("参数------------------>{}", uploadDisposingResultParam); |
| | | if (uploadDisposingResultParam.getArrivalTime() != null) { |
| | | uploadDisposingResultParam.setArrivalTime(uploadDisposingResultParam.getArrivalTime().replace("/", "-")); |
| | | } |
| | | if (uploadDisposingResultParam.getInvestigationTime() != null) { |
| | | uploadDisposingResultParam.setInvestigationTime(uploadDisposingResultParam.getInvestigationTime().replace("/", "-")); |
| | | } |
| | | |
| | | AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal(); |
| | | List<ArrivalSituation> list = iArrivalSituationService.list(new LambdaQueryWrapper<ArrivalSituation>().eq(ArrivalSituation::getBaseCaseId, uploadDisposingResultParam.getCaseId())); |
| | | if (!list.isEmpty()) { |
| | |
| | | //设置流程环节数据 |
| | | disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId()); |
| | | disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId()); |
| | | return baseMapper.insert(disposeRecord) == 1 ? true : false; |
| | | boolean result = baseMapper.insert(disposeRecord) == 1 ? true : false; |
| | | if (!result) { |
| | | CommonResult.failed("已提交,请勿重复提交"); |
| | | } |
| | | return CommonResult.success("add success"); |
| | | } |
| | | } |