diff --git a/src/test/java/test/Test.java b/src/test/java/test/Test.java index c417b4b..c0ebd53 100644 --- a/src/test/java/test/Test.java +++ b/src/test/java/test/Test.java @@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.kiisoo.ic.activity.entity.*; import com.kiisoo.ic.activity.service.*; import com.kiisoo.ic.app.IcApplication; +import com.kiisoo.ic.config.WxCpConfiguration; import com.kiisoo.ic.generalize.entity.PrivilageOrganizational; import com.kiisoo.ic.store.mapper.PoiStoreDOMapper; import com.kiisoo.ic.common.utils.RedisUtil; @@ -28,6 +29,7 @@ import lombok.extern.slf4j.Slf4j; import com.kiisoo.ic.wx.service.QWMailListManageService; import lombok.extern.slf4j.Slf4j; import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.cp.api.impl.WxCpServiceOkHttpImpl; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.io.FileUtils; import org.apache.commons.lang3.StringUtils; @@ -37,6 +39,7 @@ import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.transaction.annotation.Transactional; +import java.io.*; import java.util.Date; import java.util.List; import java.util.Set; @@ -47,8 +50,6 @@ import java.util.List; import java.util.Set; import java.util.stream.Collectors; -import java.io.File; -import java.io.IOException; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -105,7 +106,7 @@ public class Test { */ Date now = new Date(); List starts = pmnActivityInstanceService.list(Wrappers.lambdaQuery().eq(PmnActivityInstance::getStatus, 1).le(PmnActivityInstance::getBeginTime, now).ge(PmnActivityInstance::getEndTime, now).select(PmnActivityInstance::getId)); - if(starts.size() > 0) { + if (starts.size() > 0) { starts.stream().forEach(item -> item.setStatus(2L)); Set startInstances = starts.stream().map(PmnActivityInstance::getId).collect(Collectors.toSet()); pmnActivityInstanceService.updateBatchById(starts); @@ -127,7 +128,7 @@ public class Test { * 失效 */ List ends = pmnActivityInstanceService.list(Wrappers.lambdaQuery().ne(PmnActivityInstance::getStatus, 3).ne(PmnActivityInstance::getStatus, 4).le(PmnActivityInstance::getEndTime, now).select(PmnActivityInstance::getId)); - if(ends.size() > 0) { + if (ends.size() > 0) { ends.stream().forEach(item -> item.setStatus(3L)); Set endInstances = ends.stream().map(PmnActivityInstance::getId).collect(Collectors.toSet()); pmnActivityInstanceService.updateBatchById(ends); @@ -159,7 +160,7 @@ public class Test { String staffCode = arr[2]; - if(name.length() < 3){ + if (name.length() < 3) { System.out.println("不修改" + item); continue; } @@ -170,12 +171,12 @@ public class Test { map.put("status", "1"); List staffList = poiStoreStaffDOMapper.selectByMap(map); - if(CollectionUtils.isEmpty(staffList)){ + if (CollectionUtils.isEmpty(staffList)) { System.out.println("staff_code 空 | " + item); continue; } - if(staffList.size() > 1){ + if (staffList.size() > 1) { System.out.println("多个人员编码" + item); continue; } @@ -206,13 +207,12 @@ public class Test { String abName = arr[3]; - PoiStore storeDO = new PoiStore(); storeDO.setId(storeId); PoiStore storeEntity = new PoiStore(); storeEntity = poiStoreDOMapper.selectOne(new QueryWrapper<>(storeDO)); - if(null == storeEntity){ + if (null == storeEntity) { System.out.println(item); continue; } @@ -227,7 +227,7 @@ public class Test { // 创建二维码 String qrCode = storeEmployeeService.getQrCodeFromBSD("mayifei", Constants.BSD_REQ_QRCODE_TYPE_ACTIVITY, "pmn_1_1_1", "A0645"); - if(StringUtils.isBlank(qrCode)){ + if (StringUtils.isBlank(qrCode)) { System.out.println("error"); } } @@ -238,7 +238,7 @@ public class Test { // 门店号 boolean b = storeEmployeeService.cancelQrCodeFromBSD("18152147506", "0"); - if(!b){ + if (!b) { System.out.println("error"); } } @@ -261,11 +261,10 @@ public class Test { @org.junit.Test public void test8() throws Exception { - customerDataJob.handle(true,null); + customerDataJob.handle(true, null); } - @Autowired private QWMailListManageService qwMailListManageService; @@ -280,4 +279,21 @@ public class Test { String url = storeEmployeeService.getQrCodeFromBSD("mayifei", "0", "0", "EZ17"); System.out.println(url); } + + @org.junit.Test + public void media() throws WxErrorException, IOException { + WxCpServiceOkHttpImpl serviceOkHttp = WxCpConfiguration.getCpService(WxCpConfiguration.APPLICATIONID); + File file = serviceOkHttp.getMediaService().download("3X4c2rhaeR1CoQG7v-KFRy-aVHwhc5lR_IpvfB6iu4fY"); + File targetPath = new File("upload/"); + if (!targetPath.exists()) { + boolean state = targetPath.mkdirs(); + } + InputStream input = new FileInputStream(file); + OutputStream out = new FileOutputStream("upload/test.png"); + byte[] buf = new byte[1024]; + int bytesRead; + if((bytesRead = input.read(buf)) != -1) { + out.write(buf, 0, bytesRead); + } + } }