基于Java与HTML的阿卡丽二手商城设计源码

package com.akali.order.distributed.utils; import com.akali.common.utils.JSONUtils; import com.akali.order.distributed.utils.model.TaskInstance; import com.akali.order.distributed.utils.model.Test1; import com.akali.order.distributed.utils.model.mock.*; import com.akali.order.distributed.utils.repository.*; import com.google.gson.reflect.TypeToken; import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.data.domain.Page; import org.springframework.data.domain.PageRequest; import org.springframework.data.domain.Pageable; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.util.StringUtils; import java.lang.reflect.Type; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.*; import java.util.concurrent.*; @Slf4j @SpringBootTest class OrderDistributedUtilsApplicationTests { @Autowired private TaskInstanceRepository taskInstanceRepository; @Autowired private ApiImproveRepository apiImproveRepository; @Autowired private ApiCostReduceRepository apiCostReduceRepository; @Autowired private ApiIncomeRepository apiIncomeRepository; @Autowired private HotApiRepository hotApiRepository; @Autowired private RedisTemplate<String, Object> redisTemplate; @Test void contextLoads() { System.out.println("启动成功！！"); } @Test void testTaskInstanceRepository() { // TaskInstance taskInstance = new TaskInstance(); // taskInstance.setId(UUID.randomUUID().toString()); // taskInstance.setTaskName("TestTaskName"); // // 新增 // taskInstanceRepository.save(taskInstance); // 根据id查询 // TaskInstance taskById = findTaskById("bedd3268-bbee-4938-ae37-6f75aafa8dcc"); // if (taskById != null) { // // 更新 // taskById.setTaskName("NewTaskname"); // taskInstanceRepository.save(taskById); // } // 分页查询 PageRequest pageRequest = PageRequest.of(0, 10); Page<TaskInstance> tasks = taskInstanceRepository.findByTaskNameAndSliceAndStatus("NewTaskname", "01", "01", pageRequest); for (TaskInstance task : tasks) { System.out.println(task); } } private TaskInstance findTaskById(String id) { Optional<TaskInstance> existedTask = taskInstanceRepository.findById(id); return existedTask.orElse(null); } @Test void testStrStartWith() { String testStr = "CRON: 0 45 7 * * ?"; // if (testStr.startsWith("CRON:")) { // new CronSe // } } @Test void testJsonExam() { List<String> test1s = new ArrayList<>(); test1s.add(JSONUtils.toJson(new Test1(1, "我是1"))); test1s.add(JSONUtils.toJson(new Test1(1, "我是2"))); test1s.add(JSONUtils.toJson(new Test1(2, "我是3"))); List<String> attributes = getAttributes(1, test1s); System.out.println(attributes); } private List<String> getAttributes(Integer type, List<String> jsonList) { List<String> attributes = new ArrayList<>(); if (jsonList == null || jsonList.isEmpty()) { return attributes; } for (String s : jsonList) { Test1 test1 = JSONUtils.fromJson(s, Test1.class); if (test1 != null && type.equals(test1.getType())) { attributes.add(test1.getDesc()); } } return attributes; } // 插入1万条收入信息 @Test void testApiIncome() { List<ApiIncome> apiIncomes = new ArrayList<>(); LocalDateTime currentTime = LocalDateTime.now(); for (int i = 0; i < 1000; i++) { ApiIncome apiIncome = new ApiIncome(); apiIncome.setIncome(new BigDecimal("10000")); apiIncome.setOrderId("ORDER001"); apiIncome.setTitle("测试"); apiIncome.setCreateTime(currentTime); apiIncome.setUpdateTime(currentTime); apiIncomes.add(apiIncome); } apiIncomeRepository.saveAll(apiIncomes); } // 插入1万条降本信息 @Test void testApiCostReduce() { List<ApiCostReduce> apiCostReduces = new ArrayList<>(); LocalDateTime currentTime = LocalDateTime.now(); for (int i = 0; i < 1000; i++) { ApiCostReduce apiCostReduce = new ApiCostReduce(); apiCostReduce.setCostReduce(new BigDecimal("10000")); apiCostReduce.setOrderId("ORDER001"); apiCostReduce.setTitle("测试"); apiCostReduce.setCreateTime(currentTime); apiCostReduce.setUpdateTime(currentTime); apiCostReduces.add(apiCostReduce); } apiCostReduceRepository.saveAll(apiCostReduces); } // 插入1万条提效信息 @Test void testApiImprove() { List<ApiImprove> apiImproves = new ArrayList<>(); LocalDateTime currentTime = LocalDateTime.now(); for (int i = 0; i < 1000; i++) { ApiImprove apiImprove = new ApiImprove(); apiImprove.setImprove(new BigDecimal("10000")); apiImprove.setOrderId("ORDER001"); apiImprove.setTitle("测试"); apiImprove.setCreateTime(currentTime); apiImprove.setUpdateTime(currentTime); apiImproves.add(apiImprove); } apiImproveRepository.saveAll(apiImproves); } // 不使用CompletableFuture并行加载能力统计模块的数据 @Test void testUnCompletableFuture() { long start = System.currentTimeMillis(); ApiStatistics apiStatistics = new ApiStatistics(); // 能力收入信息 api_income List<ApiIncome> all = apiIncomeRepository.findAll(); apiStatistics.setApiIncomeList(all); // 能力降本信息 api_cost_reduce List<ApiCostReduce> all1 = apiCostReduceRepository.findAll(); apiStatistics.setApiCostReduceList(all1); // 能力提效信息 api_improve List<ApiImprove> all2 = apiImproveRepository.findAll(); apiStatistics.setApiImproveList(all2); log.info("不使用Future花费时间：{}", System.currentTimeMillis() - start); // 326 } // 使用CompletableFuture并行加载能力统计模块的数据 @Test void testCompletableFuture() throws ExecutionException, InterruptedException { long start = System.currentTimeMillis(); ApiStatistics apiStatistics = new ApiStatistics(); ExecutorService executorService = Executors.newWorkStealingPool(); CompletableFuture<List<ApiIncome>> list1 = CompletableFuture.supplyAsync(() -> apiIncomeRepository.findAll(), executorService); CompletableFuture<List<ApiCostReduce>> list2 = CompletableFuture.supplyAsync(() -> apiCostReduceRepository.findAll(), executorService); CompletableFuture<List<ApiImprove>> list3 = CompletableFuture.supplyAsync(() -> apiImproveRepository.findAll(), executorService); CompletableFuture.allOf(list1, list2, list3).join(); apiStatistics.setApiIncomeList(list1.get()); apiStatistics.setApiCostReduceList(list2.get()); apiStatistics.setApiImproveList(list3.get()); log.info("使用Future花费时间：{}", System.currentTimeMillis() - start); // 332 } /** * 使用redis缓存，降低热门能力接口的响应时间 */ @Test void testSaveHotApi() { // 先存入10万热门能力 List<HotApi> hotApis = new ArrayList<>(); for (int i = 0; i < 100000; i++) { HotApi hotApi = new HotApi(); hotApi.setApiName("牛头测试能力名称"); hotApi.setApiCode("牛头测试能力编码"); hotApi.setApiDesc("牛头测试能力描述");