hanrenchun
1 year ago
parent
ecd9a4de0d
commit
ef75232c95
@ -0,0 +1,59 @@
|
|||||||
|
package com.ssf.mysqloracletest.domain;
|
||||||
|
|
||||||
|
import lombok.Data;
|
||||||
|
|
||||||
|
@Data
|
||||||
|
public class VLgryGjxxOracle {
|
||||||
|
private String YJXXID;
|
||||||
|
private String YJLX;
|
||||||
|
private String HDFSSJ;
|
||||||
|
private String YJJDZB;
|
||||||
|
private String YJWDZB;
|
||||||
|
private String YJFBSJ;
|
||||||
|
private String PCZT;
|
||||||
|
private String YJDXLX;
|
||||||
|
private String YJDXMC;
|
||||||
|
private String YJDXHM;
|
||||||
|
private String KEY1;
|
||||||
|
private String VALUE1;
|
||||||
|
private String KEY2;
|
||||||
|
private String VALUE2;
|
||||||
|
private String KEY3;
|
||||||
|
private String VALUE3;
|
||||||
|
private String KEY4;
|
||||||
|
private String VALUE4;
|
||||||
|
private String KEY5;
|
||||||
|
private String VALUE5;
|
||||||
|
private String KEY6;
|
||||||
|
private String VALUE6;
|
||||||
|
private String KEY7;
|
||||||
|
private String VALUE7;
|
||||||
|
private String KEY8;
|
||||||
|
private String VALUE8;
|
||||||
|
private String KEY9;
|
||||||
|
private String VALUE9;
|
||||||
|
private String KEY10;
|
||||||
|
private String VALUE10;
|
||||||
|
private String KEY11;
|
||||||
|
private String VALUE11;
|
||||||
|
private String KEY12;
|
||||||
|
private String VALUE12;
|
||||||
|
private String KEY13;
|
||||||
|
private String VALUE13;
|
||||||
|
private String HDFSDD;
|
||||||
|
private String ZPDT;
|
||||||
|
private String ZPXT;
|
||||||
|
private String RXURL;
|
||||||
|
private String PCMS;
|
||||||
|
private String PCRXM;
|
||||||
|
private String PCRSFZH;
|
||||||
|
private String PCRDWDM;
|
||||||
|
private String PCRDWMC;
|
||||||
|
private String PCSJ;
|
||||||
|
private String HDFSDDDM;
|
||||||
|
private String KEY14;
|
||||||
|
private String VALUE14;
|
||||||
|
private String KEY15;
|
||||||
|
private String VALUE15;
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,30 @@
|
|||||||
|
package com.ssf.mysqloracletest.mapper;
|
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||||
|
import com.ssf.mysqloracletest.domain.VLgryGjxxOracle;
|
||||||
|
import com.ssf.mysqloracletest.domain.VSwryGjxxOracle;
|
||||||
|
import org.apache.ibatis.annotations.Mapper;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【v_sy_sydw_cyry】的数据库操作Mapper
|
||||||
|
* @createDate 2023-11-29 20:30:59
|
||||||
|
* @Entity com.ssf.mysqloracletest.domain.VSySydwCyry
|
||||||
|
*/
|
||||||
|
@Mapper
|
||||||
|
public interface VLgryGjxxOracleMapper extends BaseMapper<VLgryGjxxOracle> {
|
||||||
|
public int countLgry();
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getLgryList(Map map);
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getLgryListByTime(Map map);
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getRealTimeRecording(String maxTime);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -0,0 +1,23 @@
|
|||||||
|
package com.ssf.mysqloracletest.service;
|
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.extension.service.IService;
|
||||||
|
import com.ssf.mysqloracletest.domain.VLgryGjxxOracle;
|
||||||
|
import com.ssf.mysqloracletest.domain.VLgryGjxxOracle;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【v_sy_sydw_Lgry】的数据库操作Service
|
||||||
|
* @createDate 2023-11-29 20:30:59
|
||||||
|
*/
|
||||||
|
public interface VLgryGjxxOracleService extends IService<VLgryGjxxOracle> {
|
||||||
|
public int countLgry();
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getLgryList(Map map);
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getLgryListByTime(Map map);
|
||||||
|
|
||||||
|
public List<VLgryGjxxOracle> getRealTimeRecording(String maxTime);
|
||||||
|
}
|
||||||
@ -0,0 +1,50 @@
|
|||||||
|
package com.ssf.mysqloracletest.service.impl;
|
||||||
|
|
||||||
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
||||||
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||||
|
import com.ssf.mysqloracletest.domain.VLgryGjxxOracle;
|
||||||
|
import com.ssf.mysqloracletest.mapper.VLgryGjxxOracleMapper;
|
||||||
|
import com.ssf.mysqloracletest.service.VLgryGjxxOracleService;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @author 28758
|
||||||
|
* @description 针对表【Lgry】的数据库操作Service实现
|
||||||
|
* @createDate 2023-11-29 20:30:59
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
@DS("oracleSydz")
|
||||||
|
public class VLgryGjxxOracleServiceImpl extends ServiceImpl<VLgryGjxxOracleMapper, VLgryGjxxOracle>
|
||||||
|
implements VLgryGjxxOracleService {
|
||||||
|
|
||||||
|
@Resource
|
||||||
|
private VLgryGjxxOracleMapper oracleMapper;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public int countLgry() {
|
||||||
|
return oracleMapper.countLgry();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<VLgryGjxxOracle> getLgryList(Map map) {
|
||||||
|
return oracleMapper.getLgryList(map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<VLgryGjxxOracle> getLgryListByTime(Map map) {
|
||||||
|
return oracleMapper.getLgryListByTime(map);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public List<VLgryGjxxOracle> getRealTimeRecording(String time) {
|
||||||
|
return oracleMapper.getRealTimeRecording(time);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@ -0,0 +1,186 @@
|
|||||||
|
package com.ssf.mysqloracletest.task;
|
||||||
|
|
||||||
|
import cn.hutool.core.date.DateField;
|
||||||
|
import cn.hutool.core.date.DateTime;
|
||||||
|
import cn.hutool.core.date.DateUtil;
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
||||||
|
import com.ssf.mysqloracletest.domain.TransitImpUserRecord;
|
||||||
|
import com.ssf.mysqloracletest.domain.TransitImpVehicleRecord;
|
||||||
|
import com.ssf.mysqloracletest.domain.VLgryGjxxOracle;
|
||||||
|
import com.ssf.mysqloracletest.service.TransitImpUserRecordService;
|
||||||
|
import com.ssf.mysqloracletest.service.TransitImpVehicleRecordService;
|
||||||
|
import com.ssf.mysqloracletest.service.VLgryGjxxOracleService;
|
||||||
|
import com.ssf.mysqloracletest.utils.ConfigParam;
|
||||||
|
import com.ssf.mysqloracletest.utils.NumKit;
|
||||||
|
import com.ssf.mysqloracletest.utils.StringKit;
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
import org.springframework.scheduling.annotation.Scheduled;
|
||||||
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
import java.text.SimpleDateFormat;
|
||||||
|
import java.util.HashMap;
|
||||||
|
import java.util.List;
|
||||||
|
import java.util.Map;
|
||||||
|
import java.util.concurrent.CountDownLatch;
|
||||||
|
import java.util.concurrent.ExecutorService;
|
||||||
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 用户数据接入
|
||||||
|
*/
|
||||||
|
@Component
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class VLgryGjxxTask {
|
||||||
|
|
||||||
|
private static final Logger logger = LoggerFactory.getLogger(VLgryGjxxTask.class);
|
||||||
|
|
||||||
|
|
||||||
|
String pattern = "yyyyMMddHHmmss";
|
||||||
|
|
||||||
|
SimpleDateFormat dateFormat = new SimpleDateFormat(pattern);
|
||||||
|
|
||||||
|
private final VLgryGjxxOracleService vLgryGjxxOracleService;
|
||||||
|
|
||||||
|
private final TransitImpUserRecordService transitImpUserRecordService;
|
||||||
|
|
||||||
|
private final TransitImpVehicleRecordService transitImpVehicleRecordService;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 连云港 对接海康平台获取人员基础数据
|
||||||
|
* //
|
||||||
|
*/
|
||||||
|
@Scheduled(initialDelay = 100, fixedDelay = 3000)
|
||||||
|
public void translgry() {
|
||||||
|
|
||||||
|
if (!"true".equals(ConfigParam.LgrySwitch)) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
try {
|
||||||
|
long currentTimeMillis = System.currentTimeMillis();
|
||||||
|
// Convert long to DateTime
|
||||||
|
DateTime currentDateTime = DateUtil.date(currentTimeMillis);
|
||||||
|
String currentFormattedDate = null;
|
||||||
|
Long maxTime1 = transitImpVehicleRecordService.selectMaxTime("列管人员");
|
||||||
|
Long maxTime = transitImpUserRecordService.selectMaxTime("列管人员");
|
||||||
|
if (maxTime1 == null && maxTime == null) {
|
||||||
|
// 获取当前时间的格式化字符串
|
||||||
|
currentFormattedDate = currentDateTime.toString("yyyyMMddHHmmss");
|
||||||
|
System.out.println("Current Formatted Date: " + currentFormattedDate);
|
||||||
|
} else {
|
||||||
|
if (maxTime1 <= maxTime) {
|
||||||
|
currentFormattedDate = maxTime1.toString();
|
||||||
|
} else {
|
||||||
|
currentFormattedDate = maxTime.toString();
|
||||||
|
}
|
||||||
|
System.out.println("库中的最大时间" + currentFormattedDate);
|
||||||
|
}
|
||||||
|
System.out.println("最大时间" + currentFormattedDate);
|
||||||
|
// 获取1年后的时间
|
||||||
|
DateTime oneYearLaterDateTime = currentDateTime.offset(DateField.YEAR, 1);
|
||||||
|
String oneYearLaterFormattedDate = oneYearLaterDateTime.toString("yyyyMMddHHmmss");
|
||||||
|
System.out.println("1 Year Later Formatted Date: " + oneYearLaterFormattedDate);
|
||||||
|
Map lgryMap = new HashMap();
|
||||||
|
lgryMap.put("maxTime", currentFormattedDate);
|
||||||
|
lgryMap.put("minTime", oneYearLaterFormattedDate);
|
||||||
|
List<VLgryGjxxOracle> list = vLgryGjxxOracleService.getLgryListByTime(lgryMap);
|
||||||
|
CountDownLatch latch = new CountDownLatch(list.size());
|
||||||
|
ExecutorService LgryPool = Executors.newFixedThreadPool(5);
|
||||||
|
LgryPool.submit(() -> {
|
||||||
|
try {
|
||||||
|
for (VLgryGjxxOracle lgry : list) {
|
||||||
|
if ("10".equals(lgry.getYJLX())) {
|
||||||
|
TransitImpVehicleRecord transitImpVehicleRecord = new TransitImpVehicleRecord();
|
||||||
|
transitImpVehicleRecord.setDeviceCode(lgry.getHDFSDDDM());
|
||||||
|
transitImpVehicleRecord.setLongitude(NumKit.checkBigDecimal(lgry.getYJJDZB()));
|
||||||
|
transitImpVehicleRecord.setLatitude(NumKit.checkBigDecimal(lgry.getYJWDZB()));
|
||||||
|
transitImpVehicleRecord.setDeviceAddress(lgry.getHDFSDD());
|
||||||
|
transitImpVehicleRecord.setOrientation(lgry.getVALUE7());
|
||||||
|
transitImpVehicleRecord.setPlateNo(lgry.getVALUE2());
|
||||||
|
transitImpVehicleRecord.setGlobalPic(lgry.getZPDT());
|
||||||
|
transitImpVehicleRecord.setPlatePic(lgry.getZPXT());
|
||||||
|
transitImpVehicleRecord.setUserPic(lgry.getRXURL());
|
||||||
|
transitImpVehicleRecord.setOwnerName(lgry.getYJDXMC());
|
||||||
|
transitImpVehicleRecord.setIdCard(lgry.getYJDXHM());
|
||||||
|
transitImpVehicleRecord.setPassTime(NumKit.checkLong(lgry.getYJFBSJ()));
|
||||||
|
transitImpVehicleRecord.setPartitionField(dateFormat.parse(lgry.getYJFBSJ()));
|
||||||
|
transitImpVehicleRecord.setPoliceStationName(lgry.getVALUE8());
|
||||||
|
transitImpVehicleRecord.setControlBasis(lgry.getVALUE9());
|
||||||
|
transitImpVehicleRecord.setControlBasisNotes(lgry.getVALUE10());
|
||||||
|
transitImpVehicleRecord.setImpUserTypeName("列管人员");
|
||||||
|
TransitImpVehicleRecord one = transitImpVehicleRecordService.lambdaQuery().eq(TransitImpVehicleRecord::getGlobalPic, lgry.getZPDT()).one();
|
||||||
|
if (one == null) {
|
||||||
|
boolean save = transitImpVehicleRecordService.save(transitImpVehicleRecord);
|
||||||
|
if (save) {
|
||||||
|
logger.info("Lgry-" + lgry.getYJXXID() + ":插入成功");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
UpdateWrapper<TransitImpVehicleRecord> transitImpVehicleRecordUpdateWrapper = new UpdateWrapper<>();
|
||||||
|
transitImpVehicleRecordUpdateWrapper.eq("global_pic", lgry.getZPDT());
|
||||||
|
boolean update = transitImpVehicleRecordService.update(transitImpVehicleRecord, transitImpVehicleRecordUpdateWrapper);
|
||||||
|
if (update) {
|
||||||
|
logger.info("Lgry-" + lgry.getYJXXID() + ":更新成功");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if ("09".equals(lgry.getYJLX())) {
|
||||||
|
TransitImpUserRecord transitImpUserRecord = new TransitImpUserRecord();
|
||||||
|
transitImpUserRecord.setDeviceCode(lgry.getHDFSDDDM());
|
||||||
|
transitImpUserRecord.setLongitude(NumKit.checkBigDecimal(lgry.getYJJDZB()));
|
||||||
|
transitImpUserRecord.setLatitude(NumKit.checkBigDecimal(lgry.getYJWDZB()));
|
||||||
|
transitImpUserRecord.setDeviceAddress(lgry.getHDFSDD());
|
||||||
|
transitImpUserRecord.setGlobalPic(lgry.getZPDT());
|
||||||
|
transitImpUserRecord.setUserPic(lgry.getZPXT());
|
||||||
|
transitImpUserRecord.setSimilarity(lgry.getVALUE2());
|
||||||
|
transitImpUserRecord.setOwnerName(lgry.getYJDXMC());
|
||||||
|
transitImpUserRecord.setIdCard(lgry.getYJDXHM());
|
||||||
|
transitImpUserRecord.setPassTime(NumKit.checkLong(lgry.getYJFBSJ()));
|
||||||
|
transitImpUserRecord.setPartitionField(dateFormat.parse(lgry.getYJFBSJ()));
|
||||||
|
transitImpUserRecord.setPoliceStationName(lgry.getVALUE8());
|
||||||
|
transitImpUserRecord.setControlBasis(lgry.getVALUE9());
|
||||||
|
transitImpUserRecord.setControlBasisNotes(lgry.getVALUE10());
|
||||||
|
transitImpUserRecord.setImpUserTypeName("列管人员");
|
||||||
|
TransitImpUserRecord one = transitImpUserRecordService.lambdaQuery().eq(TransitImpUserRecord::getGlobalPic, lgry.getZPDT()).one();
|
||||||
|
if (one == null) {
|
||||||
|
boolean save = transitImpUserRecordService.save(transitImpUserRecord);
|
||||||
|
if (save) {
|
||||||
|
logger.info("Lgry-" + lgry.getYJXXID() + ":插入成功");
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
UpdateWrapper<TransitImpUserRecord> transitImpUserRecordUpdateWrapper = new UpdateWrapper<>();
|
||||||
|
transitImpUserRecordUpdateWrapper.eq("global_pic", lgry.getZPDT());
|
||||||
|
boolean update = transitImpUserRecordService.update(transitImpUserRecord, transitImpUserRecordUpdateWrapper);
|
||||||
|
if (update) {
|
||||||
|
logger.info("Lgry-" + lgry.getYJXXID() + ":更新成功");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
logger.info("Lgrys:" + StringKit.getTrace(e));
|
||||||
|
}
|
||||||
|
latch.countDown();
|
||||||
|
});
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Wait for all threads to complete
|
||||||
|
latch.await();
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
// 关闭线程池
|
||||||
|
LgryPool.shutdown();
|
||||||
|
|
||||||
|
} catch (
|
||||||
|
Exception e) {
|
||||||
|
logger.info(StringKit.getTrace(e));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
@ -0,0 +1,40 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<!DOCTYPE mapper
|
||||||
|
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||||
|
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||||
|
<mapper namespace="com.ssf.mysqloracletest.mapper.TransitImpUserRecordMapper">
|
||||||
|
|
||||||
|
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TransitImpUserRecord">
|
||||||
|
<id property="id" column="id" jdbcType="BIGINT"/>
|
||||||
|
<result property="deviceCode" column="device_code" jdbcType="VARCHAR"/>
|
||||||
|
<result property="longitude" column="longitude" jdbcType="DECIMAL"/>
|
||||||
|
<result property="latitude" column="latitude" jdbcType="DECIMAL"/>
|
||||||
|
<result property="deviceAddress" column="device_address" jdbcType="VARCHAR"/>
|
||||||
|
<result property="orientation" column="orientation" jdbcType="VARCHAR"/>
|
||||||
|
<result property="globalPic" column="global_pic" jdbcType="VARCHAR"/>
|
||||||
|
<result property="userPic" column="user_pic" jdbcType="VARCHAR"/>
|
||||||
|
<result property="similarity" column="similarity" jdbcType="VARCHAR"/>
|
||||||
|
<result property="ownerName" column="owner_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="idCard" column="id_card" jdbcType="VARCHAR"/>
|
||||||
|
<result property="phone" column="phone" jdbcType="VARCHAR"/>
|
||||||
|
<result property="passTime" column="pass_time" jdbcType="BIGINT"/>
|
||||||
|
<result property="partitionField" column="partition_field" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="policeStationName" column="police_station_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="controlBasis" column="control_basis" jdbcType="VARCHAR"/>
|
||||||
|
<result property="controlBasisNotes" column="control_basis_notes" jdbcType="VARCHAR"/>
|
||||||
|
<result property="impUserTypeName" column="imp_user_type_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="createBy" column="create_by" jdbcType="INTEGER"/>
|
||||||
|
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="updateBy" column="update_by" jdbcType="INTEGER"/>
|
||||||
|
<result property="isActive" column="is_active" jdbcType="TINYINT"/>
|
||||||
|
</resultMap>
|
||||||
|
|
||||||
|
|
||||||
|
<select id="selectMaxTime" parameterType="java.lang.String" resultMap="BaseResultMap">
|
||||||
|
SELECT *
|
||||||
|
FROM transit_imp_user_record
|
||||||
|
WHERE imp_user_type_name = #{impUserTypeName}
|
||||||
|
ORDER BY pass_time desc limit 1;
|
||||||
|
</select>
|
||||||
|
</mapper>
|
||||||
@ -0,0 +1,40 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<!DOCTYPE mapper
|
||||||
|
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||||
|
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||||
|
<mapper namespace="com.ssf.mysqloracletest.mapper.TransitImpVehicleRecordMapper">
|
||||||
|
|
||||||
|
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.TransitImpVehicleRecord">
|
||||||
|
<id property="id" column="id" jdbcType="BIGINT"/>
|
||||||
|
<result property="deviceCode" column="device_code" jdbcType="VARCHAR"/>
|
||||||
|
<result property="longitude" column="longitude" jdbcType="DECIMAL"/>
|
||||||
|
<result property="latitude" column="latitude" jdbcType="DECIMAL"/>
|
||||||
|
<result property="deviceAddress" column="device_address" jdbcType="VARCHAR"/>
|
||||||
|
<result property="orientation" column="orientation" jdbcType="VARCHAR"/>
|
||||||
|
<result property="plateNo" column="plate_no" jdbcType="VARCHAR"/>
|
||||||
|
<result property="globalPic" column="global_pic" jdbcType="VARCHAR"/>
|
||||||
|
<result property="platePic" column="plate_pic" jdbcType="VARCHAR"/>
|
||||||
|
<result property="userPic" column="user_pic" jdbcType="VARCHAR"/>
|
||||||
|
<result property="ownerName" column="owner_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="idCard" column="id_card" jdbcType="VARCHAR"/>
|
||||||
|
<result property="phone" column="phone" jdbcType="VARCHAR"/>
|
||||||
|
<result property="passTime" column="pass_time" jdbcType="BIGINT"/>
|
||||||
|
<result property="partitionField" column="partition_field" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="policeStationName" column="police_station_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="controlBasis" column="control_basis" jdbcType="VARCHAR"/>
|
||||||
|
<result property="controlBasisNotes" column="control_basis_notes" jdbcType="VARCHAR"/>
|
||||||
|
<result property="impUserTypeName" column="imp_user_type_name" jdbcType="VARCHAR"/>
|
||||||
|
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="createBy" column="create_by" jdbcType="INTEGER"/>
|
||||||
|
<result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
|
||||||
|
<result property="updateBy" column="update_by" jdbcType="INTEGER"/>
|
||||||
|
<result property="isActive" column="is_active" jdbcType="TINYINT"/>
|
||||||
|
</resultMap>
|
||||||
|
|
||||||
|
<select id="selectMaxTime" parameterType="java.lang.String" resultMap="BaseResultMap">
|
||||||
|
SELECT *
|
||||||
|
FROM transit_imp_vehicle_record
|
||||||
|
WHERE imp_user_type_name = #{impUserTypeName}
|
||||||
|
ORDER BY pass_time desc limit 1;
|
||||||
|
</select>
|
||||||
|
</mapper>
|
||||||
@ -0,0 +1,81 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<!DOCTYPE mapper
|
||||||
|
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
||||||
|
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||||
|
<mapper namespace="com.ssf.mysqloracletest.mapper.VLgryGjxxOracleMapper">
|
||||||
|
|
||||||
|
<select id="countLgry" resultType="int">
|
||||||
|
select count(*)
|
||||||
|
from SYX_JWYSJ.V_LGRY_GJXX
|
||||||
|
</select>
|
||||||
|
|
||||||
|
<resultMap id="BaseResultMap" type="com.ssf.mysqloracletest.domain.VLgryGjxxOracle">
|
||||||
|
|
||||||
|
<result property="YJXXID" column="YJXXID" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJLX" column="YJLX" jdbcType="VARCHAR"/>
|
||||||
|
<result property="HDFSSJ" column="HDFSSJ" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJJDZB" column="YJJDZB" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJWDZB" column="YJWDZB" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJFBSJ" column="YJFBSJ" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCZT" column="PCZT" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJDXLX" column="YJDXLX" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJDXMC" column="YJDXMC" jdbcType="VARCHAR"/>
|
||||||
|
<result property="YJDXHM" column="YJDXHM" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY1" column="KEY1" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE1" column="VALUE1" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY2" column="KEY2" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE2" column="VALUE2" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY3" column="KEY3" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE3" column="VALUE3" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY4" column="KEY4" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE4" column="VALUE4" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY5" column="KEY5" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE5" column="VALUE5" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY6" column="KEY6" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE6" column="VALUE6" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY7" column="KEY7" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE7" column="VALUE7" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY8" column="KEY8" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE8" column="VALUE8" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY9" column="KEY9" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE9" column="VALUE9" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY10" column="KEY10" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE10" column="VALUE10" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY11" column="KEY11" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE11" column="VALUE11" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY12" column="KEY12" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE12" column="VALUE12" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY13" column="KEY13" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE13" column="VALUE13" jdbcType="VARCHAR"/>
|
||||||
|
<result property="HDFSDD" column="HDFSDD" jdbcType="VARCHAR"/>
|
||||||
|
<result property="ZPDT" column="ZPDT" jdbcType="VARCHAR"/>
|
||||||
|
<result property="ZPXT" column="ZPXT" jdbcType="VARCHAR"/>
|
||||||
|
<result property="RXURL" column="RXURL" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCMS" column="PCMS" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCRXM" column="PCRXM" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCRSFZH" column="PCRSFZH" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCRDWDM" column="PCRDWDM" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCRDWMC" column="PCRDWMC" jdbcType="VARCHAR"/>
|
||||||
|
<result property="PCSJ" column="PCSJ" jdbcType="VARCHAR"/>
|
||||||
|
<result property="HDFSDDDM" column="HDFSDDDM" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY14" column="KEY14" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE14" column="VALUE14" jdbcType="VARCHAR"/>
|
||||||
|
<result property="KEY15" column="KEY15" jdbcType="VARCHAR"/>
|
||||||
|
<result property="VALUE15" column="VALUE15" jdbcType="VARCHAR"/>
|
||||||
|
</resultMap>
|
||||||
|
|
||||||
|
<select id="getLgryList" parameterType="java.util.Map" resultMap="BaseResultMap">
|
||||||
|
SELECT t2.*
|
||||||
|
FROM (SELECT ROWNUM rn, t1.* FROM (SELECT * FROM SYX_JWYSJ.V_LGRY_GJXX) t1 WHERE ROWNUM<![CDATA[ <= ]]> ${rowEnd}) t2
|
||||||
|
WHERE t2.rn <![CDATA[ >= ]]> ${rowStart}
|
||||||
|
</select>
|
||||||
|
|
||||||
|
<select id="getLgryListByTime" parameterType="java.util.Map" resultMap="BaseResultMap">
|
||||||
|
SELECT * FROM SYX_JWYSJ.V_LGRY_GJXX where HDFSSJ <![CDATA[ >= ]]> #{maxTime} and HDFSSJ <![CDATA[ <= ]]> #{minTime}
|
||||||
|
</select>
|
||||||
|
|
||||||
|
<select id="getRealTimeRecording" parameterType="java.util.Map" resultMap="BaseResultMap">
|
||||||
|
SELECT * FROM SYX_JWYSJ.V_LGRY_GJXX where HDFSSJ >#{maxTime}
|
||||||
|
</select>
|
||||||
|
|
||||||
|
</mapper>
|
||||||
Loading…
Reference in new issue