riku
2019-09-23 14ce5d2ccfae554497763da846ffb9eb39cd6d34
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
package com.flightfeather.obd.repository.impl
 
import com.flightfeather.obd.domain.entity.CarLogin
import com.flightfeather.obd.domain.mapper.CarLoginMapper
import com.flightfeather.obd.lightshare.bean.CarLoginVo
import com.flightfeather.obd.repository.CarLoginRepository
import com.flightfeather.obd.socket.bean.CarRegisterData
import com.flightfeather.obd.socket.bean.ObdPackageData
import com.flightfeather.obd.socket.eunm.ObdCommandUnit
import com.github.pagehelper.PageHelper
import org.springframework.beans.BeanUtils
import org.springframework.stereotype.Repository
import tk.mybatis.mapper.entity.Example
 
/**
 * @author riku
 * Date: 2019/9/17
 */
@Repository
class CarLoginDaoImpl(val carLoginMapper: CarLoginMapper) : CarLoginRepository {
 
    override fun saveCarLogin(packageData: ObdPackageData): Boolean {
 
        return if (packageData.commandUnit == ObdCommandUnit.CarRegister.value) {
            val carLogin = CarLogin().apply {
                obdDeviceCode = packageData.deviceCode
            }
 
            packageData.dataUnit.forEach {
                when (it) {
                    is CarRegisterData -> carLogin.apply {
                        loginDataTime = it.time
                        loginSerialNum = it.serialNum
                        loginSimCode = it.SIMCode
                    }
                }
            }
 
            carLoginMapper.insert(carLogin) == 1
        } else {
            false
        }
    }
 
    override fun getLoginData(deviceCode: String, pageNum: Int?, pageSize: Int?, startTime: String?, endTime: String?): List<CarLoginVo> {
        val example = Example(CarLogin::class.java).apply {
            createCriteria().andEqualTo("obdDeviceCode", deviceCode).run {
                startTime?.let { andGreaterThanOrEqualTo("loginDataTime", it) }
                endTime?.let { andLessThanOrEqualTo("loginDataTime", it) }
                orderBy("loginDataTime").desc()
            }
        }
 
        //分页
        val offset = (pageSize?.times(pageNum?.minus(1) ?: 0)) ?: 0
        PageHelper.offsetPage<CarLogin>(offset, pageSize ?: 10)
        val result = carLoginMapper.selectByExample(example)
 
        val resultList = mutableListOf<CarLoginVo>()
        result.forEach {
            val vo = CarLoginVo()
            BeanUtils.copyProperties(it, vo)
            resultList.add(vo)
        }
 
        return resultList
    }
}