lisai17@sina.com 2020-10-22 18:04:52 +08:00
parent b9d6503f32
commit f3867d33ed
3 changed files with 21 additions and 29 deletions

View File

@ -17,6 +17,19 @@ public class ModifyLogSyncService {
private static Log log = Log.getLog(ModifyLogSyncService.class); private static Log log = Log.getLog(ModifyLogSyncService.class);
public static final ModifyLogSyncService me = new ModifyLogSyncService(); public static final ModifyLogSyncService me = new ModifyLogSyncService();
public ModifyLog generator(String table, String pks, String editdata, int type, Sysuser sysuser){
ModifyLog modify = new ModifyLog();
modify.setId(StrKit.getRandomUUID());
modify.setTable(table);
modify.setPks(pks);
modify.setEditdata(editdata);
modify.setType(type);
modify.setCreateUserId(sysuser.getId());
modify.setCreateUserName(sysuser.getName());
return modify;
}
/** /**
* *
* *

View File

@ -673,28 +673,6 @@ public class TransportSyncService {
} }
} }
/**
*
*
* @param editdata
* @param sysuser
* @return
*/
public boolean saveLog(String editdata, Sysuser sysuser) {
return ModifyLogSyncService.me.save(Transport.tablename, "id", editdata, Enums.DataOpType.SAVE.getId(), sysuser);
}
/**
*
*
* @param editdata
* @param sysuser
* @return
*/
public boolean editLog(String editdata, Sysuser sysuser) {
return ModifyLogSyncService.me.save(Transport.tablename, "id", editdata, Enums.DataOpType.UPDATE.getId(), sysuser);
}
/** /**
* *
* *
@ -760,16 +738,16 @@ public class TransportSyncService {
@Override @Override
public boolean run() { public boolean run() {
try { try {
boolean ret = transport.save() && editLog(logrecord.toJson(), sysuser); boolean ret = transport.save();
if (!ret) { if (!ret) {
return false; return false;
} }
synctask.addSaveData(ModifyLogSyncService.me.generator(Transport.tablename, "id", logrecord.toJson(), Enums.DataOpType.UPDATE.getId(), sysuser));
synctask.addSaveData(transport); synctask.addSaveData(transport);
return SyncTaskService.me.save(synctask) return SyncTaskService.me.save(synctask);
&& ModifyLogSyncService.me.save(transport, null, Enums.DataOpType.SAVE.getId(), sysuser);
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
return false; return false;
@ -837,9 +815,10 @@ public class TransportSyncService {
return false; return false;
} }
synctask.addSaveData(ModifyLogSyncService.me.generator(Transport.tablename, "id", transport.toJson(), Enums.DataOpType.SAVE.getId(), sysuser));
synctask.addSaveData(transport); synctask.addSaveData(transport);
return SyncTaskService.me.save(synctask) && saveLog(transport.toJson(), sysuser); return SyncTaskService.me.save(synctask);
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
return false; return false;
@ -916,10 +895,10 @@ public class TransportSyncService {
if (!ret) { if (!ret) {
return false; return false;
} }
synctask.addSaveData(ModifyLogSyncService.me.generator(Transport.tablename, "id", logrecord.toJson(), Enums.DataOpType.UPDATE.getId(), sysuser));
synctask.addUpdateData(transport); synctask.addUpdateData(transport);
return SyncTaskService.me.save(synctask) && editLog(logrecord.toJson(), sysuser); return SyncTaskService.me.save(synctask);
} catch (Exception e) { } catch (Exception e) {
log.error(e.getMessage(), e); log.error(e.getMessage(), e);
return false; return false;

View File

@ -15,7 +15,7 @@ socketserver.port=21002
socketio.port=12002 socketio.port=12002
#当前部署本地程序的砂站id #当前部署本地程序的砂站id
current.supermarket_id=6 current.supermarket_id=1
#落杆后,等待上磅的时间 #落杆后,等待上磅的时间
default_scale_wait_time=5000 default_scale_wait_time=5000