大客流临加记录

yiming
1 parent 40b60b30
Showing 5 changed files with 118 additions and 2 deletions
src/main/java/com/bsth/data/zndd/OutEntrance.java
src/main/java/com/bsth/entity/realcontrol/ScheduleRealInfo.java
src/main/java/com/bsth/entity/zndd/LoggerZndd.java
src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
src/main/resources/static/real_control_v2/zndd/type/dkl.html
@@ -17,7 +17,13 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.web.bind.annotation.*;
+import java.io.*;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.nio.file.StandardCopyOption;
  
 import java.io.ByteArrayInputStream;
 import java.io.File;
@@ -262,7 +268,7 @@ public class OutEntrance {
             rtn.put("status",ResponseCode.SUCCESS);
         } catch (Exception e) {
             rtn.put("status", ResponseCode.ERROR);
-            Logger logger = LoggerFactory.getLogger(this.getClass());
+            logger.error("大客流推送异常----",e);
         }
         return rtn;
     }
@@ -308,7 +314,7 @@ public class OutEntrance {
                     destfile.mkdirs();
                 }
                 //文件新名称
-                String fileNameNew = "666"+ ".png";
+                String fileNameNew = AutomaticSch.UUID()+ ".png";
                 File f = new File(destfile.getAbsoluteFile() + File.separator + fileNameNew);
                 // 将字符串转换成二进制，用于显示图片
                 // 将上面生成的图片格式字符串 imgStr，还原成图片显示
@@ -334,6 +340,30 @@ public class OutEntrance {
         return null;
     }
  
+    /**
+     * 转移文件图片
+     * @param  url 文件路径
+     * @param  （示例：D:\\1.png）
+     * @return
+     */
+    public String moveImg(String url) throws Exception {
+        try {
+            String file = url.replace("/"+profile+"/avat",imgurl+"/img");
+            String destDir = file.substring(0,file.lastIndexOf("/"));
+            File destPath = new File(destDir);
+            if (!destPath.exists()) {
+                destPath.mkdirs();
+            }
+            Path sourceFile= Paths.get(url.replace("/"+profile,imgurl));
+            Path destFile= Paths.get(url.replace("/"+profile+"/avat",imgurl+"/img"));
+            Files.copy(sourceFile, destFile,StandardCopyOption.REPLACE_EXISTING);
+            return file;
+        } catch (IOException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
     private static ConcurrentMap<String, Map<String,Object>> trafficMap = new ConcurrentHashMap<>();
     public String getTraffic(String nbbm,String lon,String lat){
         Map<String,Object> traffic=trafficMap.get(nbbm);
@@ -359,5 +389,26 @@ public class OutEntrance {
         return traffic.get("trafficStatus").toString();
     }
  
+    @Scheduled(cron = "0 0 0 * * ?")
+    public void clearImg(){
+        try {
+            File folder=new File(imgurl+"/avat");
+            delete(folder);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void delete(File folder) throws Exception{
+        if(folder.isDirectory()) {
+            File[] files = folder.listFiles();
+            if(files != null) { // 如果文件夹为空，files可能为null
+                for(File file : files) {
+                    delete(file); // 递归删除子文件夹和文件
+                }
+            }
+        }
+        folder.delete(); // 删除空文件夹或者文件
+    }
  
 }
@@ -245,6 +245,18 @@ public class ScheduleRealInfo {
 	@Transient
 	private String kxcl;
  
+	/**
+	 * 大客流图片
+	 */
+	@Transient
+	private String img;
+
+	/**
+	 * 操作类型 大客流-1
+	 */
+	@Transient
+	private String operationType;
+
 	public Integer getLpChange() {
 		return lpChange;
 	}
@@ -1026,4 +1038,20 @@ public class ScheduleRealInfo {
 	public void setKxcl(String kxcl) {
 		this.kxcl = kxcl;
 	}
+
+	public String getImg() {
+		return img;
+	}
+
+	public void setImg(String img) {
+		this.img = img;
+	}
+
+	public String getOperationType() {
+		return operationType;
+	}
+
+	public void setOperationType(String operationType) {
+		this.operationType = operationType;
+	}
 }
@@ -32,6 +32,8 @@ public class LoggerZndd implements Serializable {
  
     private String dir;
  
+    private String img;
+
     // 创建日期
     @Column(updatable = false, name = "create_date", columnDefinition = "TIMESTAMP DEFAULT CURRENT_TIMESTAMP")
     private Date createDate;
@@ -107,4 +109,12 @@ public class LoggerZndd implements Serializable {
     public void setDir(String dir) {
         this.dir = dir;
     }
+
+    public String getImg() {
+        return img;
+    }
+
+    public void setImg(String img) {
+        this.img = img;
+    }
 }
@@ -11,6 +11,7 @@ import java.sql.SQLException;
 import java.text.DecimalFormat;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Collection;
@@ -29,6 +30,7 @@ import java.util.concurrent.*;
 import java.util.regex.Pattern;
  
 import com.bsth.data.SystemParamCache;
+import com.bsth.data.zndd.OutEntrance;
 import com.bsth.entity.zndd.LoggerZndd;
 import com.bsth.repository.zndd.LoggerZnddRepository;
 import org.apache.commons.io.IOUtils;
@@ -228,6 +230,9 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
     @Autowired
     LoggerZnddRepository loggerZnddRepository;
  
+    @Autowired
+    OutEntrance outEntrance;
+
     Logger logger = LoggerFactory.getLogger(this.getClass());
  
     SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd"),
@@ -728,6 +733,26 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
     public Map<String, Object> save(ScheduleRealInfo sch) {
         Map<String, Object> rs = new HashMap<>();
         try {
+            if("1".equals(sch.getOperationType())){//大客流临加班次
+                String img = outEntrance.moveImg(sch.getImg());
+                if(img==null){
+                    rs.put("status", ResponseCode.ERROR);
+                    rs.put("msg", "照片缺失");
+                    return rs;
+                }
+                LoggerZndd lz = addZndd(sch);
+                String text = "大客流预警:"+sch.getXlName()+"_"+sch.getFcsj()+"新增临加班次";
+                lz.setText(text);
+                lz.setCreateBy(SecurityUtils.getCurrentUser().getId());
+                lz.setCreateDate(new Date());
+                lz.setLineCode(sch.getXlBm());
+                lz.setLineName(sch.getXlName());
+                lz.setDir(sch.getXlDir());
+                lz.setImg(img);
+                String rq=java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd").format(LocalDate.now());
+                lz.setRq(rq);
+                loggerZnddRepository.save(lz);
+            }
             String clZbh = sch.getClZbh(), lpName = sch.getLpName();
             if (StringUtils.isEmpty(lpName) || StringUtils.isEmpty(lpName.trim())) {
                 rs.put("status", ResponseCode.ERROR);
@@ -427,6 +427,8 @@
                     data.fgsBm = line.brancheCompany;
                 }
  
+                data.img=sch.image;
+                data.operationType=1;
                 gb_common.$post('/realSchedule', data, function (rs) {
                     notify_succ('新增临加班次成功');
                     cb && cb(rs);