wulin/wl_management
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

发送消息抽出

Browse Source
This commit is contained in:
wulin 2020-08-26 11:16:43 +08:00
parent 0eed89529b
commit def6370ace
2 changed files with 22 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/com/lz/modules/app/controller/ResultRecordController.java
View File

@ -319,8 +319,7 @@ public class ResultRecordController extends AbstractController {
r = R.ok("成功") r = R.ok("成功")
.put("from", mySelf) .put("from", mySelf)
.put("to", mySelf) .put("to", mySelf)
.put("type", WorkMsgTypeEnum.REJECT) .put("type", WorkMsgTypeEnum.REJECT);
.put("count", 1);
} }
} }
resultCommentService.addOrUpdateComment(req, getUserId(), status); resultCommentService.addOrUpdateComment(req, getUserId(), status);
@ -330,20 +329,7 @@ public class ResultRecordController extends AbstractController {
StaffEntity mySelf = (StaffEntity)r.get("from"); StaffEntity mySelf = (StaffEntity)r.get("from");
StaffEntity toSelf = (StaffEntity)r.get("to"); StaffEntity toSelf = (StaffEntity)r.get("to");
WorkMsgTypeEnum workMsgTypeEnum = (WorkMsgTypeEnum)r.get("type"); WorkMsgTypeEnum workMsgTypeEnum = (WorkMsgTypeEnum)r.get("type");
String url = domain + "/management/dingtalklogin?url=";//免登接口 sendWorkMSG(mySelf, toSelf, workMsgTypeEnum, req.getRecordResultId(), 1);
String jump;
if((int)r.get("count") == 1){//一个提交
logger.info("单个提交推送消息");
jump = domain + "/management/recorddetail?id=" + req.getRecordResultId()
+ "&recordType=3" ;//跳转接口
}else{//批量提交
logger.info("批量提交推送消息");
jump = domain + "/management/result-record-lzresultrecordapp";//跳转接口
}
jump = URLEncoder.encode(jump);
String msg = dingtalkBusiness.sendWorkMSGByEntity(appid, mySelf, toSelf, workMsgTypeEnum, url + jump);
logger.info("发送钉钉工作消息{}", msg);
return R.ok("成功"); return R.ok("成功");
} }
return r; return r;
@ -354,6 +340,24 @@ public class ResultRecordController extends AbstractController {
//return r != null ? r : R.ok("成功"); //return r != null ? r : R.ok("成功");
} }
private void sendWorkMSG(StaffEntity mySelf, StaffEntity toSelf, WorkMsgTypeEnum workMsgTypeEnum
, Long recordResultId, int count){
String url = domain + "/management/dingtalklogin?url=";//免登接口
String jump;
if(count == 1){//一个提交
logger.info("单个提交推送消息");
jump = domain + "/management/recorddetail?id=" + recordResultId
+ "&recordType=3" ;//跳转接口
}else{//批量提交
logger.info("批量提交推送消息");
jump = domain + "/management/result-record-lzresultrecordapp";//跳转接口
}
jump = URLEncoder.encode(jump);
String msg = dingtalkBusiness.sendWorkMSGByEntity(appid, mySelf, toSelf, workMsgTypeEnum, url + jump);
logger.info("发送钉钉工作消息{}", msg);
}
/** /**
* 信息 * 信息
*/ */

6
src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
View File

@ -374,8 +374,7 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
return R.ok("流程审批结束") return R.ok("流程审批结束")
.put("from", staff) .put("from", staff)
.put("to", staff) .put("to", staff)
.put("type", WorkMsgTypeEnum.PASS) .put("type", WorkMsgTypeEnum.PASS);
.put("count", 1);
} }
FlowRecord flowRecord = new FlowRecord(); FlowRecord flowRecord = new FlowRecord();
@ -434,8 +433,7 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
return R.ok("提交审批成功") return R.ok("提交审批成功")
.put("from", staff) .put("from", staff)
.put("to", approvalStaff) .put("to", approvalStaff)
.put("type", WorkMsgTypeEnum.SUBMIT) .put("type", WorkMsgTypeEnum.SUBMIT);
.put("count", staffRoleDtos.size());
} }
@Override @Override