fix: 客户区分宜搭/手动新增

gongchunyi

3 天以前 33eccd5e76d865b3f3c4a421cd993498c25b6137

 src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java

@@ -173,17 +173,17 @@
                    c.setAddressPhone(address + "(" + phone + ")");

                    // 查询最新的跟进记录
                    CustomerFollowUp followUp = customerFollowUpService.getOne(
                            new LambdaQueryWrapper<CustomerFollowUp>()
                                    .eq(CustomerFollowUp::getCustomerId, c.getId())
                                    .orderByDesc(CustomerFollowUp::getFollowUpTime)
                                    .last("LIMIT 1")
                    );

                    if (followUp != null) {
                        c.setFollowUpLevel(followUp.getFollowUpLevel());
                        c.setFollowUpTime(followUp.getFollowUpTime());
                    }
//                    CustomerFollowUp followUp = customerFollowUpService.getOne(
//                            new LambdaQueryWrapper<CustomerFollowUp>()
//                                    .eq(CustomerFollowUp::getCustomerId, c.getId())
//                                    .orderByDesc(CustomerFollowUp::getFollowUpTime)
//                                    .last("LIMIT 1")
//                    );
//
//                    if (followUp != null) {
//                        c.setFollowUpLevel(followUp.getFollowUpLevel());
//                        c.setFollowUpTime(followUp.getFollowUpTime());
//                    }
                })
                .collect(Collectors.toList());

@@ -205,6 +205,7 @@
        LoginUser loginUser = SecurityUtils.getLoginUser();
        Long tenantId = loginUser.getTenantId();
        customer.setTenantId(tenantId);
        customer.setType(2);
        return customerMapper.insert(customer);
    }

@@ -276,7 +277,7 @@

    @Override
    public void syncCustomerJob() {
        syncCustomerData(2);
        syncCustomerData();
    }

    @Override
@@ -322,11 +323,7 @@
     * 同步数据
     */
    @Transactional(rollbackFor = Exception.class)
    public void syncCustomerData(Integer dataSyncType) {
        if (!syncLock.tryLock()) {
            log.warn("同步正在进行中，本次 {} 同步请求被跳过", dataSyncType == 1 ? "手动" : "定时任务");
            return;
        }
    public void syncCustomerData() {
        try {
            JSONArray searchConditions = new JSONArray();
            JSONObject statusCondition = new JSONObject();
@@ -351,9 +348,12 @@

            String searchFieldJson = searchConditions.toJSONString();

            JSONArray dataArr = AliDingUtils.getFormDataList(aliDingConfig, aliDingConfig.getCustomerCodeFormUuid(), searchFieldJson, this, Customer::getFormModifiedTime);
            LambdaQueryWrapper<Customer> countWrapper = new LambdaQueryWrapper<>();
            countWrapper.eq(Customer::getType, 1);

            if (dataArr.isEmpty()) {
            JSONArray dataArr = AliDingUtils.getFormDataList(aliDingConfig, aliDingConfig.getCustomerCodeFormUuid(), searchFieldJson, this, Customer::getFormModifiedTime, countWrapper);

            if (dataArr == null || dataArr.isEmpty()) {
                log.info("没有更多新数据需要同步");
                return;
            }
@@ -368,9 +368,6 @@

        } catch (Exception e) {
            log.error("同步客户信息异常", e);
        } finally {
            // 释放锁
            syncLock.unlock();
        }
    }

@@ -394,6 +391,7 @@
            customer.setMaintenanceTime(date);
            customer.setFormInstanceId(formInstanceId);
            customer.setFormModifiedTime(dateTime);
            customer.setType(1);
            list.add(customer);
        }
        return list;