1

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<PmnActivityInstance> starts = pmnActivityInstanceService.list(Wrappers.<PmnActivityInstance>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<Long> startInstances = starts.stream().map(PmnActivityInstance::getId).collect(Collectors.toSet());
             pmnActivityInstanceService.updateBatchById(starts);
@@ -127,7 +128,7 @@ public class Test {
          * 失效
          */
         List<PmnActivityInstance> ends = pmnActivityInstanceService.list(Wrappers.<PmnActivityInstance>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<Long> 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<PoiStoreStaff> 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);
+        }
+    }
 }