package com.ruoyi.quartz.task;
|
|
import com.ruoyi.project.domain.*;
|
import com.ruoyi.project.domain.vo.DingTalkReqVo;
|
import com.ruoyi.project.service.*;
|
import com.ruoyi.project.service.impl.DingTalkServiceImpl;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
import com.ruoyi.common.utils.StringUtils;
|
|
import java.lang.reflect.Array;
|
import java.util.*;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* 定时任务调度测试
|
*
|
* @author ruoyi
|
*/
|
@Component("ryTask")
|
public class RyTask {
|
@Autowired
|
private DingTalkService dingTalkService;
|
|
@Autowired
|
private IServiceReimbursementSharedService serviceReimbursementSharedService;
|
|
@Autowired
|
private IServiceFundSharedService serviceFundSharedService;
|
|
|
@Autowired
|
private IServiceFundService serviceFundService;
|
|
@Autowired
|
private IServiceReimbursementService serviceReimbursementService;
|
|
@Autowired
|
private IServiceFundflowService fundflowService;
|
|
public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i) {
|
System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
|
}
|
|
public void ryParams(String params) {
|
System.out.println("执行有参方法：" + params);
|
}
|
|
public void ryNoParams() {
|
System.out.println("执行无参方法");
|
}
|
|
public void checkReportInfo() {
|
//查出所有被医院退回的Fund数据
|
List<ServiceFundShared> serviceFundShareds = serviceFundSharedService.queryFundShareList();
|
for (ServiceFundShared serviceFundShared : serviceFundShareds) {
|
String[] split = serviceFundShared.getCxrjyj().split("&");
|
String phone = serviceFundShared.getPhone();
|
//将分享里的该数据删除
|
serviceFundSharedService.delfundsharedInfoById(serviceFundShared.getId());
|
|
ServiceFund serviceFund = new ServiceFund();
|
serviceFund.setId(serviceFundShared.getSerfunid());
|
List<ServiceFund> serviceFunds = serviceFundService.queryList(serviceFund);
|
ServiceFund serviceFund1 = serviceFunds.get(0);
|
serviceFund1.setFlowlevel(0);
|
serviceFund1.setDel_flag(0);
|
serviceFund1.setBackflowlevel(199);
|
serviceFundService.updateById(serviceFund1);
|
sendMeg(split, phone,serviceFundShared.getApplytype(),2,serviceFundShared.getSerfunid());
|
}
|
|
|
//查出所有被医院退回的Reimbursement数据
|
List<ServiceReimbursementShared> serviceReimbursementShareds = serviceReimbursementSharedService.queryReShareList();
|
for (ServiceReimbursementShared serviceReimbursementShared : serviceReimbursementShareds) {
|
String phone = serviceReimbursementShared.getPhone();
|
String[] split = serviceReimbursementShared.getCxrjyj().split("&");
|
|
//将分享里的该数据删除
|
serviceReimbursementSharedService.delResharedInfoById(serviceReimbursementShared.getId());
|
|
//将Flowlevel 设置为0;
|
ServiceReimbursement serviceReimbursement = new ServiceReimbursement();
|
serviceReimbursement.setId(serviceReimbursementShared.getReimid());
|
List<ServiceReimbursement> serviceReimbursementList = serviceReimbursementService.queryList(serviceReimbursement);
|
ServiceReimbursement serviceReimbursement1 = serviceReimbursementList.get(0);
|
serviceReimbursement1.setFlowlevel(0L);
|
serviceReimbursement1.setDelFlag(0);
|
serviceReimbursement1.setBackflowlevel(199L);
|
serviceReimbursement1.setRecordstatus(-1);
|
serviceReimbursementService.updateById(serviceReimbursement1);
|
sendMeg(split, phone, "0", 1, serviceReimbursementShared.getReimid());
|
|
}
|
|
}
|
|
public void sendMeg(String[] split, String phone, String applyType, Integer fundType, Long fundId) {
|
//记录操作记录
|
ServiceFundflow serviceFundflow = new ServiceFundflow();
|
serviceFundflow.setCreateBy("admin");
|
serviceFundflow.setCreateTime(new Date());
|
serviceFundflow.setUpdateBy("admin");
|
serviceFundflow.setUpdateTime(new Date());
|
serviceFundflow.setCheckusername(split[0]);
|
serviceFundflow.setFlowcontent(split[2]);
|
serviceFundflow.setFlowconclusion(2);
|
serviceFundflow.setFundtype(fundType);
|
serviceFundflow.setFlowlevel(100);
|
serviceFundflow.setApplytype(applyType);
|
serviceFundflow.setFundid(fundId);
|
fundflowService.save(serviceFundflow);
|
|
ArrayList<ConcurrentHashMap<String, String>> contentList = new ArrayList<>();
|
ConcurrentHashMap map = new ConcurrentHashMap();
|
map.put("审批人", split[0]);
|
map.put("审批时间", split[1]);
|
map.put("意见", split[2]);
|
contentList.add(map);
|
DingTalkReqVo dingTalkReqVo = new DingTalkReqVo();
|
dingTalkReqVo.setTitle("财务系统驳回信息");
|
dingTalkReqVo.setNumber("13634195431");
|
dingTalkReqVo.setContents(contentList);
|
dingTalkService.sendNotification(dingTalkReqVo);
|
}
|
|
}
|
