| | |
| | | import com.dy.common.webUtil.QueryResultVo; |
| | | import com.dy.pmsGlobal.aop.Log; |
| | | import com.dy.pmsGlobal.pojoPr.PrAssemblyPlan; |
| | | import com.dy.pmsGlobal.pojoPr.PrEquip; |
| | | import com.dy.pmsGlobal.pojoPr.PrDevice; |
| | | import com.dy.pmsGlobal.util.QrCodeUtil; |
| | | import com.google.zxing.WriterException; |
| | | import jakarta.servlet.http.HttpServletResponse; |
| | | import jakarta.validation.Valid; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.validation.BindingResult; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.io.IOException; |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | |
| | | /** |
| | | * 组装任务计划 |
| | |
| | | /** |
| | | * 增加设备号 |
| | | */ |
| | | @PostMapping(path="addEquip") |
| | | @PostMapping(path="addDevice") |
| | | @SsoPowerAop(power = "-1") |
| | | @Log("增加设备号") |
| | | public BaseResponse<?> addEquip(@RequestBody QueryVo vo){ |
| | | public BaseResponse<?> addDevice(@RequestBody QueryVo vo){ |
| | | if(vo.addNum == null || vo.addNum <= 0 || vo.planId == null){ |
| | | return BaseResponseUtils.buildFail("参数错误"); |
| | | } |
| | | int count = sv.addEquip(vo.planId,vo.addNum); |
| | | int count = sv.addDevice(vo.planId,vo.addNum); |
| | | if (count <= 0) { |
| | | return BaseResponseUtils.buildFail("数据库存储失败"); |
| | | } else { |
| | |
| | | } |
| | | } |
| | | |
| | | @PostMapping(path="someEquip") |
| | | @PostMapping(path="someDevice") |
| | | @SsoPowerAop(power = "-1") |
| | | @Log("分页查询设备号") |
| | | public BaseResponse<QueryResultVo<List<PrEquip>>> someEquip(@RequestBody QueryVo queryVo){ |
| | | QueryResultVo<List<PrEquip>> list = sv.selectSomeEquip(queryVo) ; |
| | | public BaseResponse<QueryResultVo<List<PrDevice>>> someDevice(@RequestBody QueryVo queryVo){ |
| | | QueryResultVo<List<PrDevice>> list = sv.selectSomeDevice(queryVo) ; |
| | | return BaseResponseUtils.buildSuccess(list); |
| | | } |
| | | |
| | | @GetMapping(path="exportEquip") |
| | | @GetMapping(path="exportDevice") |
| | | @SsoPowerAop(power = "-1") |
| | | @Log("导出设备号") |
| | | public void exportEquip(Long batchId, HttpServletResponse response){ |
| | | public void exportDevice(Long batchId, HttpServletResponse response){ |
| | | Date start = new Date() ; |
| | | List<Converter> list = new ArrayList<>(); |
| | | |
| | | List<PrEquip> equipList = sv.selectEquipByBatchId(batchId) ; |
| | | List<PrDevice> deviceList = sv.selectDeviceByBatchId(batchId) ; |
| | | // 使用并行流提高性能 |
| | | equipList.parallelStream().forEach(equip -> { |
| | | deviceList.parallelStream().forEach(device -> { |
| | | ExcelVo vo = new ExcelVo(); |
| | | vo.equipNo = equip.equipNo; |
| | | vo.deviceNo = device.deviceNo; |
| | | try { |
| | | vo.qrCode = QrCodeUtil.genQrCode(vo.equipNo); |
| | | vo.qrCode = QrCodeUtil.genQrCode(vo.deviceNo); |
| | | } catch (IOException | WriterException e) { |
| | | e.printStackTrace(); |
| | | } |