1、客户联系表 更改为物理删除

hx-customer/src/main/java/com/fjhx/customer/mapper/customer/CustomerUserMapper.java

@@ -29,4 +29,5 @@ public interface CustomerUserMapper extends BaseMapper<CustomerUser> {
      */
     Page<CustomerUserVo> getPage(@Param("page") Page<Object> page, @Param("ew") IWrapper<CustomerUser> wrapper);
 
+    void deleteByCustomerId(Long id);
 }

hx-customer/src/main/java/com/fjhx/customer/service/customer/CustomerUserService.java

@@ -49,4 +49,5 @@ public interface CustomerUserService extends BaseService<CustomerUser> {
      */
     void delete(Long id);
 
+    void deleteByCustomerId(Long id);
 }

hx-customer/src/main/java/com/fjhx/customer/service/customer/impl/CustomerUserServiceImpl.java

@@ -87,4 +87,9 @@ public class CustomerUserServiceImpl extends ServiceImpl<CustomerUserMapper, Cus
         this.removeById(id);
     }
 
+    @Override
+    public void deleteByCustomerId(Long id) {
+        baseMapper.deleteByCustomerId(id);
+    }
+
 }

hx-customer/src/main/java/com/fjhx/customer/service/xiaoman/impl/XiaomanCustomerServiceImpl.java

@@ -125,14 +125,11 @@ public class XiaomanCustomerServiceImpl extends ServiceImpl<XiaomanCustomerMappe
     public void handleSaveOrUpdate(List<CustomerApiVo> customerApiVoList, Set<Long> allCustomer,boolean flag) {
         List<XiaomanCustomer> xiaomanCustomerList = new ArrayList<>(customerApiVoList);
         for (XiaomanCustomer customer : xiaomanCustomerList) {
-            if(customer.getCompanyId() == 16769466149910L){
                 if (allCustomer.contains(customer.getCompanyId())) {
                     processCustomer(customer, true,flag);
                 } else {
                     processCustomer(customer, false,flag);
                 }
-            }
-
         }
     }
 
@@ -179,8 +176,7 @@ public class XiaomanCustomerServiceImpl extends ServiceImpl<XiaomanCustomerMappe
         //联系人
         if (!vo.getCustomers().isEmpty()){
             //删除原有联系人
-            customerUserService.lambdaUpdate()
-                    .eq(CustomerUser::getCustomerId,customer.getId()).remove();
+            customerUserService.deleteByCustomerId(customer.getId());
             for (CustomerInfoVo.Customer cus  : vo.getCustomers()){
                 if (StringUtils.isNotEmpty(cus.getEmail())){
                     CustomerUser customerUser = new CustomerUser();
@@ -241,8 +237,7 @@ public class XiaomanCustomerServiceImpl extends ServiceImpl<XiaomanCustomerMappe
                 //联系人
                 if (!vo.getCustomers().isEmpty()){
                     //删除原有联系人
-                    customerUserService.lambdaUpdate()
-                            .eq(CustomerUser::getCustomerId,customer.getId()).remove();
+                    customerUserService.deleteByCustomerId(customer.getId());
                     for (CustomerInfoVo.Customer cus  :vo.getCustomers()) {
                             CustomerUser customerUser = new CustomerUser();
                             customerUser.setId(cus.getCustomerId());
@@ -377,6 +372,6 @@ public class XiaomanCustomerServiceImpl extends ServiceImpl<XiaomanCustomerMappe
     }
     @Override
     public void updateList() {
-        xiaomanApiService.updateList(24);
+        xiaomanApiService.updateList(2);
     }
 }

hx-customer/src/main/resources/mapper/customer/CustomerUserMapper.xml

@@ -1,6 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.fjhx.customer.mapper.customer.CustomerUserMapper">
+
     <select id="getList" resultType="com.fjhx.customer.entity.customer.vo.CustomerUserVo">
         select
             cu.id,
@@ -31,4 +32,9 @@
             ${ew.customSqlSegment}
     </select>
 
+    <delete id="deleteByCustomerId">
+        delete from customer_user
+        where customer_id = #{customerId}
+
+    </delete>
 </mapper>