main
gaoshuguang 2 years ago
parent 063a34ebef
commit bbde3834c3

@ -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<NameTableAuto> 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();

@ -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) {

Loading…
Cancel
Save