毕业设计—基于java区块链技术开发考勤管理系统.zip

package com.attendance.service; import java.util.ArrayList; import java.util.Collection; import java.util.List; import com.attendance.blockchain.block.Block; import com.attendance.blockchain.block.BlockBody; import com.attendance.blockchain.block.body.Attendance; import com.attendance.blockchain.block.pair.PairKey; import com.attendance.blockchain.block.pair.PrivateKey; import com.attendance.blockchain.common.Sha256; import com.attendance.blockchain.common.TrustSDK; import com.attendance.blockchain.core.block.body.Place; import com.attendance.blockchain.core.block.db.DbBlockRead; import com.attendance.blockchain.core.block.service.BlockService; import com.attendance.entity.UserEntity; import com.attendance.service.exception.MsgException; import com.jfinal.aop.Aop; import com.jfinal.kit.StrKit; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Record; import cn.hutool.core.date.DateUtil; public class UserService { private BlockService blockService = Aop.get(BlockService.class); /** * 保存用户信息 * @Author: zhangwei * @Date: 2022年5月7日 下午3:00:49 */ public void saveUser(String userName, String password) { Record userRecord = Db.findById("USER", "USER_NAME", userName); if(userRecord != null) { throw new MsgException("该用户名已被注册！"); } PairKey pairKey = TrustSDK.generatePairKey(); UserEntity userEntity = new UserEntity(); userEntity.setUsername(userName).setPassword(password); userEntity.setPublicKey(pairKey.getPublicKey().toString()); userEntity.setPrivatekey(pairKey.getPrivateKey().toString()); userEntity.save(); } /** * 保存用户信息 * @Author: zhangwei * @Date: 2022年5月7日 下午3:00:49 */ public void login(String userName, String password) { Record userRecord = Db.findById("USER", "USER_NAME", userName); if(userRecord == null) { throw new MsgException("该用户名不存在！"); } String userPwd = userRecord.getStr("PASSWORD"); if(!userPwd.equals(password)) { throw new MsgException("密码错误！"); } } /** * 打卡 * @Author: zhangwei * @Date: 2022年5月7日 下午3:00:49 */ public void clockIn(String userName, String placeStr) { Record userRecord = Db.findById("USER", "USER_NAME", userName); if(userRecord == null) { throw new MsgException("该用户名不存在！"); } Place place = Place.toPlace(placeStr); Attendance attendance = new Attendance(); attendance.setTimeStamp(System.currentTimeMillis()); attendance.setPlace(place); attendance.setPublicKey(userRecord.getStr("PUBLIC_KEY")); String buildStr = attendance.getTimeStamp() + attendance.getPlace().toString() + attendance.getPublicKey().toString(); attendance.setSign(TrustSDK.signString(PrivateKey.create(userRecord.getStr("PRIVATE_KEY")), buildStr)); attendance.setHash(Sha256.digestHex(buildStr)); blockService.recordBody(attendance); } /** * 获取所有打卡信息 * * @Author: zhangwei * @Date: 2022年5月7日 下午3:00:49 */ public List<Record> getAllClockInData(String searchPublicKey) { DbBlockRead readDbBlock = blockService.getReadDbBlock(); List<Block> blockList = readDbBlock.getBlockAll(); List<Record> attendanceList = new ArrayList<Record>(); for(Block block : blockList) { if(block == null) continue; BlockBody blockBody = block.getBlockBody(); Collection<Attendance> bodyList = blockBody.getBodyList(); for(Attendance body : bodyList) { String publicKey = body.getPublicKey(); if(StrKit.notBlank(searchPublicKey) && StrKit.notBlank(publicKey) && !searchPublicKey.equals(publicKey)) { continue; } Record record = new Record().set("place", body.getPlace().getDescribe()); record.set("publicKey", publicKey).set("time", DateUtil.formatDateTime(DateUtil.date(body.getTimeStamp()))); record.set("contractBody", body.getContractBody()); Record userRecord = Db.findById("USER", "PUBLIC_KEY", publicKey); attendanceList.add(record.set("userName", userRecord.getStr("USER_NAME"))); } } return attendanceList; } /** * 获取所有打卡信息 * * @Author: zhangwei * @Date: 2022年5月7日 下午3:00:49 */ public List<UserEntity> getAllUserData() { return UserEntity.dao.findAll(); } }