blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-09-17 e13b129c300d3eff2ba555d0c41bbccbaab1014a 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -26,6 +26,7 @@


import com.ycl.platform.wvp.WVPResult;


import com.ycl.system.Result;


import com.ycl.system.domain.SysConfig;


import com.ycl.system.entity.SysDictData;


import com.ycl.system.mapper.SysConfigMapper;


import com.ycl.system.mapper.SysDictDataMapper;


import com.ycl.system.model.LoginUser;


@@ -55,11 +56,6 @@


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;




import javax.imageio.ImageIO;


import javax.swing.*;


import java.awt.image.BufferedImage;


import java.io.File;


import java.io.IOException;


import java.time.LocalDateTime;


import java.time.ZoneId;


import java.util.*;


@@ -101,7 +97,7 @@




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) {


    public synchronized Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) {


        int total = workOrderList.size();


        workOrderList.stream().filter(item -> {


            return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && !CollectionUtils.isEmpty(item.getErrorTypeList());


@@ -689,6 +685,8 @@


                FFmpegFrameGrabber grabber = null;


                try {


                    grabber = FFmpegFrameGrabber.createDefault(rtspUrl);


                    //设置10s超时


                    grabber.setTimeout(10000);


                    grabber.start();


                    Frame frame = grabber.grabImage(); // 直接捕获一帧


                    if (frame != null) {


@@ -782,4 +780,19 @@


        }


        return Result.ok().data(process);


    }




    @Override


    public Result detailByNo(String workOrderNo) {


        WorkOrderDetailVO workOrder = baseMapper.detailByNo(workOrderNo);


        // 是否报备


        boolean hasReport = new LambdaQueryChainWrapper<>(reportMapper)


                .eq(Report::getSerialNumber, workOrder.getSerialNumber())


                .exists();


        workOrder.setHasReport(hasReport);


        // 故障类型


        List<SysDictData> errorList = workOrderErrorTypeService.getBaseMapper().getErrorList(workOrder.getWorkOrderNo());


        List<String> errList = errorList.stream().map(SysDictData::getDictLabel).collect(Collectors.toList());


        workOrder.setErrorTypeList(errList);


        return Result.ok().data(workOrder);


    }


}