ZoneInfoService.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612
  1. package com.lqkj.link.module.zone.service;
  2. import com.alibaba.fastjson2.JSON;
  3. import com.alibaba.fastjson2.JSONArray;
  4. import com.alibaba.fastjson2.JSONObject;
  5. import com.lqkj.link.module.authority.domain.UserInfo;
  6. import com.lqkj.link.module.authority.repository.UserInfoRepository;
  7. import com.lqkj.link.module.bulletin.domain.NoticeInfo;
  8. import com.lqkj.link.module.bulletin.repository.NoticeInfoRepository;
  9. import com.lqkj.link.module.zone.domain.*;
  10. import com.lqkj.link.module.zone.repository.*;
  11. import com.lqkj.link.util.AliOSSUtils;
  12. import com.lqkj.link.util.PhoneUtils;
  13. import com.lqkj.link.util.Unzipper;
  14. import org.apache.commons.lang3.StringUtils;
  15. import org.apache.commons.lang3.SystemUtils;
  16. import org.aspectj.weaver.ast.Var;
  17. import org.checkerframework.checker.units.qual.A;
  18. import org.aspectj.weaver.ast.Var;
  19. import org.locationtech.jts.geom.Coordinate;
  20. import org.locationtech.jts.geom.GeometryFactory;
  21. import org.springframework.beans.BeanUtils;
  22. import org.springframework.beans.factory.annotation.Autowired;
  23. import org.springframework.data.domain.Page;
  24. import org.springframework.data.domain.PageImpl;
  25. import org.springframework.data.domain.PageRequest;
  26. import org.springframework.data.domain.Pageable;
  27. import org.springframework.stereotype.Service;
  28. import org.springframework.transaction.annotation.Transactional;
  29. import java.io.File;
  30. import java.io.IOException;
  31. import java.nio.file.Files;
  32. import java.nio.file.Paths;
  33. import java.sql.Timestamp;
  34. import java.text.SimpleDateFormat;
  35. import java.util.*;
  36. import java.util.stream.Collectors;
  37. @Service
  38. public class ZoneInfoService {
  39. private final ZoneInfoRepository zoneInfoRepository;
  40. private final UserInfoRepository userInfoRepository;
  41. private final GeomInfoRepository geomInfoRepository;
  42. private final ModelInfoRepository modelInfoRepository;
  43. @Autowired
  44. private AliOSSUtils aliOSSUtils;
  45. private static final Long ONEDAY = 24 * 60 * 60 * 1000L;
  46. @Autowired
  47. private LikesInfoRepository likesInfoRepository;
  48. @Autowired
  49. private NoticeInfoRepository noticeInfoRepository;
  50. @Autowired
  51. private ShareInfoRepository shareInfoRepository;
  52. public ZoneInfoService(ZoneInfoRepository zoneInfoRepository, UserInfoRepository userInfoRepository,
  53. GeomInfoRepository geomInfoRepository, ModelInfoRepository modelInfoRepository) {
  54. this.zoneInfoRepository = zoneInfoRepository;
  55. this.userInfoRepository = userInfoRepository;
  56. this.geomInfoRepository = geomInfoRepository;
  57. this.modelInfoRepository = modelInfoRepository;
  58. }
  59. public Page<ZoneInfo> pageQueryTemplate(String zoneName, Integer page, Integer pageSize) {
  60. Pageable pageable = PageRequest.of(page, pageSize);
  61. return zoneInfoRepository.pageQueryTemplate(zoneName, pageable);
  62. }
  63. @Transactional
  64. public Map<String, Object> saveTemplate(ZoneInfo zoneInfo) {
  65. Map<String, Object> result = new HashMap<>();
  66. if ((zoneInfo.getZoneId() != null && zoneInfoRepository.hasSameTemplateNameWithoutOne(zoneInfo.getZoneName(), zoneInfo.getZoneId()))
  67. || (zoneInfo.getZoneId() == null && zoneInfoRepository.hasSameTemplateName(zoneInfo.getZoneName()))) {
  68. result.put("msg", "模板名称不能重复!");
  69. return result;
  70. }
  71. zoneInfo.setUpdateTime(new Date());
  72. boolean isUpdated = true;
  73. if (zoneInfo.getZoneId() == null) {
  74. zoneInfo.setShareCount(0);
  75. zoneInfo.setViewCount(0);
  76. zoneInfo.setTemplateUse(0);
  77. }else {
  78. ZoneInfo oldZoneInfo = zoneInfoRepository.findById(zoneInfo.getZoneId()).get();
  79. isUpdated = !oldZoneInfo.getTemplateFilePath().equals(zoneInfo.getTemplateFilePath());
  80. }
  81. ZoneInfo zoneInfo1 = zoneInfoRepository.save(zoneInfo);
  82. if (StringUtils.isNotBlank(zoneInfo.getTemplateFilePath()) && isUpdated) {
  83. // 清除元素与模型
  84. geomInfoRepository.deleteAllByZoneId(zoneInfo1.getZoneId());
  85. modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
  86. // 解压压缩文件
  87. // 文件目录格式:
  88. // --geom.json
  89. // --models
  90. // ----model1.fbx 模型1文件
  91. // ----model2.fbx 模型2文件
  92. // ----model1.json 模型1材质
  93. // ----model2.json 模型2材质
  94. //
  95. // geom.json文件总json格式:
  96. // {
  97. // "init": {
  98. // "rotation": {
  99. // "x": 0,
  100. // "y": 0,
  101. // "z": 0,
  102. // "w": 0
  103. // },
  104. // "translation": {
  105. // "x": 0,
  106. // "y": 0,
  107. // "z": 0
  108. // },
  109. // "scale3D": {
  110. // "x": 0,
  111. // "y": 0,
  112. // "z": 0
  113. // }
  114. // },
  115. // "models": [
  116. // {
  117. // "modelPath": "model1.fbx",
  118. // "location": [
  119. // {
  120. // "rotation": {
  121. // "x": 0,
  122. // "y": 0,
  123. // "z": 0,
  124. // "w": 0
  125. // },
  126. // "translation": {
  127. // "x": 0,
  128. // "y": 0,
  129. // "z": 0
  130. // },
  131. // "scale3D": {
  132. // "x": 0,
  133. // "y": 0,
  134. // "z": 0
  135. // }
  136. // }
  137. // ]
  138. // }
  139. // ]
  140. // }
  141. String geomJsonString = null;
  142. try {
  143. Unzipper.unZipFiles(new File("." + zoneInfo.getTemplateFilePath()), "./upload/template/" + zoneInfo1.getZoneId() + "/");
  144. geomJsonString = Files.readString(Paths.get("./upload/template/" + zoneInfo1.getZoneId() + "/geom.json"));
  145. } catch (IOException e) {
  146. // modelInfoRepository.deleteAllByTemplateIds(Collections.singletonList(zoneInfo1.getZoneId()));
  147. // zoneInfoRepository.delete(zoneInfo1);
  148. result.put("msg", "模板压缩文件解压失败!");
  149. return result;
  150. }
  151. checkZipContent(zoneInfo1);
  152. TemplateGeom templateGeom = JSON.parseObject(geomJsonString, TemplateGeom.class);
  153. zoneInfo1.setInitLocation(templateGeom.getInit());
  154. zoneInfoRepository.save(zoneInfo1);
  155. List<TemplateInfo> templateInfoList = templateGeom.getModels();
  156. List<ModelInfo> list = new ArrayList<>();
  157. if (zoneInfo1.getTypeNumber() == 1){
  158. String modelFolderPath = "./upload/template/" + zoneInfo1.getZoneId() + "/models";
  159. File modelFolder = new File(modelFolderPath);
  160. File[] models = modelFolder.listFiles();
  161. assert models != null;
  162. for (File model : models) {
  163. if (model.isFile()) {
  164. String modelFileName = model.getName();
  165. if (modelFileName.endsWith(".fbx")) {
  166. String modelPath = aliOSSUtils.upload(model);
  167. ModelInfo modelInfo = new ModelInfo();
  168. modelInfo.setModelName(modelFileName.substring(0, modelFileName.lastIndexOf(".")).toLowerCase());
  169. modelInfo.setOriginalPath(modelPath);
  170. modelInfo.setModelIcon(zoneInfo1.getThumbnail());
  171. modelInfo.setTemplateId(zoneInfo1.getZoneId());
  172. modelInfo.setTypeNumber(1);
  173. list.add(modelInfo);
  174. }
  175. }
  176. }
  177. }else {
  178. String directoryPath = "./upload/template/" + zoneInfo1.getZoneId();
  179. File directory = new File(directoryPath);
  180. // 获取目录下的所有文件
  181. File[] files = directory.listFiles((dir, name) -> name.endsWith(".pak"));
  182. assert files != null;
  183. StringBuilder pakPath = new StringBuilder();
  184. for (File file : files){
  185. assert false;
  186. pakPath.append(aliOSSUtils.upload(file)).append(",");
  187. }
  188. zoneInfo1.setPakPath(pakPath.toString());
  189. zoneInfoRepository.save(zoneInfo1);
  190. for (TemplateInfo templateInfo : templateInfoList) {
  191. ModelInfo modelInfo = new ModelInfo();
  192. modelInfo.setModelName(templateInfo.getModelPath().substring(templateInfo.getModelPath().lastIndexOf(".") + 1));
  193. modelInfo.setOriginalPath(templateInfo.getModelPath());
  194. modelInfo.setModelIcon(zoneInfo1.getThumbnail());
  195. modelInfo.setTemplateId(zoneInfo1.getZoneId());
  196. modelInfo.setTypeNumber(2);
  197. list.add(modelInfo);
  198. }
  199. }
  200. List<ModelInfo> modelInfoList = modelInfoRepository.saveAll(list);
  201. Map<String, ModelInfo> modelPathIdMap = modelInfoList
  202. .stream()
  203. .collect(Collectors.toMap(ModelInfo::getOriginalPath, ModelInfo -> ModelInfo));
  204. Map<String, String> collect = null;
  205. if (zoneInfo1.getTypeNumber() == 1) {
  206. collect = modelInfoList.stream().collect(Collectors.toMap(ModelInfo::getModelName, ModelInfo::getOriginalPath));
  207. }
  208. List<GeomInfo> geomInfoList = new ArrayList<>();
  209. GeometryFactory geometryFactory = new GeometryFactory();
  210. int j = 1;
  211. for (TemplateInfo templateInfo : templateInfoList) {
  212. String modelName = templateInfo.getModelPath();
  213. if (zoneInfo1.getTypeNumber() == 1) {
  214. assert collect != null;
  215. modelName = collect.get(modelName.substring(0, modelName.lastIndexOf(".")).toLowerCase());
  216. }
  217. ModelInfo modelInfo = modelPathIdMap.get(modelName);
  218. for (int i = 0; i < templateInfo.getLocation().size(); i++) {
  219. JSONObject trans = templateInfo.getLocation().get(i);
  220. GeomInfo geomInfo = new GeomInfo();
  221. geomInfo.setGeomId(zoneInfo1.getZoneId() + "_" + j);
  222. geomInfo.setModelId(modelInfo.getModelId());
  223. geomInfo.setGeomName(modelInfo.getModelName());
  224. geomInfo.setZoneId(zoneInfo1.getZoneId());
  225. geomInfo.setLocking(false);
  226. geomInfo.setTrans(trans);
  227. JSONObject pointObject = trans.getJSONObject("translation");
  228. geomInfo.setGeom(geometryFactory.createPoint(new Coordinate(
  229. Double.parseDouble(pointObject.get("x").toString()),
  230. Double.parseDouble(pointObject.get("y").toString()),
  231. Double.parseDouble(pointObject.get("z").toString()))));
  232. j++;
  233. geomInfoList.add(geomInfo);
  234. }
  235. }
  236. geomInfoRepository.saveAll(geomInfoList);
  237. }
  238. result.put("zone", zoneInfo1);
  239. return result;
  240. }
  241. /**
  242. * 检查zip包内容
  243. * @param zoneInfo
  244. */
  245. private void checkZipContent(ZoneInfo zoneInfo) {
  246. int fileLength;
  247. if (zoneInfo.getTypeNumber() == 1){
  248. String modelFolderPath = "./upload/template/" + zoneInfo.getZoneId() + "/models";
  249. File modelFolder = new File(modelFolderPath);
  250. File[] models = modelFolder.listFiles();
  251. fileLength = models == null ? 0 : models.length;
  252. }
  253. else {
  254. String directoryPath = "./upload/template/" + zoneInfo.getZoneId();
  255. File directory = new File(directoryPath);
  256. // 获取目录下的所有文件
  257. File[] files = directory.listFiles((dir, name) -> name.endsWith(".pak"));
  258. fileLength = files == null ? 0 : files.length;
  259. }
  260. if (fileLength == 0){
  261. throw new RuntimeException("模板内容选择有误,请确认后重新上传!");
  262. }
  263. }
  264. @Transactional
  265. public void deleteTemplate(List<Integer> zoneIds) {
  266. zoneInfoRepository.deleteAllByIdInBatch(zoneIds);
  267. modelInfoRepository.deleteAllByTemplateIds(zoneIds);
  268. }
  269. public List<String> autoCompleteMyWork(String userCode, String keyword) {
  270. return zoneInfoRepository
  271. .autoCompleteMyWork(userCode, keyword)
  272. .stream()
  273. .map(v -> (String) v.get("name"))
  274. .toList();
  275. }
  276. public List<String> autoCompleteResource(String keyword, Integer searchType) {
  277. return zoneInfoRepository
  278. .autoCompleteResource(keyword, searchType)
  279. .stream()
  280. .map(v -> (String) v.get("name"))
  281. .toList();
  282. }
  283. public List<String> autoCompleteAudit(String keyword, Integer searchType) {
  284. return zoneInfoRepository
  285. .autoCompleteAudit(keyword, searchType)
  286. .stream()
  287. .map(v -> (String) v.get("name"))
  288. .toList();
  289. }
  290. public Page<ZoneInfo> myWork(String userCode, String name, Integer page, Integer pageSize) {
  291. Pageable pageable = PageRequest.of(page, pageSize);
  292. return zoneInfoRepository.pageQueryMyWork(userCode, name, pageable);
  293. }
  294. public Page<Map<String, Object>> resourceCenter(String name, Integer searchType, Integer page, Integer pageSize, Integer orderType, String userCode) {
  295. Pageable pageable = PageRequest.of(page, pageSize);
  296. Page<Map<String, Object>> maps = zoneInfoRepository.pageQueryResourceCenter(name, searchType, pageable, orderType);
  297. List<Map<String, Object>> result = new ArrayList<>();
  298. maps.getContent().forEach(map -> {
  299. Integer zoneId = (Integer) map.get("zoneId");
  300. UserInfo userInfo = userInfoRepository.findByUserCode(userCode);
  301. boolean isLiked = likesInfoRepository.isLiked(zoneId, userInfo.getUserId());
  302. HashMap<String, Object> zoneInfo = new HashMap<>(map);
  303. if (isLiked) {
  304. zoneInfo.put("isLiked", true);
  305. } else {
  306. zoneInfo.put("isLiked", false);
  307. }
  308. result.add(zoneInfo);
  309. });
  310. return new PageImpl<>(result, PageRequest.of(page, pageSize), maps.getTotalElements());
  311. }
  312. public Page<Map<String, Object>> auditCenter(String name, Integer searchType, Integer page, Integer pageSize) {
  313. Pageable pageable = PageRequest.of(page, pageSize);
  314. return zoneInfoRepository.auditCenter(name, searchType, pageable);
  315. }
  316. @Transactional
  317. public String share(Integer zoneId, String userCode, String shareUserCode, Integer shareType) {
  318. UserInfo shareUserInfo = userInfoRepository.findByUserCode(shareUserCode);
  319. if (Objects.isNull(shareUserInfo)) throw new RuntimeException("未能找到与该手机号码相关的账户,请确认号码无误");
  320. String shareCode = UUID.randomUUID().toString();
  321. List<ShareInfo> shareInfoList = shareInfoRepository.findByZoneIdAndSharedUserId(zoneId, shareUserInfo.getUserId());
  322. if (shareInfoList.size() > 0 && (shareTime(shareInfoList.get(0)) > System.currentTimeMillis())) throw new RuntimeException("该账户已分享过该作品");
  323. else if (shareInfoList.size() > 0 && (shareTime(shareInfoList.get(0)) < System.currentTimeMillis())) {
  324. shareInfoRepository.updateShareTime(zoneId, shareUserInfo.getUserId(), shareType);
  325. }else {
  326. zoneInfoRepository.share(zoneId, userCode, shareCode, shareUserInfo.getUserId(), shareType);
  327. }
  328. UserInfo userInfo = userInfoRepository.findByUserCode(userCode);
  329. NoticeInfo noticeInfo = new NoticeInfo();
  330. noticeInfo.setUserId(shareUserInfo.getUserId());
  331. noticeInfo.setType(4);
  332. noticeInfo.setContent(PhoneUtils.encryptPhoneNumber(userInfo.getUserCode()) + "邀请你参加作品协作,与他(她)共建场景。");
  333. noticeInfo.setHasView(false);
  334. noticeInfo.setCreateTime(new Date());
  335. noticeInfo.setZoneId(zoneId);
  336. noticeInfoRepository.save(noticeInfo);
  337. return shareCode;
  338. }
  339. private Long shareTime(ShareInfo shareInfo){
  340. return shareInfo.getShareTime().getTime() + shareInfo.getCanUse() * ONEDAY;
  341. }
  342. @Transactional
  343. public void view(Integer zoneId, String userCode) {
  344. zoneInfoRepository.view(zoneId, userCode);
  345. }
  346. @Transactional
  347. public String rename(Integer zoneId, String newName, String userCode) {
  348. if (zoneInfoRepository.hasSameNameWithUser(newName, userCode, zoneId)) {
  349. return "不能与已有作品重名!";
  350. }
  351. zoneInfoRepository.rename(newName, zoneId);
  352. return null;
  353. }
  354. @Transactional
  355. public String deleteWork(Integer zoneId, String userCode) {
  356. if(!zoneInfoRepository.existsById(zoneId)){
  357. return "该作品不存在!";
  358. }
  359. if (!zoneInfoRepository.isAuthor(zoneId, userCode)) {
  360. return "您不是该作品的作者!";
  361. }
  362. if (!zoneInfoRepository.canBeDeleteWithAuthStatus(zoneId)) {
  363. return "不能删除正在审核的作品!";
  364. }
  365. notifySharer(zoneId);
  366. shareInfoRepository.deleteByZoneId(zoneId);
  367. zoneInfoRepository.deleteById(zoneId);
  368. return null;
  369. }
  370. /**
  371. * 通知分享者
  372. * @param zoneId
  373. */
  374. private void notifySharer(Integer zoneId) {
  375. List<NoticeInfo> noticeInfos = new ArrayList<>();
  376. ZoneInfo zoneInfo = zoneInfoRepository.findById(zoneId).get();
  377. shareInfoRepository.findByZoneId(zoneId).forEach(shareInfo -> {
  378. NoticeInfo noticeInfo = new NoticeInfo();
  379. noticeInfo.setUserId(shareInfo.getSharedUserId());
  380. noticeInfo.setType(6);
  381. noticeInfo.setContent("经决定对" + zoneInfo.getZoneName() + "团队进行调整。很遗憾地通知您,您将不再作为该项目的协作者。我们感谢您到目前为止的贡献。");
  382. noticeInfo.setHasView(false);
  383. noticeInfo.setCreateTime(new Date());
  384. noticeInfo.setZoneId(zoneId);
  385. noticeInfos.add(noticeInfo);
  386. });
  387. noticeInfoRepository.saveAll(noticeInfos);
  388. }
  389. @Transactional
  390. public Map<String, Object> create(String name, Integer templateId, String userCode) {
  391. Map<String, Object> result = new HashMap<>();
  392. UserInfo userInfo = userInfoRepository.findByUserCode(userCode);
  393. if (zoneInfoRepository.existsByZoneNameAndUserId(name, userInfo.getUserId())) {
  394. result.put("msg", "不能与已有作品重名!");
  395. return result;
  396. }
  397. ZoneInfo template = null;
  398. if (templateId != null) {
  399. template = zoneInfoRepository.findById(templateId).get();
  400. }
  401. ZoneInfo zoneInfo = new ZoneInfo(null, userInfo.getUserId(), name, template == null ? new JSONObject(JSON.parseObject("{\"rotation\":{\"x\":0,\"y\":0.4383658766746521,\"z\":0,\"w\":0.8987966179847717},\"translation\":{\"x\":-820.947265625,\"y\":0,\"z\":955.6719360351563},\"scale3D\":{\"x\":1,\"y\":1,\"z\":1}}")) : template.getInitLocation(),
  402. template == null ? null : template.getThumbnail(), 0, new Date(), 0, 0,
  403. null, null, 0,0, null, template == null ? 1 : template.getTypeNumber(), template == null ? null : template.getPakPath());
  404. ZoneInfo newInfo = zoneInfoRepository.save(zoneInfo);
  405. GeometryFactory geometryFactory = new GeometryFactory();
  406. if (templateId != null) {
  407. if (geomInfoRepository.hasGeom(templateId)) {
  408. List<GeomInfo> geomInfoList = geomInfoRepository.findAllByZoneId(templateId);
  409. List<GeomInfo> list = new ArrayList<>();
  410. for (GeomInfo geomInfo : geomInfoList) {
  411. String geomId = geomInfo.getGeomId();
  412. String newId = newInfo.getZoneId() + "_" + geomId.split("_")[1];
  413. GeomInfo newGeom = JSON.parseObject(JSON.toJSONString(geomInfo), GeomInfo.class);
  414. newGeom.setGeomId(newId);
  415. newGeom.setZoneId(newInfo.getZoneId());
  416. newGeom.setTrans(geomInfo.getLocation());
  417. JSONObject pointObject = geomInfo.getLocation().getJSONObject("translation");
  418. newGeom.setGeom(geometryFactory.createPoint(new Coordinate(
  419. Double.parseDouble(pointObject.get("x").toString()),
  420. Double.parseDouble(pointObject.get("y").toString()),
  421. Double.parseDouble(pointObject.get("z").toString()))));
  422. newGeom.setLocking(false);
  423. list.add(newGeom);
  424. }
  425. geomInfoRepository.saveAll(list);
  426. }
  427. // 模板使用次数+1
  428. zoneInfoRepository.addTemplateUse(templateId);
  429. }else {
  430. GeomInfo geomInfo = new GeomInfo();
  431. geomInfo.setZoneId(newInfo.getZoneId());
  432. geomInfo.setGeomId(newInfo.getZoneId() + "_1");
  433. geomInfo.setModelId(10000);
  434. geomInfo.setGeomName("地板");
  435. geomInfo.setLocking(false);
  436. geomInfo.setTrans(new JSONObject(JSON.parseObject("{\"rotation\":{\"x\":0,\"y\":0,\"z\":0,\"w\":1},\"translation\":{\"x\":0,\"y\":0,\"z\":20},\"scale3D\":{\"x\":1,\"y\":1,\"z\":1}}")));
  437. geomInfo.setGeom(geometryFactory.createPoint(new Coordinate(0, 0, 0)));
  438. geomInfo.setTypeNumber(0);
  439. geomInfoRepository.save(geomInfo);
  440. }
  441. result.put("zone", newInfo);
  442. return result;
  443. }
  444. public void saveThumbnail(Integer zoneId, String thumbnailPath) {
  445. ZoneInfo zoneInfo = zoneInfoRepository.findById(zoneId).get();
  446. zoneInfo.setThumbnail(thumbnailPath);
  447. // zoneInfo.setUpdateTime(new Date());
  448. zoneInfoRepository.save(zoneInfo);
  449. }
  450. public JSONObject readTrans(Integer zoneId) {
  451. return zoneInfoRepository.findById(zoneId).get().getInitLocation();
  452. }
  453. /**
  454. * 检查分享状态
  455. * @param zoneId
  456. * @param userId
  457. * @return
  458. */
  459. public boolean checkShareStatus(Integer zoneId, Integer userId) {
  460. List<ShareInfo> shareInfos = shareInfoRepository.findByZoneIdAndSharedUserId(zoneId, userId);
  461. if (shareInfos.size() < 1) return false;
  462. return shareTime(shareInfos.get(0)) > System.currentTimeMillis();
  463. }
  464. /**
  465. * 获取分享中心数据
  466. * @param name
  467. * @param userId
  468. * @param page
  469. * @param pageSize
  470. * @return
  471. */
  472. public Page<Map<String, Object>> shareCenter(String name, Integer userId, Integer page, Integer pageSize) {
  473. Pageable pageable = PageRequest.of(page, pageSize);
  474. Page<Map<String, Object>> maps = zoneInfoRepository.pageQueryshareCenter(name, userId, pageable);
  475. List<Map<String, Object>> result = new ArrayList<>();
  476. maps.getContent().forEach(map -> {
  477. String update_time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(map.get("update_time"));
  478. HashMap<String, Object> resultMap = new HashMap<>(map);
  479. resultMap.put("update_time", update_time);
  480. result.add(resultMap);
  481. });
  482. return new PageImpl<>(result, PageRequest.of(page, pageSize), maps.getTotalElements());
  483. }
  484. /**
  485. * 分享中心自动补全接口
  486. * @param keyword
  487. * @param userId
  488. * @return
  489. */
  490. public List<String> autoCompleteShare(String keyword, Integer userId) {
  491. return zoneInfoRepository.autoCompleteShare(keyword, userId);
  492. }
  493. /**
  494. * 接受分享
  495. * @param zoneId
  496. * @param userId
  497. */
  498. @Transactional
  499. public void acceptShare(Integer zoneId, Integer userId, Boolean acceptStatus) {
  500. zoneInfoRepository.acceptShare(zoneId, userId, acceptStatus);
  501. if (!acceptStatus) {
  502. UserInfo userInfo = userInfoRepository.findById(userId).get();
  503. ShareInfo shareInfo = shareInfoRepository.findByZoneIdAndSharedUserId(zoneId, userId).get(0);
  504. NoticeInfo noticeInfo = new NoticeInfo();
  505. noticeInfo.setAcceptStatus(false);
  506. noticeInfo.setCreateTime(new Date());
  507. noticeInfo.setHasView(false);
  508. noticeInfo.setUserId(shareInfo.getUserId());
  509. noticeInfo.setType(5);
  510. noticeInfo.setContent("手机号为" + PhoneUtils.encryptPhoneNumber(userInfo.getUserCode()) + "的用户拒绝参加您的作品协作!");
  511. noticeInfo.setZoneId(zoneId);
  512. noticeInfoRepository.save(noticeInfo);
  513. }
  514. }
  515. /**
  516. * 查看分享用户
  517. * @param zoneId
  518. * @return
  519. */
  520. public List<Map<String, Object>> viewShareUser(Integer zoneId) {
  521. return userInfoRepository.viewShareUser(zoneId);
  522. }
  523. public List<Map<String, Object>> getSpawnPointList(Integer zoneId) {
  524. List<Map<String, Object>> spawnPointList = zoneInfoRepository.getSpawnPointList(zoneId);
  525. ArrayList<Map<String, Object>> maps = new ArrayList<>();
  526. for (Map<String, Object> map : spawnPointList) {
  527. HashMap<String, Object> stringObjectHashMap = new HashMap<>();
  528. stringObjectHashMap.put("id", map.get("id"));
  529. stringObjectHashMap.put("zone_id", map.get("zone_id"));
  530. stringObjectHashMap.put("name", map.get("name"));
  531. stringObjectHashMap.put("init_location", JSONObject.parse(map.get("init_location").toString()));
  532. maps.add(stringObjectHashMap);
  533. }
  534. return maps;
  535. }
  536. public void save(ZoneInfo zoneInfo) {
  537. zoneInfoRepository.save(zoneInfo);
  538. }
  539. public ZoneInfo zoneDetails(Integer zoneId) {
  540. return zoneInfoRepository.findById(zoneId).get();
  541. }
  542. @Transactional
  543. public void updateShareType(Integer zoneId, Integer shareType, Integer sharedUserId) {
  544. shareInfoRepository.updateShareType(zoneId, shareType, sharedUserId);
  545. }
  546. @Transactional
  547. public void removeShareUser(Integer zoneId, Integer sharedUserId) {
  548. shareInfoRepository.removeShareUser(zoneId, sharedUserId);
  549. }
  550. }