|
@@ -3,6 +3,7 @@ package com.zfire.jiasm.syncdata.download.basedata;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.zfire.jiasm.syncdata.constant.DictTypeEnum;
|
|
|
import com.zfire.jiasm.syncdata.constant.InterFaceTypeEnum;
|
|
|
import com.zfire.jiasm.syncdata.data.Token;
|
|
@@ -27,7 +28,7 @@ import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
- * 格力品牌固障代码基础资料下载 同步一次不再使用
|
|
|
+ * 格力品牌固障代码基础资料下载 同步一次不再同步,PC端使用
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@Component
|
|
@@ -56,9 +57,9 @@ public class GLPPGuZhandDaiMa {
|
|
|
@Scheduled(fixedDelayString = "${guzdm}")
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
public void processGZDMTask() throws Exception {
|
|
|
- /*if (1==1){
|
|
|
+ if (1==1){
|
|
|
return;
|
|
|
- }*/
|
|
|
+ }
|
|
|
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
|
Map<String, String> paramMap = new HashMap<String, String>();
|
|
@@ -95,6 +96,17 @@ public class GLPPGuZhandDaiMa {
|
|
|
// 数据同步到本地故障现象表
|
|
|
extractedGZDMLocalAddOrUpdate(brandRec, addRec, updateRec);
|
|
|
|
|
|
+ // 新增的插入到表
|
|
|
+ if (addRec.size()>0){
|
|
|
+ // 先清除再新增
|
|
|
+ QueryWrapper del = new QueryWrapper<ItfTblAssignGzdmDowload>()
|
|
|
+ .gt("gzid", 0);
|
|
|
+ itfTblAssignGzdmDowloadService.remove(del);
|
|
|
+
|
|
|
+ itfTblAssignGzdmDowloadService.saveBatch(addRec);
|
|
|
+ log.info("格力品牌固障代码信息同步新增插入了{}条数据", addRec.size());
|
|
|
+ addRec.clear();
|
|
|
+ }
|
|
|
|
|
|
log.info("格力品牌固障代码处理完成: \uF0B7{}",sdf.format(new Date()));
|
|
|
}else {
|
|
@@ -105,52 +117,39 @@ public class GLPPGuZhandDaiMa {
|
|
|
|
|
|
private void extractedGZDMLocalAddOrUpdate(Brand brandRec, List<ItfTblAssignGzdmDowload> addRec, List<ItfTblAssignGzdmDowload> updateRec) {
|
|
|
List<RepairBug> addRepairBug = new ArrayList<>();
|
|
|
- List<RepairBug> updateRepairBug = new ArrayList<>();
|
|
|
// 提取小类字典数据
|
|
|
List<SysDict> oldSysDictRec = sysDictService.lambdaQuery()
|
|
|
.eq(SysDict::getDictType, DictTypeEnum.DICT_TYPE_SMALL_TYPE.getCode())
|
|
|
.eq(SysDict::getStatus, DictTypeEnum.DICT_TYPE_ON.getCode())
|
|
|
.list();
|
|
|
// 小类名称
|
|
|
- List<String> oldSysDictReclist = oldSysDictRec.stream().map(SysDict::getDictValue).collect(Collectors.toList());
|
|
|
+ List<String> xlname = oldSysDictRec.stream().map(SysDict::getDictValue).collect(Collectors.toList());
|
|
|
// 小类编号
|
|
|
- Map<String, List<SysDict>> oldSysDictRecMap = oldSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictValue));
|
|
|
+ Map<String, List<SysDict>> xlMap = oldSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictValue));
|
|
|
|
|
|
// 提取大类字典数据
|
|
|
List<SysDict> oldDSysDictRec = sysDictService.lambdaQuery()
|
|
|
.eq(SysDict::getDictType, DictTypeEnum.DICT_TYPE_MAIN_TYPE.getCode())
|
|
|
.eq(SysDict::getStatus, DictTypeEnum.DICT_TYPE_ON.getCode()).list();
|
|
|
// 大类名称
|
|
|
- List<String> oldSysDictReclistDL = oldDSysDictRec.stream().map(SysDict::getDictValue).collect(Collectors.toList());
|
|
|
+ List<String> dlname = oldDSysDictRec.stream().map(SysDict::getDictValue).collect(Collectors.toList());
|
|
|
// 大类编号
|
|
|
- Map<String, List<SysDict>> oldDSysDictRecMapN = oldDSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictValue));
|
|
|
- // 大类编号
|
|
|
- Map<String, List<SysDict>> oldDSysDictRecMap = oldDSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictCode));
|
|
|
-
|
|
|
- // 提取原有数据
|
|
|
- List<RepairBug> oldRepairBugRec = repairBugService.lambdaQuery()
|
|
|
- .eq(RepairBug::getBrandId, brandRec.getBrandId()).list();
|
|
|
- Map<String, List<RepairBug>> oldRepairBugRecMap = oldRepairBugRec.stream().collect(Collectors.groupingBy(RepairBug::getGzid));
|
|
|
+ Map<String, List<SysDict>> dlMap = oldDSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictCode));
|
|
|
+ Map<String, List<SysDict>> dlNameMap = oldDSysDictRec.stream().collect(Collectors.groupingBy(SysDict::getDictValue));
|
|
|
|
|
|
// 获取新增的
|
|
|
if (addRec.size()>0){
|
|
|
+ // 先清除再新增
|
|
|
+ QueryWrapper del = new QueryWrapper<RepairBug>()
|
|
|
+ .eq("brand_id", brandRec.getBrandId());
|
|
|
+ repairBugService.remove(del);
|
|
|
+
|
|
|
for (ItfTblAssignGzdmDowload item : addRec){
|
|
|
// 类别不存在不新增 这里的类别为类别名称,可能是大类也可能是小类
|
|
|
// 大类的处理
|
|
|
// addDL(brandRec, addRepairBug, oldSysDictReclistDL, oldDSysDictRecMapN, oldDSysDictRecMap, item);
|
|
|
// 小类的处理
|
|
|
- addXL(brandRec, addRepairBug, oldSysDictReclist, oldSysDictRecMap, oldDSysDictRecMap, item);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- // 获取修改的
|
|
|
- if (updateRec.size()>0){
|
|
|
- for (ItfTblAssignGzdmDowload item : updateRec){
|
|
|
- // 大类修改
|
|
|
- // upDL(updateRepairBug, oldSysDictRecMap, oldSysDictReclistDL, oldDSysDictRecMapN, oldDSysDictRecMap, oldRepairBugRecMap, item);
|
|
|
- // 小类修改
|
|
|
- upXL(updateRepairBug, oldSysDictReclist, oldSysDictRecMap, oldDSysDictRecMap, oldRepairBugRecMap, item);
|
|
|
+ addXL(brandRec, addRepairBug, xlname, xlMap, dlMap, item, dlname, dlNameMap);
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -158,15 +157,13 @@ public class GLPPGuZhandDaiMa {
|
|
|
if (addRepairBug.size()>0){
|
|
|
repairBugService.saveBatch(addRepairBug);
|
|
|
log.info("格力品牌固障代码本地信息表新增插入了{}条数据",addRepairBug.size());
|
|
|
- }
|
|
|
- // 更新
|
|
|
- if (updateRepairBug.size()>0){
|
|
|
- repairBugService.updateBatchById(updateRepairBug);
|
|
|
- log.info("格力品牌固障代码本地信息表更新修改了{}条数据", updateRepairBug.size());
|
|
|
+ addRepairBug.clear();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void upXL(List<RepairBug> updateRepairBug, List<String> oldSysDictReclist, Map<String, List<SysDict>> oldSysDictRecMap, Map<String, List<SysDict>> oldDSysDictRecMap, Map<String, List<RepairBug>> oldRepairBugRecMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ private void upXL(List<RepairBug> updateRepairBug, List<String> oldSysDictReclist,
|
|
|
+ Map<String, List<SysDict>> oldSysDictRecMap, Map<String, List<SysDict>> oldDSysDictRecMap,
|
|
|
+ Map<String, List<RepairBug>> oldRepairBugRecMap, ItfTblAssignGzdmDowload item) {
|
|
|
Boolean flag;
|
|
|
flag = Boolean.FALSE;
|
|
|
// 类别存在的修改
|
|
@@ -353,17 +350,190 @@ public class GLPPGuZhandDaiMa {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void addXL(Brand brandRec, List<RepairBug> addRepairBug, List<String> oldSysDictReclist, Map<String, List<SysDict>> oldSysDictRecMap, Map<String, List<SysDict>> oldDSysDictRecMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ private void addXL(Brand brandRec, List<RepairBug> addRepairBug, List<String> xlname, Map<String, List<SysDict>> xlMap,
|
|
|
+ Map<String, List<SysDict>> dlMap, ItfTblAssignGzdmDowload item, List<String> dlname,Map<String, List<SysDict>> dlNameMap) {
|
|
|
+ Boolean flag = Boolean.FALSE;
|
|
|
// leib为小类的名称
|
|
|
- if (oldSysDictReclist.contains(item.getLeib())){
|
|
|
- addRepairBugCheck(brandRec, addRepairBug, oldSysDictRecMap, oldDSysDictRecMap, item);
|
|
|
+ if (xlname.contains(item.getLeib())){
|
|
|
+ addRepairBugCheck(brandRec, addRepairBug, xlMap, dlMap, item);
|
|
|
+ } else {
|
|
|
+ // 部分小类特殊处理
|
|
|
+ if (!StringUtils.isEmpty(item.getLeib())){
|
|
|
+ // 小类的处理
|
|
|
+ flag = addRepairBugCheckt(brandRec, addRepairBug, xlMap, dlMap, item);
|
|
|
+ if (flag){
|
|
|
+ // 小类做为大类处理
|
|
|
+ flag = addRepairBugCheckd(brandRec, addRepairBug, item,dlNameMap);
|
|
|
+ if (flag){
|
|
|
+ // 无法对应到类别信息直接添加
|
|
|
+ addRepairBug(brandRec, addRepairBug, item);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ // 无小类信息直接添加
|
|
|
+ addRepairBug(brandRec, addRepairBug, item);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addXLbak(Brand brandRec, List<RepairBug> addRepairBug, List<String> xlname, Map<String, List<SysDict>> xlMap,
|
|
|
+ Map<String, List<SysDict>> dlMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ // leib为小类的名称
|
|
|
+ if (xlname.contains(item.getLeib())){
|
|
|
+ addRepairBugCheck(brandRec, addRepairBug, xlMap, dlMap, item);
|
|
|
} else {
|
|
|
// 无小类信息直接添加
|
|
|
addRepairBug(brandRec, addRepairBug, item);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void addRepairBugCheck(Brand brandRec, List<RepairBug> addRepairBug, Map<String, List<SysDict>> oldSysDictRecMap, Map<String, List<SysDict>> oldDSysDictRecMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ private void addRepairBugCheck(Brand brandRec, List<RepairBug> addRepairBug, Map<String, List<SysDict>> xlMap,
|
|
|
+ Map<String, List<SysDict>> dlMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ RepairBug v = new RepairBug();
|
|
|
+ v.setBugId(UUID.randomUUID().toString());
|
|
|
+ v.setGzid(String.valueOf(item.getGzid()));
|
|
|
+ v.setBrandId(brandRec.getBrandId());
|
|
|
+ v.setBrandName(brandRec.getBrand());
|
|
|
+ // 类别不为空时 key名称
|
|
|
+ if (xlMap.get(item.getLeib()).get(0)!=null){
|
|
|
+ // 小类编号
|
|
|
+ v.setSmallId(xlMap.get(item.getLeib()).get(0).getDictCode());
|
|
|
+ // 小类名称
|
|
|
+ v.setSmallName(xlMap.get(item.getLeib()).get(0).getDictValue());
|
|
|
+ // 小类有对应的父类时 提取父类信息
|
|
|
+ if (!StringUtils.isEmpty(xlMap.get(item.getLeib()).get(0).getParentDictCode())){
|
|
|
+ v.setMainId(xlMap.get(item.getLeib()).get(0).getParentDictCode());
|
|
|
+ v.setMainName(dlMap.get(v.getMainId()).get(0).getDictValue());
|
|
|
+ v.setMainFlag(dlMap.get(v.getMainId()).get(0).getFlag());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ v.setBugObj(item.getGzmc());
|
|
|
+ v.setBugObjCode(item.getGzno());
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_OFF.getCode());
|
|
|
+ if (item.getFlag().equals(DictTypeEnum.DICT_TYPE_FLAG_ON.getCode())){
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_ON.getCode());
|
|
|
+ }
|
|
|
+ v.setCreateBy("system");
|
|
|
+ v.setCreateTime(new Date());
|
|
|
+ if (item.getCjren() !=null){
|
|
|
+ v.setCreateBy(item.getCjren());
|
|
|
+ }
|
|
|
+ if (item.getCjdt() != null){
|
|
|
+ v.setCreateTime(item.getCjdt());
|
|
|
+ }
|
|
|
+ addRepairBug.add(v);
|
|
|
+ }
|
|
|
+
|
|
|
+ private Boolean addRepairBugCheckt(@NotNull Brand brandRec, List<RepairBug> addRepairBug, Map<String, List<SysDict>> xlMap,
|
|
|
+ Map<String, List<SysDict>> dlMap, ItfTblAssignGzdmDowload item) {
|
|
|
+ RepairBug v = new RepairBug();
|
|
|
+ v.setBugId(UUID.randomUUID().toString());
|
|
|
+ v.setGzid(String.valueOf(item.getGzid()));
|
|
|
+ v.setBrandId(brandRec.getBrandId());
|
|
|
+ v.setBrandName(brandRec.getBrand());
|
|
|
+ // 类别不为空时 key名称
|
|
|
+ String leibname = "";
|
|
|
+ if (item.getLeib().equals("煤气灶")){
|
|
|
+ leibname="燃气灶";
|
|
|
+ } else if (item.getLeib().equals("家用热水器") || item.getLeib().equals("商用热水器")){
|
|
|
+ leibname="家用空气能热水器";
|
|
|
+ } else if (item.getLeib().equals("电风扇/冷风扇/塔扇")){
|
|
|
+ leibname="电风扇/冷风扇/大厦扇";
|
|
|
+ } else if (item.getLeib().equals("电风扇/冷风扇/塔扇")){
|
|
|
+ leibname="电风扇/冷风扇/大厦扇";
|
|
|
+ } else if (item.getLeib().equals("抽油烟机")){
|
|
|
+ leibname="吸油烟机";
|
|
|
+ }
|
|
|
+ if (StringUtils.isEmpty(leibname)) {
|
|
|
+ return Boolean.TRUE;
|
|
|
+ }
|
|
|
+ if (!xlMap.containsKey(leibname)){
|
|
|
+ return Boolean.TRUE;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 小类编号
|
|
|
+ v.setSmallId(xlMap.get(leibname).get(0).getDictCode());
|
|
|
+ // 小类名称
|
|
|
+ v.setSmallName(xlMap.get(leibname).get(0).getDictValue());
|
|
|
+ // 小类有对应的父类时 提取父类信息
|
|
|
+ if (!StringUtils.isEmpty(xlMap.get(leibname).get(0).getParentDictCode())){
|
|
|
+ v.setMainId(xlMap.get(leibname).get(0).getParentDictCode());
|
|
|
+ v.setMainName(dlMap.get(v.getMainId()).get(0).getDictValue());
|
|
|
+ v.setMainFlag(dlMap.get(v.getMainId()).get(0).getFlag());
|
|
|
+ }
|
|
|
+
|
|
|
+ v.setBugObj(item.getGzmc());
|
|
|
+ v.setBugObjCode(item.getGzno());
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_OFF.getCode());
|
|
|
+ if (item.getFlag().equals(DictTypeEnum.DICT_TYPE_FLAG_ON.getCode())){
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_ON.getCode());
|
|
|
+ }
|
|
|
+ v.setCreateBy("system");
|
|
|
+ v.setCreateTime(new Date());
|
|
|
+ if (item.getCjren() !=null){
|
|
|
+ v.setCreateBy(item.getCjren());
|
|
|
+ }
|
|
|
+ if (item.getCjdt() != null){
|
|
|
+ v.setCreateTime(item.getCjdt());
|
|
|
+ }
|
|
|
+ addRepairBug.add(v);
|
|
|
+ return Boolean.FALSE;
|
|
|
+ }
|
|
|
+
|
|
|
+ private Boolean addRepairBugCheckd(Brand brandRec, List<RepairBug> addRepairBug, ItfTblAssignGzdmDowload item,
|
|
|
+ Map<String, List<SysDict>> dlNameMap) {
|
|
|
+ RepairBug v = new RepairBug();
|
|
|
+ v.setBugId(UUID.randomUUID().toString());
|
|
|
+ v.setGzid(String.valueOf(item.getGzid()));
|
|
|
+ v.setBrandId(brandRec.getBrandId());
|
|
|
+ v.setBrandName(brandRec.getBrand());
|
|
|
+ // 类别不为空时 key名称
|
|
|
+ String leibname = "";
|
|
|
+ if (item.getLeib().equals("空调")){
|
|
|
+ leibname="家用空调";
|
|
|
+ } else if (item.getLeib().equals("家用热水器") || item.getLeib().equals("商用热水器")){
|
|
|
+ leibname="家用空气能热水器";
|
|
|
+ } else if (item.getLeib().equals("晶弘冰箱")){
|
|
|
+ leibname="晶弘冰箱";
|
|
|
+ } else if (item.getLeib().equals("洗衣机")){
|
|
|
+ leibname="洗衣机";
|
|
|
+ } else if (item.getLeib().equals("商用空调")){
|
|
|
+ leibname="商用空调";
|
|
|
+ } else if (item.getLeib().equals("手机")){
|
|
|
+ leibname="手机";
|
|
|
+ } else if (item.getLeib().equals("移动电源")){
|
|
|
+ leibname="移动电源";
|
|
|
+ } else if (item.getLeib().equals("智能门锁")){
|
|
|
+ leibname="智能门锁";
|
|
|
+ }
|
|
|
+ if (StringUtils.isEmpty(leibname)) {
|
|
|
+ return Boolean.TRUE;
|
|
|
+ }
|
|
|
+ if (!dlNameMap.containsKey(leibname)){
|
|
|
+ return Boolean.TRUE;
|
|
|
+ }
|
|
|
+ v.setMainId(dlNameMap.get(leibname).get(0).getDictCode());
|
|
|
+ v.setMainName(dlNameMap.get(leibname).get(0).getDictValue());
|
|
|
+ v.setMainFlag(dlNameMap.get(leibname).get(0).getFlag());
|
|
|
+ v.setBugObj(item.getGzmc());
|
|
|
+ v.setBugObjCode(item.getGzno());
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_OFF.getCode());
|
|
|
+ if (item.getFlag().equals(DictTypeEnum.DICT_TYPE_FLAG_ON.getCode())){
|
|
|
+ v.setStatus(DictTypeEnum.DICT_TYPE_ON.getCode());
|
|
|
+ }
|
|
|
+ v.setCreateBy("system");
|
|
|
+ v.setCreateTime(new Date());
|
|
|
+ if (item.getCjren() !=null){
|
|
|
+ v.setCreateBy(item.getCjren());
|
|
|
+ }
|
|
|
+ if (item.getCjdt() != null){
|
|
|
+ v.setCreateTime(item.getCjdt());
|
|
|
+ }
|
|
|
+ addRepairBug.add(v);
|
|
|
+ return Boolean.FALSE;
|
|
|
+ }
|
|
|
+
|
|
|
+ private void addRepairBugCheckBak(Brand brandRec, List<RepairBug> addRepairBug, Map<String, List<SysDict>> oldSysDictRecMap, Map<String, List<SysDict>> oldDSysDictRecMap, ItfTblAssignGzdmDowload item) {
|
|
|
RepairBug v = new RepairBug();
|
|
|
v.setBugId(UUID.randomUUID().toString());
|
|
|
v.setGzid(String.valueOf(item.getGzid()));
|
|
@@ -423,15 +593,11 @@ public class GLPPGuZhandDaiMa {
|
|
|
addRepairBug.add(v);
|
|
|
}
|
|
|
|
|
|
+
|
|
|
private void extractedGZDMAddOrUpdate(JSONArray jsonArray, List<ItfTblAssignGzdmDowload> addRec, List<ItfTblAssignGzdmDowload> updateRec) {
|
|
|
- Boolean flag = Boolean.FALSE;
|
|
|
String synTaskNo = UUID.randomUUID().toString();
|
|
|
- // 提取现有的数据信息
|
|
|
- List<ItfTblAssignGzdmDowload> oldRec = itfTblAssignGzdmDowloadService.lambdaQuery().list();
|
|
|
- List<Long> oldRecId = oldRec.stream().map(ItfTblAssignGzdmDowload::getGzid).collect(Collectors.toList());
|
|
|
- Map<Long, List<ItfTblAssignGzdmDowload>> oldRecMap = oldRec.stream().collect(Collectors.groupingBy(ItfTblAssignGzdmDowload::getGzid));
|
|
|
+
|
|
|
for (int i = 0; i < jsonArray.size(); i++) {
|
|
|
- flag = Boolean.FALSE;
|
|
|
JSONObject aData = jsonArray.getJSONObject(i);
|
|
|
ItfTblAssignGzdmDowload item = JSON.toJavaObject(aData,ItfTblAssignGzdmDowload.class);
|
|
|
if (StringUtils.isEmpty(item.getGzno())){
|
|
@@ -454,70 +620,15 @@ public class GLPPGuZhandDaiMa {
|
|
|
item.setPxdj(0);
|
|
|
}
|
|
|
|
|
|
-
|
|
|
- // 修改
|
|
|
- if (oldRecId.contains(item.getGzid())){
|
|
|
- ItfTblAssignGzdmDowload old = oldRecMap.get(item.getGzid()).get(0);
|
|
|
- if (!old.getGzno().equals(item.getGzno())){
|
|
|
- old.setGzno(item.getGzno());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
-
|
|
|
- if (!old.getGzmc().equals(item.getGzmc())){
|
|
|
- old.setGzmc(item.getGzmc());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
- if (!old.getPxdj().equals(item.getPxdj())){
|
|
|
- old.setPxdj(item.getPxdj());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
- if (!old.getFlag().equals(item.getFlag())){
|
|
|
- old.setFlag(item.getFlag());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
- if (!old.getLeib().equals(item.getLeib())){
|
|
|
- old.setLeib(item.getLeib());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
- if (!old.getCjwdno().equals(item.getCjwdno())){
|
|
|
- old.setCjwdno(item.getCjwdno());
|
|
|
- flag = Boolean.TRUE;
|
|
|
- }
|
|
|
- if (flag){
|
|
|
- old.setLastModifiedBy("system");
|
|
|
- old.setLastModifiedDate(new Date());
|
|
|
- // 操作人
|
|
|
- if (item.getLastModifiedBy() != null){
|
|
|
- old.setLastModifiedBy(item.getLastModifiedBy());
|
|
|
- }
|
|
|
- // 修改时间
|
|
|
- if (item.getLastModifiedDate() != null){
|
|
|
- old.setLastModifiedDate(item.getLastModifiedDate());
|
|
|
- }
|
|
|
- updateRec.add(old);
|
|
|
- }
|
|
|
- } else {
|
|
|
- // 新增
|
|
|
- item.setSynTaskNo(synTaskNo);
|
|
|
- if (item.getCreatedBy() ==null){
|
|
|
- item.setCreatedBy("system");
|
|
|
- }
|
|
|
- if (item.getCreatedDate() == null){
|
|
|
- item.setCreatedDate(new Date());
|
|
|
- }
|
|
|
- addRec.add(item);
|
|
|
+ // 新增
|
|
|
+ item.setSynTaskNo(synTaskNo);
|
|
|
+ if (item.getCreatedBy() ==null){
|
|
|
+ item.setCreatedBy("system");
|
|
|
}
|
|
|
- }
|
|
|
- // 新增的插入到表
|
|
|
- if (addRec.size()>0){
|
|
|
- itfTblAssignGzdmDowloadService.saveBatch(addRec);
|
|
|
- log.info("格力品牌固障代码信息同步新增插入了{}条数据", addRec.size());
|
|
|
- }
|
|
|
-
|
|
|
- // 更新
|
|
|
- if (updateRec.size()>0){
|
|
|
- itfTblAssignGzdmDowloadService.updateBatchById(updateRec);
|
|
|
- log.info("格力品牌固障代码信息同步更新修改了{}条数据", updateRec.size());
|
|
|
+ if (item.getCreatedDate() == null){
|
|
|
+ item.setCreatedDate(new Date());
|
|
|
+ }
|
|
|
+ addRec.add(item);
|
|
|
}
|
|
|
}
|
|
|
}
|