//根据username 查询
public List<Address> list(String username);

@Override
public List<Address> list(String username) {
    Address address=new Address();
    address.setUsername(username);

    List<Address> addressList = addressMapper.select(address);

    return addressList;
}

@Autowired
TokenDecode tokenDecode;

//根据username 查询 lsit<Address>
@GetMapping("/list")
public List<Address> list(){
    //当前登录人
    String username = tokenDecode.getUserInfo().get("username");

    List<Address> addressList = addressService.list(username);

    return addressList;
}

@Bean
public TokenDecode tokenDecode(){
    return  new TokenDecode();
}

@Controller
@RequestMapping("/worder")
public class OrderController {
    @RequestMapping("/ready/order")
    public String readyOrder(Model model) {
        return "order";
    }
}

@FeignClient(name="user")
public interface AddressFeign {

    /***
     * 查询用户的收件地址信息
     * @return
     */
    @GetMapping(value = "/list")
    public Result<List<Address>> list();
}

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients(basePackages = {"com.ydles.order.feign","com.ydles.user.feign"})
public class OrderWebApplication {

@Controller
@RequestMapping("/worder")
public class OrderController {

    @Autowired
    private AddressFeign addressFeign;

    @Autowired
    private CartFeign cartFeign;

    @RequestMapping("/ready/order")
    public String readyOrder(Model model) {
         //1收件人的地址信息
        List<Address> addressList = addressFeign.list().getData();
        model.addAttribute("address",addressList);

        //2购物车信息
        Map map = cartFeign.list();
        List<OrderItem> orderItemList = (List<OrderItem>) map.get("orderItemList");
        Integer totalMoney = (Integer) map.get("totalMoney");
        Integer totalNum = (Integer) map.get("totalNum");

        model.addAttribute("carts",orderItemList);
        model.addAttribute("totalMoney",totalMoney);
        model.addAttribute("totalNum",totalNum);
        return "order";
    }
}

//默认收件人信息
for (Address address : addressList) {
    if ("1".equals(address.getIsDefault())){
        //默认收件人
        model.addAttribute("deAddr",address);
        break;
    }
}

@Bean
public IdWorker idWorker() {
    return new IdWorker(workerId, datacenterId);
}

/**
     * 下单
     * @param order
     * 缺啥补啥
     */
@Override
public boolean add(Order order){
    //1 获取 购物车信息
    Map cartMap = cartService.list(order.getUsername());
    //map.put("orderItemList",orderItemList);
    Integer totalNum = (Integer) cartMap.get("totalNum");
    Integer totalMoney = (Integer) cartMap.get("totalMoney");

    //2 order表里存数据
    String orderId = idWorker.nextId()+"";
    order.setId(orderId);
    order.setTotalNum(totalNum);
    order.setTotalMoney(totalMoney);
    //作业：优惠金额 怎么算      本店满50-5 跨店 300-50
    //作业：邮费金额 怎么算
    order.setPayMoney(totalMoney);
    order.setCreateTime(new Date());
    order.setUpdateTime(new Date());
    //作业：买家留言
    order.setBuyerRate("0");
    order.setSourceType("1");
    order.setOrderStatus("0");
    order.setPayStatus("0");
    order.setConsignStatus("0");
    order.setIsDelete("0");

    orderMapper.insertSelective(order);

    //3 orderItem表里存数据
    List<OrderItem> orderItemList = (List<OrderItem>) cartMap.get("orderItemList");
    for (OrderItem orderItem : orderItemList) {
        orderItem.setOrderId(orderId);
        orderItem.setPostFee(0);
        orderItem.setIsReturn("0");
        orderItemMapper.insertSelective(orderItem);
    }

    //4 删除购物车信息
    stringRedisTemplate.delete(CART+order.getUsername());

    return true;
}

@Autowired
TokenDecode tokenDecode;

/***
     * 下单
     * @param order
     * @return
     */
@PostMapping
public Result add(@RequestBody Order order){
    String username = tokenDecode.getUserInfo().get("username");
    order.setUsername(username);

    orderService.add(order);
    return new Result(true,StatusCode.OK,"添加成功");
}

@FeignClient(name = "order")
public interface OrderFeign {

    @PostMapping("/order")
    public Result add(@RequestBody Order order);
}

@Autowired
private OrderFeign orderFeign;

@PostMapping("/add")
@ResponseBody
public Result add(@RequestBody Order order){
    Result result = orderFeign.add(order);
    return result;
}

/**
 * 递减库存
 * @param orderItem
 * @return
 */
@Update("UPDATE tb_sku SET num=num-#{num},sale_num=sale_num+#{num} WHERE id=#{skuId} AND num>=#{num}")
int decrCount(OrderItem orderItem);

/***
 * 库存递减
 * @param username
 */
void decrCount(String username);

@Autowired
private RedisTemplate redisTemplate;

/***
 * 库存递减
 * @param username
 */
@Override
public void decrCount(String username) {
    //获取购物车数据
    List<OrderItem> orderItems = redisTemplate.boundHashOps("Cart_" + username).values();

    //循环递减
    for (OrderItem orderItem : orderItems) {
        //递减库存
        int count = skuMapper.decrCount(orderItem);
        if(count<=0){
            throw new RuntimeException("库存不足，递减失败！");
        }
    }
}

/***
 * 库存递减
 * @param username
 * @return
 */
@PostMapping(value = "/decr/count")
public Result decrCount(@RequestParam("username") String username){
    //库存递减
    skuService.decrCount(username);
    return new Result(true,StatusCode.OK,"库存递减成功！");
}

/***
 * 库存递减
 * @param username
 * @return
 */
@PostMapping(value = "/decr/count")
Result decrCount(@RequestParam(value = "username") String username);

@Bean
public FeignInterceptor feignInterceptor(){
    return new FeignInterceptor();
}

@Autowired
private SkuFeign skuFeign;

//库存减库存
skuFeign.decrCount(order.getUsername());

/**
 * 增加
 * @param order
 */
@Override
public Boolean add(Order order){
    //查询出用户的所有购物车
    Map orderItemMap = cartService.list(order.getUsername());

    //统计计算
    Integer totalMoney = Integer.parseInt(String.valueOf(orderItemMap.get("totalPrice")));
    Integer num = Integer.parseInt(String.valueOf(orderItemMap.get("totalNum")));

    //购买商品数量
    order.setTotalNum(num);
    //购买金额
    order.setTotalMoney(totalMoney);
    //支付金额
    order.setPayMoney(totalMoney);
    //优惠金额
    order.setPreMoney(totalMoney);

    //其他数据完善
    order.setCreateTime(new Date());
    order.setUpdateTime(order.getCreateTime());
    order.setBuyerRate("0");        //0:未评价，1：已评价
    order.setSourceType("1");       //来源，1：WEB
    order.setOrderStatus("0");      //0:未完成,1:已完成，2：已退货
    order.setPayStatus("0");        //0:未支付，1：已支付，2：支付失败
    order.setConsignStatus("0");    //0:未发货，1：已发货，2：已收货
    order.setId(idWorker.nextId());
    int count = orderMapper.insertSelective(order);

    //保存待支付订单到redis中
    redisTemplate.boundValueOps(Constants.ORDER_PAY + order.getUsername()).set(order);

    //添加订单明细
    List<OrderItem> orderItemList = (List<OrderItem>)orderItemMap.get("orderItemList");
    for (OrderItem orderItem : orderItemList) {
        orderItem.setId(idWorker.nextId());
        orderItem.setIsReturn("0");
        orderItem.setOrderId(order.getId());
        orderItemMapper.insertSelective(orderItem);
    }

    //扣减库存
    skuFeign.decrCount(order.getUsername());

    //清除Redis缓存购物车数据
    redisTemplate.delete("Cart_"+order.getUsername());
    return true;
}

/***
 * 增加用户积分
 * @param username
 * @param pint
 * @return
 */
@Update("UPDATE tb_user SET points=points+#{point} WHERE  username=#{username}")
int addUserPoints(@Param("username") String username, @Param("point") Integer pint);

/***
 * 添加用户积分
 * @param username
 * @param pint
 * @return
 */
int addUserPoints(String username,Integer pint);

/***
 * 修改用户积分
 * @param username
 * @param pint
 * @return
 */
@Override
public int addUserPoints(String username, Integer pint) {
    return userMapper.addUserPoints(username,pint);
}

@Autowired
private TokenDecode tokenDecode;

/***
 * 增加用户积分
 * @param points:要添加的积分
 */
@GetMapping(value = "/points/add")
public Result addPoints(Integer points){
    //获取用户名
    Map<String, String> userMap = tokenDecode.getUserInfo();
    String username = userMap.get("username");

    //添加积分
    userService.addUserPoints(username,points);
    return new Result(true,StatusCode.OK,"添加积分成功！");
}

/***
 * 添加用户积分
 * @param points
 * @return
 */
@GetMapping(value = "/points/add")
Result addPoints(@RequestParam(value = "points")Integer points);

/**
  * 此代码为示例代码, 不需要演示, 主要看AT和TCC代码的区别使用
  */
@GlobalTransactional(timeoutMills = 300000, name = "dubbo-demo-tx")
public void purchase(String userId, String commodityCode, int orderCount) {
    LOGGER.info("purchase begin ... xid: " + RootContext.getXID());
    storageService.deduct(commodityCode, orderCount);
    orderService.create(userId, commodityCode, orderCount);
    throw new RuntimeException("AT 模式发生异常，回滚事务");
}

/**
 * 此代码为示例代码, 不需要演示, 主要看AT和TCC代码的区别使用
 * 转账操作
 * @param from  扣钱账户
 * @param to  加钱账户
 * @param amount  转账金额
 * @return
 */
@Override
@GlobalTransactional
public boolean transfer(final String from, final String to, final double amount) {
    //扣钱参与者，一阶段执行
    boolean ret = firstTccAction.prepareMinus(null, from, amount);

    if(!ret){
        //扣钱参与者，一阶段失败; 回滚本地事务和分布式事务
        throw new RuntimeException("账号:["+from+"] 预扣款失败");
    }

    //加钱参与者，一阶段执行
    ret = secondTccAction.prepareAdd(null, to, amount);

    if(!ret){
        throw new RuntimeException("账号:["+to+"] 预收款失败");
    }

    System.out.println(String.format("transfer amount[%s] from [%s] to [%s] finish.", String.valueOf(amount), from, to));
    return true;
}

package com.ydles.order.pojo;

import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
import java.util.Date;

@Table(name = "tb_task")
public class Task {
    @Id
    private Long id;

    @Column(name = "create_time")
    private Date createTime;

    @Column(name = "update_time")
    private Date updateTime;

    @Column(name = "delete_time")
    private Date deleteTime;

    @Column(name = "task_type")
    private String taskType;

    @Column(name = "mq_exchange")
    private String mqExchange;

    @Column(name = "mq_routingkey")
    private String mqRoutingkey;

    @Column(name = "request_body")
    private String requestBody;

    @Column(name = "status")
    private String status;

    @Column(name = "errormsg")
    private String errormsg;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public Date getUpdateTime() {
        return updateTime;
    }

    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }

    public Date getDeleteTime() {
        return deleteTime;
    }

    public void setDeleteTime(Date deleteTime) {
        this.deleteTime = deleteTime;
    }

    public String getTaskType() {
        return taskType;
    }

    public void setTaskType(String taskType) {
        this.taskType = taskType;
    }

    public String getMqExchange() {
        return mqExchange;
    }

    public void setMqExchange(String mqExchange) {
        this.mqExchange = mqExchange;
    }

    public String getMqRoutingkey() {
        return mqRoutingkey;
    }

    public void setMqRoutingkey(String mqRoutingkey) {
        this.mqRoutingkey = mqRoutingkey;
    }

    public String getRequestBody() {
        return requestBody;
    }

    public void setRequestBody(String requestBody) {
        this.requestBody = requestBody;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }

    public String getErrormsg() {
        return errormsg;
    }

    public void setErrormsg(String errormsg) {
        this.errormsg = errormsg;
    }
}

package com.ydles.order.pojo;

import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
import java.util.Date;

@Table(name = "tb_task_his")
public class TaskHis {

    @Id
    private Long id;

    @Column(name = "create_time")
    private Date createTime;

    @Column(name = "update_time")
    private Date updateTime;

    @Column(name = "delete_time")
    private Date deleteTime;

    @Column(name = "task_type")
    private String taskType;

    @Column(name = "mq_exchange")
    private String mqExchange;

    @Column(name = "mq_routingkey")
    private String mqRoutingkey;

    @Column(name = "request_body")
    private String requestBody;

    @Column(name = "status")
    private String status;

    @Column(name = "errormsg")
    private String errormsg;

    public Long getId() {
        return id;
    }

    public void setId(Long id) {
        this.id = id;
    }

    public Date getCreateTime() {
        return createTime;
    }

    public void setCreateTime(Date createTime) {
        this.createTime = createTime;
    }

    public Date getUpdateTime() {
        return updateTime;
    }

    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }

    public Date getDeleteTime() {
        return deleteTime;
    }

    public void setDeleteTime(Date deleteTime) {
        this.deleteTime = deleteTime;
    }

    public String getTaskType() {
        return taskType;
    }

    public void setTaskType(String taskType) {
        this.taskType = taskType;
    }

    public String getMqExchange() {
        return mqExchange;
    }

    public void setMqExchange(String mqExchange) {
        this.mqExchange = mqExchange;
    }

    public String getMqRoutingkey() {
        return mqRoutingkey;
    }

    public void setMqRoutingkey(String mqRoutingkey) {
        this.mqRoutingkey = mqRoutingkey;
    }

    public String getRequestBody() {
        return requestBody;
    }

    public void setRequestBody(String requestBody) {
        this.requestBody = requestBody;
    }

    public String getStatus() {
        return status;
    }

    public void setStatus(String status) {
        this.status = status;
    }

    public String getErrormsg() {
        return errormsg;
    }

    public void setErrormsg(String errormsg) {
        this.errormsg = errormsg;
    }
}

package com.ydles.user.pojo;

import javax.persistence.Table;

@Table(name = "tb_point_log")
public class PointLog {

    private String orderId;
    private String userId;
    private Integer point;

    public String getOrderId() {
        return orderId;
    }

    public void setOrderId(String orderId) {
        this.orderId = orderId;
    }

    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public Integer getPoint() {
        return point;
    }

    public void setPoint(Integer point) {
        this.point = point;
    }
}

package com.ydles.order.config;

import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    //添加积分任务交换机
    public static final String EX_BUYING_ADDPOINTUSER = "ex_buying_addpointuser";

    //添加积分消息队列
    public static final String CG_BUYING_ADDPOINT = "cg_buying_addpoint";

    //完成添加积分消息队列
    public static final String CG_BUYING_FINISHADDPOINT = "cg_buying_finishaddpoint";

    //添加积分路由key
    public static final String CG_BUYING_ADDPOINT_KEY = "addpoint";

    //完成添加积分路由key
    public static final String CG_BUYING_FINISHADDPOINT_KEY = "finishaddpoint";

    //声明交换机
    @Bean(EX_BUYING_ADDPOINTUSER)
    public Exchange EX_BUYING_ADDPOINTUSER(){
        return ExchangeBuilder.directExchange(EX_BUYING_ADDPOINTUSER).durable(true).build();
    }

    //声明队列
    @Bean(CG_BUYING_ADDPOINT)
    public Queue CG_BUYING_ADDPOINT(){
        Queue queue = new Queue(CG_BUYING_ADDPOINT);
        return queue;
    }
    @Bean(CG_BUYING_FINISHADDPOINT)
    public Queue CG_BUYING_FINISHADDPOINT(){
        Queue queue = new Queue(CG_BUYING_FINISHADDPOINT);
        return queue;
    }

    //队列绑定交换机
    @Bean
    public Binding BINDING_CG_BUYING_ADDPOINT(@Qualifier(CG_BUYING_ADDPOINT) Queue queue, @Qualifier(EX_BUYING_ADDPOINTUSER)Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with(CG_BUYING_ADDPOINT_KEY).noargs();
    }
    @Bean
    public Binding BINDING_CG_BUYING_FINISHADDPOINT(@Qualifier(CG_BUYING_FINISHADDPOINT) Queue queue,@Qualifier(EX_BUYING_ADDPOINTUSER)Exchange exchange){
        return BindingBuilder.bind(queue).to(exchange).with(CG_BUYING_FINISHADDPOINT_KEY).noargs();
    }
}

// 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);

@Component
public class QueryPointTask {
    @Autowired
    private TaskMapper taskMapper;
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Scheduled(cron = "0/2 * * * * ?")
    public void queryTask(){
        //1. 获取小于系统当前时间的数据
        List<Task> taskList = taskMapper.findTaskLessThanCurrentTime(new Date());
        if (taskList != null && taskList.size()>0){
            //2.将任务发送到消息队列上
            for (Task task : taskList) {
                rabbitTemplate.convertAndSend(RabbitMQConfig.EX_BUYING_ADDPOINTUSER, RabbitMQConfig.CG_BUYING_ADDPOINT_KEY, JSON.toJSONString(task));
                System.out.println("订单服务向添加积分队列发送了一条消息");
            }
        }
    }
}

@Select("select * from tb_task where update_time<#{currentTime}")
@Results({@Result(column = "create_time",property = "createTime"),
        @Result(column = "update_time",property = "updateTime"),
        @Result(column = "delete_time",property = "deleteTime"),
        @Result(column = "task_type",property = "taskType"),
        @Result(column = "mq_exchange",property = "mqExchange"),
        @Result(column = "mq_routingkey",property = "mqRoutingkey"),
        @Result(column = "request_body",property = "requestBody"),
        @Result(column = "status",property = "status"),
        @Result(column = "errormsg",property = "errormsg")})
List<Task> findTaskLessThanCurrentTime(Date currentTime);

package com.ydles.user.listener;

import com.alibaba.fastjson.JSON;
import com.ydles.order.pojo.Task;
import com.ydles.user.config.RabbitMQConfig;
import com.ydles.user.service.UserService;
import org.apache.commons.lang.StringUtils;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
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.Component;

@Component
public class AddPointListener {

    @Autowired
    private RedisTemplate redisTemplate;

    @Autowired
    private UserService userService;

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @RabbitListener(queues = RabbitMQConfig.CG_BUYING_ADDPOINT)
    public void receiveAddPointMessage(String message){
        System.out.println("用户服务接收到了任务消息");

        //转换消息
        Task task = JSON.parseObject(message, Task.class);
        if (task == null || StringUtils.isEmpty(task.getRequestBody())){
            return;
        }

        //判断redis中当前的任务是否存在
        Object value = redisTemplate.boundValueOps(task.getId()).get();
        if (value != null){
            return;
        }

}

int updateUserPoint(Task task);