From 8470e06b5ce5189162f9f6cd3f2cea7d14ad80af Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期一, 28 四月 2025 10:37:56 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java | 214 ++++++++++++++++++++++++++++++++++++++++-------------
1 files changed, 162 insertions(+), 52 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
index 91309e2..42227d5 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
@@ -111,6 +111,8 @@
private ErpTool erpTool;
@Autowired
+ private VisitParkMapper visitParkMapper;
+ @Autowired
private WxPlatNotice wxPlatNotice;
@Autowired
@@ -170,7 +172,7 @@
if (erpVisitDTO.getEndtime().getTime() <= erpVisitDTO.getStarttime().getTime()) {
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝棰勭害缁撴潫鏃堕棿蹇呴』澶т簬寮�濮嬫椂闂达紒");
}
- if (Constants.equalsInteger(Constants.ZERO, erpVisitDTO.getIdcardType()) && erpVisitDTO.getIdcardNo().length() != 18
+ if (StringUtils.isNotBlank(erpVisitDTO.getIdcardNo()) && Constants.equalsInteger(Constants.ZERO, erpVisitDTO.getIdcardType()) && erpVisitDTO.getIdcardNo().length() != 18
//&&!IdcardUtil.isValidCard(visits.getIdcardNo())
){
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝韬唤璇佸彿鐮佹湁璇紝璇锋牳瀹炲悗閲嶈瘯锛�");
@@ -238,9 +240,8 @@
getHkDeviceRoles(visits,isERP);
//妫�楠屾嫓璁夸汉鏄惁鍚堟硶
Member visitMember = isValideVisitedUser(visits.getReceptMemberId());
- if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())
- &&visits.getIdcardNo().length()!=18
- ){
+ if(StringUtils.isNotBlank(visits.getIdcardNo()) && Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())
+ &&visits.getIdcardNo().length()!=18 ){
throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝韬唤璇佸彿鐮佹湁璇紝璇锋牳瀹炲悗閲嶈瘯锛�");
}
Date date = new Date();
@@ -301,8 +302,7 @@
WxPlatNotice wxPlatNotice = new WxPlatNotice();
wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz,
wxNoticeConfigMapper,visits,
- Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
- systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
+ Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
Arrays.asList(visits.getOpenid().split(","))
);
}
@@ -311,7 +311,6 @@
return visits.getId();
}
-
@Override
@Transactional(rollbackFor = {BusinessException.class,Exception.class})
@@ -340,7 +339,6 @@
wxPlatNotice.sendVisitTemplateNotice(systemDictDataBiz,
wxNoticeConfigMapper,visits,
Constants.equalsInteger(visits.getType(),Constants.TWO)?WxPlatConstants.visitReportContent.visitReportUpload:WxPlatConstants.visitContent.visitUpload,
- systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
Arrays.asList(systemUser.getOpenid().split(","))
);
}
@@ -567,7 +565,7 @@
.eq(ApproveParam::getLevel,Constants.ONE)
.eq(ApproveParam::getMemberType,Constants.ZERO)
.last("limit 1"));
- return Objects.isNull(approveParam)?null:approveParam.getId();
+ return Objects.isNull(approveParam)?null:approveParam.getId();
}
@@ -1044,6 +1042,7 @@
problemLog.setUserId(member.getId());
problemLog.setPhone(member.getPhone());
problemLog.setLogId(visits.getId());
+ problemLog.setCompanyName(visits.getCompanyName());
problemLogMapper.updateById(problemLog);
}
}
@@ -1570,31 +1569,42 @@
.eq(Retention::getMemberId,visits.getMemberId()));
}
- @Autowired
- private VisitParkMapper visitParkMapper;
-
- /**
- * 澶勭悊寰呭鏍搞�佸鏍镐腑銆佸凡瀹℃牳鐨勬暟鎹彇娑堜笟鍔�
- * 2025骞�3鏈�25鏃�14:10:10
- */
@Override
- public void visitsCancel(Integer visitId,LoginUserInfo loginUserInfo){
+ public void visitsSelfCancel(Integer visitId,Integer memberId){
Visits visits = visitsMapper.selectById(visitId);
if(Objects.isNull(visits)){
throw new BusinessException(ResponseStatus.DATA_EMPTY);
}
- if(!(Constants.equalsInteger(loginUserInfo.getMemberId(),visits.getMemberId()) ||
- Constants.equalsInteger(loginUserInfo.getMemberId(),visits.getCreateMemberId()) ||
- ( CollectionUtils.isNotEmpty(loginUserInfo.getPermissions()) &&
- loginUserInfo.getPermissions().stream().filter(i->i.equals("business:visits:cancel")).collect(Collectors.toList()).size()>0))){
+ if(!(Constants.equalsInteger(memberId,visits.getMemberId()))){
throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犳鎿嶄綔鏉冮檺");
}
+ this.visitsCancelBiz(visits);
+ }
+
+ @Override
+ public void visitsCancel(Integer visitId,LoginUserInfo loginUserInfo) {
+ Visits visits = visitsMapper.selectById(visitId);
+ if (Objects.isNull(visits)) {
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ if(!(
+ CollectionUtils.isNotEmpty(loginUserInfo.getPermissions()) &&
+ loginUserInfo.getPermissions().stream().filter(i->i.equals("business:visits:cancel")).collect(Collectors.toList()).size()>0)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犳鎿嶄綔鏉冮檺");
+ }
+ this.visitsCancelBiz(visits);
+ }
+ /**
+ * 澶勭悊寰呭鏍搞�佸鏍镐腑銆佸凡瀹℃牳鐨勬暟鎹彇娑堜笟鍔�
+ * 2025骞�3鏈�25鏃�14:10:10
+ */
+ public void visitsCancelBiz(Visits visits){
UpdateWrapper<Visits> updateWrapper = new UpdateWrapper();
updateWrapper.lambda().set(Visits::getStatus,Constants.VisitStatus.cancel)
.set(Visits::getEditDate,DateUtil.getCurrDateTime())
- .set(Visits::getEditor,loginUserInfo.getId())
- .eq(Visits::getId,visitId);
+ .set(Visits::getEditor,visits.getEditor())
+ .eq(Visits::getId,visits.getId());
//璁垮鎶ュ
if(Constants.equalsInteger(visits.getType(),Constants.TWO)){
if(!(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.waitCheck)||Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.submitCheck)
@@ -1603,7 +1613,7 @@
}
if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.pass)
&& Constants.equalsInteger(visits.getHkStatus(),Constants.ONE)
- &&StringUtils.isNotBlank(visits.getHkId())){
+ &&StringUtils.isNotBlank(visits.getCarNos())){
//鍙栨秷鍋滆溅鍦洪绾�
List<VisitPark> visitParkList = visitParkMapper.selectList(new QueryWrapper<VisitPark>().lambda()
.eq(VisitPark::getCarCode,visits.getCarNos())
@@ -1639,9 +1649,9 @@
}
if(Constants.equalsInteger(visits.getStatus(),Constants.VisitStatus.xfSuccess)
&& Constants.equalsInteger(visits.getHkStatus(),Constants.ONE)
- &&StringUtils.isNotBlank(visits.getHkId())){
+ &&StringUtils.isNotBlank(visits.getHkRecordId())){
VisitAppointmentCancelRequest request = new VisitAppointmentCancelRequest();
- request.setAppointRecordIds(new String[]{visits.getHkId()});
+ request.setAppointRecordIds(new String[]{visits.getHkRecordId()});
BaseResponse response = HKService.iccmCancelAppointment(request);
if(response==null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) || response.getData()==null){
throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),response.getMsg());
@@ -1649,6 +1659,53 @@
updateWrapper.lambda().set(Visits::getHkStatus,Constants.ZERO).set(Visits::getHkDate,DateUtil.getCurrDateTime());
}
}
+
+ if(Constants.equalsInteger(visits.getStatus(),Constants.ZERO)||Constants.equalsInteger(visits.getStatus(),Constants.ONE)){
+ //鏇存柊瀹℃壒涓殑璁板綍涓哄彇娑�
+ approveMapper.update(null,
+ new UpdateWrapper<Approve>().lambda()
+ .set(Approve::getEditDate,new Date())
+ .set(Approve::getStatus,Constants.approveStatus.cancel)
+ .set(Approve::getStatusInfo,"鎵嬪姩鍙栨秷")
+ .set(Approve::getCheckInfo,"鎵嬪姩鍙栨秷")
+ .eq(Approve::getIsdeleted,Constants.ZERO)
+ .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
+ .eq(Approve::getObjId,visits.getId())
+ .eq(Approve::getObjType,visits.getType()));
+ //鏇存柊寰呭姙娑堟伅鐘舵��
+ noticesJoinMapper.update(null,
+ new UpdateWrapper<Notices>().lambda()
+ .set(Notices::getEditDate,new Date())
+ .set(Notices::getInfo,"鎵嬪姩鍙栨秷")
+ .setSql(" param4 = user_id ")
+ .set(Notices::getStatus,Constants.ONE)
+ .set(Notices::getParam2,Constants.ONE)//鏍囪宸插鐞�
+ .eq(Notices::getStatus,Constants.ZERO)
+ .eq(Notices::getParam2,Constants.ZERO)//寰呭鐞�
+ .eq(Notices::getObjId,visits.getId())
+ .eq(Notices::getObjType,!Constants.equalsInteger(visits.getType(),Constants.TWO)?
+ Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting)
+ );
+
+ Approve approve = new Approve();
+ approve.setCreateDate(new Date());
+ approve.setIsdeleted(Constants.ZERO);
+ approve.setRemark("鎵嬪姩鍙栨秷");
+ approve.setChekorId(visits.getEditor());
+ approve.setTitle("鍙栨秷棰勭害");
+ approve.setStatus(Constants.THREE);
+ approve.setStatusInfo("鎵嬪姩鍙栨秷");
+ approve.setObjId(visits.getId());
+ approve.setLevel(9999);
+ approve.setApproveType(2);
+ approve.setDriverParam(Constants.ZERO);
+ approve.setAddrParam(Constants.ZERO);
+ approve.setObjType(visits.getType());
+ approve.setType(Constants.ZERO);
+ approve.setCheckDate(new Date());
+ approveMapper.insert(approve);
+ }
+
visitsMapper.update(null,updateWrapper);
}
@@ -1924,6 +1981,7 @@
List<Visits> visitsList = visitsMapper.selectList(new QueryWrapper<Visits>().lambda()
.eq(Visits::getStatus,Constants.VisitStatus.signin)
.eq(Visits::getSendTimeOutNotice,Constants.ZERO)
+ .eq(Visits::getIsdeleted,Constants.ZERO)
.apply(" now() >= DATE_ADD(ENDTIME,INTERVAL -"+times+" MINUTE) ")
);
Integer visitTimeCount = 0;
@@ -1969,9 +2027,6 @@
);
}
}
-
-
-
}
@Override
public void visitNoCheckCancel(){
@@ -1997,31 +2052,86 @@
.set(Visits::getEditDate,date)
.set(Visits::getRemark,"棰勭害鎴鏃堕棿宸茶繃鏈鎵癸紝绯荤粺鑷姩鍙栨秷")
.eq(Visits::getId,s.getId()));
- //鏇存柊瀹℃壒涓殑璁板綍涓哄彇娑�
- approveMapper.update(null,
- new UpdateWrapper<Approve>().lambda()
- .set(Approve::getEditDate,date)
- .set(Approve::getStatus,Constants.approveStatus.cancel)
- .set(Approve::getStatusInfo,"绯荤粺宸插彇娑�")
- .set(Approve::getCheckInfo,"璁块棶鏃堕棿宸茶繃锛岀郴缁熻嚜鍔ㄥ彇娑�")
- .eq(Approve::getIsdeleted,Constants.ZERO)
- .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
- .eq(Approve::getObjId,s.getId())
- .eq(Approve::getObjType,s.getType()));
- //鏇存柊寰呭姙娑堟伅鐘舵��
- noticesJoinMapper.update(null,
- new UpdateWrapper<Notices>().lambda()
- .set(Notices::getEditDate,date)
- .set(Notices::getInfo,"宸插彇娑�")
-// .set(Notices::getStatus,Constants.ONE)
- .set(Notices::getParam2,Constants.FOUR)//宸插彇娑�
- .eq(Notices::getIsdeleted,Constants.ZERO)
- .eq(Notices::getStatus,Constants.ZERO)
- .eq(Notices::getParam2,Constants.ZERO)//寰呭鐞�
- .eq(Notices::getObjId,s.getId())
- .eq(Notices::getObjType,Constants.equalsInteger(s.getType(),Constants.ZERO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting)
+
+ VisitsServiceImpl.dealCancelNoticesData(noticesJoinMapper,approveMapper,"绯荤粺鍙栨秷",s.getId(),
+ s.getType(),
+ !Constants.equalsInteger(s.getType(),Constants.TWO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting
);
+
+ Approve approve = new Approve();
+ approve.setCreateDate(new Date());
+ approve.setIsdeleted(Constants.ZERO);
+ approve.setRemark("绯荤粺鑷姩鍙栨秷");
+ approve.setTitle("鍙栨秷棰勭害");
+ approve.setStatus(Constants.THREE);
+ approve.setStatusInfo("瓒呮椂鑷姩鍙栨秷");
+ approve.setObjId(s.getId());
+ approve.setLevel(9999);
+ approve.setApproveType(2);
+ approve.setDriverParam(Constants.ZERO);
+ approve.setAddrParam(Constants.ZERO);
+ approve.setObjType(s.getType());
+ approve.setType(Constants.ZERO);
+ approve.setCheckDate(new Date());
+ approveMapper.insert(approve);
+
+// //鏇存柊瀹℃壒涓殑璁板綍涓哄彇娑�
+// approveMapper.update(null,
+// new UpdateWrapper<Approve>().lambda()
+// .set(Approve::getEditDate,date)
+// .set(Approve::getStatus,Constants.approveStatus.cancel)
+// .set(Approve::getStatusInfo,"绯荤粺宸插彇娑�")
+// .set(Approve::getCheckInfo,"璁块棶鏃堕棿宸茶繃锛岀郴缁熻嚜鍔ㄥ彇娑�")
+// .eq(Approve::getIsdeleted,Constants.ZERO)
+// .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
+// .eq(Approve::getObjId,s.getId())
+// .eq(Approve::getObjType,s.getType()));
+// //鏇存柊寰呭姙娑堟伅鐘舵��
+// noticesJoinMapper.update(null,
+// new UpdateWrapper<Notices>().lambda()
+// .set(Notices::getEditDate,date)
+// .set(Notices::getInfo,"宸插彇娑�")
+//// .set(Notices::getStatus,Constants.ONE)
+// .set(Notices::getParam2,Constants.FOUR)//宸插彇娑�
+// .eq(Notices::getIsdeleted,Constants.ZERO)
+// .eq(Notices::getStatus,Constants.ZERO)
+// .eq(Notices::getParam2,Constants.ZERO)//寰呭鐞�
+// .eq(Notices::getObjId,s.getId())
+// .eq(Notices::getObjType,Constants.equalsInteger(s.getType(),Constants.ZERO)?Constants.noticesObjectType.visit:Constants.noticesObjectType.visitReporting)
+// );
}
+ public static void dealCancelNoticesData(NoticesJoinMapper noticesJoinMapper,ApproveMapper approveMapper,String info,Integer objId,Integer approveObjectType,Integer noticesType){
+ if(Objects.nonNull(approveObjectType)){
+ approveMapper.update(null,
+ new UpdateWrapper<Approve>().lambda()
+ .set(Approve::getEditDate,new Date())
+ .set(Approve::getStatus,Constants.approveStatus.cancel)
+ .set(Approve::getStatusInfo,info)
+ .set(Approve::getCheckInfo,info)
+ .eq(Approve::getIsdeleted,Constants.ZERO)
+ .in(Approve::getStatus,Constants.approveStatus.auditIng,Constants.approveStatus.wait)
+ .eq(Approve::getObjId,objId)
+ .eq(Approve::getObjType,approveObjectType));
+ }
+ if(Objects.nonNull(noticesType)){
+ //鏇存柊寰呭姙娑堟伅鐘舵��
+ noticesJoinMapper.update(null,
+ new UpdateWrapper<Notices>().lambda()
+ .set(Notices::getEditDate,new Date())
+ .set(Notices::getInfo,"鑷姩鍙栨秷")
+ .setSql(" param4 = user_id ")
+ .set(Notices::getStatus,Constants.ONE)
+ .set(Notices::getParam2,Constants.ONE)//宸插彇娑�
+ .eq(Notices::getStatus,Constants.ZERO)
+ .eq(Notices::getParam2,Constants.ZERO)//寰呭鐞�
+ .eq(Notices::getObjId,objId)
+ .eq(Notices::getObjType,noticesType)
+ );
+ }
+ }
+
+
+
}
--
Gitblit v1.9.3