1.添加第三方基础数据同步和系统设置同步代码
x_z
2 years ago
parent
7d6341a9c2
commit
c68cb845a0
@ -0,0 +1,80 @@
|
||||
package com.glxp.api.res.sync;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import com.glxp.api.entity.basic.BasicBusTypeChangeEntity;
|
||||
import com.glxp.api.entity.basic.BasicBusTypePreEntity;
|
||||
import com.glxp.api.entity.basic.EntrustReceEntity;
|
||||
import com.glxp.api.entity.system.*;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 同步系统设置数据
|
||||
*/
|
||||
@Data
|
||||
public class SpsSyncSysSettingResponse extends BaseSyncResponse {
|
||||
|
||||
private List<SystemParamConfigEntity> systemParamConfigEntities;
|
||||
|
||||
private List<EntrustReceEntity> entrustReceEntities;
|
||||
|
||||
private List<SystemPDFModuleEntity> systemPDFModuleEntities;
|
||||
|
||||
private List<SystemPDFTemplateEntity> systemPDFTemplateEntities;
|
||||
|
||||
private List<SysPdfTemplateRelevanceCodeEntity> sysPdfTemplateRelevanceCodeEntities;
|
||||
|
||||
private List<SysPdfTemplateRelevanceBizEntity> sysPdfTemplateRelevanceBizEntities;
|
||||
|
||||
private List<SysPdfTemplateRelevanceLabelEntity> sysPdfTemplateRelevanceLabelEntities;
|
||||
|
||||
private List<SysPdfTemplateRelevanceStatemenEntity> sysPdfTemplateRelevanceStatemenEntities;
|
||||
|
||||
private List<BasicBusTypePreEntity> basicBusTypePreEntities;
|
||||
|
||||
private List<BasicBusTypeChangeEntity> basicBusTypeChangeEntities;
|
||||
|
||||
|
||||
/**
|
||||
* 拼接日志
|
||||
*
|
||||
* @return
|
||||
*/
|
||||
public String logs() {
|
||||
StringBuilder logs = new StringBuilder();
|
||||
if (CollUtil.isNotEmpty(this.systemParamConfigEntities)) {
|
||||
logs.append("系统运行参数：").append(this.systemParamConfigEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.entrustReceEntities)) {
|
||||
logs.append("委托验收设置：").append(this.entrustReceEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.systemPDFModuleEntities)) {
|
||||
logs.append("打印模块：").append(this.systemPDFModuleEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.systemPDFTemplateEntities)) {
|
||||
logs.append("打印模板：").append(this.systemPDFTemplateEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.sysPdfTemplateRelevanceCodeEntities)) {
|
||||
logs.append("扫码单据关联表：").append(this.sysPdfTemplateRelevanceCodeEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.sysPdfTemplateRelevanceBizEntities)) {
|
||||
logs.append("业务单据关联表：").append(this.sysPdfTemplateRelevanceBizEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.sysPdfTemplateRelevanceLabelEntities)) {
|
||||
logs.append("内部码打印关联表：").append(this.sysPdfTemplateRelevanceLabelEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.sysPdfTemplateRelevanceStatemenEntities)) {
|
||||
logs.append("资质证书打印关联表：").append(this.sysPdfTemplateRelevanceStatemenEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.basicBusTypePreEntities)) {
|
||||
logs.append("自动建出入库单设置：").append(this.basicBusTypePreEntities.size()).append("条\n");
|
||||
}
|
||||
if (CollUtil.isNotEmpty(this.basicBusTypeChangeEntities)) {
|
||||
logs.append("自动建业务单设置：").append(this.basicBusTypeChangeEntities.size()).append("条\n");
|
||||
}
|
||||
return logs.toString();
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@ -0,0 +1,30 @@
|
||||
package com.glxp.api.res.sync;
|
||||
|
||||
import com.glxp.api.entity.thrsys.ThrCorpEntity;
|
||||
import com.glxp.api.entity.thrsys.ThrDeptEntity;
|
||||
import com.glxp.api.entity.thrsys.ThrInvWarehouseEntity;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 同步第三方基础数据
|
||||
*/
|
||||
@Data
|
||||
public class SpsSyncThrDataResponse extends BaseSyncResponse {
|
||||
|
||||
/**
|
||||
* 部门信息
|
||||
*/
|
||||
private List<ThrDeptEntity> deptEntities;
|
||||
|
||||
/**
|
||||
* 仓库信息
|
||||
*/
|
||||
private List<ThrInvWarehouseEntity> invWarehouseEntities;
|
||||
|
||||
/**
|
||||
* 往来单位信息
|
||||
*/
|
||||
private List<ThrCorpEntity> corpEntities;
|
||||
}
|
||||
@ -0,0 +1,19 @@
|
||||
package com.glxp.api.res.sync;
|
||||
|
||||
import com.glxp.api.entity.thrsys.ThrProductsEntity;
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 同步第三方产品数据
|
||||
*/
|
||||
@Data
|
||||
public class SpsSyncThrProductsResponse extends BaseSyncResponse {
|
||||
|
||||
/**
|
||||
* 产品信息
|
||||
*/
|
||||
private List<ThrProductsEntity> productsEntities;
|
||||
|
||||
}
|
||||
@ -0,0 +1,89 @@
|
||||
package com.glxp.api.service.sync;
|
||||
|
||||
import com.glxp.api.entity.thrsys.ThrCorpEntity;
|
||||
import com.glxp.api.entity.thrsys.ThrDeptEntity;
|
||||
import com.glxp.api.entity.thrsys.ThrInvWarehouseEntity;
|
||||
import com.glxp.api.entity.thrsys.ThrProductsEntity;
|
||||
import com.glxp.api.req.sync.SpsSyncDataRequest;
|
||||
import com.glxp.api.res.sync.SpsSyncThrDataResponse;
|
||||
import com.glxp.api.res.sync.SpsSyncThrProductsResponse;
|
||||
import com.glxp.api.res.system.SyncDataSetResponse;
|
||||
import com.glxp.api.service.thrsys.ThrCorpService;
|
||||
import com.glxp.api.service.thrsys.ThrDeptService;
|
||||
import com.glxp.api.service.thrsys.ThrInvWarehouseService;
|
||||
import com.glxp.api.service.thrsys.ThrProductsService;
|
||||
import com.glxp.api.util.DateUtil;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* 上传第三方基础数据到自助平台
|
||||
*/
|
||||
@Service
|
||||
public class UpThrDataService {
|
||||
|
||||
@Resource
|
||||
private SyncDataSetService syncDataSetService;
|
||||
@Resource
|
||||
private ThrDeptService thrDeptService;
|
||||
@Resource
|
||||
private ThrInvWarehouseService thrInvWarehouseService;
|
||||
@Resource
|
||||
private ThrProductsService thrProductsService;
|
||||
@Resource
|
||||
private ThrCorpService thrCorpService;
|
||||
|
||||
/**
|
||||
* 上传最近更新的第三方基础信息数据
|
||||
*
|
||||
* @param spsSyncDataRequest
|
||||
* @return
|
||||
*/
|
||||
public SpsSyncThrDataResponse upThrData(SpsSyncDataRequest spsSyncDataRequest) {
|
||||
SpsSyncThrDataResponse spsSyncThrDataResponse = new SpsSyncThrDataResponse();
|
||||
//查询数据同步设置
|
||||
SyncDataSetResponse syncDataSet = syncDataSetService.selectSet();
|
||||
|
||||
//第三方部门信息
|
||||
if (syncDataSet.getBasicThirdDept() == 1) {
|
||||
List<ThrDeptEntity> deptEntities = thrDeptService.findByLastTime(DateUtil.parseDate(spsSyncDataRequest.getLastUpdateTime()));
|
||||
spsSyncThrDataResponse.setDeptEntities(deptEntities);
|
||||
}
|
||||
|
||||
//第三方仓库信息
|
||||
if (syncDataSet.getBasicThirdInv() == 1) {
|
||||
List<ThrInvWarehouseEntity> invWarehouseEntities = thrInvWarehouseService.findByLastTime(DateUtil.parseDate(spsSyncDataRequest.getLastUpdateTime()));
|
||||
spsSyncThrDataResponse.setInvWarehouseEntities(invWarehouseEntities);
|
||||
}
|
||||
|
||||
//第三方往来单位信息
|
||||
if (syncDataSet.getBasicThirdCorp() == 1) {
|
||||
List<ThrCorpEntity> corpEntities = thrCorpService.findByLastTime(DateUtil.parseDate(spsSyncDataRequest.getLastUpdateTime()));
|
||||
spsSyncThrDataResponse.setCorpEntities(corpEntities);
|
||||
}
|
||||
return spsSyncThrDataResponse;
|
||||
}
|
||||
|
||||
/**
|
||||
* 上传最近更新的第三方产品信息数据
|
||||
*
|
||||
* @param spsSyncDataRequest
|
||||
* @return
|
||||
*/
|
||||
public SpsSyncThrProductsResponse upThrProducts(SpsSyncDataRequest spsSyncDataRequest) {
|
||||
SpsSyncThrProductsResponse spsSyncThrProductsResponse = new SpsSyncThrProductsResponse();
|
||||
//查询数据同步设置
|
||||
SyncDataSetResponse syncDataSet = syncDataSetService.selectSet();
|
||||
|
||||
//第三方产品信息
|
||||
if (syncDataSet.getBasicThirdProducts() == 1) {
|
||||
List<ThrProductsEntity> thrProductsEntities = thrProductsService.findByLastTime(DateUtil.parseDate(spsSyncDataRequest.getLastUpdateTime()));
|
||||
spsSyncThrProductsResponse.setProductsEntities(thrProductsEntities);
|
||||
}
|
||||
|
||||
return spsSyncThrProductsResponse;
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue