package com.whn.hellospring;

import com.whn.hellospring.mapper.CoffeeMapper;
import com.whn.hellospring.model.CoffeeDO;
import com.whn.hellospring.model.CoffeeOrderDO;
import com.whn.hellospring.model.OrderState;
import com.whn.hellospring.repository.CoffeeOrderRepository;
import com.whn.hellospring.repository.CoffeeRepository;
import com.whn.hellospring.service.CoffeeOrderService;
import com.whn.hellospring.service.CoffeeService;
import com.whn.hellospring.service.JuheService;
import org.joda.money.CurrencyUnit;
import org.joda.money.Money;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import lombok.extern.slf4j.Slf4j;
import redis.clients.jedis.Jedis;

import java.util.List;
import java.util.Optional;
import java.util.stream.Collectors;

@ComponentScan("com")
@SpringBootApplication
@RestController
@Slf4j
@EnableJpaRepositories
@EnableTransactionManagement
public class HelloSpringApplication extends SpringBootServletInitializer implements ApplicationRunner {

	@Autowired
	private CoffeeRepository coffeeRepository;

	@Autowired
	private CoffeeOrderRepository orderRepository;

	@Autowired
	private CoffeeMapper coffeeMapper;

	@Autowired
	private CoffeeService coffeeService;

	@Autowired
	private CoffeeOrderService orderService;


	@Autowired
	private JuheService juheService;

	public static void main(String[] args) {
		SpringApplication.run(HelloSpringApplication.class, args);
	}

	// 继承SpringBootServletInitializer 实现configure 方便打war 外部服务器部署。

	@Override
	protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
		return application.sources(HelloSpringApplication.class);
	}

	@Transactional
	@Override
	public void run(ApplicationArguments args) throws Exception {
//		initOrders();

//		findOrders();

//		testMybatis();

//		breakPage();

//		bucks();//初步测试

//		oil();

//		testRedis();



	}

	private void testRedis() {
		Jedis jedis = new Jedis("192.168.0.217");
		jedis.auth("root");//加入这一段代码
		System.out.println("Server is running: "+jedis.ping());
		System.out.println("connection to server sucessfully");
		jedis.set("title","hellword");
		System.out.println(jedis.get("title"));
	}

	private void oil() {
		juheService.getOilPrice();

	}

	private void bucks() {
		log.info("findAllCoffee{}",coffeeRepository.findAll());
		Optional<CoffeeDO> latte = coffeeService.findOneCoffee("Latte");
		if (latte.isPresent()){
//			CoffeeOrderDO order = orderService.createOrder( latte.get());
//			log.info("update",orderService.updateState(order,OrderState.INIT));
//			log.info("update",orderService.updateState(order,OrderState.PAID));
		}
	}


	/**
	 * 分页测试
	 * Mybatis PageHelper
	 */
//	private void breakPage() {
//		//第一页数据
//		coffeeMapper.findAllWithRowBounds(new RowBounds(1,3))
//				.forEach(c->log.info("page(1) Coffee{}",c));
//
//		//第二页数据
//		coffeeMapper.findAllWithRowBounds(new RowBounds(2,3))
//				.forEach(c->log.info("page(2) Coffee{}",c));
//
//		log.info("=============================");
//
//		//page传递为0的时候会取出所有数据
//		coffeeMapper.findAllWithRowBounds(new RowBounds(1,0))
//				.forEach(c->log.info("Page(1) 所有数据 Coffee{}",c));
//
//		log.info("=============================");
//
//		//使用参数来获取
//		coffeeMapper.findAllWithParam(1,3)
//				.forEach(c->log.info("Page(1) 使用参数来获取3 Coffee{}",c));
//
//
//		List<Coffee> list = coffeeMapper.findAllWithParam(2,3);
//		PageInfo<Coffee> page = new PageInfo<>(list);
//		log.info("page{}",page);
//
//	}

//	private void testMybatis() {
//		Coffee c = Coffee.builder().name("espresso")
//				.price(Money.of(CurrencyUnit.of("CNY"),20.0))
//				.build();
//
//		int count = coffeeMapper.save(c);
//		log.info("Save{} coffee:{}",count,c);
//
//		c = Coffee.builder().name("latte")
//				.price(Money.of(CurrencyUnit.of("CNY"),25.0))
//				.build();
//
//		count = coffeeMapper.save(c);
//		log.info("Save{} coffee:{}",count,c);
//
//		c = coffeeMapper.findById(c.getId());
//		log.info("find coffee:{}",c);
//
//	}


	@RequestMapping("/hello")
	public String hello(){
		return "hello spring";
	}

	private void initOrders(){

		//创建一杯咖啡
		CoffeeDO espresso = CoffeeDO.builder().name("espresso")
				.price(Money.of(CurrencyUnit.of("CNY"),20.0))
				.build();
		coffeeRepository.save(espresso);
		log.info("Coffee:{}",espresso);


		//创建一杯咖啡
		CoffeeDO latte = CoffeeDO.builder().name("latte")
				.price(Money.of(CurrencyUnit.of("CNY"),30.0))
				.build();
		coffeeRepository.save(latte);
		log.info("Coffee:{}",latte);


		//创建一个订单，包含一杯咖啡
		CoffeeOrderDO order = CoffeeOrderDO.builder()
				.customer("Li Lei")
//				.items(Collections.singletonList(espresso))
				.state(OrderState.INIT)
				.build();
		orderRepository.save(order);
		log.info("Order:{}",order);


		//创建一个订单，包含两杯咖啡
		 order = CoffeeOrderDO.builder()
				.customer("Li Lei")
//				.items(Arrays.asList(espresso,latte))
				 .state(OrderState.INIT)
				.build();
		orderRepository.save(order);
		log.info("Order:{}",order);


		//创建一个订单，包含两杯咖啡
		order = CoffeeOrderDO.builder()
				.customer("Li Lei")
//				.items(Arrays.asList(espresso,latte))
				.state(OrderState.INIT)
				.build();
		orderRepository.save(order);
		log.info("Order:{}",order);

		//创建一个订单，包含两杯咖啡
		order = CoffeeOrderDO.builder()
				.customer("Li Lei")
//				.items(Arrays.asList(espresso,latte))
				.state(OrderState.INIT)
				.build();
		orderRepository.save(order);
		log.info("Order:{}",order);
	}


//	private void  findOrders(){
//		//获取咖啡
//		coffeeRepository
//				.findAll()
//				.forEach(c->log.info("Loading{}",c));
//
//		//获取前三，更新时间降序，ID升序
//		List<CoffeeOrder> list = orderRepository.findTop3ByOrderByUpdateTimeDescIdAsc();
//		log.info("findTop3ByOrderByUpdateTimeDescIdAsc:{}" ,getJoinedOrderId(list));
//
//		//获取Li Lei 的订单id
//		list = orderRepository.findByCustomerOrderById("Li Lei");
//		log.info("findByCustomerOrderById:{}" ,getJoinedOrderId(list));
//
//		//列出订单，订单中的咖啡
//		list.forEach(o->{
//			log.info("Order{}",o.getId());
//			o.getItems().forEach(i->log.info(" Item{}",i));
//		});
//
//		//获取latte的咖啡列表
//		list = orderRepository.findByItems_Name("latte");
//		log.info("findByItems_Name:{}" ,getJoinedOrderId(list));
//	}

	/**
	 * 将列表中的id用，拼接
	 * @param list
	 * @return
	 */
	private String getJoinedOrderId(List<CoffeeOrderDO> list) {
		return list.stream().map(o->o.getId().toString())
				.collect(Collectors.joining(","));
	}
}