From a68a91af2eadd014405c25a549ece1fb7bbcba2e Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期二, 16 七月 2024 10:04:44 +0800 Subject: [PATCH] 提交 --- server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java | 28 ++++++++++++++++++---------- 1 files changed, 18 insertions(+), 10 deletions(-) diff --git a/server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java b/server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java index e4288db..bd783e7 100644 --- a/server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java +++ b/server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java @@ -208,6 +208,7 @@ private void dealSyncDataBiz(Date date,List<CRMDaogouBindListResponse> list) { List<CustomerUser> addList = new ArrayList<>(); + List<String> phoneList = new ArrayList<>(); for(CRMDaogouBindListResponse data : list){ if(StringUtils.isBlank(data.getCustomerPhone())){ continue; @@ -222,15 +223,8 @@ if(member == null){ continue; } - /** - * 鍒犻櫎鑰佸緱鏁版嵁 - */ - customerUserMapper.update(null,new UpdateWrapper<CustomerUser>().lambda() - .eq(CustomerUser::getPhone,data.getDgPhone() ) - .eq(CustomerUser::getUsername,data.getUseName() ) - .eq(CustomerUser::getIsdeleted,Constants.ZERO) - .set(CustomerUser::getIsdeleted,Constants.ONE) - ); + phoneList.add(data.getCustomerPhone()); + CustomerUser model = new CustomerUser(); model.setCreateDate(date); model.setIsdeleted(Constants.ZERO); @@ -240,12 +234,26 @@ model.setOrgName(data.getOrgName()); model.setCustomerName(data.getCustomerName()); model.setCustomerPhone(data.getCustomerPhone()); - model.setUsername(data.getUseName()); + model.setUsername(data.getUserName()); + model.setSource(Constants.ONE); + model.setZtStatus(Constants.ONE); + model.setZtInfo("crm鍚屾"); model.setIamUserId(data.getUserId()); model.setUserId(user== null?null:user.getId()); model.setCreationDate(data.getCreationDate()); addList.add(model); } + if(phoneList.size()>0){ + /** + * 鍒犻櫎鑰佸緱鏁版嵁 + */ + customerUserMapper.update(null,new UpdateWrapper<CustomerUser>().lambda() + .in(CustomerUser::getPhone,phoneList) + .eq(CustomerUser::getZtStatus,Constants.ONE) + .eq(CustomerUser::getIsdeleted,Constants.ZERO) + .set(CustomerUser::getIsdeleted,Constants.ONE) + ); + } if(addList .size() >0){ int temp = 0; while(temp < addList.size()){ -- Gitblit v1.9.3