erviceReimbursementShared上传oa文件

liusheng

2023-06-30 7e02a4f66a6d045e2347f6bed115b7e7e2aa5b33

erviceReimbursementShared上传oa文件

 ruoyi-project/src/main/java/com/ruoyi/project/mapper/ServiceReimbursementdetailMapper.java

@@ -2,17 +2,20 @@


import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import java.util.List;

import com.ruoyi.project.domain.ServiceReimbursementdetail;
import org.apache.ibatis.annotations.Mapper;

/**
 * 报销申请明细Mapper接口
 * 
 *
 * @author ruoyi
 * @date 2022-01-24
 */
public interface ServiceReimbursementdetailMapper extends BaseMapper<ServiceReimbursementdetail>
{
@Mapper
public interface ServiceReimbursementdetailMapper extends BaseMapper<ServiceReimbursementdetail> {
    /**
     * 查询报销申请明细列表
     *

 ruoyi-project/src/main/java/com/ruoyi/project/mapper/ServiceReimbursementdetailSharedMapper.java

@@ -2,17 +2,20 @@


import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import java.util.List;

import com.ruoyi.project.domain.ServiceReimbursementdetailShared;
import org.apache.ibatis.annotations.Mapper;

/**
 * 报销申请明细Mapper接口
 * 
 *
 * @author ruoyi
 * @date 2023-04-20
 */
public interface ServiceReimbursementdetailSharedMapper extends BaseMapper<ServiceReimbursementdetailShared>
{
@Mapper
public interface ServiceReimbursementdetailSharedMapper extends BaseMapper<ServiceReimbursementdetailShared> {
    /**
     * 查询报销申请明细列表
     *

 ruoyi-project/src/main/java/com/ruoyi/project/mapper/ServiceReimbursementpayeeMapper.java

@@ -4,6 +4,7 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.ruoyi.project.domain.ServiceReimbursementEo;
import com.ruoyi.project.domain.ServiceReimbursementpayee;
import org.apache.ibatis.annotations.Mapper;

import java.util.List;

@@ -13,6 +14,7 @@
 * @author ruoyi
 * @date 2023-05-10
 */
@Mapper
public interface ServiceReimbursementpayeeMapper extends BaseMapper<ServiceReimbursementpayee> {
    /**
     * 查询差旅报销付款信息列表

 ruoyi-project/src/main/java/com/ruoyi/project/mapper/ServiceReimbursementpayeeSharedMapper.java

@@ -2,17 +2,20 @@


import com.baomidou.mybatisplus.core.mapper.BaseMapper;

import java.util.List;

import com.ruoyi.project.domain.ServiceReimbursementpayeeShared;
import org.apache.ibatis.annotations.Mapper;

/**
 * 差旅报销付款信息Mapper接口
 * 
 *
 * @author ruoyi
 * @date 2023-04-20
 */
public interface ServiceReimbursementpayeeSharedMapper extends BaseMapper<ServiceReimbursementpayeeShared>
{
@Mapper
public interface ServiceReimbursementpayeeSharedMapper extends BaseMapper<ServiceReimbursementpayeeShared> {
    /**
     * 查询差旅报销付款信息列表
     *

 ruoyi-project/src/main/java/com/ruoyi/project/service/impl/ServiceReimbursementServiceImpl.java

@@ -1,8 +1,13 @@
package com.ruoyi.project.service.impl;

import java.io.File;
import java.util.HashMap;
import java.util.List;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.common.config.RuoYiConfig;
import com.ruoyi.common.utils.HttpClientKit;
import com.ruoyi.common.utils.bean.DtoConversionUtils;
import com.ruoyi.project.domain.*;
import com.ruoyi.project.domain.dto.ServiceReimbursementDto;
@@ -125,7 +130,8 @@
        List<ServiceReimbursementpayeeShared> serviceReimbursementpayeeShareds = DtoConversionUtils.sourceToTarget(serviceReimbursementpayees, ServiceReimbursementpayeeShared.class);
        //将组装好的数据插入到分享表中
        sharedService.save(serviceReimbursementShared);

        //上传OA文件
        uploadOAFileAndUpdateDb(serviceReimbursementShared);
        //将serviceReimbursementdetail表里的id赋值给Rdid; 将serviceReimbursementShared里的ID赋值给RBID,并将serviceReimbursementdetailShared表里的id置空，由数据库重新生成
        for (int i = 0; i < details.size(); i++) {
            serviceReimbursementdetailShareds.get(i).setRdid(serviceReimbursementdetailShareds.get(i).getId());
@@ -171,4 +177,127 @@
    }


    int uploadOAFileAndUpdateDb(ServiceReimbursementShared remShare) {
        //上传OA文件
        //String strUrl = "http://129.88.242.39:8899/seeyon/rest/token?userName=opo&password=127814f8-84e8-4304-84a5-a71573567efd&loginName=demo3";
        String strUrl = "http://129.88.242.39:8899/seeyon/rest/token";
        //String strUrl = "http://slb.hospitalstar.com:8899/seeyon/rest/token";
        //上传文件成功后，去更新相关的数据库


        Map<String, Object> map = new HashMap<String, Object>();
        map.put("userName", "opo");
        map.put("password", "4126407a-9821-4874-be41-6568abd6dbe5");
        map.put("loginName", "demo3");

        JSONObject jsonObj = new JSONObject(map);

        System.out.println("uploadOAFileAndUpdateDb + jsonObject" + jsonObj.toString() + "\r\n" + jsonObj.toJSONString());
        String strRes = HttpClientKit.postOpr(strUrl, jsonObj.toString());//
        //String strRes = HttpClientKit.postMsg(strUrl,jsonObj);//得到返回的token?

        JSONObject json1 = JSONObject.parseObject(strRes);
        strRes = json1.get("id").toString();

        ///if(strRes.isEmpty() || "" == strRes) return -1;// 为空代表失败

        //下面需求调用文件的接口，调用成功返回后，得到filename和fileid 用这二个值去更新数据

        String filePath = RuoYiConfig.getUploadPath();
        String strMutfileUrl = remShare.getFileurl();//可能存在多个地址，以,分开

        String strFUrl = "http://129.88.242.39:8899/seeyon/rest/attachment?token=" + strRes;
        //String strFUrl = "http://slb.hospitalstar.com:8899/seeyon/rest/attachment?token="+strRes;
        //strFUrl = String.format(strFUrl, strRes);

        /*File test = null;
        File file = new File("E:\\YYJQ\\OPO\\WEB\\Upload\\upload\\2023\\02\\17");
        if (file.exists() && file.isDirectory()) {
            // 获取所有盲盒文件夹
            File[] ones = file.listFiles();
            for (File one : ones) {
                test = one;
            }
        }*/

        String filename = "";
        String fileid = "";

        String[] urlArray = strMutfileUrl.split(",");
        for (int i = 0; i < urlArray.length; i++) {
            String strOneFileName = urlArray[i];
            String strTemp = strOneFileName.substring(15);
            String strFile = filePath + strTemp;
            //FileUploadUtils.getAbsoluteFile(filePath,strOneFileName);
            String struploadResult = "";
            File filetest = new File(strFile);
            try {
                struploadResult = HttpClientKit.sendPostWithFile(filetest, strFUrl);
            } catch (Exception e) {
                e.printStackTrace();
            }


            /*CloseableHttpClient httpClient = HttpClients.createDefault();
            //创建post方法连接实例，在post方法中传入待连接地址
            HttpPost httpPost = new HttpPost(strFUrl);
            CloseableHttpResponse response = null;

            String struploadResult = "";
            try {
                //设置请求参数（类似html页面中name属性）
                MultipartEntityBuilder entity = MultipartEntityBuilder.create();
                //entity.setMode(HttpMultipartMode.BROWSER_COMPATIBLE);
                entity.setCharset(Charset.forName("UTF-8"));

                byte[] fileBytes = Files.readAllBytes(Paths.get(strFile));
                if (fileBytes != null) {
                    //内容类型，用于定义网络文件的类型和网页的编码，决定文件接收方将以什么形式、什么编码读取这个文件
                    ContentType OCTEC_STREAM = ContentType.create("application/octet-stream", Charset.forName("UTF-8"));
                    //添加文件
                    entity.addBinaryBody("file", fileBytes, OCTEC_STREAM, strTemp);
                }

                httpPost.setEntity(entity.build());
                //发起请求，并返回请求响应
                response = httpClient.execute(httpPost);
                struploadResult = EntityUtils.toString(response.getEntity(), "utf-8");
            }
            catch (Exception e)
            {
                e.printStackTrace();
            }*/

            //String strFRes = HttpClientKit.postMsg(strFUrl,jsonFObj);
            if (struploadResult == null) return 0;
            if (struploadResult.isEmpty()) return 0;

            JSONObject jsonR = JSONObject.parseObject(struploadResult);

            JSONArray jsonArr = jsonR.getJSONArray("atts");
            for (int j = 0; j < jsonArr.size(); j++) {
                JSONObject jsonRet = jsonArr.getJSONObject(j);
                String name1 = jsonRet.get("filename").toString();
                String id1 = jsonRet.get("fileUrl").toString();
                filename += name1;
                fileid += id1;
                if (i != urlArray.length - 1) {
                    filename += ",";
                    fileid += ",";
                }
            }

        }

//        long nId = remShare.getId();
//        remShare.setId(nId);
//        remShare.setFilename(filename);
//        remShare.setFileid(fileid);
//        boolean bRet = serviceReimbursementServiceShare.updateById(remShare);
//        if (!bRet) return -1;

        return 0;
    }


}