From 568e38a95cb6fb20fe16b53d17f610aefc6f744f Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期四, 09 十月 2025 18:29:29 +0800
Subject: [PATCH] 钉钉通知 与钥匙柜开发
---
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinet.java | 45 +
server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetLogCloudController.java | 14
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkKeys.java | 19
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetServiceImpl.java | 299 +++++++++----
server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetCloudController.java | 45 +
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetLogServiceImpl.java | 3
server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkKeysCloudController.java | 16
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkKeysServiceImpl.java | 147 ++++--
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java | 2
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetGridMapper.java | 4
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetGridService.java | 10
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java | 18
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarUseBook.java | 6
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Visits.java | 5
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java | 193 ++++++++-
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetGridServiceImpl.java | 175 +++++--
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkKeysMapper.java | 3
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetLogMapper.java | 3
server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetGridCloudController.java | 14
server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinetGrid.java | 18
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetService.java | 3
server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java | 180 ++++----
22 files changed, 859 insertions(+), 363 deletions(-)
diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetCloudController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetCloudController.java
index 5000734..cf0044a 100644
--- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetCloudController.java
+++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetCloudController.java
@@ -35,57 +35,64 @@
@ApiOperation("鏂板缓")
@PostMapping("/create")
@CloudRequiredPermission("business:jkcabinet:create")
- public ApiResponse create(@RequestBody JkCabinet jkCabinet) {
+ public ApiResponse create(@RequestBody JkCabinet jkCabinet,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ jkCabinet.setLoginUserInfo(this.getLoginUser(token));
return ApiResponse.success(jkCabinetService.create(jkCabinet));
}
@ApiOperation("鏍规嵁ID鍒犻櫎")
@GetMapping("/delete/{id}")
@CloudRequiredPermission("business:jkcabinet:delete")
- public ApiResponse deleteById(@PathVariable Integer id) {
+ public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkCabinetService.deleteById(id);
return ApiResponse.success(null);
}
- @ApiOperation("鎵归噺鍒犻櫎")
- @GetMapping("/delete/batch")
- @CloudRequiredPermission("business:jkcabinet:delete")
- public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
- String [] idArray = ids.split(",");
- List<Integer> idList = new ArrayList<>();
- for (String id : idArray) {
- idList.add(Integer.valueOf(id));
- }
- jkCabinetService.deleteByIdInBatch(idList);
- return ApiResponse.success(null);
- }
@ApiOperation("鏍规嵁ID淇敼")
@PostMapping("/updateById")
@CloudRequiredPermission("business:jkcabinet:update")
- public ApiResponse updateById(@RequestBody JkCabinet jkCabinet) {
+ public ApiResponse updateById(@RequestBody JkCabinet jkCabinet,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ jkCabinet.setLoginUserInfo(this.getLoginUser(token));
jkCabinetService.updateById(jkCabinet);
+ return ApiResponse.success(null);
+ }
+
+ @ApiOperation("鏍规嵁ID淇敼鐘舵��")
+ @PostMapping("/updateStatusById")
+ @CloudRequiredPermission("business:jkcabinet:update")
+ public ApiResponse updateStatusById(@RequestBody JkCabinet jkCabinet,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ jkCabinet.setLoginUserInfo(this.getLoginUser(token));
+ jkCabinetService.updateStatusById(jkCabinet);
return ApiResponse.success(null);
}
@ApiOperation("鍒嗛〉鏌ヨ")
@PostMapping("/page")
@CloudRequiredPermission("business:jkcabinet:query")
- public ApiResponse<PageData<JkCabinet>> findPage (@RequestBody PageWrap<JkCabinet> pageWrap) {
+ public ApiResponse<PageData<JkCabinet>> findPage (@RequestBody PageWrap<JkCabinet> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetService.findPage(pageWrap));
}
+
+ @ApiOperation("鍒楄〃鏌ヨ")
+ @PostMapping("/list")
+ @CloudRequiredPermission("business:jkcabinet:query")
+ public ApiResponse<List<JkCabinet>> findList (@RequestBody JkCabinet jkCabinet,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ return ApiResponse.success(jkCabinetService.findList(jkCabinet));
+ }
+
@ApiOperation("瀵煎嚭Excel")
@PostMapping("/exportExcel")
@CloudRequiredPermission("business:jkcabinet:exportExcel")
- public void exportExcel (@RequestBody PageWrap<JkCabinet> pageWrap, HttpServletResponse response) {
+ public void exportExcel (@RequestBody PageWrap<JkCabinet> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
ExcelExporter.build(JkCabinet.class).export(jkCabinetService.findPage(pageWrap).getRecords(), "閽ュ寵鏌滃熀鏈俊鎭〃", response);
}
@ApiOperation("鏍规嵁ID鏌ヨ")
@GetMapping("/{id}")
@CloudRequiredPermission("business:jkcabinet:query")
- public ApiResponse findById(@PathVariable Integer id) {
- return ApiResponse.success(jkCabinetService.findById(id));
+ public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ return ApiResponse.success(jkCabinetService.getDetail(id));
}
}
diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetGridCloudController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetGridCloudController.java
index 0b9de85..14dcffe 100644
--- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetGridCloudController.java
+++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetGridCloudController.java
@@ -35,14 +35,14 @@
@ApiOperation("鏂板缓")
@PostMapping("/create")
@CloudRequiredPermission("business:jkcabinetgrid:create")
- public ApiResponse create(@RequestBody JkCabinetGrid jkCabinetGrid) {
+ public ApiResponse create(@RequestBody JkCabinetGrid jkCabinetGrid,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetGridService.create(jkCabinetGrid));
}
@ApiOperation("鏍规嵁ID鍒犻櫎")
@GetMapping("/delete/{id}")
@CloudRequiredPermission("business:jkcabinetgrid:delete")
- public ApiResponse deleteById(@PathVariable Integer id) {
+ public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkCabinetGridService.deleteById(id);
return ApiResponse.success(null);
}
@@ -50,7 +50,7 @@
@ApiOperation("鎵归噺鍒犻櫎")
@GetMapping("/delete/batch")
@CloudRequiredPermission("business:jkcabinetgrid:delete")
- public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
+ public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
String [] idArray = ids.split(",");
List<Integer> idList = new ArrayList<>();
for (String id : idArray) {
@@ -63,7 +63,7 @@
@ApiOperation("鏍规嵁ID淇敼")
@PostMapping("/updateById")
@CloudRequiredPermission("business:jkcabinetgrid:update")
- public ApiResponse updateById(@RequestBody JkCabinetGrid jkCabinetGrid) {
+ public ApiResponse updateById(@RequestBody JkCabinetGrid jkCabinetGrid,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkCabinetGridService.updateById(jkCabinetGrid);
return ApiResponse.success(null);
}
@@ -71,21 +71,21 @@
@ApiOperation("鍒嗛〉鏌ヨ")
@PostMapping("/page")
@CloudRequiredPermission("business:jkcabinetgrid:query")
- public ApiResponse<PageData<JkCabinetGrid>> findPage (@RequestBody PageWrap<JkCabinetGrid> pageWrap) {
+ public ApiResponse<PageData<JkCabinetGrid>> findPage (@RequestBody PageWrap<JkCabinetGrid> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetGridService.findPage(pageWrap));
}
@ApiOperation("瀵煎嚭Excel")
@PostMapping("/exportExcel")
@CloudRequiredPermission("business:jkcabinetgrid:exportExcel")
- public void exportExcel (@RequestBody PageWrap<JkCabinetGrid> pageWrap, HttpServletResponse response) {
+ public void exportExcel (@RequestBody PageWrap<JkCabinetGrid> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
ExcelExporter.build(JkCabinetGrid.class).export(jkCabinetGridService.findPage(pageWrap).getRecords(), "閽ュ寵鏌滄煖鏍煎熀鏈俊鎭〃", response);
}
@ApiOperation("鏍规嵁ID鏌ヨ")
@GetMapping("/{id}")
@CloudRequiredPermission("business:jkcabinetgrid:query")
- public ApiResponse findById(@PathVariable Integer id) {
+ public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetGridService.findById(id));
}
}
diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetLogCloudController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetLogCloudController.java
index 0299c8e..b04f026 100644
--- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetLogCloudController.java
+++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkCabinetLogCloudController.java
@@ -35,14 +35,14 @@
@ApiOperation("鏂板缓")
@PostMapping("/create")
@CloudRequiredPermission("business:jkcabinetlog:create")
- public ApiResponse create(@RequestBody JkCabinetLog jkCabinetLog) {
+ public ApiResponse create(@RequestBody JkCabinetLog jkCabinetLog,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetLogService.create(jkCabinetLog));
}
@ApiOperation("鏍规嵁ID鍒犻櫎")
@GetMapping("/delete/{id}")
@CloudRequiredPermission("business:jkcabinetlog:delete")
- public ApiResponse deleteById(@PathVariable Integer id) {
+ public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkCabinetLogService.deleteById(id);
return ApiResponse.success(null);
}
@@ -50,7 +50,7 @@
@ApiOperation("鎵归噺鍒犻櫎")
@GetMapping("/delete/batch")
@CloudRequiredPermission("business:jkcabinetlog:delete")
- public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
+ public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
String [] idArray = ids.split(",");
List<Integer> idList = new ArrayList<>();
for (String id : idArray) {
@@ -63,7 +63,7 @@
@ApiOperation("鏍规嵁ID淇敼")
@PostMapping("/updateById")
@CloudRequiredPermission("business:jkcabinetlog:update")
- public ApiResponse updateById(@RequestBody JkCabinetLog jkCabinetLog) {
+ public ApiResponse updateById(@RequestBody JkCabinetLog jkCabinetLog,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkCabinetLogService.updateById(jkCabinetLog);
return ApiResponse.success(null);
}
@@ -71,21 +71,21 @@
@ApiOperation("鍒嗛〉鏌ヨ")
@PostMapping("/page")
@CloudRequiredPermission("business:jkcabinetlog:query")
- public ApiResponse<PageData<JkCabinetLog>> findPage (@RequestBody PageWrap<JkCabinetLog> pageWrap) {
+ public ApiResponse<PageData<JkCabinetLog>> findPage (@RequestBody PageWrap<JkCabinetLog> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetLogService.findPage(pageWrap));
}
@ApiOperation("瀵煎嚭Excel")
@PostMapping("/exportExcel")
@CloudRequiredPermission("business:jkcabinetlog:exportExcel")
- public void exportExcel (@RequestBody PageWrap<JkCabinetLog> pageWrap, HttpServletResponse response) {
+ public void exportExcel (@RequestBody PageWrap<JkCabinetLog> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
ExcelExporter.build(JkCabinetLog.class).export(jkCabinetLogService.findPage(pageWrap).getRecords(), "閽ュ寵鏌滃紑鍏抽棬璁板綍", response);
}
@ApiOperation("鏍规嵁ID鏌ヨ")
@GetMapping("/{id}")
@CloudRequiredPermission("business:jkcabinetlog:query")
- public ApiResponse findById(@PathVariable Integer id) {
+ public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkCabinetLogService.findById(id));
}
}
diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkKeysCloudController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkKeysCloudController.java
index 4fe9b33..b32f626 100644
--- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkKeysCloudController.java
+++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/JkKeysCloudController.java
@@ -35,14 +35,15 @@
@ApiOperation("鏂板缓")
@PostMapping("/create")
@CloudRequiredPermission("business:jkkeys:create")
- public ApiResponse create(@RequestBody JkKeys jkKeys) {
+ public ApiResponse create(@RequestBody JkKeys jkKeys,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ jkKeys.setLoginUserInfo(this.getLoginUser(token));
return ApiResponse.success(jkKeysService.create(jkKeys));
}
@ApiOperation("鏍规嵁ID鍒犻櫎")
@GetMapping("/delete/{id}")
@CloudRequiredPermission("business:jkkeys:delete")
- public ApiResponse deleteById(@PathVariable Integer id) {
+ public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
jkKeysService.deleteById(id);
return ApiResponse.success(null);
}
@@ -50,7 +51,7 @@
@ApiOperation("鎵归噺鍒犻櫎")
@GetMapping("/delete/batch")
@CloudRequiredPermission("business:jkkeys:delete")
- public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
+ public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
String [] idArray = ids.split(",");
List<Integer> idList = new ArrayList<>();
for (String id : idArray) {
@@ -63,7 +64,8 @@
@ApiOperation("鏍规嵁ID淇敼")
@PostMapping("/updateById")
@CloudRequiredPermission("business:jkkeys:update")
- public ApiResponse updateById(@RequestBody JkKeys jkKeys) {
+ public ApiResponse updateById(@RequestBody JkKeys jkKeys,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
+ jkKeys.setLoginUserInfo(this.getLoginUser(token));
jkKeysService.updateById(jkKeys);
return ApiResponse.success(null);
}
@@ -71,21 +73,21 @@
@ApiOperation("鍒嗛〉鏌ヨ")
@PostMapping("/page")
@CloudRequiredPermission("business:jkkeys:query")
- public ApiResponse<PageData<JkKeys>> findPage (@RequestBody PageWrap<JkKeys> pageWrap) {
+ public ApiResponse<PageData<JkKeys>> findPage (@RequestBody PageWrap<JkKeys> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkKeysService.findPage(pageWrap));
}
@ApiOperation("瀵煎嚭Excel")
@PostMapping("/exportExcel")
@CloudRequiredPermission("business:jkkeys:exportExcel")
- public void exportExcel (@RequestBody PageWrap<JkKeys> pageWrap, HttpServletResponse response) {
+ public void exportExcel (@RequestBody PageWrap<JkKeys> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
ExcelExporter.build(JkKeys.class).export(jkKeysService.findPage(pageWrap).getRecords(), "閽ュ寵鍩烘湰淇℃伅琛�", response);
}
@ApiOperation("鏍规嵁ID鏌ヨ")
@GetMapping("/{id}")
@CloudRequiredPermission("business:jkkeys:query")
- public ApiResponse findById(@PathVariable Integer id) {
+ public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
return ApiResponse.success(jkKeysService.findById(id));
}
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java b/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
index 0f41075..2291752 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
@@ -373,20 +373,25 @@
* api 鍦板潃 https://open.dingtalk.com/document/orgapp/asynchronous-sending-of-enterprise-session-messages
* @throws ApiException
*/
- public void workInfoOANotice(Long agentId,String userIds,OapiMessageCorpconversationAsyncsendV2Request.Msg msg)throws ApiException {
- DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2");
- OapiMessageCorpconversationAsyncsendV2Request request = new OapiMessageCorpconversationAsyncsendV2Request();
- request.setAgentId(agentId);
- request.setUseridList(userIds);
- request.setToAllUser(false);
+ public void workInfoOANotice(Long agentId,String userIds,OapiMessageCorpconversationAsyncsendV2Request.Msg msg){
+ try{
+ DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2");
+ OapiMessageCorpconversationAsyncsendV2Request request = new OapiMessageCorpconversationAsyncsendV2Request();
+ request.setAgentId(agentId);
+ request.setUseridList(userIds);
+ request.setToAllUser(false);
- request.setMsg(msg);
- OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(request, "60c2df248ca93d4eafb4a04a2330d3d3");//getToken());
- if(rsp.getErrcode().equals(Constants.DD_ERR_CODE)){
+ request.setMsg(msg);
+ OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(request, "60c2df248ca93d4eafb4a04a2330d3d3");//getToken());
+ if(rsp.getErrcode().equals(Constants.DD_ERR_CODE)){
- }else{
- throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),rsp.getMessage());
+ }else{
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),rsp.getMessage());
+ }
+ }catch (ApiException apiException){
+
}
+
}
@@ -532,79 +537,83 @@
* unionIdList 寰呭姙閫氱煡浜哄憳闆嗗悎
* @throws Exception
*/
- public String toDoNotice(String title,List<String> unionIdList,List<CreateTodoTaskRequest.CreateTodoTaskRequestContentFieldList> fieldList) throws Exception {
- com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
- CreateTodoTaskHeaders createTodoTaskHeaders = new CreateTodoTaskHeaders();
- createTodoTaskHeaders.xAcsDingtalkAccessToken = "43cf8213909f34ef81e7447905b822fb";//getToken();
- //寰呭姙鎴鍓嶇殑鎻愰啋
- CreateTodoTaskRequest.CreateTodoTaskRequestRemindNotifyConfigs remindNotifyConfigs = new CreateTodoTaskRequest.CreateTodoTaskRequestRemindNotifyConfigs()
- .setDingNotify("1")
- .setSendTodoApn("true");
- //寰呭姙閫氱煡閰嶇疆
- CreateTodoTaskRequest.CreateTodoTaskRequestNotifyConfigs notifyConfigs = new CreateTodoTaskRequest.CreateTodoTaskRequestNotifyConfigs()
- .setDingNotify("1")
- .setSendTodoApn("true")
- .setSendAssistantChat("true");
- //鎸夐挳浜嬩欢
- CreateTodoTaskRequest.CreateTodoTaskRequestActionListParam actionList0Param = new CreateTodoTaskRequest.CreateTodoTaskRequestActionListParam()
- .setBody("");
- CreateTodoTaskRequest.CreateTodoTaskRequestActionList actionList0 = new CreateTodoTaskRequest.CreateTodoTaskRequestActionList()
- .setTitle("鍘诲鐞�")
- .setActionType(2)
- .setParam(actionList0Param)
- .setUrl("https://www.baidu.com") //TODO 璇︽儏鍦板潃
- .setActionKey("ak-1-1");
- //璇︽儏椤祏rl璺宠浆鍦板潃
- CreateTodoTaskRequest.CreateTodoTaskRequestDetailUrl detailUrl = new CreateTodoTaskRequest.CreateTodoTaskRequestDetailUrl()
- .setAppUrl("https://www.baidu.com")
- .setPcUrl("https://www.baidu.com");
- CreateTodoTaskRequest createTodoTaskRequest = new CreateTodoTaskRequest()
- .setSubject(title)
- .setCreatorId(unionIdList.get(Constants.ZERO))
- .setDescription(title)
- .setExecutorIds(unionIdList)
- .setDetailUrl(detailUrl)
- .setContentFieldList(fieldList)
- .setIsOnlyShowExecutor(true)
- .setPriority(20)
- .setNotifyConfigs(notifyConfigs)
- .setActionList(java.util.Arrays.asList(actionList0))
- .setTodoType("TODO")
- .setRemindNotifyConfigs(remindNotifyConfigs);
- try {
- CreateTodoTaskResponse response = client.createTodoTaskWithOptions(unionIdList.get(Constants.ZERO), createTodoTaskRequest, createTodoTaskHeaders, new com.aliyun.teautil.models.RuntimeOptions());
- log.error("寰呭姙閫氱煡鍙戦�佹垚鍔燂紝鍙戦�佸唴瀹癸細{}"+JSONObject.toJSONString(response));
- return response.getBody().getId();
- } catch (TeaException err) {
- if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
- log.error("寰呭姙閫氱煡鍙戦�佸け璐ワ紝澶辫触鍘熷洜锛歿}"+err.message);
+ public String toDoNotice(String title,List<String> unionIdList,List<CreateTodoTaskRequest.CreateTodoTaskRequestContentFieldList> fieldList,String url) {
+ try{
+ com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
+ CreateTodoTaskHeaders createTodoTaskHeaders = new CreateTodoTaskHeaders();
+ createTodoTaskHeaders.xAcsDingtalkAccessToken = getToken();
+ //寰呭姙鎴鍓嶇殑鎻愰啋
+ CreateTodoTaskRequest.CreateTodoTaskRequestRemindNotifyConfigs remindNotifyConfigs = new CreateTodoTaskRequest.CreateTodoTaskRequestRemindNotifyConfigs()
+ .setDingNotify("1")
+ .setSendTodoApn("true");
+ //寰呭姙閫氱煡閰嶇疆
+ CreateTodoTaskRequest.CreateTodoTaskRequestNotifyConfigs notifyConfigs = new CreateTodoTaskRequest.CreateTodoTaskRequestNotifyConfigs()
+ .setDingNotify("1")
+ .setSendTodoApn("true")
+ .setSendAssistantChat("true");
+ //鎸夐挳浜嬩欢
+ CreateTodoTaskRequest.CreateTodoTaskRequestActionListParam actionList0Param = new CreateTodoTaskRequest.CreateTodoTaskRequestActionListParam()
+ .setBody("");
+ CreateTodoTaskRequest.CreateTodoTaskRequestActionList actionList0 = new CreateTodoTaskRequest.CreateTodoTaskRequestActionList()
+ .setTitle("鍘诲鐞�")
+ .setActionType(2)
+ .setParam(actionList0Param)
+ .setUrl("https://www.baidu.com") //TODO 璇︽儏鍦板潃
+ .setActionKey("ak-1-1");
+ //璇︽儏椤祏rl璺宠浆鍦板潃
+ CreateTodoTaskRequest.CreateTodoTaskRequestDetailUrl detailUrl = new CreateTodoTaskRequest.CreateTodoTaskRequestDetailUrl()
+ .setAppUrl("https://www.baidu.com")
+ .setPcUrl("https://www.baidu.com");
+ CreateTodoTaskRequest createTodoTaskRequest = new CreateTodoTaskRequest()
+ .setSubject(title)
+ .setCreatorId(unionIdList.get(Constants.ZERO))
+ .setDescription(title)
+ .setExecutorIds(unionIdList)
+ .setDetailUrl(detailUrl)
+ .setContentFieldList(fieldList)
+ .setIsOnlyShowExecutor(true)
+ .setPriority(20)
+ .setNotifyConfigs(notifyConfigs)
+ .setActionList(java.util.Arrays.asList(actionList0))
+ .setTodoType("TODO")
+ .setRemindNotifyConfigs(remindNotifyConfigs);
+ try {
+ CreateTodoTaskResponse response = client.createTodoTaskWithOptions(unionIdList.get(Constants.ZERO), createTodoTaskRequest, createTodoTaskHeaders, new com.aliyun.teautil.models.RuntimeOptions());
+ log.error("寰呭姙閫氱煡鍙戦�佹垚鍔燂紝鍙戦�佸唴瀹癸細{}"+JSONObject.toJSONString(response));
+ return response.getBody().getId();
+ } catch (TeaException err) {
+ if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
+ log.error("寰呭姙閫氱煡鍙戦�佸け璐ワ紝澶辫触鍘熷洜锛歿}"+err.message);
+ }
+ } catch (Exception _err) {
+ TeaException err = new TeaException(_err.getMessage(), _err);
+ if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
+ // err 涓惈鏈� code 鍜� message 灞炴�э紝鍙府鍔╁紑鍙戝畾浣嶉棶棰�
+ log.error("寰呭姙閫氱煡鍙戦�佸け璐ワ紝澶辫触鍘熷洜锛歿}"+err.message);
+ }
}
- } catch (Exception _err) {
- TeaException err = new TeaException(_err.getMessage(), _err);
- if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
- // err 涓惈鏈� code 鍜� message 灞炴�э紝鍙府鍔╁紑鍙戝畾浣嶉棶棰�
- log.error("寰呭姙閫氱煡鍙戦�佸け璐ワ紝澶辫触鍘熷洜锛歿}"+err.message);
- }
+ return null;
+ }catch (Exception e){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽夐拤寰呭姙浠诲姟閫氱煡鍙戦�佸け璐�");
}
- return null;
}
/**
- * 澶勭悊鍏ㄩ儴浜虹殑寰呭姙淇℃伅
+ * 澶勭悊鍏ㄩ儴浜虹殑寰呭姙淇℃伅 锛堟祦绋嬪鎵瑰畬鎴愩�佹湰绾у鎵瑰畬鎴� 浣跨敤锛�
* @param unionId
* @param taskId
* api鍦板潃 https://open.dingtalk.com/document/orgapp/updates-dingtalk-to-do-tasks
* @throws Exception
*/
- public void updToDoNoticeInfoStatus(String unionId,String taskId) throws Exception {
- com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
- UpdateTodoTaskHeaders updateTodoTaskHeaders = new UpdateTodoTaskHeaders();
- updateTodoTaskHeaders.xAcsDingtalkAccessToken = "43cf8213909f34ef81e7447905b822fb";//getToken();
- UpdateTodoTaskRequest updateTodoTaskRequest = new UpdateTodoTaskRequest()
- .setOperatorId(unionId)
- .setDone(true);
+ public void updToDoNoticeInfoStatus(String unionId,String taskId){
try {
+ com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
+ UpdateTodoTaskHeaders updateTodoTaskHeaders = new UpdateTodoTaskHeaders();
+ updateTodoTaskHeaders.xAcsDingtalkAccessToken = getToken();
+ UpdateTodoTaskRequest updateTodoTaskRequest = new UpdateTodoTaskRequest()
+ .setOperatorId(unionId)
+ .setDone(true);
UpdateTodoTaskResponse response = client.updateTodoTaskWithOptions(unionId, taskId, updateTodoTaskRequest, updateTodoTaskHeaders, new RuntimeOptions());
log.error("寰呭姙閫氱煡鍙戦�佹垚鍔燂紝鍙戦�佸唴瀹癸細{}"+JSONObject.toJSONString(response));
} catch (TeaException err) {
@@ -612,7 +621,6 @@
// err 涓惈鏈� code 鍜� message 灞炴�э紝鍙府鍔╁紑鍙戝畾浣嶉棶棰�
log.error("寰呭姙閫氱煡鍙戦�佸け璐ワ紝澶辫触鍘熷洜锛歿}"+err.message);
}
-
} catch (Exception _err) {
TeaException err = new TeaException(_err.getMessage(), _err);
if (!com.aliyun.teautil.Common.empty(err.code) && !com.aliyun.teautil.Common.empty(err.message)) {
@@ -630,18 +638,18 @@
* api 鍦板潃 https://open.dingtalk.com/document/orgapp/update-dingtalk-to-do-status
* @throws Exception
*/
- public void updUserToDoNoticeInfoStatus(String unionId,String taskId,String dealUnionId) throws Exception {
- com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
- UpdateTodoTaskExecutorStatusHeaders updateTodoTaskExecutorStatusHeaders = new UpdateTodoTaskExecutorStatusHeaders();
- updateTodoTaskExecutorStatusHeaders.xAcsDingtalkAccessToken = "43cf8213909f34ef81e7447905b822fb";//getToken();
- UpdateTodoTaskExecutorStatusRequest.UpdateTodoTaskExecutorStatusRequestExecutorStatusList executorStatusList0 = new UpdateTodoTaskExecutorStatusRequest.UpdateTodoTaskExecutorStatusRequestExecutorStatusList()
- .setId(dealUnionId)
- .setIsDone(true);
- UpdateTodoTaskExecutorStatusRequest updateTodoTaskExecutorStatusRequest = new UpdateTodoTaskExecutorStatusRequest()
- .setExecutorStatusList(java.util.Arrays.asList(
- executorStatusList0
- ));
+ public void updUserToDoNoticeInfoStatus(String unionId,String taskId,String dealUnionId){
try {
+ com.aliyun.dingtalktodo_1_0.Client client = DingTalk.createV1Client();
+ UpdateTodoTaskExecutorStatusHeaders updateTodoTaskExecutorStatusHeaders = new UpdateTodoTaskExecutorStatusHeaders();
+ updateTodoTaskExecutorStatusHeaders.xAcsDingtalkAccessToken = getToken();
+ UpdateTodoTaskExecutorStatusRequest.UpdateTodoTaskExecutorStatusRequestExecutorStatusList executorStatusList0 = new UpdateTodoTaskExecutorStatusRequest.UpdateTodoTaskExecutorStatusRequestExecutorStatusList()
+ .setId(dealUnionId)
+ .setIsDone(true);
+ UpdateTodoTaskExecutorStatusRequest updateTodoTaskExecutorStatusRequest = new UpdateTodoTaskExecutorStatusRequest()
+ .setExecutorStatusList(java.util.Arrays.asList(
+ executorStatusList0
+ ));
UpdateTodoTaskExecutorStatusResponse response = client.updateTodoTaskExecutorStatusWithOptions(unionId, taskId, updateTodoTaskExecutorStatusRequest, updateTodoTaskExecutorStatusHeaders, new RuntimeOptions());
log.error("寰呭姙閫氱煡鍙戦�佹垚鍔燂紝鍙戦�佸唴瀹癸細{}"+JSONObject.toJSONString(response));
} catch (TeaException err) {
@@ -729,10 +737,10 @@
carUseBook.setType(Constants.ZERO);
- dingTalk.workInfoOANotice(4015267031L,"1568490244651036",dingTalk.getCarUseNoticeMsg(carUseBook,"鐢ㄨ溅鐢宠"));
+// dingTalk.workInfoOANotice(4015267031L,"1568490244651036",dingTalk.getCarUseNoticeMsg(carUseBook,"鐢ㄨ溅鐢宠"));
-// dingTalk.toDoNotice("灏忚眴涓佹彁浜ょ殑鍏姟杞︾敤杞�",java.util.Arrays.asList("iPsP86axviPHiSP4nm5YgQNCQiEiE","XiPYJKRAv9eCoO4UPM20HQQiEiE","eWbHiSp3uRtrMtiiOX5LXamgiEiE") ,dingTalk.getToDoCarUseBookFiledInfo(carUseBook));
+ dingTalk.toDoNotice("灏忚眴涓佹彁浜ょ殑鍏姟杞︾敤杞�",java.util.Arrays.asList("iPsP86axviPHiSP4nm5YgQNCQiEiE","XiPYJKRAv9eCoO4UPM20HQQiEiE","eWbHiSp3uRtrMtiiOX5LXamgiEiE") ,dingTalk.getToDoCarUseBookFiledInfo(carUseBook),"");
//
// dingTalk.updUserToDoNoticeInfoStatus("iPsP86axviPHiSP4nm5YgQNCQiEiE",
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetGridMapper.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetGridMapper.java
index 69cdf93..f5e0ee8 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetGridMapper.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetGridMapper.java
@@ -2,11 +2,13 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.JkCabinetGrid;
+import com.github.yulichang.base.mapper.MPJJoinMapper;
+import com.github.yulichang.interfaces.MPJBaseJoin;
/**
* @author 姹熻箘韫�
* @date 2025/09/28 09:01
*/
-public interface JkCabinetGridMapper extends BaseMapper<JkCabinetGrid> {
+public interface JkCabinetGridMapper extends MPJJoinMapper<JkCabinetGrid> {
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetLogMapper.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetLogMapper.java
index 63566fe..4bf0c72 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetLogMapper.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkCabinetLogMapper.java
@@ -2,11 +2,12 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.JkCabinetLog;
+import com.github.yulichang.base.mapper.MPJJoinMapper;
/**
* @author 姹熻箘韫�
* @date 2025/09/28 09:01
*/
-public interface JkCabinetLogMapper extends BaseMapper<JkCabinetLog> {
+public interface JkCabinetLogMapper extends MPJJoinMapper<JkCabinetLog> {
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkKeysMapper.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkKeysMapper.java
index b854736..233ea58 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkKeysMapper.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/JkKeysMapper.java
@@ -2,11 +2,12 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.JkKeys;
+import com.github.yulichang.base.mapper.MPJJoinMapper;
/**
* @author 姹熻箘韫�
* @date 2025/09/28 09:01
*/
-public interface JkKeysMapper extends BaseMapper<JkKeys> {
+public interface JkKeysMapper extends MPJJoinMapper<JkKeys> {
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarUseBook.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarUseBook.java
index 3376b70..cc1f7cd 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarUseBook.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarUseBook.java
@@ -145,6 +145,12 @@
//@ExcelColumn(name="鍙告満缂栫爜锛堝叧鑱攎emberId锛�")
private Integer driverId;
+ @ApiModelProperty(value = "閽夐拤寰呭姙浠诲姟涓婚敭")
+ private String ddToDoId;
+
+ @ApiModelProperty(value = "閽夐拤寰呭姙浠诲姟褰掑睘浜轰富閿�")
+ private String ddBelongToUnionId;
+
@ApiModelProperty(value = "鍙告満濮撳悕", example = "1")
@TableField(exist = false)
private String driverName;
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinet.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinet.java
index 26f0b8c..e9e3f6c 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinet.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinet.java
@@ -1,5 +1,6 @@
package com.doumee.dao.business.model;
+import com.baomidou.mybatisplus.annotation.TableField;
import com.doumee.core.annotation.excel.ExcelColumn;
import com.doumee.service.business.third.model.LoginUserModel;
import io.swagger.annotations.ApiModel;
@@ -11,6 +12,7 @@
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;
import java.math.BigDecimal;
+import java.util.List;
/**
* 閽ュ寵鏌滃熀鏈俊鎭〃
@@ -73,17 +75,27 @@
@ExcelColumn(name="閫氳鍦板潃")
private String linkAddr;
- @ApiModelProperty(value = "鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭", example = "1")
- @ExcelColumn(name="鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭")
+ @ApiModelProperty(value = "鐘舵�� 0鍚敤 1绂佺敤", example = "1")
+ @ExcelColumn(name="鐘舵�� 0鍚敤 1绂佺敤")
private Integer status;
+
+ @ApiModelProperty(value = "杩愯鐘舵�� 0=鍦ㄧ嚎 1=绂荤嚎", example = "1")
+ @ExcelColumn(name="杩愯鐘舵�� 0=鍦ㄧ嚎 1=绂荤嚎")
+ private Integer runStatus;
+
@ApiModelProperty(value = "绔彛", example = "1")
@ExcelColumn(name="绔彛")
private Integer port;
- @ApiModelProperty(value = "璁惧绠$悊鍛樼紪鐮侊紙鍏宠仈member)", example = "1")
+ @ApiModelProperty(value = "璁惧绠$悊鍛樼紪鐮侊紙鍏宠仈member) 澶氫釜浠�,鍒嗗壊", example = "1")
@ExcelColumn(name="璁惧绠$悊鍛樼紪鐮侊紙鍏宠仈member)")
- private Integer managerId;
+ private String managerId;
+
+ @ApiModelProperty(value = "楠岃瘉浜虹紪鐮侊紙鍏宠仈member)", example = "1")
+ @ExcelColumn(name="楠岃瘉浜虹紪鐮侊紙鍏宠仈member)")
+ private String authMemberId;
+
@ApiModelProperty(value = "浣跨敤鏃堕暱(绉�)", example = "1")
@ExcelColumn(name="浣跨敤鏃堕暱(绉�)")
@@ -93,10 +105,6 @@
@ExcelColumn(name="鏄惁鍙岄噸楠岃瘉 0鍚� 1鏄�")
private Integer doubleAuth;
- @ApiModelProperty(value = "楠岃瘉浜虹紪鐮侊紙鍏宠仈member)", example = "1")
- @ExcelColumn(name="楠岃瘉浜虹紪鐮侊紙鍏宠仈member)")
- private Integer authMemberId;
-
@ApiModelProperty(value = "鎺掓暟", example = "1")
@ExcelColumn(name="鎺掓暟")
private Integer rowNum;
@@ -104,6 +112,10 @@
@ApiModelProperty(value = "鍒楁暟", example = "1")
@ExcelColumn(name="鍒楁暟")
private Integer columnNum;
+
+ @ApiModelProperty(value = "鎺掑簭椤哄簭锛�0=浠庡乏鍚戝彸锛�1=浠庝笂鍚戜笅", example = "1")
+ @ExcelColumn(name="鎺掑簭椤哄簭")
+ private Integer sortType;
@ApiModelProperty(value = "鏈�鍚庨�氳鏃堕棿")
@ExcelColumn(name="鏈�鍚庨�氳鏃堕棿")
@@ -138,4 +150,21 @@
@ExcelColumn(name="璧峰缂栫爜")
private Integer noIndex;
+ @ApiModelProperty(value = "缁忕含搴︿俊鎭� 鍙傛暟鍊硷細缁忓害,绾害")
+ @TableField(exist = false)
+ private String jwd;
+
+ @ApiModelProperty(value = "鏌滄牸鏁伴噺", example = "1")
+ @TableField(exist = false)
+ private Integer gridNum;
+
+ @ApiModelProperty(value = "璁惧绠$悊浜哄憳鏁扮粍", example = "1")
+ @TableField(exist = false)
+ private List<String> managerIdList;
+
+ @ApiModelProperty(value = "楠岃瘉浜虹紪鐮佹暟缁�", example = "1")
+ @TableField(exist = false)
+ private List<String> authMemberIdList;
+
+
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinetGrid.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinetGrid.java
index 35fa13a..8e30971 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinetGrid.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkCabinetGrid.java
@@ -1,5 +1,6 @@
package com.doumee.dao.business.model;
+import com.baomidou.mybatisplus.annotation.TableField;
import com.doumee.core.annotation.excel.ExcelColumn;
import com.doumee.service.business.third.model.LoginUserModel;
import io.swagger.annotations.ApiModel;
@@ -68,12 +69,23 @@
@ExcelColumn(name="搴忓垪鍙�")
private String serialNo;
- @ApiModelProperty(value = "鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭", example = "1")
- @ExcelColumn(name="鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭")
+ @ApiModelProperty(value = "鐘舵�� 0鍚敤锛�1绂佺敤", example = "1")
+ @ExcelColumn(name="鐘舵�� 0鍚敤锛�1=绂佺敤")
private Integer status;
- @ApiModelProperty(value = "杩愯鐘舵��", example = "1")
+ @ApiModelProperty(value = "杩愯鐘舵�� 0姝e父 1鏁呴殰 ", example = "1")
@ExcelColumn(name="杩愯鐘舵��")
private Integer workingStatus;
+ @ApiModelProperty(value = "缁戝畾鐘舵�� 0鏈粦瀹氾紱1宸茬粦瀹�", example = "1")
+ @TableField(exist = false)
+ private Integer bindStatus;
+
+ @ApiModelProperty(value = "閽ュ寵鏌滃悕绉�", example = "1")
+ @TableField(exist = false)
+ private String cabinetName;
+
+ @ApiModelProperty(value = "閽ュ寵缂栫爜", example = "1")
+ @TableField(exist = false)
+ private String keyCode;
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkKeys.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkKeys.java
index 2148e5c..198fb8c 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkKeys.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/JkKeys.java
@@ -1,5 +1,6 @@
package com.doumee.dao.business.model;
+import com.baomidou.mybatisplus.annotation.TableField;
import com.doumee.core.annotation.excel.ExcelColumn;
import com.doumee.service.business.third.model.LoginUserModel;
import io.swagger.annotations.ApiModel;
@@ -54,7 +55,7 @@
@ApiModelProperty(value = "閽ュ寵缂栧彿", example = "1")
@ExcelColumn(name="閽ュ寵缂栧彿")
- private Integer code;
+ private String code;
@ApiModelProperty(value = "杞︾墝鍙�")
@ExcelColumn(name="杞︾墝鍙�")
@@ -72,8 +73,20 @@
@ExcelColumn(name="棰嗗彇瑙勫垯 0闅忚溅 1闅忔淳杞﹀崟")
private Integer roleType;
- @ApiModelProperty(value = "鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭", example = "1")
- @ExcelColumn(name="鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭")
+ @ApiModelProperty(value = " 鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭 3缁翠慨淇濆吇", example = "1")
+ @ExcelColumn(name=" 鐘舵�� 0鏈粦瀹� 1鍦ㄤ綅 2鍊熷嚭 3缁翠慨淇濆吇")
private Integer status;
+ @ApiModelProperty(value = "瀛樻斁浣嶇疆", example = "1")
+ @TableField(exist = false)
+ private String gridCode;
+
+ @ApiModelProperty(value = "缁戝畾閽ュ寵鏌�", example = "1")
+ @TableField(exist = false)
+ private String cabinetName;
+
+ @ApiModelProperty(value = "鏄惁缁戝畾锛�0=鍚︼紱1=鏄紱", example = "1")
+ @TableField(exist = false)
+ private Integer isBinding;
+
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Visits.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Visits.java
index 0c23522..244311f 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Visits.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Visits.java
@@ -242,6 +242,11 @@
@ExcelColumn(name="鏂藉伐浜嬬敱")
private String constructionReason;
+ @ApiModelProperty(value = "閽夐拤寰呭姙浠诲姟涓婚敭")
+ private String ddToDoId;
+
+ @ApiModelProperty(value = "閽夐拤寰呭姙浠诲姟褰掑睘浜轰富閿�")
+ private String ddBelongToUnionId;
@ApiModelProperty(value = "鏅�氳瀹㈢敵璇烽殢璁夸汉鍛�")
@TableField(exist = false)
private List<Visits> withUserList;
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetGridService.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetGridService.java
index 508b858..f3080cd 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetGridService.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetGridService.java
@@ -1,7 +1,5 @@
package com.doumee.service.business;
-//import com.doumee.service.business.third.model.PageData;
-//import com.doumee.service.business.third.model.PageWrap;
import com.doumee.dao.business.model.JkCabinetGrid;
import com.doumee.service.business.third.model.PageData;
import com.doumee.service.business.third.model.PageWrap;
@@ -97,4 +95,12 @@
* @return long
*/
long count(JkCabinetGrid jkCabinetGrid);
+
+ /**
+ * 缁戝畾閽ュ寵
+ * @param jkCabinetGrid
+ */
+ void bindingKeys(JkCabinetGrid jkCabinetGrid);
+
+ void unBindKeys(List<Integer> idList);
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetService.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetService.java
index ad0bc17..c9f2469 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetService.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/JkCabinetService.java
@@ -48,6 +48,8 @@
*/
void updateById(JkCabinet jkCabinet);
+ void updateStatusById(JkCabinet jkCabinet);
+
/**
* 鎵归噺涓婚敭鏇存柊
*
@@ -63,6 +65,7 @@
*/
JkCabinet findById(Integer id);
+ JkCabinet getDetail(Integer id);
/**
* 鏉′欢鏌ヨ鍗曟潯璁板綍
*
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
index b352a5e..fe94066 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/ApproveServiceImpl.java
@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSONObject;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.dingTalk.DingTalk;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.BaseResponse;
@@ -124,6 +125,8 @@
private SmsEmailMapper smsEmailMapper;
@Autowired
private EmayService emayService;
+ @Autowired
+ private DingTalk dingTalk;
@Override
public Integer create(Approve approve) {
approveMapper.insert(approve);
@@ -621,6 +624,7 @@
Arrays.asList(member.getSystemOpenid().split(","))
);
}
+
}else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)){
//璁垮鎶ュ
SmsEmailServiceImpl.sendVisitReportSms(systemDictDataBiz,
@@ -659,9 +663,44 @@
}
}
}
+ }
+ }
+ if(Constants.equalsInteger(i,Constants.ZERO) && CollectionUtils.isNotEmpty(memberList)){
+ //鐢熸垚绗竴鎵归拤閽夊鎵归�氱煡淇℃伅
+ List<String> erpId = memberList.stream().filter(m->StringUtils.isNotBlank(m.getErpId())).map(m->m.getErpId()).collect(Collectors.toList());
+ if(CollectionUtils.isNotEmpty(erpId)){
+ if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.useCar)){
+ CarUseBook carUseBook = carUseBookMapper.selectJoinOne(CarUseBook.class,
+ new MPJLambdaWrapper<CarUseBook>()
+ .selectAll(CarUseBook.class)
+ .selectAs(Member::getName,CarUseBook::getMemberName)
+ .leftJoin(Member.class,Member::getId,CarUseBook::getMemberId)
+ .eq(CarUseBook::getId,businessId)
+ .last(" limit 1 ")
+ );
+ if(Objects.nonNull(carUseBook)){
+ if(CollectionUtils.isNotEmpty(erpId)){
+ String ddTalkId = dingTalk.toDoNotice(StringUtils.isNotBlank(carUseBook.getMemberName())?(carUseBook.getMemberName()+"鎻愪氦鐨勫叕鍔$敤杞︾敵璇�"):"鍏姟杞︾敤杞︾敵璇�",
+ erpId ,
+ dingTalk.getToDoCarUseBookFiledInfo(carUseBook),"pages/staff/vehicle/sendACarDetail?id="+carUseBook.getId());
+ carUseBookMapper.update(new UpdateWrapper<CarUseBook>().lambda()
+ .set(CarUseBook::getDdBelongToUnionId,erpId.get(Constants.ZERO))
+ .set(CarUseBook::getDdToDoId,ddTalkId).eq(CarUseBook::getId,carUseBook.getId()));
+ }
+ }
+ }else if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit) || Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)) {
+ Visits visits = visitsMapper.selectById(businessId);
+ if (Objects.nonNull(visits)) {
+ //TODO 缂哄皯鍩熷悕鍓嶇紑鍐呭
+ String ddTalkId = dingTalk.toDoNotice(visits.getName() + "鐨勮瀹㈢敵璇�",
+ erpId,
+ dingTalk.getToDoVisitFiledInfo(visits), "pages/appointmentDetails/appointmentDetails?id=" + visits.getId());
+ visitsMapper.update(new UpdateWrapper<Visits>().lambda()
+ .set(Visits::getDdBelongToUnionId,erpId.get(Constants.ZERO))
+ .set(Visits::getDdToDoId, ddTalkId).eq(Visits::getId, visits.getId()));
+ }
+ }
}
-
-
}
}
}
@@ -1285,6 +1324,7 @@
approveMapper.updateById(approve);
//鏄惁澶勭悊 涓氬姟鏁版嵁
Boolean dealBusinessBean = false;
+ Boolean dealDDToDo = false;
//瀹℃壒椹冲洖鎯呭喌
if(approveDTO.getStatus().equals(Constants.THREE)){
dealBusinessBean = true;
@@ -1347,7 +1387,6 @@
.in(Approve::getId,approveList.stream().map(m->m.getId()).collect(Collectors.toList())));
}
/**寮�鍚笅涓�绾у埆鐨勬暟鎹负寰呭鏍�**/
-
List<Approve> waitAuditList = approveJoinMapper.selectJoinList(Approve.class,
new MPJLambdaWrapper<Approve>()
.selectAll(Approve.class)
@@ -1383,13 +1422,17 @@
// }
}else if(approve.getApproveType().equals(Constants.ONE)){
//浼氱 涓旂粓瀹�
+ if(!Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){
+ //鏍囪閽夐拤閫氱煡鑷繁宸插鐞�
+ dealDDToDo = true;
+ }
+
//鏃犱粬浜哄鎵圭殑鎯呭喌 鍒欎慨鏀规暟鎹姸鎬�
if(Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ONE)){
dealBusinessBean = true;
}else{
if(Constants.equalsInteger(approveList.size(),Constants.ZERO)&&Constants.equalsInteger(approve.getIsEndCheck(),Constants.ZERO)){
/**寮�鍚笅涓�绾у埆鐨勬暟鎹负寰呭鏍�**/
-
List<Approve> waitAuditList = approveJoinMapper.selectJoinList(Approve.class,
new MPJLambdaWrapper<Approve>()
.selectAll(Approve.class)
@@ -1419,6 +1462,7 @@
List<String> memberPhone = waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getMemberPhone())).map(i->i.getMemberPhone()).collect(Collectors.toList());
List<String> openIdList =waitAuditList.stream().filter(i->StringUtils.isNotBlank(i.getSystemOpenid())).map(i->i.getSystemOpenid()).collect(Collectors.toList());
+
this.sendNextLvSms(approve,approveDTO,memberPhone,openIdList);
}
@@ -1428,7 +1472,7 @@
// }
}
}
- this.passNextNotices(dealBusinessBean,notices,approve,approveList,approveCopyList,approveDTO);
+ this.passNextNotices(dealBusinessBean,notices,approve,approveList,approveCopyList,approveDTO,dealDDToDo);
}
//澶勭悊涓氬姟鏁版嵁
if(dealBusinessBean){
@@ -1442,6 +1486,12 @@
public void sendNextLvSms(Approve approve ,ApproveDTO approveDTO , List<String> memberPhone ,List<String> openIdList){
WxPlatNotice wxPlatNotice = new WxPlatNotice();
//鐗╂祦杞﹂绾�
+ List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
+ .in(Member::getPhone,memberPhone)
+ .eq(Member::getIsdeleted,Constants.ZERO)
+ .eq(Member::getStatus,Constants.ZERO)
+ .isNotNull(Member::getErpId)
+ );
if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){
SmsEmailServiceImpl.sendPlatformBookSms(systemDictDataBiz,
emayService,smsEmailMapper,smsConfigMapper,platformBooksMapper,approveDTO.getObjId(),
@@ -1468,9 +1518,15 @@
SmsConstants.carUseBookContent.carUseBookWaitAudit,
approveDTO.getCheckInfo(),memberPhone);
//鍙戦�佸叕浼楀彿閫氱煡
- if(CollectionUtils.isNotEmpty(openIdList)){
- CarUseBook carUseBook = carUseBookMapper.selectById(approve.getObjId());
- if(Objects.nonNull(carUseBook)){
+ CarUseBook carUseBook = carUseBookMapper.selectJoinOne(CarUseBook.class,
+ new MPJLambdaWrapper<CarUseBook>()
+ .selectAll(CarUseBook.class)
+ .selectAs(Member::getName,CarUseBook::getMemberName)
+ .leftJoin(Member.class,Member::getId,CarUseBook::getMemberId)
+ .eq(CarUseBook::getId,approve.getObjId())
+ .last(" limit 1 ")
+ );
+ if(CollectionUtils.isNotEmpty(openIdList)&&Objects.nonNull(carUseBook)){
SystemUser systemUser = systemUserMapper.selectById(carUseBook.getCreator());
if(Objects.nonNull(systemUser)){
carUseBook.setMemberName(systemUser.getRealname());
@@ -1479,9 +1535,19 @@
wxNoticeConfigMapper,carUseBook,
WxPlatConstants.carUseBookContent.carUseBookWaitAudit,
openIdList,1);
- }
- }
+ }
}
+ //鍙戦�侀拤閽夊緟鍔� 鍏姟杞︾敵璇�
+ if(Objects.nonNull(carUseBook)&&Objects.nonNull(memberList)){
+ //鏍囪褰撳墠瀹℃壒浜哄凡瀹屾垚
+ dingTalk.updToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId());
+ //TODO 缂哄皯鍩熷悕鍓嶇紑鍐呭
+ String ddTalkId = dingTalk.toDoNotice(StringUtils.isNotBlank(carUseBook.getMemberName())?(carUseBook.getMemberName()+"鎻愪氦鐨勫叕鍔$敤杞︾敵璇�"):"鍏姟杞︾敤杞︾敵璇�",
+ memberList.stream().map(i->i.getErpId()).collect(Collectors.toList()) ,
+ dingTalk.getToDoCarUseBookFiledInfo(carUseBook),"pages/staff/vehicle/sendACarDetail?id="+carUseBook.getId());
+ carUseBookMapper.update(new UpdateWrapper<CarUseBook>().lambda()
+ .set(CarUseBook::getDdToDoId,ddTalkId).eq(CarUseBook::getId,carUseBook.getId()));
+ }
}else
//璁垮鐢宠/鎶ュ
if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit)
@@ -1506,6 +1572,16 @@
openIdList
);
}
+ if(Objects.nonNull(visits)&&Objects.nonNull(memberList)){
+ //鏍囪褰撳墠瀹℃壒浜哄凡瀹屾垚
+ dingTalk.updToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId());
+ //TODO 缂哄皯鍩熷悕鍓嶇紑鍐呭
+ String ddTalkId = dingTalk.toDoNotice(visits.getName()+"鐨勮瀹㈢敵璇�",
+ memberList.stream().map(i->i.getErpId()).collect(Collectors.toList()) ,
+ dingTalk.getToDoVisitFiledInfo(visits),"pages/appointmentDetails/appointmentDetails?id="+visits.getId());
+ visitsMapper.update(new UpdateWrapper<Visits>().lambda()
+ .set(Visits::getDdToDoId,ddTalkId).eq(Visits::getId,visits.getId()));
+ }
}
}
@@ -1518,15 +1594,15 @@
* @param dealBusinessBean 鏄惁闇�瑕佽繘琛屾洿鏂颁笟鍔℃暟鎹姸鎬�
* @param approve 瀹℃壒璁板綍
* @param approveList 鍚岀骇寰呭鎵规暟鎹�
+ * @param dealDDToDo 鏄惁澶勭悊 褰撳墠瀹℃壒淇℃伅浜虹殑閽夐拤鐨勫伐浣滈�氱煡
+ *
*/
- public void passNextNotices(Boolean dealBusinessBean,Notices notices,Approve approve,List<Approve> approveList,List<Approve> copyList,ApproveDTO approveDTO){
+ public void passNextNotices(Boolean dealBusinessBean,Notices notices,Approve approve,List<Approve> approveList,List<Approve> copyList,ApproveDTO approveDTO,Boolean dealDDToDo){
//鏈紑鍚笅涓�绾ф椂锛屾搷浣滃悗鐨勫緟瀹℃壒浜�
String memberNames =notices.getParam5()
.replaceAll(","+notices.getRemark(),"")
.replaceAll(notices.getRemark()+",","")
.replaceAll(notices.getRemark(),"");
-
-
//1銆佷慨鏀硅嚜宸辩殑鏁版嵁璁板綍
noticesJoinMapper.update(null,new UpdateWrapper<Notices>().lambda()
@@ -1607,6 +1683,30 @@
}
}
}
+ if(dealDDToDo){
+ if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit)
+ ||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit)
+ ||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)) {
+ Member member = memberMapper.selectById(approve.getChekorId());
+ // 璁垮 涓夌被涓氬姟鏁版嵁
+ Visits visits = visitsMapper.selectById(approveDTO.getObjId());
+ if(Objects.nonNull(member)&&Objects.nonNull(member.getErpId())
+ &&Objects.nonNull(visits)&&Objects.nonNull(visits.getDdToDoId())&&Objects.nonNull(visits.getDdBelongToUnionId())){
+ dingTalk.updUserToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId(),member.getErpId());
+ }
+ }else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals(
+ Constants.approveObjectType.unCityUseCar)){
+ Member member = memberMapper.selectById(approve.getChekorId());
+ CarUseBook carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId());
+ if(Objects.nonNull(member)&&Objects.nonNull(member.getErpId())
+ &&Objects.nonNull(carUseBook)&&Objects.nonNull(carUseBook.getDdToDoId())&&Objects.nonNull(carUseBook.getDdBelongToUnionId())){
+ dingTalk.updUserToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId(),member.getErpId());
+ }
+ }
+
+
+
+ }
}
@@ -1654,11 +1754,13 @@
public void dealBusinessData(ApproveDTO approveDTO,Approve approve){
WxPlatNotice wxPlatNotice = new WxPlatNotice();
+ Visits visits = new Visits();
+ CarUseBook carUseBook = new CarUseBook();
if(approveDTO.getObjType().equals(Constants.approveObjectType.unConstructionVisit)
||approveDTO.getObjType().equals(Constants.approveObjectType.constructionVisit)
||approveDTO.getObjType().equals(Constants.approveObjectType.visitReporting)){
// 璁垮 涓夌被涓氬姟鏁版嵁
- Visits visits = visitsMapper.selectById(approveDTO.getObjId());
+ visits = visitsMapper.selectById(approveDTO.getObjId());
if(Objects.isNull(visits)){
throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"鏈煡璇㈠埌鐢宠璁板綍");
}
@@ -1762,12 +1864,25 @@
Arrays.asList(visits.getOpenid().split(","))
);
}
+ //閽夐拤閫氱煡 璁垮琚浜烘垨鎶ュ鎻愪氦浜�
+ Member beVisitMember = memberMapper.selectById(Constants.equalsInteger(visits.getType(),Constants.TWO)?visits.getMemberId():visits.getReceptMemberId());
+ if(Objects.nonNull(beVisitMember)&&StringUtils.isNotBlank(beVisitMember.getDdId())){
+ dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
+ beVisitMember.getDdId(),
+ dingTalk.getVisitNoticeMsg(visits,visits.getName()+"鐨�"+(Constants.equalsInteger(visits.getType(),Constants.TWO)?"璁垮鎶ュ":"璁垮鐢宠")+"锛�"+
+ (Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? "宸插鎵归�氳繃":"宸插鎵归┏鍥�"))
+ );
+ }
}
-
+ if(StringUtils.isNotBlank(visits.getDdBelongToUnionId())
+ && StringUtils.isNotBlank(visits.getDdToDoId())){
+ //鏍囪褰撳墠閽夐拤瀹℃壒宸插畬鎴�
+ dingTalk.updToDoNoticeInfoStatus(visits.getDdBelongToUnionId(),visits.getDdToDoId());
+ }
}else if(approveDTO.getObjType().equals(Constants.approveObjectType.cityUseCar)||approveDTO.getObjType().equals(
Constants.approveObjectType.unCityUseCar)){
this.updDriver(approveDTO,approve,true);
- CarUseBook carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId());
+ carUseBook = carUseBookJoinMapper.selectById(approveDTO.getObjId());
if(Objects.nonNull(carUseBook)){
SystemUser systemUser = systemUserMapper.selectById(carUseBook.getCreator());
//鍙戦�侀�氱煡鐭伅
@@ -1787,6 +1902,20 @@
Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)?WxPlatConstants.carUseBookContent.carUseBookAuditSuccess: WxPlatConstants.carUseBookContent.carUseBookAuditFail,
Arrays.asList(systemUser.getOpenid().split(",")),0);
}
+ }
+ //閽夐拤閫氱煡鍙戣捣浜�
+ Member creatMember = memberMapper.selectById(carUseBook.getMemberId());
+ if(Objects.nonNull(creatMember)&&StringUtils.isNotBlank(creatMember.getDdId())){
+ dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
+ creatMember.getErpId(),
+ dingTalk.getCarUseNoticeMsg(carUseBook,carUseBook.getMemberName() + "鎻愪氦鐨勫叕鍔$敤杞︼紝"+
+ (Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? "宸插鎵归�氳繃":"宸插鎵归┏鍥�"))
+ );
+ }
+ if(StringUtils.isNotBlank(carUseBook.getDdBelongToUnionId())
+ && StringUtils.isNotBlank(carUseBook.getDdToDoId())){
+ //鏍囪褰撳墠閽夐拤瀹℃壒宸插畬鎴�
+ dingTalk.updToDoNoticeInfoStatus(carUseBook.getDdBelongToUnionId(),carUseBook.getDdToDoId());
}
}else if(approveDTO.getObjType().equals(Constants.approveObjectType.reason)){
@@ -1862,13 +1991,33 @@
throw new BusinessException(ResponseStatus.BAD_REQUEST);
}
if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)){
- //澶勭悊閫氳繃 鏄剧ず鎵�鏈夌殑鎶勯�佽褰�
- approveMapper.update(null,new UpdateWrapper<Approve>().lambda().set(Approve::getStatus,Constants.TWO)
- .set(Approve::getCheckDate,new Date())
- .eq(Approve::getObjId,approve.getObjId())
+ List<Approve> approveList = approveMapper.selectList(new QueryWrapper<Approve>().lambda().eq(Approve::getObjId,approve.getObjId())
.eq(Approve::getObjType,approve.getObjType())
- .eq(Approve::getType,Constants.ONE)
- );
+ .eq(Approve::getType,Constants.ONE));
+ if(CollectionUtils.isNotEmpty(approveList)){
+ //澶勭悊閫氳繃 鏄剧ず鎵�鏈夌殑鎶勯�佽褰�
+ approveMapper.update(null,new UpdateWrapper<Approve>().lambda().set(Approve::getStatus,Constants.TWO)
+ .set(Approve::getCheckDate,new Date())
+ .eq(Approve::getObjId,approve.getObjId())
+ .eq(Approve::getObjType,approve.getObjType())
+ .eq(Approve::getType,Constants.ONE)
+ );
+ List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
+ .eq(Member::getIsdeleted,Constants.ZERO)
+ .eq(Member::getStatus,Constants.ZERO)
+ .isNotNull(Member::getDdId)
+ .in(Member::getId,approveList.stream().map(i->i.getChekorId()).collect(Collectors.toList())));
+ if(CollectionUtils.isNotEmpty(memberList)){
+ if(Objects.nonNull(visits)||Objects.nonNull(carUseBook)){
+ dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
+ StringUtils.join(memberList.stream().map(i->i.getDdId()).collect(Collectors.toList()),","),
+ Objects.nonNull(visits)?
+ dingTalk.getVisitNoticeMsg(visits,visits.getName()+"鐨�"+(Constants.equalsInteger(visits.getType(),Constants.TWO)?"璁垮鎶ュ":"璁垮鐢宠")+"锛屾妱閫佺粰鎮紝璇风煡鏅�"):
+ dingTalk.getCarUseNoticeMsg(carUseBook,carUseBook.getMemberName() + "鎻愪氦鐨勫叕鍔$敤杞︼紝鎶勯�佺粰鎮紝璇风煡鏅�")
+ );
+ }
+ }
+ }
}
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
index 7db1430..bc8fae7 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/HiddenDangerServiceImpl.java
@@ -7,6 +7,7 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.dingTalk.DingTalk;
import com.doumee.core.exception.BusinessException;
import com.doumee.dao.business.dao.*;
import com.doumee.dao.business.vo.GeneralDataVO;
@@ -98,6 +99,9 @@
@Autowired
private ApproveMapper approveMapper;
+
+ @Autowired
+ private DingTalk dingTalk;
@Override
@@ -247,6 +251,13 @@
systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
Arrays.asList(checkUser.getOpenid().split(",")));
}
+
+ if(StringUtils.isNotBlank(member.getDdId())){
+ dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
+ member.getDdId(),
+ dingTalk.getHiddenDangerNoticeMsg(hiddenDanger));
+ }
+
return hiddenDanger.getId();
}
@@ -794,6 +805,13 @@
systemDictDataBiz.queryByCode(Constants.WX_PLATFORM,Constants.WX_PLATFORM_ACCESS_TOKEN).getCode(),
Arrays.asList(checkUser.getOpenid().split(",")));
}
+
+ if(StringUtils.isNotBlank(member.getDdId())){
+ dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
+ member.getDdId(),
+ dingTalk.getHiddenDangerNoticeMsg(hiddenDanger));
+ }
+
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetGridServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetGridServiceImpl.java
index d197518..0cdc384 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetGridServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetGridServiceImpl.java
@@ -1,5 +1,14 @@
package com.doumee.service.business.impl;
+import com.alibaba.druid.sql.visitor.functions.Concat;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.dao.business.JkKeysMapper;
+import com.doumee.dao.business.model.Cars;
+import com.doumee.dao.business.model.JkCabinet;
+import com.doumee.dao.business.model.JkKeys;
import com.doumee.service.business.third.model.PageData;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.JkCabinetGridMapper;
@@ -10,11 +19,17 @@
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.service.business.third.model.PageWrap;
+import com.github.yulichang.toolkit.MPJWrappers;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
-import org.springframework.util.CollectionUtils;
+import com.github.xiaoymin.knife4j.core.util.CollectionUtils;
+import org.springframework.transaction.annotation.Transactional;
import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
/**
* 閽ュ寵鏌滄煖鏍煎熀鏈俊鎭〃Service瀹炵幇
@@ -26,6 +41,9 @@
@Autowired
private JkCabinetGridMapper jkCabinetGridMapper;
+
+ @Autowired
+ private JkKeysMapper jkKeysMapper;
@Override
public Integer create(JkCabinetGrid jkCabinetGrid) {
@@ -87,57 +105,25 @@
@Override
public PageData<JkCabinetGrid> findPage(PageWrap<JkCabinetGrid> pageWrap) {
IPage<JkCabinetGrid> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
- QueryWrapper<JkCabinetGrid> queryWrapper = new QueryWrapper<>();
Utils.MP.blankToNull(pageWrap.getModel());
- if (pageWrap.getModel().getId() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getId, pageWrap.getModel().getId());
+ JkCabinetGrid model = pageWrap.getModel();
+ MPJLambdaWrapper<JkCabinetGrid> wrapper = new MPJLambdaWrapper<JkCabinetGrid>()
+ .selectAll(JkCabinetGrid.class)
+ .selectAs(JkCabinet::getName,JkCabinetGrid::getCabinetName)
+ .selectAs(JkKeys::getCode,JkCabinetGrid::getKeyCode)
+ .leftJoin(JkCabinet.class,JkCabinet::getId,JkCabinetGrid::getCabinetId)
+ .leftJoin(JkKeys.class,JkKeys::getId,JkCabinetGrid::getKeyId)
+ .eq(JkCabinetGrid::getIsdeleted,Constants.ZERO)
+ .eq(Objects.nonNull(model.getCabinetId()),JkCabinetGrid::getCabinetId,model.getCabinetId())
+ .eq(Objects.nonNull(model.getStatus()),JkCabinetGrid::getStatus,model.getStatus())
+ .isNull(Objects.nonNull(model.getBindStatus())&&Constants.equalsInteger(model.getBindStatus(),Constants.ZERO),JkCabinetGrid::getKeyId)
+ .isNotNull(Objects.nonNull(model.getBindStatus())&&Constants.equalsInteger(model.getBindStatus(),Constants.ONE),JkCabinetGrid::getKeyId)
+ .like(StringUtils.isNotBlank(model.getKeyCode()),JkKeys::getCode,model.getKeyCode());
+ IPage<JkCabinetGrid> iPage = jkCabinetGridMapper.selectJoinPage(page,JkCabinetGrid.class,wrapper);
+ for (JkCabinetGrid jkCabinetGrid:iPage.getRecords()) {
+ jkCabinetGrid.setBindStatus(Objects.isNull(jkCabinetGrid.getKeyId())?Constants.ZERO:Constants.ONE);
}
- if (pageWrap.getModel().getCreator() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getCreator, pageWrap.getModel().getCreator());
- }
- if (pageWrap.getModel().getCreateDate() != null) {
- queryWrapper.lambda().ge(JkCabinetGrid::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
- queryWrapper.lambda().le(JkCabinetGrid::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
- }
- if (pageWrap.getModel().getEditor() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getEditor, pageWrap.getModel().getEditor());
- }
- if (pageWrap.getModel().getEditDate() != null) {
- queryWrapper.lambda().ge(JkCabinetGrid::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
- queryWrapper.lambda().le(JkCabinetGrid::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
- }
- if (pageWrap.getModel().getIsdeleted() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getIsdeleted, pageWrap.getModel().getIsdeleted());
- }
- if (pageWrap.getModel().getInfo() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getInfo, pageWrap.getModel().getInfo());
- }
- if (pageWrap.getModel().getCabinetId() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getCabinetId, pageWrap.getModel().getCabinetId());
- }
- if (pageWrap.getModel().getCode() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getCode, pageWrap.getModel().getCode());
- }
- if (pageWrap.getModel().getKeyId() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getKeyId, pageWrap.getModel().getKeyId());
- }
- if (pageWrap.getModel().getSerialNo() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getSerialNo, pageWrap.getModel().getSerialNo());
- }
- if (pageWrap.getModel().getStatus() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getStatus, pageWrap.getModel().getStatus());
- }
- if (pageWrap.getModel().getWorkingStatus() != null) {
- queryWrapper.lambda().eq(JkCabinetGrid::getWorkingStatus, pageWrap.getModel().getWorkingStatus());
- }
- for(PageWrap.SortData sortData: pageWrap.getSorts()) {
- if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
- queryWrapper.orderByDesc(sortData.getProperty());
- } else {
- queryWrapper.orderByAsc(sortData.getProperty());
- }
- }
- return PageData.from(jkCabinetGridMapper.selectPage(page, queryWrapper));
+ return PageData.from(iPage);
}
@Override
@@ -145,4 +131,93 @@
QueryWrapper<JkCabinetGrid> wrapper = new QueryWrapper<>(jkCabinetGrid);
return jkCabinetGridMapper.selectCount(wrapper);
}
+
+ @Override
+ public void bindingKeys(JkCabinetGrid jkCabinetGrid){
+ if(Objects.isNull(jkCabinetGrid)
+ || Objects.isNull(jkCabinetGrid.getId())
+ || Objects.isNull(jkCabinetGrid.getKeyId())){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ JkCabinetGrid model = jkCabinetGridMapper.selectById(jkCabinetGrid.getId());
+ if(Objects.isNull(model)|| Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ if(Objects.nonNull(model.getKeyId())){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"宸茬粦瀹氾紝璇峰嬁閲嶅缁戝畾");
+ }
+ JkKeys keysModel = jkKeysMapper.selectById(jkCabinetGrid.getKeyId());
+ if(Objects.isNull(keysModel)|| Constants.equalsInteger(keysModel.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ if(!Constants.equalsInteger(keysModel.getStatus(), (Constants.ZERO))){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵宸茶缁戝畾锛岃閫夋嫨鍏朵粬閽ュ寵缁戝畾");
+ }
+ //鏇存柊閽ュ寵鏌滀俊鎭�
+ jkCabinetGridMapper.update(new UpdateWrapper<JkCabinetGrid>().lambda()
+ .set(JkCabinetGrid::getKeyId,jkCabinetGrid.getKeyId())
+ .set(JkCabinetGrid::getEditDate, DateUtil.getCurrDateTime())
+ .eq(JkCabinetGrid::getId,jkCabinetGrid.getId()));
+ //鏍囪閽ュ寵淇℃伅
+ jkKeysMapper.update(new UpdateWrapper<JkKeys>().lambda()
+ .set(JkKeys::getStatus,Constants.ONE)
+ .eq(JkKeys::getId,jkCabinetGrid.getKeyId())
+ );
+ }
+
+
+
+ @Override
+ @Transactional(rollbackFor = {Exception.class,BusinessException.class})
+ public void unBindKeys(List<Integer> idList){
+ if(CollectionUtils.isEmpty(idList)){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ if(idList.size()==Constants.ONE){
+ JkCabinetGrid model = jkCabinetGridMapper.selectById(idList.get(Constants.ZERO));
+ if(Objects.isNull(model)|| Constants.equalsInteger(model.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ if(Objects.isNull(model.getKeyId())){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠瑙勬牸鏈粦瀹氶挜鍖欙紝璇峰埛鏂版煡鐪�");
+ }else{
+ //鏇存柊閽ュ寵鏌滀俊鎭�
+ jkCabinetGridMapper.update(new UpdateWrapper<JkCabinetGrid>().lambda()
+ .set(JkCabinetGrid::getKeyId,null)
+ .set(JkCabinetGrid::getEditDate, DateUtil.getCurrDateTime())
+ .eq(JkCabinetGrid::getId,model.getId()));
+ JkKeys keysModel = jkKeysMapper.selectById(model.getKeyId());
+ if(Objects.nonNull(keysModel) && !Constants.equalsInteger(keysModel.getStatus(),Constants.ZERO)){
+ jkKeysMapper.update(new UpdateWrapper<JkKeys>().lambda()
+ .set(JkKeys::getStatus,Constants.ZERO)
+ .eq(JkKeys::getId,keysModel.getId())
+ );
+ }
+ }
+ }else{
+ List<JkCabinetGrid> jkCabinetGridList = jkCabinetGridMapper.selectList(new QueryWrapper<JkCabinetGrid>().lambda()
+ .eq(JkCabinetGrid::getIsdeleted,Constants.ZERO)
+ .isNotNull(JkCabinetGrid::getKeyId)
+ .in(JkCabinetGrid::getId,idList));
+ if(CollectionUtils.isNotEmpty(jkCabinetGridList)){
+ jkCabinetGridMapper.update(new UpdateWrapper<JkCabinetGrid>().lambda()
+ .set(JkCabinetGrid::getKeyId,null)
+ .set(JkCabinetGrid::getEditDate, DateUtil.getCurrDateTime())
+ .eq(JkCabinetGrid::getId,jkCabinetGridList.stream().map(i->i.getId()).collect(Collectors.toList())));
+ List<Integer> keyIdList = jkCabinetGridList.stream().filter(i->Objects.nonNull(i.getKeyId())).map(i->i.getKeyId()).collect(Collectors.toList());
+ if(CollectionUtils.isNotEmpty(keyIdList)){
+ jkKeysMapper.update(new UpdateWrapper<JkKeys>().lambda()
+ .set(JkKeys::getStatus,Constants.ZERO)
+ .in(JkKeys::getId,keyIdList)
+ );
+ }
+
+ }
+ }
+ }
+
+
+
+
+
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetLogServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetLogServiceImpl.java
index bb3b8da..4b57d27 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetLogServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetLogServiceImpl.java
@@ -89,6 +89,9 @@
IPage<JkCabinetLog> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
QueryWrapper<JkCabinetLog> queryWrapper = new QueryWrapper<>();
Utils.MP.blankToNull(pageWrap.getModel());
+ JkCabinetLog model = pageWrap.getModel();
+
+
if (pageWrap.getModel().getId() != null) {
queryWrapper.lambda().eq(JkCabinetLog::getId, pageWrap.getModel().getId());
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetServiceImpl.java
index be0bceb..36b38ff 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkCabinetServiceImpl.java
@@ -1,5 +1,14 @@
package com.doumee.service.business.impl;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.DateUtil;
+import com.doumee.dao.business.JkCabinetGridMapper;
+import com.doumee.dao.business.JkKeysMapper;
+import com.doumee.dao.business.model.JkCabinetGrid;
+import com.doumee.dao.business.model.JkKeys;
+import com.doumee.service.business.third.model.LoginUserInfo;
import com.doumee.service.business.third.model.PageData;
import com.doumee.service.business.third.model.PageWrap;
import com.doumee.core.utils.Utils;
@@ -10,11 +19,15 @@
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
-import java.util.List;
+import java.math.BigDecimal;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* 閽ュ寵鏌滃熀鏈俊鎭〃Service瀹炵幇
@@ -27,15 +40,118 @@
@Autowired
private JkCabinetMapper jkCabinetMapper;
+ @Autowired
+ private JkCabinetGridMapper jkCabinetGridMapper;
+
+ @Autowired
+ private JkKeysMapper jkKeysMapper;
+
@Override
+ @Transactional(rollbackFor = {Exception.class,BusinessException.class})
public Integer create(JkCabinet jkCabinet) {
+ if(Objects.isNull(jkCabinet)
+ || StringUtils.isBlank(jkCabinet.getCode())
+ || StringUtils.isBlank(jkCabinet.getName())
+ || StringUtils.isBlank(jkCabinet.getDevId())
+ || StringUtils.isBlank(jkCabinet.getLinkAddr())
+ || StringUtils.isBlank(jkCabinet.getCode())
+
+ || Objects.isNull(jkCabinet.getPort())
+ || CollectionUtils.isEmpty(jkCabinet.getManagerIdList())
+ || CollectionUtils.isEmpty(jkCabinet.getAuthMemberIdList())
+ || Objects.isNull(jkCabinet.getDoubleAuth())
+
+ || Objects.isNull(jkCabinet.getRowNum())
+ || jkCabinet.getRowNum() <= Constants.ZERO
+ || Objects.isNull(jkCabinet.getColumnNum())
+ || jkCabinet.getColumnNum() <= Constants.ZERO
+ || Objects.isNull(jkCabinet.getNoType())
+ || Objects.isNull(jkCabinet.getSortType())
+ || (
+ Constants.equalsInteger(jkCabinet.getNoType(),Constants.ONE)
+ && ( Objects.isNull(jkCabinet.getNoIndex()) || Objects.isNull(jkCabinet.getNoLength()) || StringUtils.isBlank(jkCabinet.getNoPrefix()) )
+ )
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ //鏌ヨ缂栧彿鏄惁閲嶅
+ if(jkCabinetMapper.selectCount(new QueryWrapper<JkCabinet>().lambda().eq(JkCabinet::getCode,jkCabinet.getCode()).eq(JkCabinet::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵鏌滆澶囩紪鍙峰凡瀛樺湪锛�");
+ }
+ if(jkCabinetMapper.selectCount(new QueryWrapper<JkCabinet>().lambda().eq(JkCabinet::getDevId,jkCabinet.getDevId()).eq(JkCabinet::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵鏌滆澶嘔D宸插瓨鍦紒");
+ }
+ LoginUserInfo loginUserInfo = jkCabinet.getLoginUserInfo();
+ jkCabinet.setCreateDate(new Date());
+ jkCabinet.setEditDate(jkCabinet.getCreateDate());
+ jkCabinet.setCreator(loginUserInfo.getId());
+ jkCabinet.setEditor(loginUserInfo.getId());
+ jkCabinet.setIsdeleted(Constants.ZERO);
+ jkCabinet.setStatus(Constants.ZERO);
+ jkCabinet.setRunStatus(Constants.ONE);
+ if(StringUtils.isNotBlank(jkCabinet.getJwd())&&jkCabinet.getJwd().split(",").length>Constants.ONE){
+ jkCabinet.setLongitude(new BigDecimal(jkCabinet.getJwd().split(",")[Constants.ZERO]));
+ jkCabinet.setLatitude(new BigDecimal(jkCabinet.getJwd().split(",")[Constants.ONE]));
+ }
+ jkCabinet.setManagerId(String.join(",",jkCabinet.getManagerIdList()));
+ jkCabinet.setAuthMemberId(String.join(",",jkCabinet.getAuthMemberIdList()));
jkCabinetMapper.insert(jkCabinet);
+ this.createGrid(jkCabinet);
return jkCabinet.getId();
+ }
+
+
+ public void createGrid(JkCabinet jkCabinet){
+ LoginUserInfo loginUserInfo = jkCabinet.getLoginUserInfo();
+ Integer startNo = Constants.equalsInteger(jkCabinet.getNoType(),Constants.ZERO)?1:jkCabinet.getNoIndex() ;
+ List<JkCabinetGrid> jkCabinetGridList = new ArrayList<>();
+ Integer maxNum = jkCabinet.getRowNum() * jkCabinet.getColumnNum();
+ for (int i = 0; i < maxNum; i++) {
+ JkCabinetGrid grid = new JkCabinetGrid();
+ grid.setCreateDate(new Date());
+ grid.setEditDate(jkCabinet.getCreateDate());
+ grid.setCreator(loginUserInfo.getId());
+ grid.setEditor(loginUserInfo.getId());
+ grid.setIsdeleted(Constants.ZERO);
+ grid.setStatus(Constants.ZERO);
+ grid.setCabinetId(jkCabinet.getId());
+ if(Constants.equalsInteger(jkCabinet.getNoType(),Constants.ZERO)){
+ grid.setCode(StringUtils.leftPad(startNo.toString(),maxNum.toString().length()+1,"0"));
+ }else{
+ grid.setCode(jkCabinet.getNoPrefix() + StringUtils.leftPad(startNo.toString(),jkCabinet.getNoLength(),"0"));
+ }
+
+ jkCabinetGridList.add(grid);
+ startNo = startNo + 1;
+ }
+ jkCabinetGridMapper.insert(jkCabinetGridList);
}
@Override
public void deleteById(Integer id) {
- jkCabinetMapper.deleteById(id);
+ JkCabinet jkCabinet = jkCabinetMapper.selectById(id);
+ if(Constants.equalsInteger(jkCabinet.getStatus(),Constants.ZERO)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"闈炵鐢ㄦ暟鎹紝鏃犳硶杩涜鍒犻櫎");
+ }
+ //鏌ヨ閽ュ寵鏌滀笅鐨勬煖鏍间俊鎭�
+ List<JkCabinetGrid> jkCabinetGridList = jkCabinetGridMapper.selectList(new QueryWrapper<JkCabinetGrid>().lambda().eq(JkCabinetGrid::getIsdeleted,Constants.ZERO)
+ .eq(JkCabinetGrid::getCabinetId,jkCabinet.getId())
+ );
+ if(Objects.nonNull(jkCabinetGridList)){
+ jkCabinetGridMapper.update(null,new UpdateWrapper<JkCabinetGrid>().lambda().set(JkCabinetGrid::getIsdeleted,Constants.ONE)
+ .in(JkCabinetGrid::getId,jkCabinetGridList.stream().map(i->i.getId()).collect(Collectors.toList()))
+ );
+ List<Integer> keyIdList = jkCabinetGridList.stream().filter(i->Objects.nonNull(i.getKeyId())).map(i->i.getKeyId()).collect(Collectors.toList());
+ if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(keyIdList)){
+ jkKeysMapper.update(null,new UpdateWrapper<JkKeys>().lambda()
+ .set(JkKeys::getStatus,Constants.ZERO)
+ .in(JkKeys::getId,keyIdList)
+ );
+ }
+ }
+ jkCabinetMapper.update(null,new UpdateWrapper<JkCabinet>().lambda()
+ .set(JkCabinet::getIsdeleted,Constants.ONE)
+ .eq(JkCabinet::getId,jkCabinet.getId()));
}
@Override
@@ -54,8 +170,59 @@
@Override
public void updateById(JkCabinet jkCabinet) {
+ if(Objects.isNull(jkCabinet)
+ || Objects.isNull(jkCabinet.getId())
+ || StringUtils.isBlank(jkCabinet.getCode())
+ || StringUtils.isBlank(jkCabinet.getName())
+ || StringUtils.isBlank(jkCabinet.getDevId())
+ || StringUtils.isBlank(jkCabinet.getLinkAddr())
+ || StringUtils.isBlank(jkCabinet.getCode())
+ || CollectionUtils.isEmpty(jkCabinet.getManagerIdList())
+ || CollectionUtils.isEmpty(jkCabinet.getAuthMemberIdList())
+ || Objects.isNull(jkCabinet.getPort())
+ || Objects.isNull(jkCabinet.getDoubleAuth())
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ jkCabinet.setRowNum(null);
+ jkCabinet.setColumnNum(null);
+ jkCabinet.setSortType(null);
+ jkCabinet.setNoType(null);
+ jkCabinet.setNoIndex(null);
+ jkCabinet.setNoLength(null);
+ jkCabinet.setNoPrefix(null);
+ //鏌ヨ缂栧彿鏄惁閲嶅
+ if(jkCabinetMapper.selectCount(new QueryWrapper<JkCabinet>().lambda().ne(JkCabinet::getId,jkCabinet.getId()).eq(JkCabinet::getCode,jkCabinet.getCode()).eq(JkCabinet::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵鏌滆澶囩紪鍙峰凡瀛樺湪锛�");
+ }
+ if(jkCabinetMapper.selectCount(new QueryWrapper<JkCabinet>().lambda().ne(JkCabinet::getId,jkCabinet.getId()).eq(JkCabinet::getDevId,jkCabinet.getDevId()).eq(JkCabinet::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵鏌滆澶嘔D宸插瓨鍦紒");
+ }
+ LoginUserInfo loginUserInfo = jkCabinet.getLoginUserInfo();
+ jkCabinet.setEditDate(new Date());
+ jkCabinet.setEditor(loginUserInfo.getId());
+ if(StringUtils.isNotBlank(jkCabinet.getJwd())&&jkCabinet.getJwd().split(",").length>Constants.ONE){
+ jkCabinet.setLongitude(new BigDecimal(jkCabinet.getJwd().split(",")[Constants.ZERO]));
+ jkCabinet.setLatitude(new BigDecimal(jkCabinet.getJwd().split(",")[Constants.ONE]));
+ }
+ jkCabinet.setManagerId(String.join(",",jkCabinet.getManagerIdList()));
+ jkCabinet.setAuthMemberId(String.join(",",jkCabinet.getAuthMemberIdList()));
jkCabinetMapper.updateById(jkCabinet);
}
+
+ @Override
+ public void updateStatusById(JkCabinet jkCabinet) {
+ if(Objects.isNull(jkCabinet)
+ || Objects.isNull(jkCabinet.getId())
+ || Objects.isNull(jkCabinet.getStatus())){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ jkCabinetMapper.update(null,new UpdateWrapper<JkCabinet>()
+ .lambda().set(JkCabinet::getStatus,jkCabinet.getStatus())
+ .set(JkCabinet::getEditDate, DateUtil.getCurrDateTime())
+ .eq(JkCabinet::getId,jkCabinet.getId()));
+ }
+
@Override
public void updateByIdInBatch(List<JkCabinet> jkCabinets) {
@@ -72,6 +239,18 @@
return jkCabinetMapper.selectById(id);
}
+
+ @Override
+ public JkCabinet getDetail(Integer id){
+ JkCabinet jkCabinet = jkCabinetMapper.selectById(id);
+ if(Objects.nonNull(jkCabinet.getLongitude())
+ && Objects.nonNull(jkCabinet.getLatitude())){
+ jkCabinet.setJwd(jkCabinet.getLongitude() + "," + jkCabinet.getLatitude());
+ }
+ jkCabinet.setGridNum(jkCabinet.getColumnNum()*jkCabinet.getRowNum());
+ return jkCabinet;
+ }
+
@Override
public JkCabinet findOne(JkCabinet jkCabinet) {
QueryWrapper<JkCabinet> wrapper = new QueryWrapper<>(jkCabinet);
@@ -80,6 +259,8 @@
@Override
public List<JkCabinet> findList(JkCabinet jkCabinet) {
+ jkCabinet.setIsdeleted(Constants.ZERO);
+ jkCabinet.setStatus(Constants.ZERO);
QueryWrapper<JkCabinet> wrapper = new QueryWrapper<>(jkCabinet);
return jkCabinetMapper.selectList(wrapper);
}
@@ -87,103 +268,20 @@
@Override
public PageData<JkCabinet> findPage(PageWrap<JkCabinet> pageWrap) {
IPage<JkCabinet> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
- QueryWrapper<JkCabinet> queryWrapper = new QueryWrapper<>();
Utils.MP.blankToNull(pageWrap.getModel());
- if (pageWrap.getModel().getId() != null) {
- queryWrapper.lambda().eq(JkCabinet::getId, pageWrap.getModel().getId());
+ JkCabinet model = pageWrap.getModel();
+ IPage<JkCabinet> iPage = jkCabinetMapper.selectPage(page, new QueryWrapper<JkCabinet>()
+ .lambda()
+ .eq(JkCabinet::getIsdeleted,Constants.ZERO)
+ .like(StringUtils.isNotBlank(model.getName()),JkCabinet::getName, model.getName())
+ .like(StringUtils.isNotBlank(model.getCode()),JkCabinet::getCode, model.getCode())
+ .eq(Objects.nonNull(model.getStatus()),JkCabinet::getStatus, model.getStatus())
+ .eq(Objects.nonNull(model.getRunStatus()),JkCabinet::getRunStatus, model.getRunStatus())
+ );
+ for (JkCabinet jkCabinet:iPage.getRecords()) {
+ jkCabinet.setGridNum(jkCabinet.getColumnNum()*jkCabinet.getRowNum());
}
- if (pageWrap.getModel().getCreator() != null) {
- queryWrapper.lambda().eq(JkCabinet::getCreator, pageWrap.getModel().getCreator());
- }
- if (pageWrap.getModel().getCreateDate() != null) {
- queryWrapper.lambda().ge(JkCabinet::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
- queryWrapper.lambda().le(JkCabinet::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
- }
- if (pageWrap.getModel().getEditor() != null) {
- queryWrapper.lambda().eq(JkCabinet::getEditor, pageWrap.getModel().getEditor());
- }
- if (pageWrap.getModel().getEditDate() != null) {
- queryWrapper.lambda().ge(JkCabinet::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
- queryWrapper.lambda().le(JkCabinet::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
- }
- if (pageWrap.getModel().getIsdeleted() != null) {
- queryWrapper.lambda().eq(JkCabinet::getIsdeleted, pageWrap.getModel().getIsdeleted());
- }
- if (pageWrap.getModel().getInfo() != null) {
- queryWrapper.lambda().eq(JkCabinet::getInfo, pageWrap.getModel().getInfo());
- }
- if (pageWrap.getModel().getCode() != null) {
- queryWrapper.lambda().eq(JkCabinet::getCode, pageWrap.getModel().getCode());
- }
- if (pageWrap.getModel().getName() != null) {
- queryWrapper.lambda().eq(JkCabinet::getName, pageWrap.getModel().getName());
- }
- if (pageWrap.getModel().getDevId() != null) {
- queryWrapper.lambda().eq(JkCabinet::getDevId, pageWrap.getModel().getDevId());
- }
- if (pageWrap.getModel().getSerialNo() != null) {
- queryWrapper.lambda().eq(JkCabinet::getSerialNo, pageWrap.getModel().getSerialNo());
- }
- if (pageWrap.getModel().getLinkAddr() != null) {
- queryWrapper.lambda().eq(JkCabinet::getLinkAddr, pageWrap.getModel().getLinkAddr());
- }
- if (pageWrap.getModel().getStatus() != null) {
- queryWrapper.lambda().eq(JkCabinet::getStatus, pageWrap.getModel().getStatus());
- }
- if (pageWrap.getModel().getPort() != null) {
- queryWrapper.lambda().eq(JkCabinet::getPort, pageWrap.getModel().getPort());
- }
- if (pageWrap.getModel().getManagerId() != null) {
- queryWrapper.lambda().eq(JkCabinet::getManagerId, pageWrap.getModel().getManagerId());
- }
- if (pageWrap.getModel().getUseTime() != null) {
- queryWrapper.lambda().eq(JkCabinet::getUseTime, pageWrap.getModel().getUseTime());
- }
- if (pageWrap.getModel().getDoubleAuth() != null) {
- queryWrapper.lambda().eq(JkCabinet::getDoubleAuth, pageWrap.getModel().getDoubleAuth());
- }
- if (pageWrap.getModel().getAuthMemberId() != null) {
- queryWrapper.lambda().eq(JkCabinet::getAuthMemberId, pageWrap.getModel().getAuthMemberId());
- }
- if (pageWrap.getModel().getRowNum() != null) {
- queryWrapper.lambda().eq(JkCabinet::getRowNum, pageWrap.getModel().getRowNum());
- }
- if (pageWrap.getModel().getColumnNum() != null) {
- queryWrapper.lambda().eq(JkCabinet::getColumnNum, pageWrap.getModel().getColumnNum());
- }
- if (pageWrap.getModel().getHaertTime() != null) {
- queryWrapper.lambda().ge(JkCabinet::getHaertTime, Utils.Date.getStart(pageWrap.getModel().getHaertTime()));
- queryWrapper.lambda().le(JkCabinet::getHaertTime, Utils.Date.getEnd(pageWrap.getModel().getHaertTime()));
- }
- if (pageWrap.getModel().getLocation() != null) {
- queryWrapper.lambda().eq(JkCabinet::getLocation, pageWrap.getModel().getLocation());
- }
- if (pageWrap.getModel().getLongitude() != null) {
- queryWrapper.lambda().eq(JkCabinet::getLongitude, pageWrap.getModel().getLongitude());
- }
- if (pageWrap.getModel().getLatitude() != null) {
- queryWrapper.lambda().eq(JkCabinet::getLatitude, pageWrap.getModel().getLatitude());
- }
- if (pageWrap.getModel().getNoType() != null) {
- queryWrapper.lambda().eq(JkCabinet::getNoType, pageWrap.getModel().getNoType());
- }
- if (pageWrap.getModel().getNoPrefix() != null) {
- queryWrapper.lambda().eq(JkCabinet::getNoPrefix, pageWrap.getModel().getNoPrefix());
- }
- if (pageWrap.getModel().getNoLength() != null) {
- queryWrapper.lambda().eq(JkCabinet::getNoLength, pageWrap.getModel().getNoLength());
- }
- if (pageWrap.getModel().getNoIndex() != null) {
- queryWrapper.lambda().eq(JkCabinet::getNoIndex, pageWrap.getModel().getNoIndex());
- }
- for(PageWrap.SortData sortData: pageWrap.getSorts()) {
- if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
- queryWrapper.orderByDesc(sortData.getProperty());
- } else {
- queryWrapper.orderByAsc(sortData.getProperty());
- }
- }
- return PageData.from(jkCabinetMapper.selectPage(page, queryWrapper));
+ return PageData.from(iPage);
}
@Override
@@ -191,4 +289,11 @@
QueryWrapper<JkCabinet> wrapper = new QueryWrapper<>(jkCabinet);
return jkCabinetMapper.selectCount(wrapper);
}
+
+
+
+
+
+
+
}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkKeysServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkKeysServiceImpl.java
index dcb7279..e80144f 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkKeysServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/JkKeysServiceImpl.java
@@ -1,5 +1,13 @@
package com.doumee.service.business.impl;
+import com.doumee.core.constants.ResponseStatus;
+import com.doumee.core.exception.BusinessException;
+import com.doumee.core.utils.Constants;
+import com.doumee.dao.business.CarsMapper;
+import com.doumee.dao.business.model.Cars;
+import com.doumee.dao.business.model.JkCabinet;
+import com.doumee.dao.business.model.JkCabinetGrid;
+import com.doumee.service.business.third.model.LoginUserInfo;
import com.doumee.service.business.third.model.PageData;
import com.doumee.service.business.third.model.PageWrap;
import com.doumee.core.utils.Utils;
@@ -10,11 +18,16 @@
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.github.yulichang.interfaces.MPJBaseJoin;
+import com.github.yulichang.wrapper.MPJLambdaWrapper;
+import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
+import java.util.Date;
import java.util.List;
+import java.util.Objects;
/**
* 閽ュ寵鍩烘湰淇℃伅琛⊿ervice瀹炵幇
@@ -27,14 +40,55 @@
@Autowired
private JkKeysMapper jkKeysMapper;
+ @Autowired
+ private CarsMapper carsMapper;
+
@Override
public Integer create(JkKeys jkKeys) {
+ if(Objects.isNull(jkKeys)
+ || Objects.isNull(jkKeys.getCarId())
+ || Objects.isNull(jkKeys.getRoleType())
+ || StringUtils.isBlank(jkKeys.getCode())
+ || StringUtils.isBlank(jkKeys.getRfidLable())
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ //鏌ヨ缂栧彿鏄惁閲嶅
+ if(jkKeysMapper.selectCount(new QueryWrapper<JkKeys>().lambda().eq(JkKeys::getCode,jkKeys.getCode()).eq(JkKeys::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵缂栧彿宸插瓨鍦紒");
+ }
+ Cars cars = carsMapper.selectById(jkKeys.getCarId());
+ if(Objects.isNull(cars)||Constants.equalsInteger(cars.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"杞﹁締淇℃伅鏈煡璇㈠埌锛�");
+ }
+ JkKeys carsKeys = jkKeysMapper.selectOne(new QueryWrapper<JkKeys>().lambda().eq(JkKeys::getCarId,jkKeys.getCarId()).eq(JkKeys::getIsdeleted,Constants.ZERO).last("limit 1"));
+ if(Objects.nonNull(carsKeys)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠杞﹁締宸茶閽ュ寵["+carsKeys.getCode()+"]缁戝畾浣跨敤锛�");
+ }
+ JkKeys rfidKeys = jkKeysMapper.selectOne(new QueryWrapper<JkKeys>().lambda().eq(JkKeys::getRfidLable,jkKeys.getRfidLable()).eq(JkKeys::getIsdeleted,Constants.ZERO).last("limit 1"));
+ if(Objects.nonNull(rfidKeys)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠RFID鏍囩宸茶閽ュ寵["+rfidKeys.getCode()+"]浣跨敤锛�");
+ }
+ LoginUserInfo loginUserInfo = jkKeys.getLoginUserInfo();
+ jkKeys.setCreateDate(new Date());
+ jkKeys.setEditDate(jkKeys.getCreateDate());
+ jkKeys.setCreator(loginUserInfo.getId());
+ jkKeys.setEditor(loginUserInfo.getId());
+ jkKeys.setIsdeleted(Constants.ZERO);
+ jkKeys.setStatus(Constants.ZERO);
jkKeysMapper.insert(jkKeys);
return jkKeys.getId();
}
@Override
public void deleteById(Integer id) {
+ JkKeys jkKeys = jkKeysMapper.selectById(id);
+ if(Objects.isNull(jkKeys)||Constants.equalsInteger(jkKeys.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.DATA_EMPTY);
+ }
+ if(!Constants.equalsInteger(jkKeys.getStatus(),Constants.ZERO)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵宸茬粦瀹�,鏃犳硶杩涜鍒犻櫎");
+ }
jkKeysMapper.deleteById(id);
}
@@ -54,6 +108,34 @@
@Override
public void updateById(JkKeys jkKeys) {
+ if(Objects.isNull(jkKeys)
+ || Objects.isNull(jkKeys.getId())
+ || Objects.isNull(jkKeys.getCarId())
+ || Objects.isNull(jkKeys.getRoleType())
+ || StringUtils.isBlank(jkKeys.getCode())
+ || StringUtils.isBlank(jkKeys.getRfidLable())
+ ){
+ throw new BusinessException(ResponseStatus.BAD_REQUEST);
+ }
+ //鏌ヨ缂栧彿鏄惁閲嶅
+ if(jkKeysMapper.selectCount(new QueryWrapper<JkKeys>().lambda().ne(JkKeys::getId,jkKeys.getId()).eq(JkKeys::getCode,jkKeys.getCode()).eq(JkKeys::getIsdeleted,Constants.ZERO))>Constants.ZERO){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽ュ寵缂栧彿宸插瓨鍦紒");
+ }
+ Cars cars = carsMapper.selectById(jkKeys.getCarId());
+ if(Objects.isNull(cars)||Constants.equalsInteger(cars.getIsdeleted(),Constants.ONE)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"杞﹁締淇℃伅鏈煡璇㈠埌锛�");
+ }
+ JkKeys carsKeys = jkKeysMapper.selectOne(new QueryWrapper<JkKeys>().lambda().ne(JkKeys::getId,jkKeys.getId()).eq(JkKeys::getCarId,jkKeys.getCarId()).eq(JkKeys::getIsdeleted,Constants.ZERO).last("limit 1"));
+ if(Objects.nonNull(carsKeys)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠杞﹁締宸茶閽ュ寵["+carsKeys.getCode()+"]缁戝畾浣跨敤锛�");
+ }
+ JkKeys rfidKeys = jkKeysMapper.selectOne(new QueryWrapper<JkKeys>().lambda().ne(JkKeys::getId,jkKeys.getId()).eq(JkKeys::getRfidLable,jkKeys.getRfidLable()).eq(JkKeys::getIsdeleted,Constants.ZERO).last("limit 1"));
+ if(Objects.nonNull(rfidKeys)){
+ throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"褰撳墠RFID鏍囩宸茶閽ュ寵["+rfidKeys.getCode()+"]浣跨敤锛�");
+ }
+ LoginUserInfo loginUserInfo = jkKeys.getLoginUserInfo();
+ jkKeys.setEditDate(new Date());
+ jkKeys.setEditor(loginUserInfo.getId());
jkKeysMapper.updateById(jkKeys);
}
@@ -89,57 +171,26 @@
IPage<JkKeys> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
QueryWrapper<JkKeys> queryWrapper = new QueryWrapper<>();
Utils.MP.blankToNull(pageWrap.getModel());
- if (pageWrap.getModel().getId() != null) {
- queryWrapper.lambda().eq(JkKeys::getId, pageWrap.getModel().getId());
+ JkKeys model = pageWrap.getModel();
+ MPJLambdaWrapper<JkKeys> wrapper = new MPJLambdaWrapper<JkKeys>()
+ .selectAll(JkKeys.class)
+ .selectAs(JkCabinetGrid::getCode,JkKeys::getGridCode)
+ .selectAs(JkCabinet::getName,JkKeys::getCabinetName)
+ .leftJoin(Cars.class,Cars::getId,JkKeys::getCarId)
+ .leftJoin(JkCabinetGrid.class,JkCabinetGrid::getKeyId,JkKeys::getId)
+ .leftJoin(JkCabinet.class,JkCabinet::getId,JkCabinetGrid::getCabinetId)
+ .eq(JkKeys::getIsdeleted,Constants.ZERO)
+ .like(StringUtils.isNotBlank(model.getCode()),JkKeys::getCode,model.getCode())
+ .like(StringUtils.isNotBlank(model.getCarCode()),JkKeys::getCarCode,model.getCode());
+ IPage<JkKeys> iPage = jkKeysMapper.selectJoinPage(page,JkKeys.class,wrapper);
+ for (JkKeys jkKeys:iPage.getRecords()) {
+ jkKeys.setIsBinding(StringUtils.isBlank(jkKeys.getGridCode())?Constants.ZERO:Constants.ONE);
}
- if (pageWrap.getModel().getCreator() != null) {
- queryWrapper.lambda().eq(JkKeys::getCreator, pageWrap.getModel().getCreator());
- }
- if (pageWrap.getModel().getCreateDate() != null) {
- queryWrapper.lambda().ge(JkKeys::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
- queryWrapper.lambda().le(JkKeys::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
- }
- if (pageWrap.getModel().getEditor() != null) {
- queryWrapper.lambda().eq(JkKeys::getEditor, pageWrap.getModel().getEditor());
- }
- if (pageWrap.getModel().getEditDate() != null) {
- queryWrapper.lambda().ge(JkKeys::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
- queryWrapper.lambda().le(JkKeys::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
- }
- if (pageWrap.getModel().getIsdeleted() != null) {
- queryWrapper.lambda().eq(JkKeys::getIsdeleted, pageWrap.getModel().getIsdeleted());
- }
- if (pageWrap.getModel().getInfo() != null) {
- queryWrapper.lambda().eq(JkKeys::getInfo, pageWrap.getModel().getInfo());
- }
- if (pageWrap.getModel().getCode() != null) {
- queryWrapper.lambda().eq(JkKeys::getCode, pageWrap.getModel().getCode());
- }
- if (pageWrap.getModel().getCarCode() != null) {
- queryWrapper.lambda().eq(JkKeys::getCarCode, pageWrap.getModel().getCarCode());
- }
- if (pageWrap.getModel().getCarId() != null) {
- queryWrapper.lambda().eq(JkKeys::getCarId, pageWrap.getModel().getCarId());
- }
- if (pageWrap.getModel().getRfidLable() != null) {
- queryWrapper.lambda().eq(JkKeys::getRfidLable, pageWrap.getModel().getRfidLable());
- }
- if (pageWrap.getModel().getRoleType() != null) {
- queryWrapper.lambda().eq(JkKeys::getRoleType, pageWrap.getModel().getRoleType());
- }
- if (pageWrap.getModel().getStatus() != null) {
- queryWrapper.lambda().eq(JkKeys::getStatus, pageWrap.getModel().getStatus());
- }
- for(PageWrap.SortData sortData: pageWrap.getSorts()) {
- if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
- queryWrapper.orderByDesc(sortData.getProperty());
- } else {
- queryWrapper.orderByAsc(sortData.getProperty());
- }
- }
- return PageData.from(jkKeysMapper.selectPage(page, queryWrapper));
+ return PageData.from(iPage);
}
+
+
@Override
public long count(JkKeys jkKeys) {
QueryWrapper<JkKeys> wrapper = new QueryWrapper<>(jkKeys);
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
index bc1b948..40f62c5 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
@@ -2491,7 +2491,7 @@
if(Objects.nonNull(deptIdList)){
List<Company> companyList = companyMapper.selectList(new QueryWrapper<Company>().lambda().in(Company::getErpId,deptIdList)
.eq(Company::getType,Constants.ONE).eq(Company::getIsdeleted,Constants.ZERO)
-// .isNotNull(Company::getHkId) 鏆傛椂鏃犳硶鍚屾寮�鑸� 鍏堟敞閲�
+// .isNotNull(Company::getHkId) 鏆傛椂鏃犳硶鍚屾娴峰悍 鍏堟敞閲�
);
if(CollectionUtils.isNotEmpty(companyList)){
member.setHkOrgId(companyList.get(Constants.ZERO).getHkId());
--
Gitblit v1.9.3