# Conflicts:

#	suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/AnalysisDiyCustomerComponent.java
#	suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/ShopUserTypeComponent.java

suishenbang-admin/src/main/java/com/dgtly/web/controller/system/AlertConfigurationController.java

@@ -118,7 +118,6 @@ public class AlertConfigurationController extends BaseController
     {
 
         log.info("新增弹框配置");
-        log.info("222222222{}", JSON.toJSON(alertConfiguration));
         //如果userType为空,则添加所有人通知
         if (StringUtils.isEmpty(alertConfiguration.getUserType())){
             alertConfiguration.setUserType("2");

suishenbang-admin/src/main/java/com/dgtly/web/controller/system/SysUserController.java

@@ -1,27 +1,23 @@
 package com.dgtly.web.controller.system;
 
-import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
+
 
 import com.dgtly.common.core.domain.Ztree;
 import com.dgtly.common.exception.BusinessException;
 import com.dgtly.common.utils.ShiroSaltUtil;
 import com.dgtly.common.utils.security.EncryptPassWordClass;
+import com.dgtly.sync.service.AnalysisDiyCustomerComponent;
 import com.dgtly.system.domain.*;
 import com.dgtly.system.service.*;
+import io.lettuce.core.dynamic.annotation.Param;
 import org.apache.shiro.authz.annotation.RequiresPermissions;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.ui.ModelMap;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 import com.dgtly.common.annotation.Log;
 import com.dgtly.common.constant.UserConstants;
@@ -54,6 +50,9 @@ public class SysUserController extends BaseController
     @Autowired
     private ISysUserOrderAuthorService sysUserOrderAuthorService;
 
+    @Autowired
+    private AnalysisDiyCustomerComponent analysisDiyCustomerComponent;
+
     @Autowired
     private ISysPostService postService;
     @Autowired
@@ -139,7 +138,21 @@ public class SysUserController extends BaseController
     }
 
     /**
-     * 新增用户
+     * 获取经销商负责人
+     * @param depCode
+     * @param userNo
+     * @return
+     */
+    @GetMapping("/getManagerList")
+    @ResponseBody
+    public AjaxResult getManagerList(@RequestParam(value = "depCode" , required = false) String depCode , @RequestParam(value = "userNo", required = false) String userNo)
+    {
+        String result =  analysisDiyCustomerComponent.getManagerList(depCode,userNo);
+        return AjaxResult.success(result);
+    }
+
+    /**
+     * 新增获取经销商负责人
      */
     @GetMapping("/add")
     public String add(ModelMap mmap)

suishenbang-admin/src/main/java/com/dgtly/web/controller/system/getCustomerDataController.java

@@ -0,0 +1,26 @@
+package com.dgtly.web.controller.system;
+
+import com.dgtly.common.core.controller.BaseController;
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+/**
+ * 缓存清理
+ * 
+ * @author ruoyi
+ */
+@Controller
+@RequestMapping("/system/getCustomerData")
+public class getCustomerDataController extends BaseController
+{
+    private String prefix = "system/getCustomerData";
+
+    @RequiresPermissions("system:getCustomerData:view")
+    @GetMapping()
+    public String clearStorage()
+    {
+        return prefix + "/getCustomerData";
+    }
+}

suishenbang-admin/src/main/resources/application-dev.yml

@@ -67,6 +67,22 @@ user:
 
 # Spring配置
 spring:
+  redis:
+    host: 127.0.0.1
+    port: 6379
+    password: 'Ssbtest#1207'
+    # 连接超时时间
+    timeout: 10s
+    lettuce:
+      pool:
+        # 连接池中的最小空闲连接
+        min-idle: 1
+        # 连接池中的最大空闲连接
+        max-idle: 8
+        # 连接池的最大数据库连接数
+        max-active: 20
+        # #连接池最大阻塞等待时间（使用负值表示没有限制）
+        max-wait: -1ms
   # 模板引擎
   thymeleaf:
     mode: HTML

suishenbang-admin/src/main/resources/application-uat-druid.yml

@@ -53,7 +53,7 @@ spring:
                     enabled: true
                     # 慢SQL记录
                     log-slow-sql: true
-                    slow-sql-millis: 30000
+                    slow-sql-millis: 5000
                     merge-sql: true
                 wall:
                     config:

suishenbang-admin/src/main/resources/application-uat.yml

@@ -10,7 +10,7 @@ ruoyi:
   demoEnabled: true
   # 文件路径 示例（ Windows配置D:/ruoyi/uploadPath，Linux配置 /home/ruoyi/uploadPath）
   profile: /home/admin/project/file
-#  profile: D:/ruoyi/uploadPath
+  #  profile: D:/ruoyi/uploadPath
   # 获取ip地址开关
   addressEnabled: false
   cloudPath: http://127.0.0.1:8000/
@@ -32,10 +32,18 @@ shop:
 
 #hana数据库数据同步配置
 hana:
+  #  hana-driver: com.sap.db.jdbc.Driver
+  #  hana-url: jdbc:sap://hanaentsltd.nipponpaint.com.cn:30015?reconnect=true
+  #  hana-user: SSB_HANA
+  #  hana-pwd: s$EW12445T
+#  hana-driver: com.sap.db.jdbc.Driver
+#  hana-url: jdbc:sap://hanaentsltd.nipponpaint.com.cn:30015?reconnect=true
+#  hana-user: SSB_HANA
+#  hana-pwd: s$EW12445T
   hana-driver: com.sap.db.jdbc.Driver
-  hana-url: jdbc:sap://hanaentsltd.nipponpaint.com.cn:30015?reconnect=true
+  hana-url: jdbc:sap://hanaentsltp.nipponpaint.com.cn:30015?reconnect=true
   hana-user: SSB_HANA
-  hana-pwd: s$EW12445T
+  hana-pwd: Erty567*
   mysql-driver: com.mysql.jdbc.Driver
 #  mysql-url: jdbc:mysql://pc-uf637rafh16b6nl16.rwlb.rds.aliyuncs.com:3306/ssbtest?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
 #  mysql-user: ssbtest
@@ -102,12 +110,12 @@ spring:
     include: uat-druid
   # 文件上传
   servlet:
-     multipart:
-       # 单个文件大小
-       max-file-size:  10MB
-       # 设置总上传的文件大小
-       max-request-size:  20MB
-       location: /data/upload_tmp
+    multipart:
+      # 单个文件大小
+      max-file-size:  10MB
+      # 设置总上传的文件大小
+      max-request-size:  20MB
+      location: /data/upload_tmp
   tms:
     #TMS接口地址
     tmsUrl: https://lbtest.lutms.com/wuliu/apissbzt/ssb_update_authFile.do
@@ -148,12 +156,12 @@ spring:
 
 # MyBatis
 mybatis:
-    # 搜索指定包别名
-    typeAliasesPackage: com.dgtly.**.domain
-    # 配置mapper的扫描，找到所有的mapper.xml映射文件
-    mapperLocations: classpath*:mapper/**/*Mapper.xml
-    # 加载全局的配置文件
-    configLocation: classpath:mybatis/mybatis-config.xml
+  # 搜索指定包别名
+  typeAliasesPackage: com.dgtly.**.domain
+  # 配置mapper的扫描，找到所有的mapper.xml映射文件
+  mapperLocations: classpath*:mapper/**/*Mapper.xml
+  # 加载全局的配置文件
+  configLocation: classpath:mybatis/mybatis-config.xml
 
 # PageHelper分页插件
 pagehelper:

suishenbang-admin/src/main/resources/templates/monitor/clearStorage/clearStorage.html

@@ -50,7 +50,7 @@
             </div>
         </div>
         <div class="row" style="margin-top: 10px;">
-            <label class="col-sm-1 control-label" style="text-align: right;padding: 0;">清空单体：</label>
+            <label class="col-sm-1 control-label" style="text-align: right;padding: 0;height: 34px;line-height: 34px;">清空单体：</label>
             <div class="col-sm-8">
                 <input type="text" id="keyName" name="" class="form-control" placeholder="">
             </div>

suishenbang-admin/src/main/resources/templates/system/getCustomerData/getCustomerData.html

@@ -0,0 +1,56 @@
+<!DOCTYPE html>
+<html lang="zh" xmlns:th="http://www.thymeleaf.org" >
+<head>
+    <th:block th:include="include :: header('缓存清理')" />
+</head>
+<body class="gray-bg">
+<div class="wrapper wrapper-content">
+    <div class="col-sm-12">
+        <div class="row" style="margin-top: 10px;">
+            <label class="col-sm-1 control-label" style="text-align: right;padding: 0;height: 34px;line-height: 34px;font-size: 14px;font-weight: bold;">经销商代码：</label>
+            <div class="col-sm-2">
+                <input type="text" id="keyName" name="" class="form-control" placeholder="输入经销商代码">
+            </div>
+        </div>
+        <div class="row" style="margin-top: 10px;">
+            <label class="col-sm-1 control-label"></label>
+            <button id="applyBtn" class="btn btn-success" style="margin-left: 15px;">
+                提交
+            </button>
+        </div>
+    </div>
+</div>
+</body>
+<th:block th:include="include :: footer" />
+<script type="text/javascript">
+    var domain = window.location.host;
+    var ht = domain.indexOf('localhost') != -1 ? 'http://' : 'https://';
+    var prefixEdit = ht + domain + "/oneportal/system/user/getManagerList";
+    // var prefixEdit = 'https://suishenbangtest.nipponpaint.com.cn/oneportal/system/user/getManagerList';
+
+    $('#applyBtn').on('click', function (res) {
+        var keyNameValue = $('#keyName').val();
+        if (keyNameValue == ''){
+            $.modal.alertWarning('请输入经销商代码');
+            return;
+        }
+        var data = {
+            depCode:keyNameValue
+        }
+        console.log(1,data);
+        $.ajax({
+            url: prefixEdit,
+            type: "get",
+            contentType: 'application/json',
+            data: data,
+            success: function (result) {
+                if (result.code == 0) {
+                    $.modal.alertWarning(result.msg);
+                } else {
+                    $.modal.alertWarning(result.msg);
+                }
+            }
+        })
+    })
+</script>
+</html>

suishenbang-api/src/main/resources/application-uat.yml

@@ -8,7 +8,7 @@ ruoyi:
   copyrightYear: 2020
   # 文件路径 示例（ Windows配置D:/ruoyi/uploadPath，Linux配置 /home/ruoyi/uploadPath）
   profile: /home/admin/project/file
-  # profile: D:/ruoyi/uploadPath
+  #  profile: D:/ruoyi/uploadPath
   # 获取ip地址开关
   addressEnabled: false
   #是否开启swagger

suishenbang-common/pom.xml

@@ -8,62 +8,69 @@
         <version>4.0.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
-	
+
     <artifactId>suishenbang-common</artifactId>
-	
+
 	<description>
 	    common通用工具
 	</description>
 
     <dependencies>
-		
+
 		<!-- Spring框架基本的核心工具 -->
 		<dependency>
 			<groupId>org.springframework</groupId>
 			<artifactId>spring-context-support</artifactId>
 		</dependency>
-		
+
 		<!-- SpringWeb模块 -->
 		<dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-web</artifactId>
         </dependency>
-        
+
         <!--Shiro核心框架 -->
 		<dependency>
 			<groupId>org.apache.shiro</groupId>
 			<artifactId>shiro-core</artifactId>
 		</dependency>
-        
+
 		<!-- pagehelper 分页插件 -->
 		<dependency>
 			<groupId>com.github.pagehelper</groupId>
 			<artifactId>pagehelper-spring-boot-starter</artifactId>
 		</dependency>
-		
+
 		<!-- 自定义验证注解 -->
         <dependency>
 			<groupId>javax.validation</groupId>
 			<artifactId>validation-api</artifactId>
         </dependency>
-    
+
         <!--常用工具类 -->
 		<dependency>
 			<groupId>org.apache.commons</groupId>
 			<artifactId>commons-lang3</artifactId>
 		</dependency>
 
-		
+
 		<!-- JSON工具类 -->
 		<dependency>
 		    <groupId>com.fasterxml.jackson.core</groupId>
 		    <artifactId>jackson-databind</artifactId>
+			<version>2.17.1</version>
+		</dependency>
+		<dependency>
+			<groupId>com.fasterxml.jackson.core</groupId>
+			<artifactId>jackson-core</artifactId>
+			<version>2.17.1</version>
 		</dependency>
 
 		<!-- 阿里JSON解析器 -->
 		<dependency>
 			<groupId>com.alibaba</groupId>
 			<artifactId>fastjson</artifactId>
+			<version>2.0.51</version>
 		</dependency>
 
 		<!-- io常用工具类 -->
@@ -77,19 +84,19 @@
 			<groupId>commons-fileupload</groupId>
 			<artifactId>commons-fileupload</artifactId>
 		</dependency>
-		
+
 		<!-- excel工具 -->
 		<dependency>
 			<groupId>org.apache.poi</groupId>
 			<artifactId>poi-ooxml</artifactId>
 		</dependency>
-		
+
 		<!-- yml解析器 -->
 		<dependency>
 		    <groupId>org.yaml</groupId>
 		    <artifactId>snakeyaml</artifactId>
 		</dependency>
-		
+
 		<!-- servlet包 -->
         <dependency>
 		    <groupId>javax.servlet</groupId>
@@ -113,5 +120,5 @@
             <artifactId>lombok</artifactId>
         </dependency>
     </dependencies>
-  
-</project>
+
+</project>

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/mapper/CustomersMapper.java

@@ -69,6 +69,9 @@ public interface CustomersMapper
     @MapKey("chainsCode")
     public Map<String,Customers> selectCustomerMapByChainsCode();
 
+    @MapKey("chainsCode")
+    public Map<String,Customers> selectCustomerMapByChainsCodeByCode(String CustomerCode);
+
     /**
      * @description:根据经销商code查询名称
      * @param:

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/AnalysisDiyCustomerComponent.java

@@ -26,7 +26,6 @@ import com.dgtly.system.service.IAssRelcustomerinfoService;
 import com.dgtly.system.service.ISysConfigService;
 import com.dgtly.system.service.impl.SysUserServiceImpl;
 import com.dgtly.wxportal.mapper.WxQyUserMapper;
-import lombok.extern.slf4j.Slf4j;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -143,13 +142,13 @@ public class AnalysisDiyCustomerComponent {
                     MSQ.addAll(msqjson.getJSONArray("data"));
                 }
             }
-            success += buildSysUser(MSQ, loginNameSet, diyNameSet, 4, failDetails, packageId, chainsMap);
+            success += buildSysUser(false,MSQ, loginNameSet, diyNameSet, 4, failDetails, packageId, chainsMap);
             total += MSQ.size();
         } else {
             int code = msqjson.getInteger("code");
             if (code == 0) {
                 MSQ.addAll(msqjson.getJSONArray("data"));
-                success += buildSysUser(MSQ, loginNameSet, diyNameSet, 4, failDetails, packageId, chainsMap);
+                success += buildSysUser(false,MSQ, loginNameSet, diyNameSet, 4, failDetails, packageId, chainsMap);
                 total += MSQ.size();
             }
         }
@@ -187,14 +186,14 @@ public class AnalysisDiyCustomerComponent {
                     WQBM.addAll(wqbmjson.getJSONArray("data"));
                 }
             }
-            success += buildSysUser(WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
+            success += buildSysUser(false,WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
             total += WQBM.size();
 
         } else {
             int code = msqjson.getInteger("code");
             if (code == 0) {
                 WQBM.addAll(msqjson.getJSONArray("data"));
-                success += buildSysUser(WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
+                success += buildSysUser(false,WQBM, loginNameSet, diyNameSet, 5, failDetails, packageId, chainsMap);
                 total += WQBM.size();
             }
         }
@@ -456,7 +455,7 @@ public class AnalysisDiyCustomerComponent {
         if(code==0){
             JSONArray STOREGUIDE = new JSONArray();
             STOREGUIDE.addAll(gjson.getJSONArray("userlist"));
-            success+=buildSysUser(STOREGUIDE,loginNameSet,diyNameSet,0,failDetails,packageId,codeMap);
+            success+=buildSysUser(false,STOREGUIDE,loginNameSet,diyNameSet,0,failDetails,packageId,codeMap);
             total+=gjson.getJSONArray("userlist").size();
         }
 
@@ -477,7 +476,7 @@ public class AnalysisDiyCustomerComponent {
         if(code==0){
             JSONArray MANAGER = new JSONArray();
             MANAGER.addAll(mjson.getJSONArray("userlist"));
-            success+=buildSysUser(MANAGER,loginNameSet,diyNameSet,1,failDetails,packageId,chainsMap);
+            success+=buildSysUser(false,MANAGER,loginNameSet,diyNameSet,1,failDetails,packageId,chainsMap);
             total+=mjson.getJSONArray("userlist").size();
         }
 //财务3.2
@@ -513,13 +512,13 @@ public class AnalysisDiyCustomerComponent {
                     FINANCE.addAll(fjson.getJSONArray("userlist"));
                 }
             }
-            success+=buildSysUser(FINANCE,loginNameSet,diyNameSet,2,failDetails,packageId,chainsMap);
+            success+=buildSysUser(false,FINANCE,loginNameSet,diyNameSet,2,failDetails,packageId,chainsMap);
             total+=FINANCE.size();
         }else{
             code = fjson.getInteger("code");
             if(code==0){
                 FINANCE.addAll(fjson.getJSONArray("userlist"));
-                success+=buildSysUser(FINANCE,loginNameSet,diyNameSet,2,failDetails,packageId,chainsMap);
+                success+=buildSysUser(false,FINANCE,loginNameSet,diyNameSet,2,failDetails,packageId,chainsMap);
                 total+=FINANCE.size();
             }
         }
@@ -557,13 +556,13 @@ public class AnalysisDiyCustomerComponent {
                     WAREHOUSE.addAll(wjson.getJSONArray("userlist"));
                 }
             }
-            success+=buildSysUser(WAREHOUSE,loginNameSet,diyNameSet,3,failDetails,packageId,chainsMap);
+            success+=buildSysUser(false,WAREHOUSE,loginNameSet,diyNameSet,3,failDetails,packageId,chainsMap);
             total+=WAREHOUSE.size();
         }else{
             code = wjson.getInteger("code");
             if(code==0){
                 WAREHOUSE.addAll(wjson.getJSONArray("userlist"));
-                success+=buildSysUser(WAREHOUSE,loginNameSet,diyNameSet,3,failDetails,packageId,chainsMap);
+                success+=buildSysUser(false,WAREHOUSE,loginNameSet,diyNameSet,3,failDetails,packageId,chainsMap);
                 total+=WAREHOUSE.size();
             }
         }
@@ -584,7 +583,7 @@ public class AnalysisDiyCustomerComponent {
         if(code==0){
             JSONArray xlsMANAGER = new JSONArray();
             xlsMANAGER.addAll(xlsJson.getJSONArray("data"));
-            success+=buildSysUser(xlsMANAGER,loginNameSet,diyNameSet,7,failDetails,packageId,chainsMap);
+            success+=buildSysUser(false,xlsMANAGER,loginNameSet,diyNameSet,7,failDetails,packageId,chainsMap);
             total+=xlsMANAGER.size();
         }
 
@@ -603,7 +602,7 @@ public class AnalysisDiyCustomerComponent {
         if(code==0){
             JSONArray homeCustomer = new JSONArray();
             homeCustomer.addAll(homeJson.getJSONArray("userlist"));
-            success+=buildSysUser(homeCustomer,loginNameSet,diyNameSet,9,failDetails,packageId,chainsMap);
+            success+=buildSysUser(false,homeCustomer,loginNameSet,diyNameSet,9,failDetails,packageId,chainsMap);
             total+=homeCustomer.size();
         }
 
@@ -669,6 +668,55 @@ public class AnalysisDiyCustomerComponent {
         return null;
     }
 
+    /**
+     * 获取经销商负责人
+     * @param depCode
+     * @param userNo
+     * @return
+     */
+    public  String  getManagerList(String depCode , String userNo){
+    try {
+        log.info("接收到参数depCode:{},userNO:{}",depCode,userNo);
+            String url = customerAccessTokenUtil.getUrl(UrlType.MANAGERLIST, null);
+            Map<String,Customers> chainsMap = customersMapper.selectCustomerMapByChainsCodeByCode(depCode);
+            List<SyncFailDetail> failDetails = new ArrayList<>();
+            //获取经销商负责人
+            //拼接请求参数
+            if (StringUtils.isNotEmpty(depCode)){
+                url = url+"&depCode="+depCode;
+            }
+            if (StringUtils.isNotEmpty(userNo)){
+                url = url+"&userNo="+userNo;
+            }
+            log.info("获取经销商负责人请求地址{}",url);
+            JSONObject managerListJson = JSONObject.parseObject(HttpUtils.sendSSLGet(url));
+            log.info("获取经销商负责人请求结果为:{}",managerListJson);
+            int code = managerListJson.getInteger("code");
+            if (code == 0) {
+                JSONArray dataArray = managerListJson.getJSONArray("data");
+                if(dataArray.size() >0){
+                    StringBuffer users = new StringBuffer();
+                    for (int i = 0; i < dataArray.size(); i++){
+                        JSONObject object = dataArray.getJSONObject(i);
+                        String name = object.getString("name");
+                        users.append(name).append(",");
+                    }
+                    String packageId = "diycustomer"+new Date().getTime();
+                    buildSysUser(true ,dataArray, null, null, 1, failDetails, packageId, chainsMap);
+                    return users.substring(0,users.length()-1)+"同步成功";
+                }else {
+                    return "同步成功,数据为空";
+                }
+            }else {
+                return "获取数据失败";
+            }
+        } catch (Exception e) {
+            customerAccessTokenUtil.reSetToken();
+            log.error("获取经销商负责人接口错误！",e);
+            return "获取数据失败";
+        }
+    }
+
 
     /*
      * @description: 厨卫人员拉取
@@ -788,11 +836,13 @@ public class AnalysisDiyCustomerComponent {
      * @param isManager
      * @return
      */
-    public Integer buildSysUser(JSONArray jsonArray, Set<String> loginNameSet,Set<String> diyNameSet, int isManager, List<SyncFailDetail> failDetails,String packageId, Map<String,Customers> cusMap) {
+    public Integer buildSysUser(boolean oneUser,JSONArray jsonArray, Set<String> loginNameSet,Set<String> diyNameSet, int isManager, List<SyncFailDetail> failDetails,String packageId, Map<String,Customers> cusMap) {
         // JSONArray jsonArray = json.getJSONArray("userlist");
-        log.info("开始解析用户列表");
-        log.info("用户列表数量：{}", jsonArray.size());
         log.info("开始解析用户列表{}",jsonArray);
+        if (oneUser){
+            Long roleId = Long.parseLong(configService.selectConfigByKey("libang.customer.roleid"));
+            roleIds = new Long[]{roleId};
+        }
         int count = 0;
         List<String> interfaceList = new ArrayList<>();
         List<UserAssVO> assVOList =new ArrayList<>();
@@ -819,91 +869,95 @@ public class AnalysisDiyCustomerComponent {
         List<String> collect =new ArrayList<>();
         loginNames.removeAll(interfaceList);
         collect.addAll(loginNames);
-        if (collect.size() > 0) {
-            for (String login : collect
-            ) {
-                SysUser u = sysUserService.selectUserByLoginName(login);
-                if (("0").equals(u.getIsSync())) {
-                    String CustomerManager = u.getSysUserExt().getIsCustomerManager();
-                    String[] manager = CustomerManager.split(",");
-                    if (manager.length > 1) {
-                        if(assVOList !=null && assVOList.size()>0){
-                            boolean containsValue = assVOList.iterator().hasNext() && assVOList.iterator().next().getUserName().equals(u.getUserName());
-                            if(containsValue){
-                                for (UserAssVO vo:assVOList
-                                     ) {
-                                    if(vo.getUserName().equals(u.getUserName()) && vo.getPhone().equals(u.getPhonenumber()) ){
-                                        List<AssRelcustomerinfo> assRelcustomerinfoList = assRelcustomerinfoService.selectRelcustomerinfoByKunnr(vo.getCustomerCode(), String.valueOf(u.getUserId()));
-                                        if(assRelcustomerinfoList !=null && assRelcustomerinfoList.size()>0){
-                                            assRelcustomerinfoService.deleteAssRelcustomerinfoByUserId(u.getUserId().toString(), vo.getCustomerCode());
+        if (!oneUser){
+            if (collect.size() > 0) {
+                for (String login : collect
+                ) {
+                    SysUser u = sysUserService.selectUserByLoginName(login);
+                    if (("0").equals(u.getIsSync())) {
+                        String CustomerManager = u.getSysUserExt().getIsCustomerManager();
+                        if (StringUtils.isNotEmpty(CustomerManager)){
+                            String[] manager = CustomerManager.split(",");
+                            if (manager.length > 1) {
+                                if(assVOList !=null && assVOList.size()>0){
+                                    boolean containsValue = assVOList.iterator().hasNext() && assVOList.iterator().next().getUserName().equals(u.getUserName());
+                                    if(containsValue){
+                                        for (UserAssVO vo:assVOList
+                                        ) {
+                                            if(vo.getUserName().equals(u.getUserName()) && vo.getPhone().equals(u.getPhonenumber()) ){
+                                                List<AssRelcustomerinfo> assRelcustomerinfoList = assRelcustomerinfoService.selectRelcustomerinfoByKunnr(vo.getCustomerCode(), String.valueOf(u.getUserId()));
+                                                if(assRelcustomerinfoList !=null && assRelcustomerinfoList.size()>0){
+                                                    assRelcustomerinfoService.deleteAssRelcustomerinfoByUserId(u.getUserId().toString(), vo.getCustomerCode());
+                                                }
+                                            }
                                         }
                                     }
-                                }
-                            }
-
-                        }
-                        List<String> resultList = new ArrayList<>(manager.length);
-                        Collections.addAll(resultList,manager);
-                        Object i=isManager;
-                        resultList.remove(i.toString());
-                        String IsManager = resultList.stream().map(String::valueOf).collect(Collectors.joining(","));
-                        u.getSysUserExt().setIsCustomerManager(IsManager);
-                        sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
-                    } else {
-                        if(assVOList !=null && assVOList.size()>0){
-                            boolean containsValue = assVOList.iterator().hasNext() && assVOList.iterator().next().getUserName().equals(u.getUserName());
-                            if(containsValue){
-                                for (UserAssVO vo:assVOList
-                                ) {
-                                    if(vo.getUserName().equals(u.getUserName()) && vo.getPhone().equals(u.getPhonenumber())){
-                                        List<AssRelcustomerinfo> assRelcustomerinfoList = assRelcustomerinfoService.selectRelcustomerinfoByKunnr(vo.getCustomerCode(), String.valueOf(u.getUserId()));
-                                        if(assRelcustomerinfoList !=null && assRelcustomerinfoList.size()>0){
-                                            assRelcustomerinfoService.deleteAssRelcustomerinfoByUserId(u.getUserId().toString(), vo.getCustomerCode());
-                                        }else{
-                                                //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
-                                                if(("1").equals(u.getIsShopAccount())){
-                                                    SysUserExt userExt = u.getSysUserExt();
-                                                    if(userExt !=null){
-                                                        userExt.setDelFlag("2");
-                                                        userExt.setDelTime(new Date());
-                                                        sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
-                                                    }
 
+                                }
+                                List<String> resultList = new ArrayList<>(manager.length);
+                                Collections.addAll(resultList,manager);
+                                Object i=isManager;
+                                resultList.remove(i.toString());
+                                String IsManager = resultList.stream().map(String::valueOf).collect(Collectors.joining(","));
+                                u.getSysUserExt().setIsCustomerManager(IsManager);
+                                sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
+                            } else {
+                                if(assVOList !=null && assVOList.size()>0){
+                                    boolean containsValue = assVOList.iterator().hasNext() && assVOList.iterator().next().getUserName().equals(u.getUserName());
+                                    if(containsValue){
+                                        for (UserAssVO vo:assVOList
+                                        ) {
+                                            if(vo.getUserName().equals(u.getUserName()) && vo.getPhone().equals(u.getPhonenumber())){
+                                                List<AssRelcustomerinfo> assRelcustomerinfoList = assRelcustomerinfoService.selectRelcustomerinfoByKunnr(vo.getCustomerCode(), String.valueOf(u.getUserId()));
+                                                if(assRelcustomerinfoList !=null && assRelcustomerinfoList.size()>0){
+                                                    assRelcustomerinfoService.deleteAssRelcustomerinfoByUserId(u.getUserId().toString(), vo.getCustomerCode());
                                                 }else{
-                                                    u.setQuit("2");
-                                                    sysUserService.updateUserInfo(u);
+                                                    //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
+                                                    if(("1").equals(u.getIsShopAccount())){
+                                                        SysUserExt userExt = u.getSysUserExt();
+                                                        if(userExt !=null){
+                                                            userExt.setDelFlag("2");
+                                                            userExt.setDelTime(new Date());
+                                                            sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
+                                                        }
+
+                                                    }else{
+                                                        u.setQuit("2");
+                                                        sysUserService.updateUserInfo(u);
+                                                    }
                                                 }
+                                            }
                                         }
-                                    }
-                                }
-                            }else{
-                                //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
-                                if(("1").equals(u.getIsShopAccount())){
-                                    SysUserExt userExt = u.getSysUserExt();
-                                    if(userExt !=null){
-                                        userExt.setDelFlag("2");
-                                        userExt.setDelTime(new Date());
-                                        sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
-                                    }
+                                    }else{
+                                        //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
+                                        if(("1").equals(u.getIsShopAccount())){
+                                            SysUserExt userExt = u.getSysUserExt();
+                                            if(userExt !=null){
+                                                userExt.setDelFlag("2");
+                                                userExt.setDelTime(new Date());
+                                                sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
+                                            }
 
+                                        }else{
+                                            u.setQuit("2");
+                                            sysUserService.updateUserInfo(u);
+                                        }
+                                    }
                                 }else{
-                                    u.setQuit("2");
-                                    sysUserService.updateUserInfo(u);
-                                }
-                            }
-                        }else{
-                            //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
-                            if(("1").equals(u.getIsShopAccount())){
-                                SysUserExt userExt = u.getSysUserExt();
-                                if(userExt !=null){
-                                    userExt.setDelFlag("2");
-                                    userExt.setDelTime(new Date());
-                                    sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
-                                }
+                                    //检测用户是否还有门店账号标识，有则把用户扩展信息离职掉，没有则主账号离职+扩展信息离职
+                                    if(("1").equals(u.getIsShopAccount())){
+                                        SysUserExt userExt = u.getSysUserExt();
+                                        if(userExt !=null){
+                                            userExt.setDelFlag("2");
+                                            userExt.setDelTime(new Date());
+                                            sysUserExtMapper.updateSysUserExt(u.getSysUserExt());
+                                        }
 
-                            }else{
-                                u.setQuit("2");
-                                sysUserService.updateUserInfo(u);
+                                    }else{
+                                        u.setQuit("2");
+                                        sysUserService.updateUserInfo(u);
+                                    }
+                                }
                             }
                         }
                     }
@@ -1019,7 +1073,7 @@ public class AnalysisDiyCustomerComponent {
                     SysUser userOld = sysUserService.selectUserByLoginName(userid);
                     SysUser user = sysUserService.selectUserByLoginName(userid);
                     //将用户扩展表的信息给加上
-                      if(StringUtils.isBlank(user.getSysUserExt().getSalesLevel())){
+                    if(StringUtils.isBlank(user.getSysUserExt().getSalesLevel())){
                         log.info("进行用户扩展表信息补偿：--------userId:"+user.getSysUserExt().getUserId().toString());
                         SysUserExt userExt = new SysUserExt();
                         userExt.setUserId(user.getUserId());
@@ -1048,7 +1102,6 @@ public class AnalysisDiyCustomerComponent {
                         user.setSysUserExt(userExt);
                         userOld.setSysUserExt(userExt);
                     }
-
                     if (("0").equals(user.getIsSync())) {
                         //查询该用户是否存在该接口返回中
                         user.setPhonenumber(jo.getString("mobile"));

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/HanaOrderComponent.java

@@ -168,7 +168,7 @@ public class HanaOrderComponent {
                 "                A.KVGR4, "+
                 "                A.POSID, "+
                 "               A.PD_NO, "+
-                "               A.BSTKD,"+
+                "              REPLACE(A.BSTKD, '$', '') as BSTKD, "+
                 "               A.NETPR, "+
                 "               A.NTGEW_MARA,"+
                 "               A.PSTYV,"+
@@ -356,8 +356,7 @@ public class HanaOrderComponent {
         }
     }*/
 
-    //C类
-    private int  createTmabcTxt(ResultSet result) throws Exception {
+    private int createDeliverSignatureTxt(ResultSet result) throws Exception {
         File file = null;
         FileWriter fw = null;
         Connection conn = null;
@@ -367,19 +366,18 @@ public class HanaOrderComponent {
             long i =0;
 
             //创建IO需求的条件，并声明输出路径
-            file = new File((Global.getTemdataPath()+"erpOrderByC/"));
-            log.info("erpOrderByC数据缓存路径：" + Global.getTemdataPath()+"erpOrderByC/");
+            file = new File((Global.getTemdataPath()+"deliverSignature/"));
+            log.info("deliverSignature数据缓存路径：" + Global.getTemdataPath()+"deliverSignature/");
             if(!file.exists()){
                 file.mkdir();
             }
 
-            file = new File(Global.getTemdataPath()+"erpOrderByC/"+j+".txt");
+            file = new File(Global.getTemdataPath()+"deliverSignature/"+j+".txt");
             if(!file.exists()){
                 file.createNewFile();
             }else {
                 //取得这个目录下的所有子文件对象
-                File[] files = new File(Global.getTemdataPath()+"erpOrderByC/").listFiles();
-                //遍历该目录下的文件对象
+                File[] files = new File(Global.getTemdataPath()+"deliverSignature/").listFiles();
 
                 for (File f: files){
                     f.delete();
@@ -392,18 +390,31 @@ public class HanaOrderComponent {
             while (result.next()){
 
                 fw.write(
-                        result.getString("MAABC")
-                                +"$$"+ result.getString("SPRAS")
-                                +"$$"+ result.getString("TMABC")
+                        result.getString("VBELN")
+                         +"$$"+ result.getString("POSNR")
+                                +"$$"+ result.getString("MATNR")
+                                +"$$"+ result.getString("VGBEL")
+                                +"$$"+ result.getString("VGPOS")
+                                +"$$"+ result.getString("ERDAT_SO")
+                                +"$$"+ result.getString("LFIMG")
+                                +"$$"+ result.getString("MODIFIEDVALUE")
+                                +"$$"+ result.getString("LFIMG_CY")
+                                +"$$"+ result.getString("ZDATE_KH")
+                                +"$$"+ result.getString("ZTIME_KH")
+                                +"$$"+ result.getString("ZVBELN_YCHH")
+                                +"$$"+ result.getString("ZSTATUS_HH")
+                                +"$$"+ result.getString("CONTRACTID")
+                                +"$$"+ result.getString("BIZNO")
                                 +"$$"+ result.getString("MANDT")
                                 + "\r\n");
 
+
                 fw.flush();
                 i++;
                 if (i%50000==0){
                     j++;
                     //创建IO需求的条件，并声明输出路径
-                    file = new File(Global.getTemdataPath()+"erpOrderByC/"+j+".txt");
+                    file = new File(Global.getTemdataPath()+"deliverSignature/"+j+".txt");
                     if(!file.exists()){
                         file.createNewFile();
                     }else {
@@ -415,8 +426,7 @@ public class HanaOrderComponent {
                 }
             }
             Long endTime = System.currentTimeMillis();
-            log.info("生成erpOrderByC-TXT用时：" + (endTime - startTime) + "毫秒");
-
+            log.info("生成deliverSignature-TXT用时：" + (endTime - startTime) + "毫秒");
 
         }catch (Exception e){
             e.printStackTrace();
@@ -442,9 +452,9 @@ public class HanaOrderComponent {
         return j;
     }
 
-//电子单签收
 
-    private int createDeliverSignatureTxt(ResultSet result) throws Exception {
+    //C类
+    private int  createTmabcTxt(ResultSet result) throws Exception {
         File file = null;
         FileWriter fw = null;
         Connection conn = null;
@@ -454,18 +464,19 @@ public class HanaOrderComponent {
             long i =0;
 
             //创建IO需求的条件，并声明输出路径
-            file = new File((Global.getTemdataPath()+"deliverSignature/"));
-            log.info("deliverSignature数据缓存路径：" + Global.getTemdataPath()+"deliverSignature/");
+            file = new File((Global.getTemdataPath()+"erpOrderByC/"));
+            log.info("erpOrderByC数据缓存路径：" + Global.getTemdataPath()+"erpOrderByC/");
             if(!file.exists()){
                 file.mkdir();
             }
 
-            file = new File(Global.getTemdataPath()+"deliverSignature/"+j+".txt");
+            file = new File(Global.getTemdataPath()+"erpOrderByC/"+j+".txt");
             if(!file.exists()){
                 file.createNewFile();
             }else {
                 //取得这个目录下的所有子文件对象
-                File[] files = new File(Global.getTemdataPath()+"deliverSignature/").listFiles();
+                File[] files = new File(Global.getTemdataPath()+"erpOrderByC/").listFiles();
+                //遍历该目录下的文件对象
 
                 for (File f: files){
                     f.delete();
@@ -478,31 +489,18 @@ public class HanaOrderComponent {
             while (result.next()){
 
                 fw.write(
-                        result.getString("VBELN")
-                         +"$$"+ result.getString("POSNR")
-                                +"$$"+ result.getString("MATNR")
-                                +"$$"+ result.getString("VGBEL")
-                                +"$$"+ result.getString("VGPOS")
-                                +"$$"+ result.getString("ERDAT_SO")
-                                +"$$"+ result.getString("LFIMG")
-                                +"$$"+ result.getString("MODIFIEDVALUE")
-                                +"$$"+ result.getString("LFIMG_CY")
-                                +"$$"+ result.getString("ZDATE_KH")
-                                +"$$"+ result.getString("ZTIME_KH")
-                                +"$$"+ result.getString("ZVBELN_YCHH")
-                                +"$$"+ result.getString("ZSTATUS_HH")
-                                +"$$"+ result.getString("CONTRACTID")
-                                +"$$"+ result.getString("BIZNO")
+                        result.getString("MAABC")
+                                +"$$"+ result.getString("SPRAS")
+                                +"$$"+ result.getString("TMABC")
                                 +"$$"+ result.getString("MANDT")
                                 + "\r\n");
 
-
                 fw.flush();
                 i++;
                 if (i%50000==0){
                     j++;
                     //创建IO需求的条件，并声明输出路径
-                    file = new File(Global.getTemdataPath()+"deliverSignature/"+j+".txt");
+                    file = new File(Global.getTemdataPath()+"erpOrderByC/"+j+".txt");
                     if(!file.exists()){
                         file.createNewFile();
                     }else {
@@ -514,7 +512,8 @@ public class HanaOrderComponent {
                 }
             }
             Long endTime = System.currentTimeMillis();
-            log.info("生成deliverSignature-TXT用时：" + (endTime - startTime) + "毫秒");
+            log.info("生成erpOrderByC-TXT用时：" + (endTime - startTime) + "毫秒");
+
 
         }catch (Exception e){
             e.printStackTrace();

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/service/ShopUserTypeComponent.java

@@ -115,7 +115,7 @@ public class ShopUserTypeComponent {
                 calendar.set(Calendar.MILLISECOND, 0);
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm");
                 String runTime = sdf.format(calendar.getTime());
-                if (runTime.contains("2025-11-29")){
+                if (runTime.contains("2025-11-24")){
                     runTime = "2025-08-28T00:00";
                 }
                 stoneParams.put("datetime_start", runTime);
@@ -204,7 +204,7 @@ public class ShopUserTypeComponent {
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm");
                 Date date = sdf.parse(truncatedDate);
                 String runTime = sdf.format(date);
-                if (runTime.contains("2025-11-29")){
+                if (runTime.contains("2025-11-24")){
                     runTime = "2025-08-28T00:00";
                 }
                 //获取上次同步时间进行增量同步

suishenbang-sync/suishenbang-sync-common/src/main/java/com/dgtly/sync/utils/CustomerAccessTokenUtil.java

@@ -26,6 +26,7 @@ public class CustomerAccessTokenUtil {
         MANAGERLIST,
         BUSINESSLIST,*/
         WAREHOUSE,
+        MANAGERLIST,
         AllRole,
         STAFF,
         BZ,
@@ -73,9 +74,9 @@ public class CustomerAccessTokenUtil {
     //获取经销商仓管人员列表(分页)
     private String warehouseListUrl ;
     //厨卫 获取老板列表
-   /* private String bossListUrl ;
+   /* private String bossListUrl ;*/
     //厨卫 获取经理列表
-    private String managerUrl ;*/
+    private String managerUrl ;
     //获取经销商分销业务员人员列表(分页)
     private String resellerUrl ;
     //获取厨卫业务员人员
@@ -109,10 +110,10 @@ public class CustomerAccessTokenUtil {
         WqbmListUrl =domain+"/api/diydt/v1/user/outwall/list?page=%s&access_token=%s";
         //获取经销商仓管人员列表(分页)存在name，code
         warehouseListUrl =domain+"/wechatwork/diydt/v2/user/warehouse/list?page=%s&access_token=%s";
-        /**
-        bossListUrl =domain+"/wechatwork/chuwei/v1/user/boss/list?access_token=%s";
-        managerUrl =domain+"/wechatwork/chuwei/v1/user/manager/list?access_token=%s";
-        */
+
+       // bossListUrl =domain+"/wechatwork/chuwei/v1/user/boss/list?access_token=%s";
+        managerUrl =domain+"/api/diydt/v3/user/manager/list?access_token=%s";
+
         //获取经销商分销业务员人员列表(分页)存在name，code
         resellerUrl =domain+"/api/diydt/v2/user/reseller/list?page=%s&access_token=%s";
       /*  businessUrl =domain+"/wechatwork/chuwei/v1/user/business/list?access_token=%s";*/
@@ -195,12 +196,12 @@ public class CustomerAccessTokenUtil {
             case WAREHOUSE:
                 url = String.format(warehouseListUrl,pageNum,token);
                 break;
-      /*      case BOSSLIST:
-                url = String.format(bossListUrl,token);
-                break;
             case MANAGERLIST:
                 url = String.format(managerUrl,token);
                 break;
+      /*      case BOSSLIST:
+                url = String.format(bossListUrl,token);
+                break;
             case BUSINESSLIST:
                 url = String.format(businessUrl, token);
                 break;*/

suishenbang-sync/suishenbang-sync-common/src/main/resources/mapper/sync/CustomersMapper.xml

@@ -137,6 +137,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         SELECT CustomerCode as chains_code,CustomerName as chains_name FROM data_master_customer where CustomerCode is not null
     </select>
 
+    <select id="selectCustomerMapByChainsCodeByCode" resultMap="CustomersResult">
+        SELECT CustomerCode as chains_code,CustomerName as chains_name FROM data_master_customer where CustomerCode = #{CustomerCode}
+    </select>
+
     <select id="selectCustomerNameByCustomerCode" resultType="java.lang.String">
         select CustomerName from data_master_customer where 1=1
         <if test="customerCode !=null and customerCode !='' ">and CustomerCode =#{customerCode}</if>

suishenbang-wxportal/suishenbang-wxportal-api/src/main/java/com/dgtly/wxportal/controller/EsignController.java

@@ -21,6 +21,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.tomcat.util.digester.ArrayStack;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
@@ -69,6 +70,8 @@ public class EsignController extends ApiBaseController {
     private ICustomersCodeService customersService;
     @Autowired
     private ISysUserCustomerAuthorizationService authorizationService;
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
     /**
      * @description: 经销商订单签收方法
      * 没有注册就注册，注册完就认证，然后再点击签署按钮，获取经销商用户id，对应主体id
@@ -743,6 +746,12 @@ public class EsignController extends ApiBaseController {
 //       /*根据org_code查询多个经销商列表*/
         List<SysUserExt> sysUserExtList = new ArrayStack<>();
         List<AssRelcustomerinfo>  assRelcustomerinfoList= assRelcustomerinfoService.selectRelcustomerinfoListByorgCode(sysUser.getSysUserExt().getOrgCode(),sysUser.getUserId().toString());
+        List<String> res = new ArrayList<>();
+        List<Map<String,Object>> custInfo = jdbcTemplate.queryForList("select  customerCode from cust_exclusion_info  where  userId=?",userId);
+        res=custInfo.stream()
+                .map(row -> (String) row.get("customerCode"))
+                .collect(Collectors.toList());
+
         if (assRelcustomerinfoList.size()>0){
             for (AssRelcustomerinfo ar:assRelcustomerinfoList) {
                 SysUserExt sysUserExt = new SysUserExt();
@@ -757,7 +766,10 @@ public class EsignController extends ApiBaseController {
                 sysUserExt.setIsCustomerManager(sysUser.getSysUserExt().getIsCustomerManager());
                 sysUserExt.setPostCode(sysUser.getSysUserExt().getPostCode());
                 sysUserExt.setPostName(sysUser.getSysUserExt().getPostName());
-                sysUserExtList.add(sysUserExt);
+                if(!res.contains(ar.getMainkunnr())){
+                    sysUserExtList.add(sysUserExt);
+                }
+
             }
 
             for (AssRelcustomerinfo ar:assRelcustomerinfoList) {
@@ -773,7 +785,10 @@ public class EsignController extends ApiBaseController {
                 sysUserExt.setIsCustomerManager(sysUser.getSysUserExt().getIsCustomerManager());
                 sysUserExt.setPostCode(sysUser.getSysUserExt().getPostCode());
                 sysUserExt.setPostName(sysUser.getSysUserExt().getPostName());
-                sysUserExtList.add(sysUserExt);
+                if(!res.contains(ar.getKunnr())){
+                    sysUserExtList.add(sysUserExt);
+                }
+
             }
             /*SysUserExt sysUserExt = new SysUserExt();
             sysUserExt.setUserId(sysUser.getSysUserExt().getUserId());

suishenbang-wxportal/suishenbang-wxportal-api/src/main/java/com/dgtly/wxportal/controller/WxPortalController.java

@@ -68,13 +68,14 @@ public class WxPortalController extends ApiBaseController {
     private ISysUserCustomerAuthorizationService authorizationService;
     @Autowired
     private ISysUserExtService sysUserExtService;
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+
 
     @Autowired
     private ISysUserShopExtService sysUserShopExtService;
 
 
-    @Autowired
-    JdbcTemplate jdbcTemplate;
     @ApiOperation(value = "微信门户首页",notes = "参数：{userId:1}")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "params" , paramType = "body")
@@ -237,6 +238,14 @@ public class WxPortalController extends ApiBaseController {
         /*根据org_code查询多个经销商列表*/
         List<SysUserExt> sysUserExtList = new ArrayList<>();
         List<AssRelcustomerinfo>  assRelcustomerinfoList= assRelcustomerinfoService.selectRelcustomerinfoListByorgCode(customerCode,sysUser.getUserId().toString());
+
+        //查询需要过滤的客户信息
+        List<String> res = new ArrayList<>();
+        List<Map<String,Object>> custInfo = jdbcTemplate.queryForList("select  customerCode from cust_exclusion_info  where  userId=?",userId);
+        res=custInfo.stream()
+                .map(row -> (String) row.get("customerCode"))
+                .collect(Collectors.toList());
+
         if (assRelcustomerinfoList.size()>0){
             for (AssRelcustomerinfo ar:assRelcustomerinfoList) {
                 SysUserExt sysUserExt = new SysUserExt();
@@ -251,7 +260,11 @@ public class WxPortalController extends ApiBaseController {
                 sysUserExt.setIsCustomerManager(sysUser.getSysUserExt().getIsCustomerManager());
                 sysUserExt.setPostCode(sysUser.getSysUserExt().getPostCode());
                 sysUserExt.setPostName(sysUser.getSysUserExt().getPostName());
-                sysUserExtList.add(sysUserExt);
+                if(!res.contains(ar.getMainkunnr())){
+                    sysUserExtList.add(sysUserExt);
+                }
+
+
             }
 
             for (AssRelcustomerinfo ar:assRelcustomerinfoList) {
@@ -267,7 +280,9 @@ public class WxPortalController extends ApiBaseController {
                 sysUserExt.setIsCustomerManager(sysUser.getSysUserExt().getIsCustomerManager());
                 sysUserExt.setPostCode(sysUser.getSysUserExt().getPostCode());
                 sysUserExt.setPostName(sysUser.getSysUserExt().getPostName());
-                sysUserExtList.add(sysUserExt);
+                if(!res.contains(ar.getKunnr())){
+                    sysUserExtList.add(sysUserExt);
+                }
             }
 
             /*
@@ -449,6 +464,8 @@ public class WxPortalController extends ApiBaseController {
     }
 
 
+
+    @ApiOperation(value = "首页突变配置")
     @PostMapping("/getHomeIconInfo")
     public AjaxResult getHoemIconCongif() throws IOException {
         Map<String,Object> iconInfo= wxMagnetService.selectHomeIconInfoById();

suishenbang-wxportal/suishenbang-wxportal-common/pom.xml

@@ -47,7 +47,6 @@
             <artifactId>itext-asian</artifactId>
             <version>5.2.0</version>
         </dependency>
-
         <dependency>
             <groupId>redis.clients</groupId>
             <artifactId>jedis</artifactId>

suishenbang-wxportal/suishenbang-wxportal-common/src/main/java/com/dgtly/wxportal/utils/JedisPoolUtil.java

@@ -1,19 +1,18 @@
 package com.dgtly.wxportal.utils;
 
+import org.springframework.stereotype.Service;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 
 
-
+@Service
 public class JedisPoolUtil {
     private static volatile JedisPool jedisPool = null;
     private static final String HOST="127.0.0.1" ;
     private static final int PORT = 6379;
     private static final String PASSWORD = "Ssbprod#1207";
     private static final int TIMEOUT = 2000;
-
-
     private JedisPoolUtil() {}
     public static JedisPool getPool() {
         if (jedisPool == null) {

suishenbang-wxportal/suishenbang-wxportal-manager/src/main/java/com/dgtly/wxportal/controller/WxMagnetController.java

@@ -206,12 +206,6 @@ public class WxMagnetController extends BaseController
        return  AjaxResult.success("保存成功!");
     }
 
-    @PostMapping("/getHomeIconInfo")
-    @ResponseBody
-    public AjaxResult getHoemIconCongif() throws IOException {
-        Map<String,Object> iconInfo= wxMagnetService.selectHomeIconInfoById();
-        return  AjaxResult.success(iconInfo);
-    }
 
 
     @Log(title = "redis缓存清除", businessType = BusinessType.UPDATE)
@@ -219,6 +213,8 @@ public class WxMagnetController extends BaseController
     @ResponseBody
     public AjaxResult cleanRedisByDb(@RequestBody RedisDbParam redisDbParam)
     {
+
+
         if(redisDbParam.getRedisDb().length==0){
             return AjaxResult.error(201,"redis库未指定！");
         }
@@ -235,11 +231,21 @@ public class WxMagnetController extends BaseController
                 }
             }
         }
-        return AjaxResult.success("操作成功!");
+        return AjaxResult.success("200","操作成功!");
+    }
+
+
+    @PostMapping("/getHomeIconInfo")
+    @ResponseBody
+    public AjaxResult getHoemIconCongif() throws IOException {
+        Map<String,Object> iconInfo= wxMagnetService.selectHomeIconInfoById();
+        return  AjaxResult.success(iconInfo);
     }
 
 
 
+
+
     /**
      * 加载角色磁贴列表树
      */