SyncAppImpl0.java 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498
  1. package com.persagy.bdtp.adm.service.impl;
  2. import cn.hutool.core.collection.CollUtil;
  3. import cn.hutool.core.date.DatePattern;
  4. import cn.hutool.core.date.DateUtil;
  5. import cn.hutool.core.util.IdUtil;
  6. import cn.hutool.core.util.StrUtil;
  7. import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  8. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  9. import com.fasterxml.jackson.core.type.TypeReference;
  10. import com.fasterxml.jackson.databind.JsonNode;
  11. import com.fasterxml.jackson.databind.ObjectMapper;
  12. import com.fasterxml.jackson.databind.node.ArrayNode;
  13. import com.fasterxml.jackson.databind.node.ObjectNode;
  14. import com.persagy.bdtp.adm.client.DicClient;
  15. import com.persagy.bdtp.adm.client.RwdClient;
  16. import com.persagy.bdtp.adm.common.AdmConst;
  17. import com.persagy.bdtp.adm.common.AdmResult;
  18. import com.persagy.bdtp.adm.dao.*;
  19. import com.persagy.bdtp.adm.entity.*;
  20. import com.persagy.bdtp.adm.entity.db.*;
  21. import com.persagy.bdtp.adm.entity.oldadm.OProject;
  22. import com.persagy.bdtp.adm.service.*;
  23. import com.persagy.dmp.basic.model.QueryCriteria;
  24. import com.persagy.dmp.common.constant.ResponseCode;
  25. import com.persagy.dmp.common.constant.ValidEnum;
  26. import com.persagy.dmp.common.exception.BusinessException;
  27. import com.persagy.dmp.common.model.response.CommonResult;
  28. import com.persagy.dmp.define.entity.RelationDefine;
  29. import org.springframework.beans.factory.annotation.Autowired;
  30. import org.springframework.core.io.Resource;
  31. import org.springframework.core.io.ResourceLoader;
  32. import org.springframework.stereotype.Service;
  33. import org.springframework.transaction.annotation.Transactional;
  34. import java.io.IOException;
  35. import java.util.*;
  36. import java.util.function.Supplier;
  37. @Service
  38. public class SyncAppImpl0 implements ISyncApp {
  39. @Autowired
  40. private IAdmObjectService objectService;
  41. @Autowired
  42. private IQueryFromOldAdm queryOldAdm;
  43. @Autowired
  44. private RwdClient rwdClient;
  45. @Autowired
  46. private DicClient dicClient;
  47. @Autowired
  48. private IConfigService configService;
  49. @Autowired
  50. private AdmObjectMapper admObjMapper;
  51. @Autowired
  52. private AdmRelationMapper relationMapper;
  53. @Autowired
  54. private AdmPipeMapper pipeMapper;
  55. @Autowired
  56. private AdmJobSpaceMapper jobSpaceMapper;
  57. @Autowired
  58. private AdmProblemArchMapper problemArchMapper;
  59. @Autowired
  60. private AdmProblemEquipMapper problemEquipMapper;
  61. @Autowired
  62. private AdmFileMapper fileMapper;
  63. @Autowired
  64. private AdmQrCodeMapper qrCodeMapper;
  65. @Autowired
  66. private AdmServeAreaMapper serveAreaMapper;
  67. @Autowired
  68. private ISyncModel syncModel;
  69. @Autowired
  70. private ObjectMapper objectMapper;
  71. @Autowired
  72. private IAdmLogService logService;
  73. @Autowired
  74. ResourceLoader resourceLoader;
  75. @Override
  76. public String getClientId(String userId) {
  77. return IdUtil.fastSimpleUUID();
  78. }
  79. @Override
  80. public Dict downloadDict(String groupCode, String projectId, String userId) {
  81. //临时方案,腾讯云生产环境没有数据字典4.0,从本地文件加载
  82. try{
  83. Resource resource = resourceLoader.getResource("classpath:dict.json");
  84. return objectMapper.readValue(resource.getInputStream(), Dict.class);
  85. } catch (Exception e) {
  86. e.printStackTrace();
  87. }
  88. return queryDict(groupCode, projectId, userId, true, true);
  89. }
  90. @Override
  91. public Map<String, Object> downloadConfig(String groupCode, String projectId, String userId) {
  92. //配置数据查询
  93. List<AdmM2dEquip> m2dTypes = configService.queryM2dEquip(projectId);
  94. List<AdmInfosConfig> infosConfig = configService.queryInfosConfig(projectId);
  95. List<AdmRelsConfig> relConfig = configService.queryRelsConfig(projectId);
  96. List<AdmPipeConfig> pipeConfig = configService.queryPipeConfig(projectId);
  97. List<AdmConfig> config = configService.queryCommonConfig(projectId);
  98. List<AdmComponent> component = configService.queryComponent(projectId);
  99. List<AdmContainerConfig> containerConfig = configService.queryContainerConfig(projectId);
  100. HashMap<String, Object> data = new HashMap<>();
  101. data.put("m2dTypes", m2dTypes);
  102. data.put("infosConfig", serializeJsonProp(infosConfig));
  103. data.put("relConfig", relConfig);
  104. data.put("pipeConfig", pipeConfig);
  105. data.put("config", serializeJsonProp(config));
  106. data.put("component", component);
  107. data.put("containerConfig", containerConfig);
  108. return data;
  109. }
  110. @Override
  111. public Dict queryDict(String groupCode, String projectId, String userId, boolean includeRel, boolean includeInfos){
  112. boolean newDict = "JD".equalsIgnoreCase(groupCode);
  113. //从知识库服务获取专业分类
  114. QueryCriteria majorCriteria = ServiceUtil.getQueryCriteria(objectMapper);
  115. majorCriteria.getCriteria().put("type", "major");
  116. List<Map<String, Object>> majorList = ServiceUtil.call (() -> dicClient.dataQuery(groupCode, projectId, AdmConst.APP_ID, userId, majorCriteria));
  117. //查询系统和设备定义
  118. QueryCriteria criteria = ServiceUtil.getQueryCriteria(objectMapper, "system", "equipment");
  119. List<TypeDef> typeList = ServiceUtil.queryAllPage(() -> rwdClient.queryObjectType(groupCode, projectId, AdmConst.APP_ID, userId, criteria), criteria, new Pagination(500));
  120. //查询重命名设备类型
  121. ObjectNode renameNode = !newDict ? configService.queryRenameEquipTypes(projectId) : null;
  122. LinkedList<TypeDef> sysList = new LinkedList<>();
  123. LinkedList<TypeDef> equipList = new LinkedList<>();
  124. for(TypeDef def : typeList){
  125. if(def.getObjType().equals("system"))
  126. sysList.add(def);
  127. else if(def.getObjType().equals("equipment")) {
  128. if(!newDict) {
  129. if (renameNode != null) { //设备类型重命名
  130. JsonNode n = renameNode.get(def.getCode());
  131. if(n != null)
  132. def.setName(n.asText());
  133. }
  134. }
  135. equipList.add(def);
  136. }
  137. }
  138. //加载新增的自定义设备类
  139. // try{
  140. // Resource resource = resourceLoader.getResource("classpath:equip.json");
  141. // List<TypeDef> types = objectMapper.readValue(resource.getInputStream(), new TypeReference<List<TypeDef>>(){});
  142. // equipList.addAll(types);
  143. // }catch (Exception e) {
  144. //
  145. // }
  146. if(!newDict) {
  147. ArrayNode arr = configService.queryNewEquipTypes(projectId);
  148. if(arr != null) {
  149. try{
  150. List<TypeDef> types = objectMapper.readValue(objectMapper.writeValueAsString(arr), new TypeReference<List<TypeDef>>(){});
  151. equipList.addAll(types);
  152. }catch (Exception e) {
  153. }
  154. }
  155. }
  156. Dict data = new Dict();
  157. data.setMajor(majorList);
  158. data.setSystem(sysList);
  159. data.setEquipment(equipList);
  160. //查询关系定义
  161. if(includeRel) {
  162. List<RelationDefine> relList = ServiceUtil.call(() -> rwdClient.queryRelDef(groupCode, projectId, AdmConst.APP_ID, userId, new QueryCriteria()));
  163. data.setRelation(relList);
  164. }
  165. //查询信息点定义
  166. if(includeInfos) {
  167. QueryCriteria qc = new QueryCriteria();
  168. qc.setCriteria(objectMapper.createObjectNode());
  169. List<InfoDef> funcList = ServiceUtil.call(() -> rwdClient.queryFunc(groupCode, projectId, AdmConst.APP_ID, userId, qc));
  170. data.setInfos(funcList);
  171. }
  172. return data;
  173. }
  174. @Override
  175. public Map<String, Object> downloadFrameData(String groupCode, String projectId, String userId) {
  176. List<OProject> prjList = null;
  177. String token = queryOldAdm.login();
  178. if(StrUtil.isNotBlank(token))
  179. prjList = queryOldAdm.queryProject(token, groupCode, projectId);
  180. else
  181. throw new CallException(new AdmResult(ResponseCode.A0220.getCode(), "ADM platform: " + ResponseCode.A0220.getDesc()));
  182. String[] prjIds = new String[prjList.size()];
  183. for (int i = 0; i < prjIds.length; i++) {
  184. prjIds[i] = prjList.get(i).getId();
  185. }
  186. List<AdmObject> bdAndFl = objectService.queryBdAndFl(prjIds);
  187. HashMap<String, Object> data = new HashMap<>();
  188. data.put("projects", prjList);
  189. data.put("buildingsAndFloors", serializeJsonProp(bdAndFl));
  190. return data;
  191. }
  192. @Override
  193. public BuildingData downloadBuildingData(String projectId, String buildingId, String uploadFlag, String lastDownloadTime) {
  194. List<AdmObject> bdData = admObjMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmObject>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  195. List<AdmRelation> bdRel = relationMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmRelation>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  196. List<AdmPipe> pipes = pipeMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmPipe>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  197. //任务相关数据查询
  198. List<AdmJobSpace> jobSpace = jobSpaceMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmJobSpace>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  199. List<AdmProblemArch> problemArch = problemArchMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmProblemArch>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  200. List<AdmProblemEquip> problemEquip = problemEquipMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmProblemEquip>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  201. List<AdmFile> file = fileMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmFile>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  202. List<AdmQrCode> qrCode = qrCodeMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmQrCode>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  203. List<AdmServeArea> serveArea = serveAreaMapper.selectList(buildDownloadQueryWrapper(new QueryWrapper<AdmServeArea>(), projectId, buildingId, uploadFlag, lastDownloadTime));
  204. BuildingData data = new BuildingData();
  205. data.setBuildingId(buildingId);
  206. data.setObjects(serializeJsonProp(bdData));
  207. data.setRelations(bdRel);
  208. data.setPipes(serializeJsonProp(pipes));
  209. data.setJobSpace(serializeJsonProp(jobSpace));
  210. data.setProblemArch(serializeJsonProp(problemArch));
  211. data.setProblemEquip(problemEquip);
  212. data.setFile(file);
  213. data.setQrCode(serializeJsonProp(qrCode));
  214. data.setServeArea(serveArea);
  215. data.setTimestamp(DateUtil.format(new Date(), DatePattern.PURE_DATETIME_PATTERN));
  216. return data;
  217. }
  218. private <T> QueryWrapper<T> buildDownloadQueryWrapper(QueryWrapper<T> wrapper, String projectId, String buildingId, String uploadFlag, String lastDownloadTime){
  219. wrapper.eq("project_id", projectId).eq("building_id", buildingId);
  220. applyUploadFlag(wrapper, uploadFlag,lastDownloadTime);
  221. return wrapper;
  222. }
  223. private void applyUploadFlag(QueryWrapper<?> wrapper, String uploadFlag, String lastDownloadTime){
  224. if (StrUtil.isNotBlank(lastDownloadTime)) { //非初始化下载
  225. if (StrUtil.isNotBlank(uploadFlag))
  226. wrapper.and(w -> w.isNull("upload_flag").or().ne("upload_flag", uploadFlag));
  227. wrapper.and(
  228. w -> w.isNotNull("modified_time").gt("modified_time", lastDownloadTime)
  229. .or()
  230. .isNull("modified_time").gt("creation_time", lastDownloadTime)
  231. );
  232. }
  233. }
  234. @Override
  235. public BuildingData downloadBuildingData(String groupCode, String projectId, String userId, String uploadFlag, String buildingId, Long bdtpDownloadTs, Long admDownloadTs) {
  236. throw new RuntimeException("not supported");
  237. }
  238. @Override
  239. public ProjectData downloadProjectData(String groupCode, String projectId, String userId, String uploadFlag, Long bdtpDownloadTs, Long admDownloadTs) {
  240. throw new RuntimeException("not supported");
  241. }
  242. @Override
  243. @Transactional(rollbackFor = Exception.class)
  244. public UploadRtn uploadData(UploadData uploadData, String groupCode, String projectId, String userId, String uploadFlag) {
  245. UploadRtn rtn = new UploadRtn();
  246. String timestamp = DateUtil.format(new Date(), DatePattern.PURE_DATETIME_PATTERN);
  247. if (CollUtil.isNotEmpty(uploadData.getObjects())) {
  248. List<AdmObject> dbObjs = admObjMapper.selectList(new QueryWrapper<AdmObject>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  249. List<AdmObject> expired = uploadAdmData(deserializeJsonProp(toEntities(uploadData.getObjects(), AdmObject.class)), dbObjs, uploadFlag, timestamp, admObjMapper, "object");
  250. rtn.setExpiredObjectIds(buildExpiredIds(expired));
  251. }
  252. if (CollUtil.isNotEmpty(uploadData.getRelations())) {
  253. List<AdmRelation> dbObjs = relationMapper.selectList(new QueryWrapper<AdmRelation>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  254. List<AdmRelation> expired = uploadAdmData(toEntities(uploadData.getRelations(), AdmRelation.class), dbObjs, uploadFlag, timestamp, relationMapper, "relation");
  255. rtn.setExpiredRelationIds(buildExpiredIds(expired));
  256. }
  257. if (CollUtil.isNotEmpty(uploadData.getPipes())) {
  258. List<AdmPipe> dbObjs = pipeMapper.selectList(new QueryWrapper<AdmPipe>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  259. List<AdmPipe> expired = uploadAdmData(deserializeJsonProp(uploadData.getPipes()), dbObjs, uploadFlag, timestamp, pipeMapper, "pipe");
  260. rtn.setExpiredPipeIds(buildExpiredIds(expired));
  261. }
  262. if (CollUtil.isNotEmpty(uploadData.getJobSpace())) {
  263. List<AdmJobSpace> dbObjs = jobSpaceMapper.selectList(new QueryWrapper<AdmJobSpace>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  264. List<AdmJobSpace> expired = uploadAdmData(deserializeJsonProp(uploadData.getJobSpace()), dbObjs, uploadFlag, timestamp, jobSpaceMapper, null);
  265. rtn.setExpiredJobSpaceIds(buildExpiredIds(expired));
  266. }
  267. if (CollUtil.isNotEmpty(uploadData.getProblemArch())) {
  268. List<AdmProblemArch> dbObjs = problemArchMapper.selectList(new QueryWrapper<AdmProblemArch>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  269. List<AdmProblemArch> expired = uploadAdmData(deserializeJsonProp(uploadData.getProblemArch()), dbObjs, uploadFlag, timestamp, problemArchMapper, null);
  270. rtn.setExpiredProblemArchIds(buildExpiredIds(expired));
  271. }
  272. if (CollUtil.isNotEmpty(uploadData.getProblemEquip())) {
  273. List<AdmProblemEquip> dbObjs = problemEquipMapper.selectList(new QueryWrapper<AdmProblemEquip>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  274. List<AdmProblemEquip> expired = uploadAdmData(uploadData.getProblemEquip(), dbObjs, uploadFlag, timestamp, problemEquipMapper, null);
  275. rtn.setExpiredProblemEquipIds(buildExpiredIds(expired));
  276. }
  277. if (CollUtil.isNotEmpty(uploadData.getFile())) {
  278. List<AdmFile> dbObjs = fileMapper.selectList(new QueryWrapper<AdmFile>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  279. List<AdmFile> expired = uploadAdmData(uploadData.getFile(), dbObjs, uploadFlag, timestamp, fileMapper, null);
  280. rtn.setExpiredFileIds(buildExpiredIds(expired));
  281. }
  282. if (CollUtil.isNotEmpty(uploadData.getQrCode())) {
  283. List<AdmQrCode> dbObjs = qrCodeMapper.selectList(new QueryWrapper<AdmQrCode>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  284. List<AdmQrCode> expired = uploadAdmData(deserializeJsonProp(uploadData.getQrCode()), dbObjs, uploadFlag, timestamp, qrCodeMapper, null);
  285. rtn.setExpiredQrCodeIds(buildExpiredIds(expired));
  286. }
  287. if (CollUtil.isNotEmpty(uploadData.getServeArea())) {
  288. List<AdmServeArea> dbObjs = serveAreaMapper.selectList(new QueryWrapper<AdmServeArea>().eq("building_id", uploadData.getBuildingId()).eq("valid", ValidEnum.TRUE.getType()));
  289. List<AdmServeArea> expired = uploadAdmData(uploadData.getServeArea(), dbObjs, uploadFlag, timestamp, serveAreaMapper, null);
  290. rtn.setExpiredServeAreaIds(buildExpiredIds(expired));
  291. }
  292. rtn.setTimestamp(timestamp);
  293. rtn.setBuildingId(uploadData.getBuildingId());
  294. return rtn;
  295. }
  296. private <T extends BaseAdmDataEntity> List<T> toEntities(List<ObjectNode> list, Class<T> cls){
  297. List<T> entities = new ArrayList<>(list.size());
  298. try {
  299. for(ObjectNode node : list) {
  300. entities.add(objectMapper.readValue(node.toString(), cls));
  301. }
  302. } catch (IOException e) {
  303. throw new BusinessException(ResponseCode.A0427.getCode(), ResponseCode.A0427.getDesc());
  304. }
  305. return entities;
  306. }
  307. private <T extends BaseAdmDataEntity> List<T> uploadAdmData(List<T> objs, List<T> dbObjs, String uploadFlag, String timestamp, BaseMapper<T> mapper, String d2mType){
  308. List<T> expired = new ArrayList<>();
  309. HashMap<String, T> dbMap = new HashMap<>(dbObjs.size());
  310. for(T dbObj : dbObjs) {
  311. dbMap.put(dbObj.getId(), dbObj);
  312. }
  313. List<T> msgAdd = new ArrayList<>();
  314. List<T> msgModify = new ArrayList<>();
  315. List<T> msgRemove = new ArrayList<>();
  316. for (T obj : objs) {
  317. if(obj == null)
  318. continue;
  319. logService.saveUploadLog(new AdmUploadLog());
  320. T dbObj = dbMap.get(obj.getId());
  321. if (dbObj == null) {
  322. if(obj.getValid().intValue() == ValidEnum.FALSE.getType())
  323. continue;
  324. obj.setCreationTime(timestamp);
  325. obj.setCreator(AdmConst.CREATOR_APP);
  326. //obj.setUploadFlag(uploadFlag);
  327. if(d2mType != null)
  328. setDeliveryDataProps((BaseDeliveryEntity) obj, null);
  329. mapper.insert(obj);
  330. if(d2mType != null)
  331. msgAdd.add(obj);
  332. } else {
  333. // String dbTs;
  334. // String ts;
  335. // if(dbObj.getModifiedTime() != null){
  336. // dbTs = dbObj.getModifiedTime();
  337. // ts = obj.getModifiedTime();
  338. // } else {
  339. // dbTs = dbObj.getCreationTime();
  340. // ts = obj.getCreationTime();
  341. // }
  342. // if (!dbTs.equals(ts)) {
  343. // //TODO 时间戳不一致,离线数据无效,暂时跳过处理
  344. // expired.add(obj);
  345. // } else {
  346. obj.setModifiedTime(timestamp);
  347. obj.setModifier(AdmConst.CREATOR_APP);
  348. //obj.setUploadFlag(uploadFlag);
  349. if(d2mType != null)
  350. setDeliveryDataProps((BaseDeliveryEntity) obj, null);
  351. //合并信息点
  352. if(dbObj instanceof AdmObject && obj instanceof AdmObject)
  353. ((AdmObject) obj).setInfos(mergeInfos(((AdmObject) obj).getInfos(), ((AdmObject) dbObj).getInfos()));
  354. else if(dbObj instanceof AdmPipe && obj instanceof AdmPipe)
  355. ((AdmPipe) obj).setInfos(mergeInfos(((AdmPipe) obj).getInfos(), ((AdmPipe) dbObj).getInfos()));
  356. mapper.updateById(obj);
  357. if(d2mType != null) {
  358. if(obj.getValid().intValue() == ValidEnum.FALSE.getType())
  359. msgRemove.add(obj);
  360. else
  361. msgModify.add(obj);
  362. }
  363. // }
  364. }
  365. }
  366. if(d2mType != null)
  367. sendD2mMessage(d2mType, msgAdd, msgModify, msgRemove);
  368. return expired;
  369. }
  370. private void setDeliveryDataProps(BaseDeliveryEntity obj, BaseDeliveryEntity dbObj){
  371. obj.setD2mState(ValidEnum.FALSE.getType());
  372. obj.setDeliveryState(ValidEnum.FALSE.getType());
  373. if(dbObj != null) {
  374. obj.setClientId(dbObj.getClientId());
  375. obj.setClientDevice(dbObj.getClientDevice());
  376. }
  377. }
  378. private ObjectNode mergeInfos(ObjectNode infos, ObjectNode dbInfos){
  379. if(dbInfos != null) {
  380. if(infos != null)
  381. dbInfos.setAll(infos);
  382. return dbInfos;
  383. } else
  384. return infos;
  385. }
  386. private void sendD2mMessage(String objectType, List msgAdd, List msgModify, List msgRemove){
  387. D2mMessage message = new D2mMessage(objectType, "", "");
  388. message.setAddItems(msgAdd);
  389. message.setModifyItems(msgModify);
  390. message.setRemoveItems(msgRemove);
  391. if(message.isNotEmpty())
  392. syncModel.sendMessageToModel(message);
  393. }
  394. private List<String> buildExpiredIds(List<? extends BaseAdmDataEntity> expired){
  395. if(expired.size() > 0) {
  396. List<String> ids = new ArrayList<>();
  397. for(BaseAdmDataEntity entity : expired) {
  398. ids.add(entity.getId());
  399. }
  400. return ids;
  401. }
  402. return null;
  403. }
  404. private <T extends BaseAdmEntity> List<T> serializeJsonProp(List<T> list){
  405. //app端完善,不需要做tostr处理了
  406. // for(BaseAdmEntity entity : list) {
  407. // entity.serializeJsonProp();
  408. // }
  409. return list;
  410. }
  411. private <T extends BaseAdmEntity> List<T> deserializeJsonProp(List<T> list){
  412. for(BaseAdmEntity entity : list) {
  413. entity.deserializeJsonProp();
  414. }
  415. return list;
  416. }
  417. }