|
|
@ -2,6 +2,7 @@ package com.logpm.factorydata.suofeiya.job; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil; |
|
|
|
import cn.hutool.core.collection.CollUtil; |
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
|
|
|
|
import cn.hutool.json.JSONUtil; |
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
|
|
|
import com.logpm.factorydata.suofeiya.entity.CustomPushEntity; |
|
|
|
import com.logpm.factorydata.suofeiya.entity.CustomPushEntity; |
|
|
|
import com.logpm.factorydata.suofeiya.service.CustomPushService; |
|
|
|
import com.logpm.factorydata.suofeiya.service.CustomPushService; |
|
|
@ -45,6 +46,7 @@ public class AuthPushJob { |
|
|
|
.eq(CustomPushEntity::getSendStatus, 0) |
|
|
|
.eq(CustomPushEntity::getSendStatus, 0) |
|
|
|
.orderByAsc(CustomPushEntity::getNodeCode) |
|
|
|
.orderByAsc(CustomPushEntity::getNodeCode) |
|
|
|
.last("limit 1")); |
|
|
|
.last("limit 1")); |
|
|
|
|
|
|
|
log.info("回推工厂数据:{}", JSONUtil.toJsonStr(list)); |
|
|
|
if (CollUtil.isNotEmpty(list)) { |
|
|
|
if (CollUtil.isNotEmpty(list)) { |
|
|
|
CustomPushEntity customPushEntity = list.get(0); |
|
|
|
CustomPushEntity customPushEntity = list.get(0); |
|
|
|
if (StrUtil.isNotEmpty(customPushEntity.getContent())) { |
|
|
|
if (StrUtil.isNotEmpty(customPushEntity.getContent())) { |
|
|
|