修改统计报表

bill-manager/src/main/java/com/mortals/xhx/module/ph/web/PhQueueController.java

@@ -147,8 +147,32 @@ public class PhQueueController extends BaseCRUDJsonBodyMappingController<PhQueue
         }
     }
 
-
     private void getSite(PhQueueEntity entity) {
+        if (!ObjectUtils.isEmpty(entity.getSiteId())) {
+            RedisTemplate<String, String> baseRedisTemplate = cacheService.selectDbRedisTemplate(1);
+            //com:mortals:xhx:module:site:model:SiteEntity  redis调用
+            String siteStr = (String) baseRedisTemplate.opsForHash().get("com:mortals:xhx:module:site:model:SiteEntity", String.valueOf(entity.getSiteId()));
+            if (!ObjectUtils.isEmpty(siteStr)) {
+                SitePdu sitePdu = JSON.parseObject(siteStr, SitePdu.class);
+
+                entity.setSiteId(sitePdu.getId());
+                entity.setSiteCode(sitePdu.getSiteCode());
+                entity.setSiteName(sitePdu.getSiteName());
+
+            } else if (!ObjectUtils.isEmpty(entity.getSiteCode())) {
+                buildSiteBySideCode(entity);
+            } else {
+                log.info("站点信息不存在,siteId={}", entity.getSiteId());
+            }
+        } else {
+            if (!ObjectUtils.isEmpty(entity.getSiteCode())) {
+                buildSiteBySideCode(entity);
+            }
+        }
+    }
+
+
+   /* private void getSite(PhQueueEntity entity) {
         if (!ObjectUtils.isEmpty(entity.getSiteId())) {
 
             RedisTemplate<String, String> baseRedisTemplate = cacheService.selectDbRedisTemplate(1);
@@ -166,7 +190,7 @@ public class PhQueueController extends BaseCRUDJsonBodyMappingController<PhQueue
             }
 
             //feign调用
-         /*   Rest<SitePdu> sitePduRest = siteFeign.info(entity.getSiteId());
+         *//*   Rest<SitePdu> sitePduRest = siteFeign.info(entity.getSiteId());
             if (YesNoEnum.YES.getValue() == sitePduRest.getCode()) {
                 SitePdu sitePdu = sitePduRest.getData();
                 if (!ObjectUtils.isEmpty(sitePdu)) {
@@ -175,7 +199,7 @@ public class PhQueueController extends BaseCRUDJsonBodyMappingController<PhQueue
                 } else {
                     log.info("站点信息不存在,siteId={}", entity.getSiteId());
                 }
-            }*/
+            }*//*
         } else {
             if (!ObjectUtils.isEmpty(entity.getSiteCode())) {
                 SitePdu pdu = new SitePdu();
@@ -194,6 +218,23 @@ public class PhQueueController extends BaseCRUDJsonBodyMappingController<PhQueue
                 }
             }
         }
+    }*/
+
+
+
+    private void buildSiteBySideCode(PhQueueEntity entity) {
+        RedisTemplate<String, String> baseRedisTemplate = cacheService.selectDbRedisTemplate(1);
+        String siteStr = (String) baseRedisTemplate.opsForHash().get("com:mortals:xhx:module:site:model:SiteEntity", entity.getSiteCode());
+        if (!ObjectUtils.isEmpty(siteStr)) {
+            SitePdu sitePdu = JSON.parseObject(siteStr, SitePdu.class);
+            if (!ObjectUtils.isEmpty(sitePdu)) {
+                entity.setSiteId(sitePdu.getId());
+                entity.setSiteCode(sitePdu.getSiteCode());
+                entity.setSiteName(sitePdu.getSiteName());
+            } else {
+                log.info("站点信息不存在,siteId={}", entity.getSiteId());
+            }
+        }
     }