diff --git a/src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserModelInfo.java b/src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserModelInfo.java new file mode 100644 index 0000000..92ee8c8 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/MetaImpUserModelInfo.java @@ -0,0 +1,314 @@ +package com.ssf.mysqloracletest.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import lombok.Data; + +/** + * ?ص???Ԥ??ģ????Ϣ? + * @TableName meta_imp_user_model_info + */ +@TableName(value ="meta_imp_user_model_info") +@Data +public class MetaImpUserModelInfo implements Serializable { + /** + * ???? + */ + @TableId(type = IdType.AUTO) + private Long id; + + + private String warning_id; + /** + * ??̬??Ϣ??? + */ + private Integer dataType; + + /** + * ?ص???С? + */ + private String impUserSubType; + + /** + * ?ص??????? + */ + private String impUserName; + + /** + * ?ص???????֤ + */ + private String impUserIdCard; + + /** + * ???????????? + */ + private BigDecimal longitude; + + /** + * ?????????γ? + */ + private BigDecimal latitude; + + /** + * ?????ʱ? + */ + private String activityTime; + + /** + * ???????????? + */ + private String activityDeviceAddress; + + /** + * ???????????? + */ + private String activityDeviceCode; + + /** + * ?????????????????????? + */ + private String activityPoliceStationCode; + + /** + * ?????????????????????? + */ + private String activityPoliceStationName; + + /** + * ???????Ϣ + */ + private String activityMessage; + + /** + * Ԥ??????? + */ + private String signPoliceman; + + /** + * Ԥ??????????????֤ + */ + private String signPolicemanIdCard; + + /** + * ǩ??״̬ + */ + private Integer signStatus; + + /** + * ????״̬ + */ + private Integer disposalStatus; + + /** + * Ԥ?????յ?λ + */ + private String signPoliceStation; + + /** + * Ԥ?????յ?λ??? + */ + private String signPoliceCode; + + /** + * Ԥ??ʱ? + */ + private String warningTime; + + /** + * ?Ƿ??ص???λ + */ + private String isImpAddress; + + /** + * ??ֵ1 + */ + private String key1; + + /** + * ????1 + */ + private String value1; + + /** + * ??ֵ2 + */ + private String key2; + + /** + * ????2 + */ + private String value2; + + /** + * ??ֵ3 + */ + private String key3; + + /** + * ????3 + */ + private String value3; + + /** + * ??ֵ4 + */ + private String key4; + + /** + * ????4 + */ + private String value4; + + /** + * ??ֵ5 + */ + private String key5; + + /** + * ????5 + */ + private String value5; + + /** + * ??ֵ6 + */ + private String key6; + + /** + * ????6 + */ + private String value6; + + /** + * ??ֵ7 + */ + private String key7; + + /** + * ????7 + */ + private String value7; + + /** + * ??ֵ8 + */ + private String key8; + + /** + * ????8 + */ + private String value8; + + /** + * ??ֵ9 + */ + private String key9; + + /** + * ????9 + */ + private String value9; + + /** + * ??ֵ10 + */ + private String key10; + + /** + * ????10 + */ + private String value10; + + /** + * ??ֵ11 + */ + private String key11; + + /** + * ????11 + */ + private String value11; + + /** + * ??ֵ12 + */ + private String key12; + + /** + * ????12 + */ + private String value12; + + /** + * ??ֵ13 + */ + private String key13; + + /** + * ????13 + */ + private String value13; + + /** + * ??ֵ14 + */ + private String key14; + + /** + * ????14 + */ + private String value14; + + /** + * ??ֵ15 + */ + private String key15; + + /** + * ????15 + */ + private String value15; + + /** + * ??ֵ16 + */ + private String key16; + + /** + * ????16 + */ + private String value16; + + /** + * ????ʱ? + */ + private Date createTime; + + /** + * ????? + */ + private Integer createBy; + + /** + * ????ʱ? + */ + private Date updateTime; + + /** + * ????? + */ + private Integer updateBy; + + /** + * 0:????Ծ,1:??Ծ + */ + private Integer isActive; + + @TableField(exist = false) + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/domain/SwzdryView.java b/src/main/java/com/ssf/mysqloracletest/domain/SwzdryView.java new file mode 100644 index 0000000..d82e9ab --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/domain/SwzdryView.java @@ -0,0 +1,89 @@ +package com.ssf.mysqloracletest.domain; + +import lombok.Data; + +import java.io.Serializable; + +@Data +public class SwzdryView implements Serializable { + private String ZDRYYJXXID; + private String DTXXLB; + private String ZDRYXXID; + private String ZDRYLBBJ; + private String ZDRYXL; + private String ZDRYXM; + private String ZDRYSFZH; + private String HDFSSJ; + private String HDFSDQH; + private String HDFSDXZ; + private String HDFSCSMC; + private String HDFSCSDM; + private String HDFSDSSGAJGDM; + private String HDFSDSSGAJGMC; + private String HDXGXX; + private String YJJSDWMC; + private String YJJSDW; + private String YJJSMJ; + private String YJJSMJSFZH; + private String YJFBSJ; + private String QSZT; + private String FKZT; + 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 KEY14; + private String VALUE14; + private String KEY15; + private String VALUE15; + private String KEY16; + private String VALUE16; + private String HDFSDJDZB; + private String HDFSDWDZB; + private String SFXF; + private String XFGZYQ; + private String XFRXM; + private String XFRSFZH; + private String XFRDWDM; + private String XFRDWMC; + private String XFSJ; + private String SFDW; + private String DXFS; + private String DXFSNR; + private String KS_HDFSDJDZB; + private String KS_HDFSDWDZB; + private String KS_HDFSDQH; + private String DXFSZD; + private String CZJG; + private String VALUE19; + private String SFFHBFRY; + private String VALUE20; + private String DXFSZALD; + private String DXFSXFLD; + private String DXFSZYLD; + private String DXFSPCSLD; + private String DXFSZJLD; + private String SFZDDW; +} diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserModelInfoMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserModelInfoMapper.java new file mode 100644 index 0000000..7a4bb42 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/MetaImpUserModelInfoMapper.java @@ -0,0 +1,20 @@ +package com.ssf.mysqloracletest.mapper; + +import com.ssf.mysqloracletest.domain.MetaImpUserModelInfo; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; + +/** +* @author 10503 +* @description 针对表【meta_imp_user_model_info(?ص???Ԥ??ģ????Ϣ?)】的数据库操作Mapper +* @createDate 2024-01-27 17:35:51 +* @Entity com.ssf.mysqloracletest.domain.MetaImpUserModelInfo +*/ +@Mapper +public interface MetaImpUserModelInfoMapper extends BaseMapper { + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/SwzdryViewMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/SwzdryViewMapper.java new file mode 100644 index 0000000..ffa9fd6 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/mapper/SwzdryViewMapper.java @@ -0,0 +1,7 @@ +package com.ssf.mysqloracletest.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ssf.mysqloracletest.domain.SwzdryView; + +public interface SwzdryViewMapper extends BaseMapper { +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/MetaImpUserModelInfoService.java b/src/main/java/com/ssf/mysqloracletest/service/MetaImpUserModelInfoService.java new file mode 100644 index 0000000..b2a72d6 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/MetaImpUserModelInfoService.java @@ -0,0 +1,13 @@ +package com.ssf.mysqloracletest.service; + +import com.ssf.mysqloracletest.domain.MetaImpUserModelInfo; +import com.baomidou.mybatisplus.extension.service.IService; + +/** +* @author 10503 +* @description 针对表【meta_imp_user_model_info(?ص???Ԥ??ģ????Ϣ?)】的数据库操作Service +* @createDate 2024-01-27 17:35:51 +*/ +public interface MetaImpUserModelInfoService extends IService { + +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/SwzdryViewService.java b/src/main/java/com/ssf/mysqloracletest/service/SwzdryViewService.java new file mode 100644 index 0000000..1e7fb71 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/SwzdryViewService.java @@ -0,0 +1,8 @@ +package com.ssf.mysqloracletest.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ssf.mysqloracletest.domain.SlryOracle; +import com.ssf.mysqloracletest.domain.SwzdryView; + +public interface SwzdryViewService extends IService { +} diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserModelInfoServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserModelInfoServiceImpl.java new file mode 100644 index 0000000..c19f5ec --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/MetaImpUserModelInfoServiceImpl.java @@ -0,0 +1,24 @@ +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.MetaImpUserModelInfo; +import com.ssf.mysqloracletest.service.MetaImpUserModelInfoService; +import com.ssf.mysqloracletest.mapper.MetaImpUserModelInfoMapper; +import org.springframework.stereotype.Service; + +/** +* @author 10503 +* @description 针对表【meta_imp_user_model_info(?ص???Ԥ??ģ????Ϣ?)】的数据库操作Service实现 +* @createDate 2024-01-27 17:35:51 +*/ +@Service +@DS("mysql") +public class MetaImpUserModelInfoServiceImpl extends ServiceImpl + implements MetaImpUserModelInfoService{ + +} + + + + diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/SwzdryViewServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/SwzdryViewServiceImpl.java new file mode 100644 index 0000000..934a0a6 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/SwzdryViewServiceImpl.java @@ -0,0 +1,13 @@ +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.SwzdryView; +import com.ssf.mysqloracletest.mapper.SwzdryViewMapper; +import com.ssf.mysqloracletest.service.SwzdryViewService; +import org.springframework.stereotype.Service; + +@Service +@DS("postgreUser") +public class SwzdryViewServiceImpl extends ServiceImpl implements SwzdryViewService { +} diff --git a/src/main/java/com/ssf/mysqloracletest/task/MetaImpUserModelInfoTask.java b/src/main/java/com/ssf/mysqloracletest/task/MetaImpUserModelInfoTask.java new file mode 100644 index 0000000..53655c3 --- /dev/null +++ b/src/main/java/com/ssf/mysqloracletest/task/MetaImpUserModelInfoTask.java @@ -0,0 +1,143 @@ +package com.ssf.mysqloracletest.task; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.ssf.mysqloracletest.domain.MetaImpUserModelInfo; +import com.ssf.mysqloracletest.domain.SwzdryView; +import com.ssf.mysqloracletest.service.MetaImpUserInfoService; +import com.ssf.mysqloracletest.service.MetaImpUserModelInfoService; +import com.ssf.mysqloracletest.service.SwzdryViewService; +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.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.Date; +import java.util.List; +import java.util.concurrent.CountDownLatch; + +@Component +@RequiredArgsConstructor +public class MetaImpUserModelInfoTask { + private static final Logger logger = LoggerFactory.getLogger(MetaImpUserModelInfoTask.class); + + private final SwzdryViewService swzdryViewService; + + private final MetaImpUserModelInfoService metaimpUserModelInfoService; + + final int oncesCounts = NumKit.checkInt(ConfigParam.oncesCounts) == 0 ? 1000 : NumKit.checkInt(ConfigParam.oncesCounts); + + @Scheduled(initialDelay = 100, fixedDelay = 3000) + public void transswzdry() { + if (!"true".equals(ConfigParam.SwzdrySwitch)) { + return; + } + + try { + int countTStrh = swzdryViewService.count(); + if (countTStrh > 0) { + int count = countTStrh / oncesCounts; + CountDownLatch latch = new CountDownLatch(countTStrh); + + for (int i = 0; i <= count; i++) { + try { + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMddHHmmss"); + QueryWrapper wrapper = new QueryWrapper<>(); + List list = swzdryViewService.list(wrapper); + for (SwzdryView Info : list) { + MetaImpUserModelInfo modelInfo = new MetaImpUserModelInfo(); + modelInfo.setWarning_id(Info.getZDRYYJXXID()); + modelInfo.setDataType(Integer.parseInt(Info.getDTXXLB())); + modelInfo.setImpUserSubType(Info.getZDRYXL()); + modelInfo.setImpUserName(Info.getZDRYXM()); + modelInfo.setImpUserIdCard(Info.getZDRYSFZH()); + modelInfo.setLongitude(new BigDecimal(Info.getHDFSDJDZB())); + modelInfo.setLatitude(new BigDecimal(Info.getHDFSDWDZB())); + modelInfo.setActivityTime(Info.getHDFSSJ()); + modelInfo.setActivityDeviceAddress(Info.getHDFSCSDM()); + modelInfo.setActivityDeviceCode(Info.getHDFSCSDM()); + modelInfo.setActivityPoliceStationCode(Info.getHDFSDSSGAJGDM()); + modelInfo.setActivityPoliceStationName(Info.getHDFSDSSGAJGMC()); + modelInfo.setActivityMessage(Info.getHDXGXX()); + modelInfo.setSignPoliceman(Info.getYJJSMJ()); + modelInfo.setSignPolicemanIdCard(Info.getYJJSMJSFZH()); + modelInfo.setSignStatus(Integer.parseInt(Info.getQSZT()));// 签收状态 0：未签收 1：已签收 + modelInfo.setDisposalStatus(Integer.parseInt(Info.getFKZT()));// 反馈状态 0：未反馈 1：已反馈 + modelInfo.setSignPoliceStation(Info.getYJJSDWMC()); + modelInfo.setSignPoliceCode(Info.getYJJSDW()); + String yjfbsjString = Info.getYJFBSJ(); + Date yjfbsjDate = dateFormat.parse(yjfbsjString); + modelInfo.setWarningTime(StringKit.toString(yjfbsjDate)); + modelInfo.setIsImpAddress(Info.getSFZDDW()); + modelInfo.setKey1(Info.getKEY1()); + modelInfo.setKey2(Info.getKEY2()); + modelInfo.setKey3(Info.getKEY3()); + modelInfo.setKey4(Info.getKEY4()); + modelInfo.setKey5(Info.getKEY5()); + modelInfo.setKey6(Info.getKEY6()); + modelInfo.setKey7(Info.getKEY7()); + modelInfo.setKey8(Info.getKEY8()); + modelInfo.setKey9(Info.getKEY9()); + modelInfo.setKey10(Info.getKEY10()); + modelInfo.setKey11(Info.getKEY11()); + modelInfo.setKey12(Info.getKEY12()); + modelInfo.setKey13(Info.getKEY13()); + modelInfo.setKey14(Info.getKEY14()); + modelInfo.setKey15(Info.getKEY15()); + modelInfo.setKey16(Info.getKEY16()); + modelInfo.setValue1(Info.getVALUE1()); + modelInfo.setValue2(Info.getVALUE2()); + modelInfo.setValue3(Info.getVALUE3()); + modelInfo.setValue4(Info.getVALUE4()); + modelInfo.setValue5(Info.getVALUE5()); + modelInfo.setValue6(Info.getVALUE6()); + modelInfo.setValue7(Info.getVALUE7()); + modelInfo.setValue8(Info.getVALUE8()); + modelInfo.setValue9(Info.getVALUE9()); + modelInfo.setValue10(Info.getVALUE10()); + modelInfo.setValue11(Info.getVALUE11()); + modelInfo.setValue12(Info.getVALUE12()); + modelInfo.setValue13(Info.getVALUE13()); + modelInfo.setValue14(Info.getVALUE14()); + modelInfo.setValue15(Info.getVALUE15()); + modelInfo.setValue16(Info.getVALUE16()); + //确定一个数据是否唯一 + MetaImpUserModelInfo one = metaimpUserModelInfoService.lambdaQuery().eq(MetaImpUserModelInfo::getWarning_id, Info.getZDRYYJXXID()).one(); + if (one == null) { + boolean save = metaimpUserModelInfoService.save(modelInfo); + if (save) { + logger.info("MODEL:-:" + Info.getZDRYYJXXID() + ":插入成功"); + } + } else { + UpdateWrapper wrapper1 = new UpdateWrapper<>(); + wrapper1.eq("warning_id", Info.getZDRYYJXXID()); + boolean update = metaimpUserModelInfoService.update(modelInfo, wrapper1); + if (update) { + logger.info("MODEL:-:" + Info.getZDRYYJXXID() + ":更新成功"); + } + } + } + } catch (Exception e) { + logger.info(StringKit.getTrace(e)); + } + latch.countDown(); + } + try { + // Wait for all threads to complete + latch.await(); + } catch (InterruptedException e) { + e.printStackTrace(); + } + } + } catch (Exception e) { + logger.info(StringKit.getTrace(e)); + } + } +} +