|
@@ -9,9 +9,12 @@ import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
import javax.annotation.Resource;
|
|
|
|
+import java.util.Date;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
import java.util.concurrent.atomic.AtomicInteger;
|
|
|
|
|
|
|
|
+import static com.google.common.collect.Lists.newArrayList;
|
|
|
|
+
|
|
@Slf4j
|
|
@Slf4j
|
|
@Service
|
|
@Service
|
|
public class MssqlService {
|
|
public class MssqlService {
|
|
@@ -65,4 +68,91 @@ public class MssqlService {
|
|
log.info("=======================end list size="+list.size()+"-count="+count.get());
|
|
log.info("=======================end list size="+list.size()+"-count="+count.get());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ public void test() {
|
|
|
|
+ String originName = "jl";
|
|
|
|
+ DynamicDataSourceContextHolder.setDataSourceKey(originName);
|
|
|
|
+ log.info("=====service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
|
|
|
|
+ TRemoteCustomer tRemoteCustomerOld = tRemoteCustomerMapper.findByMeteraddr("004A770124022052");
|
|
|
|
+ if (tRemoteCustomerOld != null) {
|
|
|
|
+ log.info("已经存在");
|
|
|
|
+ tRemoteCustomerOld.setUsername("李丹");
|
|
|
|
+ tRemoteCustomerOld.setLinkman("李丹");
|
|
|
|
+ tRemoteCustomerOld.setPhone("18708931160");
|
|
|
|
+ tRemoteCustomerOld.setPaperno("421023199004156622");
|
|
|
|
+ tRemoteCustomerOld.setAddress("3301");
|
|
|
|
+ tRemoteCustomerMapper.updateByPrimaryKeySelective(tRemoteCustomerOld);
|
|
|
|
+ return;
|
|
|
|
+ }else {
|
|
|
|
+ log.info("不存在");
|
|
|
|
+ }
|
|
|
|
+ TRemoteCustomer tRemoteCustomer = new TRemoteCustomer();
|
|
|
|
+ tRemoteCustomer.setFactoryid(5);
|
|
|
|
+ tRemoteCustomer.setMeteraddr("770124022052");
|
|
|
|
+ tRemoteCustomer.setUsername("李丹");
|
|
|
|
+ tRemoteCustomer.setLinkman("李丹");
|
|
|
|
+ tRemoteCustomer.setPhone("18708931160");
|
|
|
|
+ tRemoteCustomer.setPaperno("421023199004156622");
|
|
|
|
+ tRemoteCustomer.setAddress("3301");
|
|
|
|
+ //tRemoteCustomer.setCaliber(); 口径
|
|
|
|
+ tRemoteCustomer.setInstalldate(new Date());
|
|
|
|
+ tRemoteCustomer.setIfctrlvalve(0);//是否阀控表
|
|
|
|
+ tRemoteCustomer.setImported(0);
|
|
|
|
+ //log.info(JSON.toJSONString(tRemoteCustomer));
|
|
|
|
+ //tRemoteCustomer.setOldmeterid();
|
|
|
|
+ //tRemoteCustomer.setUsercode();//客户编码
|
|
|
|
+ //tRemoteCustomer.setExtenddata1();
|
|
|
|
+ //tRemoteCustomer.setExtenddata2();
|
|
|
|
+ //tRemoteCustomer.setExtenddata3();
|
|
|
|
+ //tRemoteCustomer.setOldmeteraddr();
|
|
|
|
+ //tRemoteCustomer.setValveflag();
|
|
|
|
+ //tRemoteCustomer.setId();
|
|
|
|
+ //tRemoteCustomerMapper.insertSelective(tRemoteCustomer);
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void addJlCustomer() {
|
|
|
|
+ String originName = "jl";
|
|
|
|
+ AtomicInteger count = new AtomicInteger(0);
|
|
|
|
+ DynamicDataSourceContextHolder.setDataSourceKey("smart-city");
|
|
|
|
+ log.info("=====service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
|
|
|
|
+ List<DeviceCustomerInfo> list = deviceMapper.getDeviceCustomerInfoByCustomerId(19);
|
|
|
|
+
|
|
|
|
+ DynamicDataSourceContextHolder.setDataSourceKey(originName);
|
|
|
|
+ log.info("=====service当前连接的数据库是:" + DynamicDataSourceContextHolder.getDataSourceKey());
|
|
|
|
+ if (list != null && list.size() > 0) {
|
|
|
|
+ log.info("=======================list size="+list.size());
|
|
|
|
+ for (DeviceCustomerInfo deviceCustomerInfo : list) {
|
|
|
|
+ TRemoteCustomer tRemoteCustomerOld = tRemoteCustomerMapper.findByMeteraddr(deviceCustomerInfo.getDeviceNo());
|
|
|
|
+ if (tRemoteCustomerOld != null) {
|
|
|
|
+ log.info(deviceCustomerInfo.getDeviceNo()+"已经存在");
|
|
|
|
+ continue;
|
|
|
|
+ }
|
|
|
|
+ TRemoteCustomer tRemoteCustomer = new TRemoteCustomer();
|
|
|
|
+ tRemoteCustomer.setFactoryid(5);
|
|
|
|
+ tRemoteCustomer.setMeteraddr(deviceCustomerInfo.getWaterMeterNo());
|
|
|
|
+ tRemoteCustomer.setUsername(deviceCustomerInfo.getUserName());
|
|
|
|
+ tRemoteCustomer.setLinkman(deviceCustomerInfo.getUserName());
|
|
|
|
+ tRemoteCustomer.setPhone(deviceCustomerInfo.getUserPhone());
|
|
|
|
+ tRemoteCustomer.setPaperno(deviceCustomerInfo.getIdCard());
|
|
|
|
+ tRemoteCustomer.setAddress(deviceCustomerInfo.getLocation());
|
|
|
|
+ //tRemoteCustomer.setCaliber(); 口径
|
|
|
|
+ tRemoteCustomer.setInstalldate(deviceCustomerInfo.getInstallTime());
|
|
|
|
+ tRemoteCustomer.setIfctrlvalve(0);//是否阀控表
|
|
|
|
+ tRemoteCustomer.setImported(0);
|
|
|
|
+ //log.info(JSON.toJSONString(tRemoteCustomer));
|
|
|
|
+ //tRemoteCustomer.setOldmeterid();
|
|
|
|
+ //tRemoteCustomer.setUsercode();//客户编码
|
|
|
|
+ //tRemoteCustomer.setExtenddata1();
|
|
|
|
+ //tRemoteCustomer.setExtenddata2();
|
|
|
|
+ //tRemoteCustomer.setExtenddata3();
|
|
|
|
+ //tRemoteCustomer.setOldmeteraddr();
|
|
|
|
+ //tRemoteCustomer.setValveflag();
|
|
|
|
+ //tRemoteCustomer.setId();
|
|
|
|
+ tRemoteCustomerMapper.insertSelective(tRemoteCustomer);
|
|
|
|
+ count.incrementAndGet();
|
|
|
|
+ }
|
|
|
|
+ log.info("=======================end list size="+list.size()+"-count="+count.get());
|
|
|
|
+ }
|
|
|
|
+ }
|
|
}
|
|
}
|