diff --git a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CreateDbfByDllServiceImpl.java b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CreateDbfByDllServiceImpl.java index 4a8becea..7b34a3d9 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CreateDbfByDllServiceImpl.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/CreateDbfByDllServiceImpl.java @@ -431,64 +431,48 @@ public class CreateDbfByDllServiceImpl implements CreateDbfByDllService { updateWrapper //.set("CARDFLAG", Integer.parseInt(protocolType)) .set("CARDFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_102: sqbType = Constant.STR_1002; updateWrapper //.set("CARDINCFLAG", Integer.parseInt(protocolType)) .set("CARDINCFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_103: sqbType = Constant.STR_1003; updateWrapper //.set("OBUFLAG", Integer.parseInt(protocolType)) .set("OBUFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_104: sqbType = Constant.STR_1004; updateWrapper //.set("OBUINCFLAG", Integer.parseInt(protocolType)) .set("OBUINCFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_105: sqbType = Constant.STR_1005; updateWrapper //.set("CARNOFLAG", Integer.parseInt(protocolType)) .set("CARNOFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_106: sqbType = Constant.STR_1006; updateWrapper //.set("CARNOINCFLAG", Integer.parseInt(protocolType)) .set("CARNOINCFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_107: sqbType = Constant.STR_1007; updateWrapper //.set("CARNOGRAYFLAG", Integer.parseInt(protocolType)) .set("CARNOGRAYFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_108: sqbType = Constant.STR_1008; updateWrapper //.set("CARNOGRAYINCFLAG", Integer.parseInt(protocolType)) .set("CARNOGRAYINCFLAGSQB", Integer.parseInt(sqbType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; } UpdateWrapper updateWrapper2 = new UpdateWrapper<>(); @@ -497,48 +481,35 @@ public class CreateDbfByDllServiceImpl implements CreateDbfByDllService { switch (protocolType) { case Constant.STR_101: updateWrapper2.set("CARDFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_102: updateWrapper2.set("CARDINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_103: updateWrapper2.set("OBUFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_104: updateWrapper2.set("OBUINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_105: updateWrapper2.set("CARNOFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_106: updateWrapper2.set("CARNOINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_107: updateWrapper2.set("CARNOGRAYFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; case Constant.STR_108: updateWrapper2.set("CARNOGRAYINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper2); break; } //入库新文件的信息表 intoNewFileInfo(protocolType, zlibFileNameMd5, dbfDir, version, sqbType, zlibFileNameMd5Sqb); + //更新自动下发分中心相应状态 + nameTableAutoMapper.update(null, updateWrapper); + nameTableAutoMapper.update(null, updateWrapper2); String nowString = DateTimeUtil.getFormateString(new Date(), Constant.YYYY_MM_DD_HH_MM_SS); String sqlParam = Constant.UPDATE_BUSINESS_HANDLER + nowString + Constant.PUBLISH_TIME + nowString + Constant.WHERE_ID + businessTask.getId(); diff --git a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/ZipToSqbServiceImpl.java b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/ZipToSqbServiceImpl.java index 35c9ec03..a01a27e6 100644 --- a/ParamDownload/src/main/java/com/nm/gsgl/service/impl/ZipToSqbServiceImpl.java +++ b/ParamDownload/src/main/java/com/nm/gsgl/service/impl/ZipToSqbServiceImpl.java @@ -338,40 +338,26 @@ public class ZipToSqbServiceImpl implements ZipToSqbService { switch (protocolType) { case Constant.STR_801: updateWrapper.set("GREENFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_802: updateWrapper.set("GREENINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_808: updateWrapper.set("BIGAPPFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_809: updateWrapper.set("BIGFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_111: basicType = Constant.STR_222; updateWrapper.set("BASICCDFLAG", Integer.parseInt(protocolType)) .set("BASICFLAG", Integer.parseInt(basicType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_919: updateWrapper.set("EMERCARFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; case Constant.STR_920: updateWrapper.set("EMERCARINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; default: log.error("[uuid:{}]-未找到相应的更新自动下发分中心相应状态方法", uuid); @@ -380,6 +366,8 @@ public class ZipToSqbServiceImpl implements ZipToSqbService { //入库新文件的信息表 intoNewFileInfo(protocolType, zlibFileNameMd5Sqb, dbfDir, version, basicType, dayBackPath, fileName); + //更新自动下发分中心相应状态 + nameTableAutoMapper.update(null, updateWrapper); String nowString = DateTimeUtil.getFormateString(new Date(), Constant.YYYY_MM_DD_HH_MM_SS); String sqlParam = Constant.UPDATE_BUSINESS_HANDLER + nowString + Constant.PUBLISH_TIME + nowString + Constant.WHERE_ID + businessTask.getId(); if (DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqlParam) > 0) { @@ -627,13 +615,10 @@ public class ZipToSqbServiceImpl implements ZipToSqbService { switch (protocolType) { case Constant.STR_3501: updateWrapper.set("BLACKFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); + break; case Constant.STR_3601: updateWrapper.set("BLACKINCFLAG", Integer.parseInt(protocolType)); - //更新自动下发分中心相应状态 - nameTableAutoMapper.update(null, updateWrapper); break; default: log.error("[uuid:{}]-未找到相应的更新自动下发分中心相应状态方法", uuid); @@ -642,6 +627,8 @@ public class ZipToSqbServiceImpl implements ZipToSqbService { //入库新文件的信息表 intoNewFileInfo(protocolType, zlibFileNameMd5Sqb, dbfDir, version, basicType, dayBackPath, fileName); + //更新自动下发分中心相应状态 + nameTableAutoMapper.update(null, updateWrapper); String nowString = DateTimeUtil.getFormateString(new Date(), Constant.YYYY_MM_DD_HH_MM_SS); String sqlParam = Constant.UPDATE_BUSINESS_HANDLER + nowString + Constant.PUBLISH_TIME + nowString + Constant.WHERE_ID + businessTask.getId(); if (DatabaseUtil.insertSqlite(sqliteDriverName, sqliteUrl, sqlParam) > 0) {