加入我的预约订单功能

java110-db/src/main/resources/mapper/store/ReserveGoodsOrderTimeV1ServiceDaoImplMapper.xml

@@ -19,7 +19,7 @@
     <select id="getReserveGoodsOrderTimeInfo" parameterType="Map" resultType="Map">
         select t.hours,t.quantity,t.time_id,t.time_id timeId,t.order_id,t.order_id orderId,t.goods_id,t.goods_id
         goodsId,t.status_cd,t.status_cd statusCd,t.state,t.community_id,t.community_id communityId,rgo.person_name personName,
-        rgo.person_tel personTel,rgo.appointment_time appointmentTime,rg.goods_name goodName,rgo.received_amount receivedAmount,rgo.state,
+        rgo.person_tel personTel,rgo.appointment_time appointmentTime,rg.goods_name goodsName,rgo.received_amount receivedAmount,rgo.state,
         td.`name` stateName
         from reserve_goods_order_time t
         left join reserve_goods_order rgo on t.order_id = rgo.order_id and rgo.status_cd='0'

service-store/src/main/java/com/java110/store/cmd/reserveOrder/DeleteReserveGoodsPersonCmd.java

@@ -0,0 +1,142 @@
+/*
+ * 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.store.cmd.reserveOrder;
+
+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.dto.communitySpacePerson.CommunitySpacePersonDto;
+import com.java110.dto.communitySpacePersonTime.CommunitySpacePersonTimeDto;
+import com.java110.dto.onlinePay.OnlinePayDto;
+import com.java110.dto.reserveGoodsOrder.ReserveGoodsOrderDto;
+import com.java110.intf.acct.IOnlinePayV1InnerServiceSMO;
+import com.java110.intf.community.ICommunitySpacePersonTimeV1InnerServiceSMO;
+import com.java110.intf.community.ICommunitySpacePersonV1InnerServiceSMO;
+import com.java110.intf.store.IReserveGoodsOrderTimeV1InnerServiceSMO;
+import com.java110.intf.store.IReserveGoodsOrderV1InnerServiceSMO;
+import com.java110.po.communitySpacePerson.CommunitySpacePersonPo;
+import com.java110.po.communitySpacePersonTime.CommunitySpacePersonTimePo;
+import com.java110.po.onlinePay.OnlinePayPo;
+import com.java110.po.reserveGoodsOrder.ReserveGoodsOrderPo;
+import com.java110.po.reserveGoodsOrderTime.ReserveGoodsOrderTimePo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.List;
+
+/**
+ * 类表述：删除
+ * 服务编码：communitySpacePerson.deleteCommunitySpacePerson
+ * 请求路劲：/app/communitySpacePerson.DeleteCommunitySpacePerson
+ * add by 吴学文 at 2022-09-30 11:36:52 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 = "reserveOrder.deleteReserveGoodsPerson")
+public class DeleteReserveGoodsPersonCmd extends Cmd {
+    private static Logger logger = LoggerFactory.getLogger(DeleteReserveGoodsPersonCmd.class);
+
+    @Autowired
+    private IReserveGoodsOrderV1InnerServiceSMO reserveGoodsOrderV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IOnlinePayV1InnerServiceSMO onlinePayV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IReserveGoodsOrderTimeV1InnerServiceSMO reserveGoodsOrderTimeV1InnerServiceSMOImpl;
+
+    @Override
+    public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
+        Assert.hasKeyAndValue(reqJson, "orderId", "orderId不能为空");
+        Assert.hasKeyAndValue(reqJson, "communityId", "communityId不能为空");
+
+    }
+
+    @Override
+    @Java110Transactional
+    public void doCmd(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) throws CmdException {
+
+        // 是否线上支付
+        ReserveGoodsOrderDto reserveGoodsOrderDto = new ReserveGoodsOrderDto();
+        reserveGoodsOrderDto.setOrderId(reqJson.getString("orderId"));
+        reserveGoodsOrderDto.setState(CommunitySpacePersonDto.STATE_S);
+        List<ReserveGoodsOrderDto> reserveGoodsOrderDtos = reserveGoodsOrderV1InnerServiceSMOImpl.queryReserveGoodsOrders(reserveGoodsOrderDto);
+
+        Assert.listOnlyOne(reserveGoodsOrderDtos, "未找到可以取消订单");
+
+        returnOnlinePayMoney(reserveGoodsOrderDtos);
+
+        if(!StringUtil.isEmpty(reserveGoodsOrderDtos.get(0).getExtOrderId()) &&
+                !"-1".equals(reserveGoodsOrderDtos.get(0).getExtOrderId())){
+            reserveGoodsOrderDto = new ReserveGoodsOrderDto();
+            reserveGoodsOrderDto.setExtOrderId(reserveGoodsOrderDtos.get(0).getExtOrderId());
+            reserveGoodsOrderDto.setState(CommunitySpacePersonDto.STATE_S);
+            reserveGoodsOrderDtos = reserveGoodsOrderV1InnerServiceSMOImpl.queryReserveGoodsOrders(reserveGoodsOrderDto);
+
+        }
+
+        for (ReserveGoodsOrderDto reserveGoodsOrderDto1 : reserveGoodsOrderDtos) {
+            ReserveGoodsOrderPo reserveGoodsOrderPo = new ReserveGoodsOrderPo();
+            reserveGoodsOrderPo.setOrderId(reserveGoodsOrderDto1.getOrderId());
+            reserveGoodsOrderPo.setState(CommunitySpacePersonDto.STATE_CL);
+            int flag = reserveGoodsOrderV1InnerServiceSMOImpl.updateReserveGoodsOrder(reserveGoodsOrderPo);
+
+            if (flag < 1) {
+                throw new CmdException("删除数据失败");
+            }
+
+
+            ReserveGoodsOrderTimePo reserveGoodsOrderTimePo = new ReserveGoodsOrderTimePo();
+            reserveGoodsOrderTimePo.setOrderId(reserveGoodsOrderDto1.getOrderId());
+            reserveGoodsOrderTimePo.setState(CommunitySpacePersonTimeDto.STATE_CL);
+            reserveGoodsOrderTimeV1InnerServiceSMOImpl.updateReserveGoodsOrderTime(reserveGoodsOrderTimePo);
+        }
+
+
+        cmdDataFlowContext.setResponseEntity(ResultVo.success());
+    }
+
+    /**
+     * 发起退款
+     *
+     * @param reserveGoodsOrderDtos
+     */
+    private void returnOnlinePayMoney(List<ReserveGoodsOrderDto> reserveGoodsOrderDtos) {
+        OnlinePayDto onlinePayDto = new OnlinePayDto();
+        onlinePayDto.setOrderId(reserveGoodsOrderDtos.get(0).getExtOrderId());
+        List<OnlinePayDto> onlinePayDtos = onlinePayV1InnerServiceSMOImpl.queryOnlinePays(onlinePayDto);
+        if (onlinePayDtos == null || onlinePayDtos.size() < 1) {
+            return;
+        }
+
+        OnlinePayPo onlinePayPo = new OnlinePayPo();
+        onlinePayPo.setOrderId(onlinePayDtos.get(0).getOrderId());
+        onlinePayPo.setPayId(onlinePayDtos.get(0).getPayId());
+        onlinePayPo.setState(OnlinePayDto.STATE_WT);
+        onlinePayPo.setRefundFee(onlinePayDtos.get(0).getTotalFee());
+        onlinePayV1InnerServiceSMOImpl.updateOnlinePay(onlinePayPo);
+    }
+}