From 1be9f9fdb13f7c5cdcf29494cb72ced35cd7af10 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期二, 16 七月 2024 22:18:04 +0800
Subject: [PATCH] 提交
---
server/service/src/main/java/com/doumee/service/business/impl/CustomerUserServiceImpl.java | 45 ++++++++++++++++++++++++++++++++++-----------
1 files changed, 34 insertions(+), 11 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..00d2f47 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
@@ -182,6 +182,21 @@
request.setPageSize(100);
request.setTiming(Constants.ONE+"");
request.setCreationDate(date);
+ this.syncData(request);
+ }
+
+ @Override
+ @Transactional
+ public void syncByPhone(String phone) {
+ CrmDaogouBindListRequest request = new CrmDaogouBindListRequest();
+ request.setPage(0);
+ request.setPageSize(100);
+ request.setTiming(Constants.ZERO+"");
+ request.setKeyWords(phone);
+ this.syncData(request);
+ }
+
+ public void syncData(CrmDaogouBindListRequest request){
boolean hasMore = true;
int currentNum = 0;
Date cdate = new Date();
@@ -201,13 +216,14 @@
}
dealSyncDataBiz(cdate,response.getData());
}catch (Exception e){
- hasMore = false;
+ hasMore = false;
}
}
}
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 +238,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 +249,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