From fb82de61823770dd1fa68cd90e046f0835484ca8 Mon Sep 17 00:00:00 2001
From: shuliYao <1397940314@qq.com>
Date: Thu, 18 Apr 2024 11:53:41 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=8B=89=E5=8F=96=E6=95=B0=E6=8D=AE?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=8D=95=E4=B8=9A=E5=8A=A1=E4=B8=BB=E4=BD=93?=
 =?UTF-8?q?=E6=8B=89=E5=8F=96=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ocr/controller/ApiTestController.java     | 68 +++++++++++++++++++
 1 file changed, 68 insertions(+)

diff --git a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/ApiTestController.java b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/ApiTestController.java
index 9190734..cce9ccf 100644
--- a/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/ApiTestController.java
+++ b/jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/controller/ApiTestController.java
@@ -52,6 +52,74 @@ public class ApiTestController {
     @Resource
     private DepartmentMybatisDao departmentMybatisDao;
 
+    /**
+     * 拉取无量云任务数据，根据单租户、业务主体拉取
+     * pull wyl task data
+     * @param request
+     * @return
+     */
+    @GetMapping("pullPictureByOneAccountNo")
+    public String pullPictureByOneAccountNo(HttpServletRequest request){
+        String beginStr = request.getParameter("beginStr");
+        String endStr = request.getParameter("endStr");
+        String pageSize = request.getParameter("pageSize");
+        String pageNo = request.getParameter("pageNo");
+        String tenantNoStr = request.getParameter("tenantNo");
+        if(StringUtils.isBlank(tenantNoStr)){
+            return "租户不能为空";
+        }
+        String accountNoStr = request.getParameter("accountNo");
+        if(StringUtils.isBlank(accountNoStr)){
+            return "业务主体不能为空";
+        }
+        Long tenantNo = Long.parseLong(request.getParameter("tenantNo"));
+        Long accountNo = Long.parseLong(request.getParameter("accountNo"));
+
+        PictureSourceParameter pictureSourceParameter = new PictureSourceParameter();
+        DateTime dateTime = DateUtil.parse(beginStr+" 00:00:00","yyyy-MM-dd HH:mm:ss");
+//        DateTime dateTime = DateUtil.parse("2024-03-31 07:00:000","yyyy-MM-dd HH:mm:ss");
+        Instant binstant = dateTime.toInstant();
+        DateTime dateTime1 = DateUtil.parse(endStr+" 00:00:00","yyyy-MM-dd HH:mm:ss");
+//        DateTime dateTime1 = DateUtil.parse("2024-03-31 09:00:00","yyyy-MM-dd HH:mm:ss");
+        Instant einstant = dateTime1.toInstant();
+        pictureSourceParameter.setStartTime(Date.from(binstant));
+        pictureSourceParameter.setEndTime(Date.from(einstant));
+        pictureSourceParameter.setPageNo(Integer.parseInt(pageNo));
+        pictureSourceParameter.setPageSize(Integer.parseInt(pageSize));
+        pictureSourceParameter.setTenantNo(tenantNo);
+        pictureSourceParameter.setAccountNo(accountNo);
+        try {
+            ApiPage<PictureSourceResult> apiPage  =  prevailCloudApi.pullPictureSource(pictureSourceParameter);
+            if(apiPage==null){
+                return "获取数据为空！";
+            }
+            List<PictureSourceResult> listResult= apiPage.getRecords();
+            int count = apiPage.getTotal();
+            int localCount = listResult.size();
+            int size = 0;
+            for (PictureSourceResult pictureSourceResult : listResult) {
+                //1.如果不存在图片默认一个默认图片，方便走测试。
+                if(pictureSourceResult.getLivePhoto()==null){
+                    List<Map<String,Object>> livePhoto = new ArrayList<>();
+                    Map<String,Object> map = new HashMap<>();
+                    map.put("imgUrl","http://47.93.59.251/api/image/default.png");
+                    map.put("imgName","default.png");
+                    livePhoto.add(map);
+                    pictureSourceResult.setLivePhoto(livePhoto);
+//                    continue;
+                }
+                size++;
+                //将可以处理数据放入处理队列中
+                TaskQueue.pictureDisposePushData(pictureSourceResult);
+            }
+            return "当前区间内图片总数:"+count+"条，本次获取："+localCount+"条，可处理数据:"+size+"条";
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        return "处理失败";
+    }
+
     @GetMapping("psTest")
     public String psTset(HttpServletRequest request) {
         String beginStr = request.getParameter("beginStr");