Bläddra i källkod

轧钢平台钢坯接收接口增加根据停浇时间时间过滤

lingpeng.li 1 månad sedan
förälder
incheckning
dca994eadd

+ 1 - 1
zgztBus/jeecg-module-sbm/src/main/java/org/jeecg/modules/actualControl/heatsActuals/controller/BilletSendRecordController.java

@@ -161,7 +161,7 @@ public class BilletSendRecordController extends JeecgController<BilletSendRecord
     }
 
 
-    @Scheduled(cron = "0 */5 * * * ?") // 每5分钟触发一次
+//    @Scheduled(cron = "0 */5 * * * ?") // 每5分钟触发一次
     @ApiOperation(value = "轧钢平台钢坯接收接口", notes = "轧钢平台钢坯接收接口")
     @GetMapping(value = "/sendData")
     public Result<IPage<BilletSendRecord>> sendData() {

+ 3 - 1
zgztBus/jeecg-module-sbm/src/main/java/org/jeecg/modules/actualControl/heatsActuals/service/impl/BilletSendRecordServiceImpl.java

@@ -71,7 +71,9 @@ public class BilletSendRecordServiceImpl extends ServiceImpl<BilletSendRecordMap
     public void sendHeatsActuals() {
         //查询出所有未完成推送的数据
         LambdaQueryWrapper<HeatsActuals> queryHeatsWrapper = new LambdaQueryWrapper<HeatsActuals>()
-                .eq(HeatsActuals::getCompleteStatus, 1);
+                .eq(HeatsActuals::getCompleteStatus, 1)
+                .isNotNull(HeatsActuals::getStartPourTime)
+                .isNotNull(HeatsActuals::getStopPourTime);
 
         List<HeatsActuals> heatsActuals = heatsActualsMapper.selectList(queryHeatsWrapper);