企业绑定门店

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/enums/ChannelCodeEnum.java

@@ -13,6 +13,8 @@ public enum ChannelCodeEnum {
     SYNC_UNBIND(2003,"GIC同步解绑"),
     WEIXIN_DEL(2004,"微信删除解绑"),
     AUDIT_UNBIND(2005,"审核解绑"),
+    RIGHT_CHANGE_UNBIND(2006, "权限变更解绑"),
+    STORE_CHANGE_UNBIND(2007, "门店变更解绑"),
 //    CHANGR_RIGHT_UNBIND(2005,"审核解绑"),
     ;
     private int code;

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/WxEnterpriseRelatedApiServiceImpl.java

@@ -271,8 +271,8 @@ public class WxEnterpriseRelatedApiServiceImpl implements WxEnterpriseRelatedApi
 
         miniprogramSettingService.saveMiniprogramSetting(miniprogramSetting);
 		//刷新门店信息
-        ServiceResponse response = this.flushBindStoreByEnterpriseId(detailDTO.getEnterpriseId(), detailDTO.getWxEnterpriseId(), detailDTO.getStaffId(), ChannelCodeEnum.ADMIN_UNBIND.getCode());
-        logger.info("刷新返回信息：{}", JSONObject.toJSONString(response));
+		ServiceResponse response = this.flushBindStoreByEnterpriseId(detailDTO.getEnterpriseId(), detailDTO.getWxEnterpriseId(), detailDTO.getStaffId(), ChannelCodeEnum.RIGHT_CHANGE_UNBIND.getCode());
+		logger.info("刷新返回信息：{}", JSONObject.toJSONString(response));
         //如果已经在刷新了 需要放入队列再刷新
         if (response.getCode() == 2) {
             logger.info("放入队列刷新：{}", detailDTO.getEnterpriseId());

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java

@@ -245,7 +245,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
         FlushStoreMqDTO mqDTO = new FlushStoreMqDTO();
         mqDTO.setEnterpriseId(enterrpriseId);
         mqDTO.setWxEnterpriseId("-1");
-        mqDTO.setChannalCode(ChannelCodeEnum.SYNC_UNBIND.getCode());
+        mqDTO.setChannalCode(ChannelCodeEnum.STORE_CHANGE_UNBIND.getCode());
         mqDTO.setOptStaffId("-1");
         wxEnterpriseRelatedApiService.flushBindStoreToDelayMq(enterrpriseId, mqDTO);
     }