代购修改

mec-biz/src/main/java/com/ym/mec/biz/dal/dto/StudentGoodsSellDto.java

@@ -12,12 +12,22 @@ public class StudentGoodsSellDto extends StudentPaymentOrder {
 
     private Integer authorUser;
 
+    private String goodsType;
+
     private BigDecimal totalAmount = BigDecimal.ZERO;
 
     private BigDecimal marketAmount = BigDecimal.ZERO;
 
     private Integer autoAffirmReceiveTime;
 
+    public String getGoodsType() {
+        return goodsType;
+    }
+
+    public void setGoodsType(String goodsType) {
+        this.goodsType = goodsType;
+    }
+
     public Integer getAutoAffirmReceiveTime() {
         return autoAffirmReceiveTime;
     }

mec-biz/src/main/java/com/ym/mec/biz/dal/entity/StudentGoodsSell.java

@@ -76,6 +76,17 @@ public class StudentGoodsSell extends BaseEntity {
 	@ApiModelProperty(value = "优惠券详情列表", required = false)
 	private List<SysCouponCodeDto> couponCodeDtoList;
 
+	// 商品来源类型 MALL商城
+	private String goodsType;
+
+	public String getGoodsType() {
+		return goodsType;
+	}
+
+	public void setGoodsType(String goodsType) {
+		this.goodsType = goodsType;
+	}
+
 	public String getCouponIds() {
 		return couponIds;
 	}

mec-biz/src/main/java/com/ym/mec/biz/dal/page/GoodsSellQueryInfo.java

@@ -14,6 +14,17 @@ public class GoodsSellQueryInfo extends QueryInfo {
 	@ApiModelProperty(value = "交易状态",required = true)
 	private String status;
 
+	@ApiModelProperty("商品来源类型 MALL：商城")
+	private String goodsType;
+
+	public String getGoodsType() {
+		return goodsType;
+	}
+
+	public void setGoodsType(String goodsType) {
+		this.goodsType = goodsType;
+	}
+
 	public Integer getTeacherId() {
 		return teacherId;
 	}

mec-biz/src/main/java/com/ym/mec/biz/service/StudentPaymentOrderService.java

@@ -244,4 +244,6 @@ public interface StudentPaymentOrderService extends BaseService<Long, StudentPay
     Map createOrder(MallCreateOrderModel model) throws Exception;
 
     void mallBuyOrderCallback(StudentPaymentOrder order);
+
+    void mallSaveOrderInfo(MallCreateOrderModel model);
 }

mec-biz/src/main/java/com/ym/mec/biz/service/impl/StudentPaymentOrderServiceImpl.java

@@ -1,14 +1,12 @@
 package com.ym.mec.biz.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.ym.mec.auth.api.client.SysUserFeignService;
 import com.ym.mec.auth.api.entity.SysUser;
 import com.ym.mec.biz.dal.dao.*;
-import com.ym.mec.biz.dal.dto.PageInfoOrder;
-import com.ym.mec.biz.dal.dto.SporadicChargeInfoDto;
-import com.ym.mec.biz.dal.dto.StudentPaymentOrderDto;
-import com.ym.mec.biz.dal.dto.StudentPaymentOrderExportDto;
+import com.ym.mec.biz.dal.dto.*;
 import com.ym.mec.biz.dal.entity.*;
 import com.ym.mec.biz.dal.enums.*;
 import com.ym.mec.biz.dal.page.SporadicOrderQueryInfo;
@@ -127,6 +125,8 @@ public class StudentPaymentOrderServiceImpl extends BaseServiceImpl<Long, Studen
     private StudentDao studentDao;
     @Autowired
     private StudentPaymentOrderService studentPaymentOrderService;
+
+
     @Autowired
     private SysUserCashAccountDetailService sysUserCashAccountDetailService;
     private final Logger logger = LoggerFactory.getLogger(this.getClass());
@@ -1030,10 +1030,56 @@ public class StudentPaymentOrderServiceImpl extends BaseServiceImpl<Long, Studen
         return studentPaymentOrderDao.getMemberIngOrder(member, status);
     }
 
+    @Autowired
+    private StudentRepairDao studentRepairDao;
+    @Autowired
+    private MusicGroupDao musicGroupDao;
+
+    @Autowired
+    private StudentGoodsSellDao studentGoodsSellDao;
 
     @Override
     public Map createOrder(MallCreateOrderModel model) throws Exception {
 
+        if(model == null ||model.getUserId() == null) {
+            throw new BizException("参数错误");
+        }
+        StudentGoodsSell studentGoodsSell;
+        if (StringUtils.isNotEmpty(model.getOldOrderNo())) {
+            studentGoodsSell = studentGoodsSellDao.findByOrderNo(model.getOldOrderNo());
+        }  else {
+            studentGoodsSell = new StudentGoodsSell();
+        }
+        studentDao.lockUser(model.getUserId());
+        SysUser student = studentDao.getUser(model.getUserId());
+        Map payMap = new HashMap();
+        if (student == null) {
+            payMap.put("mallStatus",0);
+            return payMap;
+        }
+        studentGoodsSell.setUserId(model.getUserId());
+        studentGoodsSell.setTeacherId(model.getTeacherId() >0 ? model.getTeacherId():studentGoodsSell.getTeacherId());
+        studentGoodsSell.setAuthorUser(model.getTeacherId() >0 ? model.getTeacherId():studentGoodsSell.getAuthorUser());
+        //如果教务老师为空，代表学员自己创建的订单
+        if (model.getTeacherId() == null && studentGoodsSell.getTeacherId() == null) {
+            //获取学生关联的所有教务老师列表
+            List<Integer> stuEducation = studentRepairDao.countStuEducation(model.getUserId());
+            if (stuEducation != null && stuEducation.size() == 1) {
+                //获取学员乐团关联的教务
+                MusicGroup musicGroup = musicGroupDao.getStuMusic(model.getUserId());
+                studentGoodsSell.setTeacherId(stuEducation.get(0));
+                if (musicGroup != null) {
+                    studentGoodsSell.setCooperationOrganId(musicGroup.getCooperationOrganId());
+                }
+            }
+        } else if (studentGoodsSell.getCooperationOrganId() == null) {
+            //获取教务老师，学员关联的乐团
+            MusicGroup musicGroup = musicGroupDao.getStuEduMusic(model.getUserId(), studentGoodsSell.getTeacherId());
+            if (musicGroup != null) {
+                studentGoodsSell.setCooperationOrganId(musicGroup.getCooperationOrganId());
+            }
+        }
+
         if (StringUtils.isNotEmpty(model.getOldOrderNo())) {
             StudentPaymentOrder orderByOrderNo = studentPaymentOrderService.findOrderByOrderNo(model.getOldOrderNo());
             if (orderByOrderNo == null) {
@@ -1049,20 +1095,18 @@ public class StudentPaymentOrderServiceImpl extends BaseServiceImpl<Long, Studen
             sysCouponCodeService.quit(orderByOrderNo.getCouponCodeId());
         }
 
-        SysUser student = studentDao.getUser(model.getUserId());
-        Map payMap = new HashMap();
-        if (student == null) {
-            payMap.put("mallStatus",0);
-            return payMap;
-        }
+
         Date date = new Date();
         StudentPaymentOrder studentPaymentOrder = sysCouponCodeService.use(model.getCouponIdList(), model.getAmount(),false);
 
+        studentPaymentOrder.setStatus(DealStatusEnum.ING);
+        if (studentPaymentOrder.getActualAmount().compareTo(BigDecimal.ZERO) == 0) {
+            studentPaymentOrder.setStatus(DealStatusEnum.SUCCESS);
+        }
         studentPaymentOrder.setGroupType(GroupType.MALL_SELL);
         studentPaymentOrder.setUserId(model.getUserId());
         studentPaymentOrder.setType(OrderTypeEnum.MALL_BUY);
         studentPaymentOrder.setOrderNo(model.getOrderNo());
-        studentPaymentOrder.setStatus(DealStatusEnum.ING);
         studentPaymentOrder.setCreateTime(date);
         studentPaymentOrder.setUpdateTime(date);
         studentPaymentOrder.setOrganId(student.getOrganId());
@@ -1070,6 +1114,19 @@ public class StudentPaymentOrderServiceImpl extends BaseServiceImpl<Long, Studen
         studentPaymentOrder.setTenantId(student.getTenantId());
         studentPaymentOrderService.insert(studentPaymentOrder);
 
+        studentGoodsSell.setCouponMarketAmount(studentPaymentOrder.getCouponRemitFee());
+        studentGoodsSell.setOrganId(student.getOrganId());
+        studentGoodsSell.setTotalAmount(studentPaymentOrder.getActualAmount());
+        studentGoodsSell.setGoodsType("MALL");
+        // studentGoodsSell.setGoodsJson(JSONObject.toJSONString(goodsSellDtos));
+        studentGoodsSell.setOrderNo(model.getOrderNo());
+        List<Integer> couponIdList = model.getCouponIdList();
+        if (couponIdList != null && couponIdList.size() > 0) {
+            studentGoodsSell.setCouponIds(StringUtils.join(couponIdList, ","));
+        }
+        studentGoodsSell.setTenantId(student.getTenantId());
+        studentGoodsSellDao.insert(studentGoodsSell);
+
         String baseApiUrl = sysConfigDao.findConfigValue("base_api_url");
 
         //  receiver类型
@@ -1149,4 +1206,16 @@ public class StudentPaymentOrderServiceImpl extends BaseServiceImpl<Long, Studen
             sysCouponCodeService.quit(studentPaymentOrder.getCouponCodeId());
         }
     }
+
+    @Override
+    public void mallSaveOrderInfo(MallCreateOrderModel model) {
+
+        StudentGoodsSell studentGoodsSell = studentGoodsSellDao.findByOrderNo(model.getOrderNo());
+        if (studentGoodsSell == null) {
+            throw new BizException("未找到订单信息");
+        }
+        studentGoodsSell.setGoodsJson(model.getOrderInfo());
+        studentGoodsSell.setGoodsType("MALL");
+        studentGoodsSellDao.update(studentGoodsSell);
+    }
 }

mec-biz/src/main/resources/config/mybatis/StudentGoodsSellMapper.xml

@@ -40,9 +40,9 @@
 	<!-- 向数据库增加一条记录 -->
 	<insert id="insert" parameterType="com.ym.mec.biz.dal.entity.StudentGoodsSell" useGeneratedKeys="true" keyColumn="id" keyProperty="id">
 		INSERT INTO student_goods_sell (user_id_,teacher_id_,goods_json_,total_amount_,market_amount_,
-		create_time_,update_time_,order_no_,organ_id_,author_user_,cooperation_organ_id_,coupon_market_amount_,coupon_ids_,tenant_id_)
+		create_time_,update_time_,order_no_,organ_id_,author_user_,cooperation_organ_id_,coupon_market_amount_,coupon_ids_,tenant_id_,goods_type_)
 		VALUES(#{userId},#{teacherId},#{goodsJson},#{totalAmount},#{marketAmount},
-		NOW(),NOW(),#{orderNo},#{organId},#{authorUser},#{cooperationOrganId},#{couponMarketAmount},#{couponIds},#{tenantId})
+		NOW(),NOW(),#{orderNo},#{organId},#{authorUser},#{cooperationOrganId},#{couponMarketAmount},#{couponIds},#{tenantId},#{goodsType})
 	</insert>
 	
 	<!-- 根据主键查询一条记录 -->
@@ -81,6 +81,9 @@
 		<if test="goodsJson != null">
 			goods_json_ = #{goodsJson},
 		</if>
+		<if test="goodsType != null">
+			goods_type_ = #{goodsType},
+		</if>
 		update_time_ = NOW()
 		</set> WHERE id_ = #{id} and tenant_id_ = #{tenantId}
 	</update>
@@ -110,6 +113,7 @@
 	</select>
 	<resultMap type="com.ym.mec.biz.dal.dto.StudentGoodsSellDto" id="StudentGoodsSellDto" extends="com.ym.mec.biz.dal.dao.StudentPaymentOrderDao.StudentPaymentOrder">
 		<result column="goods_json_" property="goodsJson" />
+		<result column="goods_type_" property="goodsType" />
 		<result column="total_amount_" property="totalAmount" />
 		<result column="market_amount_" property="marketAmount" />
 		<result column="username_" property="userName" />
@@ -118,6 +122,15 @@
 	<sql id="queryStudentGoodsOrdersSql">
 		<where>
 			sgs.tenant_id_ = #{tenantId}
+
+			<choose>
+				<when test="goodsType != null and goodsType =='MALL'">
+					and sgs.goods_type_ = 'MALL'
+				</when>
+				<otherwise>
+					and sgs.goods_type_ is null
+				</otherwise>
+			</choose>
 			<if test="teacherId != null">
 				AND sgs.teacher_id_ = #{teacherId}
 			</if>
@@ -136,7 +149,7 @@
 		</where>
 	</sql>
 	<select id="queryStudentGoodsOrders" resultMap="StudentGoodsSellDto">
-		SELECT spo.*,sgs.goods_json_,sgs.total_amount_,sgs.market_amount_,su.username_,sgs.author_user_
+		SELECT spo.*,sgs.goods_json_,sgs.total_amount_,sgs.market_amount_,su.username_,sgs.author_user_,sgs.goods_type_
 		FROM student_payment_order spo
 		LEFT JOIN student_goods_sell sgs ON spo.order_no_ = sgs.order_no_
 		LEFT JOIN sys_user su ON sgs.user_id_ = su.id_

mec-client-api/src/main/java/com/ym/mec/web/WebFeignService.java

@@ -51,4 +51,9 @@ public interface WebFeignService {
 
 	@PostMapping("/api/cancelOrder")
 	HttpResponseResult<OrderCancelModel> cancelOrder(@RequestParam("orderNo") String orderNo);
+
+
+
+	@PostMapping("/api/mallSaveOrderInfo")
+	HttpResponseResult<Map> mallSaveOrderInfo(@RequestBody MallCreateOrderModel model);
 }

mec-client-api/src/main/java/com/ym/mec/web/fallback/WebFeignServiceFallback.java

@@ -75,4 +75,9 @@ public class WebFeignServiceFallback implements WebFeignService {
 	public HttpResponseResult<OrderCancelModel> cancelOrder(String orderNo) {
 		return null;
 	}
+
+	@Override
+	public HttpResponseResult<Map> mallSaveOrderInfo(MallCreateOrderModel model) {
+		return null;
+	}
 }

mec-common/common-core/src/main/java/com/ym/mec/common/entity/MallCreateOrderModel.java

@@ -19,8 +19,30 @@ public class MallCreateOrderModel {
 
     private List<Integer> couponIdList;
 
+    // 需要购买的人
     private Integer userId;
 
+    // 代购人id
+    private Integer teacherId;
+
+    private String orderInfo;
+
+    public String getOrderInfo() {
+        return orderInfo;
+    }
+
+    public void setOrderInfo(String orderInfo) {
+        this.orderInfo = orderInfo;
+    }
+
+    public Integer getTeacherId() {
+        return teacherId;
+    }
+
+    public void setTeacherId(Integer teacherId) {
+        this.teacherId = teacherId;
+    }
+
     public String getOldOrderNo() {
         return oldOrderNo;
     }

mec-mall/mall-common/src/main/java/com/yonge/cooleshow/mall/common/enums/TradeStatusEnum.java

@@ -0,0 +1,52 @@
+package com.yonge.cooleshow.mall.common.enums;
+
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.ym.mec.common.enums.BaseEnum;
+
+/**
+ * 交易状态 pending 交易处理中 succeeded 交易成功 failed 交易失败
+ *
+ * @Author: liweifan
+ * @Data: 2022/3/31 14:59
+ */
+public enum TradeStatusEnum implements BaseEnum<String, TradeStatusEnum> {
+    pending("交易处理中"),
+    succeeded("交易成功"),
+    failed("交易失败"),
+    close("交易关闭");
+
+    @EnumValue
+    private String code;
+    private String msg;
+
+    TradeStatusEnum(String msg) {
+        this.code = this.name();
+        this.msg = msg;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    @Override
+    public String getCode() {
+        return this.code;
+    }
+
+    public static TradeStatusEnum getByName(String name) {
+        for (TradeStatusEnum statusEnum : TradeStatusEnum.values()) {
+            if (statusEnum.getCode().equals(name)) {
+                return statusEnum;
+            }
+        }
+        return null;
+    }
+}

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/config/ResourceServerConfig.java

@@ -26,8 +26,8 @@ public class ResourceServerConfig extends ResourceServerConfigurerAdapter {
         http.csrf().disable().exceptionHandling().accessDeniedHandler(baseAccessDeniedHandler).authenticationEntryPoint(baseAuthenticationEntryPoint).and()
             .authorizeRequests().antMatchers("/task/**").hasIpAddress("0.0.0.0/0")
                 .and()
-                .authorizeRequests().antMatchers("/wechat/*","/v2/api-docs", "/code/*","/payment/callback",
-                 "/order/paySuccess/test","/order/cancelUserOrder/test","/open/**","/task/**")
+                .authorizeRequests().antMatchers("/wechat/*","/v2/api-docs", "/code/*","/payment/callback","/order/adapayNo/list",
+                 "/order/paySuccess/test","/order/cancelUserOrder/test","/open/**","/task/**","/order/detail/sn/**","/cart/addAll","/order/generateOrder")
             .permitAll().anyRequest().authenticated().and().httpBasic();
     }
 

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/controller/OmsCartItemController.java

@@ -64,9 +64,18 @@ public class OmsCartItemController {
                 lock.unlock();
             }
         }
+    }
+
+    @ApiOperation("批量添加商品到购物车")
+    @RequestMapping(value = "/addAll", method = RequestMethod.POST)
+    @ResponseBody
+    public CommonResult<List<OmsCartItem>> addAll(@RequestBody List<OmsCartItem> cartItemList) {
 
+        List<OmsCartItem> omsCartItem = cartItemService.addAll(cartItemList);
+        return CommonResult.success(omsCartItem);
     }
 
+
     @ApiOperation("获取当前会员的购物车列表")
     @RequestMapping(value = "/list", method = RequestMethod.GET)
     @ResponseBody

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/controller/OmsPortalOrderController.java

@@ -7,10 +7,14 @@ import com.yonge.cooleshow.mall.common.enums.OrderCacheEnum;
 import com.yonge.cooleshow.mall.common.util.DistributedLock;
 import com.yonge.cooleshow.mall.common.util.StringUtil;
 import com.yonge.cooleshow.mbg.model.OmsOrder;
+import com.yonge.cooleshow.mbg.model.UmsMember;
+import com.yonge.cooleshow.mbg.model.UserOrderPayment;
 import com.yonge.cooleshow.portal.domain.ConfirmOrderResult;
 import com.yonge.cooleshow.portal.domain.OmsOrderDetail;
 import com.yonge.cooleshow.portal.domain.OrderParam;
 import com.yonge.cooleshow.portal.service.OmsPortalOrderService;
+import com.yonge.cooleshow.portal.service.UmsMemberService;
+import com.yonge.cooleshow.portal.service.UserOrderPaymentService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
@@ -35,8 +39,11 @@ import java.util.concurrent.TimeUnit;
 public class OmsPortalOrderController {
     @Autowired
     private OmsPortalOrderService portalOrderService;
+    @Autowired
+    private UmsMemberService memberService;
 
-
+    @Autowired
+    private UserOrderPaymentService userOrderPaymentService;
 
     @Value("${message.debugMode}")
     private boolean debugMode;
@@ -75,6 +82,17 @@ public class OmsPortalOrderController {
         return CommonResult.success(result, "下单成功");
     }
 
+
+    @ApiOperation("根据购物车信息生成订单")
+    @RequestMapping(value = "/teacher/generateOrder", method = RequestMethod.POST)
+    @ResponseBody
+    public CommonResult teacherGenerateOrder(@RequestBody OrderParam orderParam) {
+        UmsMember currentMember = memberService.getCurrentMember();
+        orderParam.setTeacherId(currentMember.getId());
+        Map<String, Object> result = portalOrderService.generateOrder(orderParam);
+        return CommonResult.success(result, "下单成功");
+    }
+
     @ApiOperation("用户支付成功的回调")
     @RequestMapping(value = "/paySuccess", method = RequestMethod.POST)
     @ResponseBody
@@ -91,6 +109,15 @@ public class OmsPortalOrderController {
         return CommonResult.success(null);
     }
 
+
+    @ApiOperation("根据订单号查询订单信息")
+    @RequestMapping(value = "/adapayNo/list", method = RequestMethod.POST)
+    @ResponseBody
+    public List<OmsOrderDetail> cancelTimeOutOrder(@RequestBody List<String> adapayNoList) {
+        List<OmsOrderDetail> result =  portalOrderService.list(adapayNoList);
+        return result;
+    }
+
     @ApiOperation("按状态分页获取用户订单列表")
     @ApiImplicitParam(name = "status", value = "订单状态：-1->全部；0->待付款；1->待发货；2->已发货；3->已完成；4->已关闭",
             defaultValue = "-1", allowableValues = "-1,0,1,2,3,4", paramType = "query", dataType = "string")
@@ -176,7 +203,14 @@ public class OmsPortalOrderController {
                        .runIfLockCanGet(OrderCacheEnum.LOCK_ORDER_NO_MALL.getRedisKey(omsOrder.getOrderSn())
                                , () -> {
                                        if (omsOrder.getStatus() == 0 || omsOrder.getStatus() == 6) {
-                                           portalOrderService.paymentSucceededHandle(omsOrder.getOrderSn(),omsOrder.getPayAmount(),"wx_pub");
+
+                                           UserOrderPayment orderPayment = userOrderPaymentService.getByOrderNoAndStatusPaying(
+                                                   omsOrder.getOrderSn());
+                                           if (orderPayment == null) {
+                                               throw new BizException("未找到支付信息");
+                                           }
+
+                                           portalOrderService.paymentSucceededHandle(orderPayment.getAdapayNo(),omsOrder.getPayAmount(),"wx_pub");
 
                                        } else {
                                            throw new BizException("订单已支付或已取消");

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/dao/PortalOrderDao.java

@@ -1,5 +1,6 @@
 package com.yonge.cooleshow.portal.dao;
 
+import com.yonge.cooleshow.mbg.model.OmsOrder;
 import com.yonge.cooleshow.mbg.model.OmsOrderItem;
 import com.yonge.cooleshow.portal.domain.OmsOrderDetail;
 import org.apache.ibatis.annotations.Param;
@@ -38,4 +39,6 @@ public interface PortalOrderDao {
     int releaseSkuStockLock(@Param("itemList") List<OmsOrderItem> orderItemList);
 
     int releaseProductStockLock(@Param("itemList") List<OmsOrderItem> orderItemList);
+
+    List<OmsOrder> listByAdapayNo(@Param("alapayNoList") List<String> alapayNoList, @Param("adapayNos") String adapayNos);
 }

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/domain/OrderParam.java

@@ -28,12 +28,22 @@ public class OrderParam {
     @ApiModelProperty("订单金额")
     private BigDecimal orderAmount;
 
-    @ApiModelProperty("代码用户id")
+    @ApiModelProperty("代码用户id 需要代买时传购买用户id")
     private Long  userId;
 
-    @ApiModelProperty("订单号 ")
+    private Long teacherId;
+
+    @ApiModelProperty("订单号 重复支付传订单号")
     private String orderNo;
 
+    public Long getTeacherId() {
+        return teacherId;
+    }
+
+    public void setTeacherId(Long teacherId) {
+        this.teacherId = teacherId;
+    }
+
     public String getOrderNo() {
         return orderNo;
     }

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/OmsCartItemService.java

@@ -59,4 +59,10 @@ public interface OmsCartItemService {
     int clear(Long memberId);
 
     OmsCartItem get(Long id);
+
+    /**
+     * 添加购物车
+     */
+    @Transactional
+    List<OmsCartItem> addAll(List<OmsCartItem> cartItemList);
 }

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/OmsPortalOrderService.java

@@ -113,4 +113,9 @@ public interface OmsPortalOrderService {
     void paymentSucceededHandle(String orderNo, BigDecimal payAmount, String payChannel);
 
     void paymentFailedHandle(String orderNo, Map<String, Object> notifyMap);
+
+    /**
+     * 根据支付订单号查询订单列表
+     */
+    List<OmsOrderDetail> list(List<String> adapayNoList);
 }

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/UserOrderPaymentService.java

@@ -0,0 +1,47 @@
+package com.yonge.cooleshow.portal.service;
+
+import com.yonge.cooleshow.mbg.model.UserOrderPayment;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * Description
+ *
+ * @author liujunchi
+ * @date 2022-04-24
+ */
+public interface UserOrderPaymentService {
+
+    /**
+     * 保存订单记录
+     *
+     * @param userOrderPayment
+     */
+    @Transactional
+    void save(UserOrderPayment userOrderPayment);
+
+    @Transactional
+    void saveOrUpdate(UserOrderPayment userOrderPayment);
+
+    /**
+     * 根据订单查询 订单支付信息
+     *
+     * @param orderSn 订单号
+     * @return
+     */
+    List<UserOrderPayment> getByOrderNo(String orderSn);
+
+    /**
+     * 查询支付中的订单， 最多只有一个
+     *
+     * @param orderSn
+     * @return
+     */
+    UserOrderPayment getByOrderNoAndStatusPaying(String orderSn);
+
+    /**
+     * 查询回调支付信息
+     */
+    UserOrderPayment getByAdapayNo(String paymentNo);
+}

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/impl/OmsCartItemServiceImpl.java

@@ -46,7 +46,15 @@ public class OmsCartItemServiceImpl implements OmsCartItemService {
 
     @Override
     public OmsCartItem add(OmsCartItem cartItem) {
-        UmsMember currentMember =memberService.getCurrentMember();
+        UmsMember currentMember;
+        if(cartItem.getMemberId() != null) {
+            currentMember = memberService.getById(cartItem.getMemberId());
+            if (currentMember == null) {
+                throw new BizException("未找到用户信息");
+            }
+        } else {
+            currentMember = memberService.getCurrentMember();
+        }
         cartItem.setMemberId(currentMember.getId());
         cartItem.setMemberNickname(currentMember.getNickname());
         cartItem.setDeleteStatus(0);
@@ -228,4 +236,14 @@ public class OmsCartItemServiceImpl implements OmsCartItemService {
     public OmsCartItem get(Long id) {
         return cartItemMapper.selectByPrimaryKey(id);
     }
+
+    @Override
+    public List<OmsCartItem> addAll(List<OmsCartItem> cartItemList) {
+        List<OmsCartItem> result = new ArrayList<>();
+        for (OmsCartItem omsCartItem : cartItemList) {
+            OmsCartItem cartItem = add(omsCartItem);
+            result.add(cartItem);
+        }
+        return result;
+    }
 }

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/impl/OmsPortalOrderServiceImpl.java

@@ -3,6 +3,7 @@ package com.yonge.cooleshow.portal.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.map.MapUtil;
+import com.alibaba.fastjson.JSON;
 import com.github.pagehelper.PageHelper;
 import com.ym.mec.common.entity.HttpResponseResult;
 import com.ym.mec.common.entity.MallCreateOrderModel;
@@ -12,6 +13,7 @@ import com.ym.mec.common.service.IdGeneratorService;
 import com.ym.mec.web.WebFeignService;
 import com.yonge.cooleshow.mall.common.api.CommonPage;
 import com.yonge.cooleshow.mall.common.enums.OrderCacheEnum;
+import com.yonge.cooleshow.mall.common.enums.TradeStatusEnum;
 import com.yonge.cooleshow.mall.common.exception.Asserts;
 import com.yonge.cooleshow.mall.common.service.RedisService;
 import com.yonge.cooleshow.mall.common.util.DistributedLock;
@@ -90,6 +92,9 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
     @Autowired
     private RedissonClient redissonClient;
 
+    @Autowired
+    private UserOrderPaymentService userOrderPaymentService;
+
 
     @Autowired
     private PortalProductDao productDao;
@@ -127,22 +132,21 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
             // 订单号不为空 先删除订单  在重新创建订单
             OmsOrderDetail detail = detail(orderParam.getOrderNo());
             if (detail != null && detail.getStatus() == 0) {
-                detail.setStatus(4);
-                orderMapper.updateByPrimaryKeySelective(detail);
-                // 另外生成一个订单
-                detail.setId(null);
-                detail.setStatus(0);
-                detail.setOrderSn(orderSn);
-                List<OmsOrderItem> orderItemList = detail.getOrderItemList();
-                orderMapper.insert(detail);
-                for (OmsOrderItem omsOrderItem : orderItemList) {
-                    omsOrderItem.setId(null);
-                    omsOrderItem.setOrderSn(detail.getOrderSn());
-                    omsOrderItem.setOrderId(detail.getId());
-                }
-                orderItemDao.insertList(orderItemList);
+                // 取消原有的订单支付
+                UserOrderPayment userOrderPayment = userOrderPaymentService.getByOrderNoAndStatusPaying(
+                        orderParam.getOrderNo());
+                userOrderPayment.setStatus(TradeStatusEnum.close.getCode());
 
-                return feignMecCreateOrder(order.getCouponId(),orderParam.getOrderNo(), orderSn, detail.getMemberId(), detail.getTotalAmount());
+                String oldORderNo = userOrderPayment.getAdapayNo();
+                userOrderPaymentService.saveOrUpdate(userOrderPayment);
+
+                // 增加一个支付中的记录
+                userOrderPayment.setStatus(TradeStatusEnum.pending.getCode());
+                userOrderPayment.setAdapayNo(orderSn);
+                userOrderPayment.setId(null);
+                userOrderPaymentService.saveOrUpdate(userOrderPayment);
+
+                return feignMecCreateOrder(order.getCouponId(), oldORderNo, orderSn, null, detail.getMemberId().intValue(), detail.getTotalAmount());
             } else {
                 throw new BizException("订单信息获取失败");
             }
@@ -154,9 +158,11 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
         }
         List<OmsOrderItem> orderItemList = new ArrayList<>();
         //获取购物车及优惠信息
-        UmsMember currentMember = memberService.getCurrentMember();
+        UmsMember currentMember;
         if (orderParam.getUserId() != null && orderParam.getUserId() > 0) {
             currentMember = memberService.getById(orderParam.getUserId());
+        } else {
+            currentMember =  memberService.getCurrentMember();
         }
 
         List<CartPromotionItem> cartPromotionItemList = cartItemService.listPromotion(currentMember.getId(),
@@ -190,7 +196,8 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
 
         BigDecimal amount = calcTotalAmount(orderItemList);
 
-        Map data = feignMecCreateOrder(orderParam.getCouponId(),orderParam.getOrderNo(), orderSn, currentMember.getId(), amount);
+        Map data = feignMecCreateOrder(orderParam.getCouponId(),orderParam.getOrderNo(), orderSn,
+                                       orderParam.getTeacherId()==null?null:orderParam.getTeacherId().intValue(), currentMember.getId().intValue(), amount);
 
         BigDecimal couponAmount = MapUtil.get(data, "mallCouponAmount", BigDecimal.class);
         if (couponAmount == null) {
@@ -340,20 +347,48 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
         Map<String, Object> result = new HashMap<>();
         result.put("order", order);
         result.put("orderItemList", orderItemList);
+        result.put("orderType","paying");
+
+        // 创建订单时，创建一条用户支付订单信息  金额信息不做处理
+        UserOrderPayment userOrderPayment = new UserOrderPayment();
+        userOrderPayment.setOpenType("ADAPAY");
+        userOrderPayment.setPaymentClient(orderParam.getPlatformType());
+        userOrderPayment.setOrderNo(order.getOrderSn());
+        userOrderPayment.setAdapayNo(order.getOrderSn());
+        userOrderPayment.setStatus(TradeStatusEnum.pending.getCode());
+
         if (order.getPayAmount().compareTo(BigDecimal.ZERO) == 0) {
             paySuccess(order.getId(),order.getPayType());
             order.setStatus(1);
+            result.put("orderType","success");
+            userOrderPayment.setStatus(TradeStatusEnum.succeeded.getCode());
         }
+        userOrderPaymentService.save(userOrderPayment);
         result.put("pay",data);
+
+        // 保存商品信息到管乐迷
+        OmsOrderDetail detail = detail(order.getOrderSn());
+
+        MallCreateOrderModel model = new MallCreateOrderModel();
+        model.setOrderNo(order.getOrderSn());
+        model.setOrderInfo(JSON.toJSONString(detail));
+        HttpResponseResult<Map> mapHttpResponseResult = webFeignService.mallSaveOrderInfo(model);
+        if (!mapHttpResponseResult.getStatus()) {
+            throw new BizException(mapHttpResponseResult.getMsg());
+        }
+
         return result;
     }
 
-    private Map feignMecCreateOrder(String couponId,String oldOrderNo, String orderSn, Long userId, BigDecimal amount) {
+    private Map feignMecCreateOrder(String couponId, String oldOrderNo, String orderSn, Integer teacherId, Integer userId, BigDecimal amount) {
         // 远程调用管乐迷订单记录
         MallCreateOrderModel model = new MallCreateOrderModel();
         model.setAmount(amount);
         model.setOrderNo(orderSn);
-        model.setUserId(userId.intValue());
+        if (!userId.equals(teacherId)) {
+            model.setTeacherId(teacherId);
+        }
+        model.setUserId(userId);
         model.setCouponIdList(StringUtil.toIntegerList(couponId));
         model.setOldOrderNo(oldOrderNo);
         HttpResponseResult<Map> mapHttpResponseResult = webFeignService.mallCreateOrder(model);
@@ -741,14 +776,22 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
     @Transactional
     public void paymentSucceededHandle(String orderNo, BigDecimal payAmount, String payChannel) {
         //订单完成
-        OmsOrderDetail detail = detail(orderNo);
+        UserOrderPayment orderPayment = userOrderPaymentService.getByAdapayNo(orderNo);
+        if (orderPayment == null) {
+            throw new BizException("订单支付信息未找到");
+        }
+        OmsOrderDetail detail = detail(orderPayment.getOrderNo());
         if (detail.getStatus() == 0) {
             orderSuccess(detail, payAmount, payChannel);
+
+            orderPayment.setStatus(TradeStatusEnum.succeeded.getCode());
+            userOrderPaymentService.saveOrUpdate(orderPayment);
+
             Map<String,Object> notifyMap = new HashMap<>();
             notifyMap.put("channelType", payChannel);
             notifyMap.put("tradeState", "1");
             notifyMap.put("totalMoney", payAmount);
-            notifyMap.put("merOrderNo", orderNo);
+            notifyMap.put("merOrderNo",orderNo);
             HttpResponseResult httpResponseResult = webFeignService.updateOrder(notifyMap);
             if (!httpResponseResult.getStatus()) {
                 throw new BizException(httpResponseResult.getMsg());
@@ -768,14 +811,22 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
     @Override
     @Transactional
     public void paymentFailedHandle(String orderNo, Map<String, Object> notifyMap) {
-
-        OmsOrderDetail detail = detail(orderNo);
+        UserOrderPayment orderPayment = userOrderPaymentService.getByAdapayNo(orderNo);
+        if (orderPayment == null) {
+            throw new BizException("订单支付信息未找到");
+        }
+        OmsOrderDetail detail = detail(orderPayment.getOrderNo());
         if (null == detail) {
             LOG.error("汇付支付回调，订单未找到。 req is {}", orderNo);
             throw new BizException("订单未找到");
         }
         if (detail.getStatus() == 0) {
             cancelOrder(detail.getId(), "支付失败");
+
+            // 修改用户付款状态
+            orderPayment.setStatus(TradeStatusEnum.succeeded.getCode());
+            userOrderPaymentService.saveOrUpdate(orderPayment);
+
             HttpResponseResult httpResponseResult = webFeignService.updateOrder(notifyMap);
             if (!httpResponseResult.getStatus()) {
                 throw new BizException(httpResponseResult.getMsg());
@@ -785,6 +836,30 @@ public class OmsPortalOrderServiceImpl implements OmsPortalOrderService {
         }
     }
 
+    @Override
+    public List<OmsOrderDetail> list(List<String> adapayNoList) {
+        String adapayNos = adapayNoList.stream().collect(Collectors.joining(","));
+
+        List<OmsOrder> orderList = portalOrderDao.listByAdapayNo(adapayNoList,adapayNos);
+        //设置数据信息
+        List<Long> orderIds = orderList.stream().map(OmsOrder::getId).collect(Collectors.toList());
+        OmsOrderItemExample orderItemExample = new OmsOrderItemExample();
+        orderItemExample.createCriteria().andOrderIdIn(orderIds);
+        List<OmsOrderItem> orderItemList = orderItemMapper.selectByExample(orderItemExample);
+        List<OmsOrderDetail> orderDetailList = new ArrayList<>();
+        for (OmsOrder omsOrder : orderList) {
+            OmsOrderDetail orderDetail = new OmsOrderDetail();
+            BeanUtil.copyProperties(omsOrder, orderDetail);
+            List<OmsOrderItem> relatedItemList = orderItemList.stream()
+                                                              .filter(item -> item.getOrderId()
+                                                                                  .equals(orderDetail.getId()))
+                                                              .collect(Collectors.toList());
+            orderDetail.setOrderItemList(relatedItemList);
+            orderDetailList.add(orderDetail);
+        }
+        return orderDetailList;
+    }
+
     /**
      * 订单完成
      *

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/impl/UmsMemberReceiveAddressServiceImpl.java

@@ -74,9 +74,8 @@ public class UmsMemberReceiveAddressServiceImpl implements UmsMemberReceiveAddre
 
     @Override
     public UmsMemberReceiveAddress getItem(Long id) {
-        UmsMember currentMember = memberService.getCurrentMember();
         UmsMemberReceiveAddressExample example = new UmsMemberReceiveAddressExample();
-        example.createCriteria().andMemberIdEqualTo(currentMember.getId()).andIdEqualTo(id);
+        example.createCriteria().andIdEqualTo(id);
         List<UmsMemberReceiveAddress> addressList = addressMapper.selectByExample(example);
         if(!CollectionUtils.isEmpty(addressList)){
             return addressList.get(0);

mec-mall/mall-portal/src/main/java/com/yonge/cooleshow/portal/service/impl/UserOrderPaymentServiceImpl.java

@@ -0,0 +1,56 @@
+package com.yonge.cooleshow.portal.service.impl;
+
+import com.yonge.cooleshow.mbg.mapper.UserOrderPaymentMapper;
+import com.yonge.cooleshow.mbg.model.UserOrderPayment;
+import com.yonge.cooleshow.portal.service.UserOrderPaymentService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Description
+ *
+ * @author liujunchi
+ * @date 2022-04-24
+ */
+@Service
+public class UserOrderPaymentServiceImpl implements UserOrderPaymentService {
+
+    @Autowired
+    private UserOrderPaymentMapper userOrderPaymentMapper;
+
+
+
+    @Override
+    public void save(UserOrderPayment userOrderPayment) {
+        userOrderPaymentMapper.insert(userOrderPayment);
+    }
+
+    @Override
+    public void saveOrUpdate(UserOrderPayment userOrderPayment) {
+        if (userOrderPayment.getId() == null) {
+            userOrderPaymentMapper.insert(userOrderPayment);
+        } else {
+            userOrderPaymentMapper.updateByPrimaryKeySelective(userOrderPayment);
+        }
+    }
+
+
+    @Override
+    public List<UserOrderPayment> getByOrderNo(String orderSn) {
+        return userOrderPaymentMapper.selectByOrderNo(orderSn);
+    }
+
+
+    @Override
+    public UserOrderPayment getByOrderNoAndStatusPaying(String orderSn) {
+        return userOrderPaymentMapper.selectByOrderNoAndStatusPaying(orderSn);
+    }
+
+    @Override
+    public UserOrderPayment getByAdapayNo(String paymentNo) {
+        return userOrderPaymentMapper.selectByAdapayNo(paymentNo);
+    }
+}

mec-mall/mall-portal/src/main/resources/config/mybatis/PortalOrderDao.xml

@@ -41,10 +41,8 @@
         FROM
             oms_order o
             LEFT JOIN oms_order_item ot ON o.id = ot.order_id
-        left join user_order_payment uop on uop.order_no_ = o.order_sn and uop.status_ = 'pending'
         WHERE
-            (o.status = 6 AND o.create_time < date_add(NOW(), INTERVAL -#{orderMinute} MINUTE))
-            or (o.status = 0 and uop.create_time_ < date_add(NOW(), INTERVAL -#{payMinute} MINUTE));
+            (o.status = 0 AND o.create_time < date_add(NOW(), INTERVAL -#{payMinute} MINUTE))
     </select>
 
     <update id="updateSkuStock">
@@ -108,4 +106,17 @@
             #{item.productId}
         </foreach>
     </update>
+
+    <select id="listByAdapayNo" resultType="com.yonge.cooleshow.mbg.model.OmsOrder">
+        select oo.* from
+        user_order_payment uop
+        left join oms_order oo on oo.order_sn = uop.adapay_no_
+        <where>
+            uop.adapay_no_ in
+            <foreach collection="alapayNoList" separator="," item="item" close=")" open="(" >
+                #{item}
+            </foreach>
+        </where>
+        order by find_in_set(uop.adapay_no_,#{adapayNos})
+    </select>
 </mapper>

mec-web/src/main/java/com/ym/mec/web/controller/APIController.java

@@ -145,6 +145,18 @@ public class APIController extends BaseController {
 		}
 	}
 
+
+	@PostMapping("/mallSaveOrderInfo")
+	public HttpResponseResult<Map> mallSaveOrderInfo(@RequestBody MallCreateOrderModel model) {
+		try {
+			studentPaymentOrderService.mallSaveOrderInfo(model);
+			return succeed();
+		} catch (Exception e) {
+			e.printStackTrace();
+			return failed();
+		}
+	}
+
 	@ApiOperation(value = "台牌支付")
 	@PostMapping("/executePayment")
 	@ApiImplicitParams({