Commit 3a9a02aa authored by zhaowei's avatar zhaowei

test

parent 02fdf72d
package com.miya.draw; ///*
//package com.miya.draw;
import com.alibaba.fastjson.JSON; //
import com.miya.draw.entity.ActivityGoods; //import com.alibaba.fastjson.JSON;
import com.miya.draw.manager.IDrawManager; //import com.miya.draw.entity.ActivityGoods;
import com.miya.draw.manager.IOtherManager; //import com.miya.draw.manager.IDrawManager;
import com.miya.draw.model.SyncTradeConfigModel; //import com.miya.draw.manager.IOtherManager;
import com.miya.draw.service.IActivityGoodsService; //import com.miya.draw.model.SyncTradeConfigModel;
import com.miya.draw.util.OrikaUtil; //import com.miya.draw.service.IActivityGoodsService;
import com.miya.draw.xxljob.DrawResultSyncJob; //import com.miya.draw.util.OrikaUtil;
import com.miya.draw.xxljob.TradeSyncJob; //import com.miya.draw.xxljob.DrawResultSyncJob;
import io.swagger.annotations.ApiModelProperty; //import com.miya.draw.xxljob.TradeSyncJob;
import lombok.Data; //import io.swagger.annotations.ApiModelProperty;
import org.apache.http.entity.ContentType; //import lombok.Data;
import org.junit.jupiter.api.Test; //import org.apache.http.entity.ContentType;
import org.springframework.beans.factory.annotation.Autowired; //import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest; //import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.mock.web.MockMultipartFile; //import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.web.multipart.MultipartFile; //import org.springframework.mock.web.MockMultipartFile;
//import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource; //
import java.io.File; //import javax.annotation.Resource;
import java.io.FileInputStream; //import java.io.File;
import java.io.IOException; //import java.io.FileInputStream;
import java.io.Serializable; //import java.io.IOException;
import java.time.LocalDateTime; //import java.io.Serializable;
import java.util.List; //import java.time.LocalDateTime;
import java.util.stream.Collectors; //import java.util.List;
//import java.util.stream.Collectors;
@SpringBootTest //
class DrawApplicationTests { //@SpringBootTest
//class DrawApplicationTests {
@Autowired //
protected TradeSyncJob tradeSyncJob; // @Autowired
// protected TradeSyncJob tradeSyncJob;
@Autowired //
protected DrawResultSyncJob drawResultSyncJob; // @Autowired
// protected DrawResultSyncJob drawResultSyncJob;
@Autowired //
protected IDrawManager drawManager; // @Autowired
// protected IDrawManager drawManager;
@Test //
void contextLoads() { // @Test
// void contextLoads() {
} //
// }
//
@Test //
public void testSyncJob() throws Exception { // @Test
SyncTradeConfigModel model = new SyncTradeConfigModel(); // public void testSyncJob() throws Exception {
model.setMaxSize(3); // SyncTradeConfigModel model = new SyncTradeConfigModel();
model.setWriteUnit(3); // model.setMaxSize(3);
tradeSyncJob.execute(null); // model.setWriteUnit(3);
} // tradeSyncJob.execute(null);
// }
@Test //
public void testSyncJob1() throws Exception { // @Test
SyncTradeConfigModel model = new SyncTradeConfigModel(); // public void testSyncJob1() throws Exception {
model.setMaxSize(10); // SyncTradeConfigModel model = new SyncTradeConfigModel();
drawResultSyncJob.execute(JSON.toJSONString(model)); // model.setMaxSize(10);
} // drawResultSyncJob.execute(JSON.toJSONString(model));
// }
@Test //
public void testJob1() throws Exception { // @Test
for (int i = 0; i < 10000; i++) { // public void testJob1() throws Exception {
drawManager.drawClick("15314614603"); // for (int i = 0; i < 10000; i++) {
} // drawManager.drawClick("15314614603");
} // }
// }
@Autowired //
private IOtherManager otherManager; // @Autowired
// private IOtherManager otherManager;
@Test //
public void testSendCoupon() { // @Test
otherManager.sendCoupon("123", "", 1L); // public void testSendCoupon() {
} // otherManager.sendCoupon("123", "", 1L);
// }
@Resource //
private IActivityGoodsService activityGoodsService; // @Resource
// private IActivityGoodsService activityGoodsService;
@Test //
public void insertGoods() throws IOException { // @Test
String path = "C:\\Users\\Administrator\\Desktop\\2.xlsx"; // public void insertGoods() throws IOException {
File file = new File(path); // String path = "C:\\Users\\Administrator\\Desktop\\2.xlsx";
FileInputStream fileInputStream = new FileInputStream(file); // File file = new File(path);
MultipartFile multipartFile = new MockMultipartFile("copy" + file.getName(), file.getName(), ContentType.APPLICATION_OCTET_STREAM.toString(), fileInputStream); // FileInputStream fileInputStream = new FileInputStream(file);
List<Object> objects = EasyExcelUtil.readExcel(multipartFile, Model1.class); // MultipartFile multipartFile = new MockMultipartFile("copy" + file.getName(), file.getName(), ContentType.APPLICATION_OCTET_STREAM.toString(), fileInputStream);
List<Model1> model1List; // List<Object> objects = EasyExcelUtil.readExcel(multipartFile, Model1.class);
model1List = OrikaUtil.convertList(objects.stream().skip(1).collect(Collectors.toList()), Model1.class); // List<Model1> model1List;
System.err.println(JSON.toJSONString(model1List)); // model1List = OrikaUtil.convertList(objects.stream().skip(1).collect(Collectors.toList()), Model1.class);
System.err.println(model1List.size()); // System.err.println(JSON.toJSONString(model1List));
List<ActivityGoods> activityGoodsList = model1List.stream() // System.err.println(model1List.size());
.map(x -> { // List<ActivityGoods> activityGoodsList = model1List.stream()
ActivityGoods activityGoods = OrikaUtil.convert(x, ActivityGoods.class); // .map(x -> {
activityGoods.setActivityId(3L); // ActivityGoods activityGoods = OrikaUtil.convert(x, ActivityGoods.class);
activityGoods.setValidState(1); // activityGoods.setActivityId(3L);
activityGoods.setCreateTime(LocalDateTime.now()); // activityGoods.setValidState(1);
activityGoods.setUpdateTime(LocalDateTime.now()); // activityGoods.setCreateTime(LocalDateTime.now());
return activityGoods; // activityGoods.setUpdateTime(LocalDateTime.now());
}).collect(Collectors.toList()); // return activityGood
// }).collect(Collectors.toList());
activityGoodsService.saveBatch(activityGoodsList); //
} // activityGoodsService.saveBatch(activityGoodsList);
// }
//
@Data //
public static class Model1 implements Serializable, Cloneable { // @Data
// public static class Model1 implements Serializable, Cloneable {
private String type1; //
// private String type1;
private String type2; //
// private String type2;
@ApiModelProperty(value = "货号") //
private String code; // @ApiModelProperty(value = "货号")
// private String code;
private String type3; //
// private String type3;
private String type4; //
// private String type4;
@ApiModelProperty(value = "新小类") //
private String newType; // @ApiModelProperty(value = "新小类")
// private String newType;
private String type5; //
// private String type5;
@ApiModelProperty(value = "活动商品名称") //
private String goodsName; // @ApiModelProperty(value = "活动商品名称")
// private String goodsName;
@ApiModelProperty(value = "条形码") //
private String barcode; // @ApiModelProperty(value = "条形码")
// private String barcode;
//
} //
// }
} //
//}
//*/
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment