/* * Copyright 2017-2020 吴学文 and java110 team. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.java110.acct.cmd.payment; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.java110.core.annotation.Java110Cmd; import com.java110.core.annotation.Java110Transactional; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.core.factory.GenerateCodeFactory; import com.java110.dto.fee.FeeConfigDto; import com.java110.dto.payment.PaymentPoolDto; import com.java110.intf.acct.IPaymentPoolConfigV1InnerServiceSMO; import com.java110.intf.acct.IPaymentPoolV1InnerServiceSMO; import com.java110.intf.acct.IPaymentPoolValueV1InnerServiceSMO; import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO; import com.java110.po.payment.PaymentPoolPo; import com.java110.po.payment.PaymentPoolConfigPo; import com.java110.po.payment.PaymentPoolValuePo; import com.java110.utils.exception.CmdException; import com.java110.utils.util.Assert; import com.java110.utils.util.BeanConvertUtil; import com.java110.vo.ResultVo; import org.springframework.beans.factory.annotation.Autowired; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.List; /** * 支付池保存命令类 * * 该类负责处理支付池的保存操作，包括支付池基本信息、动态字段值和费用配置关联关系的保存 * 主要功能： * 1. 验证请求参数的完整性 * 2. 保存支付池基本信息 * 3. 保存支付池的动态字段值 * 4. 保存支付池与费用配置的关联关系 * * 服务编码：payment.savePaymentPool * 请求路径：/app/payment.SavePaymentPool * * @author 吴学文 at 2023-10-25 11:52:42 mail: 928255095@qq.com * @open source address: https://gitee.com/wuxw7/MicroCommunity * @官网：http://www.homecommunity.cn * @温馨提示：如果您对此文件进行修改 请不要删除原有作者及注释信息，请补充您的 修改的原因以及联系邮箱如下 * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复，注释10至20行 加入 20行至30行 */ @Java110Cmd(serviceCode = "payment.savePaymentPool") public class SavePaymentPoolCmd extends Cmd { private static Logger logger = LoggerFactory.getLogger(SavePaymentPoolCmd.class); /** * ID生成前缀 */ public static final String CODE_PREFIX_ID = "10"; /** * 支付池服务接口 */ @Autowired private IPaymentPoolV1InnerServiceSMO paymentPoolV1InnerServiceSMOImpl; /** * 支付池值服务接口 */ @Autowired private IPaymentPoolValueV1InnerServiceSMO paymentPoolValueV1InnerServiceSMOImpl; /** * 费用配置服务接口 */ @Autowired private IPayFeeConfigV1InnerServiceSMO payFeeConfigV1InnerServiceSMOImpl; /** * 支付池配置服务接口 */ @Autowired private IPaymentPoolConfigV1InnerServiceSMO paymentPoolConfigV1InnerServiceSMOImpl; /** * 参数验证方法 * * 验证请求参数的完整性和业务规则，包括： * 1. 必填字段验证 * 2. 动态字段验证 * 3. 支付类型业务规则验证 * 4. 费用配置验证 * * @param event 命令事件对象 * @param cmdDataFlowContext 命令数据流上下文 * @param reqJson 请求参数JSON对象 * @throws CmdException 当参数验证失败时抛出异常 */ @Override public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { // 调用父类属性验证方法 super.validateProperty(cmdDataFlowContext); // 验证必填字段 Assert.hasKeyAndValue(reqJson, "paymentName", "请求报文中未包含paymentName"); Assert.hasKeyAndValue(reqJson, "paymentType", "请求报文中未包含paymentType"); Assert.hasKeyAndValue(reqJson, "communityId", "请求报文中未包含communityId"); Assert.hasKeyAndValue(reqJson, "state", "请求报文中未包含state"); Assert.hasKeyAndValue(reqJson, "payType", "请求报文中未包含payType"); // 验证动态字段 Assert.hasKey(reqJson, "paymentKeys", "未包含动态字段"); JSONArray paymentKeys = reqJson.getJSONArray("paymentKeys"); if (paymentKeys == null || paymentKeys.isEmpty()) { throw new CmdException("未包含字段"); } // 验证动态字段的完整性 JSONObject columns = null; // 动态字段格式示例： // {"columnKey":"WECHAT_KEY","keyId":"2","name":"支付密码","page":-1,"paymentType":"WECHAT", // "records":0,"remark":"请输入微信v2支付秘钥","row":0,"statusCd":"0","total":0,"columnValue":"1"} for (int keyIndex = 0; keyIndex < paymentKeys.size(); keyIndex++) { columns = paymentKeys.getJSONObject(keyIndex); Assert.hasKeyAndValue(columns, "columnKey", "未包含key"); Assert.hasKeyAndValue(columns, "columnValue", reqJson.getString("name") + "未填写值"); } // 如果支付类型不是费用配置类型，检查是否已存在相同支付类型的支付池 if (!PaymentPoolDto.PAY_TYPE_FEE_CONFIG.equals(reqJson.getString("payType"))) { PaymentPoolDto paymentPoolDto = new PaymentPoolDto(); paymentPoolDto.setCommunityId(reqJson.getString("communityId")); paymentPoolDto.setPayType(reqJson.getString("payType")); int count = paymentPoolV1InnerServiceSMOImpl.queryPaymentPoolsCount(paymentPoolDto); if (count > 0) { throw new CmdException("已经存在，请勿重复添加，只有支付范围为费用项的可以添加多个支付"); } return; } // 如果是费用配置类型，验证费用配置ID JSONArray configIds = reqJson.getJSONArray("configIds"); if (configIds == null || configIds.isEmpty()) { throw new CmdException("未包含费用项"); } } /** * 执行保存支付池命令 * * 该方法负责保存支付池的完整信息，包括： * 1. 保存支付池基本信息 * 2. 保存支付池动态字段值 * 3. 保存支付池与费用配置的关联关系 * * @param event 命令事件对象 * @param cmdDataFlowContext 命令数据流上下文 * @param reqJson 请求参数JSON对象 * @throws CmdException 当保存操作失败时抛出异常 */ @Override @Java110Transactional public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { // 转换并保存支付池基本信息 PaymentPoolPo paymentPoolPo = BeanConvertUtil.covertBean(reqJson, PaymentPoolPo.class); paymentPoolPo.setPpId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID)); int flag = paymentPoolV1InnerServiceSMOImpl.savePaymentPool(paymentPoolPo); if (flag < 1) { throw new CmdException("保存数据失败"); } // 保存动态字段值 JSONArray paymentKeys = reqJson.getJSONArray("paymentKeys"); JSONObject columns = null; PaymentPoolValuePo paymentPoolValuePo = null; for (int keyIndex = 0; keyIndex < paymentKeys.size(); keyIndex++) { columns = paymentKeys.getJSONObject(keyIndex); paymentPoolValuePo = new PaymentPoolValuePo(); paymentPoolValuePo.setColumnValue(columns.getString("columnValue")); paymentPoolValuePo.setColumnKey(columns.getString("columnKey")); paymentPoolValuePo.setCommunityId(paymentPoolPo.getCommunityId()); paymentPoolValuePo.setPpId(paymentPoolPo.getPpId()); paymentPoolValuePo.setValueId(GenerateCodeFactory.getGeneratorId("11")); paymentPoolValueV1InnerServiceSMOImpl.savePaymentPoolValue(paymentPoolValuePo); } // 如果支付类型不是费用配置类型，直接返回成功 if (!PaymentPoolDto.PAY_TYPE_FEE_CONFIG.equals(reqJson.getString("payType"))) { cmdDataFlowContext.setResponseEntity(ResultVo.success()); return; } // 保存支付池与费用配置的关联关系 JSONArray configIds = reqJson.getJSONArray("configIds"); FeeConfigDto feeConfigDto = new FeeConfigDto(); feeConfigDto.setConfigIds(configIds.toArray(new String[configIds.size()])); feeConfigDto.setCommunityId(reqJson.getString("communityId")); List feeConfigDtos = payFeeConfigV1InnerServiceSMOImpl.queryPayFeeConfigs(feeConfigDto); if (feeConfigDtos == null || feeConfigDtos.isEmpty()) { cmdDataFlowContext.setResponseEntity(ResultVo.success()); return; } // 遍历费用配置列表，保存关联关系 PaymentPoolConfigPo paymentPoolConfigPo = null; for (FeeConfigDto tmpFeeConfigDto : feeConfigDtos) { paymentPoolConfigPo = new PaymentPoolConfigPo(); paymentPoolConfigPo.setConfigId(tmpFeeConfigDto.getConfigId()); paymentPoolConfigPo.setFeeName(tmpFeeConfigDto.getFeeName()); paymentPoolConfigPo.setCommunityId(paymentPoolPo.getCommunityId()); paymentPoolConfigPo.setPpId(paymentPoolPo.getPpId()); paymentPoolConfigPo.setPpcId(GenerateCodeFactory.getGeneratorId("11")); paymentPoolConfigV1InnerServiceSMOImpl.savePaymentPoolConfig(paymentPoolConfigPo); } // 设置成功响应 cmdDataFlowContext.setResponseEntity(ResultVo.success()); } }