e想行空

import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlRootElement;
import lombok.Data;

@JacksonXmlRootElement(localName = "service")
@Data
public class XmlTestBean {
    @JacksonXmlProperty(isAttribute = true)
    private String version = "2.0";
    @JacksonXmlProperty(localName = "BODY")
    private Body body;
    @Data
    public class Body {
        @JacksonXmlProperty(localName = "TX_CODE")
        private Element txCode;
        @JacksonXmlProperty(localName = "Name")
        private Element name;
    }
    @JacksonXmlProperty(localName = "SYS_HEAD")
    private SysHead sysHead;
    @Data
    public class SysHead {
        @JacksonXmlProperty(localName = "TRAN_TIMESTAMP")
        private Element tranTimestamp;
    }
}

@RestController
@RequestMapping("/xml")
public class XmlController {
    private Logger logger=Logger.getLogger(String.valueOf(getClass()));

    /***
     * consumes为请求参数的格式 Content-Type设置为application/xml
     * produces为返回内容的格式 Content-Type设置为application/xml
     * @param xmlTestBean
     * @return
     */
    @RequestMapping(value = "/test",consumes = MediaType.APPLICATION_XML_VALUE,produces = MediaType.TEXT_XML_VALUE)
    @ResponseBody
    public XmlTestBean test(@RequestBody XmlTestBean xmlTestBean){
        logger.info("receive data: "+xmlTestBean.toString());
        xmlTestBean.setVersion(xmlTestBean.getVersion()+"0");
        XmlTestBean.Body body= xmlTestBean.getBody();
        Element name =body.getName();
        name.setAttr(name.getAttr()+"1");
        name.setValue(name.getValue()+"2");
        body.setName(name);
        body.setTxCode(new Element(body.getTxCode().getAttr()+"3",body.getTxCode().getValue()+"4"));
        xmlTestBean.setBody(body);
        return xmlTestBean;
    }
}

@Configuration
public class Config {
    /**
     * jackson 转xml 全局配置
     *
     * @param builder
     * @return
     */
    @Bean
    public MappingJackson2XmlHttpMessageConverter mappingJackson2XmlHttpMessageConverter(
            Jackson2ObjectMapperBuilder builder) {
        ObjectMapper mapper = builder.createXmlMapper(true).build();
//        设置全局返回显示 <?xml version='1.0' encoding='UTF-8'?>
        ((XmlMapper) mapper).enable(ToXmlGenerator.Feature.WRITE_XML_DECLARATION);
        //<?xml version='1.0' encoding='UTF-8'?> 改为双引号 <?xml version="1.0" encoding="UTF-8"?>
        String propName = com.ctc.wstx.api.WstxOutputProperties.P_USE_DOUBLE_QUOTES_IN_XML_DECL;
        ((XmlMapper) mapper).getFactory()
                .getXMLOutputFactory()
                .setProperty(propName, true);
        return new MappingJackson2XmlHttpMessageConverter(mapper);
    }
}

Query query = new Query(Criteria.where("devices_statuses.device_id").is(termId).and("devices_statuses.status").in("0");
Update update = new Update();
//更新删除，删除devices_statuses数组对象中termId=？的，pull为从数组移出
//update.pull("devices_statuses", Query.query(Criteria.where("term_id").is(termId)));
//更新状态为1                        
update.set("devices_statuses.$.sync_status", "1");
mongoTemplate.updateMulti(query, update, CustomerInfoDevice.class);

Query query = new Query(Criteria.where("devices_statuses").elemMatch(
                   Criteria.where("term_id").is(termId)
                           .and("sync_status").is(Constants.OFFLINE_SYNC_DEVICE_PROGRESSFAIL)
                           .and("err_msg").ne(Constants.OFFLINE_SYNC_ERRORREASON_FAIL_FEATURE)
           ));

Aggregation aggregation = Aggregation.newAggregation(
                    Aggregation.facet()
                            .and(
                                    Aggregation.project("_id").and("time").substring(0, 10).as("day")
                                    , Aggregation.match(Criteria.where("day").is(nowDate))
                                    , Aggregation.count().as("count")
                            ).as("day")
                            .and(
                                    Aggregation.count().as("total")
                            ).as("total")
                            .and(
                                    Aggregation.lookup("b_user", "Id", "company_id", "user")
                                    , Aggregation.unwind("$user")
                                    , Aggregation.project("_id").and("user.user_login_time").substring(0, 10).as("day")
                                    , Aggregation.match(Criteria.where("day").is(nowDate))
                                    , Aggregation.group("_id")
                                    , Aggregation.count().as("total")
                            ).as("login")
            );

ConditionalOperators.Cond condOperatorsFeature=ConditionalOperators.when(
              criteria.where("devices_statuses.err_msg").is(Constants.OFFLINE_SYNC_ERRORREASON_FAIL_FEATURE))
              .then(1)
              .otherwise(0);
      ConditionalOperators.Cond condOperatorsFail=ConditionalOperators.when(
              criteria.where("devices_statuses.sync_status").is(Constants.OFFLINE_SYNC_DEVICE_PROGRESSFAIL))
              .then(1)
              .otherwise(0);


      ConditionalOperators.Cond condOperatorsFeatureTotal=ConditionalOperators.when(
              criteria.where("feature_fail").gt(0))
              .then(1)
              .otherwise(0);
      ConditionalOperators.Cond condOperatorsFailTotal=ConditionalOperators.when(
              criteria.where("total_fail").gt(0))
              .then(1)
              .otherwise(0);

      Aggregation aggregation = Aggregation.newAggregation(
              Aggregation.unwind("$devices_statuses")
              ,LookupOperation.newLookup().from("b_terminfo")
                      .localField("devices_statuses.term_id")
                      .foreignField("term_id").as("term_info")
              ,Aggregation.unwind("$term_info")
              ,Aggregation.match(criteria)
              ,Aggregation.project("customer_id","class_name")
                      .and(condOperatorsFeature).as("feature_fail")
                      .and(condOperatorsFail).as("total_fail")
              ,Aggregation.group("customer_id","class_name")
                      .sum("total_fail").as("total_fail")
                      .sum("feature_fail").as("feature_fail")
              ,Aggregation.project()
                      .and(condOperatorsFeatureTotal).as("feature_fail")
                      .and(condOperatorsFailTotal).as("total_fail")
              ,Aggregation.group()
                      .count().as("total_customer")
                      .sum("total_fail").as("total_fail")
                      .sum("feature_fail").as("feature_fail")
      );
      AggregationResults<BasicDBObject> dBObjects=mongoTemplate.aggregate(aggregation,"b_customer_info_device",BasicDBObject.class);

      JSONArray countResult = JSON.parseObject(dBObjects.getRawResults().toJson()).getJSONArray("result");
      if(countResult!=null&&countResult.size()>0){
          JSONObject jobj = (JSONObject)countResult.get(0);
         return jobj;
      }

String startTime = startDay + " 00:00:00";

           ConditionalOperators.Cond condCompany= addCompanyIdCriteriaInCond("record.company_id");

           //判断是否是当天
           ConditionalOperators.Cond condDay = ConditionalOperators.when(Criteria.where("record.trans_time").gte(startTime)
           ).then(condCompany!=null?condCompany:1).otherwise(0);

           //添加字表的判断是否是应答事件
           ConditionalOperators.Cond condOpposite = ConditionalOperators.when(Criteria.where("record.is_opposite").is(false)
           ).then(condDay).otherwise(0);

           //gt(0)是为了判断对象(是否有记录)是否为null，如果有对象就会大于0
           ConditionalOperators.Cond condOperators = ConditionalOperators.when(Criteria.where("record").gt(0)
           ).then(condOpposite).otherwise(0);

           Aggregation aggregation = Aggregation.newAggregation(
                   Aggregation.match(Criteria.where("event_type").is("device"))
                   , Aggregation.lookup("r_event_record", "event_id", "event_id", "record")
                   , Aggregation.unwind("$record", true)
                   , Aggregation.project("event_id", "event_name","event_sub_type").and(condOperators).as("num")
                   , Aggregation.group("event_id", "event_name","event_sub_type").sum("num").as("total")
                   , Aggregation.group("_id.event_sub_type").push("$$ROOT").as("sub").sum("$$ROOT.total").as("total")
           );

           AggregationResults<BasicDBObject> dBObjects = mongoTemplate.aggregate(aggregation, "b_event_info", BasicDBObject.class);

@Component
public class TestSchedule {
    @ScheduleAnnotaion(serviceId = "DataSync", scheduleDesc = "数据同步", checkIntervalTime = 30, isSignalExecuteFlag = true, addHisTaskTableFlag = false)
    @Scheduled(cron = "0 * * * * ?") // 每1分钟执行一次

    public void executeSchedule() throws ResponseException {
        executeScheduleNow();
    }

    public void executeScheduleNow() {
        //todo 需要添加的操作
    }
}