黑名单等入库信息不做判重插入直接入库

main
gaoshuguang 5 months ago
parent fab1dd4fe9
commit a793187cae

@ -60,17 +60,7 @@ public class BigAppointServiceImpl implements BigAppointService {
List<BigAppoint> bigAppoints = JSON.parseObject(json, new TypeReference<List<BigAppoint>>() {
});
if(!bigAppoints.isEmpty()) {
//bigAppoints.forEach(item -> item.setDT(dt));
//count = bigAppointMapper.insertBatchSomeColumn(bigAppoints);
for (BigAppoint e : bigAppoints) {
QueryWrapper<BigAppoint> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("tractorVehicleId", e.getTractorVehicleId())
.eq("certNo", e.getCertNo());
boolean exists = bigAppointMapper.exists(queryWrapper);
if (exists) {
int delete = bigAppointMapper.delete(queryWrapper);
//log.info("[uuid:{}]删除数据库etc_big_appoint表中重复记录{}", uuid, delete);
}
e.setDT(dt);
e.setZipFileName(fileName);
bigAppointMapper.insert(e);

@ -72,22 +72,10 @@ public class CardBlackServiceImpl implements CardBlackService {
op.setIssuerId(StringUtils.isNotBlank((CharSequence) mapList.get("issuerId")) ? (String) mapList.get("issuerId") : null);
op.setStatus((mapList.get("status") != null) ? Integer.valueOf(String.valueOf(mapList.get("status"))) : null);
op.setType((mapList.get("type") != null) ? Integer.valueOf(String.valueOf(mapList.get("type"))) : null);
//cardBlackStatusMapper.insert(op);
//lists.add(op);
QueryWrapper<CardBlackStatus> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("CARDID", op.getCardId())
.eq("STATUS", op.getStatus())
.eq("TYPE", op.getType());
boolean exists = cardBlackStatusMapper.exists(queryWrapper);
if (exists) {
int delete = cardBlackStatusMapper.delete(queryWrapper);
//log.info("[uuid:{}]先删除数据库etc_cardblack_status表中重复记录条数{},再插入最新数据", uuid, delete);
}
op.setZipFileName(fileName);
cardBlackStatusMapper.insert(op);
count++;
}
//count = cardBlackStatusMapper.insertBatchSomeColumn(lists);
}
FileUtil.fileDelete(jsonPath);
log.info("[uuid:{}]插入数据库etc_cardblack_status表中记录{}", uuid, count);

@ -58,20 +58,8 @@ public class EmerCarServiceImpl implements EmerCarService {
List<EmerCar> emerCars = JSON.parseObject(json, new TypeReference<List<EmerCar>>() {
});
if(!emerCars.isEmpty()){
//emerCars.forEach(item -> item.setDT(dt));
//count = emerCarMapper.insertBatchSomeColumn(emerCars);
for (EmerCar e : emerCars) {
QueryWrapper<EmerCar> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("vehicleId", e.getVehicleId())
.eq("id", e.getId())
.eq("startTime", e.getStartTime())
.eq("endTime", e.getEndTime());
boolean exists = emerCarMapper.exists(queryWrapper);
if (exists) {
int delete = emerCarMapper.delete(queryWrapper);
//log.info("[uuid:{}]删除数据库etc_emer_car表中重复记录{}", uuid, delete);
}
e.setDT(dt);
e.setZipFileName(fileName);
emerCarMapper.insert(e);

@ -60,17 +60,7 @@ public class GreenAppointServiceImpl implements GreenAppointService {
List<GreenAppoint> bigAppoints = JSON.parseObject(json, new TypeReference<List<GreenAppoint>>() {
});
if(!bigAppoints.isEmpty()){
//bigAppoints.forEach(item -> item.setDT(dt));
//count = greenAppointMapper.insertBatchSomeColumn(bigAppoints);
for (GreenAppoint e : bigAppoints) {
QueryWrapper<GreenAppoint> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("vehicleId", e.getVehicleId())
.eq("id", e.getId());
boolean exists = greenAppointMapper.exists(queryWrapper);
if (exists) {
int delete = greenAppointMapper.delete(queryWrapper);
//log.info("[uuid:{}]删除数据库etc_green_appoint表中重复记录{}", uuid, delete);
}
e.setDT(dt);
e.setZipFileName(fileName);
greenAppointMapper.insert(e);

@ -70,7 +70,11 @@ public class MinFeeIntoDataBaseServiceImpl implements MinFeeIntoDataBaseService
String url = Constant.SQLITE_PRE + minFeeBackPath + fileName;
String[] split = fileName.split(Constant.STR_);
String exId = split[0];
List<AllRoadMinFee> allRoadMinFees = DatabaseUtil.selectAllRoadMinFee(Constant.SQLITE_DRIVER_NAME, url, Constant.SELECT_ALL_ROAD_MIN_FEE_TABLE);
List<AllRoadMinFee> allRoadMinFees =new ArrayList<>();
if(Constant.STR_ONE.equals(isInMPay) || Constant.STR_ONE.equals(isInJTJT)){
allRoadMinFees = DatabaseUtil.selectAllRoadMinFee(Constant.SQLITE_DRIVER_NAME, url, Constant.SELECT_ALL_ROAD_MIN_FEE_TABLE);
}
log.info("[uuid:{}]查询{}文件ALLROADMINFEE_TABLE表中数据条数为:{}", uuid, fileName, allRoadMinFees.size());
if (!allRoadMinFees.isEmpty()) {
int listSize = allRoadMinFees.size();

@ -71,23 +71,10 @@ public class ObuBlackServiceImpl implements ObuBlackService {
op.setIssuerId(StringUtils.isNotBlank((CharSequence) mapList.get("issuerId")) ? (String) mapList.get("issuerId") : null);
op.setStatus((mapList.get("status") != null) ? Integer.valueOf(String.valueOf(mapList.get("status"))) : null);
op.setType((mapList.get("type") != null) ? Integer.valueOf(String.valueOf(mapList.get("type"))) : null);
//obuBlackStatusMapper.insert(op);
//lists.add(op);
//count++;
QueryWrapper<ObuBlackStatus> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("OBUID", op.getObuId())
.eq("STATUS", op.getStatus())
.eq("TYPE", op.getType());
boolean exists = obuBlackStatusMapper.exists(queryWrapper);
if (exists) {
int delete = obuBlackStatusMapper.delete(queryWrapper);
//log.info("[uuid:{}]删除数据库etc_obublack_status表中重复记录{}", uuid, delete);
}
op.setZipFileName(fileName);
obuBlackStatusMapper.insert(op);
count++;
}
//count = obuBlackStatusMapper.insertBatchSomeColumn(lists);
}
FileUtil.fileDelete(jsonPath);
log.info("[uuid:{}]插入数据库etc_obublack_status表中记录{}", uuid, count);

@ -58,19 +58,7 @@ public class SNBlacklistServiceImpl implements SNBlacklistService {
List<SNBlacklist> emerCars = JSON.parseObject(json, new TypeReference<List<SNBlacklist>>() {
});
if(!emerCars.isEmpty()){
//emerCars.forEach(item -> item.setDT(dt));
//count = sNBlacklistMapper.insertBatchSomeColumn(emerCars);
for (SNBlacklist em : emerCars) {
QueryWrapper<SNBlacklist> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("vehicleId", em.getVehicleId())
.eq("status", em.getStatus())
.eq("oweFee", em.getOweFee())
.eq("creationTime", em.getCreationTime());
boolean exists = sNBlacklistMapper.exists(queryWrapper);
if (exists) {
int delete = sNBlacklistMapper.delete(queryWrapper);
//log.info("[uuid:{}]删除数据库etc_snblack_list表中重复记录{}", uuid, delete);
}
em.setDT(dt);
em.setZipFileName(fileName);
sNBlacklistMapper.insert(em);

Loading…
Cancel
Save