suqinyi před 1 rokem
rodič
revize
9427a1396b
16 změnil soubory, kde provedl 80 přidání a 78 odebrání
  1. 31 31
      svr/svr-base/src/main/java/com/yihu/jw/base/service/servicePackage/ServicePackageService.java
  2. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/async/AsynService.java
  3. 2 2
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/consult/controller/ConsultController.java
  4. 2 2
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/consult/controller/DoctorConsultController.java
  5. 4 3
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/DoorOrderService.java
  6. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/WlyyDoorPrescriptionService.java
  7. 6 5
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/WlyyDoorServiceOrderService.java
  8. 2 2
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/followup/service/FollowUpService.java
  9. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/jw/service/JwArchivesService.java
  10. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/jw/service/JwSmjkService.java
  11. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/RehabilitationInfoService.java
  12. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/ZsRehabilitationInfoService.java
  13. 1 1
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/upload/controller/FileUploadController.java
  14. 4 4
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/task/PushMsgTask.java
  15. 2 2
      svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/utils/DoctorAssistantUtil.java
  16. 20 20
      svr/svr-visit-behind/src/main/resources/application.yml

+ 31 - 31
svr/svr-base/src/main/java/com/yihu/jw/base/service/servicePackage/ServicePackageService.java

@ -36,7 +36,6 @@ import java.util.Map;
import java.util.stream.Collectors;
/**
 *
 * @author yeshijie on 2018/8/17.
 */
@Service
@ -65,55 +64,56 @@ public class ServicePackageService extends BaseJpaService<ServicePackageDO, Serv
    private ServicePackageSignRecordDao servicePackageSignRecordDao;
    @Transactional(rollbackFor = Exception.class)
    public JSONObject create(ServicePackageDO servicePackageDO,String uid){
    public JSONObject create(ServicePackageDO servicePackageDO, String uid) {
        JSONObject result = new JSONObject();
        UserDO userDO = userDao.findById(uid);
        List<ServicePackageItemDO> itemDOList = servicePackageDO.getPackageItemDOList();
        if(itemDOList==null){
        if (itemDOList == null) {
            servicePackageDO.setNum(0);
        }else {
        } else {
            servicePackageDO.setNum(itemDOList.size());
        }
        if(StringUtil.isEmpty(servicePackageDO.getId())){
        if (StringUtil.isEmpty(servicePackageDO.getId())) {
            //新增
            servicePackageDO.setCreateTime(new Date());
            if(userDO!=null){
            if (userDO != null) {
                servicePackageDO.setCreateUser(userDO.getId());
                servicePackageDO.setCreateUserName(userDO.getName());
            }
            servicePackageDO=servicePackageDao.save(servicePackageDO);
        }else{
            servicePackageDO = servicePackageDao.save(servicePackageDO);
        } else {
            //修改
            servicePackageDO.setUpdateTime(new Date());
            if(userDO!=null){
            if (userDO != null) {
                servicePackageDO.setUpdateUser(userDO.getId());
                servicePackageDO.setUpdateUserName(userDO.getName());
            }
            servicePackageDO= servicePackageDao.save(servicePackageDO);
            servicePackageDO = servicePackageDao.save(servicePackageDO);
        }
        List<ServiceItemConfig> itemConfigList = new ArrayList<>();
        String sql = " SELECT dict_code from wlyy_hospital_sys_dict WHERE dict_name = 'plan_frequency' limit 1";
        List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);
        String frequencyCode = "0 0 10 ? * *";
        if(list.size()>0){
            frequencyCode = list.get(0).get("dict_code")+"";
        if (list.size() > 0) {
            frequencyCode = list.get(0).get("dict_code") + "";
        }
        for (ServicePackageItemDO itemDO:itemDOList){
        for (ServicePackageItemDO itemDO : itemDOList) {
            boolean flag = false;
            ServicePackageItemDO itemDO1 = new ServicePackageItemDO();
            if(StringUtils.isNotBlank(itemDO.getId())){
            if (StringUtils.isNotBlank(itemDO.getId())) {
                itemDO1 = servicePackageItemDao.findOne(itemDO.getId());
            }
            if("system".equals(itemDO1.getServicePackageId())){
            if ("system".equals(itemDO1.getServicePackageId())) {
                flag = true;
                BeanUtils.copyProperties(itemDO1,itemDO);
                BeanUtils.copyProperties(itemDO1, itemDO);
                itemDO.setId(null);
                itemDO.setCreateTime(DateUtil.getStringDate());
 //               itemDO.setServicePackageItemId(itemDO1.getId());//20231110补的
                itemDO.setServicePackageId(servicePackageDO.getId());
            }
            servicePackageItemDao.save(itemDO);
            if(flag){
            if (flag) {
                String itemId = itemDO.getId();
                //新增的服务项新增默认执行计划
                ServiceItemConfig itemConfig = new ServiceItemConfig();
@ -131,12 +131,12 @@ public class ServicePackageService extends BaseJpaService<ServicePackageDO, Serv
            }
        }
        if(itemConfigList.size()>0){
        if (itemConfigList.size() > 0) {
            itemConfigDao.save(itemConfigList);
        }
        result.put("response", ConstantUtils.SUCCESS);
        result.put("msg","操作成功");
        result.put("msg", "操作成功");
        return result;
    }
@ -166,29 +166,29 @@ public class ServicePackageService extends BaseJpaService<ServicePackageDO, Serv
        String pageSql = " limit " + (page - 1) * size + "," + size;
        detailSql += sql + pageSql;
        countSql += sql;
        List<ServicePackageDO> list = jdbcTemplate.query(detailSql,new BeanPropertyRowMapper<>(ServicePackageDO.class));
        List<ServicePackageDO> list = jdbcTemplate.query(detailSql, new BeanPropertyRowMapper<>(ServicePackageDO.class));
        List<WlyyHospitalSysDictDO> wlyyHospitalSysDictDOS = wlyyHospitalSysDictDao.findByDictName("serviceType");
        List<WlyyHospitalSysDictDO> wlyyHospitalSysDictDOS1 = wlyyHospitalSysDictDao.findByDictName("isEffect");
        for (ServicePackageDO servicePackageDO:list){
        for (ServicePackageDO servicePackageDO : list) {
            List<ServicePackageItemDO> itemDOList = servicePackageItemDao.findByServicePackageId(servicePackageDO.getId());
            List<String> orgNames = itemDOList.stream().map(p -> p.getOrgName()).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
            List<String> orgCodes = itemDOList.stream().map(p -> p.getOrgCode()).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList());
            servicePackageDO.setOrgNames(StringUtils.join(orgNames,","));
            servicePackageDO.setOrgCodes(StringUtils.join(orgCodes,","));
            for (WlyyHospitalSysDictDO wlyyHospitalSysDictDO:wlyyHospitalSysDictDOS){
                if (servicePackageDO.getType().equalsIgnoreCase(wlyyHospitalSysDictDO.getDictCode())){
            servicePackageDO.setOrgNames(StringUtils.join(orgNames, ","));
            servicePackageDO.setOrgCodes(StringUtils.join(orgCodes, ","));
            for (WlyyHospitalSysDictDO wlyyHospitalSysDictDO : wlyyHospitalSysDictDOS) {
                if (servicePackageDO.getType().equalsIgnoreCase(wlyyHospitalSysDictDO.getDictCode())) {
                    servicePackageDO.setTypeName(wlyyHospitalSysDictDO.getDictValue());
                }
            }
            for (WlyyHospitalSysDictDO wlyyHospitalSysDictDO:wlyyHospitalSysDictDOS1){
                if (servicePackageDO.getDel().equalsIgnoreCase(wlyyHospitalSysDictDO.getDictCode())){
            for (WlyyHospitalSysDictDO wlyyHospitalSysDictDO : wlyyHospitalSysDictDOS1) {
                if (servicePackageDO.getDel().equalsIgnoreCase(wlyyHospitalSysDictDO.getDictCode())) {
                    servicePackageDO.setDelName(wlyyHospitalSysDictDO.getDictValue());
                }
            }
        }
        Long count = jdbcTemplate.queryForObject(countSql, Long.class);
        return PageEnvelop.getSuccessListWithPage("获取成功",list,page,size,count);
        return PageEnvelop.getSuccessListWithPage("获取成功", list, page, size, count);
    }
    public void deleteById(String id) {
@ -209,11 +209,11 @@ public class ServicePackageService extends BaseJpaService<ServicePackageDO, Serv
        jdbcTemplate.execute(sql01);
    }
    public void changeState(String id,String del,String uid) {
    public void changeState(String id, String del, String uid) {
        ServicePackageDO packageDO = servicePackageDao.findOne(id);
        packageDO.setDel(del);
        UserDO userDO = userDao.findById(uid);
        if(userDO!=null){
        if (userDO != null) {
            packageDO.setUpdateUser(userDO.getId());
            packageDO.setUpdateUserName(userDO.getName());
        }

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/async/AsynService.java

@ -44,7 +44,7 @@ public class AsynService {
    @Autowired
    private ImUtil imUtill;
    //基卫服务地址
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Autowired
    private HttpClientUtil httpClientUtil;

+ 2 - 2
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/consult/controller/ConsultController.java

@ -102,10 +102,10 @@ public class ConsultController extends EnvelopRestEndpoint {
    @Autowired
    WeiXinAccessTokenUtils weiXinAccessTokenUtils;
    @Value("${doctorAssistant.api}")
//    @Value("${doctorAssistant.api}")
    private String doctorAssistant;
    @Value("${doctorAssistant.target_url}")
//    @Value("${doctorAssistant.target_url}")
    private String targetUrl;

+ 2 - 2
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/consult/controller/DoctorConsultController.java

@ -39,9 +39,9 @@ import org.springframework.web.bind.annotation.RestController;
@Api(description = "三师咨询")
public class DoctorConsultController extends EnvelopRestEndpoint {
    @Value("${doctorAssistant.api}")
//    @Value("${doctorAssistant.api}")
    private String doctorAssistant;
    @Value("${doctorAssistant.target_url}")
//    @Value("${doctorAssistant.target_url}")
    private String targetUrl;
    @Autowired
    private ConsultTeamService consultTeamService;

+ 4 - 3
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/DoorOrderService.java

@ -66,9 +66,9 @@ public class DoorOrderService {
    @Autowired
    private HttpClientUtil httpClientUtil;
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Value("${server.server_url}")
//    @Value("${server.server_url}")
    private String wxServerUrl;
    //图片服务地址
    @Value("${fastDFS.fastdfs_file_url}")
@ -152,7 +152,8 @@ public class DoorOrderService {
    public PageEnvelop getServiceItem(String signId, String name, String type, Integer page, Integer size){
        String sql = "SELECT si.* ";
        String countSql = "select count(si.id) ";
        String filter = " from base_service_package_sign_record r,base_service_package_item i,base_service_package_sub_item si,base_service_package_item_relational ir " +
        String filter = " from base_service_package_sign_record r," +
                "base_service_package_item i,base_service_package_sub_item si,base_service_package_item_relational ir " +
                "WHERE r.id = '"+signId+"' and i.service_package_id=r.service_package_id and i.`code`='"+type+"' and si.status='1' " +
                " and i.id = ir.item_id and ir.sub_item_id= si.id ";
        if(StringUtils.isNotBlank(name)){

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/WlyyDoorPrescriptionService.java

@ -61,7 +61,7 @@ public class WlyyDoorPrescriptionService {
    private BaseDoctorDao doctorDao;
    @Autowired
    private WlyyDoorPrescriptionDrugDao doorPrescriptionDrugDao;
    @Value("${server.server_url}")
//    @Value("${server.server_url}")
    private String server_url;
    @Autowired
    private JdbcTemplate jdbcTemplate;

+ 6 - 5
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/door/service/WlyyDoorServiceOrderService.java

@ -164,11 +164,11 @@ public class WlyyDoorServiceOrderService extends BaseJpaService<WlyyDoorServiceO
    @Autowired
    FileUploadService fileUploadService;
    @Value("${neiwang.enable}")
//    @Value("${neiwang.enable}")
    private Boolean isneiwang;  //如果不是内网项目要转到到内网wlyy在上传
    @Value("${fastDFS.fastdfs_file_url}")
    private String fastdfs_file_url;
    @Value("${neiwang.wlyy}")
//    @Value("${neiwang.wlyy}")
    private String neiwangWlyy;  //内网的项目地址
    @Value("${wlyy.url}")
@ -3066,9 +3066,10 @@ public class WlyyDoorServiceOrderService extends BaseJpaService<WlyyDoorServiceO
        String sql = "SELECT * from base_doctor doc WHERE doctor_level=1 and id not in ( " +
                "SELECT doctor from wlyy_door_doctor_status " +
                ")";
        if (org.apache.commons.lang.StringUtils.isNotBlank(hospital)) {
            sql += "and EXISTS (select id from base_doctor_hospital dh where doc.id = dh.doctor_code and dh.org_code='" + hospital + "' and dh.del=1 ) ";
        }
        //机构就不要了
//        if (org.apache.commons.lang.StringUtils.isNotBlank(hospital)) {
//            sql += "and EXISTS (select id from base_doctor_hospital dh where doc.id = dh.doctor_code and dh.org_code='" + hospital + "' and dh.del=1 ) ";
//        }
        List<BaseDoctorDO> doctorDOs = jdbcTemplate.query(sql, new BeanPropertyRowMapper(BaseDoctorDO.class));
        List<WlyyDoorDoctorStatusDO> doctorList = new ArrayList<>(doctorDOs.size());

+ 2 - 2
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/followup/service/FollowUpService.java

@ -111,10 +111,10 @@ public class FollowUpService {
    @Autowired
    private HttpClientUtil httpClientUtil;
    @Value("${doctorAssistant.api}")
//    @Value("${doctorAssistant.api}")
    private String doctorAssistant;
    @Value("${doctorAssistant.target_url}")
//    @Value("${doctorAssistant.target_url}")
    private String targetUrl;
//
//    @Value("${es.type.FollowUpContent}")

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/jw/service/JwArchivesService.java

@ -27,7 +27,7 @@ public class JwArchivesService {
    private SystemDictService systemDictService;
    @Autowired
    private com.yihu.jw.util.http.HttpClientUtil HttpClientUtil;
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Value("${testPattern.sign}")
    private String isClose;

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/jw/service/JwSmjkService.java

@ -32,7 +32,7 @@ import java.util.Map;
public class JwSmjkService {
    //基卫服务地址
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Value("${demo.flag}")

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/RehabilitationInfoService.java

@ -71,7 +71,7 @@ public class RehabilitationInfoService  {
    
 
    //基卫服务地址
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Autowired

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/rehabilitation/service/ZsRehabilitationInfoService.java

@ -27,7 +27,7 @@ import java.util.*;
public class ZsRehabilitationInfoService {
    //基卫服务地址
    @Value("${sign.check_upload}")
//    @Value("${sign.check_upload}")
    private String jwUrl;
    @Autowired
    private HttpClientUtil httpClientUtil;

+ 1 - 1
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/module/upload/controller/FileUploadController.java

@ -42,7 +42,7 @@ public class FileUploadController extends EnvelopRestEndpoint {
    @Value("${fastDFS.fastdfs_file_url}")
    private String fastdfs_file_url;
    @Value("${neiwang.enable}")
//    @Value("${neiwang.enable}")
    private Boolean isneiwang = false;  //如果不是内网项目要转到到内网wlyy在上传
    @Autowired

+ 4 - 4
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/task/PushMsgTask.java

@ -37,13 +37,13 @@ public class PushMsgTask {
    @Autowired
    private HttpUtil httpUtil;
    @Value("${server.server_url}")
//    @Value("${server.server_url}")
    private String server_url;
    @Value("${pushMes.method}")
//    @Value("${pushMes.method}")
    private String putMesMethod;
    @Value("${pushMes.redis_prescription_title}")
//    @Value("${pushMes.redis_prescription_title}")
    private String redisQueue;
    //    @Value("${putMesType.wechat}")
 //    @Value("${putMesType.wechat}")
    private String putMesType;
    //模板id

+ 2 - 2
svr/svr-visit-behind/src/main/java/com/yihu/jw/hospital/utils/DoctorAssistantUtil.java

@ -17,9 +17,9 @@ import java.util.List;
@Component
public class DoctorAssistantUtil {
    @Value("${doctorAssistant.api}")
//    @Value("${doctorAssistant.api}")
    private String doctorAssistant;
    @Value("${doctorAssistant.target_url}")
//    @Value("${doctorAssistant.target_url}")
    private String targetUrl;
    @Autowired
    private HttpClientUtil httpClientUtil;

+ 20 - 20
svr/svr-visit-behind/src/main/resources/application.yml

@ -301,26 +301,26 @@ cloudCare:
# 20231012新增的
server:
  server_url: https://ehr.yihu.com/wlyy/
  # 服务器图片改存FastDFS地址
  server_img_url: http://172.26.0.110:8888/
#医生助手服务器地址及模板跳转链接(医生未读消息统计页)
doctorAssistant:
  api: https://ehr.yihu.com/wlyy/
  target_url: home/html/unreadMessageStatistic.html
sign:
  check_upload_sign: http://172.19.103.88:8011/wlyy_sign
  check_upload: http://172.26.0.118:8085/wlyy_service
pushMes:
  # 1为推送redis,0为推送消息队列
  method: 0
  # redis队列名称
  redis_prescription_title: redisMessage
##如果是外网项目就是flase 内网是true
neiwang:
  enable: true
  wlyy: http://172.26.0.110:22122/
#server:
#  server_url: https://ehr.yihu.com/wlyy/
#  # 服务器图片改存FastDFS地址
#  server_img_url: http://172.26.0.110:8888/
##医生助手服务器地址及模板跳转链接(医生未读消息统计页)
#doctorAssistant:
#  api: https://ehr.yihu.com/wlyy/
#  target_url: home/html/unreadMessageStatistic.html
#sign:
#  check_upload_sign: http://172.19.103.88:8011/wlyy_sign0
#  check_upload: http://172.26.0.118:8085/wlyy_service
#pushMes:
#  # 1为推送redis,0为推送消息队列
#  method: 0
#  # redis队列名称
#  redis_prescription_title: redisMessage
###如果是外网项目就是flase 内网是true
#neiwang:
#  enable: true
#  wlyy: http://172.26.0.110:22122/
basedb:
  name: base