Merge pull request 'feat：1.添加无量云调用日志' (#151) from feat/addPrevailCloudLog into test

Reviewed-on: #151

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/flowable/controller/FlowTaskController.java

@@ -37,6 +37,8 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import io.swagger.annotations.*;
 import org.apache.commons.collections4.CollectionUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.http.MediaType;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.*;
@@ -54,6 +56,7 @@ import java.util.stream.Collectors;
 @RequestMapping("/flow/task")
 public class FlowTaskController extends BaseController {
 
+    private static final Logger log = LoggerFactory.getLogger(FlowTaskController.class);
     @Resource
     IFlowTaskService flowTaskService;
 
@@ -676,8 +679,10 @@ public class FlowTaskController extends BaseController {
     })
     @GetMapping("/repetitionTask")
     @ResponseBody
-    public ResultVo repetitionTask(@RequestParam(value = "type",required = false,defaultValue = "1") Integer type) {
-        return flowTaskService.repetitionTask(type);
+    public ResultVo repetitionTask(HttpServletRequest request,
+            @RequestParam(value = "type",required = false,defaultValue = "1") Integer type) {
+        String tenantId = request.getHeader("X-Tenant-Id");
+        return flowTaskService.repetitionTask(type,tenantId);
     }
 
     /**
@@ -691,10 +696,36 @@ public class FlowTaskController extends BaseController {
     })
     @GetMapping("/repetitionTaskList")
     @ResponseBody
-    public ResultVo repetitionTaskList(@RequestParam(name = "pageNo") Integer pageNo,
+    public ResultVo repetitionTaskList(HttpServletRequest request,
+                                       @RequestParam(name = "pageNo") Integer pageNo,
                                        @RequestParam(name = "pageSize") Integer pageSize,
                                        @RequestParam(value = "type",required = false,defaultValue = "1") Integer type) {
-        Page<OcrTaskchildPicture> result = flowTaskService.repetitionTaskList(pageNo, pageSize,type);
+        String tenantId = request.getHeader("X-Tenant-Id");
+        Page<OcrTaskchildPicture> result = flowTaskService.repetitionTaskList(pageNo, pageSize,type,tenantId);
+        return ResultVoUtil.success(result);
+    }
+
+    /**
+     * 重复任务
+     *
+     * @return
+     */
+    @ApiOperation(value = "失败重试无量云", notes = "失败重试无量云")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "header", name = "X-Tenant-Id", value = "租户主键,用户登录时的信息“tenantList”中获得。", dataType = "String", required = true),
+    })
+    @GetMapping("/retryPrevailCloud")
+    @ResponseBody
+    public ResultVo retryPrevailCloud(HttpServletRequest request,
+                                       @RequestParam(name = "formId") String formId) {
+        String tenantId = request.getHeader("X-Tenant-Id");
+        Boolean result = null;
+        try {
+            result = flowTaskService.retryPrevailCloud(tenantId,formId);
+        } catch (Exception e) {
+            log.error(e.getMessage());
+            result =false;
+        }
         return ResultVoUtil.success(result);
     }
 }

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/flowable/service/IFlowTaskService.java

@@ -193,7 +193,9 @@ public interface IFlowTaskService {
      *
      * @return
      */
-    ResultVo repetitionTask(Integer type);
+    ResultVo repetitionTask(Integer type, String tenantId);
 
-    Page<OcrTaskchildPicture> repetitionTaskList(Integer pageNo, Integer pageSize,Integer type);
+    Page<OcrTaskchildPicture> repetitionTaskList(Integer pageNo, Integer pageSize, Integer type, String tenantId);
+
+    Boolean retryPrevailCloud(String tenantId, String formId) throws Exception;
 }

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/flowable/service/impl/FlowTaskServiceImpl.java

@@ -35,10 +35,12 @@ import cn.jyjz.xiaoyao.oa.from.service.*;
 
 import cn.jyjz.xiaoyao.oa.from.vo.FlowUnionVo;
 import cn.jyjz.xiaoyao.oa.from.vo.RepeatedContentVo;
+import cn.jyjz.xiaoyao.ocr.api.PrevailCloudApi;
 import cn.jyjz.xiaoyao.ocr.dataobject.*;
 import cn.jyjz.xiaoyao.ocr.service.*;
 import cn.jyjz.xiaoyao.ocr.util.SearchParaFormatting;
 import cn.jyjz.xiaoyao.ocr.vo.OcrTaskchildPictureApproVo;
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@@ -117,6 +119,10 @@ public class FlowTaskServiceImpl extends FlowServiceFactory implements IFlowTask
     private IOcrMsgService ocrMsgService;
     @Resource
     private UserdistionaryService userdistionaryService;
+    @Resource
+    private OcrPrevailCloudLogService prevailCloudLogService;
+    @Resource
+    private PrevailCloudApi prevailCloudApi;
 
     @Override
     public void myTodoTaskList(PageUtils vo, HttpServletRequest request) {
@@ -599,7 +605,8 @@ public class FlowTaskServiceImpl extends FlowServiceFactory implements IFlowTask
             model.setFinishtime(System.currentTimeMillis());
             model.setStates(SystemConstantsOa.OA_STATUS_TYPE_END);
             OcrPicture picture = ocrPictureService.getById(model.getPictureid());
-            ocrTaskchildPictureService.sendFlowTaskResult(childPicture, picture, approve);
+            Boolean result = ocrTaskchildPictureService.sendFlowTaskResult(childPicture, picture, approve);
+            model.setSendResult(result ? 1 : 0);
         } else {
             childPicture.setTaskNode(taskData.getDescription());
             //判断节点上的描述字段，是否伟finale_judgment,如果是，记录到终审表中，如果终审表已经存在，不再重复记录
@@ -1955,8 +1962,8 @@ public class FlowTaskServiceImpl extends FlowServiceFactory implements IFlowTask
     }
 
     @Override
-    public ResultVo repetitionTask(Integer type) {
-        List<RepeatedContentVo> repeatedContentVoList = flowableccMybatisDao.repetitionTask(type);
+    public ResultVo repetitionTask(Integer type, String tenantId) {
+        List<RepeatedContentVo> repeatedContentVoList = flowableccMybatisDao.repetitionTask(type, tenantId);
         List<String> formIdsToUpdate = new ArrayList<>();
         if (org.apache.commons.collections4.CollectionUtils.isNotEmpty(repeatedContentVoList)) {
             List<OcrCheckDescribeHis> checkDescribeHis = new ArrayList<>();
@@ -2004,12 +2011,18 @@ public class FlowTaskServiceImpl extends FlowServiceFactory implements IFlowTask
     }
 
     @Override
-    public Page<OcrTaskchildPicture> repetitionTaskList(Integer pageNo, Integer pageSize, Integer type) {
+    public Page<OcrTaskchildPicture> repetitionTaskList(Integer pageNo, Integer pageSize, Integer type, String tenantId) {
         Page<OcrTaskchildPicture> page = new Page<>(pageNo, pageSize);
-        Page<OcrTaskchildPicture> result = flowableccMybatisDao.repetitionTaskList(page, type);
+        Page<OcrTaskchildPicture> result = flowableccMybatisDao.repetitionTaskList(page, type, tenantId);
         return result;
     }
 
+    @Override
+    public Boolean retryPrevailCloud(String tenantId, String formId) throws Exception {
+        OcrPrevailCloudLog one = prevailCloudLogService.getOne(new LambdaQueryWrapper<OcrPrevailCloudLog>().eq(OcrPrevailCloudLog::getFormId, formId));
+        return prevailCloudApi.sendFlowTaskResult(formId, one.getRequestParam(), one.getPictureId(), one.getTaskId());
+    }
+
     /**
      * 格式化筛选关系
      *

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/oa/from/dataDao/FlowableccMybatisDao.java

@@ -40,7 +40,7 @@ public interface FlowableccMybatisDao extends BaseMapper<Flowablecc> {
      */
     List<UserDistionaryVo> selectUserByFromid(String fromid);
 
-    List<RepeatedContentVo> repetitionTask(@Param("type") Integer type);
+    List<RepeatedContentVo> repetitionTask(@Param("type") Integer type, @Param("tenantId") String tenantId);
 
-    Page<OcrTaskchildPicture> repetitionTaskList(Page<OcrTaskchildPicture> page, @Param("type") Integer type);
+    Page<OcrTaskchildPicture> repetitionTaskList(Page<OcrTaskchildPicture> page, @Param("type") Integer type, @Param("tenantId") String tenantId);
 }

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/api/PrevailCloudApi.java

@@ -3,7 +3,6 @@ package cn.jyjz.xiaoyao.ocr.api;
 import cn.jyjz.xiaoyao.ocr.api.entity.PictureSourceParameter;
 import cn.jyjz.xiaoyao.ocr.api.entity.PictureSourceResult;
 import cn.jyjz.xiaoyao.ocr.api.utils.ApiPage;
-import org.apache.commons.compress.utils.Lists;
 
 import java.util.List;
 
@@ -23,7 +22,7 @@ public interface PrevailCloudApi {
      */
     ApiPage<PictureSourceResult> pullPictureSource(PictureSourceParameter pictureSourceParameter) throws Exception;
 
-    void sendFlowTaskResult(String tenantId,String data) throws Exception;
+    Boolean sendFlowTaskResult(String formId, String data, Long pictureId, String remark) throws Exception;
 
     /**
      * 根据租户id 拉取对应业务主体信息

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/api/impl/PrevailCloudApiImpl.java

@@ -11,8 +11,11 @@ import cn.jyjz.xiaoyao.ocr.api.utils.ApiHelper;
 import cn.jyjz.xiaoyao.ocr.api.utils.ApiPage;
 import cn.jyjz.xiaoyao.ocr.api.utils.RequestData;
 import cn.jyjz.xiaoyao.ocr.api.utils.ResultData;
+import cn.jyjz.xiaoyao.ocr.common.PrevailCloudConstant;
 import cn.jyjz.xiaoyao.ocr.dataobject.OcrPicture;
+import cn.jyjz.xiaoyao.ocr.dataobject.OcrPrevailCloudLog;
 import cn.jyjz.xiaoyao.ocr.service.OcrPictureService;
+import cn.jyjz.xiaoyao.ocr.service.OcrPrevailCloudLogService;
 import cn.jyjz.xiaoyao.ocr.thread.TaskQueue;
 import cn.jyjz.xiaoyao.ocr.thread.entity.PictureImgToLocalEntity;
 import cn.jyjz.xiaoyao.ocr.util.httputil.HttpClient;
@@ -28,6 +31,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -51,6 +55,9 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
     @Autowired
     private ApiConfig apiConfig;
 
+    @Resource
+    private OcrPrevailCloudLogService prevailCloudLogService;
+
     /**
      * 拉取图片信息
      */
@@ -78,7 +85,9 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
         if (!apiConfig.checkConfig()) {
             return null;
         }
-
+        OcrPrevailCloudLog prevailCloudLog = new OcrPrevailCloudLog();
+        prevailCloudLog.setType(PrevailCloudConstant.PULL_PICTURE_SOURCE);
+        prevailCloudLog.setRequestParam(JSONUtil.toJsonStr(pictureSourceParameter));
         //2.对象转map
         Map<String, Object> queryParam = BeanUtil.beanToMap(pictureSourceParameter);
         Map<String, String> queryParamStr = new HashMap<>();
@@ -108,6 +117,8 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
         String responseJsonStr = HttpClient.doPost(url, httpParamers, null, apiConfig.getConnectTimeout(), apiConfig.getReadTimeout());
         System.out.println(responseJsonStr);
         ResultData<String> resultData = JSONUtil.toBean(responseJsonStr, ResultData.class);
+        prevailCloudLog.setResponseParam(responseJsonStr);
+        prevailCloudLog.setStatus(resultData.getStatus());
 
         //解密请求数据
         if (resultData.getStatus() == 100) {
@@ -126,11 +137,18 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
             logger.debug("请求图片接口数据失败,参数:{},返回值:{}", json, responseJsonStr);
 
         }
+        prevailCloudLogService.save(prevailCloudLog);
         return null;
     }
 
     @Override
-    public void sendFlowTaskResult(String tenantId, String data) throws Exception {
+    public Boolean sendFlowTaskResult(String formId, String data, Long pictureId, String remark) throws Exception {
+        OcrPrevailCloudLog prevailCloudLog = new OcrPrevailCloudLog();
+        prevailCloudLog.setType(PrevailCloudConstant.SEND_FLOW_RESULT);
+        prevailCloudLog.setRequestParam(data);
+        prevailCloudLog.setFormId(Long.parseLong(formId));
+        prevailCloudLog.setTaskId(remark);
+        prevailCloudLog.setPictureId(pictureId);
         ResultData<String> stringResultData = ApiHelper.buildResponse(apiConfig.getAccessCode(), data);
 //        RequestData requestData = ApiHelper.buildRequest(tenantId, apiConfig.getAccessKey(), apiConfig.getAccessCode(),data);//组装请求参数
         String url = apiConfig.getInterfaceDomain() + sendResultUrl;
@@ -141,11 +159,21 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
         httpParamers.setJsonParamer(requestBodyJson);
         //发起请求
         String responseJsonStr = HttpClient.doPost(url, httpParamers, null, apiConfig.getConnectTimeout(), apiConfig.getReadTimeout());
-        System.out.println(responseJsonStr);
+        prevailCloudLog.setResponseParam(responseJsonStr);
+        ResultData<String> resultData = JSONUtil.toBean(responseJsonStr, ResultData.class);
+        prevailCloudLog.setStatus(resultData.getStatus());
+        prevailCloudLogService.save(prevailCloudLog);
+        if (resultData.getStatus() == 100) {
+            return true;
+        }
+        return false;
     }
 
     @Override
     public void pullAccountInfo(long tenantNo) throws Exception {
+        OcrPrevailCloudLog prevailCloudLog = new OcrPrevailCloudLog();
+        prevailCloudLog.setType(PrevailCloudConstant.PULL_ACCOUNT_INFO);
+        prevailCloudLog.setRequestParam(String.valueOf(tenantNo));
         Map<String, Object> queryParam = new HashMap<>();
         queryParam.put("tenantNo", tenantNo);
         String json = JSONObject.toJSONString(queryParam);
@@ -159,8 +187,9 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
         String responseJsonStr = HttpClient.doPost(url, httpParamers, null, apiConfig.getConnectTimeout(), apiConfig.getReadTimeout());
         System.out.println(responseJsonStr);
         ResultData<String> resultData = JSONUtil.toBean(responseJsonStr, ResultData.class);
+        prevailCloudLog.setResponseParam(responseJsonStr);
+        prevailCloudLog.setStatus(resultData.getStatus());
         if (resultData.getStatus() == 100) {
-            ;
             //解析基础数据
             String data = ApiHelper.decryptResponse(apiConfig.getAccessCode(), resultData);
             ApiPage<String> apiPage = JSONUtil.toBean(data, ApiPage.class);
@@ -174,6 +203,8 @@ public class PrevailCloudApiImpl implements PrevailCloudApi {
 //            resultApiPage.setRecords(listResult);
 //            return resultApiPage;
         }
+        prevailCloudLogService.save(prevailCloudLog);
+
     }
 
     /**

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/common/PrevailCloudConstant.java

@@ -0,0 +1,19 @@
+package cn.jyjz.xiaoyao.ocr.common;
+
+/**
+ * ClassName： PrevailCloudConstant$.java
+ * Description:
+ * Author： scl.
+ * Date： 2024/4/25 下午8:36
+ */
+public class PrevailCloudConstant {
+
+    public static Integer PULL_PICTURE_SOURCE = 0;
+
+    public static Integer SEND_FLOW_RESULT = 1;
+
+    public static Integer PULL_ACCOUNT_INFO = 2;
+
+
+
+}

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataDao/OcrPrevailCloudLogMapper.java

@@ -0,0 +1,13 @@
+package cn.jyjz.xiaoyao.ocr.dataDao;
+
+import cn.jyjz.xiaoyao.ocr.dataobject.OcrPrevailCloudLog;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * ClassName： $className$.java
+ * Description:
+ * Author： scl.
+ * Date： 2024/4/25 下午9:18
+ */
+public interface OcrPrevailCloudLogMapper extends BaseMapper<OcrPrevailCloudLog> {
+}

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataobject/OcrPrevailCloudLog.java

@@ -0,0 +1,110 @@
+package cn.jyjz.xiaoyao.ocr.dataobject;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.util.Date;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * ClassName： $className$.java
+ * Description: 
+ * Author： scl.
+ * Date： 2024/4/25 下午9:18
+ */
+
+/**
+ * 无量云请求日志
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName(value = "ocr_prevail_cloud_log")
+public class OcrPrevailCloudLog {
+    /**
+     * ID主键自增
+     */
+    @TableId(value = "id", type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 表单id
+     */
+    @TableField(value = "form_id")
+    private Long formId;
+
+    /**
+     * 请求参数
+     */
+    @TableField(value = "request_param")
+    private String requestParam;
+
+    /**
+     * 返回参数
+     */
+    @TableField(value = "response_param")
+    private String responseParam;
+
+    /**
+     * 返回参数
+     */
+    @TableField(value = "`status`")
+    private Integer status;
+
+    /**
+     * 查询方法
+     */
+    @TableField(value = "`type`")
+    private Integer type;
+
+    /**
+     * 创建人
+     */
+    @TableField(value = "create_by")
+    private String createBy;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 修改人
+     */
+    @TableField(value = "update_by")
+    private String updateBy;
+
+    /**
+     * 修改时间
+     */
+    @TableField(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 任务id
+     */
+    @TableField(value = "task_id")
+    private String taskId;
+
+    /**
+     * 图片id
+     */
+    @TableField(value = "picture_id")
+    private Long pictureId;
+
+    /**
+     * 业务主体id
+     */
+    @TableField(value = "tenant_id")
+    private String tenantId;
+
+    /**
+     * 冗余字段
+     */
+    @TableField(value = "redundance")
+    private String redundance;
+}

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/dataobject/OcrTaskchildPicture.java

@@ -215,6 +215,12 @@ public class OcrTaskchildPicture implements BaseDto, java.io.Serializable {
     @TableField(value = "is_repeated_nodules")
     private Integer isRepeatedNodules;
 
+    @Schema(description = "无量云回调结果")
+    @TableField(value = "send_result")
+    private Integer sendResult;
+
+
+
     @ApiModelProperty(value = "项目对象")
     @TableField(exist = false)
     private Category categoryDto;
@@ -295,6 +301,7 @@ public class OcrTaskchildPicture implements BaseDto, java.io.Serializable {
     @TableField(exist = false)
     private String serverThumbnailUrl;
 
+
     public FlowModelVO getFlowModelVO() {
         FlowModelVO flowModelVO = new FlowModelVO();
         flowModelVO.setFormid(this.getId());

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/OcrPrevailCloudLogService.java

@@ -0,0 +1,14 @@
+package cn.jyjz.xiaoyao.ocr.service;
+
+import cn.jyjz.xiaoyao.ocr.dataobject.OcrPrevailCloudLog;
+import com.baomidou.mybatisplus.extension.service.IService;
+    /**
+ * ClassName： $className$.java
+ * Description: 
+ * Author： scl.
+ * Date： 2024/4/25 上午12:52
+ */
+public interface OcrPrevailCloudLogService extends IService<OcrPrevailCloudLog>{
+
+
+}

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/OcrTaskchildPictureService.java

@@ -149,7 +149,7 @@ public interface OcrTaskchildPictureService extends BaseService<OcrTaskchildPict
 
     Page<OcrTaskChildPictureVo> getPackageSimilarityList(Integer pageNo, Integer pageSize, String oderType, String oderName, String checkDuplicateId, String pictureId);
 
-    void sendFlowTaskResult(OcrTaskchildPicture taskchildPicture, OcrPicture picture, FlowApprove flowApprove) throws Exception;
+    Boolean sendFlowTaskResult(OcrTaskchildPicture taskchildPicture, OcrPicture picture, FlowApprove flowApprove) throws Exception;
 
     List<OcrTaskChildPictureVo> getDubiousfileList(List<String> pictureIds, String userNodeType);
 }

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrPrevailCloudLogServiceImpl.java

@@ -0,0 +1,19 @@
+package cn.jyjz.xiaoyao.ocr.service.impl;
+
+import org.springframework.stereotype.Service;
+import org.springframework.beans.factory.annotation.Autowired;
+import java.util.List;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import cn.jyjz.xiaoyao.ocr.dataobject.OcrPrevailCloudLog;
+import cn.jyjz.xiaoyao.ocr.dataDao.OcrPrevailCloudLogMapper;
+import cn.jyjz.xiaoyao.ocr.service.OcrPrevailCloudLogService;
+/**
+ * ClassName： $className$.java
+ * Description: 
+ * Author： scl.
+ * Date： 2024/4/25 上午12:52
+ */
+@Service
+public class OcrPrevailCloudLogServiceImpl extends ServiceImpl<OcrPrevailCloudLogMapper, OcrPrevailCloudLog> implements OcrPrevailCloudLogService{
+
+}

jyjz-system/jyjz-system-oa/src/main/java/cn/jyjz/xiaoyao/ocr/service/impl/OcrTaskchildPictureServiceImpl.java

@@ -737,7 +737,7 @@ public class OcrTaskchildPictureServiceImpl extends BaseServiceImpl<OcrTaskchild
     }
 
     @Override
-    public void sendFlowTaskResult(OcrTaskchildPicture taskchildPicture, OcrPicture picture, FlowApprove flowApprove) throws Exception {
+    public Boolean sendFlowTaskResult(OcrTaskchildPicture taskchildPicture, OcrPicture picture, FlowApprove flowApprove) throws Exception {
         FlowResultDto flowResultDto = new FlowResultDto();
         flowResultDto.setTenantNo(picture.getTenantId());
         flowResultDto.setAccountNo(Long.parseLong(picture.getPictureid()));
@@ -757,7 +757,8 @@ public class OcrTaskchildPictureServiceImpl extends BaseServiceImpl<OcrTaskchild
             }
         }
         flowResultDto.setApproveDetailList(nodeList);
-        prevailCloudApi.sendFlowTaskResult(picture.getTenantId().toString(),JSON.toJSONString(flowResultDto));
+        return prevailCloudApi.sendFlowTaskResult(taskchildPicture.getId().toString(), JSON.toJSONString(flowResultDto), picture.getId(), picture.getRemark());
+
     }
 
 

jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/FlowableccMapper.xml

@@ -229,6 +229,7 @@
         HAVING count(field8) > 1) t1
             LEFT JOIN ocr_taskchild_picture t2 ON t1.ID = t2.PICTUREID
             LEFT JOIN ocr_picture t3 on t1.id = t3.ID
+		where t2.TENANTID = #{tenantId,jdbcType=VARCHAR}
     </select>
 
 	<select id="repetitionTaskList" resultType="cn.jyjz.xiaoyao.ocr.dataobject.OcrTaskchildPicture">
@@ -236,11 +237,12 @@
         FROM ocr_taskchild_picture t2
                  LEFT JOIN ocr_picture t3 ON t2.PICTUREID = t3.ID
         WHERE
+		 t2.TENANTID = #{tenantId,jdbcType=VARCHAR}
 		<if test="type == 0">
-			 t2.ISFINAIL = 1
+			 and t2.ISFINAIL = 1
 		</if>
 		<if test="type == 1">
-			 t2.ISFINAIL = 1
+			and  t2.ISFINAIL = 1
 		</if>
 		and t3.field8 IN (SELECT t3.field8
                             FROM ocr_taskchild_picture t2

jyjz-system/jyjz-system-oa/src/main/resources/mapper/oa/OcrPrevailCloudLogMapper.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.jyjz.xiaoyao.ocr.dataDao.OcrPrevailCloudLogMapper">
+  <resultMap id="BaseResultMap" type="cn.jyjz.xiaoyao.ocr.dataobject.OcrPrevailCloudLog">
+    <!--@mbg.generated-->
+    <!--@Table ocr_prevail_cloud_log-->
+    <id column="id" jdbcType="BIGINT" property="id" />
+    <result column="form_id" jdbcType="BIGINT" property="formId" />
+    <result column="request_param" jdbcType="VARCHAR" property="requestParam" />
+    <result column="response_param" jdbcType="VARCHAR" property="responseParam" />
+    <result column="status" jdbcType="INTEGER" property="status" />
+    <result column="type" jdbcType="INTEGER" property="type" />
+    <result column="create_by" jdbcType="VARCHAR" property="createBy" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="update_by" jdbcType="VARCHAR" property="updateBy" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="task_id" jdbcType="VARCHAR" property="taskId" />
+    <result column="picture_id" jdbcType="BIGINT" property="pictureId" />
+    <result column="tenant_id" jdbcType="VARCHAR" property="tenantId" />
+    <result column="redundance" jdbcType="VARCHAR" property="redundance" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, form_id, request_param, response_param, `status`, `type`, create_by, create_time, 
+    update_by, update_time, task_id, picture_id, tenant_id, redundance
+  </sql>
+</mapper>