Compare commits
No commits in common. '2b346567ed668617040e7275412f29fa3d250c35' and 'd57ff4141b062ca2600d3bffd3fc3b585e0d7430' have entirely different histories.
2b346567ed
...
d57ff4141b
@ -1,56 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.domain;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.annotation.IdType;
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableId;
|
|
||||||
import com.baomidou.mybatisplus.annotation.TableName;
|
|
||||||
import lombok.Data;
|
|
||||||
import lombok.EqualsAndHashCode;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋信息表(MetaRealEstateInfo)Domain
|
|
||||||
*
|
|
||||||
* @author makejava
|
|
||||||
* @since 2023-12-05 09:24:09
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
@EqualsAndHashCode(callSuper = false)
|
|
||||||
@TableName(value = "meta_real_estate_info")
|
|
||||||
public class MetaRealEstateInfo {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 主键
|
|
||||||
*/
|
|
||||||
@TableId(value = "id", type = IdType.AUTO)
|
|
||||||
private Long id;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 房屋ID
|
|
||||||
*/
|
|
||||||
private String homeId;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 派出所代码
|
|
||||||
*/
|
|
||||||
private String policeStationCode;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 警务区编码
|
|
||||||
*/
|
|
||||||
private String policeDistrictCode;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋地址
|
|
||||||
*/
|
|
||||||
private String realEstateAddress;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 经度
|
|
||||||
*/
|
|
||||||
private Double longitude;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 纬度
|
|
||||||
*/
|
|
||||||
private Double latitude;
|
|
||||||
|
|
||||||
}
|
|
@ -1,30 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.domain;
|
|
||||||
|
|
||||||
import lombok.Data;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋对象 v_jwt_syfw
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
* @date 2023-12-04
|
|
||||||
*/
|
|
||||||
@Data
|
|
||||||
public class VJwtSyfw {
|
|
||||||
|
|
||||||
private Long id;
|
|
||||||
|
|
||||||
private String pcsdm;
|
|
||||||
|
|
||||||
private String jwqdm;
|
|
||||||
|
|
||||||
private String mc;
|
|
||||||
|
|
||||||
private String x;
|
|
||||||
|
|
||||||
private String y;
|
|
||||||
|
|
||||||
private String oldid;
|
|
||||||
|
|
||||||
private String status;
|
|
||||||
|
|
||||||
}
|
|
@ -1,16 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.mapper;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
|
|
||||||
import org.apache.ibatis.annotations.Mapper;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋信息表(MetaRealEstateInfo)Mapper
|
|
||||||
*
|
|
||||||
* @author makejava
|
|
||||||
* @since 2023-12-05 09:24:09
|
|
||||||
*/
|
|
||||||
@Mapper
|
|
||||||
public interface MetaRealEstateInfoMapper extends BaseMapper<MetaRealEstateInfo> {
|
|
||||||
|
|
||||||
}
|
|
@ -1,64 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.mapper;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
||||||
import com.ssf.mysqloracletest.domain.VJwtSyfw;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 【请填写功能名称】Mapper接口
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
* @date 2023-12-04
|
|
||||||
*/
|
|
||||||
public interface VJwtSyfwMapper extends BaseMapper<VJwtSyfw> {
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 【请填写功能名称】
|
|
||||||
*/
|
|
||||||
public VJwtSyfw selectVJwtSyfwById(Long id);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】列表
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 【请填写功能名称】集合
|
|
||||||
*/
|
|
||||||
public List<VJwtSyfw> selectVJwtSyfwList(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int insertVJwtSyfw(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 修改【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int updateVJwtSyfw(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
public int updateVJwtSyfwByMc(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteVJwtSyfwById(Long id);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param ids 需要删除的数据主键集合
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteVJwtSyfwByIds(Long[] ids);
|
|
||||||
}
|
|
@ -1,69 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.service;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
|
||||||
import com.ssf.mysqloracletest.domain.VJwtSyfw;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 【请填写功能名称】Service接口
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
* @date 2023-12-04
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public interface JwtSyfwService extends IService<VJwtSyfw> {
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 【请填写功能名称】
|
|
||||||
*/
|
|
||||||
public VJwtSyfw selectVJwtSyfwById(Long id);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】列表
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 【请填写功能名称】集合
|
|
||||||
*/
|
|
||||||
public List<VJwtSyfw> selectVJwtSyfwList(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int insertVJwtSyfw(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 修改【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int updateVJwtSyfw(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
public int updateVJwtSyfwByMc(VJwtSyfw vJwtSyfw);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param ids 需要删除的【请填写功能名称】主键集合
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteVJwtSyfwByIds(Long[] ids);
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除【请填写功能名称】信息
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
public int deleteVJwtSyfwById(Long id);
|
|
||||||
|
|
||||||
|
|
||||||
public boolean saveOrUpdate(VJwtSyfw bean);
|
|
||||||
}
|
|
@ -1,23 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.service;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.IService;
|
|
||||||
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋信息表(MetaRealEstateInfo)Service
|
|
||||||
*
|
|
||||||
* @author makejava
|
|
||||||
* @since 2023-12-05 09:24:09
|
|
||||||
*/
|
|
||||||
public interface MetaRealEstateInfoService extends IService<MetaRealEstateInfo> {
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增或者更新实有房屋信息表
|
|
||||||
*
|
|
||||||
* @param metaRealEstateInfo 实有房屋信息表对象
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
boolean insertOrUpdate(MetaRealEstateInfo metaRealEstateInfo);
|
|
||||||
|
|
||||||
}
|
|
@ -1,24 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.service.impl;
|
|
||||||
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
||||||
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
|
|
||||||
import com.ssf.mysqloracletest.mapper.MetaRealEstateInfoMapper;
|
|
||||||
import com.ssf.mysqloracletest.service.MetaRealEstateInfoService;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 实有房屋信息表(MetaRealEstateInfo)ServiceImpl
|
|
||||||
*
|
|
||||||
* @author makejava
|
|
||||||
* @since 2023-12-05 09:24:09
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
public class MetaRealEstateInfoServiceImpl extends ServiceImpl<MetaRealEstateInfoMapper, MetaRealEstateInfo> implements MetaRealEstateInfoService {
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean insertOrUpdate(MetaRealEstateInfo metaRealEstateInfo) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
@ -1,117 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.service.impl;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
||||||
import com.ssf.mysqloracletest.domain.VJwtSyfw;
|
|
||||||
import com.ssf.mysqloracletest.mapper.VJwtSyfwMapper;
|
|
||||||
import com.ssf.mysqloracletest.service.JwtSyfwService;
|
|
||||||
import lombok.RequiredArgsConstructor;
|
|
||||||
import org.springframework.stereotype.Service;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 【请填写功能名称】Service业务层处理
|
|
||||||
*
|
|
||||||
* @author ruoyi
|
|
||||||
* @date 2023-12-04
|
|
||||||
*/
|
|
||||||
@Service
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class VJwtSyfwServiceImpl extends ServiceImpl<VJwtSyfwMapper, VJwtSyfw>
|
|
||||||
implements JwtSyfwService {
|
|
||||||
|
|
||||||
|
|
||||||
private final VJwtSyfwMapper vJwtSyfwMapper;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 【请填写功能名称】
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public VJwtSyfw selectVJwtSyfwById(Long id) {
|
|
||||||
return vJwtSyfwMapper.selectVJwtSyfwById(id);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 查询【请填写功能名称】列表
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 【请填写功能名称】
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public List<VJwtSyfw> selectVJwtSyfwList(VJwtSyfw vJwtSyfw) {
|
|
||||||
return vJwtSyfwMapper.selectVJwtSyfwList(vJwtSyfw);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 新增【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int insertVJwtSyfw(VJwtSyfw vJwtSyfw) {
|
|
||||||
return vJwtSyfwMapper.insertVJwtSyfw(vJwtSyfw);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 修改【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param vJwtSyfw 【请填写功能名称】
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int updateVJwtSyfw(VJwtSyfw vJwtSyfw) {
|
|
||||||
return vJwtSyfwMapper.updateVJwtSyfw(vJwtSyfw);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public int updateVJwtSyfwByMc(VJwtSyfw vJwtSyfw) {
|
|
||||||
return vJwtSyfwMapper.updateVJwtSyfwByMc(vJwtSyfw);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 批量删除【请填写功能名称】
|
|
||||||
*
|
|
||||||
* @param ids 需要删除的【请填写功能名称】主键
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int deleteVJwtSyfwByIds(Long[] ids) {
|
|
||||||
return vJwtSyfwMapper.deleteVJwtSyfwByIds(ids);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 删除【请填写功能名称】信息
|
|
||||||
*
|
|
||||||
* @param id 【请填写功能名称】主键
|
|
||||||
* @return 结果
|
|
||||||
*/
|
|
||||||
@Override
|
|
||||||
public int deleteVJwtSyfwById(Long id) {
|
|
||||||
return vJwtSyfwMapper.deleteVJwtSyfwById(id);
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean saveOrUpdate(VJwtSyfw bean) {
|
|
||||||
VJwtSyfw syfwPara = new VJwtSyfw();
|
|
||||||
syfwPara.setMc(bean.getMc());
|
|
||||||
List<VJwtSyfw> syfws = selectVJwtSyfwList(syfwPara);
|
|
||||||
if (syfws != null && syfws.size() > 0) {
|
|
||||||
//根据地址更新数据
|
|
||||||
updateVJwtSyfwByMc(bean);
|
|
||||||
} else {
|
|
||||||
//插入数据
|
|
||||||
insertVJwtSyfw(bean);
|
|
||||||
}
|
|
||||||
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
@ -1,107 +0,0 @@
|
|||||||
package com.ssf.mysqloracletest.task;
|
|
||||||
|
|
||||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
||||||
import com.ssf.mysqloracletest.domain.MetaRealEstateInfo;
|
|
||||||
import com.ssf.mysqloracletest.domain.VJwtSyfw;
|
|
||||||
import com.ssf.mysqloracletest.service.JwtSyfwService;
|
|
||||||
import com.ssf.mysqloracletest.service.MetaRealEstateInfoService;
|
|
||||||
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.beans.BeanUtils;
|
|
||||||
import org.springframework.scheduling.annotation.Scheduled;
|
|
||||||
import org.springframework.stereotype.Component;
|
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.concurrent.CountDownLatch;
|
|
||||||
import java.util.concurrent.ExecutorService;
|
|
||||||
import java.util.concurrent.Executors;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 用户数据接入
|
|
||||||
*/
|
|
||||||
@Component
|
|
||||||
@RequiredArgsConstructor
|
|
||||||
public class MetaRealEstateInfoTask {
|
|
||||||
|
|
||||||
private static final Logger logger = LoggerFactory.getLogger(MetaRealEstateInfoTask.class);
|
|
||||||
|
|
||||||
private final MetaRealEstateInfoService estateInfoService;
|
|
||||||
private final JwtSyfwService jwySyfwService;
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
|
||||||
* 清洗实有房屋
|
|
||||||
*/
|
|
||||||
@Scheduled(initialDelay = 100, fixedDelay = 3000)
|
|
||||||
public void transMetaRealEstateInfo() {
|
|
||||||
|
|
||||||
if (!"true".equals(ConfigParam.metaRealEstateInfoSwitch)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
QueryWrapper<VJwtSyfw> queryWrapper = new QueryWrapper<>();
|
|
||||||
queryWrapper.isNull("status");
|
|
||||||
Page<VJwtSyfw> page = new Page<>(1, 1000);
|
|
||||||
List<VJwtSyfw> resultList = jwySyfwService.page(page, queryWrapper).getRecords();
|
|
||||||
|
|
||||||
CountDownLatch latch = new CountDownLatch(resultList.size());
|
|
||||||
ExecutorService jwtSyfwPool = Executors.newFixedThreadPool(50);
|
|
||||||
|
|
||||||
for (VJwtSyfw bean : resultList) {
|
|
||||||
jwtSyfwPool.submit(() -> {
|
|
||||||
cleanJwtSyfw(bean);
|
|
||||||
latch.countDown();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
try {
|
|
||||||
// Wait for all threads to complete
|
|
||||||
latch.await();
|
|
||||||
} catch (InterruptedException e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
// 关闭线程池
|
|
||||||
jwtSyfwPool.shutdown();
|
|
||||||
} catch (Exception e) {
|
|
||||||
logger.info(StringKit.getTrace(e));
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
private void cleanJwtSyfw(VJwtSyfw bean) {
|
|
||||||
VJwtSyfw jwtSyfwCp = new VJwtSyfw();
|
|
||||||
try {
|
|
||||||
|
|
||||||
BeanUtils.copyProperties(bean, jwtSyfwCp);
|
|
||||||
MetaRealEstateInfo realEstateInfo = new MetaRealEstateInfo();
|
|
||||||
// realEstateInfo.setId();
|
|
||||||
// realEstateInfo.setHomeId();
|
|
||||||
realEstateInfo.setPoliceStationCode(StringKit.toString(jwtSyfwCp.getPcsdm()));
|
|
||||||
realEstateInfo.setPoliceDistrictCode(StringKit.toString(jwtSyfwCp.getJwqdm()));
|
|
||||||
realEstateInfo.setRealEstateAddress(StringKit.toString(jwtSyfwCp.getMc()));
|
|
||||||
realEstateInfo.setLongitude(NumKit.checkDouble(jwtSyfwCp.getY()));
|
|
||||||
realEstateInfo.setLatitude(NumKit.checkDouble(jwtSyfwCp.getX()));
|
|
||||||
boolean b = estateInfoService.save(realEstateInfo);
|
|
||||||
|
|
||||||
if (b) {
|
|
||||||
jwtSyfwCp.setStatus("1");
|
|
||||||
jwySyfwService.updateVJwtSyfw(jwtSyfwCp);
|
|
||||||
}
|
|
||||||
} catch (Exception e) {
|
|
||||||
logger.info(StringKit.getTrace(e));
|
|
||||||
jwtSyfwCp.setStatus("2");
|
|
||||||
jwySyfwService.updateVJwtSyfw(jwtSyfwCp);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
@ -1,97 +0,0 @@
|
|||||||
<?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.VJwtSyfwMapper">
|
|
||||||
|
|
||||||
<resultMap type="com.ssf.mysqloracletest.domain.VJwtSyfw" id="VJwtSyfwResult">
|
|
||||||
<result property="id" column="id" />
|
|
||||||
<result property="pcsdm" column="pcsdm" />
|
|
||||||
<result property="jwqdm" column="jwqdm" />
|
|
||||||
<result property="mc" column="mc" />
|
|
||||||
<result property="x" column="x" />
|
|
||||||
<result property="y" column="y" />
|
|
||||||
<result property="oldid" column="oldid" />
|
|
||||||
<result property="status" column="status" />
|
|
||||||
</resultMap>
|
|
||||||
|
|
||||||
<sql id="selectVJwtSyfwVo">
|
|
||||||
select id, pcsdm, jwqdm, mc, x, y, oldid,status from v_jwt_syfw
|
|
||||||
</sql>
|
|
||||||
|
|
||||||
<select id="selectVJwtSyfwList" parameterType="com.ssf.mysqloracletest.domain.VJwtSyfw" resultMap="VJwtSyfwResult">
|
|
||||||
<include refid="selectVJwtSyfwVo"/>
|
|
||||||
<where>
|
|
||||||
<if test="pcsdm != null and pcsdm != ''"> and pcsdm = #{pcsdm}</if>
|
|
||||||
<if test="jwqdm != null and jwqdm != ''"> and jwqdm = #{jwqdm}</if>
|
|
||||||
<if test="mc != null and mc != ''"> and mc = #{mc}</if>
|
|
||||||
<if test="x != null and x != ''"> and x = #{x}</if>
|
|
||||||
<if test="y != null and y != ''"> and y = #{y}</if>
|
|
||||||
<if test="oldid != null and oldid != ''"> and oldid = #{oldid}</if>
|
|
||||||
</where>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<select id="selectVJwtSyfwById" parameterType="Long" resultMap="VJwtSyfwResult">
|
|
||||||
<include refid="selectVJwtSyfwVo"/>
|
|
||||||
where id = #{id}
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<insert id="insertVJwtSyfw" parameterType="com.ssf.mysqloracletest.domain.VJwtSyfw" useGeneratedKeys="true" keyProperty="id">
|
|
||||||
insert into v_jwt_syfw
|
|
||||||
<trim prefix="(" suffix=")" suffixOverrides=",">
|
|
||||||
<if test="pcsdm != null">pcsdm,</if>
|
|
||||||
<if test="jwqdm != null">jwqdm,</if>
|
|
||||||
<if test="mc != null">mc,</if>
|
|
||||||
<if test="x != null">x,</if>
|
|
||||||
<if test="y != null">y,</if>
|
|
||||||
<if test="oldid != null">oldid,</if>
|
|
||||||
<if test="status != null">status,</if>
|
|
||||||
</trim>
|
|
||||||
<trim prefix="values (" suffix=")" suffixOverrides=",">
|
|
||||||
<if test="pcsdm != null">#{pcsdm},</if>
|
|
||||||
<if test="jwqdm != null">#{jwqdm},</if>
|
|
||||||
<if test="mc != null">#{mc},</if>
|
|
||||||
<if test="x != null">#{x},</if>
|
|
||||||
<if test="y != null">#{y},</if>
|
|
||||||
<if test="oldid != null">#{oldid},</if>
|
|
||||||
<if test="status != null">#{status},</if>
|
|
||||||
</trim>
|
|
||||||
</insert>
|
|
||||||
|
|
||||||
<update id="updateVJwtSyfw" parameterType="com.ssf.mysqloracletest.domain.VJwtSyfw">
|
|
||||||
update v_jwt_syfw
|
|
||||||
<trim prefix="SET" suffixOverrides=",">
|
|
||||||
<if test="pcsdm != null">pcsdm = #{pcsdm},</if>
|
|
||||||
<if test="jwqdm != null">jwqdm = #{jwqdm},</if>
|
|
||||||
<if test="mc != null">mc = #{mc},</if>
|
|
||||||
<if test="x != null">x = #{x},</if>
|
|
||||||
<if test="y != null">y = #{y},</if>
|
|
||||||
<if test="oldid != null">oldid = #{oldid},</if>
|
|
||||||
<if test="status != null">status = #{status},</if>
|
|
||||||
</trim>
|
|
||||||
where id = #{id}
|
|
||||||
</update>
|
|
||||||
|
|
||||||
<update id="updateVJwtSyfwByMc" parameterType="com.ssf.mysqloracletest.domain.VJwtSyfw">
|
|
||||||
update v_jwt_syfw
|
|
||||||
<trim prefix="SET" suffixOverrides=",">
|
|
||||||
<if test="pcsdm != null">pcsdm = #{pcsdm},</if>
|
|
||||||
<if test="jwqdm != null">jwqdm = #{jwqdm},</if>
|
|
||||||
<if test="x != null">x = #{x},</if>
|
|
||||||
<if test="y != null">y = #{y},</if>
|
|
||||||
<if test="oldid != null">oldid = #{oldid},</if>
|
|
||||||
</trim>
|
|
||||||
where mc = #{mc}
|
|
||||||
</update>
|
|
||||||
|
|
||||||
<delete id="deleteVJwtSyfwById" parameterType="Long">
|
|
||||||
delete from v_jwt_syfw where id = #{id}
|
|
||||||
</delete>
|
|
||||||
|
|
||||||
<delete id="deleteVJwtSyfwByIds" parameterType="String">
|
|
||||||
delete from v_jwt_syfw where id in
|
|
||||||
<foreach item="id" collection="array" open="(" separator="," close=")">
|
|
||||||
#{id}
|
|
||||||
</foreach>
|
|
||||||
</delete>
|
|
||||||
</mapper>
|
|
Loading…
Reference in new issue