|
@@ -6,6 +6,7 @@ import com.huimv.receiver.farm.dao.entity.ProdDayWeightEntity;
|
|
import com.huimv.receiver.farm.dao.repo.ProdBatchWeightRepo;
|
|
import com.huimv.receiver.farm.dao.repo.ProdBatchWeightRepo;
|
|
import com.huimv.receiver.farm.dao.repo.ProdDayWeightRepo;
|
|
import com.huimv.receiver.farm.dao.repo.ProdDayWeightRepo;
|
|
import com.huimv.receiver.farm.service.IWeight;
|
|
import com.huimv.receiver.farm.service.IWeight;
|
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
@@ -21,6 +22,7 @@ import java.util.Date;
|
|
* @Create : 2020-12-25
|
|
* @Create : 2020-12-25
|
|
**/
|
|
**/
|
|
@Service
|
|
@Service
|
|
|
|
+@Slf4j
|
|
public class WeightImpl implements IWeight {
|
|
public class WeightImpl implements IWeight {
|
|
@Autowired
|
|
@Autowired
|
|
private ProdDayWeightRepo dayWeightRepo;
|
|
private ProdDayWeightRepo dayWeightRepo;
|
|
@@ -39,6 +41,7 @@ public class WeightImpl implements IWeight {
|
|
*/
|
|
*/
|
|
@Override
|
|
@Override
|
|
public void saveDayWeight(String data) {
|
|
public void saveDayWeight(String data) {
|
|
|
|
+ log.info("saveDayWeight>>"+data);
|
|
JSONObject dayWeightJo = JSONObject.parseObject(data);
|
|
JSONObject dayWeightJo = JSONObject.parseObject(data);
|
|
Long date = dayWeightJo.getLong("addTime");
|
|
Long date = dayWeightJo.getLong("addTime");
|
|
Integer farmId = dayWeightJo.getInteger("farmId");
|
|
Integer farmId = dayWeightJo.getInteger("farmId");
|
|
@@ -89,11 +92,13 @@ public class WeightImpl implements IWeight {
|
|
newBatchWeightEntity.setNetWeight(batchWeightJo.getFloat("netWeight"));
|
|
newBatchWeightEntity.setNetWeight(batchWeightJo.getFloat("netWeight"));
|
|
newBatchWeightEntity.setAddTime(new Timestamp(new Date().getTime()));
|
|
newBatchWeightEntity.setAddTime(new Timestamp(new Date().getTime()));
|
|
batchWeightRepo.saveAndFlush(newBatchWeightEntity);
|
|
batchWeightRepo.saveAndFlush(newBatchWeightEntity);
|
|
|
|
+ log.info("新增批次称重数据>>"+newBatchWeightEntity);
|
|
}else{
|
|
}else{
|
|
existBatchWeightEntity.setGrossWeight(batchWeightJo.getFloat("grossWeight"));
|
|
existBatchWeightEntity.setGrossWeight(batchWeightJo.getFloat("grossWeight"));
|
|
existBatchWeightEntity.setTareWeight(batchWeightJo.getFloat("tareWeight"));
|
|
existBatchWeightEntity.setTareWeight(batchWeightJo.getFloat("tareWeight"));
|
|
existBatchWeightEntity.setNetWeight(batchWeightJo.getFloat("netWeight"));
|
|
existBatchWeightEntity.setNetWeight(batchWeightJo.getFloat("netWeight"));
|
|
batchWeightRepo.saveAndFlush(existBatchWeightEntity);
|
|
batchWeightRepo.saveAndFlush(existBatchWeightEntity);
|
|
|
|
+ log.info("编辑批次称重数据>>"+existBatchWeightEntity);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|