增加气瓶数据同步更新

amos-boot-data/amos-boot-data-openapi/src/main/java/com/yeejoin/amos/api/openapi/face/service/SyncCylinderDataService.java

@@ -11,10 +11,13 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderInfoDto;
+import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderFilling;
+import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderFillingCheck;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderFillingRecord;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderInfo;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnit;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnitVideo;
+import com.yeejoin.amos.boot.module.cylinder.flc.api.mapper.CylCylinderFillingCheckMapper;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.mapper.CylinderFillingCheckMapper;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.mapper.CylinderFillingExamineMapper;
 import com.yeejoin.amos.boot.module.cylinder.flc.api.mapper.CylinderFillingMapper;
@@ -53,6 +56,8 @@ public class SyncCylinderDataService
    */
   @Autowired
   private CylinderFillingCheckMapper  cylinderFillingCheckMapper;
+  @Autowired
+  private CylCylinderFillingCheckMapper cylCylinderFillingCheckMapper;
   /**
    * 液化气体气瓶充装信息审核
    */
@@ -77,27 +82,36 @@ public class SyncCylinderDataService
     List<CylinderUnit> cylinderUnitList = Bean.toModels(cylinderUnitDto,CylinderUnit.class);
     cylinderUnitMapper.saveOrUpdateBatch(cylinderUnitList);
   }
-
+  @DS("tzs")
   public void syncCylinderInfo(final List<TmCylinderInfoModel> cylinderInfoDto) {
     List<CylinderInfo> cylinderUnitList = Bean.toModels(cylinderInfoDto,CylinderInfo.class);
     cylinderInfoMapper.saveOrUpdateBatch(cylinderUnitList);
   }
-
+  @DS("tzs")
   public void syncCylinderFillingExamine(List<TmCylinderFillingExamineModel> cylinderFillingExamineDto) {
-  }
 
+  }
+  @DS("tzs")
   public void syncCylinderFillingRecord(List<TmCylinderFillingRecordModel> cylinderFillingRecordDtos) {
+    List<CylinderFillingRecord> cylinderFillingRecordList = Bean.toModels(cylinderFillingRecordDtos, CylinderFillingRecord.class);
+    cylCylinderFillingCheckMapper.batchInsertOrUpdate(cylinderFillingRecordList);
   }
-
+  @DS("tzs")
   public void syncCylinderInspection(List<TmCylinderInspectionModel> cylinderInspectionDto) {
-  }
 
-  public void syncCylinderTag(List<TmCylinderTagsModel> cylinderTagsDtos) {
   }
+  @DS("tzs")
+  public void syncCylinderTag(List<TmCylinderTagsModel> cylinderTagsDtos) {
 
+  }
+  @DS("tzs")
   public void syncCylinderFillingBefore(List<TmCylinderFillingModel> cylinderFillingDtos) {
+    List<CylinderFilling> cylinderFillingList = Bean.toModels(cylinderFillingDtos, CylinderFilling.class);
+    cylCylinderFillingCheckMapper.saveAndBatchInsert(cylinderFillingList);
   }
-
+  @DS("tzs")
   public void syncCylinderFillingAfter(List<TmCylinderFillingCheckModel> cylinderFillingCheckDtos) {
+    List<CylinderFillingCheck> cylinderFillingChecList = Bean.toModels(cylinderFillingCheckDtos, CylinderFillingCheck.class);
+    cylinderFillingCheckMapper.saveOrUpdateByCondition(cylinderFillingChecList);
   }
 }