rakor
/
mobilebroken
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 从CRM同步设备信息逻辑调整 

同步接口添加了设备状态字段，所以表中设备编号允许重复了，表还添加了来源id字段，用于更新数据
This commit is contained in:
曹鹏飞 2025-03-24 17:25:16 +08:00
parent a0f4b92bd1
commit 3f89429512
3 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/pojo/vo/CmrDeviceResultVO.java
View File

@ -23,6 +23,7 @@ public class CmrDeviceResultVO {
//客户 //客户
private String Account; private String Account;
private Integer CfsStatus__c;
private String Id;
} }

15
nflg-mobilebroken-admin/src/main/java/com/nflg/mobilebroken/admin/service/AdminDeviceService.java
View File

@ -122,26 +122,24 @@ public class AdminDeviceService {
if (CollUtil.isEmpty(crmDeviceList)) { if (CollUtil.isEmpty(crmDeviceList)) {
return; return;
} }
Set<String> crmDeviceNos = crmDeviceList.stream().map(u -> u.getMachine_Number__c()).collect(Collectors.toSet()); Set<String> crmDeviceIds = crmDeviceList.stream().map(CmrDeviceResultVO::getId).collect(Collectors.toSet());
List<Device> deviceList = deviceService.lambdaQuery().in(Device::getDeviceNo, crmDeviceNos).list(); List<Device> deviceList = deviceService.lambdaQuery().eq(Device::getSourceFrom, DeviceSourceFromEnum.FROM_CRM.getSourceKey()).in(Device::getSourceId, crmDeviceIds).list();
Map<String, Device> deviceMap = deviceList.stream().collect(Collectors.toMap(Device::getDeviceNo, device -> device)); Map<String, Device> deviceMap = deviceList.stream().collect(Collectors.toMap(Device::getSourceId, device -> device));
crmDeviceList.forEach(u -> { crmDeviceList.forEach(u -> {
if (StrUtil.isNotBlank(u.getMachine_Number__c())) { if (StrUtil.isNotBlank(u.getMachine_Number__c())) {
Device ent = deviceMap.get(u.getMachine_Number__c()); Device ent = deviceMap.get(u.getId());
if (Objects.nonNull(ent)) { if (Objects.nonNull(ent)) {
ent = deviceMap.get(u.getMachine_Number__c());
ent.setUpdateBy("crm"); ent.setUpdateBy("crm");
ent.setUpdateTime(LocalDateTime.now()); ent.setUpdateTime(LocalDateTime.now());
} else { } else {
ent = new Device(); ent = new Device();
ent.setUpdateBy("crm"); ent.setSourceId(u.getId());
ent.setUpdateTime(LocalDateTime.now());
ent.setCreateBy("crm"); ent.setCreateBy("crm");
ent.setCreateTime(LocalDateTime.now()); ent.setCreateTime(LocalDateTime.now());
} }
ent.setDeviceState(u.getCfsStatus__c());
ent.setDeviceNo(u.getMachine_Number__c()); ent.setDeviceNo(u.getMachine_Number__c());
ent.setDeviceType(u.getAssetProductLine3__c()); ent.setDeviceType(u.getAssetProductLine3__c());
ent.setDeviceTypeSub(u.getAssetProductLine4__c()); ent.setDeviceTypeSub(u.getAssetProductLine4__c());
@ -154,7 +152,6 @@ public class AdminDeviceService {
ent.setSourceFrom(DeviceSourceFromEnum.FROM_CRM.getSourceKey()); ent.setSourceFrom(DeviceSourceFromEnum.FROM_CRM.getSourceKey());
ent.setCustomerId(0); ent.setCustomerId(0);
ent.setDeviceState(0);
result.add(ent); result.add(ent);
} }
}); });

12
nflg-mobilebroken-repository/src/main/java/com/nflg/mobilebroken/repository/entity/Device.java
View File

@ -2,13 +2,14 @@ package com.nflg.mobilebroken.repository.entity;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
import java.io.Serializable;
import java.time.LocalDate;
import java.time.LocalDateTime;
/** /**
* <p> * <p>
* 设备 * 设备
@ -117,6 +118,11 @@ public class Device implements Serializable {
*/ */
private Integer sourceFrom; private Integer sourceFrom;
/**
* 数据来源id
*/
private String sourceId;
/** /**
* 创建人 * 创建人
*/ */