畅购是一个综合性的B2C平台, 基于ssm框架, 采用分布式系统架构。.zip

package com.changgou.order.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fescar.spring.annotation.GlobalTransactional; import com.changgou.goods.feign.SkuFeign; import com.changgou.order.config.RabbitMQConfig; import com.changgou.order.dao.*; import com.changgou.order.pojo.*; import com.changgou.order.service.CartService; import com.changgou.order.service.OrderService; import com.changgou.pay.feign.PayFeign; import com.changgou.util.IdWorker; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import tk.mybatis.mapper.entity.Example; import java.time.LocalDate; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; @Service public class OrderServiceImpl implements OrderService { @Autowired private OrderMapper orderMapper; /** * 查询全部列表 * @return */ @Override public List<Order> findAll() { return orderMapper.selectAll(); } /** * 根据ID查询 * @param id * @return */ @Override public Order findById(String id){ return orderMapper.selectByPrimaryKey(id); } @Autowired private CartService cartService; @Autowired private IdWorker idWorker; @Autowired private OrderItemMapper orderItemMapper; @Autowired private RedisTemplate redisTemplate; @Autowired private SkuFeign skuFeign; @Autowired private TaskMapper taskMapper; @Autowired private RabbitTemplate rabbitTemplate; /** * 增加 * @param order */ @Override @GlobalTransactional(name = "order_add") public String add(Order order){ //1.获取购物车的相关数据(redis) Map cartMap = cartService.list(order.getUsername()); List<OrderItem> orderItemList = (List<OrderItem>) cartMap.get("orderItemList"); //2.统计计算:总金额,总数量 //3.填充订单数据并保存到tb_order order.setTotalNum((Integer) cartMap.get("totalNum")); order.setTotalMoney((Integer) cartMap.get("totalMoney")); order.setPayMoney((Integer) cartMap.get("totalMoney")); order.setCreateTime(new Date()); order.setUpdateTime(new Date()); order.setBuyerRate("0"); // 0:未评价 1:已评价 order.setSourceType("1"); //1:WEB order.setOrderStatus("0"); //0:未完成 1:已完成 2:已退货 order.setPayStatus("0"); //0:未支付 1:已支付 order.setConsignStatus("0"); //0:未发货 1:已发货 String orderId = idWorker.nextId()+""; order.setId(orderId); orderMapper.insertSelective(order); //4.填充订单项数据并保存到tb_order_item for (OrderItem orderItem : orderItemList) { orderItem.setId(idWorker.nextId()+""); orderItem.setIsReturn("0"); //0:未退货 1:已退货 orderItem.setOrderId(orderId); orderItemMapper.insertSelective(orderItem); } //扣减库存并增加销量 skuFeign.decrCount(order.getUsername()); //int i =1/0; //添加任务数据 System.out.println("向订单数据库中的任务表去添加任务数据"); Task task = new Task(); task.setCreateTime(new Date()); task.setUpdateTime(new Date()); task.setMqExchange(RabbitMQConfig.EX_BUYING_ADDPOINTUSER); task.setMqRoutingkey(RabbitMQConfig.CG_BUYING_ADDPOINT_KEY); Map map = new HashMap(); map.put("username",order.getUsername()); map.put("orderId",orderId); map.put("point",order.getPayMoney()); task.setRequestBody(JSON.toJSONString(map)); taskMapper.insertSelective(task); //5.删除购物车数据(redis) redisTemplate.delete("cart_"+order.getUsername()); //发送延迟消息 rabbitTemplate.convertAndSend("","queue.ordercreate",orderId); return orderId; } /** * 修改 * @param order */ @Override public void update(Order order){ orderMapper.updateByPrimaryKey(order); } /** * 删除 * @param id */ @Override public void delete(String id){ orderMapper.deleteByPrimaryKey(id); } /** * 条件查询 * @param searchMap * @return */ @Override public List<Order> findList(Map<String, Object> searchMap){ Example example = createExample(searchMap); return orderMapper.selectByExample(example); } /** * 分页查询 * @param page * @param size * @return */ @Override public Page<Order> findPage(int page, int size){ PageHelper.startPage(page,size); return (Page<Order>)orderMapper.selectAll(); } /** * 条件+分页查询 * @param searchMap 查询条件 * @param page 页码 * @param size 页大小 * @return 分页结果 */ @Override public Page<Order> findPage(Map<String,Object> searchMap, int page, int size){ PageHelper.startPage(page,size); Example example = createExample(searchMap); return (Page<Order>)orderMapper.selectByExample(example); } @Autowired private OrderLogMapper orderLogMapper; @Override @Transactional public void updatePayStatus(String orderId, String transactionId) { //1.查询订单 Order order = orderMapper.selectByPrimaryKey(orderId); if (order != null && "0".equals(order.getPayStatus())){ //2.修改订单的支付状态 order.setPayStatus("1"); order.setOrderStatus("1"); order.setUpdateTime(new Date()); order.setPayTime(new Date()); order.setTransactionId(transactionId); //微信返回的交易流水号 orderMapper.updateByPrimaryKeySelective(order); //3.记录订单日志 OrderLog orderLog = new OrderLog(); orderLog.setId(idWorker.nextId()+""); orderLog.setOperater("system"); orderLog.setOperateTime(new Date()); orderLog.setOrderStatus("1"); orderLog.setPayStatus("1"); orderLog.setRemarks("交易流水号:"+transactionId); orderLog.setOrderId(orderId); orderLogMapper.insert(orderLog); } } @Autowired private PayFeign payFeign; @Override @Transactional public void closeOrder(String orderId) { /** * 1.根据订单id查询mysql中的订单信息,判断订单是否存在,判断订单的支付状态 * 2. 基于微信查询订单信息(微信) * 2.1)如果当前订单的支付状态为已支付,则进行数据补偿(mysql) * 2.2)如果当前订单的支付状态为未支付,则修改mysql中的订单信息,新增订单日志,恢复商品的库存,基于微信关闭订单 */ System.out.println("关闭订单业务开启:"+orderId); Order order = orderMapper.selectByPrimaryKey(orderId); if (order == null){ throw new RuntimeException("订单不存在!"); } if (!"0".equals(order.getPayStatus())){ System.out.println("当前订单不需要关闭"); return; } System.out.println("关闭订单校验通过:"+orderId); //基于微信查询订单信息 Map wxQueryMap = (Map) payFeign.queryOrder(orderId).getData(); System.out.println("查询微信支付订单:"+wxQueryMap); //如果订单的支付状态为已支付,进行数据补偿(mysql) if ("SUCCESS".equals(wxQueryMap.get("trade_state"))){ this.u