增加萝北换表

src/main/java/com/zcxk/meterreadingsystemv2/kafka/AddAccountReceiver.java

@@ -197,7 +197,7 @@ public class AddAccountReceiver {
 
             }
         }catch (Exception e){
-            log.info("Kafka consumer Received error={}",e.getMessage());
+            log.info("Kafka consumer Received error={},{}",e.getMessage(),e);
             e.printStackTrace();
         }
 

src/main/java/com/zcxk/meterreadingsystemv2/kafka/ReplaceMaterReceiver.java

@@ -115,13 +115,37 @@ public class ReplaceMaterReceiver {
                 }else {
                     log.info("user not find");
                 }
-
-
+            }
+            if("prd".equals(data.getActive()) && data.getCustomerId() == 25){
+                //萝北
+                DynamicDataSourceContextHolder.setDataSourceKey("lb");
+                log.info("＝＝＝＝＝service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
+                //commOrgLevel = "10001014";
+                //commOrgIdenty = "10001014";
+                Yhsbgxb yhsbgxb = yhsbgxbMapper.findByBsm(data.getOldWaterNo());
+                if (yhsbgxb != null) {
+                    TblIcHxHbxx hbxx = new TblIcHxHbxx();
+                    hbxx.setYhid(yhsbgxb.getYhid());
+                    hbxx.setYsbbh(data.getOldWaterNo());
+                    hbxx.setCbds(new BigDecimal(data.getOldEndWsv()).setScale(1,BigDecimal.ROUND_HALF_UP));
+                    hbxx.setXsbbh(data.getNewWaterNo());
+                    hbxx.setXbds(new BigDecimal(data.getNewBeginWsv()).setScale(1,BigDecimal.ROUND_HALF_UP));
+                    hbxx.setHbdata(data.getDateCreate());
+                    hbxx.setSbcj("37");
+                    hbxx.setFlag("0");
+                    hbxx.setScdata(new Date());
+                    //hbxx.setCommOrgLevel(commOrgLevel);
+                    //hbxx.setCommOrgIdenty(commOrgIdenty);
+                    log.info("hbxx = {}",JSON.toJSONString(hbxx));
+                    tblIcHxHbxxMapper.insertSelective(hbxx);
+                }else {
+                    log.info("user not find");
+                }
             }
             //TblIcHxHbxx tblIcHxHbxx = new TblIcHxHbxx();
 
         }catch (Exception e){
-            log.info("ReplaceMaterReceiver receiveMessage error {}",e.getMessage());
+            log.info("ReplaceMaterReceiver receiveMessage error {},{}",e.getMessage(),e);
             e.printStackTrace();
         }
     }