From 53d149f491dba554ee035599059a1bf65ea92df2 Mon Sep 17 00:00:00 2001
From: zhaowenxuan <chacca165@163.com>
Date: 星期三, 12 二月 2025 17:36:13 +0800
Subject: [PATCH] 增加手动同步lis接口

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/DictSfxmController.java |   93 ++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 85 insertions(+), 8 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/DictSfxmController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/DictSfxmController.java
index f368421..ca17cd5 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/DictSfxmController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/DictSfxmController.java
@@ -1,18 +1,21 @@
 package com.ltkj.web.controller.system;
 
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 
+import cn.hutool.extra.pinyin.PinyinUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.ltkj.common.core.redis.RedisCache;
+import com.ltkj.framework.config.MatchUtils;
 import com.ltkj.hosp.domain.DictHosp;
 import com.ltkj.hosp.domain.DictSfxm;
 import com.ltkj.hosp.domain.TjCustomer;
+import com.ltkj.hosp.domain.TjOrder;
 import com.ltkj.hosp.service.IDictHospService;
 import com.ltkj.hosp.service.IDictSfxmService;
+import com.ltkj.hosp.service.TjAsyncService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -41,17 +44,26 @@
     private IDictSfxmService dictSfxmService;
     @Resource
     private IDictHospService dictHospService;
+    @Resource
+    private RedisCache redisCache;
+    @Resource
+    private TjAsyncService asyncService;
 
     /**
      * 鏌ヨ鏀惰垂椤圭洰鍒楄〃
      */
 //    @PreAuthorize("@ss.hasPermi('system:sfxm:list')")
-    @GetMapping("/list")
+    @PostMapping("/list")
     @ApiOperation(value = "鏌ヨ")
-    public TableDataInfo list(DictSfxm dictSfxm) {
+    public TableDataInfo list(@RequestBody DictSfxm dictSfxm) {
         startPage();
+        String pym = dictSfxm.getPym();
+        if(null !=pym && !pym.isEmpty()) {
+            pym=dictSfxm.getPym().toUpperCase(Locale.ROOT);
+            dictSfxm.setPym(pym);
+        }
         List<DictSfxm> list = dictSfxmService.selectDictSfxmList(dictSfxm);
-        if (null != list && list.size() > 0) {
+        if (null != list && !list.isEmpty()) {
             for (DictSfxm sfxm : list) {
                 DictHosp hosp = dictHospService.getById(sfxm.getYqid());
                 if (null != hosp) {
@@ -93,6 +105,9 @@
     @PostMapping
     @ApiOperation(value = "鏂板")
     public AjaxResult add(@RequestBody DictSfxm dictSfxm) {
+        asyncService.getDictSfxms();
+        dictSfxm.setWbm(MatchUtils.toWubi(dictSfxm.getXmmc()));
+        dictSfxm.setPym(PinyinUtil.getFirstLetter(dictSfxm.getXmmc(),"").toUpperCase(Locale.ROOT));
         return toAjax(dictSfxmService.insertDictSfxm(dictSfxm));
     }
 
@@ -104,6 +119,7 @@
     @PutMapping
     @ApiOperation(value = "淇敼")
     public AjaxResult edit(@RequestBody DictSfxm dictSfxm) {
+        asyncService.getDictSfxms();
         return toAjax(dictSfxmService.updateDictSfxm(dictSfxm));
     }
 
@@ -115,6 +131,7 @@
     @DeleteMapping("/{ids}")
     @ApiOperation(value = "鍒犻櫎")
     public AjaxResult remove(@PathVariable Long[] ids) {
+        asyncService.getDictSfxms();
         return toAjax(dictSfxmService.deleteDictSfxmByIds(ids));
     }
 
@@ -122,6 +139,15 @@
     @GetMapping("/getList")
     @ApiOperation(value = "鎸夌収椤圭洰缂栫爜鏍戝舰鏌ヨ")
     public AjaxResult getList() {
+        if(redisCache.hasKey("getDictSfxms")){
+            List<DictSfxm> getDictSfxms = redisCache.getCacheObject("getDictSfxms");
+            return AjaxResult.success(getDictSfxms);
+        }
+        List<DictSfxm> dictSfxms = getDictSfxms();
+        return AjaxResult.success(dictSfxms);
+    }
+
+    private List<DictSfxm> getDictSfxms() {
         List<DictSfxm> dictSfxms = dictSfxmService.getYjDictSfxmList();
         if (null != dictSfxms && dictSfxms.size() > 0) {
             for (DictSfxm dictSfxm : dictSfxms) {
@@ -135,7 +161,7 @@
                 dictSfxm.setDictSfxms(sfxms);
             }
         }
-        return AjaxResult.success(dictSfxms);
+        return dictSfxms;
     }
 
 
@@ -171,6 +197,14 @@
             List<DictSfxm> sfx = dictSfxmService.getSjDictSfxmList(service.getId());
             if (null != sfx && sfx.size() > 0) {
                 List<DictSfxm> sfxmList = sfx.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+                if (null != sfxmList && sfxmList.size() > 0) {
+                    for (DictSfxm sfxm : sfxmList) {
+                        DictHosp hosp = dictHospService.getById(sfxm.getYqid());
+                        if (null != hosp) {
+                            sfxm.setYqName(hosp.getHospAreaName());
+                        }
+                    }
+                }
                 Collections.reverse(sfxmList);
                 map.put("date", sfxmList);
                 map.put("total", sfx.size());
@@ -182,4 +216,47 @@
         }
         return AjaxResult.success(map);
     }
+
+
+//    /**
+//     * 鏌ヨ鏀惰垂椤圭洰鍒楄〃
+//     */
+//    @PostMapping("/getSfxmList")
+//    @ApiOperation(value = "鏌ヨ")
+//    public AjaxResult getSfxmList(@ApiParam(value = "椤电爜鏁�(榛樿1)") @RequestParam(defaultValue = "1") Integer page,
+//                              @ApiParam(value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam(defaultValue = "10") Integer pageSize,
+//                              @ApiParam(value = "鎷奸煶鐮�") @RequestParam(required = false) String pym,
+//                              @ApiParam(value = "鍚嶇О") @RequestParam(required = false) String xmmc,
+//                              @ApiParam(value = "id") @RequestParam(required = false) String id) {
+//        Map<String, Object> map = new HashMap<>();
+//        List<DictSfxm> collect = null;
+//        LambdaQueryWrapper<DictSfxm> wq=new LambdaQueryWrapper<>();
+//        if(null !=pym && !"".equals(pym)) {
+//            pym=pym.toUpperCase(Locale.ROOT);
+//            wq.like(DictSfxm::getPym,pym);
+//        }
+//        if(null !=xmmc && !"".equals(xmmc)) {
+//            wq.like(DictSfxm::getXmmc,xmmc);
+//        }
+//        if(null !=id && !"".equals(id)) {
+//            wq.like(DictSfxm::getId,id);
+//        }
+//        List<DictSfxm> list = dictSfxmService.list(wq);
+//        if (null != list && list.size() > 0) {
+//            for (DictSfxm sfxm : list) {
+//                DictHosp hosp = dictHospService.getById(sfxm.getYqid());
+//                if (null != hosp) {
+//                    sfxm.setYqName(hosp.getHospAreaName());
+//                }
+//            }
+//        }
+//        collect = list.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//        if (null != collect) {
+//            map.put("total", collect.size());
+//        } else {
+//            map.put("total", 0);
+//        }
+//        map.put("list", collect);
+//        return AjaxResult.success(map);
+//    }
 }

--
Gitblit v1.8.0