//package org.springblade.modules.rabbitmq.controller;
//
//import lombok.AllArgsConstructor;
//import org.springblade.modules.rabbitmq.config.MQsender;
//import org.springblade.modules.rabbitmq.redis.TaskKey;
//import org.springblade.modules.rabbitmq.redis.RedisService;
//import org.springblade.modules.rabbitmq.vo.Man;
//import org.springblade.modules.rabbitmq.vo.Task;
//import org.springblade.modules.rabbitmq.vo.TaskMessage;
//import org.springframework.web.bind.annotation.GetMapping;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
//
//import java.util.Random;
//
///**
// * 消息发送
// * @author zhongrj
// */
//@RestController
//@AllArgsConstructor
//@RequestMapping("/rabbitmq")
//public class SendMessageController {
//
//	private static int count = 0;
//
//	private final MQsender mQsender;
//
//	private final RedisService redisService;
//
//
//	@GetMapping("/sendDirectMessage")
//	public String sendDirectMessage() {
//		String messageData = "test message, hello!";
//		mQsender.send(messageData);
//		return "ok";
//	}
//
//	/**
//	 * 模拟抢单
//	 * @return
//	 */
//	@GetMapping("/createTask")
//	public String createTask(Long id ,Integer num) {
//		//创建任务
//		Task task = new Task();
//		task.setId(id);
//		task.setNum(num);
//		task.setTaskName("测试");
//		//将任务数量和对应的id 存入redis
//		redisService.set(TaskKey.getTaskStock,""+task.getId(),task.getNum());
//		//返回
//		return "ok";
//	}
//
//
//	/**
//	 * 模拟抢单（不同人员同时抢）
//	 * @return
//	 */
//	@GetMapping("/testSend")
//	public String testSend(Long id) {
//		//模拟创建人员
//		Man man = new Man();
//		man.setId(System.currentTimeMillis() + new Random().nextInt(1000000));
//		man.setUsername("task"+ count);
//		// 预减库存
//		long stack = redisService.decr(TaskKey.getTaskStock,""+id);
//		if (stack<0){
//			return "已结束";
//		}
//		//入队列
//		TaskMessage taskMessage = new TaskMessage();
//		taskMessage.setTaskId(id);
//		taskMessage.setManId(man.getId());
//		//发送消息
//		mQsender.sendTaskMessage(taskMessage);
//		//返回
//		return "ok";
//	}
//}