为换人换车情况表写入数据...

潘钊
1 parent 9b76e9a7
Showing 3 changed files with 121 additions and 13 deletions
src/main/java/com/bsth/data/schedule/SchModifyLog.java
src/main/java/com/bsth/repository/form/ChangetochangeRepository.java
src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
+package com.bsth.data.schedule;
+
+import com.bsth.controller.realcontrol.dto.ChangePersonCar;
+import com.bsth.entity.mcy_forms.Changetochange;
+import com.bsth.entity.realcontrol.ScheduleRealInfo;
+import com.bsth.entity.sys.SysUser;
+import com.bsth.repository.form.ChangetochangeRepository;
+import com.bsth.security.util.SecurityUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+
+/**
+ * 线调实际排班修改日志记录
+ * Created by panzhao on 2017/5/7.
+ */
+@Service
+public class SchModifyLog {
+
+    private static DateTimeFormatter fmtHHmm = DateTimeFormat.forPattern("HH:mm");
+
+    Logger log = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    ChangetochangeRepository changetochangeRepository;
+
+    /**
+     * 换人换车情况表
+     */
+    public void saveChangetochange(ScheduleRealInfo sch, ChangePersonCar cpc){
+        try {
+            String newNbbm = cpc.getClZbh();
+            String newJsy = cpc.getJsy();
+            String oldJsy = sch.getjGh()+"/"+sch.getjName();
+
+            if(newNbbm == null && newJsy == null)
+                return;
+
+            if(newNbbm != null && newJsy != null
+                    && newNbbm.equals(sch.getClZbh()) && newJsy.equals(oldJsy))
+                return;
+
+            Date d = new Date();
+            SysUser user = SecurityUtils.getCurrentUser();
+            Changetochange cc = new Changetochange();
+            cc.setRq(sch.getScheduleDateStr());
+            cc.setGs(sch.getGsBm());
+            cc.setFgs(sch.getFgsBm());
+            cc.setXl(sch.getXlBm());
+            cc.setLp(sch.getLpName());
+            cc.setFssj(fmtHHmm.print(d.getTime()));
+            cc.setXgsj(fmtHHmm.print(d.getTime()));
+            if(user != null)
+                cc.setXgr(user.getUserName());
+
+            cc.setPcch(sch.getClZbh());
+            cc.setPcry(oldJsy);
+            cc.setJhch(sch.getClZbh());
+            cc.setJhgh(sch.getjGh());
+
+            if(StringUtils.isNotEmpty(newNbbm))
+                cc.setSjch(newNbbm);
+            if(StringUtils.isNotEmpty(newJsy))
+                cc.setSjgh(newJsy);
+
+            changetochangeRepository.save(cc);
+        }catch (Exception e){
+            log.error("纪录换人换车情况表", e);
+        }
+    }
+
+    public void saveChangetochange(ScheduleRealInfo sch, String nbbm, String jsy){
+        ChangePersonCar cpc = new ChangePersonCar();
+        cpc.setClZbh(nbbm);
+        cpc.setJsy(jsy);
+        saveChangetochange(sch, cpc);
+    }
+}
+package com.bsth.repository.form;
+
+import com.bsth.entity.mcy_forms.Changetochange;
+import com.bsth.repository.BaseRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * Created by panzhao on 2017/5/7.
+ */
+@Repository
+public interface ChangetochangeRepository extends BaseRepository<Changetochange, Integer>{
+}
@@ -12,6 +12,7 @@ import com.bsth.data.BasicData;
 import com.bsth.data.LineConfigData;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.SchAttrCalculator;
+import com.bsth.data.schedule.SchModifyLog;
 import com.bsth.data.schedule.ScheduleComparator;
 import com.bsth.data.schedule.late_adjust.LateAdjustHandle;
 import com.bsth.entity.Cars;
@@ -52,7 +53,6 @@ import com.google.common.base.Splitter;
 import com.google.common.collect.Lists;
 import org.apache.commons.lang3.StringEscapeUtils;
 import org.apache.commons.lang3.StringUtils;
-import org.drools.compiler.lang.dsl.DSLMapParser.statement_return;
 import org.joda.time.format.DateTimeFormat;
 import org.joda.time.format.DateTimeFormatter;
 import org.slf4j.Logger;
@@ -132,6 +132,9 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
     @Autowired
     CulateMileageService culateService;
  
+    @Autowired
+    SchModifyLog schModifyLog;
+
     Logger logger = LoggerFactory.getLogger(this.getClass());
  
     SimpleDateFormat sdfMonth = new SimpleDateFormat("yyyy-MM-dd"),
@@ -1171,10 +1174,14 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                 return rs;
             }
  
+            String clZbh = map.get("clZbh");
+            String jsy = map.get("jsy");
+            if(!clZbh.equals(sch.getClZbh())
+                    || !jsy.equals(sch.getjGh() + "/" + sch.getjName()))
+                schModifyLog.saveChangetochange(sch, clZbh, jsy);//为换人换车情况表写入数据
             /**
              * 换车
              */
-            String clZbh = map.get("clZbh");
             if (StringUtils.isNotEmpty(clZbh)) {
                 //换车
                 if (!carExist(sch.getGsBm(), clZbh)) {
@@ -1189,7 +1196,6 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
             /**
              * 换驾驶员
              */
-            String jsy = map.get("jsy");
             if (StringUtils.isNotEmpty(jsy) && jsy.indexOf("/") != -1) {
                 String jGh = jsy.split("/")[0];
                 String jName = getPersonName(sch.getGsBm(), jGh);
@@ -1978,11 +1984,11 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
         int dtbcZ = 0, dtbc_mZ = 0, dtbc_aZ = 0;
         int djgZ = 0, djg_mZ = 0, djg_aZ = 0, djg_timeZ = 0;
         Map<String, Object> map = null;
-        
+
         double xgssgl=0,xgljgl=0,lj=0,cj=0;
         for (int i = 0; i < list.size(); i++) {
             ScheduleRealInfo scheduleRealInfo = list.get(i);
-           
+
             if (scheduleRealInfo != null) {
                 Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
                 //计算实际里程，少驶里程，计划里程=实际里程+少驶里程
@@ -1993,7 +1999,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                 if (childTaskPlans.isEmpty()) {
                     tempJhlc = scheduleRealInfo.getJhlc() == null ? 0 : scheduleRealInfo.getJhlc();
                     jhlcOrig = scheduleRealInfo.getJhlcOrig() == null ? 0 : scheduleRealInfo.getJhlcOrig();
-                    
+
                     if(jhlcOrig-tempJhlc>0){
                     	xgssgl +=jhlcOrig-tempJhlc;
                     	cj += jhlcOrig-tempJhlc;
@@ -2005,8 +2011,8 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                     if (scheduleRealInfo.isSflj()) {
                         ljgl += tempJhlc;
                         ljglZ += tempJhlc;
-                    } 
-                    
+                    }
+
                     if (scheduleRealInfo.getStatus() == -1) {
                         ssgl += tempJhlc;
                         ssglZ += tempJhlc;
@@ -2771,7 +2777,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 		for(ScheduleRealInfo info:listInfo){
 			for(ScheduleRealInfo total:listTotal){
 				if(info.getjGh().equals(total.getjGh()) && info.getLpName().equals(total.getLpName()) && info.getClZbh().equals(total.getClZbh())){
-					
+
 				}
 			}
 		}*/
@@ -2867,7 +2873,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 		for(ScheduleRealInfo info:listInfo){
 			for(ScheduleRealInfo total:listTotal){
 				if(info.getjGh().equals(total.getjGh()) && info.getLpName().equals(total.getLpName()) && info.getClZbh().equals(total.getClZbh())){
-					
+
 				}
 			}
 		}*/
@@ -2944,7 +2950,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 	                    fage = false;
 	                }
 	                listS.add(scheduleRealInfo);
-	                
+
 	               /* if (scheduleRealInfo != null) {
 	                    //计划里程（主任务过滤掉临加班次），
 	                    //烂班里程（主任务烂班），
@@ -2960,7 +2966,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
 	                                || scheduleRealInfo.getBcType().equals("out"))) {
 	                            jhlc =Arith.add(jhlc,tempJhlc);
 	                        }
-	
+
 	                        if (scheduleRealInfo.getStatus() == -1) {
 	                            remMileage =Arith.add(remMileage,tempJhlc);
 	                        }
@@ -3046,7 +3052,7 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
         ScheduleRealInfo sch;
         //BiMap<String, String> map = BasicData.deviceId2NbbmMap.inverse();
  
-        String jGh,jName,sGh,sName;
+        String jGh = null,jName,sGh,sName;
         for (ChangePersonCar cpc : cpcs) {
  
             sch = dayOfSchedule.get(cpc.getSchId());
@@ -3067,6 +3073,12 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
                     rs.put("status", ResponseCode.ERROR);
                     return rs;
                 }
+            }
+
+            //为换人换车情况表写入数据
+            schModifyLog.saveChangetochange(sch, cpc);
+
+            if (StringUtils.isNotEmpty(cpc.getJsy())) {
                 //换驾驶员
                 persoChange(sch, jGh);
                 set.add(sch);