后台
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liusheng
2023-07-17 f0815cf1d5edfa55abbdbe06eadfafc991e340e7 
 ruoyi-admin/src/main/java/com/ruoyi/web/controller/project/ServiceReimbursementController.java


@@ -2,6 +2,8 @@




import com.alibaba.fastjson.JSONArray;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.ruoyi.common.annotation.Log;


import com.ruoyi.common.annotation.RepeatSubmit;


import com.ruoyi.common.config.RuoYiConfig;


@@ -15,6 +17,7 @@


import com.ruoyi.common.exception.ServiceException;


import com.ruoyi.common.utils.HttpClientKit;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.common.utils.bean.DtoConversionUtils;


import com.ruoyi.common.utils.poi.ExcelUtil;


import com.ruoyi.project.domain.*;


import com.ruoyi.project.domain.dto.ServiceReimbursementDto;


@@ -29,6 +32,7 @@


import freemarker.template.TemplateException;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiOperation;


import org.apache.commons.lang.ObjectUtils;


import org.apache.commons.lang.StringUtils;


import org.apache.ibatis.annotations.Options;


import org.springframework.beans.factory.annotation.Autowired;


@@ -57,10 +61,10 @@


    private IServiceReimbursementService serviceReimbursementService;




    @Autowired


    private IServiceReimbursementpayeeService reimbursementpayeeService;


    private IServiceReimbursementSharedService serviceReimbursementSharedService;




    @Autowired


    private IServiceReimbursementSharedService serviceReimbursementServiceShare;


    private IServiceReimbursementpayeeService reimbursementpayeeService;




    @Autowired


    private IServiceReimbursementdetailService serviceReimbursementdetailService;


@@ -70,6 +74,9 @@




    @Autowired


    private IServiceFundflowService serviceFundflowService;




    @Autowired


    private IServiceFundService serviceFundService;




    @Autowired


    private ISysPostService postService;


@@ -315,127 +322,128 @@


//    }






    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";


        //上传文件成功后，去更新相关的数据库


//    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;


//    }






        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;


    }




    /**


     * 差旅费上报


@@ -445,6 +453,23 @@


    @PostMapping("/travelexpensereport")


    public AjaxResult travelexpensereport(@RequestBody CheckFundVO checkFundVO) {


        ServiceReimbursement serviceReimbursement = serviceReimbursementService.getById(checkFundVO.getFundid());


        //如果等于100，说明已经走到医院财务那边了；财务那边取数据是从分享表取，所以，这里直接往分享表里添加数据就行了


        if (serviceReimbursement.getBackflowlevel() == 100 || serviceReimbursement.getBackflowlevel() == 199) {




            //将修改的上报数据 新增一条


            ServiceReimbursementShared serviceReimbursementShared = DtoConversionUtils.sourceToTarget(serviceReimbursement, ServiceReimbursementShared.class);


            serviceReimbursementShared.setId(null);


            serviceReimbursementShared.setDelFlag(0L);


            serviceReimbursementShared.setReimid(serviceReimbursement.getId());


            serviceReimbursementSharedService.save(serviceReimbursementShared);




            //将退回阶段设置成100


            serviceReimbursement.setBackflowlevel(100L);     


            serviceReimbursement.setFlowlevel(100L);


            serviceReimbursement.setRecordstatus(0);


            serviceReimbursementService.updateById(serviceReimbursement);


            return success();


        }


        if (serviceReimbursement != null) {


            Integer TotalLevel = 0;


            LoginUser loginUser = getLoginUser();


@@ -453,10 +478,12 @@




            if (!postids.contains(2)) {


                serviceReimbursement.setFlowlevel(1L);


                serviceReimbursement.setBackflowlevel(1L);


                serviceReimbursement.setRecordstatus(2);


            } else {


                serviceReimbursement.setFlowlevel(0L);


                serviceReimbursement.setRecordstatus(0);


                serviceReimbursement.setBackflowlevel(0L);


            }




            if (!postids.contains(2)) {


@@ -489,6 +516,7 @@


    @PostMapping("/checkfund")


    public AjaxResult checkFund(@RequestBody CheckFundVO checkFundVO) {


        ServiceReimbursement serviceReimbursement = serviceReimbursementService.getById(checkFundVO.getFundid());




        if (serviceReimbursement != null) {


            Integer totalLevel = 0;


            LoginUser loginUser = getLoginUser();


@@ -514,6 +542,9 @@


            Integer CheckFlag = 0;


            Integer RecordStatus = serviceReimbursement.getRecordstatus();


            Integer FlowLevel = Integer.valueOf(serviceReimbursement.getFlowlevel().toString());


            if (Objects.isNull(serviceReimbursement.getBackflowlevel()) && !Objects.isNull(serviceReimbursement.getFlowlevel())) {


                serviceReimbursement.setBackflowlevel(Long.valueOf(FlowLevel.toString()));


            }


            Integer OriginalFlowLevel = FlowLevel;


            if (checkFundVO.getFlowconclusion() == 1) {


                CheckFlag = 1;


@@ -530,16 +561,22 @@


                FlowLevel = FlowLevel + 1;


            } else {


                CheckFlag = 2;


                RecordStatus = (FlowLevel + 1) * 2 - 1;


                FlowLevel = (FlowLevel - 1);


                if (FlowLevel < 0) {




                if (CheckFlag == 2) {


                    //应医院要求如果出现退回，直接退到发起者


                    FlowLevel = 0;


                } else {


                    //下面是原来的写法，一级一级的往下退，医院现在不要这样搞了，下面这段代码先保留，等医院回心转意，再给放开


                    RecordStatus = (FlowLevel + 1) * 2 - 1;


                    FlowLevel = (FlowLevel - 1);


                    if (FlowLevel < 0) {


                        FlowLevel = 0;


                    }


                }


            }




            serviceReimbursement.setRecordstatus(RecordStatus);


            serviceReimbursement.setFlowlevel(Long.valueOf(FlowLevel.toString()));




            ServiceFundflow serviceFundflow = new ServiceFundflow();


            SysUser user = loginUser.getUser();


            serviceFundflow.setFundid(serviceReimbursement.getId());