| | |
| | | package cn.flightfeather.supervision.timingtask |
| | | |
| | | import cn.flightfeather.supervision.SupervisionApplication |
| | | import cn.flightfeather.supervision.common.net.FumeHttpService |
| | | import cn.flightfeather.supervision.domain.entity.AvgFumeMinuteValue |
| | | import cn.flightfeather.supervision.domain.entity.FumeMinuteValue |
| | | import cn.flightfeather.supervision.domain.mapper.AvgFumeMinuteValueMapper |
| | |
| | | import java.util.* |
| | | import java.util.concurrent.Executors |
| | | import java.util.concurrent.TimeUnit |
| | | import kotlin.math.round |
| | | |
| | | @RunWith(SpringJUnit4ClassRunner::class) |
| | | @SpringBootTest(classes = [SupervisionApplication::class]) |
| | | class PushFumeTest { |
| | | |
| | | @Autowired |
| | | lateinit var pushFume: PushFume |
| | | lateinit var pushFume: TaskPushFume |
| | | |
| | | @Autowired |
| | | lateinit var fumeMinuteValueMapper: FumeMinuteValueMapper |
| | | |
| | | @Autowired |
| | | lateinit var avgFumeMinuteValueMapper: AvgFumeMinuteValueMapper |
| | | |
| | | private val dateUtil = DateUtil() |
| | | |
| | | @Test |
| | | fun doTask() { |
| | |
| | | |
| | | list.forEach { |
| | | fumeMinuteValue.mvStatCode = it.mvStatCode |
| | | fumeMinuteValue.mvCreateTime = dateUtil.StringToDate(section) |
| | | fumeMinuteValue.mvDataTime = dateUtil.StringToDate(section) |
| | | fumeMinuteValue.mvCreateTime = DateUtil.StringToDate(section) |
| | | fumeMinuteValue.mvDataTime = DateUtil.StringToDate(section) |
| | | fumeMinuteValue.mvSignal = it.mvSignal |
| | | fumeMinuteValue.mvFanStatus = it.mvFanStatus |
| | | fumeMinuteValue.mvPurifierStatus = it.mvPurifierStatus |