update...

潘钊
1 parent c519a399
Showing 9 changed files with 464 additions and 14 deletions
src/main/java/com/bsth/CXFConfig.java
src/main/java/com/bsth/common/BusinessCodeData.java
src/main/java/com/bsth/server_ws/electric_oil/OilService.java
src/main/java/com/bsth/server_ws/electric_oil/OilServiceSoap.java
src/main/java/com/bsth/server_ws/electric_oil/db/ElectricMultSaveUtil.java
src/main/java/com/bsth/server_ws/electric_oil/entity/ClsCDL.java
src/main/java/com/bsth/server_ws/electric_oil/entity/Electric.java
src/main/java/com/bsth/server_ws/park_station/CompanyServiceSoap.java
src/main/resources/application.properties
@@ -41,9 +41,16 @@ public class CXFConfig {
         return new SpringBus();
     }
  
+    @Autowired
+    CompanyServiceSoap companyServiceSoap;
+    @Autowired
+    LD_ServiceSoap ld_serviceSoap;
+    @Autowired
+    AttendanceServiceSoap attendanceServiceSoap;
+
     @Bean
     public Endpoint companyEndpoint() {
-        EndpointImpl endpoint = new EndpointImpl(springBus(), new CompanyServiceSoap());
+        EndpointImpl endpoint = new EndpointImpl(springBus(), companyServiceSoap);
         endpoint.publish("/CompanyService");
         //endpoint.getInInterceptors().add(new AuthInterceptor());
         return endpoint;
@@ -51,7 +58,7 @@ public class CXFConfig {
  
     @Bean
     public Endpoint ldServiceEndpoint() {
-        EndpointImpl endpoint = new EndpointImpl(springBus(), new LD_ServiceSoap());
+        EndpointImpl endpoint = new EndpointImpl(springBus(), ld_serviceSoap);
         endpoint.publish("/LD_Service");
         //endpoint.getInInterceptors().add(new AuthInterceptor());
         return endpoint;
@@ -59,21 +66,12 @@ public class CXFConfig {
  
     @Bean
     public Endpoint attendanceServiceEndpoint() {
-        EndpointImpl endpoint = new EndpointImpl(springBus(), new AttendanceServiceSoap());
+        EndpointImpl endpoint = new EndpointImpl(springBus(), attendanceServiceSoap);
         endpoint.publish("/attendanceService");
         //endpoint.getInInterceptors().add(new AuthInterceptor());
         return endpoint;
     }
  
-
-/*    @Bean
-    public Endpoint LineServiceEndpoint(){
-        EndpointImpl endpoint = new EndpointImpl(springBus(), lineService());
-        endpoint.publish("/data_line");
-        //endpoint.getInInterceptors().add(new AuthInterceptor());
-        return endpoint;
-    }*/
-
     @Autowired
     ScheduleRealService scheduleRealService;
     @Autowired
+package com.bsth.common;
+
+import com.alibaba.fastjson.JSONObject;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
+
+/**
+ * 公司编码数据
+ * Created by panzhao on 2017/10/10.
+ */
+@Component
+public class BusinessCodeData {
+
+    private static String str = "{\"22\": {\"name\": \"金高公司\",\"fgs\": {\"1\": \"四分公司\",\"2\": \"二分公司\",\"3\": \"三分公司\",\"5\": \"一分公司\"}},\"26\": {\"name\": \"南汇公司\",\"fgs\": {\"1\": \"南汇一分\",\"2\": \"南汇二分\",\"3\": \"南汇三分\",\"4\": \"南汇维修公司\",\"5\": \"南汇公司\"}},\"55\": {\"name\": \"上南公司\",\"fgs\": {\"1\": \"上南二分公司\",\"2\": \"上南三分公司\",\"3\": \"上南六分公司\",\"4\": \"上南一分公司\"}},\"05\": {\"name\": \"杨高公司\",\"fgs\": {\"1\": \"川沙分公司\",\"2\": \"金桥分公司\",\"3\": \"芦潮港分公司\",\"5\": \"杨高分公司\",\"6\": \"周浦分公司\"}},\"24\":{\"name\": \"嘉定公交\",\"fgs\": {\"1\": \"一车队\",\"2\": \"二车队\",\"3\": \"三车队\"}},\"77\": {\"name\":  \"闵行公司\",\"fgs\": {\"78\": \"闵行公司\"}},\"99\": {\"name\": \"青浦公交\",\"fgs\": {\"100\": \"青浦公交\"}}}";
+    static JSONObject data;
+
+    /**
+     * 编码和名称对照表
+     */
+    public static Map<String, String> code2Name;
+
+    static{
+        data = JSONObject.parseObject(str);
+        code2Name = new HashMap<>();
+
+        Set<String> ks = data.keySet(), fgsKs;
+        JSONObject subObj, fgsObj;
+        for(String k : ks){
+            subObj = JSONObject.parseObject(data.getString(k));
+            code2Name.put(k, subObj.getString("name"));
+
+            //fgs
+            fgsObj = JSONObject.parseObject(subObj.getString("fgs"));
+            fgsKs = fgsObj.keySet();
+            for(String k2 : fgsKs){
+                code2Name.put(k + "_" + k2, fgsObj.getString(k2));
+            }
+        }
+    }
+}
+package com.bsth.server_ws.electric_oil;
+
+import com.bsth.server_ws.electric_oil.entity.ClsCDL;
+
+import javax.jws.WebService;
+import java.util.List;
+
+/**
+ * Created by panzhao on 2017/10/10.
+ */
+@WebService(
+        name = "OilServiceSoap",
+        targetNamespace = "http://control.bsth.com/")
+public interface OilService {
+
+    /**
+     *
+     * @param fCheckBM 接口验证码为：BSTH@BSTH#BSTH 延续老接口密码
+     * @param fStationID 停车场ID
+     * @param fKWHInfoArr 冲电量信息
+     * @return
+     */
+    String upLoadKWHInfo(String fCheckBM, String fStationID, List<ClsCDL> fKWHInfoArr);
+}
+package com.bsth.server_ws.electric_oil;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.server_ws.electric_oil.db.ElectricMultSaveUtil;
+import com.bsth.server_ws.electric_oil.entity.ClsCDL;
+import com.bsth.server_ws.electric_oil.entity.Electric;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.jws.WebService;
+import java.util.List;
+
+/**
+ * Created by panzhao on 2017/10/10.
+ */
+@Component
+@WebService(
+        name = "OilServiceSoap",
+        portName = "OilServiceSoap",
+        serviceName = "OilService",
+        targetNamespace = "http://control.bsth.com/",
+        endpointInterface = "com.bsth.server_ws.electric_oil.OilService")
+public class OilServiceSoap implements OilService {
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    @Autowired
+    ElectricMultSaveUtil electricMultSaveUtil;
+
+    @Override
+    public String upLoadKWHInfo(String fCheckBM, String fStationID, List<ClsCDL> fKWHInfoArr) {
+        try{
+            logger.info("上传电量数据, id: " + fStationID + " data [" + JSON.toJSONString(fKWHInfoArr) + "]");
+        }catch (Exception e){
+            logger.error("", e);
+        }
+        //入库
+        try {
+            List<Electric> list = Electric.getMultInstance(fKWHInfoArr, fStationID);
+            electricMultSaveUtil.multSave(list);
+        }catch (Exception e){
+            logger.error("", e);
+            return "上传失败，server 端出现异常！";
+        }
+        return null;
+    }
+}
+package com.bsth.server_ws.electric_oil.db;
+
+import com.bsth.server_ws.electric_oil.entity.Electric;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.TransactionDefinition;
+import org.springframework.transaction.TransactionStatus;
+import org.springframework.transaction.support.DefaultTransactionDefinition;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+
+/**
+ * 电量信息批量入库
+ * Created by panzhao on 2017/10/10.
+ */
+@Component
+public class ElectricMultSaveUtil {
+
+    @Autowired
+    JdbcTemplate jdbcTemplate;
+
+    Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    public void multSave(final List<Electric> list) {
+        //编程式事务
+        DataSourceTransactionManager tran = new DataSourceTransactionManager(jdbcTemplate.getDataSource());
+        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
+        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
+        TransactionStatus status = tran.getTransaction(def);
+
+        try {
+            jdbcTemplate.batchUpdate("insert into bsth_c_jdl(fgs_bm, fgs_name, gs_bm, gs_name, jdl, jdz, remarks, rq, creater_date, nbbm) VALUES(?,?,?,?,?,?,?,?,?,?)", new BatchPreparedStatementSetter() {
+                @Override
+                public void setValues(PreparedStatement ps, int i) throws SQLException {
+                    Electric e = list.get(i);
+                    ps.setString(1, e.getFgsBm());
+                    ps.setString(2, e.getFgsName());
+                    ps.setString(3, e.getGsBm());
+                    ps.setString(4, e.getGsName());
+                    ps.setDouble(5, e.getJdl());
+                    ps.setString(6, e.getJdz());
+                    ps.setString(7, e.getRemarks());
+                    ps.setDate(8, new java.sql.Date(e.getRq().getTime()));
+                    ps.setDate(9, new java.sql.Date(e.getCreateDate().getTime()));
+                    ps.setString(10, e.getNbbm());
+                }
+
+                @Override
+                public int getBatchSize() {
+                    return list.size();
+                }
+            });
+
+            tran.commit(status);
+        } catch (Exception e) {
+            logger.error("", e);
+            tran.rollback(status);
+        }
+    }
+}
+package com.bsth.server_ws.electric_oil.entity;
+
+/**
+ *
+ * Created by panzhao on 2017/10/10.
+ */
+public class ClsCDL {
+
+    /**
+     * 营运日期
+     * YYYY-MM-DD
+     */
+    private String yyrq;
+
+    /**
+     * 记录生成日期
+     * YYYY-MM-DD HH24:MI:SS
+     */
+    private String createRq;
+
+    /**
+     * 车辆自编号
+     */
+    private String nbbm;
+
+    /**
+     * 驾驶员工号
+     */
+    private String jsyGh;
+
+    /**
+     * 充电量
+     */
+    private String cdl;
+
+    public String getYyrq() {
+        return yyrq;
+    }
+
+    public void setYyrq(String yyrq) {
+        this.yyrq = yyrq;
+    }
+
+    public String getCreateRq() {
+        return createRq;
+    }
+
+    public void setCreateRq(String createRq) {
+        this.createRq = createRq;
+    }
+
+    public String getNbbm() {
+        return nbbm;
+    }
+
+    public void setNbbm(String nbbm) {
+        this.nbbm = nbbm;
+    }
+
+    public String getJsyGh() {
+        return jsyGh;
+    }
+
+    public void setJsyGh(String jsyGh) {
+        this.jsyGh = jsyGh;
+    }
+
+    public String getCdl() {
+        return cdl;
+    }
+
+    public void setCdl(String cdl) {
+        this.cdl = cdl;
+    }
+}
+package com.bsth.server_ws.electric_oil.entity;
+
+import com.alibaba.fastjson.JSON;
+import com.bsth.common.BusinessCodeData;
+import com.bsth.server_rs.base_info.car.Car;
+import com.bsth.server_rs.base_info.car.buffer.CarBufferData;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 调度系统加电量表
+ * bsth_c_jdl
+ * Created by panzhao on 2017/10/10.
+ */
+public class Electric {
+
+    private Electric(){}
+
+    static DateTimeFormatter fmtyyyyMMddHHmmss = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
+    static DateTimeFormatter fmtyyyyMMdd = DateTimeFormat.forPattern("yyyy-MM-dd");
+
+    static Logger logger = LoggerFactory.getLogger(Electric.class);
+
+    public static List<Electric> getMultInstance(List<ClsCDL> list, String stationId){
+        List<Electric> rs = new ArrayList<>();
+
+        Electric e;
+        for(ClsCDL c : list){
+            e = getInstance(c);
+            if(null != e){
+                e.setJdz(stationId);
+                rs.add(e);
+            }
+        }
+        return rs;
+    }
+
+    private static Electric getInstance(ClsCDL clsCDL){
+        String nbbm = clsCDL.getNbbm();
+        if(null == nbbm)
+            return null;
+
+        try{
+            Car car = CarBufferData.findOne(clsCDL.getNbbm());
+
+            Electric e = new Electric();
+            e.setGsBm(car.getCompanyCode());
+            e.setGsName(BusinessCodeData.code2Name.get(e.getGsBm()));
+            e.setFgsBm(car.getBrancheCompanyCode());
+            e.setFgsName(BusinessCodeData.code2Name.get(e.getFgsBm()));
+            e.setRq(fmtyyyyMMdd.parseDateTime(clsCDL.getYyrq()).toDate());
+            e.setCreateDate(fmtyyyyMMddHHmmss.parseDateTime(clsCDL.getCreateRq()).toDate());
+            e.setNbbm(nbbm);
+            e.setJdl(Double.parseDouble(clsCDL.getCdl()));
+        }catch (Exception e){
+            logger.error("异常数据；" + JSON.toJSONString(clsCDL));
+        }
+        return null;
+    }
+
+    /**
+     * 公司编码
+     */
+    private String gsBm;
+
+    /**
+     * 公司名称
+     */
+    private String gsName;
+
+    /**
+     * 分公司编码
+     */
+    private String fgsBm;
+
+    /**
+     * 分公司名称
+     */
+    private String fgsName;
+
+    /**
+     * 车辆内部编码
+     */
+    private String nbbm;
+
+    /**
+     * 加电站
+     */
+    private String jdz;
+
+    /**
+     * 加电量
+     */
+    private Double jdl;
+
+    /**
+     * 时间
+     */
+    private Date rq;
+
+    /**
+     * 入库时间
+     */
+    private Date createDate;
+
+    private String remarks = "接入数据";
+
+    public String getGsBm() {
+        return gsBm;
+    }
+
+    public void setGsBm(String gsBm) {
+        this.gsBm = gsBm;
+    }
+
+    public String getGsName() {
+        return gsName;
+    }
+
+    public void setGsName(String gsName) {
+        this.gsName = gsName;
+    }
+
+    public String getFgsBm() {
+        return fgsBm;
+    }
+
+    public void setFgsBm(String fgsBm) {
+        this.fgsBm = fgsBm;
+    }
+
+    public String getFgsName() {
+        return fgsName;
+    }
+
+    public void setFgsName(String fgsName) {
+        this.fgsName = fgsName;
+    }
+
+    public String getNbbm() {
+        return nbbm;
+    }
+
+    public void setNbbm(String nbbm) {
+        this.nbbm = nbbm;
+    }
+
+    public String getJdz() {
+        return jdz;
+    }
+
+    public void setJdz(String jdz) {
+        this.jdz = jdz;
+    }
+
+    public Date getRq() {
+        return rq;
+    }
+
+    public void setRq(Date rq) {
+        this.rq = rq;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public String getRemarks() {
+        return remarks;
+    }
+
+    public void setRemarks(String remarks) {
+        this.remarks = remarks;
+    }
+
+    public Double getJdl() {
+        return jdl;
+    }
+
+    public void setJdl(Double jdl) {
+        this.jdl = jdl;
+    }
+}
@@ -8,6 +8,7 @@ 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.stereotype.Component;
  
 import javax.jws.WebMethod;
 import javax.jws.WebService;
@@ -19,7 +20,7 @@ import java.util.List;
  * BS调度系统webservice接口实现，完美兼容老系统接口格式
  * Created by panzhao on 2017/3/10.
  */
-
+@Component
 @WebService(
         name = "CompanyServiceSoap",
         portName = "CompanyServiceSoap",
@@ -14,5 +14,5 @@ multipart.maxRequestSize = -1
 server.compression.enabled=true
 server.compression.mime-types=application/json,application/xml,text/html,text/xml,text/plain,text/javascript,text/css,application/javascript
  
-#redis »º´æ¶àÉÙÌìµÄÊý¾Ý
+#redis
 cache.days=32