|
@@ -1,6 +1,5 @@
|
1
|
1
|
package com.community.huiju.service.impl;
|
2
|
2
|
|
3
|
|
-import com.alibaba.fastjson.JSON;
|
4
|
3
|
import com.alibaba.fastjson.JSONObject;
|
5
|
4
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
6
|
5
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
@@ -11,7 +10,6 @@ import com.community.commom.constant.Constant;
|
11
|
10
|
import com.community.commom.mode.ResponseBean;
|
12
|
11
|
import com.community.commom.session.UserElement;
|
13
|
12
|
import com.community.commom.utils.AccountValidatorUtil;
|
14
|
|
-import com.community.commom.utils.BeanTools;
|
15
|
13
|
|
16
|
14
|
import com.community.huiju.common.base.messagePush;
|
17
|
15
|
import com.community.huiju.common.code.ICode;
|
|
@@ -22,9 +20,7 @@ import com.community.huiju.model.*;
|
22
|
20
|
|
23
|
21
|
import com.community.huiju.service.IBillInvoiceService;
|
24
|
22
|
import com.community.huiju.service.IBuildingOwnerInfoService;
|
25
|
|
-import com.community.huiju.service.ITaUserService;
|
26
|
23
|
import com.google.common.collect.Maps;
|
27
|
|
-import org.apache.commons.collections.CollectionUtils;
|
28
|
24
|
|
29
|
25
|
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
|
30
|
26
|
import org.apache.poi.ss.usermodel.*;
|
|
@@ -43,8 +39,7 @@ import java.io.IOException;
|
43
|
39
|
import java.io.InputStream;
|
44
|
40
|
import java.time.LocalDateTime;
|
45
|
41
|
import java.util.*;
|
46
|
|
-import java.util.regex.Pattern;
|
47
|
|
-import java.util.stream.Collectors;
|
|
42
|
+import java.util.concurrent.atomic.AtomicInteger;
|
48
|
43
|
|
49
|
44
|
|
50
|
45
|
/**
|
|
@@ -231,14 +226,9 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
231
|
226
|
return responseBean;
|
232
|
227
|
}
|
233
|
228
|
|
234
|
|
- // 插入楼栋资料库
|
235
|
|
- tpBuildingOwnerInfo = insertTpBuildingOwnerInfo(tpBuildingOwnerInfo.getPhaseId(), tpBuildingOwnerInfo.getBuildingId(), tpBuildingOwnerInfo.getUnitId(),
|
236
|
|
- tpBuildingOwnerInfo.getLevelId(), tpBuildingOwnerInfo.getRoomNoId(), userElement.getCommunityId(), userElement.getId(),
|
237
|
|
- tpBuildingOwnerInfo.getGender(), tpBuildingOwnerInfo.getOwnerName(), tpBuildingOwnerInfo.getOwnerTel());
|
|
229
|
+ TaUser appUser = getByLoginName(tpBuildingOwnerInfo.getOwnerTel());
|
238
|
230
|
|
239
|
231
|
// 开始匹配 APP 端用户表
|
240
|
|
- // 查询 APP 端
|
241
|
|
- TaUser appUser = getByLoginName(tpBuildingOwnerInfo.getOwnerTel());
|
242
|
232
|
if (null == appUser) {
|
243
|
233
|
// 如果 APP端 没有这个用户,则自动注册一个
|
244
|
234
|
TaUser taUser = new TaUser();
|
|
@@ -255,6 +245,16 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
255
|
245
|
taUserMapper.updateById(taUser);
|
256
|
246
|
appUser = taUser;
|
257
|
247
|
}
|
|
248
|
+
|
|
249
|
+ // 设置 用户性别 和 用户姓名
|
|
250
|
+ tpBuildingOwnerInfo.setGender(appUser.getGender());
|
|
251
|
+ tpBuildingOwnerInfo.setOwnerName(appUser.getUserName());
|
|
252
|
+
|
|
253
|
+ // 插入楼栋资料库
|
|
254
|
+ tpBuildingOwnerInfo = insertTpBuildingOwnerInfo(tpBuildingOwnerInfo.getPhaseId(), tpBuildingOwnerInfo.getBuildingId(), tpBuildingOwnerInfo.getUnitId(),
|
|
255
|
+ tpBuildingOwnerInfo.getLevelId(), tpBuildingOwnerInfo.getRoomNoId(), userElement.getCommunityId(), userElement.getId(),
|
|
256
|
+ tpBuildingOwnerInfo.getGender(), tpBuildingOwnerInfo.getOwnerName(), tpBuildingOwnerInfo.getOwnerTel());
|
|
257
|
+
|
258
|
258
|
// 更新 APP 端用户姓名
|
259
|
259
|
appUser.setUserName(tpBuildingOwnerInfo.getOwnerName());
|
260
|
260
|
appUser.setCreateDate(LocalDateTime.now());
|
|
@@ -311,7 +311,7 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
311
|
311
|
String[] messageArr= new messagePush().messagePushAll( );
|
312
|
312
|
for (String count : messageArr) {
|
313
|
313
|
Message message = new Message();
|
314
|
|
- message.setCommunityId(userVerify.getCommunityId());
|
|
314
|
+ message.setCommunityId(taUserVerify.getCommunityId());
|
315
|
315
|
message.setMessageType("9");
|
316
|
316
|
message.setAdviceType("1");
|
317
|
317
|
message.setModelType("1");
|
|
@@ -452,12 +452,14 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
452
|
452
|
List<TpBuildingOwnerInfo> list = (List<TpBuildingOwnerInfo>) map.get("list");
|
453
|
453
|
|
454
|
454
|
//批量插入
|
455
|
|
- tpBuildingOwnerInfoMapper.batchInsert(list);
|
|
455
|
+ // tpBuildingOwnerInfoMapper.batchInsert(list);
|
456
|
456
|
|
457
|
457
|
//构造数据
|
458
|
458
|
for (TpBuildingOwnerInfo tpBuildingOwnerInfo : list){
|
459
|
459
|
//根据手机号查询这个手机号是否注册
|
460
|
|
- TaUser taUser = taUserMapper.selectByTel(tpBuildingOwnerInfo.getOwnerTel());
|
|
460
|
+ QueryWrapper<TaUser> queryWrapper = new QueryWrapper<>();
|
|
461
|
+ queryWrapper.eq("login_name", tpBuildingOwnerInfo.getOwnerTel());
|
|
462
|
+ TaUser taUser = taUserMapper.selectOne(queryWrapper);
|
461
|
463
|
if (null == taUser){
|
462
|
464
|
//插入新用户并审核通过
|
463
|
465
|
addNewUser(tpBuildingOwnerInfo,userElement);
|
|
@@ -471,20 +473,31 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
471
|
473
|
}
|
472
|
474
|
|
473
|
475
|
private void checkUserVerify(TaUser taUser, TpBuildingOwnerInfo tpBuildingOwnerInfo, UserElement userElement) {
|
|
476
|
+
|
474
|
477
|
//有用户的情况下查看是否有申请的房产
|
475
|
478
|
QueryWrapper<TaUserVerify> queryWrapper = new QueryWrapper<>();
|
476
|
479
|
queryWrapper.eq("community_id",userElement.getCommunityId());
|
477
|
480
|
queryWrapper.eq("user_id",taUser.getId());
|
478
|
481
|
List<TaUserVerify> verifyList = taUserVerifyMapper.selectList(queryWrapper);
|
|
482
|
+ AtomicInteger rows = new AtomicInteger();
|
479
|
483
|
if (verifyList.size() > 0){
|
480
|
484
|
verifyList.stream().forEach(e -> {
|
481
|
|
- if (e.getRoomNoId().equals(tpBuildingOwnerInfo.getId()) && e.getVerifyStatus().equals("0")){
|
|
485
|
+ if (e.getVerifyStatus().equals("0") &&
|
|
486
|
+ e.getPhaseId().intValue() == tpBuildingOwnerInfo.getPhaseId().intValue()
|
|
487
|
+ && e.getBuildingId().intValue() == tpBuildingOwnerInfo.getBuildingId().intValue()
|
|
488
|
+ && e.getUnitId().intValue() == tpBuildingOwnerInfo.getUnitId().intValue()
|
|
489
|
+ && e.getLevelId().intValue() == tpBuildingOwnerInfo.getLevelId().intValue()
|
|
490
|
+ && e.getRoomNoId().intValue() == tpBuildingOwnerInfo.getRoomNoId().intValue() ){
|
|
491
|
+
|
482
|
492
|
e.setVerifyStatus("1");
|
483
|
493
|
e.setVerifyName(userElement.getUserName());
|
484
|
|
- taUserVerifyMapper.updateById(e);
|
|
494
|
+ rows.set(taUserVerifyMapper.updateById(e));
|
485
|
495
|
}
|
486
|
496
|
});
|
487
|
|
- return;
|
|
497
|
+ if (rows.get() > 0) {
|
|
498
|
+ return;
|
|
499
|
+ }
|
|
500
|
+
|
488
|
501
|
}
|
489
|
502
|
//插入一条房产数据
|
490
|
503
|
saveVerifyData(taUser.getId(),tpBuildingOwnerInfo,userElement);
|
|
@@ -520,6 +533,16 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
520
|
533
|
}else if (tpBuildingOwnerInfo.getRoleName().equals("租客")){
|
521
|
534
|
taUserVerify.setRoleId(2);
|
522
|
535
|
}
|
|
536
|
+
|
|
537
|
+ // TODO 是否只允许一个房产中只有一个角色?还是说多个角色?排除业主角色
|
|
538
|
+ TaUserVerify boolUserVerify = taUserVerifyMapper.selectCommunityAndAddressAndRoleId(userId, userElement.getCommunityId(), tpBuildingOwnerInfo.getPhaseId(),
|
|
539
|
+ tpBuildingOwnerInfo.getBuildingId(), tpBuildingOwnerInfo.getUnitId(),
|
|
540
|
+ tpBuildingOwnerInfo.getLevelId(), tpBuildingOwnerInfo.getRoomNoId(), taUserVerify.getRoleId());
|
|
541
|
+ // 表示这个用户在这个房产中已经有了这个角色, 就不进行插入
|
|
542
|
+ if (null != boolUserVerify) {
|
|
543
|
+ return;
|
|
544
|
+ }
|
|
545
|
+
|
523
|
546
|
taUserVerify.setPhaseId(tpBuildingOwnerInfo.getPhaseId());
|
524
|
547
|
taUserVerify.setPhaseName(tpBuildingOwnerInfo.getPhaseName());
|
525
|
548
|
taUserVerify.setBuildingId(tpBuildingOwnerInfo.getBuildingId());
|
|
@@ -528,12 +551,27 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
528
|
551
|
taUserVerify.setUnitName(tpBuildingOwnerInfo.getUnitName());
|
529
|
552
|
taUserVerify.setLevelId(tpBuildingOwnerInfo.getLevelId());
|
530
|
553
|
taUserVerify.setLevelName(tpBuildingOwnerInfo.getLevelName());
|
531
|
|
- taUserVerify.setRoomNoId(tpBuildingOwnerInfo.getId());
|
|
554
|
+ taUserVerify.setRoomNoId(tpBuildingOwnerInfo.getRoomNoId());
|
532
|
555
|
taUserVerify.setRoomNoName(tpBuildingOwnerInfo.getRoomNoName());
|
533
|
556
|
taUserVerify.setVerifyStatus("1");
|
534
|
557
|
taUserVerify.setCreateDate(LocalDateTime.now());
|
535
|
558
|
taUserVerify.setVerifyName(userElement.getUserName());
|
536
|
559
|
taUserVerifyMapper.insert(taUserVerify);
|
|
560
|
+
|
|
561
|
+ TaUser taUser = taUserMapper.selectById(userId);
|
|
562
|
+
|
|
563
|
+
|
|
564
|
+ // 通过后,需要往楼栋资料库写入数据
|
|
565
|
+ tpBuildingOwnerInfo.setCommunityId(userElement.getCommunityId());
|
|
566
|
+ tpBuildingOwnerInfo.setIdCard(taUser.getIdCard());
|
|
567
|
+ tpBuildingOwnerInfo.setGender(taUser.getGender());
|
|
568
|
+ tpBuildingOwnerInfo.setPairStatus("1");
|
|
569
|
+ tpBuildingOwnerInfo.setVerifyStatus("1");
|
|
570
|
+ tpBuildingOwnerInfo.setCreateDate(LocalDateTime.now());
|
|
571
|
+ tpBuildingOwnerInfo.setCreateUser(userElement.getId());
|
|
572
|
+ tpBuildingOwnerInfo.setTaUserVerifyId(taUserVerify.getId());
|
|
573
|
+
|
|
574
|
+ tpBuildingOwnerInfoMapper.insert(tpBuildingOwnerInfo);
|
537
|
575
|
}
|
538
|
576
|
|
539
|
577
|
@Override
|
|
@@ -634,8 +672,8 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
634
|
672
|
return responseBean;
|
635
|
673
|
}
|
636
|
674
|
//房产ID不为空的情况下检查房产是否存在
|
637
|
|
- TpBuildingOwnerInfo checkOwnerInfo =tpBuildingOwnerInfoMapper.selectById(roomNoId);
|
638
|
|
- if (null == checkOwnerInfo){
|
|
675
|
+ TpRoomNo tpRoomNo = tpRoomNoMapper.selectById(roomNoId);
|
|
676
|
+ if (null == tpRoomNo){
|
639
|
677
|
responseBean.addError("第" + currentRow + "行" + "房产ID不存在!");
|
640
|
678
|
return responseBean;
|
641
|
679
|
}
|
|
@@ -657,18 +695,30 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
657
|
695
|
return responseBean;
|
658
|
696
|
}
|
659
|
697
|
|
660
|
|
- if (temBuildingList.contains(roomNoId)){
|
661
|
|
- logger.info("存在重复房源:{}",roomNoId);
|
662
|
|
- responseBean.addError("第"+ currentRow +"行存在重复房源");
|
663
|
|
- return responseBean;
|
664
|
|
- }
|
|
698
|
+// if (temBuildingList.contains(roomNoId)){
|
|
699
|
+// logger.info("存在重复房源:{}",roomNoId);
|
|
700
|
+// responseBean.addError("第"+ currentRow +"行存在重复房源");
|
|
701
|
+// return responseBean;
|
|
702
|
+// }
|
665
|
703
|
|
666
|
704
|
//把数据塞入temList校验是否有重复的数据
|
667
|
705
|
temBuildingList.add(roomNoId);
|
668
|
706
|
//构建数据
|
|
707
|
+ TpBuildingOwnerInfo checkOwnerInfo = new TpBuildingOwnerInfo();
|
|
708
|
+ checkOwnerInfo.setId(null);
|
669
|
709
|
checkOwnerInfo.setRoleName(ownerRole);
|
670
|
710
|
checkOwnerInfo.setOwnerName(ownerName);
|
671
|
711
|
checkOwnerInfo.setOwnerTel(ownerTel);
|
|
712
|
+ checkOwnerInfo.setPhaseId(tpRoomNo.getPhaseId());
|
|
713
|
+ checkOwnerInfo.setPhaseName(tpRoomNo.getPhaseName());
|
|
714
|
+ checkOwnerInfo.setBuildingId(tpRoomNo.getBuildingId());
|
|
715
|
+ checkOwnerInfo.setBuildingName(tpRoomNo.getBuildingName());
|
|
716
|
+ checkOwnerInfo.setUnitId(tpRoomNo.getUnitId());
|
|
717
|
+ checkOwnerInfo.setUnitName(tpRoomNo.getUnitName());
|
|
718
|
+ checkOwnerInfo.setLevelId(tpRoomNo.getLevelId());
|
|
719
|
+ checkOwnerInfo.setLevelName(tpRoomNo.getLevelName());
|
|
720
|
+ checkOwnerInfo.setRoomNoId(tpRoomNo.getId());
|
|
721
|
+ checkOwnerInfo.setRoomNoName(tpRoomNo.getName());
|
672
|
722
|
list.add(checkOwnerInfo);
|
673
|
723
|
}
|
674
|
724
|
}
|
|
@@ -907,16 +957,13 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
907
|
957
|
// 创建列
|
908
|
958
|
XSSFCell cell = null;
|
909
|
959
|
|
910
|
|
- Integer pageNum = 1;
|
|
960
|
+ Integer pageNum = 0;
|
911
|
961
|
Integer pageSize = 10;
|
912
|
|
- Page<TpBuildingOwnerInfo> page = new Page(pageNum,pageSize);
|
|
962
|
+
|
913
|
963
|
// 分页查询
|
914
|
|
- QueryWrapper<TpBuildingOwnerInfo> buildingOwnerInfoQueryWrapper = new QueryWrapper<>();
|
915
|
|
- buildingOwnerInfoQueryWrapper.eq("community_id", userElement.getCommunityId());
|
916
|
|
- IPage<TpBuildingOwnerInfo> infoIPage = tpBuildingOwnerInfoMapper.selectPage(page, buildingOwnerInfoQueryWrapper);
|
917
|
|
- List<TpBuildingOwnerInfo> records = infoIPage.getRecords();
|
|
964
|
+ List<TpRoomNo> records = tpRoomNoMapper.selectCommunityIdList(userElement.getCommunityId(),pageNum * pageSize, pageSize);
|
918
|
965
|
// 总页数
|
919
|
|
- Long pages = infoIPage.getPages();
|
|
966
|
+ Long pages = tpRoomNoMapper.selectCommunityIdCount(userElement.getCommunityId());
|
920
|
967
|
|
921
|
968
|
|
922
|
969
|
// 行数 默认从 第 3 行开始
|
|
@@ -934,13 +981,13 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
934
|
981
|
|
935
|
982
|
if (records.size() > 0) {
|
936
|
983
|
do {
|
937
|
|
- TpBuildingOwnerInfo buildingOwnerInfo = records.get(index);
|
|
984
|
+ TpRoomNo tpRoomNo = records.get(index);
|
938
|
985
|
row = sheet.createRow(currentRow);
|
939
|
|
- String address = buildingOwnerInfo.getPhaseName() +
|
940
|
|
- buildingOwnerInfo.getBuildingName() +
|
941
|
|
- buildingOwnerInfo.getUnitName() +
|
942
|
|
- buildingOwnerInfo.getLevelName() +
|
943
|
|
- buildingOwnerInfo.getRoomNoName();
|
|
986
|
+ String address = tpRoomNo.getPhaseName() +
|
|
987
|
+ tpRoomNo.getBuildingName() +
|
|
988
|
+ tpRoomNo.getUnitName() +
|
|
989
|
+ tpRoomNo.getLevelName() +
|
|
990
|
+ tpRoomNo.getName();
|
944
|
991
|
|
945
|
992
|
cell = row.createCell(0);
|
946
|
993
|
cell.setCellType(Cell.CELL_TYPE_STRING);
|
|
@@ -948,7 +995,7 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
948
|
995
|
cell.setCellStyle(cellStyle);
|
949
|
996
|
cell = row.createCell(1);
|
950
|
997
|
cell.setCellType(Cell.CELL_TYPE_STRING);
|
951
|
|
- cell.setCellValue(buildingOwnerInfo.getId());
|
|
998
|
+ cell.setCellValue(tpRoomNo.getId());
|
952
|
999
|
cell.setCellStyle(cellStyle);
|
953
|
1000
|
cell = row.createCell(2);
|
954
|
1001
|
cell.setCellType(Cell.CELL_TYPE_STRING);
|
|
@@ -964,11 +1011,13 @@ public class BuildingOwnerInfoServiceImpl extends ServiceImpl<TpBuildingOwnerInf
|
964
|
1011
|
index ++;
|
965
|
1012
|
if (index == records.size()) {
|
966
|
1013
|
index = 0;
|
967
|
|
- page = new Page(infoIPage.getCurrent() + 1,pageSize);
|
968
|
|
- infoIPage = tpBuildingOwnerInfoMapper.selectPage(page, buildingOwnerInfoQueryWrapper);
|
969
|
|
- records = infoIPage.getRecords();
|
|
1014
|
+ pageNum ++;
|
|
1015
|
+ records = tpRoomNoMapper.selectCommunityIdList(userElement.getCommunityId(),pageNum * pageSize, pageSize);
|
|
1016
|
+ }
|
|
1017
|
+ if (records.isEmpty()) {
|
|
1018
|
+ break;
|
970
|
1019
|
}
|
971
|
|
- } while (infoIPage.getCurrent() <= pages);
|
|
1020
|
+ } while (pageNum <= pages);
|
972
|
1021
|
}
|
973
|
1022
|
|
974
|
1023
|
responseBean.addSuccess(workbook);
|