同步人员

src/main/java/org/rcisoft/business/synchronizationtime/dao/SynchronizationTimeRepository.java

@@ -32,5 +32,9 @@ public interface SynchronizationTimeRepository extends BaseMapper<Synchronizatio
             + "</script>")
     @ResultMap(value = "BaseResultMap" )
     SynchronizationTime getById(@Param("id") String id);
+
+    @Select("UPDATE synchronization_time SET synchronization_time = #{synchronizationTime} WHERE business_id = #{businessId}")
+    @ResultMap(value = "BaseResultMap" )
+    void updateById(SynchronizationTime synchronizationTime);
 }
 

src/main/java/org/rcisoft/business/synchronizationtime/service/SynchronizationTimeService.java

@@ -17,26 +17,18 @@ public interface SynchronizationTimeService {
     * @return
     */
     PersistModel save(SynchronizationTime synchronizationTime);
-
-    /**
-    * 修改 
-    * @param synchronizationTime
-    * @return
-    */
-    PersistModel merge(SynchronizationTime synchronizationTime);
-
     /**
-    * 根据id查询 
+    * 根据id查询
     * @param id
     * @return
     */
-    SynchronizationTime findById(String id);
+    SynchronizationTime getById(String id);
     /**
     * 根据id查询
-    * @param id
+    * @param synchronizationTime
     * @return
     */
-    SynchronizationTime getById(String id);
+    void upadteById(SynchronizationTime synchronizationTime);
 
 
 }

src/main/java/org/rcisoft/business/synchronizationtime/service/impl/SynchronizationTimeServiceImpl.java

@@ -39,30 +39,14 @@ public class SynchronizationTimeServiceImpl implements SynchronizationTimeServic
         return new PersistModel(line);
     }
 
-    /**
-    * 修改 synchronizationTime
-    * @param synchronizationTime
-    * @return
-    */
-    @Transactional(propagation = Propagation.REQUIRED,isolation = Isolation.DEFAULT)
     @Override
-    public PersistModel merge(SynchronizationTime synchronizationTime){
-        int line = synchronizationTimeRepository.updateByPrimaryKeySelective(synchronizationTime);
-        return new PersistModel(line);
-    }
-
-    /**
-    * 根据id查询 synchronizationTime
-    * @param id
-    * @return
-    */
-    public SynchronizationTime findById(String id){
-        return synchronizationTimeRepository.selectByPrimaryKey(id);
+    public SynchronizationTime getById(String id) {
+        return synchronizationTimeRepository.getById(id);
     }
 
     @Override
-    public SynchronizationTime getById(String id) {
-        return synchronizationTimeRepository.getById(id);
+    public void upadteById(SynchronizationTime synchronizationTime) {
+        synchronizationTimeRepository.updateById(synchronizationTime);
     }
 
 }

src/main/java/org/rcisoft/sys/user/controller/SysUserController.java

@@ -26,6 +26,7 @@ import org.rcisoft.sys.user.entity.SysUser;
 import org.rcisoft.sys.user.service.SysUserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.expression.spel.ast.Assign;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.BindingResult;
 import org.springframework.web.bind.annotation.*;
 import springfox.documentation.annotations.ApiIgnore;
@@ -60,6 +61,7 @@ public class SysUserController extends PaginationController<SysUser> {
      * @param
      * @return
      */
+    @Transactional
     @GetMapping("/user/gets")
     @ApiOperation(value = "|personnels|同步人员", notes = "同步人员信息")
     public Result synchronizedUsers(@RequestParam String corpId){
@@ -95,7 +97,7 @@ public class SysUserController extends PaginationController<SysUser> {
         if (line > 0){
             // 同步成功后，更新同步时间
             synchronizationTime.setSynchronizationTime(new Date());
-            synchronizationTimeServiceImpl.merge(synchronizationTime);
+            synchronizationTimeServiceImpl.upadteById(synchronizationTime);
             return Result.builder(new PersistModel(line),
                     MessageConstant.MESSAGE_ALERT_SUCCESS,
                     MessageConstant.MESSAGE_ALERT_ERROR,