|
@@ -50,17 +50,17 @@ public class XCFYDatav_hospitalizatio_settle_detailJob implements Job {
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
|
|
- String sql = "select * from V_YBKF_HOSPITALIZATIO_SETTLE_DETAIL where item_id is not null and rownum<1000 %s";
|
|
|
|
|
|
|
+ String sql = "select * from V_YBKF_HOSP_SETTLE_DETAIL where item_id is not null and rownum<1000 %s";
|
|
|
List<DictModel> cateGoriesList = sysDictService.getDictItems(Constant.DICT_CATEGORIES_ITEMS_KEY);
|
|
List<DictModel> cateGoriesList = sysDictService.getDictItems(Constant.DICT_CATEGORIES_ITEMS_KEY);
|
|
|
Map<String, String> cateGoriesMap = new HashMap<>();
|
|
Map<String, String> cateGoriesMap = new HashMap<>();
|
|
|
for (DictModel dictModel : cateGoriesList) {
|
|
for (DictModel dictModel : cateGoriesList) {
|
|
|
cateGoriesMap.put(dictModel.getText(), dictModel.getValue());
|
|
cateGoriesMap.put(dictModel.getText(), dictModel.getValue());
|
|
|
}
|
|
}
|
|
|
while (true) {
|
|
while (true) {
|
|
|
- log.info("开始同步V_YBKF_hospitalizatio_settle_detail数据");
|
|
|
|
|
|
|
+ log.info("开始同步V_YBKF_HOSP_SETTLE_DETAIL数据");
|
|
|
String whereSql = "";
|
|
String whereSql = "";
|
|
|
Long hsdId = getLastId();
|
|
Long hsdId = getLastId();
|
|
|
- log.info("开始同步V_YBKF_hospitalizatio_settle_detail数据,获取上个同步记录访问最大主键ID:{}", hsdId);
|
|
|
|
|
|
|
+ log.info("开始同步V_YBKF_HOSP_SETTLE_DETAIL数据,获取上个同步记录访问最大主键ID:{}", hsdId);
|
|
|
Map<String, Object> paramMap = new HashMap<>();
|
|
Map<String, Object> paramMap = new HashMap<>();
|
|
|
if (null != hsdId && hsdId > 0) {
|
|
if (null != hsdId && hsdId > 0) {
|
|
|
whereSql = "and ID>:ID";
|
|
whereSql = "and ID>:ID";
|