巴里坤

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

@@ -34,6 +34,34 @@ public class ReplaceMaterReceiver {
             log.info("WaterMeterReplaceData data = {}", JSON.toJSONString(data));
             String commOrgLevel = null;
             String commOrgIdenty = null;
+            if("prd".equals(data.getActive()) && data.getCustomerId() == 66){
+                //巴里坤
+                DynamicDataSourceContextHolder.setDataSourceKey("balikun");
+                log.info("＝＝＝＝＝service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
+                commOrgLevel = "10001013";
+                commOrgIdenty = "10001013";
+                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");
+                }
+
+
+            }
             if("prd".equals(data.getActive()) && data.getCustomerId() == 57){
                 //同江
                 DynamicDataSourceContextHolder.setDataSourceKey("tongjiang");