|
|
@ -15,6 +15,7 @@ import com.glxp.api.constant.*;
|
|
|
|
import com.glxp.api.dao.basic.*;
|
|
|
|
import com.glxp.api.dao.basic.*;
|
|
|
|
import com.glxp.api.dao.inout.IoCodeLostMapper;
|
|
|
|
import com.glxp.api.dao.inout.IoCodeLostMapper;
|
|
|
|
import com.glxp.api.dao.inout.IoCodeRelMapper;
|
|
|
|
import com.glxp.api.dao.inout.IoCodeRelMapper;
|
|
|
|
|
|
|
|
import com.glxp.api.dao.inout.IoOrderInvoiceMapper;
|
|
|
|
import com.glxp.api.dao.purchase.*;
|
|
|
|
import com.glxp.api.dao.purchase.*;
|
|
|
|
import com.glxp.api.dao.thrsys.ThrBusTypeOriginDao;
|
|
|
|
import com.glxp.api.dao.thrsys.ThrBusTypeOriginDao;
|
|
|
|
import com.glxp.api.dto.RelaySyncDto;
|
|
|
|
import com.glxp.api.dto.RelaySyncDto;
|
|
|
@ -292,7 +293,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_PRODUCTS);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_PRODUCTS);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicHospTypeEntity> hospTypeList = basicHospTypeDao.selectList(Wrappers.lambdaQuery(BasicHospTypeEntity.class)
|
|
|
|
List<BasicHospTypeEntity> hospTypeList = basicHospTypeDao.selectList(Wrappers.lambdaQuery(BasicHospTypeEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicHospTypeEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicHospTypeEntity::getUpdateTime, now)
|
|
|
@ -348,7 +349,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_CORP);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_CORP);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicCorpEntity> corpList = corpDao.selectList(Wrappers.lambdaQuery(BasicCorpEntity.class)
|
|
|
|
List<BasicCorpEntity> corpList = corpDao.selectList(Wrappers.lambdaQuery(BasicCorpEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicCorpEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicCorpEntity::getUpdateTime, now)
|
|
|
@ -371,7 +372,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SUP_CERT);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SUP_CERT);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SupCertEntity> supCertList = supCertDao.selectList(Wrappers.lambdaQuery(SupCertEntity.class)
|
|
|
|
List<SupCertEntity> supCertList = supCertDao.selectList(Wrappers.lambdaQuery(SupCertEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SupCertEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SupCertEntity::getUpdateTime, now)
|
|
|
@ -465,7 +466,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.IO_CODE_LOST);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.IO_CODE_LOST);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<IoCodeLostEntity> ioCodeLostList = ioCodeLostMapper.selectList(Wrappers.lambdaQuery(IoCodeLostEntity.class)
|
|
|
|
List<IoCodeLostEntity> ioCodeLostList = ioCodeLostMapper.selectList(Wrappers.lambdaQuery(IoCodeLostEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), IoCodeLostEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), IoCodeLostEntity::getUpdateTime, now)
|
|
|
@ -485,7 +486,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.IO_CODE_REL);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.IO_CODE_REL);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<IoCodeRelEntity> ioCodeRelList = ioCodeRelMapper.selectList(Wrappers.lambdaQuery(IoCodeRelEntity.class)
|
|
|
|
List<IoCodeRelEntity> ioCodeRelList = ioCodeRelMapper.selectList(Wrappers.lambdaQuery(IoCodeRelEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), IoCodeRelEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), IoCodeRelEntity::getUpdateTime, now)
|
|
|
@ -557,7 +558,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSSINESS_TYPE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSSINESS_TYPE);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicBussinessTypeEntity> bussinessTypeEntities = bussinessTypeService.list(Wrappers.lambdaQuery(BasicBussinessTypeEntity.class)
|
|
|
|
List<BasicBussinessTypeEntity> bussinessTypeEntities = bussinessTypeService.list(Wrappers.lambdaQuery(BasicBussinessTypeEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBussinessTypeEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBussinessTypeEntity::getUpdateTime, now)
|
|
|
@ -577,7 +578,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSTYPE_CHANGE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSTYPE_CHANGE);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicBusTypeChangeEntity> busTypeChangeList = busTypeChangeService.list(Wrappers.lambdaQuery(BasicBusTypeChangeEntity.class)
|
|
|
|
List<BasicBusTypeChangeEntity> busTypeChangeList = busTypeChangeService.list(Wrappers.lambdaQuery(BasicBusTypeChangeEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypeChangeEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypeChangeEntity::getUpdateTime, now)
|
|
|
@ -600,7 +601,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_BUSTYPE_ORIGIN);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_BUSTYPE_ORIGIN);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<ThrBusTypeOriginEntity> thrBusTypeOriginEntities = thrBusTypeOriginService.list(Wrappers.lambdaQuery(ThrBusTypeOriginEntity.class)
|
|
|
|
List<ThrBusTypeOriginEntity> thrBusTypeOriginEntities = thrBusTypeOriginService.list(Wrappers.lambdaQuery(ThrBusTypeOriginEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), ThrBusTypeOriginEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), ThrBusTypeOriginEntity::getUpdateTime, now)
|
|
|
@ -654,7 +655,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.DEPT_DATA);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.DEPT_DATA);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<DeptEntity> deptEntityList = deptService.list(Wrappers.lambdaQuery(DeptEntity.class)
|
|
|
|
List<DeptEntity> deptEntityList = deptService.list(Wrappers.lambdaQuery(DeptEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), DeptEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), DeptEntity::getUpdateTime, now)
|
|
|
@ -687,7 +688,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.WAREHOUSE_DICT);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.WAREHOUSE_DICT);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<InvWarehouseEntity> warehouseEntityList = warehouseService.list(Wrappers.lambdaQuery(InvWarehouseEntity.class)
|
|
|
|
List<InvWarehouseEntity> warehouseEntityList = warehouseService.list(Wrappers.lambdaQuery(InvWarehouseEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), InvWarehouseEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), InvWarehouseEntity::getUpdateTime, now)
|
|
|
@ -746,7 +747,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.USER_DATA);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.USER_DATA);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<AuthAdmin> adminList = adminService.list(Wrappers.lambdaQuery(AuthAdmin.class)
|
|
|
|
List<AuthAdmin> adminList = adminService.list(Wrappers.lambdaQuery(AuthAdmin.class)
|
|
|
|
.le((boolean) map.get("isNew"), AuthAdmin::getLastModifyTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), AuthAdmin::getLastModifyTime, now)
|
|
|
@ -807,7 +808,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_DEPT);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_DEPT);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<ThrDeptEntity> deptEntityList = thrDeptService.list(Wrappers.lambdaQuery(ThrDeptEntity.class)
|
|
|
|
List<ThrDeptEntity> deptEntityList = thrDeptService.list(Wrappers.lambdaQuery(ThrDeptEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), ThrDeptEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), ThrDeptEntity::getUpdateTime, now)
|
|
|
@ -828,7 +829,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_WAREHOUSE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_WAREHOUSE);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<ThrInvWarehouseEntity> warehouseEntityList = thrInvWarehouseService.list(Wrappers.lambdaQuery(ThrInvWarehouseEntity.class)
|
|
|
|
List<ThrInvWarehouseEntity> warehouseEntityList = thrInvWarehouseService.list(Wrappers.lambdaQuery(ThrInvWarehouseEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), ThrInvWarehouseEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), ThrInvWarehouseEntity::getUpdateTime, now)
|
|
|
@ -851,7 +852,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_PRODUCTS);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_PRODUCTS);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<ThrProductsEntity> productsEntityList = thrProductsService.list(Wrappers.lambdaQuery(ThrProductsEntity.class)
|
|
|
|
List<ThrProductsEntity> productsEntityList = thrProductsService.list(Wrappers.lambdaQuery(ThrProductsEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), ThrProductsEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), ThrProductsEntity::getUpdateTime, now)
|
|
|
@ -874,7 +875,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_CORP);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.THR_CORP);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<ThrCorpEntity> corpEntities = thrCorpService.list(Wrappers.lambdaQuery(ThrCorpEntity.class)
|
|
|
|
List<ThrCorpEntity> corpEntities = thrCorpService.list(Wrappers.lambdaQuery(ThrCorpEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), ThrCorpEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), ThrCorpEntity::getUpdateTime, now)
|
|
|
@ -929,7 +930,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SYSTEM_PARAM_CONFIG);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SYSTEM_PARAM_CONFIG);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SystemParamConfigEntity> systemParamConfigEntities = systemParamConfigService.list(Wrappers.lambdaQuery(SystemParamConfigEntity.class)
|
|
|
|
List<SystemParamConfigEntity> systemParamConfigEntities = systemParamConfigService.list(Wrappers.lambdaQuery(SystemParamConfigEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SystemParamConfigEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SystemParamConfigEntity::getUpdateTime, now)
|
|
|
@ -948,7 +949,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.ENTRUST_ACCEPT);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.ENTRUST_ACCEPT);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<EntrustReceEntity> entrustReceEntities = entrustReceService.list(Wrappers.lambdaQuery(EntrustReceEntity.class)
|
|
|
|
List<EntrustReceEntity> entrustReceEntities = entrustReceService.list(Wrappers.lambdaQuery(EntrustReceEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), EntrustReceEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), EntrustReceEntity::getUpdateTime, now)
|
|
|
@ -969,7 +970,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.PRINT_CONFIG);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.PRINT_CONFIG);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SystemPDFModuleEntity> systemPDFModuleEntities = systemPDFModuleService.list(Wrappers.lambdaQuery(SystemPDFModuleEntity.class)
|
|
|
|
List<SystemPDFModuleEntity> systemPDFModuleEntities = systemPDFModuleService.list(Wrappers.lambdaQuery(SystemPDFModuleEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SystemPDFModuleEntity::getUpdate_time, now)
|
|
|
|
.le((boolean) map.get("isNew"), SystemPDFModuleEntity::getUpdate_time, now)
|
|
|
@ -1056,7 +1057,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SCAN_CHANGE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.SCAN_CHANGE);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicBusTypePreEntity> basicBusTypePreEntities = iBasicBusTypePreService.list(Wrappers.lambdaQuery(BasicBusTypePreEntity.class)
|
|
|
|
List<BasicBusTypePreEntity> basicBusTypePreEntities = iBasicBusTypePreService.list(Wrappers.lambdaQuery(BasicBusTypePreEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypePreEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypePreEntity::getUpdateTime, now)
|
|
|
@ -1075,7 +1076,7 @@ public class HeartService {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BUS_TYPE_CHANGE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BUS_TYPE_CHANGE);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
map = syncTimeMap;
|
|
|
|
map = syncTimeMap;
|
|
|
|
now = syncTime;
|
|
|
|
now = syncTime;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicBusTypeChangeEntity> basicBusTypeChangeEntities = iBasicBusTypeChangeService.list(Wrappers.lambdaQuery(BasicBusTypeChangeEntity.class)
|
|
|
|
List<BasicBusTypeChangeEntity> basicBusTypeChangeEntities = iBasicBusTypeChangeService.list(Wrappers.lambdaQuery(BasicBusTypeChangeEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypeChangeEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicBusTypeChangeEntity::getUpdateTime, now)
|
|
|
@ -1414,6 +1415,14 @@ public class HeartService {
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
String fileFullPath = writeFile(filePrefix, NEW_ALL_ORDER, response.getData());
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setCacheFilePath(fileFullPath);
|
|
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
|
|
|
throw new RuntimeException(e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -1634,6 +1643,8 @@ public class HeartService {
|
|
|
|
|
|
|
|
|
|
|
|
private final IoCodeLostMapper ioCodeLostMapper;
|
|
|
|
private final IoCodeLostMapper ioCodeLostMapper;
|
|
|
|
private final IoCodeRelMapper ioCodeRelMapper;
|
|
|
|
private final IoCodeRelMapper ioCodeRelMapper;
|
|
|
|
|
|
|
|
@Resource
|
|
|
|
|
|
|
|
private final IoOrderInvoiceMapper ioOrderInvoiceMapper;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 设置嵌套事物
|
|
|
|
* 设置嵌套事物
|
|
|
@ -1645,12 +1656,22 @@ public class HeartService {
|
|
|
|
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(content);
|
|
|
|
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(content);
|
|
|
|
List<IoCodeLostEntity> ioCodeLostList = JSONUtil.toList(jsonObject.getJSONArray(IoCodeLostEntity.class.getSimpleName()), IoCodeLostEntity.class);
|
|
|
|
List<IoCodeLostEntity> ioCodeLostList = JSONUtil.toList(jsonObject.getJSONArray(IoCodeLostEntity.class.getSimpleName()), IoCodeLostEntity.class);
|
|
|
|
List<IoCodeRelEntity> ioCodeRelList = JSONUtil.toList(jsonObject.getJSONArray(IoCodeRelEntity.class.getSimpleName()), IoCodeRelEntity.class);
|
|
|
|
List<IoCodeRelEntity> ioCodeRelList = JSONUtil.toList(jsonObject.getJSONArray(IoCodeRelEntity.class.getSimpleName()), IoCodeRelEntity.class);
|
|
|
|
|
|
|
|
List<IoOrderInvoiceEntity> ioOrderInvoiceEntities = JSONUtil.toList(jsonObject.getJSONArray(IoOrderInvoiceEntity.class.getSimpleName()), IoOrderInvoiceEntity.class);
|
|
|
|
|
|
|
|
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeLostList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeLostList)) {
|
|
|
|
ioCodeLostMapper.insertOrUpdateBatch(ioCodeLostList);
|
|
|
|
ioCodeLostMapper.insertOrUpdateBatch(ioCodeLostList);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeRelList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeRelList)) {
|
|
|
|
ioCodeRelMapper.insertOrUpdateBatch(ioCodeRelList);
|
|
|
|
ioCodeRelMapper.insertOrUpdateBatch(ioCodeRelList);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(ioOrderInvoiceEntities)) {
|
|
|
|
|
|
|
|
ioOrderInvoiceMapper.insertOrUpdateBatch(ioOrderInvoiceEntities);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<String> syncFiles = JSONUtil.toList(jsonObject.getJSONArray("syncFiles"), String.class);
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncFiles)) {
|
|
|
|
|
|
|
|
fileService.download(syncFiles);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -1798,6 +1819,11 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(bean.getIoCodeRelList())) {
|
|
|
|
if (CollectionUtil.isNotEmpty(bean.getIoCodeRelList())) {
|
|
|
|
ioCodeRelMapper.insertOrUpdateBatch(bean.getIoCodeRelList());
|
|
|
|
ioCodeRelMapper.insertOrUpdateBatch(bean.getIoCodeRelList());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// if (CollectionUtil.isNotEmpty(bean.getI())) {
|
|
|
|
|
|
|
|
// ioCodeRelMapper.insertOrUpdateBatch(bean.getIoCodeRelList());
|
|
|
|
|
|
|
|
// }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
public void insetOrderDb(SpsSyncOrderResponse syncDataResponse, IoOrderEntity orderEntity) {
|
|
|
|
public void insetOrderDb(SpsSyncOrderResponse syncDataResponse, IoOrderEntity orderEntity) {
|
|
|
@ -1853,7 +1879,7 @@ public class HeartService {
|
|
|
|
List<IoOrderInvoiceEntity> orderInvoiceEntities = syncDataResponse.getOrderInvoiceEntities();
|
|
|
|
List<IoOrderInvoiceEntity> orderInvoiceEntities = syncDataResponse.getOrderInvoiceEntities();
|
|
|
|
for (IoOrderInvoiceEntity orderInvoiceEntity : orderInvoiceEntities) {
|
|
|
|
for (IoOrderInvoiceEntity orderInvoiceEntity : orderInvoiceEntities) {
|
|
|
|
if (orderInvoiceEntity.getOrderIdFk().equals(orderEntity.getBillNo())) {
|
|
|
|
if (orderInvoiceEntity.getOrderIdFk().equals(orderEntity.getBillNo())) {
|
|
|
|
orderInvoiceEntity.setId(null);
|
|
|
|
orderInvoiceEntity.setId(IdUtil.getSnowflakeNextId());
|
|
|
|
orderInvoiceService.insertInvoice(orderInvoiceEntity);
|
|
|
|
orderInvoiceService.insertInvoice(orderInvoiceEntity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|