Commit acd41b08 by guojuxing

资源组变更通知调整

parent 6ad9f13f
...@@ -42,6 +42,11 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{ ...@@ -42,6 +42,11 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{
*/ */
private CustomAreaDTO customAreaDTO; private CustomAreaDTO customAreaDTO;
/**
* 1 : 初始化 2:资源组变更
*/
private Integer resourceGroupChangeType;
public Long getStoreResource() { public Long getStoreResource() {
return storeResource; return storeResource;
} }
...@@ -96,6 +101,18 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{ ...@@ -96,6 +101,18 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{
return this; return this;
} }
public Integer getResourceGroupChangeType() {
if (resourceGroupChangeType == null) {
return 1;
}
return resourceGroupChangeType;
}
public UnionEnterpriseAuthResNoticeDTO setResourceGroupChangeType(Integer resourceGroupChangeType) {
this.resourceGroupChangeType = resourceGroupChangeType;
return this;
}
@Override @Override
public String toString() { public String toString() {
return "UnionEnterpriseAuthResNoticeDTO{" + return "UnionEnterpriseAuthResNoticeDTO{" +
...@@ -105,6 +122,7 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{ ...@@ -105,6 +122,7 @@ public class UnionEnterpriseAuthResNoticeDTO implements Serializable{
", goodsResourceId=" + goodsResourceId + ", goodsResourceId=" + goodsResourceId +
", userResourceInfoList=" + userResourceInfoList + ", userResourceInfoList=" + userResourceInfoList +
", customAreaDTO=" + customAreaDTO + ", customAreaDTO=" + customAreaDTO +
", resourceGroupChangeType=" + resourceGroupChangeType +
'}'; '}';
} }
} }
...@@ -38,10 +38,11 @@ public interface ResourceGroupApiService { ...@@ -38,10 +38,11 @@ public interface ResourceGroupApiService {
* @param unionEnterpriseId 联合商户ID * @param unionEnterpriseId 联合商户ID
* @param newResourceGroup * @param newResourceGroup
* @param oldResourceGroup * @param oldResourceGroup
* @param resourceGroupChangeType 1 : 初始化 2:资源组变更, 默认1
* @return * @return
*/ */
ServiceResponse<Void> syncResourceAuthChangeMQ(Integer ownEnterpriseId, Integer unionEnterpriseId, ServiceResponse<Void> syncResourceAuthChangeMQ(Integer ownEnterpriseId, Integer unionEnterpriseId,
ResourceGroupDTO newResourceGroup, ResourceGroupDTO oldResourceGroup); ResourceGroupDTO newResourceGroup, ResourceGroupDTO oldResourceGroup, Integer resourceGroupChangeType);
/** /**
* 分页查询 * 分页查询
......
...@@ -6,6 +6,7 @@ import java.util.List; ...@@ -6,6 +6,7 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import com.gic.store.service.UnionStoreChangeApiService;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.StringUtils; import org.apache.commons.lang.StringUtils;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
...@@ -56,6 +57,8 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{ ...@@ -56,6 +57,8 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{
private UnionEnterpriseAuthApiService unionEnterpriseAuthApiService; private UnionEnterpriseAuthApiService unionEnterpriseAuthApiService;
@Autowired @Autowired
private AuthCodeApiService authCodeApiService; private AuthCodeApiService authCodeApiService;
@Autowired
private UnionStoreChangeApiService unionStoreChangeApiService;
@Override @Override
public ServiceResponse<Integer> saveResourceGroup(ResourceGroupDTO resourceGroup) { public ServiceResponse<Integer> saveResourceGroup(ResourceGroupDTO resourceGroup) {
...@@ -84,9 +87,11 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{ ...@@ -84,9 +87,11 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{
} }
ResourceGroupDTO oldResourceGroup = EntityUtil.changeEntityNew(ResourceGroupDTO.class, ResourceGroupDTO oldResourceGroup = EntityUtil.changeEntityNew(ResourceGroupDTO.class,
checkExistResourceGroup(resourceGroup.getResourceGroupId())); checkExistResourceGroup(resourceGroup.getResourceGroupId()));
// 保存商户下联合商户资源组授权范围变化日志
unionStoreChangeApiService.save(unionEnterpriseAuthDTO.getOwnEnterpriseId(), unionEnterpriseAuthDTO.getUnionEnterpriseId());
//通知业务方数据同步联合调整 //通知业务方数据同步联合调整
syncResourceAuthChangeMQ(unionEnterpriseAuthDTO.getOwnEnterpriseId(), unionEnterpriseAuthDTO.getUnionEnterpriseId(), syncResourceAuthChangeMQ(unionEnterpriseAuthDTO.getOwnEnterpriseId(), unionEnterpriseAuthDTO.getUnionEnterpriseId(),
resourceGroup, oldResourceGroup); resourceGroup, oldResourceGroup, 2);
} }
resourceGroupService.editResourceGroup(resourceGroup); resourceGroupService.editResourceGroup(resourceGroup);
...@@ -95,7 +100,7 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{ ...@@ -95,7 +100,7 @@ public class ResourceGroupApiServiceImpl implements ResourceGroupApiService{
@Override @Override
public ServiceResponse<Void> syncResourceAuthChangeMQ(Integer ownEnterpriseId, Integer unionEnterpriseId, public ServiceResponse<Void> syncResourceAuthChangeMQ(Integer ownEnterpriseId, Integer unionEnterpriseId,
ResourceGroupDTO newResourceGroup, ResourceGroupDTO oldResourceGroup) { ResourceGroupDTO newResourceGroup, ResourceGroupDTO oldResourceGroup, Integer resourceGroupChangeType) {
UnionEnterpriseAuthResNoticeDTO unionEnterpriseAuthResNoticeDTO = new UnionEnterpriseAuthResNoticeDTO(); UnionEnterpriseAuthResNoticeDTO unionEnterpriseAuthResNoticeDTO = new UnionEnterpriseAuthResNoticeDTO();
unionEnterpriseAuthResNoticeDTO.setGoodsResourceId(newResourceGroup.getGoodsResourceId()); unionEnterpriseAuthResNoticeDTO.setGoodsResourceId(newResourceGroup.getGoodsResourceId());
unionEnterpriseAuthResNoticeDTO.setStoreResource(newResourceGroup.getStoreResource()); unionEnterpriseAuthResNoticeDTO.setStoreResource(newResourceGroup.getStoreResource());
......
...@@ -80,4 +80,5 @@ ...@@ -80,4 +80,5 @@
<dubbo:reference interface="com.gic.enterprise.service.QrCodeApiService" id="qrCodeApiService" timeout="6000" /> <dubbo:reference interface="com.gic.enterprise.service.QrCodeApiService" id="qrCodeApiService" timeout="6000" />
<dubbo:reference interface="com.gic.enterprise.service.UnionEnterpriseAuthApiService" id="unionEnterpriseAuthApiService" timeout="6000" /> <dubbo:reference interface="com.gic.enterprise.service.UnionEnterpriseAuthApiService" id="unionEnterpriseAuthApiService" timeout="6000" />
<dubbo:reference interface="com.gic.store.service.UnionStoreChangeApiService" id="unionStoreChangeApiService" timeout="6000" />
</beans> </beans>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment