|
|
@ -160,6 +160,14 @@ public class HeartService {
|
|
|
|
logs = logs + "单据条码信息:" + spsSyncOrderResponse.getCodeEntities().size() + "条\n";
|
|
|
|
logs = logs + "单据条码信息:" + spsSyncOrderResponse.getCodeEntities().size() + "条\n";
|
|
|
|
basicExportStatusEntity1.setRemark(logs);
|
|
|
|
basicExportStatusEntity1.setRemark(logs);
|
|
|
|
basicExportStatusEntity1.setUpdateTime(new Date());
|
|
|
|
basicExportStatusEntity1.setUpdateTime(new Date());
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
String fileFullPath = writeFile(filePrefix, NEW_ALL_ORDER, JsonUtils.toJsonString(spsSyncOrderResponse));
|
|
|
|
|
|
|
|
basicExportStatusEntity1.setCacheFilePath(fileFullPath);
|
|
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
|
|
|
throw new RuntimeException(e);
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
basicExportService.updateExportStatus(basicExportStatusEntity1);
|
|
|
|
basicExportService.updateExportStatus(basicExportStatusEntity1);
|
|
|
|
return ResultVOUtils.success();
|
|
|
|
return ResultVOUtils.success();
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -273,6 +281,7 @@ public class HeartService {
|
|
|
|
* @return
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public SpsSyncBasicDataResponse getBasicData(SyncDataSetEntity info, String taskId, Date now, Date syncTime) {
|
|
|
|
public SpsSyncBasicDataResponse getBasicData(SyncDataSetEntity info, String taskId, Date now, Date syncTime) {
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
SpsSyncBasicDataResponse dataResponse = null;
|
|
|
|
SpsSyncBasicDataResponse dataResponse = null;
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
@ -293,6 +302,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(hospTypeList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(hospTypeList)) {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse.setHospTypeList(hospTypeList);
|
|
|
|
dataResponse.setHospTypeList(hospTypeList);
|
|
|
|
|
|
|
|
remark.append("物资字典分类信息:").append(hospTypeList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<UdiRelevanceEntity> udiRelevanceList = udiRelevanceDao.selectList(Wrappers.lambdaQuery(UdiRelevanceEntity.class)
|
|
|
|
List<UdiRelevanceEntity> udiRelevanceList = udiRelevanceDao.selectList(Wrappers.lambdaQuery(UdiRelevanceEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), UdiRelevanceEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), UdiRelevanceEntity::getUpdateTime, now)
|
|
|
@ -304,6 +314,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setUdiRelevanceList(udiRelevanceList);
|
|
|
|
dataResponse.setUdiRelevanceList(udiRelevanceList);
|
|
|
|
|
|
|
|
remark.append("物资字典主表信息:").append(udiRelevanceList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<BasicProductsEntity> productsList = basicProductsDao.selectList(Wrappers.lambdaQuery(BasicProductsEntity.class)
|
|
|
|
List<BasicProductsEntity> productsList = basicProductsDao.selectList(Wrappers.lambdaQuery(BasicProductsEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), BasicProductsEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), BasicProductsEntity::getUpdateTime, now)
|
|
|
@ -315,6 +326,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setProductsList(productsList);
|
|
|
|
dataResponse.setProductsList(productsList);
|
|
|
|
|
|
|
|
remark.append("物资字典字表信息:").append(udiRelevanceList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<CompanyProductRelevanceEntity> relevanceList = relevanceDao.selectList(Wrappers.lambdaQuery(CompanyProductRelevanceEntity.class)
|
|
|
|
List<CompanyProductRelevanceEntity> relevanceList = relevanceDao.selectList(Wrappers.lambdaQuery(CompanyProductRelevanceEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), CompanyProductRelevanceEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), CompanyProductRelevanceEntity::getUpdateTime, now)
|
|
|
@ -326,6 +338,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setRelevanceList(relevanceList);
|
|
|
|
dataResponse.setRelevanceList(relevanceList);
|
|
|
|
|
|
|
|
remark.append("供应商物资字典信息:").append(relevanceList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//确认有开启往来单位字典同步
|
|
|
|
//确认有开启往来单位字典同步
|
|
|
@ -346,6 +359,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setCorpList(corpList);
|
|
|
|
dataResponse.setCorpList(corpList);
|
|
|
|
|
|
|
|
remark.append("往来单位信息:").append(corpList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -367,6 +381,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSupCertList(supCertList);
|
|
|
|
dataResponse.setSupCertList(supCertList);
|
|
|
|
|
|
|
|
remark.append("资质证书信息:").append(supCertList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SupCertSetEntity> supCertSetList = supCertSetDao.selectList(Wrappers.lambdaQuery(SupCertSetEntity.class)
|
|
|
|
List<SupCertSetEntity> supCertSetList = supCertSetDao.selectList(Wrappers.lambdaQuery(SupCertSetEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SupCertSetEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SupCertSetEntity::getUpdateTime, now)
|
|
|
@ -378,6 +393,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSupCertSetList(supCertSetList);
|
|
|
|
dataResponse.setSupCertSetList(supCertSetList);
|
|
|
|
|
|
|
|
remark.append("资质证书要求设置信息:").append(supCertSetList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SupCompanyEntity> supCompanyList = supCompanyDao.selectList(Wrappers.lambdaQuery(SupCompanyEntity.class)
|
|
|
|
List<SupCompanyEntity> supCompanyList = supCompanyDao.selectList(Wrappers.lambdaQuery(SupCompanyEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SupCompanyEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SupCompanyEntity::getUpdateTime, now)
|
|
|
@ -389,6 +405,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSupCompanyList(supCompanyList);
|
|
|
|
dataResponse.setSupCompanyList(supCompanyList);
|
|
|
|
|
|
|
|
remark.append("供应商资质信息:").append(supCompanyList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SupManufacturerEntity> supManufacturerList = supManufacturerDao.selectList(Wrappers.lambdaQuery(SupManufacturerEntity.class)
|
|
|
|
List<SupManufacturerEntity> supManufacturerList = supManufacturerDao.selectList(Wrappers.lambdaQuery(SupManufacturerEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SupManufacturerEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SupManufacturerEntity::getUpdateTime, now)
|
|
|
@ -400,6 +417,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSupManufacturerList(supManufacturerList);
|
|
|
|
dataResponse.setSupManufacturerList(supManufacturerList);
|
|
|
|
|
|
|
|
remark.append("生产企业资质信息:").append(supManufacturerList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<SupProductEntity> supProductList = supProductDao.selectList(Wrappers.lambdaQuery(SupProductEntity.class)
|
|
|
|
List<SupProductEntity> supProductList = supProductDao.selectList(Wrappers.lambdaQuery(SupProductEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), SupProductEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), SupProductEntity::getUpdateTime, now)
|
|
|
@ -411,12 +429,14 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
dataResponse = new SpsSyncBasicDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSupProductList(supProductList);
|
|
|
|
dataResponse.setSupProductList(supProductList);
|
|
|
|
|
|
|
|
remark.append("配送产品资质信息:").append(supProductList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.BASIC_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.BASIC_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return dataResponse;
|
|
|
|
return dataResponse;
|
|
|
@ -432,7 +452,7 @@ public class HeartService {
|
|
|
|
* @return
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
public SpsSyncOtherDataResponse getOtherData(SyncDataSetEntity info, String taskId, Date now, Date syncTime) {
|
|
|
|
public SpsSyncOtherDataResponse getOtherData(SyncDataSetEntity info, String taskId, Date now, Date syncTime) {
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
SpsSyncOtherDataResponse dataResponse = null;
|
|
|
|
SpsSyncOtherDataResponse dataResponse = null;
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
@ -453,6 +473,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeLostList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(ioCodeLostList)) {
|
|
|
|
dataResponse = new SpsSyncOtherDataResponse();
|
|
|
|
dataResponse = new SpsSyncOtherDataResponse();
|
|
|
|
dataResponse.setIoCodeLostList(ioCodeLostList);
|
|
|
|
dataResponse.setIoCodeLostList(ioCodeLostList);
|
|
|
|
|
|
|
|
remark.append("UDI码补齐信息:").append(ioCodeLostList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//确认有开启udi关联关系同步
|
|
|
|
//确认有开启udi关联关系同步
|
|
|
@ -473,11 +494,13 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncOtherDataResponse();
|
|
|
|
dataResponse = new SpsSyncOtherDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setIoCodeRelList(ioCodeRelList);
|
|
|
|
dataResponse.setIoCodeRelList(ioCodeRelList);
|
|
|
|
|
|
|
|
remark.append("UDI码关联关系:").append(ioCodeRelList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.OTHER_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.OTHER_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
return dataResponse;
|
|
|
|
return dataResponse;
|
|
|
@ -522,9 +545,10 @@ public class HeartService {
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
|
|
|
|
|
|
|
|
//确认有开启业务单据类型同步
|
|
|
|
//确认有开启扫码单据类型同步
|
|
|
|
if (needExec(info.getTypeBus())) {
|
|
|
|
if (needExec(info.getTypeScan())) {
|
|
|
|
Map<String, Object> map;
|
|
|
|
Map<String, Object> map;
|
|
|
|
if (syncTime == null) {
|
|
|
|
if (syncTime == null) {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSSINESS_TYPE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSSINESS_TYPE);
|
|
|
@ -539,11 +563,11 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(bussinessTypeEntities)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(bussinessTypeEntities)) {
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
dataResponse.setBussinessTypeEntities(bussinessTypeEntities);
|
|
|
|
dataResponse.setBussinessTypeEntities(bussinessTypeEntities);
|
|
|
|
|
|
|
|
remark.append("扫码单据类型信息:").append(bussinessTypeEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
//确认有开启业务单据类型同步
|
|
|
|
//确认有开启扫码单据类型同步
|
|
|
|
if (needExec(info.getTypeBus())) {
|
|
|
|
if (needExec(info.getTypeScan())) {
|
|
|
|
|
|
|
|
Map<String, Object> map;
|
|
|
|
Map<String, Object> map;
|
|
|
|
if (syncTime == null) {
|
|
|
|
if (syncTime == null) {
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSTYPE_CHANGE);
|
|
|
|
map = basicExportStatusTimeInfo(now, BasicExportStatusTimeEnum.BASIC_BUSTYPE_CHANGE);
|
|
|
@ -560,6 +584,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setBusTypeChangeEntities(busTypeChangeList);
|
|
|
|
dataResponse.setBusTypeChangeEntities(busTypeChangeList);
|
|
|
|
|
|
|
|
remark.append("业务单据类型:").append(busTypeChangeList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -581,12 +606,14 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
dataResponse = new SpsSyncBusResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setThrBusTypeOriginEntities(thrBusTypeOriginEntities);
|
|
|
|
dataResponse.setThrBusTypeOriginEntities(thrBusTypeOriginEntities);
|
|
|
|
|
|
|
|
remark.append("第三方单据类型信息:").append(thrBusTypeOriginEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.DOCUMENT_TYPE_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.DOCUMENT_TYPE_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return dataResponse;
|
|
|
|
return dataResponse;
|
|
|
@ -614,7 +641,7 @@ public class HeartService {
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
//确认有开启部门信息同步
|
|
|
|
//确认有开启部门信息同步
|
|
|
|
if (needExec(info.getBasicDept())) {
|
|
|
|
if (needExec(info.getBasicDept())) {
|
|
|
|
Map<String, Object> map;
|
|
|
|
Map<String, Object> map;
|
|
|
@ -631,6 +658,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(deptEntityList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(deptEntityList)) {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse.setDeptEntityList(deptEntityList);
|
|
|
|
dataResponse.setDeptEntityList(deptEntityList);
|
|
|
|
|
|
|
|
remark.append("部门信息:").append(deptEntityList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<DeptUserEntity> deptUserEntityList = deptUserService.list(Wrappers.lambdaQuery(DeptUserEntity.class)
|
|
|
|
List<DeptUserEntity> deptUserEntityList = deptUserService.list(Wrappers.lambdaQuery(DeptUserEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), DeptUserEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), DeptUserEntity::getUpdateTime, now)
|
|
|
@ -642,6 +670,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setDeptUserEntities(deptUserEntityList);
|
|
|
|
dataResponse.setDeptUserEntities(deptUserEntityList);
|
|
|
|
|
|
|
|
remark.append("部门用户信息:").append(deptEntityList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -662,6 +691,7 @@ public class HeartService {
|
|
|
|
if (dataResponse == null) {
|
|
|
|
if (dataResponse == null) {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
remark.append("仓库字典信息:").append(warehouseEntityList.size()).append("条\n");
|
|
|
|
dataResponse.setInvWarehouseEntities(warehouseEntityList);
|
|
|
|
dataResponse.setInvWarehouseEntities(warehouseEntityList);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<WarehouseUserEntity> warehouseUserEntities = warehouseUserService.list(Wrappers.lambdaQuery(WarehouseUserEntity.class)
|
|
|
|
List<WarehouseUserEntity> warehouseUserEntities = warehouseUserService.list(Wrappers.lambdaQuery(WarehouseUserEntity.class)
|
|
|
@ -673,6 +703,7 @@ public class HeartService {
|
|
|
|
if (dataResponse == null) {
|
|
|
|
if (dataResponse == null) {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
remark.append("仓库用户信息:").append(warehouseUserEntities.size()).append("条\n");
|
|
|
|
dataResponse.setWarehouseUserEntities(warehouseUserEntities);
|
|
|
|
dataResponse.setWarehouseUserEntities(warehouseUserEntities);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<WarehouseBussinessTypeEntity> warehouseBussinessTypeEntities = warehouseBussinessTypeService.list(Wrappers.lambdaQuery(WarehouseBussinessTypeEntity.class)
|
|
|
|
List<WarehouseBussinessTypeEntity> warehouseBussinessTypeEntities = warehouseBussinessTypeService.list(Wrappers.lambdaQuery(WarehouseBussinessTypeEntity.class)
|
|
|
@ -685,6 +716,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setWarehouseBussinessTypeEntities(warehouseBussinessTypeEntities);
|
|
|
|
dataResponse.setWarehouseBussinessTypeEntities(warehouseBussinessTypeEntities);
|
|
|
|
|
|
|
|
remark.append("仓库单据类型信息:").append(warehouseBussinessTypeEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<InvSpace> invSpaceList = invSpaceService.list(Wrappers.lambdaQuery(InvSpace.class)
|
|
|
|
List<InvSpace> invSpaceList = invSpaceService.list(Wrappers.lambdaQuery(InvSpace.class)
|
|
|
|
.le((boolean) map.get("isNew"), InvSpace::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), InvSpace::getUpdateTime, now)
|
|
|
@ -696,6 +728,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setInvSpaces(invSpaceList);
|
|
|
|
dataResponse.setInvSpaces(invSpaceList);
|
|
|
|
|
|
|
|
remark.append("货位信息:").append(invSpaceList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -717,6 +750,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setAuthAdminList(adminList);
|
|
|
|
dataResponse.setAuthAdminList(adminList);
|
|
|
|
|
|
|
|
remark.append("系统用户信息:").append(adminList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
List<InvBusUserEntity> busUserEntities = invBusUserService.list(Wrappers.lambdaQuery(InvBusUserEntity.class)
|
|
|
|
List<InvBusUserEntity> busUserEntities = invBusUserService.list(Wrappers.lambdaQuery(InvBusUserEntity.class)
|
|
|
|
.le((boolean) map.get("isNew"), InvBusUserEntity::getUpdateTime, now)
|
|
|
|
.le((boolean) map.get("isNew"), InvBusUserEntity::getUpdateTime, now)
|
|
|
@ -728,12 +762,14 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
dataResponse = new SpsSyncDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setInvBusUserEntities(busUserEntities);
|
|
|
|
dataResponse.setInvBusUserEntities(busUserEntities);
|
|
|
|
|
|
|
|
remark.append("用户关联单据信息:").append(busUserEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.USER_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.USER_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return dataResponse;
|
|
|
|
return dataResponse;
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -756,7 +792,7 @@ public class HeartService {
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
//确认有开启第三方部门信息同步
|
|
|
|
//确认有开启第三方部门信息同步
|
|
|
|
if (needExec(info.getBasicThirdInv())) {
|
|
|
|
if (needExec(info.getBasicThirdInv())) {
|
|
|
|
Map<String, Object> map;
|
|
|
|
Map<String, Object> map;
|
|
|
@ -773,6 +809,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(deptEntityList)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(deptEntityList)) {
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
dataResponse.setDeptEntities(deptEntityList);
|
|
|
|
dataResponse.setDeptEntities(deptEntityList);
|
|
|
|
|
|
|
|
remark.append("第三方部门信息:").append(deptEntityList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -794,6 +831,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setInvWarehouseEntities(warehouseEntityList);
|
|
|
|
dataResponse.setInvWarehouseEntities(warehouseEntityList);
|
|
|
|
|
|
|
|
remark.append("第三方仓库信息:").append(warehouseEntityList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -815,6 +853,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setProductsEntityList(productsEntityList);
|
|
|
|
dataResponse.setProductsEntityList(productsEntityList);
|
|
|
|
|
|
|
|
remark.append("第三方产品信息:").append(productsEntityList.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -836,12 +875,14 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
dataResponse = new SpsSyncThrDataResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setCorpEntities(corpEntities);
|
|
|
|
dataResponse.setCorpEntities(corpEntities);
|
|
|
|
|
|
|
|
remark.append("第三方往来信息:").append(corpEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.THIRD_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.THIRD_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return dataResponse;
|
|
|
|
return dataResponse;
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -871,6 +912,7 @@ public class HeartService {
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
Map<String, Object> syncTimeMap = new WeakHashMap<>(3);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("isNew", true);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
syncTimeMap.put("oldDate", syncTime);
|
|
|
|
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
if (needExec(info.getSystemConfig())) {
|
|
|
|
if (needExec(info.getSystemConfig())) {
|
|
|
|
Map<String, Object> map;
|
|
|
|
Map<String, Object> map;
|
|
|
|
if (syncTime == null) {
|
|
|
|
if (syncTime == null) {
|
|
|
@ -886,6 +928,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(systemParamConfigEntities)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(systemParamConfigEntities)) {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse.setSystemParamConfigEntities(systemParamConfigEntities);
|
|
|
|
dataResponse.setSystemParamConfigEntities(systemParamConfigEntities);
|
|
|
|
|
|
|
|
remark.append("运行参数设置信息:").append(systemParamConfigEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (needExec(info.getEntrustAction())) {
|
|
|
|
if (needExec(info.getEntrustAction())) {
|
|
|
@ -905,6 +948,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setEntrustReceEntities(entrustReceEntities);
|
|
|
|
dataResponse.setEntrustReceEntities(entrustReceEntities);
|
|
|
|
|
|
|
|
remark.append("委托验收设置信息:").append(entrustReceEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (needExec(info.getPrintConfig())) {
|
|
|
|
if (needExec(info.getPrintConfig())) {
|
|
|
@ -924,6 +968,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSystemPDFModuleEntities(systemPDFModuleEntities);
|
|
|
|
dataResponse.setSystemPDFModuleEntities(systemPDFModuleEntities);
|
|
|
|
|
|
|
|
remark.append("系统模板模块信息:").append(systemPDFModuleEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<SystemPDFTemplateEntity> systemPDFTemplateEntities = systemPDFTemplateService.list(Wrappers.lambdaQuery(SystemPDFTemplateEntity.class)
|
|
|
|
List<SystemPDFTemplateEntity> systemPDFTemplateEntities = systemPDFTemplateService.list(Wrappers.lambdaQuery(SystemPDFTemplateEntity.class)
|
|
|
@ -936,6 +981,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSystemPDFTemplateEntities(systemPDFTemplateEntities);
|
|
|
|
dataResponse.setSystemPDFTemplateEntities(systemPDFTemplateEntities);
|
|
|
|
|
|
|
|
remark.append("模板信息:").append(systemPDFTemplateEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<SysPdfTemplateRelevanceCodeEntity> sysPdfTemplateRelevanceCodeEntities = systemPDFTemplateRelevanceCodeService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceCodeEntity.class)
|
|
|
|
List<SysPdfTemplateRelevanceCodeEntity> sysPdfTemplateRelevanceCodeEntities = systemPDFTemplateRelevanceCodeService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceCodeEntity.class)
|
|
|
@ -948,6 +994,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceCodeEntities(sysPdfTemplateRelevanceCodeEntities);
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceCodeEntities(sysPdfTemplateRelevanceCodeEntities);
|
|
|
|
|
|
|
|
remark.append("扫码单据关联模板信息:").append(sysPdfTemplateRelevanceCodeEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<SysPdfTemplateRelevanceBizEntity> sysPdfTemplateRelevanceBizEntities = systemPDFTemplateRelevanceBizService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceBizEntity.class)
|
|
|
|
List<SysPdfTemplateRelevanceBizEntity> sysPdfTemplateRelevanceBizEntities = systemPDFTemplateRelevanceBizService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceBizEntity.class)
|
|
|
@ -960,6 +1007,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceBizEntities(sysPdfTemplateRelevanceBizEntities);
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceBizEntities(sysPdfTemplateRelevanceBizEntities);
|
|
|
|
|
|
|
|
remark.append("业务单据关联模板信息:").append(sysPdfTemplateRelevanceBizEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<SysPdfTemplateRelevanceLabelEntity> sysPdfTemplateRelevanceLabelEntities = systemPDFTemplateRelevanceLabelService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceLabelEntity.class)
|
|
|
|
List<SysPdfTemplateRelevanceLabelEntity> sysPdfTemplateRelevanceLabelEntities = systemPDFTemplateRelevanceLabelService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceLabelEntity.class)
|
|
|
@ -972,6 +1020,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceLabelEntities(sysPdfTemplateRelevanceLabelEntities);
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceLabelEntities(sysPdfTemplateRelevanceLabelEntities);
|
|
|
|
|
|
|
|
remark.append("标签关联模板信息:").append(sysPdfTemplateRelevanceLabelEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
List<SysPdfTemplateRelevanceStatemenEntity> sysPdfTemplateRelevanceStatemenEntities = systemPDFTemplateRelevanceStatemenService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceStatemenEntity.class)
|
|
|
|
List<SysPdfTemplateRelevanceStatemenEntity> sysPdfTemplateRelevanceStatemenEntities = systemPDFTemplateRelevanceStatemenService.list(Wrappers.lambdaQuery(SysPdfTemplateRelevanceStatemenEntity.class)
|
|
|
@ -984,6 +1033,7 @@ public class HeartService {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceStatemenEntities(sysPdfTemplateRelevanceStatemenEntities);
|
|
|
|
dataResponse.setSysPdfTemplateRelevanceStatemenEntities(sysPdfTemplateRelevanceStatemenEntities);
|
|
|
|
|
|
|
|
remark.append("报表关联模板信息:").append(sysPdfTemplateRelevanceStatemenEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
@ -1002,6 +1052,7 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(basicBusTypePreEntities)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(basicBusTypePreEntities)) {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse.setBasicBusTypePreEntities(basicBusTypePreEntities);
|
|
|
|
dataResponse.setBasicBusTypePreEntities(basicBusTypePreEntities);
|
|
|
|
|
|
|
|
remark.append("出入库单自动补单设置信息:").append(basicBusTypePreEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (needExec(info.getBusChangeConfig())) {
|
|
|
|
if (needExec(info.getBusChangeConfig())) {
|
|
|
@ -1019,12 +1070,14 @@ public class HeartService {
|
|
|
|
if (CollectionUtil.isNotEmpty(basicBusTypeChangeEntities)) {
|
|
|
|
if (CollectionUtil.isNotEmpty(basicBusTypeChangeEntities)) {
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse = new SpsSyncSysSettingResponse();
|
|
|
|
dataResponse.setBasicBusTypeChangeEntities(basicBusTypeChangeEntities);
|
|
|
|
dataResponse.setBasicBusTypeChangeEntities(basicBusTypeChangeEntities);
|
|
|
|
|
|
|
|
remark.append("业务单自动补单设置信息:").append(basicBusTypeChangeEntities.size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (dataResponse != null) {
|
|
|
|
if (dataResponse != null) {
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setTaskId(taskId);
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.SYS_SET_DATA.getRemark());
|
|
|
|
dataResponse.setType(BasicExportTypeEnum.SYS_SET_DATA.getRemark());
|
|
|
|
|
|
|
|
dataResponse.setSyncRemark(remark.toString());
|
|
|
|
if (CollUtil.isNotEmpty(dataResponse.getSystemPDFTemplateEntities())) {
|
|
|
|
if (CollUtil.isNotEmpty(dataResponse.getSystemPDFTemplateEntities())) {
|
|
|
|
// List<Map<String, String>> list = new ArrayList<>(spsSyncSysSettingResponse.getSystemPDFTemplateEntities().size() * 2);
|
|
|
|
// List<Map<String, String>> list = new ArrayList<>(spsSyncSysSettingResponse.getSystemPDFTemplateEntities().size() * 2);
|
|
|
|
List<String> list = new ArrayList<>();
|
|
|
|
List<String> list = new ArrayList<>();
|
|
|
@ -1068,6 +1121,9 @@ public class HeartService {
|
|
|
|
if (baseResponse.getCode() != 20000) {
|
|
|
|
if (baseResponse.getCode() != 20000) {
|
|
|
|
status = StatusEnum.FAILED.getCode();
|
|
|
|
status = StatusEnum.FAILED.getCode();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
BaseSyncResponse baseSyncResponse = (BaseSyncResponse) data;
|
|
|
|
BasicExportStatusEntity exportStatus = BasicExportStatusEntity.builder()
|
|
|
|
BasicExportStatusEntity exportStatus = BasicExportStatusEntity.builder()
|
|
|
|
.id(taskId)
|
|
|
|
.id(taskId)
|
|
|
|
.status(status)
|
|
|
|
.status(status)
|
|
|
@ -1076,9 +1132,9 @@ public class HeartService {
|
|
|
|
.startTime(new Date())
|
|
|
|
.startTime(new Date())
|
|
|
|
.endTime(new Date())
|
|
|
|
.endTime(new Date())
|
|
|
|
.updateTime(new Date())
|
|
|
|
.updateTime(new Date())
|
|
|
|
.receiveStatus(status)
|
|
|
|
.receiveStatus(status + "")
|
|
|
|
.scheduleType(BasicProcessStatus.SCHEDULE_NORMAL)
|
|
|
|
.scheduleType(BasicProcessStatus.SCHEDULE_NORMAL)
|
|
|
|
.remark(baseResponse.getMessage())
|
|
|
|
.remark(baseSyncResponse.getSyncRemark())
|
|
|
|
.build();
|
|
|
|
.build();
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
String fileFullPath = writeFile(filePrefix, exportType.getRemark(), JsonUtils.toJsonString(data));
|
|
|
|
String fileFullPath = writeFile(filePrefix, exportType.getRemark(), JsonUtils.toJsonString(data));
|
|
|
@ -1284,7 +1340,7 @@ public class HeartService {
|
|
|
|
//下载最近更新扫码单据--上级服务
|
|
|
|
//下载最近更新扫码单据--上级服务
|
|
|
|
@Transactional(propagation = Propagation.NESTED)
|
|
|
|
@Transactional(propagation = Propagation.NESTED)
|
|
|
|
public void dlAllOrder() {
|
|
|
|
public void dlAllOrder() {
|
|
|
|
BaseResponse<List<BasicExportStatusEntity>> baseResponse = spGetHttp.getBasicStatus(NEW_ALL_ORDER + "");
|
|
|
|
BaseResponse<List<BasicExportStatusEntity>> baseResponse = spGetHttp.getBasicStatus(NEW_ALL_ORDER + "", "3");
|
|
|
|
List<BasicExportStatusEntity> pageSimpleResponse = baseResponse != null ? baseResponse.getData() : new ArrayList<>();
|
|
|
|
List<BasicExportStatusEntity> pageSimpleResponse = baseResponse != null ? baseResponse.getData() : new ArrayList<>();
|
|
|
|
if (pageSimpleResponse != null) {
|
|
|
|
if (pageSimpleResponse != null) {
|
|
|
|
List<BasicExportStatusEntity> basicExportStatusEntities = pageSimpleResponse;
|
|
|
|
List<BasicExportStatusEntity> basicExportStatusEntities = pageSimpleResponse;
|
|
|
@ -1304,9 +1360,9 @@ public class HeartService {
|
|
|
|
basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_DOWNLOAD_SCAN_ORDER);
|
|
|
|
basicDownloadStatusEntity.setIdDatas(ConstantStatus.SYNC_DOWNLOAD_SCAN_ORDER);
|
|
|
|
basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_WAIT); //下载中
|
|
|
|
basicDownloadStatusEntity.setStatus(ConstantStatus.SYNC_STATUS_WAIT); //下载中
|
|
|
|
basicDownloadStatusEntity.setType(NEW_ALL_ORDER);
|
|
|
|
basicDownloadStatusEntity.setType(NEW_ALL_ORDER);
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setRemark(syncDataResponse.getSyncRemark());
|
|
|
|
basicDownloadStatusEntity.setScheduleType(1);
|
|
|
|
basicDownloadStatusEntity.setScheduleType(1);
|
|
|
|
basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
basicDownloadService.insertDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
StringBuffer remark = new StringBuffer();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities())) {
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities())) {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
@ -1314,6 +1370,7 @@ public class HeartService {
|
|
|
|
for (IoOrderEntity orderEntity : orderEntities) {
|
|
|
|
for (IoOrderEntity orderEntity : orderEntities) {
|
|
|
|
orderEntity.setUpdateTime(null);
|
|
|
|
orderEntity.setUpdateTime(null);
|
|
|
|
orderEntity.setFromType(ConstantStatus.FROM_UDISP);
|
|
|
|
orderEntity.setFromType(ConstantStatus.FROM_UDISP);
|
|
|
|
|
|
|
|
orderEntity.setProcessStatus(ConstantStatus.ORDER_DEAL_POST);
|
|
|
|
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS);
|
|
|
|
orderEntity.setStatus(ConstantStatus.ORDER_STATUS_PROCESS);
|
|
|
|
IoOrderEntity temp = orderService.findByBillNo(orderEntity.getBillNo());
|
|
|
|
IoOrderEntity temp = orderService.findByBillNo(orderEntity.getBillNo());
|
|
|
|
if (temp == null) {
|
|
|
|
if (temp == null) {
|
|
|
@ -1329,29 +1386,15 @@ public class HeartService {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
String logs = "";
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderEntities()))
|
|
|
|
|
|
|
|
logs = logs + "单据:" + syncDataResponse.getOrderEntities().size() + "条\n";
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailBizEntities()))
|
|
|
|
|
|
|
|
logs = logs + "业务详情:" + syncDataResponse.getOrderDetailBizEntities().size() + "条\n";
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailCodeEntities()))
|
|
|
|
|
|
|
|
logs = logs + "单据扫码详情:" + syncDataResponse.getOrderDetailCodeEntities().size() + "条\n";
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getOrderDetailResultEntities()))
|
|
|
|
|
|
|
|
logs = logs + "单据结果详情:" + syncDataResponse.getOrderDetailResultEntities().size() + "条\n";
|
|
|
|
|
|
|
|
if (CollUtil.isNotEmpty(syncDataResponse.getCodeEntities()))
|
|
|
|
|
|
|
|
logs = logs + "单据条码信息:" + syncDataResponse.getCodeEntities().size() + "条\n";
|
|
|
|
|
|
|
|
remark.append(logs);
|
|
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
e.printStackTrace();
|
|
|
|
e.printStackTrace();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
spGetHttp.postBasicStatus(basicExportStatusEntity.getId());
|
|
|
|
spGetHttp.finishTask(basicExportStatusEntity.getId());
|
|
|
|
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setRemark(remark.toString());
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
|
|
|
|
|
|
|
@ -1365,7 +1408,7 @@ public class HeartService {
|
|
|
|
// 下载最近更新国家库数据-上级服务
|
|
|
|
// 下载最近更新国家库数据-上级服务
|
|
|
|
@Transactional(propagation = Propagation.NESTED)
|
|
|
|
@Transactional(propagation = Propagation.NESTED)
|
|
|
|
public void dlAllDiProducts() {
|
|
|
|
public void dlAllDiProducts() {
|
|
|
|
BaseResponse<List<BasicExportStatusEntity>> baseResponse = spGetHttp.getBasicStatus(NEW_ALL_UDIS);
|
|
|
|
BaseResponse<List<BasicExportStatusEntity>> baseResponse = spGetHttp.getBasicStatus(NEW_ALL_UDIS, "3");
|
|
|
|
List<BasicExportStatusEntity> pageSimpleResponse = baseResponse.getData();
|
|
|
|
List<BasicExportStatusEntity> pageSimpleResponse = baseResponse.getData();
|
|
|
|
if (pageSimpleResponse != null) {
|
|
|
|
if (pageSimpleResponse != null) {
|
|
|
|
List<BasicExportStatusEntity> basicExportStatusEntities = pageSimpleResponse;
|
|
|
|
List<BasicExportStatusEntity> basicExportStatusEntities = pageSimpleResponse;
|
|
|
@ -1414,11 +1457,17 @@ public class HeartService {
|
|
|
|
remark.append("产品信息:").append(spSyncUdiResponse.getProductInfoEntityList().size()).append("条\n");
|
|
|
|
remark.append("产品信息:").append(spSyncUdiResponse.getProductInfoEntityList().size()).append("条\n");
|
|
|
|
}
|
|
|
|
}
|
|
|
|
batchSession.close();
|
|
|
|
batchSession.close();
|
|
|
|
spGetHttp.postBasicStatus(basicExportStatusEntity.getId());
|
|
|
|
// spGetHttp.postBasicStatus(basicExportStatusEntity.getId());
|
|
|
|
|
|
|
|
spGetHttp.finishTask(basicExportStatusEntity.getId());
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setRemark(remark.toString());
|
|
|
|
basicDownloadStatusEntity.setRemark(remark.toString());
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
String fileFullPath = writeFile(filePrefix, NEW_ALL_UDIS, JSONUtil.toJsonStr(response.getData()));
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setCacheFilePath(fileFullPath);
|
|
|
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
|
|
|
throw new RuntimeException(e);
|
|
|
|
|
|
|
|
}
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode());
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
basicDownloadService.updateDownloadStatus(basicDownloadStatusEntity);
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -1476,6 +1525,8 @@ public class HeartService {
|
|
|
|
String taskId = bean.getTaskId();
|
|
|
|
String taskId = bean.getTaskId();
|
|
|
|
if (StrUtil.isNotBlank(taskId)) {
|
|
|
|
if (StrUtil.isNotBlank(taskId)) {
|
|
|
|
//插入下载记录
|
|
|
|
//插入下载记录
|
|
|
|
|
|
|
|
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(bean.getFileContent());
|
|
|
|
|
|
|
|
String remark = jsonObject.getStr(Constant.SYNC_REMARK);
|
|
|
|
BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity();
|
|
|
|
BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity();
|
|
|
|
basicDownloadStatusEntity.setId(CustomUtil.getId());
|
|
|
|
basicDownloadStatusEntity.setId(CustomUtil.getId());
|
|
|
|
basicDownloadStatusEntity.setTaskId(taskId);
|
|
|
|
basicDownloadStatusEntity.setTaskId(taskId);
|
|
|
@ -1483,6 +1534,7 @@ public class HeartService {
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setUpdateTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setEndTime(new Date());
|
|
|
|
basicDownloadStatusEntity.setIdDatas(exportType.getKey());
|
|
|
|
basicDownloadStatusEntity.setIdDatas(exportType.getKey());
|
|
|
|
|
|
|
|
basicDownloadStatusEntity.setRemark(remark);
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode()); //下载完成
|
|
|
|
basicDownloadStatusEntity.setStatus(StatusEnum.SUCCESS.getCode()); //下载完成
|
|
|
|
basicDownloadStatusEntity.setType(exportType.getRemark());
|
|
|
|
basicDownloadStatusEntity.setType(exportType.getRemark());
|
|
|
|
basicDownloadStatusEntity.setScheduleType(1);
|
|
|
|
basicDownloadStatusEntity.setScheduleType(1);
|
|
|
@ -1781,6 +1833,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);
|
|
|
|
orderInvoiceService.insertInvoice(orderInvoiceEntity);
|
|
|
|
orderInvoiceService.insertInvoice(orderInvoiceEntity);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|