package com.ltkj.web.controller.system; import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.ltkj.common.enums.DataSourceType; import com.ltkj.common.utils.SecurityUtils; import com.ltkj.framework.config.MatchUtils; import com.ltkj.framework.datasource.DynamicDataSourceContextHolder; import com.ltkj.hosp.domain.TjCustomerBlack; import com.ltkj.hosp.domain.TjReservation; import com.ltkj.hosp.hisDto.OutpinregapplyDto; import com.ltkj.hosp.mapper.TestMapper; import com.ltkj.hosp.service.*; import com.ltkj.hosp.sqlDomain.LtkjMiddleDetail; import com.ltkj.hosp.sqlDomain.LtkjMiddleHead; import com.ltkj.hosp.sqlDomain.LtkjTjPat; import com.ltkj.system.service.ISysConfigService; import com.ltkj.web.controller.his.HisApiGetMethodService; import com.ltkj.web.controller.his.HisApiMethod; import com.ltkj.web.controller.his.HisApiMethodService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiParam; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.DigestUtils; import org.springframework.web.bind.annotation.*; import com.ltkj.common.core.controller.BaseController; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.hosp.domain.TjCustomer; import com.ltkj.common.utils.poi.ExcelUtil; import com.ltkj.common.core.page.TableDataInfo; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * 客户信息Controller * * @author ltkj * @date 2022-11-17 */ @RestController @RequestMapping("/hosp/customer") @Api(tags = "客户管理接口") public class TjCustomerController extends BaseController { @Resource private ITjCustomerService tjCustomerService; @Resource private ITjReservationService tjReservationService; @Resource private ISysConfigService sysConfigService; @Resource private TestMapper testMapper; @Resource private TjvLtkjvtjpatService tjvLtkjvtjpatService; @Resource private LtkjMiddleHeadService headService; @Resource private LtkjMiddleDetailService middleDetailService; @Resource private ITjOrderService tjOrderService; @Resource private TjCustomerBlackService blackService; @Autowired private HisApiMethod hisApiMethod; @Autowired private HisApiMethodService controller; //将方法返回值解析成json格式 public JSONObject getJSONObject(String builder) { String Response = JSONUtil.parseObj(builder).getStr("Response"); return JSONUtil.parseObj(Response); } //获取方法返回值信息 public String getAjaxResult(AjaxResult result) { return result.get("data").toString(); } @GetMapping("/newGetTjPat") @ApiOperation(value = "查询his数据库返回新的数据") public AjaxResult newGetTjPat(@RequestParam(required = false) String pacCode, @RequestParam(required = false) String pacName, @RequestParam(required = false) String pacRemark) { List> maps = testMapper.newGetTjPat(pacCode, pacName, pacRemark); DynamicDataSourceContextHolder.clearDataSourceType(); // List> list=new ArrayList<>(); // if(null !=maps && maps.size()>0){ // for (Map map : maps) { // String pacCode1 = map.get("pacCode").toString(); // List s = tjOrderService.selectTjOrderByCardId1(); // if(null !=s && s.size()>0){ // if(s.contains(pacCode1)){ //// maps.remove(map); // continue; // } // list.add(map); // } // } // } List strings = tjOrderService.selectTjOrderByCardId1(); if (null != strings && strings.size() > 0) { List> collect = maps.stream() .filter(item -> !strings.contains(item.get("pacCode").toString())).collect(Collectors.toList()); return AjaxResult.success(collect); } return AjaxResult.success(maps); // return AjaxResult.success(maps); } /** * 根据身份证号获取用户信息 */ @PostMapping(value = "/cusIdcard") @ApiOperation(value = "根据身份证号获取用户信息") // @Log(title = "客户身份信息", businessType = BusinessType.EXPORT) public AjaxResult getInfoByIdCard(@RequestParam @ApiParam(value = "客户身份证号") String cusIdcard) { if (!"".equals(cusIdcard) && cusIdcard != null) { //判断身份证号格式是否正确 // if(cusIdcard.length()==18){ // if (! MatchUtils.isIdCard(cusIdcard)) { // return AjaxResult.error("身份证号码错误"); // } // } // if(cusIdcard.length()==9){ // if (!MatchUtils.cardValidates(cusIdcard)) { // return AjaxResult.error("身份证号码错误"); // } // } //根据配置调取存储过程 将临时表数据存入预约表2023.12.12 LambdaQueryWrapper customerLambdaQueryWrapper = new LambdaQueryWrapper<>(); customerLambdaQueryWrapper.eq(TjCustomer::getCusIdcard, cusIdcard); TjCustomer tjCustomerServiceOne = tjCustomerService.getOne(customerLambdaQueryWrapper); if (null == tjCustomerServiceOne) { return AjaxResult.error("该人员信息不存在请先进行登记!!!"); } final String getInfoFromSqlData = sysConfigService.selectConfigByKey("getInfoFromSqlData"); if ("Y".equals(getInfoFromSqlData)) { //根据身份证号从his查信息 LtkjTjPat tjPatByIdCard = testMapper.getTjPatByIdCard(cusIdcard); if (null != tjPatByIdCard) { String fcardNo = tjPatByIdCard.getFcardNo(); if (null != fcardNo && !fcardNo.equals("")) { fcardNo = fcardNo.trim(); tjPatByIdCard.setFcardNo(fcardNo); } else { fcardNo = cusIdcard.trim(); tjPatByIdCard.setFcardNo(fcardNo); } //根据身份证号从数据库拿信息 没有的话保存 LtkjTjPat ltkjTjPat = tjvLtkjvtjpatService.getLtkjTjPatByCusIdCard(cusIdcard); if (null == ltkjTjPat) { tjvLtkjvtjpatService.save(tjPatByIdCard); } DynamicDataSourceContextHolder.clearDataSourceType(); //再根据身份证号写customer表 TjCustomer tjCustomer = tjCustomerService.getTjCustomerByCusIdCard(tjPatByIdCard.getFcardNo()); if (null == tjCustomer) { //为空的话掉存储过程保存到客户表 testMapper.getTjPatByCusId(cusIdcard); LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); qw.eq(TjCustomer::getCusIdcard, tjPatByIdCard.getFcardNo()); TjCustomer customer = tjCustomerService.getOne(qw); customer.setReservationId(customer.getCardId()); extracted(customer); return success(customer); } else { String cardId = tjPatByIdCard.getFcardId(); if (null != cardId && !cardId.equals("0")) { int i = tjOrderService.selectTjOrderByCardId(cardId); if (i > 0) { return AjaxResult.error("不可重复签到"); } } tjCustomer.setReservationId(tjCustomer.getCardId()); tjCustomer.setCardId(tjPatByIdCard.getFcardId()); tjCustomerService.updateById(tjCustomer); extracted(tjCustomer); return success(tjCustomer); } } } String key = sysConfigService.selectConfigByKey("sfkqdyhis"); if (null != key && key.equals("Y")) { String cardId = tjCustomerServiceOne.getCardId(); if (null != cardId && !cardId.equals("0")) { int i = tjOrderService.selectTjOrderByCardId(cardId); if (i > 0) { return AjaxResult.error("不可重复签到"); } } // controller.Outpincreateapply(tjCustomer); /* Date dates = new Date(); final String date = DateUtil.format(dates, "yyyy-MM-dd HH:mm:ss"); OutpinregapplyDto outpinregapplyDto = new OutpinregapplyDto(); outpinregapplyDto.setPationid(tjCustomerServiceOne.getPationId()); outpinregapplyDto.setSqysbm("00029"); outpinregapplyDto.setMzksbm("0101"); outpinregapplyDto.setCzybm("00029"); outpinregapplyDto.setSfjz("0"); outpinregapplyDto.setGhzlbm("01"); outpinregapplyDto.setYwckbm("0001"); outpinregapplyDto.setSflstd("0"); outpinregapplyDto.setGhrq(date); //门诊挂号 AjaxResult ajaxResult = controller.Outpinregapply(outpinregapplyDto); String result2 = getAjaxResult(ajaxResult); JSONObject object1 = getJSONObject(result2); String code1 = object1.getStr("ResultCode"); if (code1.equals("0")) { JSONArray resultDatas = object1.getJSONArray("ResultData"); if (null != resultDatas && resultDatas.size() > 0) { Map resultDatasss = (Map) resultDatas.get(0); String hisRegistrationId = resultDatasss.get("his_registration_id").toString(); //门诊医生接诊 controller.Outpinconapply(hisRegistrationId, date, SecurityUtils.getUsername()); // tjCustomerServiceOne.setCardId(hisRegistrationId); // tjCustomerServiceOne.setCusBrithday(DateUtil.parse(MatchUtils.getBirthDayByIdCard(tjCustomerServiceOne.getCusIdcard()),"yyyy-MM-dd")); // tjCustomerService.updateById(tjCustomerServiceOne); tjCustomerService.updateCardId(tjCustomerServiceOne.getCusId(),hisRegistrationId); } }*/ } //end====2023.12.12 LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); wq.eq(TjReservation::getIdCard, cusIdcard); wq.eq(TjReservation::getIsExpire, 2); TjReservation tjReservation = tjReservationService.getOne(wq); if (tjReservation != null) { if (DateUtil.endOfDay(new Date()).before(tjReservation.getReservationTime())) { return AjaxResult.error("未到预约时间"); } if (null != tjReservation.getReservationTime() && DateUtil.endOfDay(tjReservation.getReservationTime()).before(new Date())) { tjReservation.setIsExpire(1); tjReservationService.updateById(tjReservation); return AjaxResult.error("对不起您的预约已超时请重新预约"); } LambdaQueryWrapper qw = new LambdaQueryWrapper<>(); qw.eq(TjCustomer::getCusIdcard, cusIdcard); TjCustomer tjCustomer1 = tjCustomerService.getOne(qw); if (tjCustomer1 != null) { /* String key = sysConfigService.selectConfigByKey("sfkqdyhis"); if (null != key && key.equals("Y")) { Date dates = new Date(); final String date = DateUtil.format(dates, "yyyy-MM-dd HH:mm:ss"); OutpinregapplyDto outpinregapplyDto = new OutpinregapplyDto(); outpinregapplyDto.setPationid(tjCustomer1.getPationId()); outpinregapplyDto.setSqysbm(SecurityUtils.getUsername()); outpinregapplyDto.setMzksbm("0101"); outpinregapplyDto.setCzybm("00029"); outpinregapplyDto.setSfjz("0"); outpinregapplyDto.setGhzlbm("01"); outpinregapplyDto.setYwckbm("0001"); outpinregapplyDto.setSflstd("0"); outpinregapplyDto.setGhrq(date); //门诊挂号 AjaxResult ajaxResult = controller.Outpinregapply(outpinregapplyDto); String result2 = getAjaxResult(ajaxResult); JSONObject object1 = getJSONObject(result2); String code1 = object1.getStr("ResultCode"); if (code1.equals("0")) { JSONArray resultDatas = object1.getJSONArray("ResultData"); if (null != resultDatas && resultDatas.size() > 0) { Map resultDatasss = (Map) resultDatas.get(0); String hisRegistrationId = resultDatasss.get("his_registration_id").toString(); //门诊医生接诊 controller.Outpinconapply(hisRegistrationId, date, SecurityUtils.getUsername()); tjCustomer1.setCardId(hisRegistrationId); } } }*/ tjCustomer1.setTjType(tjReservation.getTjType()); tjCustomer1.setCusName(tjReservation.getName()); tjCustomer1.setCusSex(Long.valueOf(tjReservation.getSex())); tjCustomer1.setCusBrithday(tjReservation.getBirthday()); tjCustomer1.setCusPhone(tjReservation.getPhoe()); tjCustomer1.setCusEmail(tjReservation.getEmail()); tjCustomer1.setCusAddr(tjReservation.getAddress()); tjCustomer1.setCusMarryStatus(String.valueOf(tjReservation.getMarriage())); tjCustomer1.setCusNational(String.valueOf(tjReservation.getNation())); tjCustomer1.setIdType(tjReservation.getIdType()); tjCustomer1.setAge(tjReservation.getAge()); tjCustomer1.setAgeUnit(tjReservation.getAgeUnit()); tjCustomer1.setCareer(tjReservation.getCareer()); tjCustomerService.updateById(tjCustomer1); tjCustomer1.setTeamNo(tjReservation.getTeamNo()); tjCustomer1.setCompId(tjReservation.getCompanyId()); tjCustomer1.setReservationId(tjReservation.getId()); tjCustomer1.setDiscount(tjReservation.getDiscount()); tjCustomer1.setGroupingId(tjReservation.getGroupingId()); return success(tjCustomer1); } TjCustomer tjCustomer = new TjCustomer(); tjCustomer.setCusIdcard(tjReservation.getIdCard()); tjCustomer.setCusName(tjReservation.getName()); tjCustomer.setCusSex(Long.valueOf(tjReservation.getSex())); tjCustomer.setCusBrithday(tjReservation.getBirthday()); tjCustomer.setCusPhone(tjReservation.getPhoe()); tjCustomer.setCusEmail(tjReservation.getEmail()); tjCustomer.setCusAddr(tjReservation.getAddress()); tjCustomer.setCusMarryStatus(String.valueOf(tjReservation.getMarriage())); tjCustomer.setCusNational(String.valueOf(tjReservation.getNation())); tjCustomer.setIdType(tjReservation.getIdType()); tjCustomer.setAge(tjReservation.getAge()); tjCustomer.setAgeUnit(tjReservation.getAgeUnit()); tjCustomer.setCareer(tjReservation.getCareer()); tjCustomer.setDwPhone(tjReservation.getDwPhone()); tjCustomer.setCardId(tjReservation.getCardId()); tjCustomer.setIndexCard(tjReservation.getIndexCard()); //截取密码自动生成set进去 String substring = cusIdcard.substring(cusIdcard.length() - 6); substring = DigestUtils.md5DigestAsHex(substring.getBytes()); tjCustomer.setCusPassword(substring); tjCustomer.setTjType(tjReservation.getTjType()); tjCustomerService.save(tjCustomer); tjCustomer.setTeamNo(tjReservation.getTeamNo()); tjCustomer.setCompId(tjReservation.getCompanyId()); tjCustomer.setReservationId(tjReservation.getId()); tjCustomer.setDiscount(tjReservation.getDiscount()); tjCustomer.setGroupingId(tjReservation.getGroupingId()); return success(tjCustomer); } else { LambdaQueryWrapper customerLambdaQueryWrapper1 = new LambdaQueryWrapper<>(); customerLambdaQueryWrapper1.eq(TjCustomer::getCusIdcard, cusIdcard); TjCustomer one = tjCustomerService.getOne(customerLambdaQueryWrapper1); System.out.println("------------------"+one.getCusBrithday()); return AjaxResult.success("暂无预约信息", tjCustomerServiceOne); } } return error("身份证号不存在"); } private void extracted(TjCustomer customer) { //从his表抓数据 LtkjMiddleHead pat = testMapper.getMiddleHeadByPartId(customer.getCardId()); if (null != pat) { LambdaQueryWrapper wq1 = new LambdaQueryWrapper<>(); wq1.eq(LtkjMiddleHead::getFeadId, customer.getCardId()); headService.remove(wq1); LambdaQueryWrapper wq0 = new LambdaQueryWrapper<>(); wq0.eq(LtkjMiddleDetail::getFheadId, pat.getFeadId()); middleDetailService.remove(wq0); List list = testMapper.getMiddleDetailByFeadId(pat.getFeadId()); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); LtkjMiddleHead o = headService.getMiddleHeadByPartId(customer.getCardId()); if (o == null) { headService.save(pat); for (LtkjMiddleDetail ltkjMiddleDetail : list) { middleDetailService.save(ltkjMiddleDetail); } } testMapper.saveTjProByCusId(customer.getCardId(), customer.getCusIdcard()); } DynamicDataSourceContextHolder.clearDataSourceType(); } /** * 查询客户信息列表 */ // @PreAuthorize("@ss.hasPermi('hosp:customer:list')") @GetMapping("/list") @ApiOperation(value = "查看客户列表") public TableDataInfo list(TjCustomer tjCustomer) { startPage(); List list = tjCustomerService.selectTjCustomerList(tjCustomer); if (null != list && list.size() > 0) { for (TjCustomer customer : list) { // customer.setCusName(MatchUtils.hideCusName(customer.getCusName())); customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard())); TjCustomerBlack tjCustomerBlack = blackService.isTjCustomerBlack(String.valueOf(customer.getCusId())); if (null != tjCustomerBlack) { customer.setIsBlack("Y"); } else { customer.setIsBlack("N"); } } } return getDataTable(list); } /** * 导出客户信息列表 */ //@PreAuthorize("@ss.hasPermi('hosp:customer:export')") //@Log(title = "客户信息", businessType = BusinessType.EXPORT) @PostMapping("/export") public void export(HttpServletResponse response, TjCustomer tjCustomer) { List list = tjCustomerService.selectTjCustomerList(tjCustomer); ExcelUtil util = new ExcelUtil(TjCustomer.class); util.exportExcel(response, list, "客户信息数据"); } /** * 获取客户信息详细信息 */ //@PreAuthorize("@ss.hasPermi('hosp:customer:query')") @GetMapping(value = "/{cusId}") @ApiOperation(value = "根据客户id获取客户详情") public AjaxResult getInfo(@PathVariable("cusId") @ApiParam(value = "客户id") Long cusId) { return success(tjCustomerService.selectTjCustomerByCusId(cusId)); } /** * 新增客户信息 */ @PostMapping @ApiOperation(value = "新增客户") @Transactional public AjaxResult add(@RequestBody @ApiParam(value = "客户对象信息") TjCustomer tjCustomer) { if (null == tjCustomer.getCusIdcard() || null == tjCustomer.getCusPhone()) { return AjaxResult.error("请输入身份证号或手机号"); } HisApiGetMethodService hisApiGetMethodService = new HisApiGetMethodService(); Date dates = new Date(); final String date = DateUtil.format(dates, "yyyy-MM-dd HH:mm:ss"); String cusIdcard = tjCustomer.getCusIdcard(); boolean b = true; if (null != tjCustomer.getIdType()) { if (tjCustomer.getIdType().equals("1")) { b = MatchUtils.isIdCard(cusIdcard); } // else { // b = MatchUtils.cardValidate(cusIdcard, tjCustomer.getIdType()); // } } else { return AjaxResult.error("请选择证件类型"); } if (!b) return AjaxResult.error("证件号有误"); //判断身份证号格式是否正确 if (!(MatchUtils.isMobileNO(tjCustomer.getCusPhone()))) return AjaxResult.error("手机号错误"); LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); wq.eq(TjCustomer::getCusIdcard, cusIdcard); TjCustomer customer = tjCustomerService.getOne(wq); if (customer != null) { // BeanUtils.copyBeanProp(tjCustomer, customer); // String substring = cusIdcard.substring(cusIdcard.length() - 6); // substring = DigestUtils.md5DigestAsHex(substring.getBytes()); // customer.setCusPassword(substring); // customer.setCusBrithday(DateUtil.parse(MatchUtils.getBirthDayByIdCard(tjCustomer.getCusIdcard()), "yyyy-MM-dd")); // return AjaxResult.success(tjCustomerService.updateById(customer)); return AjaxResult.error("该人员已存在"); } String substring = cusIdcard.substring(cusIdcard.length() - 6); substring = DigestUtils.md5DigestAsHex(substring.getBytes()); tjCustomer.setCusPassword(substring); // if (tjCustomer.getIdType().equals("1")) { tjCustomer.setCusBrithday(DateUtil.parse(MatchUtils.getBirthDayByIdCard(tjCustomer.getCusIdcard()), "yyyy-MM-dd")); // } tjCustomer.setCusNumber(0L); String config = sysConfigService.selectConfigByKey("sfkqdyhis"); if (null != config && config.equals("Y")) { AjaxResult tjCustomer1 = suijieHisXinXi(tjCustomer, date); if (tjCustomer1 != null) return tjCustomer1; } else { if (tjCustomerService.save(tjCustomer)) { return AjaxResult.success(tjCustomer); } } return AjaxResult.error(); } private AjaxResult suijieHisXinXi(TjCustomer tjCustomer, String date) { AjaxResult result = controller.Outpincreateapply(tjCustomer); String result1 = getAjaxResult(result); JSONObject object = getJSONObject(result1); String code = object.getStr("ResultCode"); if (code.equals("0")) { JSONArray resultDatass = object.getJSONArray("ResultData"); Map resultData = (Map) resultDatass.get(0); if (null != resultData && resultData.size() > 0) { String pationid = resultData.get("PationId").toString(); if (null != pationid) { tjCustomer.setPationId(pationid); tjCustomerService.updateById(tjCustomer); /* OutpinregapplyDto outpinregapplyDto = new OutpinregapplyDto(); outpinregapplyDto.setPationid(pationid); outpinregapplyDto.setSqysbm("00029"); outpinregapplyDto.setMzksbm("0101"); outpinregapplyDto.setCzybm("00029"); outpinregapplyDto.setSfjz("0"); outpinregapplyDto.setGhzlbm("01"); outpinregapplyDto.setYwckbm("0001"); outpinregapplyDto.setSflstd("0"); outpinregapplyDto.setGhrq(date); //门诊挂号 AjaxResult ajaxResult = controller.Outpinregapply(outpinregapplyDto); String result2 = getAjaxResult(ajaxResult); JSONObject object1 = getJSONObject(result2); String code1 = object1.getStr("ResultCode"); if (code1.equals("0")) { JSONArray resultDatas = object1.getJSONArray("ResultData"); if (null != resultDatas && resultDatas.size() > 0) { Map resultDatasss = (Map) resultDatas.get(0); String hisRegistrationId = resultDatasss.get("his_registration_id").toString(); if (null != hisRegistrationId) { //门诊医生接诊 AjaxResult result3 = controller.Outpinconapply(hisRegistrationId, date,"00029"); String result4 = getAjaxResult(result3); JSONObject object2 = getJSONObject(result4); String code2 = object2.getStr("ResultCode"); if (code2.equals("0")) { Map data = object2.getJSONObject("ResultData"); String hisRegistrationId1 = data.get("his_registration_id").toString(); tjCustomer.setPationId(pationid); tjCustomer.setCardId(hisRegistrationId1); // tjCustomerService.updateById(tjCustomer); } } } }*/ } } if (tjCustomerService.save(tjCustomer)) { return AjaxResult.success(tjCustomer); } } return null; } /** * 修改客户信息 */ //@PreAuthorize("@ss.hasPermi('hosp:customer:edit')") //@Log(title = "客户信息", businessType = BusinessType.UPDATE) @PutMapping @ApiOperation(value = "修改客户信息") public AjaxResult edit(@RequestBody @ApiParam(value = "客户对象") TjCustomer tjCustomer) { String cusPhone = tjCustomer.getCusPhone(); if (null == cusPhone) { return AjaxResult.error("手机号不能为空"); } /*LambdaQueryWrapper wq = new LambdaQueryWrapper<>(); wq.eq(TjCustomer::getCusPhone, cusPhone); TjCustomer customer = tjCustomerService.getOne(wq); if (customer != null) { return AjaxResult.error("该手机号已被使用!"); }*/ tjCustomer.setCusPhone(cusPhone); return toAjax(tjCustomerService.updateTjCustomer(tjCustomer)); } /** * 删除客户信息 */ //@PreAuthorize("@ss.hasPermi('hosp:customer:remove')") //@Log(title = "客户信息", businessType = BusinessType.DELETE) @DeleteMapping("/{cusIds}") @ApiOperation(value = "删除客户") public AjaxResult remove(@PathVariable @ApiParam(value = "所删除客户的id") Long[] cusIds) { return toAjax(tjCustomerService.deleteTjCustomerByCusIds(cusIds)); } }