From a9862e81851bbe037edc6bb1c7f562c1e55c0d7f Mon Sep 17 00:00:00 2001 From: kongdeqiang <123456> Date: 星期一, 19 九月 2022 18:44:18 +0800 Subject: [PATCH] 增加日志和redis --- src/main/java/com/boying/controller/car/PlateServlet2.java | 51 +++++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 43 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/boying/controller/car/PlateServlet2.java b/src/main/java/com/boying/controller/car/PlateServlet2.java index 8fd430c..aa197ed 100755 --- a/src/main/java/com/boying/controller/car/PlateServlet2.java +++ b/src/main/java/com/boying/controller/car/PlateServlet2.java @@ -5,10 +5,7 @@ import com.boying.common.SystemConfigProperties; import com.boying.common.util.DateUtil; import com.boying.common.util.StringUtil; -import com.boying.entity.Barrier; -import com.boying.entity.EnterPark; -import com.boying.entity.OutPark; -import com.boying.entity.Ticket; +import com.boying.entity.*; import com.boying.service.*; import com.google.gson.JsonIOException; import com.google.gson.JsonObject; @@ -16,6 +13,7 @@ import com.google.gson.JsonSyntaxException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.jpa.domain.Specification; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; @@ -33,6 +31,7 @@ import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; +import java.util.concurrent.TimeUnit; import static com.boying.common.util.DateUtil.getMinute; @@ -45,6 +44,10 @@ private static final long serialVersionUID = 1L; @Autowired private SystemConfigProperties systemConfigProperties; + @Autowired + private StringRedisTemplate redisTemplate; + @Autowired + private ParkService parkService; /** * 鍥炲寮�闂� @@ -112,6 +115,7 @@ @PostMapping("/PlateServlet") protected void info(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { String s= ""; + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd-HH:mm:ss"); BufferedReader reader = new BufferedReader(new InputStreamReader(request.getInputStream(),"UTF-8")); String str = ""; String lineStr = ""; @@ -162,7 +166,8 @@ } System.out.println("缂栧彿锛�"+serialno+"璁惧璇嗗埆鍒颁簡锛�"+license); - s+="杞︾墝鍙蜂负锛�"+license+",serialno涓猴細"+code+"\n"; + String format = sdf.format(new Date()); + s+= format+",杞︾墝鍙蜂负锛�"+license+",serialno涓猴細"+code+"銆� "; Barrier barrier = barrierService.findByCode(code); if(barrier==null){ @@ -170,11 +175,11 @@ }else{ if(barrier.getType()==0){ outPark(license, barrier.getId(), barrier.getParkId()); - s+=license+"淇濆瓨鍑哄満璁板綍\n"; + s+=license+"-淇濆瓨鍑哄満璁板綍\n"; }else{ open(request, response);//鎶潌 enterPark(license,barrier.getId(),barrier.getParkId()); - s+=license+"淇濆瓨鍏ュ満璁板綍\n"; + s+=license+"-淇濆瓨鍏ュ満璁板綍\n"; } } writeTxt(s); @@ -182,14 +187,20 @@ } catch (JsonIOException e) { + System.out.println("鏃犲叆鍦鸿褰�"); + s+=" ,鏌ヨ鍦哄唴璁板綍寮傚父"; e.printStackTrace(); writeTxt(s); } catch (JsonSyntaxException e) { + System.out.println("鏃犲叆鍦鸿褰�"); + s+=" ,鏌ヨ鍦哄唴璁板綍寮傚父"; e.printStackTrace(); writeTxt(s); } catch (Exception e) { + System.out.println("鏃犲叆鍦鸿褰�"); + s+=" ,鏌ヨ鍦哄唴璁板綍寮傚父"; writeTxt(s); } } @@ -225,7 +236,20 @@ private CostRuleService costRuleService; public void enterPark(String carNo,Long barrierId,Long parkId) { - + Park park = (Park)parkService.findById(parkId); + int num = 0; + String s = redisTemplate.opsForValue().get("car_park_" + parkId); + if(park != null){ + num = park.getNum(); + if(s !=null){ + if(Integer.parseInt(s) > num){ + return; + } + }else { + s= "0"; + redisTemplate.opsForValue().set("car_park_" + parkId,s,30, TimeUnit.DAYS); + } + } enterParkService.deleteByCarNo(carNo,parkId); EnterPark enterPark = new EnterPark(); enterPark.setCreateTime(new Date()); @@ -249,6 +273,9 @@ enterPark.setStatus(1);//鍙戠幇鏈夎繚绔� } enterParkService.save(enterPark); + int i = Integer.parseInt(s); + i++; + redisTemplate.opsForValue().set("car_park_" + parkId,Integer.toString(i),30, TimeUnit.DAYS); Barrier barrier = (Barrier) barrierService.findById(barrierId); barrier.setType2(1); @@ -269,6 +296,7 @@ }else{ outPark.setEnterTime(enterPark.getCreateTime()); } + String redis = redisTemplate.opsForValue().get("car_park_" + parkId); long l = outPark.getCreateTime().getTime() - enterPark.getCreateTime().getTime(); outPark.setTime(l/(1000*60)); double money = 0; @@ -281,6 +309,13 @@ outPark.setStatus3(findTicket(carNo)); outParkService.save(outPark); + int i = Integer.parseInt(redis); + i--; + if(i<0){ + redisTemplate.opsForValue().set("car_park_" + parkId,"0",30, TimeUnit.DAYS); + }else { + redisTemplate.opsForValue().set("car_park_" + parkId,Integer.toString(i),30, TimeUnit.DAYS); + } Barrier barrier = (Barrier) barrierService.findById(barrierId); barrier.setCarNo(carNo); -- Gitblit v1.9.1