联合利华（上海）
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
jiangping
2025-07-03 cd1eb4f48fbbba55154e9aec80ec93f48e9c075b 
 server/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java


@@ -26,14 +26,19 @@


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.github.yulichang.wrapper.MPJLambdaWrapper;


import io.swagger.annotations.ApiOperation;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.lang3.StringUtils;


import org.apache.shiro.SecurityUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.CollectionUtils;


import org.springframework.web.bind.annotation.PostMapping;


import org.springframework.web.bind.annotation.RequestHeader;




import javax.annotation.Resource;


import java.io.Serializable;


import java.util.ArrayList;


import java.util.Date;


import java.util.List;


@@ -45,8 +50,11 @@


 * @since 2025/04/02 17:49


 */


@Service


@Slf4j


public class MemberServiceImpl implements MemberService {




    @Resource(name="sessionRedisTemplate")


    private RedisTemplate<Object, Serializable> redisTemplate;


    @Autowired


    private SystemDictDataBiz systemDictDataBiz;


    @Autowired


@@ -244,6 +252,7 @@


    }




    @Override


    @Transactional


    public  void syncQwAll(){


        if(Constants.DEALING_MEMBER_SYNC){


            throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对不起，同步任务正在进行，请稍后刷新页面重试！");


@@ -261,15 +270,20 @@


            LoginUserInfo user = (LoginUserInfo) SecurityUtils.getSubject().getPrincipal();


            Date date = new Date();


            List<QywxUserListResponse>  list = new ArrayList<>();


            int index =0;


            for(Company c : companyList){


                List<QywxUserListResponse> tList =   QywxUtil.getUserList(systemDictDataBiz.queryByCode(Constants.QYWX,Constants.QYWX_TOKEN).getCode(),c.getQwId());


                if(tList!=null){


                    log.error((index++)+"==============="+c.getName()+"============人员数量："+tList.size());


                    list.addAll(tList);


                }else{


                    log.error((index++)+"==============="+c.getName()+"============人员数量：0");


                }


            }


            if(list == null || list.size() ==0){


                throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"未同步到任何组织信息！");


            }


            log.error( "###################=================人员总数量："+list.size());


            List<Member>  memberList = memberMapper.selectList(new LambdaQueryWrapper<Member>().eq(Member::getIsdeleted,Constants.ZERO));


            List<Member>  newList = new ArrayList<>();


            List<Member>  updateList = new ArrayList<>();


@@ -304,7 +318,7 @@


                        if(StringUtils.isNotBlank(comNames)){


                            comNames += ",";


                        }


                        comNames += c.getNamePath();


                        comNames += StringUtils.defaultString(c.getNamePath(),c.getName());


                    }


                }


                cm.setCompanyList(qycom);