|
@@ -9,6 +9,7 @@ import com.iamberry.rst.core.page.PagedResult;
|
|
import com.iamberry.rst.core.sys.Admin;
|
|
import com.iamberry.rst.core.sys.Admin;
|
|
import com.iamberry.rst.faces.approval.ApplyPickService;
|
|
import com.iamberry.rst.faces.approval.ApplyPickService;
|
|
import com.iamberry.rst.faces.approval.ApprovalOrderService;
|
|
import com.iamberry.rst.faces.approval.ApprovalOrderService;
|
|
|
|
+import com.iamberry.rst.faces.approval.ApprovalProductionService;
|
|
import com.iamberry.rst.faces.approval.ApprovalTaskService;
|
|
import com.iamberry.rst.faces.approval.ApprovalTaskService;
|
|
import com.iamberry.rst.faces.sys.SysService;
|
|
import com.iamberry.rst.faces.sys.SysService;
|
|
import com.iamberry.wechat.core.entity.WechatUtils;
|
|
import com.iamberry.wechat.core.entity.WechatUtils;
|
|
@@ -51,6 +52,8 @@ public class ApprovalController {
|
|
private SysService sysService;
|
|
private SysService sysService;
|
|
@Autowired
|
|
@Autowired
|
|
private ApplyPickService applyPickService;
|
|
private ApplyPickService applyPickService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private ApprovalProductionService approvalProductionService;
|
|
@SuppressWarnings("restriction")
|
|
@SuppressWarnings("restriction")
|
|
private BASE64Decoder decoder = new BASE64Decoder();
|
|
private BASE64Decoder decoder = new BASE64Decoder();
|
|
/**
|
|
/**
|
|
@@ -377,6 +380,9 @@ public class ApprovalController {
|
|
if(approvalInfo == null){
|
|
if(approvalInfo == null){
|
|
return ResponseJson.getFAILURE();
|
|
return ResponseJson.getFAILURE();
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ approvalInfo = approvalOrderService.getApprovalInfoById(approvalInfo.getApprovalId());
|
|
|
|
+
|
|
//获取openid,根据openid查询当前登录人信息
|
|
//获取openid,根据openid查询当前登录人信息
|
|
String openId = WechatUtils.getUserBySession(request).getUserOpenid();
|
|
String openId = WechatUtils.getUserBySession(request).getUserOpenid();
|
|
Admin admin = sysService.getByOpenid(openId);
|
|
Admin admin = sysService.getByOpenid(openId);
|
|
@@ -406,22 +412,30 @@ public class ApprovalController {
|
|
//修改审核历史记录状态为已通过
|
|
//修改审核历史记录状态为已通过
|
|
historicalRecord.setRecordState(2);
|
|
historicalRecord.setRecordState(2);
|
|
if(approvalOrderService.updateHistoricalRecord(historicalRecord) < 1){
|
|
if(approvalOrderService.updateHistoricalRecord(historicalRecord) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改审核历史记录状态失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//查询当前审核人当前审核任务信息
|
|
//查询当前审核人当前审核任务信息
|
|
HistoricalRecord record = approvalOrderService.getHistoricalRecord(historicalRecord);
|
|
HistoricalRecord record = approvalOrderService.getHistoricalRecord(historicalRecord);
|
|
if(record == null){
|
|
if(record == null){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("查询当前审核人当前审核任务信息为空!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//获取下一个审核人,并添加审核历史信息
|
|
//获取下一个审核人,并添加审核历史信息
|
|
Map<String, Object> taskMap = approvalTaskService.completeTask(approvalInfo.getActivitiId(),record.getTaskId());
|
|
Map<String, Object> taskMap = approvalTaskService.completeTask(approvalInfo.getActivitiId(),record.getTaskId());
|
|
if(taskMap == null){
|
|
if(taskMap == null){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("获取下一个审核人,并添加审核历史信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
if((Integer) taskMap.get("status") == 1){//没有下一个审批人,修改审批任务状态为已审批通过
|
|
if((Integer) taskMap.get("status") == 1){//没有下一个审批人,修改审批任务状态为已审批通过
|
|
info.setApprovalStatus(2);
|
|
info.setApprovalStatus(2);
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改审批信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//判断是生产审批或提货审批
|
|
//判断是生产审批或提货审批
|
|
if(info.getApprovalType() == 1){
|
|
if(info.getApprovalType() == 1){
|
|
@@ -432,7 +446,9 @@ public class ApprovalController {
|
|
admininfo.setAdminId(production.getApplicantId());
|
|
admininfo.setAdminId(production.getApplicantId());
|
|
admininfo = sysService.getAdminInfo(admininfo);
|
|
admininfo = sysService.getAdminInfo(admininfo);
|
|
if(admininfo.getAdminOpenId() == null ){
|
|
if(admininfo.getAdminOpenId() == null ){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("获取管理信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//通知申请人该审批已通过
|
|
//通知申请人该审批已通过
|
|
SendMessageUtil sendMessageUtil = new SendMessageUtil();
|
|
SendMessageUtil sendMessageUtil = new SendMessageUtil();
|
|
@@ -490,14 +506,18 @@ public class ApprovalController {
|
|
|
|
|
|
}else if((Integer) taskMap.get("status") == 0){//还有下一个审批人,需要增加审批历史任务
|
|
}else if((Integer) taskMap.get("status") == 0){//还有下一个审批人,需要增加审批历史任务
|
|
if(taskMap.get("users") == null){
|
|
if(taskMap.get("users") == null){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("获取下一个审批人失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
String[] split = (String[])taskMap.get("users");
|
|
String[] split = (String[])taskMap.get("users");
|
|
for (String name : split){
|
|
for (String name : split){
|
|
//通过name查询管理员id
|
|
//通过name查询管理员id
|
|
Admin approvalAdmin = sysService.getByName(name);
|
|
Admin approvalAdmin = sysService.getByName(name);
|
|
if(approvalAdmin == null){
|
|
if(approvalAdmin == null){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("查询管理员失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
|
|
|
|
HistoricalRecord recordInfo = new HistoricalRecord();
|
|
HistoricalRecord recordInfo = new HistoricalRecord();
|
|
@@ -506,12 +526,16 @@ public class ApprovalController {
|
|
recordInfo.setRecordState(1);
|
|
recordInfo.setRecordState(1);
|
|
recordInfo.setTaskId(taskMap.get("taskId").toString());
|
|
recordInfo.setTaskId(taskMap.get("taskId").toString());
|
|
if(approvalOrderService.insertHistoricalRecord(recordInfo) < 1){
|
|
if(approvalOrderService.insertHistoricalRecord(recordInfo) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("添加历史审批人失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//修改审核信息表
|
|
//修改审核信息表
|
|
info.setApprovalStatusDetails("待"+name+"审批");
|
|
info.setApprovalStatusDetails("待"+name+"审批");
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改审核信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//推送微信模板消息通知
|
|
//推送微信模板消息通知
|
|
//查询审批订单信息
|
|
//查询审批订单信息
|
|
@@ -531,23 +555,31 @@ public class ApprovalController {
|
|
//添加流程信息记录
|
|
//添加流程信息记录
|
|
processInfo.setProcessState(2);
|
|
processInfo.setProcessState(2);
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("添加流程信息记录失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
break;
|
|
break;
|
|
case 2:
|
|
case 2:
|
|
//修改历史记录状态为已驳回
|
|
//修改历史记录状态为已驳回
|
|
historicalRecord.setRecordState(3);
|
|
historicalRecord.setRecordState(3);
|
|
if(approvalOrderService.updateHistoricalRecord(historicalRecord) < 1){
|
|
if(approvalOrderService.updateHistoricalRecord(historicalRecord) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改历史记录状态为已驳回失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
info.setApprovalStatus(3);
|
|
info.setApprovalStatus(3);
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改审批信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//添加流程信息记录
|
|
//添加流程信息记录
|
|
processInfo.setProcessState(3);
|
|
processInfo.setProcessState(3);
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("添加流程信息记录失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
|
|
|
|
//调用第三方revokeTask接口执行撤销
|
|
//调用第三方revokeTask接口执行撤销
|
|
@@ -557,7 +589,9 @@ public class ApprovalController {
|
|
//修改审批信息状态为撤销
|
|
//修改审批信息状态为撤销
|
|
info.setApprovalStatus(9);
|
|
info.setApprovalStatus(9);
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
if(approvalOrderService.updateApprovalInfo(info) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("修改审批信息状态为撤销失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//删除该审批的历史记录
|
|
//删除该审批的历史记录
|
|
approvalOrderService.deleteHistoricalRecord(approvalInfo.getApprovalId());
|
|
approvalOrderService.deleteHistoricalRecord(approvalInfo.getApprovalId());
|
|
@@ -565,7 +599,9 @@ public class ApprovalController {
|
|
//添加流程信息记录
|
|
//添加流程信息记录
|
|
processInfo.setProcessState(4);
|
|
processInfo.setProcessState(4);
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("添加流程信息记录失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
//调用第三方revokeTask接口执行撤销
|
|
//调用第三方revokeTask接口执行撤销
|
|
approvalTaskService.revokeTask(approvalInfo.getActivitiId(),"业务员撤销审核");
|
|
approvalTaskService.revokeTask(approvalInfo.getActivitiId(),"业务员撤销审核");
|
|
@@ -574,7 +610,9 @@ public class ApprovalController {
|
|
//添加评论内容到流程信息表,不用修改任何状态
|
|
//添加评论内容到流程信息表,不用修改任何状态
|
|
processInfo.setProcessState(0);
|
|
processInfo.setProcessState(0);
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
if(approvalOrderService.insertProcessInfo(processInfo) < 1){
|
|
- return ResponseJson.getFAILURE();
|
|
|
|
|
|
+ rj = ResponseJson.getFAILURE();
|
|
|
|
+ rj.setResultMsg("添加评论内容到流程信息失败!");
|
|
|
|
+ return rj;
|
|
}
|
|
}
|
|
break;
|
|
break;
|
|
}
|
|
}
|
|
@@ -697,6 +735,7 @@ public class ApprovalController {
|
|
return rj;
|
|
return rj;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 获取某个审批的整个审批流程 1:生成订单审批;2:提货申请
|
|
* 获取某个审批的整个审批流程 1:生成订单审批;2:提货申请
|
|
* @param
|
|
* @param
|
|
@@ -719,4 +758,29 @@ public class ApprovalController {
|
|
return rj;
|
|
return rj;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
+ * 查询入库记录
|
|
|
|
+ * @param approvalId
|
|
|
|
+ * @return productionItem
|
|
|
|
+ * @throws Exception
|
|
|
|
+ */
|
|
|
|
+ @ResponseBody
|
|
|
|
+ @RequestMapping(value = "/getProductionItem")
|
|
|
|
+ public ResponseJson getProductionItem(HttpServletRequest request,Integer approvalId) throws Exception {
|
|
|
|
+ ResponseJson rj =new ResponseJson(200, "查询成功", 200);
|
|
|
|
+ if(approvalId == null){
|
|
|
|
+ return ResponseJson.getFAILURE();
|
|
|
|
+ }
|
|
|
|
+ ApprovalProduction approvalProduction = new ApprovalProduction();
|
|
|
|
+ approvalProduction.setApprovalId(approvalId);
|
|
|
|
+ List<ApprovalProduction> approvalProductionList = approvalProductionService.getApprovalProductionList(approvalProduction);
|
|
|
|
+ approvalProduction = approvalProductionList.get(0);
|
|
|
|
+ ApprovalProductionItem approvalProductionItem = new ApprovalProductionItem();
|
|
|
|
+ approvalProductionItem.setProductionId(approvalProduction.getProductionId());
|
|
|
|
+ List<ApprovalProductionItem> approvalProductionItemList = approvalProductionService.getApprovalProductionItemList(approvalProductionItem);
|
|
|
|
+ rj.addResponseKeyValue("apItemList",approvalProductionItemList);
|
|
|
|
+
|
|
|
|
+ return rj;
|
|
|
|
+ }
|
|
|
|
+
|
|
}
|
|
}
|