forked from kidgrow-microservices-platform

luliqiang
2020-12-18 d41c99b7822c175abac28ddaff075716ef25e67e
kidgrow-business/kidgrow-opration-center/kidgrow-opration-center-biz/src/main/java/com/kidgrow/oprationcenter/service/impl/PartnerDockingInfoServiceImpl.java
@@ -27,6 +27,7 @@
import java.io.IOException;
import java.io.InputStream;
import java.text.SimpleDateFormat;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -101,6 +102,11 @@
        // 服务器信息SQL文
        String serverSQL= "";
        InputStream fileImput =null;
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String createTime = "";
        String updateTime = "";
        try {
            // 1、读取基础表结构SQL
            Resource resource = resourceLoader.getResource("classpath:template//imageServer_template.sql");
@@ -117,6 +123,8 @@
                List<SysHospital> hospitalLists= JSONObject.parseArray(jsonData,SysHospital.class);
                if (hospitalLists.size()> 0) {
                    SysHospital hospitalInfo = hospitalLists.get(0);
                    createTime = simpleDateFormat.format(hospitalInfo.getCreateTime());
                    updateTime = simpleDateFormat.format(hospitalInfo.getUpdateTime());
                    hospitalSQL = " INSERT INTO sys_hospital  VALUES (" +
                            hospitalInfo.getId() + ", " +
                            "'" + hospitalInfo.getHospitalName()+ "', " +
@@ -146,8 +154,8 @@
                            "'" + hospitalInfo.getCreateUserName()+ "', " +
                            hospitalInfo.getUpdateUserId() + ", " +
                            "'" + hospitalInfo.getUpdateUserName()+ "', " +
                            "'" + hospitalInfo.getCreateTime()+ "', " +
                            "'" + hospitalInfo.getUpdateTime()+"' " +
                            "'" + createTime+ "', " +
                            "'" + updateTime+"' " +
                            ");\n\r";
                }
@@ -204,6 +212,9 @@
            // 5、读取合作商信息表Partner_Info,生成SQL文
            PartnerInfo partnerInfo = partnerInfoService.getById(partnerDockingInfo.getPartnerId());
            if (partnerInfo!= null) {
                createTime = simpleDateFormat.format(partnerInfo.getCreateTime());
                updateTime = simpleDateFormat.format(partnerInfo.getUpdateTime());
                partnerSQL = "INSERT INTO partner_info VALUES (" +
                        partnerInfo.getId() + ", " +
                        "'" +partnerInfo.getPartnerName() + "', " +
@@ -217,16 +228,19 @@
                        "'" +partnerInfo.getPartnerBussinessArea() + "', " +
                        "'" +partnerInfo.getPartnerIntroduce() + "', " +
                        "'" +partnerInfo.getPartnerUniqueCode() + "', " +
                        + partnerInfo.getCreateUserId() + ", " +
                        "0, 1, "+ partnerInfo.getCreateUserId() + ", " +
                        "'" +partnerInfo.getCreateUserName() + "', " +
                        "'" +partnerInfo.getCreateTime() + "', " +
                        "'" +createTime + "', " +
                        + partnerInfo.getUpdateUserId() + ", " +
                        "'" +partnerInfo.getUpdateUserName() + "', " +
                        "'" +partnerInfo.getUpdateTime() + "'  " +
                        "'" +updateTime + "'  " +
                        ");\n\r";
            }
            // 6、读取服务器信息表Server_Info,生成SQL文
            if ((partnerDockingInfo.getAccessKey() != null) && (!partnerDockingInfo.getAccessKey().isEmpty())) {
                createTime = simpleDateFormat.format(partnerDockingInfo.getCreateTime());
                updateTime = simpleDateFormat.format(partnerDockingInfo.getUpdateTime());
                serverSQL = "INSERT INTO server_info VALUES(" +
                        partnerDockingInfo.getId() + ", " +
                        partnerDockingInfo.getPartnerId() + ", " +
@@ -239,10 +253,10 @@
                        "0, 1, " +
                        partnerDockingInfo.getCreateUserId() + ", " +
                        "'" + partnerDockingInfo.getCreateUserName() + "', " +
                        "'" + partnerDockingInfo.getCreateTime() + "', " +
                        "'" + createTime + "', " +
                        partnerDockingInfo.getUpdateUserId() + ", " +
                        "'" + partnerDockingInfo.getUpdateUserName() + "', " +
                        "'" + partnerDockingInfo.getUpdateTime() + "', " +
                        "'" + updateTime + "', " +
                        ");\n\r";
            }
            // 7、所有SQL文合并入基本的SQL中