From 3fd36846ad612f627c0784587dc6099a322a158e Mon Sep 17 00:00:00 2001 From: houruijun <411269194@kidgrow.com> Date: Wed, 24 Jun 2020 18:55:09 +0800 Subject: [PATCH] 1.编写扣费业务4大接口(AI 调用前,失败退,调用后,人工读) 2.增加写mq消息队列 3.增加扣费业务相关全局静态值 4.调整扣费,套餐,套餐记录services里面的调用关系。 --- kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java | 17 ++++++++++++----- 1 files changed, 12 insertions(+), 5 deletions(-) diff --git a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java index 80f070e..1bef92d 100644 --- a/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java +++ b/kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-server/src/main/java/com/kidgrow/oprationcenter/controller/ProductOrderController.java @@ -1,8 +1,11 @@ package com.kidgrow.oprationcenter.controller; +import com.kidgrow.common.annotation.LoginUser; import com.kidgrow.common.controller.BaseController; import com.kidgrow.common.model.PageResult; import com.kidgrow.common.model.ResultBody; +import com.kidgrow.common.model.SysOrganization; +import com.kidgrow.common.model.SysUser; import com.kidgrow.oprationcenter.model.ProductOrder; import com.kidgrow.oprationcenter.service.IBusinessRecordsService; import com.kidgrow.oprationcenter.service.IProductOrderService; @@ -51,12 +54,12 @@ @ApiImplicitParam(name = "limit", value = "分页结束位置", required = true, dataType = "Integer") }) @GetMapping - public PageResult list(@RequestParam Map<String, Object> params) { + public PageResult list(@RequestParam Map<String, Object> params, @LoginUser SysUser sysUser) { if (params.size() == 0) { params.put("page", 1); params.put("limit", 10); } - return productOrderService.findList(params); + return productOrderService.findList(params,sysUser); } /** @@ -84,7 +87,7 @@ */ @ApiOperation(value = "保存") @PostMapping - public ResultBody save(@Valid @RequestBody ProductOrder productOrder, BindingResult bindingResult) { + public ResultBody save(@Valid @RequestBody ProductOrder productOrder, BindingResult bindingResult,@LoginUser SysUser sysUser) { List<String> errMsg = new ArrayList<>(); if (bindingResult.hasErrors()) { for (ObjectError error : bindingResult.getAllErrors()) { @@ -92,6 +95,10 @@ } return ResultBody.failed().msg(errMsg.toString()); } else { + List<SysOrganization> organizations = sysUser.getOrganizations(); + if(organizations.size()>0){ + productOrder.setCreateUserOrgCode(organizations.get(organizations.size()-1).getOrgCode()); + } boolean v = productOrderService.saveOrUpdate(productOrder); if (v) { return ResultBody.ok().data(productOrder).msg("保存成功"); @@ -110,7 +117,7 @@ boolean v = productOrderService.removeById(id); if (v) { if (!businessRecordsService.recordBusinessData("删除合同:"+id,id.toString())) { - log.error(String.format("删除合同编号为:{0}的数据后,写入业务日志失败!",id)); + //log.error(String.format("删除合同编号为:{0}的数据后,写入业务日志失败!",id)); } return ResultBody.ok().msg("删除成功"); @@ -140,7 +147,7 @@ if (resultBody.getCode()==0) { String enablad=(MapUtils.getBoolean(params, "enabled"))?"启用":"禁用"; if (!businessRecordsService.recordBusinessData("修改合同状态为:"+enablad,enablad)) { - log.error(String.format("修改合同状态为:{0},写入业务日志失败!合同管理id为:{1}",enablad,MapUtils.getString(params,"id"))); + //log.error(String.format("修改合同状态为:{0},写入业务日志失败!合同管理id为:{1}",enablad,MapUtils.getString(params,"id"))); } } return resultBody; -- Gitblit v1.8.0