dev
parent
ef99e07e96
commit
4eccaff95c
|
|
@ -668,12 +668,21 @@ public class TransportSyncService {
|
||||||
transport.setOutTime(now);
|
transport.setOutTime(now);
|
||||||
transport.setOutWhich(out_which);
|
transport.setOutWhich(out_which);
|
||||||
|
|
||||||
|
SyncTask synctask = new SyncTask();
|
||||||
|
|
||||||
boolean ret = Db.tx(new IAtom() {
|
boolean ret = Db.tx(new IAtom() {
|
||||||
@Override
|
@Override
|
||||||
public boolean run() {
|
public boolean run() {
|
||||||
try {
|
try {
|
||||||
return transport.save()
|
boolean ret = transport.save();
|
||||||
&& SyncTaskService.me.save(new SyncTask().addSaveData(transport))
|
|
||||||
|
if(!ret){
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
synctask.addSaveData(transport);
|
||||||
|
|
||||||
|
return SyncTaskService.me.save(synctask)
|
||||||
&& ModifyLogService.me.save(transport, null, Enums.DataOpType.SAVE.getId(), sysuser);
|
&& ModifyLogService.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);
|
||||||
|
|
@ -684,6 +693,8 @@ public class TransportSyncService {
|
||||||
|
|
||||||
if (ret) {
|
if (ret) {
|
||||||
Config.socketio.pubRefreshInSup(TransportDeviceService.me.real());
|
Config.socketio.pubRefreshInSup(TransportDeviceService.me.real());
|
||||||
|
|
||||||
|
SyncTaskService.me.send(synctask);
|
||||||
}
|
}
|
||||||
|
|
||||||
return ret ? Result.success(transport) : Result.failed("创建失败");
|
return ret ? Result.success(transport) : Result.failed("创建失败");
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue