砂站新增商品接口修改

dev
徐杰盟 2023-09-05 16:52:20 +08:00
parent 239f6f7169
commit c45f67c983
1 changed files with 6 additions and 1 deletions

View File

@ -18,6 +18,7 @@ import com.jfinal.plugin.activerecord.IAtom;
import java.math.BigDecimal;
import java.sql.SQLException;
import java.util.Date;
import java.util.Objects;
/**
* Generated by COWR Tue Dec 07 16:33:49 CST 2021
@ -38,6 +39,8 @@ public class ProductPriceModifySyncService extends BaseSyncService {
model.setCreateUserId(user.getId());
SyncTask synctask = new SyncTask();
Integer supermarketId = model.getSupermarketId();
synctask.setSupermarketId(supermarketId);
boolean ret = Db.tx(new IAtom() {
@Override
public boolean run() {
@ -65,8 +68,10 @@ public class ProductPriceModifySyncService extends BaseSyncService {
synctask.addSaveData(model);
synctask.addSaveData(his);
Result result = SupermarketSyncService.me.addProduct(supermarketId, model.getProductId(), model.getUnitPrice().doubleValue(), user);
return SyncTaskService.me.save(synctask, model.getSupermarketId())
&& ModifyLogService.me.save(model, null, Enums.DataOpType.SAVE.getId(), user);
&& ModifyLogService.me.save(model, null, Enums.DataOpType.SAVE.getId(), user)
&& Objects.nonNull(result);
} catch (Exception e) {
log.error(e.getMessage(), e);