update...

潘钊
1 parent e5c57de6
Showing 4 changed files with 307 additions and 0 deletions
src/main/java/com/bsth/server_ws/park_station/CompanyService.java
src/main/java/com/bsth/server_ws/park_station/CompanyServiceSoap.java
src/main/java/com/bsth/server_ws/park_station/dto/LsLcPb.java
src/main/java/com/bsth/server_ws/util/WSDataConver.java
@@ -71,4 +71,14 @@ public interface CompanyService {
             @WebParam(name = "company") String company,
             @WebParam(name = "resultArray", mode = WebParam.Mode.INOUT) javax.xml.ws.Holder<String[]> result,
             @WebParam(name = "fError", mode = WebParam.Mode.INOUT) javax.xml.ws.Holder<String> fError);
+
+    boolean getLSLC_PB(
+            @WebParam(name = "ip") String ip,
+            @WebParam(name = "userName") String userName,
+            @WebParam(name = "password") String password,
+            @WebParam(name = "month") String month,
+            @WebParam(name = "workId") String workId,
+            @WebParam(name = "company") String company,
+            @WebParam(name = "resultArray", mode = WebParam.Mode.INOUT) javax.xml.ws.Holder<String[]> result,
+            @WebParam(name = "fError", mode = WebParam.Mode.INOUT) javax.xml.ws.Holder<String> fError);
 }
 package com.bsth.server_ws.park_station;
  
+import com.bsth.entity.OilInfo;
 import com.bsth.entity.ScheduleRealInfo;
 import com.bsth.server_ws.util.Constants;
 import com.bsth.server_ws.util.ControlHttpUtils;
 import com.bsth.server_ws.util.WSDataConver;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
+import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Component;
  
 import javax.jws.WebMethod;
@@ -30,6 +34,9 @@ public class CompanyServiceSoap implements CompanyService {
  
     Logger logger = LoggerFactory.getLogger(this.getClass());
  
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
     @Override
     @WebMethod
     public boolean returnCCInfo(String password, String companyId, String rq, javax.xml.ws.Holder<String[]> result, javax.xml.ws.Holder<String> fError) {
@@ -106,4 +113,25 @@ public class CompanyServiceSoap implements CompanyService {
         }
         return false;
     }
+
+    @Override
+    public boolean getLSLC_PB(String ip, String userName, String password, String month, String workId, String company, Holder<String[]> result, Holder<String> fError) {
+        try{
+            //实际排班
+            List<ScheduleRealInfo> schList =
+            jdbcTemplate.query("select * from bsth_c_s_sp_info_real where gs_bm='"+company+"' and j_gh='"+workId+"' and schedule_date_str like '"+month+"-%'",
+                    BeanPropertyRowMapper.newInstance(ScheduleRealInfo.class));
+
+            //油耗
+            List<OilInfo> oilList =
+                    jdbcTemplate.query("select * from bsth_c_ylb where jsy='"+workId+"' and rq like '"+month+"-%'",
+                            BeanPropertyRowMapper.newInstance(OilInfo.class));
+
+            result.value = WSDataConver.to_getLSLC_PB(month, schList, oilList);
+        }catch(Exception e){
+            fError.value = e.getMessage();
+            logger.error("", e);
+        }
+        return false;
+    }
 }
+package com.bsth.server_ws.park_station.dto;
+
+/**
+ * 综合查询结果集（历时、路程、排班）
+ * Created by panzhao on 2018/1/17.
+ */
+public class LsLcPb {
+
+    /**
+     * 第几天
+     */
+    private int day;
+
+    /**
+     * 1：路程、2：排班、3：当天、4：休息
+     */
+    private int type;
+
+    //##### type 为 1 时 ####
+    /**
+     * 考勤 （出勤、病假）
+     */
+    private String lckq;
+
+    /**
+     * 用油
+     */
+    private Double lcyh;
+
+    /**
+     * 营运里程
+     */
+    private Double lcyylc;
+
+    /**
+     * 非营运里程
+     */
+    private Double lcfyylc;
+
+
+    //##### type 为 2 时 ####
+    /**
+     * 线路
+     */
+    private String pbxl;
+
+    /**
+     * 路牌
+     */
+    private String pblp;
+
+    /**
+     * 报到时间
+     */
+    private String pbbd;
+
+    /**
+     * 用车
+     */
+    private String pbyc;
+
+
+    public int getDay() {
+        return day;
+    }
+
+    public void setDay(int day) {
+        this.day = day;
+    }
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    public String getLckq() {
+        return lckq;
+    }
+
+    public void setLckq(String lckq) {
+        this.lckq = lckq;
+    }
+
+    public Double getLcyh() {
+        return lcyh;
+    }
+
+    public void setLcyh(Double lcyh) {
+        this.lcyh = lcyh;
+    }
+
+    public Double getLcyylc() {
+        return lcyylc;
+    }
+
+    public void setLcyylc(Double lcyylc) {
+        this.lcyylc = lcyylc;
+    }
+
+    public Double getLcfyylc() {
+        return lcfyylc;
+    }
+
+    public void setLcfyylc(Double lcfyylc) {
+        this.lcfyylc = lcfyylc;
+    }
+
+    public String getPbxl() {
+        return pbxl;
+    }
+
+    public void setPbxl(String pbxl) {
+        this.pbxl = pbxl;
+    }
+
+    public String getPblp() {
+        return pblp;
+    }
+
+    public void setPblp(String pblp) {
+        this.pblp = pblp;
+    }
+
+    public String getPbbd() {
+        return pbbd;
+    }
+
+    public void setPbbd(String pbbd) {
+        this.pbbd = pbbd;
+    }
+
+    public String getPbyc() {
+        return pbyc;
+    }
+
+    public void setPbyc(String pbyc) {
+        this.pbyc = pbyc;
+    }
+}
@@ -5,6 +5,7 @@ import com.bsth.entity.OilInfo;
 import com.bsth.entity.SchedulePlanInfo;
 import com.bsth.entity.ScheduleRealInfo;
 import com.bsth.server_ws.attendance.entity.Jsy_attendance;
+import com.bsth.server_ws.park_station.dto.LsLcPb;
 import com.bsth.server_ws.waybill.entity.*;
 import com.bsth.util.Arith;
 import com.bsth.util.ConvertUtil;
@@ -14,6 +15,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
  
 import java.lang.reflect.Field;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
  
 /**
@@ -610,6 +613,130 @@ public class WSDataConver {
         return null;
     }
  
+    /**
+     * 将排班和油耗转换成综合查询需要的数据
+     * @param schList
+     * @param oilList
+     * @return
+     */
+    public static String[] to_getLSLC_PB(String fdate, List<ScheduleRealInfo> schList, List<OilInfo> oilList) {
+        String[] array = new String[0];
+        try {
+            //按日期分组数据
+            ArrayListMultimap<String, ScheduleRealInfo> schMultimap =
+                new ConvertUtil().groupMultiList(schList, "_", ScheduleRealInfo.class.getDeclaredField("scheduleDateStr"));
+
+            ArrayListMultimap<String, OilInfo> oilMultimap =
+                    new ConvertUtil().groupMultiList(oilList, "_", OilInfo.class.getDeclaredField("rq"));
+
+            //月份有多少天
+            int year = Integer.parseInt(fdate.substring(0, 4));
+            int month = Integer.parseInt(fdate.substring(5, 7));
+            Calendar cal = Calendar.getInstance();
+            cal.set(Calendar.YEAR,year);
+            cal.set(Calendar.MONTH,month - 1);//从0开始
+            int maxDate = cal.getActualMaximum(Calendar.DATE);
+
+            List<LsLcPb> rs = new ArrayList<>();
+            LsLcPb lcPb;
+            List<ScheduleRealInfo> pbList;
+            List<OilInfo> yhList;
+            String rq,rq2;
+            ScheduleRealInfo outSch;
+            int currentDay = cal.get(Calendar.DAY_OF_MONTH);
+            for(int i = 1; i <= maxDate; i++){
+                lcPb = new LsLcPb();
+                rq = fdate + "-" + (i < 10?"0":"") + i;
+                rq2 = rq.replaceAll("-", "");
+
+                pbList = schMultimap.get(rq);
+                yhList = oilMultimap.get(rq2);
+
+                if(pbList == null || pbList.size() == 0)
+                    lcPb.setType(4);//休息
+                else if(i < currentDay){
+                    lcPb.setType(1);
+                    lcPb.setLckq("");
+                    if(yhList != null && yhList.size() > 0){
+                        lcPb.setLcyh(yhList.get(0).getYh());
+                    }
+                    lcPb.setLcyylc(ScheduleCalculator.calcYYLC(pbList));
+                    lcPb.setLcfyylc(ScheduleCalculator.calcKSLC(pbList));
+                }
+                else if (i == currentDay)
+                    lcPb.setType(3);//今天
+                else {
+                    lcPb.setType(2);
+                    outSch = getOutSch(pbList);
+                    if(null != outSch){
+                        lcPb.setPbxl(outSch.getXlName());
+                        lcPb.setPblp(outSch.getLpName());
+                        lcPb.setPbbd(minusMinute(outSch.getDfsj(), 15));
+                        lcPb.setPbyc(outSch.getClZbh());
+                    }
+                }
+
+                rs.add(lcPb);
+            }
+
+            //拼接成字符串数组
+            array = new String[rs.size()];
+            StringBuilder sb;
+            for(int i = 0,len=rs.size(); i < len; i++){
+                lcPb = rs.get(i);
+                sb = new StringBuilder();
+
+                sb.append(lcPb.getType());
+
+                switch (lcPb.getType()){
+                    case 1:
+                        sb.append("," + lcPb.getLckq());
+                        sb.append("," + lcPb.getLcyh());
+                        sb.append("," + lcPb.getLcyylc());
+                        sb.append("," + lcPb.getLcfyylc());
+                        break;
+                    case 2:
+                        sb.append("," + lcPb.getPbxl());
+                        sb.append("," + lcPb.getPblp());
+                        sb.append("," + lcPb.getPbbd());
+                        sb.append("," + lcPb.getPbyc());
+                        break;
+                }
+                array[i] = sb.toString();
+            }
+        } catch (NoSuchFieldException e) {
+            logger.error("", e);
+        }
+        return array;
+    }
+
+    /**
+     * HH:mm 格式时间减分钟
+     * @param dfsj
+     * @param i
+     * @return
+     */
+    private static String minusMinute(String hhmm, int i) {
+        try {
+            SimpleDateFormat sdf = new SimpleDateFormat("HH:mm");
+            long t = sdf.parse(hhmm).getTime();
+
+            return sdf.format(new Date(t - (i * 60 * 1000)));
+        } catch (ParseException e) {
+            logger.error("", e);
+        }
+        return null;
+    }
+
+    private static ScheduleRealInfo getOutSch(List<ScheduleRealInfo> pbList) {
+
+        for(ScheduleRealInfo sch : pbList){
+            if(sch.getBcType().equals("out"))
+                return sch;
+        }
+        return null;
+    }
+
     public static class OilComp implements Comparator<OilInfo> {
  
         @Override