lock和unlock的实现

gjjs-bd-business/src/main/resources/mapper/lckmapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.brilliance.mda.support.mybatis.lck.LckMapper">
+
+    <insert id="insert">
+        insert into LCK(NAM,TXT,DATTIM) values(#{nam},#{key},#{date})
+    </insert>
+
+    <select id="select" resultType="java.util.Map">
+        select * from LCK where TXT = #{key}
+    </select>
+
+    <select id="delete" resultType="java.lang.Integer">
+        delete from LCK where TXT = #{key}
+    </select>
+
+</mapper>
\ No newline at end of file

gjjs-bd-mybatis-support/src/main/java/com/brilliance/mda/support/mybatis/DBLocker.java

 package com.brilliance.mda.support.mybatis;
 
 
+import com.brilliance.mda.runtime.mda.Constants;
 import com.brilliance.mda.runtime.mda.ILocker;
 import com.brilliance.mda.runtime.mda.LockInfo;
+import com.brilliance.mda.runtime.mda.driver.MdaEnv;
+import com.brilliance.mda.support.mybatis.lck.LckMapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.io.Serializable;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 @Component
 public class DBLocker implements ILocker {
+    private static Logger log = LoggerFactory.getLogger(DBLocker.class);
+
+    @Autowired
+    private LckMapper lckMapper;
 
     @Override
     public boolean lock(Serializable key) {
@@ -26,14 +39,33 @@ public class DBLocker implements ILocker {
     }
 
     @Override
-    public LockInfo lock(String userName, Serializable key) {
+    public LockInfo lock(String lockName, Serializable key) {
+        Date date = new Date();
+        try {
+            lckMapper.insert(lockName, key.toString(), date);
+        } catch (Exception e) {
+            log.warn("获取锁失败,key:{}已经被锁定", key);
+            MdaEnv.getContext().setErrorCode(Constants.ERROR_LOCKED);
+            return null;
+        }
+        List<Map> list = lckMapper.select(key.toString());
+        if (list.size() > 1) {
+            log.warn("获取锁失败,key:{}已经被锁定", key);
+            MdaEnv.getContext().setErrorCode(Constants.ERROR_LOCKED);
             return null;
         }
+        return new LockInfo(date, key.toString());
+    }
 
     @Override
     public boolean unlock(Serializable key) {
+        try {
+            lckMapper.delete(key.toString());
+        } catch (Exception e) {
             return false;
         }
+        return true;
+    }
 
     @Override
     public boolean unlock(String lockname, Serializable key) {

gjjs-bd-mybatis-support/src/main/java/com/brilliance/mda/support/mybatis/lck/LckMapper.java

+package com.brilliance.mda.support.mybatis.lck;
+
+import org.apache.ibatis.annotations.Param;
+import org.mybatis.spring.SqlSessionTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+
+@Component
+public class LckMapper {
+
+    final String FNAME = this.getClass().getName();
+
+    @Autowired
+    public SqlSessionTemplate template;
+
+
+    public Integer insert(@Param("nam") String nam, @Param("key") String key, @Param("date") Date date) {
+        // // INSERT INTO LCK(NAM,TXT,DATTIM) VALUES(?,?,?)
+        Map<String, Object> map = new HashMap<>();
+        map.put("nam", nam);
+        map.put("key", key);
+        map.put("date", date);
+        return template.insert(FNAME + ".insert", map);
+    }
+
+
+    public List<Map> select(@Param("key") String key) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("key", key);
+        return template.selectList(FNAME + ".select", map);
+    }
+
+
+    public Integer delete(@Param("key") String key) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("key", key);
+        return template.delete(FNAME + ".delete", map);
+    }
+
+
+}
\ No newline at end of file