Browse Source

8月18日(新)历史数据查询

lijianlin/feature-20250728171217-三期金豆消费相关
sunjiabei 4 days ago
parent
commit
ab1eda6c04
  1. 44
      src/main/java/com/example/demo/config/SqlServer1DataSourceConfig.java
  2. 39
      src/main/resources/sqlServiceMapper/HistoryRecordMapper.xml

44
src/main/java/com/example/demo/config/SqlServer1DataSourceConfig.java

@ -29,28 +29,28 @@ public class SqlServer1DataSourceConfig {
return DataSourceBuilder.create().type(HikariDataSource.class).build();
}
// /**
// * 定义 SQL Server SqlSessionFactory
// */
// @Bean(name = "sqlserver1SqlSessionFactory")
// public SqlSessionFactory sqlserver1SqlSessionFactory(@Qualifier("sqlserver1DataSource") DataSource dataSource,
// @Qualifier("globalConfiguration1") org.apache.ibatis.session.Configuration globalConfiguration) throws Exception {
// log.info("Initializing SQL Server SqlSessionFactory...");
// SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
// sessionFactory.setDataSource(dataSource);
// sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/sqlserver/*.xml"));
// sessionFactory.setConfiguration(globalConfiguration);
// return sessionFactory.getObject();
// }
//
// /**
// * 定义 SQL Server SqlSessionTemplate
// */
// @Bean(name = "sqlserver1SqlSessionTemplate")
// public SqlSessionTemplate sqlserver1SqlSessionTemplate(@Qualifier("sqlserver1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
// log.info("Initializing SQL Server SqlSessionTemplate...");
// return new SqlSessionTemplate(sqlSessionFactory);
// }
/**
* 定义 SQL Server SqlSessionFactory
*/
@Bean(name = "sqlserver1SqlSessionFactory")
public SqlSessionFactory sqlserver1SqlSessionFactory(@Qualifier("sqlserver1DataSource") DataSource dataSource,
@Qualifier("globalConfiguration1") org.apache.ibatis.session.Configuration globalConfiguration) throws Exception {
log.info("Initializing SQL Server SqlSessionFactory...");
SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
sessionFactory.setDataSource(dataSource);
sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/sqlServiceMapper/*.xml"));
sessionFactory.setConfiguration(globalConfiguration);
return sessionFactory.getObject();
}
/**
* 定义 SQL Server SqlSessionTemplate
*/
@Bean(name = "sqlserver1SqlSessionTemplate")
public SqlSessionTemplate sqlserver1SqlSessionTemplate(@Qualifier("sqlserver1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
log.info("Initializing SQL Server SqlSessionTemplate...");
return new SqlSessionTemplate(sqlSessionFactory);
}
/**
* 定义全局 MyBatis 配置

39
src/main/resources/sqlServiceMapper/HistoryRecordMapper.xml

@ -6,5 +6,44 @@
</select>
<select id="getNewHistoryRecord" resultType="com.example.demo.domain.vo.coin.HistoryRecord">
SELECT
-- 主表字段(hwhcGold库)
ui.Name AS name,
ugr.jwcode AS jwcode,
(ugr.buy_jb + ugr.free + ugr.core_jb) AS num,
-- 关联表字段(其他库,例如db2库的user_info表)
ugt.remark_cn AS updateType, -- 假设从其他库获取更新类型
ugr.buy_jb AS permanentGold,
ugr.free AS freeGold,
ugr.core_jb AS taskGold,
ugr.cz_user AS operator,
ugr.cz_time AS createTime,
ugr.cz_bz AS remark
FROM
-- 主表:hwhcGold库的user_gold_records
[hwhcGold].[dbo].[user_gold_records] ugr
LEFT JOIN
-- 关联表:user_info
[hwerp].[dbo].[UserInfo] ui
ON ugr.jwcode = ui.Jwcode -- 关联条件:精网号
LEFT JOIN
-- 关联表
[hwhcGold].[dbo].[user_gold_typeInfo] ugt
ON ugr.gtype = ugt.id -- 关联条件:精网号
<where>
<if test="startTime != null">
AND ugr.cz_time &gt;= #{startTime}
</if>
<if test="endTime != null">
AND ugr.cz_time &lt;= #{endTime}
</if>
<if test="jwcode != null">
AND ugr.jwcode = #{jwcode} -- 支持按精网号筛选
</if>
<if test="name != null">
AND ugr.name = #{name} -- 支持按姓名筛选
</if>
</where>
ORDER BY ugr.cz_time DESC
</select>
</mapper>
Loading…
Cancel
Save