| | |
| | | import com.java110.core.annotation.Java110Cmd; |
| | | import com.java110.core.annotation.Java110Transactional; |
| | | import com.java110.core.context.ICmdDataFlowContext; |
| | | import com.java110.core.event.cmd.AbstractServiceCmdListener; |
| | | 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.FeeDetailDto; |
| | | import com.java110.dto.fee.FeeDto; |
| | | import com.java110.dto.returnPayFee.ReturnPayFeeDto; |
| | | import com.java110.dto.user.UserDto; |
| | | import com.java110.intf.fee.IFeeDetailInnerServiceSMO; |
| | | import com.java110.intf.fee.IFeeInnerServiceSMO; |
| | | import com.java110.intf.fee.IPayFeeDetailNewV1InnerServiceSMO; |
| | | import com.java110.intf.fee.IPayFeeDetailV1InnerServiceSMO; |
| | | import com.java110.intf.fee.IReturnPayFeeV1InnerServiceSMO; |
| | | import com.java110.intf.user.IUserV1InnerServiceSMO; |
| | | import com.java110.po.fee.PayFeeDetailPo; |
| | | import com.java110.po.returnPayFee.ReturnPayFeePo; |
| | | import com.java110.utils.exception.CmdException; |
| | |
| | | * // modify by 张三 at 2021-09-12 第10行在某种场景下存在某种bug 需要修复,注释10至20行 加入 20行至30行 |
| | | */ |
| | | @Java110Cmd(serviceCode = "returnPayFee.saveReturnPayFee") |
| | | public class SaveReturnPayFeeCmd extends AbstractServiceCmdListener { |
| | | public class SaveReturnPayFeeCmd extends Cmd { |
| | | |
| | | private static Logger logger = LoggerFactory.getLogger(SaveReturnPayFeeCmd.class); |
| | | |
| | |
| | | private IFeeInnerServiceSMO feeInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IPayFeeDetailNewV1InnerServiceSMO payFeeDetailNewV1InnerServiceSMOImpl; |
| | | private IPayFeeDetailV1InnerServiceSMO payFeeDetailNewV1InnerServiceSMOImpl; |
| | | |
| | | |
| | | @Autowired |
| | | private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl; |
| | | |
| | | @Autowired |
| | | private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl; |
| | | |
| | | @Override |
| | | public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) { |
| | |
| | | @Java110Transactional |
| | | public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException { |
| | | |
| | | String userId = cmdDataFlowContext.getReqHeaders().get("user-id"); |
| | | |
| | | UserDto userDto = new UserDto(); |
| | | userDto.setUserId(userId); |
| | | List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto); |
| | | |
| | | Assert.listOnlyOne(userDtos, "用户不存在"); |
| | | |
| | | FeeDto feeDto = new FeeDto(); |
| | | feeDto.setCommunityId(reqJson.getString("communityId")); |
| | | feeDto.setFeeId(reqJson.getString("feeId")); |
| | |
| | | ReturnPayFeePo returnPayFeePo = BeanConvertUtil.covertBean(reqJson, ReturnPayFeePo.class); |
| | | returnPayFeePo.setReturnFeeId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID)); |
| | | returnPayFeePo.setState(ReturnPayFeeDto.STATE_WAIT); |
| | | returnPayFeePo.setCycles((reqJson.getDouble("cycles") * -1) + ""); |
| | | returnPayFeePo.setReceivableAmount((reqJson.getDouble("receivableAmount") * -1) + ""); |
| | | returnPayFeePo.setReceivedAmount((reqJson.getDouble("receivedAmount") * -1) + ""); |
| | | returnPayFeePo.setPrimeRate("7"); //退费默认方式为转账 |
| | | returnPayFeePo.setApplyPersonId(userId); |
| | | returnPayFeePo.setApplyPersonName(userDtos.get(0).getName()); |
| | | int flag = returnPayFeeV1InnerServiceSMOImpl.saveReturnPayFee(returnPayFeePo); |
| | | |
| | | if (flag < 1) { |